Searched refs:BufferHubRPC (Results 1 – 12 of 12) sorted by relevance
62 case BufferHubRPC::CreateConsumerQueue::Opcode: in HandleMessage()63 DispatchRemoteMethod<BufferHubRPC::CreateConsumerQueue>( in HandleMessage()67 case BufferHubRPC::GetQueueInfo::Opcode: in HandleMessage()68 DispatchRemoteMethod<BufferHubRPC::GetQueueInfo>( in HandleMessage()72 case BufferHubRPC::ProducerQueueAllocateBuffers::Opcode: in HandleMessage()73 DispatchRemoteMethod<BufferHubRPC::ProducerQueueAllocateBuffers>( in HandleMessage()78 case BufferHubRPC::ProducerQueueInsertBuffer::Opcode: in HandleMessage()79 DispatchRemoteMethod<BufferHubRPC::ProducerQueueInsertBuffer>( in HandleMessage()83 case BufferHubRPC::ProducerQueueRemoveBuffer::Opcode: in HandleMessage()84 DispatchRemoteMethod<BufferHubRPC::ProducerQueueRemoveBuffer>( in HandleMessage()[all …]
57 case BufferHubRPC::ConsumerAcquire::Opcode: in HandleImpulse()60 case BufferHubRPC::ConsumerRelease::Opcode: in HandleImpulse()73 case BufferHubRPC::GetBuffer::Opcode: in HandleMessage()74 DispatchRemoteMethod<BufferHubRPC::GetBuffer>( in HandleMessage()78 case BufferHubRPC::NewConsumer::Opcode: in HandleMessage()79 DispatchRemoteMethod<BufferHubRPC::NewConsumer>( in HandleMessage()83 case BufferHubRPC::ConsumerAcquire::Opcode: in HandleMessage()84 DispatchRemoteMethod<BufferHubRPC::ConsumerAcquire>( in HandleMessage()88 case BufferHubRPC::ConsumerRelease::Opcode: in HandleMessage()89 DispatchRemoteMethod<BufferHubRPC::ConsumerRelease>( in HandleMessage()
42 case BufferHubRPC::CreateConsumerQueue::Opcode: in HandleMessage()43 DispatchRemoteMethod<BufferHubRPC::CreateConsumerQueue>( in HandleMessage()47 case BufferHubRPC::GetQueueInfo::Opcode: in HandleMessage()48 DispatchRemoteMethod<BufferHubRPC::GetQueueInfo>( in HandleMessage()52 case BufferHubRPC::ConsumerQueueImportBuffers::Opcode: in HandleMessage()53 DispatchRemoteMethod<BufferHubRPC::ConsumerQueueImportBuffers>( in HandleMessage()
191 case BufferHubRPC::ProducerGain::Opcode: in HandleImpulse()194 case BufferHubRPC::ProducerPost::Opcode: in HandleImpulse()203 case BufferHubRPC::GetBuffer::Opcode: in HandleMessage()204 DispatchRemoteMethod<BufferHubRPC::GetBuffer>( in HandleMessage()208 case BufferHubRPC::NewConsumer::Opcode: in HandleMessage()209 DispatchRemoteMethod<BufferHubRPC::NewConsumer>( in HandleMessage()213 case BufferHubRPC::ProducerPost::Opcode: in HandleMessage()214 DispatchRemoteMethod<BufferHubRPC::ProducerPost>( in HandleMessage()218 case BufferHubRPC::ProducerGain::Opcode: in HandleMessage()219 DispatchRemoteMethod<BufferHubRPC::ProducerGain>( in HandleMessage()
30 : BASE("BufferHub", Endpoint::Create(BufferHubRPC::kClientPath)) {} in BufferHubService()239 case BufferHubRPC::CreateBuffer::Opcode: in HandleMessage()240 DispatchRemoteMethod<BufferHubRPC::CreateBuffer>( in HandleMessage()244 case BufferHubRPC::CreateProducerQueue::Opcode: in HandleMessage()245 DispatchRemoteMethod<BufferHubRPC::CreateProducerQueue>( in HandleMessage()
12 : BASE(BufferHubRPC::kClientPath) { in ProducerBuffer()19 auto status = InvokeRemoteMethod<BufferHubRPC::CreateBuffer>( in ProducerBuffer()39 : BASE(BufferHubRPC::kClientPath) { in ProducerBuffer()48 auto status = InvokeRemoteMethod<BufferHubRPC::CreateBuffer>( in ProducerBuffer()145 return ReturnStatusOrError(InvokeRemoteMethod<BufferHubRPC::ProducerPost>( in Post()156 return ReturnStatusOrError(SendImpulse(BufferHubRPC::ProducerPost::Opcode)); in PostAsync()251 auto status = InvokeRemoteMethod<BufferHubRPC::ProducerGain>(); in Gain()265 return ReturnStatusOrError(SendImpulse(BufferHubRPC::ProducerGain::Opcode)); in GainAsync()
119 auto status = InvokeRemoteMethod<BufferHubRPC::ConsumerAcquire>(); in Acquire()132 auto status = SendImpulse(BufferHubRPC::ConsumerAcquire::Opcode); in AcquireAsync()190 return ReturnStatusOrError(InvokeRemoteMethod<BufferHubRPC::ConsumerRelease>( in Release()207 SendImpulse(BufferHubRPC::ConsumerRelease::Opcode)); in ReleaseAsync()
6 constexpr char BufferHubRPC::kClientPath[];
38 InvokeRemoteMethod<BufferHubRPC::NewConsumer>(); in CreateConsumer()49 InvokeRemoteMethod<BufferHubRPC::GetBuffer>(); in ImportBuffer()
78 auto status = InvokeRemoteMethod<BufferHubRPC::GetQueueInfo>(); in ImportQueue()114 auto status = InvokeRemoteMethod<BufferHubRPC::CreateConsumerQueue>(silent); in CreateConsumerQueueHandle()430 : BASE(BufferHubRPC::kClientPath) { in ProducerQueue()432 InvokeRemoteMethod<BufferHubRPC::CreateProducerQueue>(config, usage); in ProducerQueue()459 InvokeRemoteMethod<BufferHubRPC::ProducerQueueAllocateBuffers>( in AllocateBuffers()544 InvokeRemoteMethod<BufferHubRPC::ProducerQueueInsertBuffer>( in InsertBuffer()569 InvokeRemoteMethod<BufferHubRPC::ProducerQueueRemoveBuffer>(slot); in RemoveBuffer()700 auto status = InvokeRemoteMethod<BufferHubRPC::ConsumerQueueImportBuffers>(); in ImportBuffers()
85 std::weak_ptr<ProducerChannel> buffers_[BufferHubRPC::kMaxQueueCapacity];
293 struct BufferHubRPC { struct