HomeSort by relevance Sort by last modified time
    Searched refs:CompletionQueue (Results 26 - 50 of 74) sorted by null

12 3

  /external/grpc-grpc/include/grpcpp/impl/codegen/
client_callback.h 35 class CompletionQueue;
58 CompletionQueue* cq = channel->CallbackCQ();
client_unary_call.h 32 class CompletionQueue;
52 CompletionQueue cq(grpc_completion_queue_attributes{
server_context.h 73 class CompletionQueue;
294 CompletionQueue* cq_;
async_unary_call.h 32 class CompletionQueue;
84 ChannelInterface* channel, CompletionQueue* cq,
call.h 46 class CompletionQueue;
671 Call(grpc_call* call, CallHook* call_hook, CompletionQueue* cq)
677 Call(grpc_call* call, CallHook* call_hook, CompletionQueue* cq,
689 CompletionQueue* cq() const { return cq_; }
695 CompletionQueue* cq_;
  /external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/
server.pyx.pxi 44 self, CompletionQueue call_queue not None,
45 CompletionQueue server_queue not None, tag):
61 self, CompletionQueue queue not None):
72 self.backup_shutdown_queue = CompletionQueue(shutdown_cq=True)
97 cdef _c_shutdown(self, CompletionQueue queue, tag):
106 def shutdown(self, CompletionQueue queue not None, tag):
completion_queue.pxd.pxi 22 cdef class CompletionQueue:
tag.pxd.pxi 54 # This allows CompletionQueue to notify the Python Server object that the
  /external/grpc-grpc/test/cpp/microbenchmarks/
bm_cq.cc 40 CompletionQueue cq;
52 CompletionQueue cq(core_cq);
80 CompletionQueue cq;
  /external/tensorflow/tensorflow/core/distributed_runtime/rpc/
grpc_state.h 42 RPCState(::grpc::GenericStub* stub, ::grpc::CompletionQueue* cq,
51 RPCState(::grpc::GenericStub* stub, ::grpc::CompletionQueue* cq,
165 ::grpc::CompletionQueue* cq_;
grpc_rpc_factory.h 67 ::grpc::CompletionQueue completion_queue_;
grpc_worker_cache.cc 103 // CompletionQueue.
124 ::grpc::CompletionQueue* completion_queue() { return &completion_queue_; }
127 ::grpc::CompletionQueue completion_queue_;
  /external/flatbuffers/tests/
monster_test.grpc.fb.cc 42 ::grpc::ClientAsyncResponseReader< flatbuffers::grpc::Message<Stat>>* MonsterStorage::Stub::AsyncStoreRaw(::grpc::ClientContext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) {
46 ::grpc::ClientAsyncResponseReader< flatbuffers::grpc::Message<Stat>>* MonsterStorage::Stub::PrepareAsyncStoreRaw(::grpc::ClientContext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) {
54 ::grpc::ClientAsyncReader< flatbuffers::grpc::Message<Monster>>* MonsterStorage::Stub::AsyncRetrieveRaw(::grpc::ClientContext* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq, void* tag) {
58 ::grpc::ClientAsyncReader< flatbuffers::grpc::Message<Monster>>* MonsterStorage::Stub::PrepareAsyncRetrieveRaw(::grpc::ClientContext* context, const flatbuffers::grpc::Message<Stat>& request, ::grpc::CompletionQueue* cq) {
66 ::grpc::ClientAsyncWriter< flatbuffers::grpc::Message<Monster>>* MonsterStorage::Stub::AsyncGetMaxHitPointRaw(::grpc::ClientContext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq, void* tag) {
70 ::grpc::ClientAsyncWriter< flatbuffers::grpc::Message<Monster>>* MonsterStorage::Stub::PrepareAsyncGetMaxHitPointRaw(::grpc::ClientContext* context, flatbuffers::grpc::Message<Stat>* response, ::grpc::CompletionQueue* cq) {
78 ::grpc::ClientAsyncReaderWriter< flatbuffers::grpc::Message<Monster>, flatbuffers::grpc::Message<Stat>>* MonsterStorage::Stub::AsyncGetMinMaxHitPointsRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) {
82 ::grpc::ClientAsyncReaderWriter< flatbuffers::grpc::Message<Monster>, flatbuffers::grpc::Message<Stat>>* MonsterStorage::Stub::PrepareAsyncGetMinMaxHitPointsRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) {
  /external/grpc-grpc/src/cpp/common/
alarm.cc 54 void Set(CompletionQueue* cq, gpr_timespec deadline, void* tag) {
123 void Alarm::SetInternal(CompletionQueue* cq, gpr_timespec deadline, void* tag) {
  /external/grpc-grpc/src/python/grpcio_tests/tests/unit/_cython/
_common.py 98 self.server_completion_queue = cygrpc.CompletionQueue()
116 self.client_completion_queue = cygrpc.CompletionQueue()
cygrpc_test.py 41 completion_queue = cygrpc.CompletionQueue()
68 completion_queue = cygrpc.CompletionQueue()
76 completion_queue = cygrpc.CompletionQueue()
99 self.server_completion_queue = cygrpc.CompletionQueue()
113 self.client_completion_queue = cygrpc.CompletionQueue()
_cancel_many_calls_test.py 96 call_completion_queue = cygrpc.CompletionQueue()
146 server_completion_queue = cygrpc.CompletionQueue()
_read_some_but_not_all_responses_test.py 114 server_completion_queue = cygrpc.CompletionQueue()
144 server_call_completion_queue = cygrpc.CompletionQueue()
  /external/grpc-grpc/test/cpp/util/
cli_call.h 90 grpc::CompletionQueue cq_;
  /external/tensorflow/tensorflow/contrib/verbs/
grpc_verbs_service_impl.h 69 ::grpc::CompletionQueue* new_call_cq,
  /external/grpc-grpc/test/cpp/end2end/
nonblocking_test.cc 79 if (r == CompletionQueue::SHUTDOWN) {
81 } else if (r == CompletionQueue::GOT_EVENT) {
  /external/grpc-grpc/src/cpp/server/
server_cc.cc 253 CompletionQueue cq_;
280 SyncRequestThreadManager(Server* server, CompletionQueue* server_cq,
299 case CompletionQueue::TIMEOUT:
301 case CompletionQueue::SHUTDOWN:
303 case CompletionQueue::GOT_EVENT:
379 CompletionQueue* server_cq_;
606 CompletionQueue shutdown_cq;
614 CompletionQueue::NextStatus status =
619 if (status == CompletionQueue::NextStatus::TIMEOUT) {
672 internal::ServerAsyncStreamingInterface* stream, CompletionQueue* call_cq
    [all...]
  /external/tensorflow/tensorflow/contrib/bigtable/kernels/test_kernels/
bigtable_test_client.cc 343 grpc::CompletionQueue* cq) {
385 grpc::CompletionQueue* cq) {
396 ::grpc::CompletionQueue* cq, void* tag) {
407 ::grpc::CompletionQueue* cq, void* tag) {
418 grpc::CompletionQueue* cq) {
429 grpc::CompletionQueue* cq, void* tag) {
  /external/grpc-grpc/examples/cpp/helloworld/cocoapods/HelloWorldCpp/
ViewController.mm 35 grpc::CompletionQueue cq_;
  /external/grpc-grpc/test/cpp/qps/
server_async.cc 56 CompletionQueue*, ServerCompletionQueue*, void*)>
60 CompletionQueue*, ServerCompletionQueue*, void*)>
64 CompletionQueue*, ServerCompletionQueue*, void*)>
67 ServerAsyncWriter<ResponseType>*, CompletionQueue*,
72 CompletionQueue*, ServerCompletionQueue*, void*)>

Completed in 923 milliseconds

12 3