Lines Matching refs:connectionId
80 mSender = message.connectionId; in TransactionStatus()
85 mReceiver = message.connectionId; in TransactionStatus()
169 ResultStatus Accessor::Impl::close(ConnectionId connectionId) { in close() argument
172 mBufferPool.handleClose(connectionId); in close()
173 mBufferPool.mObserver.close(connectionId); in close()
181 ConnectionId connectionId, const std::vector<uint8_t>& params, in allocate() argument
200 mBufferPool.handleOwnBuffer(connectionId, *bufferId); in allocate()
207 ConnectionId connectionId, TransactionId transactionId, in fetch() argument
214 connectionId, transactionId)) { in fetch()
265 ConnectionId connectionId, BufferId bufferId) { in handleOwnBuffer() argument
267 bool added = insert(&mUsingBuffers, connectionId, bufferId); in handleOwnBuffer()
272 insert(&mUsingConnections, bufferId, connectionId); in handleOwnBuffer()
277 ConnectionId connectionId, BufferId bufferId) { in handleReleaseBuffer() argument
278 bool deleted = erase(&mUsingBuffers, connectionId, bufferId); in handleReleaseBuffer()
288 erase(&mUsingConnections, bufferId, connectionId); in handleReleaseBuffer()
304 !contains(&mUsingBuffers, message.connectionId, message.bufferId)) { in handleTransferTo()
310 found->second->mSender = message.connectionId; in handleTransferTo()
338 insert(&mPendingTransactions, message.connectionId, in handleTransferFrom()
343 if (message.connectionId == found->second->mReceiver) { in handleTransferFrom()
353 bool deleted = erase(&mPendingTransactions, message.connectionId, in handleTransferResult()
361 handleOwnBuffer(message.connectionId, message.bufferId); in handleTransferResult()
389 message.connectionId, message.bufferId); in processStatusMessages()
416 message.newStatus, (long long)message.connectionId); in processStatusMessages()
422 bool Accessor::Impl::BufferPool::handleClose(ConnectionId connectionId) { in handleClose() argument
424 auto buffers = mUsingBuffers.find(connectionId); in handleClose()
427 bool deleted = erase(&mUsingConnections, bufferId, connectionId); in handleClose()
443 auto pending = mPendingTransactions.find(connectionId); in handleClose()
464 mConnectionIds.erase(connectionId); in handleClose()