Home
last modified time | relevance | path

Searched refs:ConnectionId (Results 1 – 19 of 19) sorted by relevance

/hardware/interfaces/media/bufferpool/aidl/default/include/bufferpool2/
DClientManager.h58 ConnectionId *pConnectionId);
75 ConnectionId senderId,
76 ConnectionId *receiverId,
88 BufferPoolStatus close(ConnectionId connectionId);
100 BufferPoolStatus flush(ConnectionId connectionId);
118 BufferPoolStatus allocate(ConnectionId connectionId,
141 BufferPoolStatus receive(ConnectionId connectionId,
162 BufferPoolStatus postSend(ConnectionId receiverId,
DBufferPoolTypes.h53 typedef int64_t ConnectionId; typedef
63 enum : ConnectionId {
/hardware/interfaces/media/bufferpool/aidl/default/
DBufferPool.h55 std::map<ConnectionId, std::set<BufferId>> mUsingBuffers;
56 std::map<BufferId, std::set<ConnectionId>> mUsingConnections;
58 std::map<ConnectionId, std::set<TransactionId>> mPendingTransactions;
69 std::set<ConnectionId> mConnectionIds;
95 std::map<ConnectionId, uint32_t> mAcks;
96 std::map<ConnectionId, const std::shared_ptr<IObserver>> mObservers;
102 void onConnect(ConnectionId conId, const std::shared_ptr<IObserver> &observer);
104 void onClose(ConnectionId conId);
106 void onAck(ConnectionId conId, uint32_t msgId);
118 std::map<ConnectionId, const std::shared_ptr<IObserver>> *observers,
[all …]
DBufferStatus.h38 std::map<ConnectionId, std::unique_ptr<BufferStatusQueue>>
52 BufferPoolStatus open(ConnectionId id, StatusDescriptor* _Nonnull fmqDescPtr);
62 BufferPoolStatus close(ConnectionId id);
103 ConnectionId connectionId,
126 ConnectionId connectionId,
127 ConnectionId targetId,
141 ConnectionId connectionId,
DClientManager.cpp54 ConnectionId senderId,
55 ConnectionId *receiverId,
59 ConnectionId *pConnectionId);
61 BufferPoolStatus close(ConnectionId connectionId);
63 BufferPoolStatus flush(ConnectionId connectionId);
65 BufferPoolStatus allocate(ConnectionId connectionId,
70 BufferPoolStatus receive(ConnectionId connectionId,
77 BufferPoolStatus postSend(ConnectionId receiverId,
82 BufferPoolStatus getAccessor(ConnectionId connectionId,
108 std::map<ConnectionId, const std::shared_ptr<BufferPoolClient>>
[all …]
DObserver.h34 void addClient(ConnectionId connectionId,
37 void delClient(ConnectionId connectionId);
45 std::map<ConnectionId, const std::weak_ptr<BufferPoolClient>> mClients;
DAccessor.h105 ConnectionId connectionId,
123 ConnectionId connectionId,
151 std::shared_ptr<Connection> *connection, ConnectionId *pConnectionId,
164 BufferPoolStatus close(ConnectionId connectionId);
198 ConnectionId getConnectionId();
DBufferStatus.cpp54 ConnectionId id, StatusDescriptor* fmqDescPtr) { in open()
72 BufferPoolStatus BufferStatusObserver::close(ConnectionId id) { in close()
123 ConnectionId connectionId, in postBufferRelease()
148 ConnectionId connectionId, in postBufferInvalidateAck()
172 BufferStatus status, ConnectionId connectionId, ConnectionId targetId, in postBufferStatusMessage()
DConnection.h78 void initialize(const std::shared_ptr<Accessor> &accessor, ConnectionId connectionId);
87 ConnectionId mConnectionId;
DObserver.cpp43 void Observer::addClient(ConnectionId connectionId, in addClient()
57 void Observer::delClient(ConnectionId connectionId) { in delClient()
DBufferPoolClient.h64 ConnectionId getConnectionId();
82 BufferPoolStatus postSend(ConnectionId receiver,
DAccessor.cpp52 ConnectionId Accessor::ConnectionIdGenerator::getConnectionId() { in getConnectionId()
168 ConnectionId connectionId; in connect()
203 ConnectionId connectionId, in allocate()
231 ConnectionId connectionId, TransactionId transactionId, in fetch()
258 std::shared_ptr<Connection> *connection, ConnectionId *pConnectionId, in connect()
269 ConnectionId id = sConIdGenerator->getConnectionId(); in connect()
293 BufferPoolStatus Accessor::close(ConnectionId connectionId) { in close()
318 std::map<ConnectionId, const std::shared_ptr<IObserver>> observers; in handleInvalidateAck()
363 std::list<ConnectionId> erased; in invalidatorThread()
DBufferPool.cpp75 ConnectionId conId, const std::shared_ptr<IObserver>& observer) { in onConnect()
80 void BufferPool::Invalidation::onClose(ConnectionId conId) { in onClose()
86 ConnectionId conId, in onAck()
146 std::map<ConnectionId, const std::shared_ptr<IObserver>> *observers, in onHandleAck() argument
180 ConnectionId connectionId, BufferId bufferId) { in handleOwnBuffer()
192 ConnectionId connectionId, BufferId bufferId) { in handleReleaseBuffer()
355 bool BufferPool::handleClose(ConnectionId connectionId) { in handleClose()
DDataHelper.h101 ConnectionId mSender;
102 ConnectionId mReceiver;
DBufferPoolClient.cpp57 ConnectionId getConnectionId() { in getConnectionId()
83 BufferId bufferId, ConnectionId receiver,
121 ConnectionId mConnectionId;
190 ConnectionId mConnectionId;
201 ConnectionId connectionId, BufferId id, native_handle_t *handle) in ClientBuffer()
502 BufferId bufferId, ConnectionId receiver, in postSend()
803 ConnectionId BufferPoolClient::getConnectionId() { in getConnectionId()
852 ConnectionId receiverId, in postSend()
DConnection.cpp84 const std::shared_ptr<Accessor>& accessor, ConnectionId connectionId) { in initialize()
/hardware/interfaces/media/bufferpool/aidl/default/tests/
Dmulti.cpp42 using aidl::android::hardware::media::bufferpool2::implementation::ConnectionId;
64 ConnectionId connectionId;
122 ConnectionId mConnectionId;
200 ConnectionId receiverId; in TEST_F()
Dsingle.cpp33 using aidl::android::hardware::media::bufferpool2::implementation::ConnectionId;
83 ConnectionId mConnectionId;
84 ConnectionId mReceiverId;
Dcond.cpp43 using aidl::android::hardware::media::bufferpool2::implementation::ConnectionId;
65 ConnectionId connectionId;
126 ConnectionId mConnectionId;
222 ConnectionId receiverId; in TEST_F()