OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
refs:CompletionQueue
(Results
26 - 50
of
74
) sorted by null
1
2
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
1
2
3