Lines Matching refs:message
82 BufferStatusMessage message; in getBufferStatusChanges() local
85 if (!it->second->read(&message, 1)) { in getBufferStatusChanges()
92 message.connectionId = it->first; in getBufferStatusChanges()
93 messages.push_back(message); in getBufferStatusChanges()
128 BufferStatusMessage message; in postBufferRelease() local
131 message.status = BufferStatus::NOT_USED; in postBufferRelease()
132 message.bufferId = id; in postBufferRelease()
133 message.connectionId = connectionId; in postBufferRelease()
134 if (!mBufferStatusQueue->write(&message, 1)) { in postBufferRelease()
154 BufferStatusMessage message; in postBufferInvalidateAck() local
155 message.status = BufferStatus::INVALIDATION_ACK; in postBufferInvalidateAck()
156 message.bufferId = invalidateId; in postBufferInvalidateAck()
157 message.connectionId = connectionId; in postBufferInvalidateAck()
158 if (!mBufferStatusQueue->write(&message, 1)) { in postBufferInvalidateAck()
178 BufferStatusMessage release, message; in postBufferStatusMessage() local
194 message.transactionId = transactionId; in postBufferStatusMessage()
195 message.bufferId = bufferId; in postBufferStatusMessage()
196 message.status = status; in postBufferStatusMessage()
197 message.connectionId = connectionId; in postBufferStatusMessage()
198 message.targetConnectionId = targetId; in postBufferStatusMessage()
200 message.timestampUs = 0; in postBufferStatusMessage()
201 if (!mBufferStatusQueue->write(&message, 1)) { in postBufferStatusMessage()
280 BufferInvalidationMessage message; in postInvalidation() local
282 message.messageId = msgId; in postInvalidation()
283 message.fromBufferId = fromId; in postInvalidation()
284 message.toBufferId = toId; in postInvalidation()
286 mBufferInvalidationQueue->write(&message); in postInvalidation()