| /external/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/codegen/ |
| D | sync.h | 49 Mutex() { g_core_codegen_interface->gpr_mu_init(&mu_); } in Mutex()
50 ~Mutex() { g_core_codegen_interface->gpr_mu_destroy(&mu_); } in ~Mutex()
72 g_core_codegen_interface->gpr_mu_lock(mu_); in MutexLock()
75 g_core_codegen_interface->gpr_mu_lock(mu_); in MutexLock()
77 ~MutexLock() { g_core_codegen_interface->gpr_mu_unlock(mu_); } in ~MutexLock()
89 g_core_codegen_interface->gpr_mu_lock(mu_); in ReleasableMutexLock()
92 g_core_codegen_interface->gpr_mu_lock(mu_); in ReleasableMutexLock()
95 if (!released_) g_core_codegen_interface->gpr_mu_unlock(mu_); in ~ReleasableMutexLock()
103 g_core_codegen_interface->gpr_mu_lock(mu_); in Lock()
110 g_core_codegen_interface->gpr_mu_unlock(mu_); in Unlock()
[all …]
|
| D | slice.h | 38 Slice() : slice_(g_core_codegen_interface->grpc_empty_slice()) {} in Slice()
40 ~Slice() { g_core_codegen_interface->grpc_slice_unref(slice_); } in ~Slice()
45 : slice_(g_core_codegen_interface->grpc_slice_ref(slice)) {} in Slice()
53 : slice_(g_core_codegen_interface->grpc_slice_malloc(len)) {} in Slice()
57 : slice_(g_core_codegen_interface->grpc_slice_from_copied_buffer( in Slice()
63 : slice_(g_core_codegen_interface->grpc_slice_from_copied_buffer( in Slice()
70 : slice_(g_core_codegen_interface->grpc_slice_from_static_buffer( in Slice()
75 : slice_(g_core_codegen_interface->grpc_slice_ref(other.slice_)) {} in Slice()
89 : slice_(g_core_codegen_interface->grpc_slice_new_with_user_data( in Slice()
98 : slice_(g_core_codegen_interface->grpc_slice_new_with_len(buf, len, in Slice()
[all …]
|
| D | proto_buffer_writer.h | 37 extern CoreCodegenInterface* g_core_codegen_interface;
68 g_core_codegen_interface->grpc_raw_byte_buffer_create(nullptr, 0); in ProtoBufferWriter()
75 g_core_codegen_interface->grpc_slice_unref(backup_slice_); in ~ProtoBufferWriter()
102 slice_ = g_core_codegen_interface->grpc_slice_malloc( in Next()
111 g_core_codegen_interface->grpc_slice_buffer_add(slice_buffer_, slice_); in Next()
124 g_core_codegen_interface->grpc_slice_buffer_pop(slice_buffer_); in BackUp()
128 backup_slice_ = g_core_codegen_interface->grpc_slice_split_tail( in BackUp()
130 g_core_codegen_interface->grpc_slice_buffer_add(slice_buffer_, slice_); in BackUp()
|
| D | completion_queue.h | 96 extern CoreCodegenInterface* g_core_codegen_interface;
118 ::grpc::g_core_codegen_interface->grpc_completion_queue_destroy(cq_); in ~CompletionQueue()
179 ::grpc::g_core_codegen_interface->gpr_inf_future( in Next()
247 cq_ = ::grpc::g_core_codegen_interface->grpc_completion_queue_create( in CompletionQueue()
248 ::grpc::g_core_codegen_interface->grpc_completion_queue_factory_lookup( in CompletionQueue()
319 ::grpc::g_core_codegen_interface->gpr_inf_future(GPR_CLOCK_REALTIME); in Pluck()
321 auto ev = ::grpc::g_core_codegen_interface->grpc_completion_queue_pluck( in Pluck()
342 ::grpc::g_core_codegen_interface->gpr_time_0(GPR_CLOCK_REALTIME); in TryPluck()
343 auto ev = ::grpc::g_core_codegen_interface->grpc_completion_queue_pluck( in TryPluck()
359 auto ev = ::grpc::g_core_codegen_interface->grpc_completion_queue_pluck( in TryPluck()
[all …]
|
| D | byte_buffer.h | 88 buffer_ = g_core_codegen_interface->grpc_raw_byte_buffer_create( in ByteBuffer()
100 g_core_codegen_interface->grpc_byte_buffer_destroy(buffer_); in ~ByteBuffer()
113 buffer_ = g_core_codegen_interface->grpc_byte_buffer_copy(buf.buffer_);
124 g_core_codegen_interface->grpc_byte_buffer_destroy(buffer_); in Clear()
135 buffer_ = g_core_codegen_interface->grpc_byte_buffer_copy(buffer_); in Duplicate()
146 : g_core_codegen_interface->grpc_byte_buffer_length(buffer_); in Length()
226 return g_core_codegen_interface->ok(); in Serialize()
|
| D | proto_buffer_reader.h | 38 extern CoreCodegenInterface* g_core_codegen_interface;
55 !g_core_codegen_interface->grpc_byte_buffer_reader_init( in ProtoBufferReader()
64 g_core_codegen_interface->grpc_byte_buffer_reader_destroy(&reader_); in ~ProtoBufferReader()
84 if (!g_core_codegen_interface->grpc_byte_buffer_reader_peek(&reader_, in Next()
|
| D | proto_utils.h | 41 extern CoreCodegenInterface* g_core_codegen_interface;
61 return g_core_codegen_interface->ok(); in GenericSerialize()
65 ? g_core_codegen_interface->ok() in GenericSerialize()
80 Status result = g_core_codegen_interface->ok(); in GenericDeserialize()
|
| D | server_callback_handlers.h | 47 ::grpc::g_core_codegen_interface->grpc_call_ref(param.call->call()); in RunHandler()
52 auto* call = new (::grpc::g_core_codegen_interface->grpc_call_arena_alloc( in RunHandler()
70 reactor = new (::grpc::g_core_codegen_interface->grpc_call_arena_alloc( in RunHandler()
91 new (::grpc::g_core_codegen_interface->grpc_call_arena_alloc( in Deserialize()
214 ::grpc::g_core_codegen_interface->grpc_call_unref(call); in CallOnDone()
263 ::grpc::g_core_codegen_interface->grpc_call_ref(param.call->call()); in RunHandler()
265 auto* reader = new (::grpc::g_core_codegen_interface->grpc_call_arena_alloc( in RunHandler()
289 reactor = new (::grpc::g_core_codegen_interface->grpc_call_arena_alloc( in RunHandler()
406 ::grpc::g_core_codegen_interface->grpc_call_unref(call); in CallOnDone()
449 ::grpc::g_core_codegen_interface->grpc_call_ref(param.call->call()); in RunHandler()
[all …]
|
| D | callback_common.h | 87 g_core_codegen_interface->grpc_call_ref(call); in CallbackWithStatusTag()
130 g_core_codegen_interface->grpc_call_unref(call_); in Run()
168 g_core_codegen_interface->grpc_call_ref(call); in Set()
181 g_core_codegen_interface->grpc_call_unref(call); in Clear()
|
| /external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/ |
| D | sync.h | 49 Mutex() { g_core_codegen_interface->gpr_mu_init(&mu_); } in Mutex()
50 ~Mutex() { g_core_codegen_interface->gpr_mu_destroy(&mu_); } in ~Mutex()
72 g_core_codegen_interface->gpr_mu_lock(mu_); in MutexLock()
75 g_core_codegen_interface->gpr_mu_lock(mu_); in MutexLock()
77 ~MutexLock() { g_core_codegen_interface->gpr_mu_unlock(mu_); } in ~MutexLock()
89 g_core_codegen_interface->gpr_mu_lock(mu_); in ReleasableMutexLock()
92 g_core_codegen_interface->gpr_mu_lock(mu_); in ReleasableMutexLock()
95 if (!released_) g_core_codegen_interface->gpr_mu_unlock(mu_); in ~ReleasableMutexLock()
103 g_core_codegen_interface->gpr_mu_lock(mu_); in Lock()
110 g_core_codegen_interface->gpr_mu_unlock(mu_); in Unlock()
[all …]
|
| D | slice.h | 38 Slice() : slice_(g_core_codegen_interface->grpc_empty_slice()) {} in Slice()
40 ~Slice() { g_core_codegen_interface->grpc_slice_unref(slice_); } in ~Slice()
45 : slice_(g_core_codegen_interface->grpc_slice_ref(slice)) {} in Slice()
53 : slice_(g_core_codegen_interface->grpc_slice_malloc(len)) {} in Slice()
57 : slice_(g_core_codegen_interface->grpc_slice_from_copied_buffer( in Slice()
63 : slice_(g_core_codegen_interface->grpc_slice_from_copied_buffer( in Slice()
70 : slice_(g_core_codegen_interface->grpc_slice_from_static_buffer( in Slice()
75 : slice_(g_core_codegen_interface->grpc_slice_ref(other.slice_)) {} in Slice()
89 : slice_(g_core_codegen_interface->grpc_slice_new_with_user_data( in Slice()
98 : slice_(g_core_codegen_interface->grpc_slice_new_with_len(buf, len, in Slice()
[all …]
|
| D | proto_buffer_writer.h | 37 extern CoreCodegenInterface* g_core_codegen_interface;
68 g_core_codegen_interface->grpc_raw_byte_buffer_create(nullptr, 0); in ProtoBufferWriter()
75 g_core_codegen_interface->grpc_slice_unref(backup_slice_); in ~ProtoBufferWriter()
102 slice_ = g_core_codegen_interface->grpc_slice_malloc( in Next()
111 g_core_codegen_interface->grpc_slice_buffer_add(slice_buffer_, slice_); in Next()
124 g_core_codegen_interface->grpc_slice_buffer_pop(slice_buffer_); in BackUp()
128 backup_slice_ = g_core_codegen_interface->grpc_slice_split_tail( in BackUp()
130 g_core_codegen_interface->grpc_slice_buffer_add(slice_buffer_, slice_); in BackUp()
|
| D | completion_queue.h | 96 extern CoreCodegenInterface* g_core_codegen_interface;
118 ::grpc::g_core_codegen_interface->grpc_completion_queue_destroy(cq_); in ~CompletionQueue()
179 ::grpc::g_core_codegen_interface->gpr_inf_future( in Next()
247 cq_ = ::grpc::g_core_codegen_interface->grpc_completion_queue_create( in CompletionQueue()
248 ::grpc::g_core_codegen_interface->grpc_completion_queue_factory_lookup( in CompletionQueue()
319 ::grpc::g_core_codegen_interface->gpr_inf_future(GPR_CLOCK_REALTIME); in Pluck()
321 auto ev = ::grpc::g_core_codegen_interface->grpc_completion_queue_pluck( in Pluck()
342 ::grpc::g_core_codegen_interface->gpr_time_0(GPR_CLOCK_REALTIME); in TryPluck()
343 auto ev = ::grpc::g_core_codegen_interface->grpc_completion_queue_pluck( in TryPluck()
359 auto ev = ::grpc::g_core_codegen_interface->grpc_completion_queue_pluck( in TryPluck()
[all …]
|
| D | byte_buffer.h | 88 buffer_ = g_core_codegen_interface->grpc_raw_byte_buffer_create( in ByteBuffer()
100 g_core_codegen_interface->grpc_byte_buffer_destroy(buffer_); in ~ByteBuffer()
113 buffer_ = g_core_codegen_interface->grpc_byte_buffer_copy(buf.buffer_);
124 g_core_codegen_interface->grpc_byte_buffer_destroy(buffer_); in Clear()
135 buffer_ = g_core_codegen_interface->grpc_byte_buffer_copy(buffer_); in Duplicate()
146 : g_core_codegen_interface->grpc_byte_buffer_length(buffer_); in Length()
226 return g_core_codegen_interface->ok(); in Serialize()
|
| D | proto_buffer_reader.h | 38 extern CoreCodegenInterface* g_core_codegen_interface;
55 !g_core_codegen_interface->grpc_byte_buffer_reader_init( in ProtoBufferReader()
64 g_core_codegen_interface->grpc_byte_buffer_reader_destroy(&reader_); in ~ProtoBufferReader()
84 if (!g_core_codegen_interface->grpc_byte_buffer_reader_peek(&reader_, in Next()
|
| D | proto_utils.h | 41 extern CoreCodegenInterface* g_core_codegen_interface;
61 return g_core_codegen_interface->ok(); in GenericSerialize()
65 ? g_core_codegen_interface->ok() in GenericSerialize()
80 Status result = g_core_codegen_interface->ok(); in GenericDeserialize()
|
| D | server_callback_handlers.h | 47 ::grpc::g_core_codegen_interface->grpc_call_ref(param.call->call()); in RunHandler()
52 auto* call = new (::grpc::g_core_codegen_interface->grpc_call_arena_alloc( in RunHandler()
70 reactor = new (::grpc::g_core_codegen_interface->grpc_call_arena_alloc( in RunHandler()
91 new (::grpc::g_core_codegen_interface->grpc_call_arena_alloc( in Deserialize()
214 ::grpc::g_core_codegen_interface->grpc_call_unref(call); in CallOnDone()
263 ::grpc::g_core_codegen_interface->grpc_call_ref(param.call->call()); in RunHandler()
265 auto* reader = new (::grpc::g_core_codegen_interface->grpc_call_arena_alloc( in RunHandler()
289 reactor = new (::grpc::g_core_codegen_interface->grpc_call_arena_alloc( in RunHandler()
406 ::grpc::g_core_codegen_interface->grpc_call_unref(call); in CallOnDone()
449 ::grpc::g_core_codegen_interface->grpc_call_ref(param.call->call()); in RunHandler()
[all …]
|
| D | callback_common.h | 87 g_core_codegen_interface->grpc_call_ref(call); in CallbackWithStatusTag()
130 g_core_codegen_interface->grpc_call_unref(call_); in Run()
168 g_core_codegen_interface->grpc_call_ref(call); in Set()
181 g_core_codegen_interface->grpc_call_unref(call); in Clear()
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| D | slice.h | 38 Slice() : slice_(g_core_codegen_interface->grpc_empty_slice()) {} in Slice()
40 ~Slice() { g_core_codegen_interface->grpc_slice_unref(slice_); } in ~Slice()
45 : slice_(g_core_codegen_interface->grpc_slice_ref(slice)) {} in Slice()
53 : slice_(g_core_codegen_interface->grpc_slice_malloc(len)) {} in Slice()
57 : slice_(g_core_codegen_interface->grpc_slice_from_copied_buffer( in Slice()
62 : slice_(g_core_codegen_interface->grpc_slice_from_copied_buffer( in Slice()
69 : slice_(g_core_codegen_interface->grpc_slice_from_static_buffer( in Slice()
74 : slice_(g_core_codegen_interface->grpc_slice_ref(other.slice_)) {} in Slice()
88 : slice_(g_core_codegen_interface->grpc_slice_new_with_user_data( in Slice()
97 : slice_(g_core_codegen_interface->grpc_slice_new_with_len(buf, len, in Slice()
[all …]
|
| D | proto_buffer_writer.h | 37 extern CoreCodegenInterface* g_core_codegen_interface;
68 g_core_codegen_interface->grpc_raw_byte_buffer_create(NULL, 0); in ProtoBufferWriter()
75 g_core_codegen_interface->grpc_slice_unref(backup_slice_); in ~ProtoBufferWriter()
102 slice_ = g_core_codegen_interface->grpc_slice_malloc( in Next()
111 g_core_codegen_interface->grpc_slice_buffer_add(slice_buffer_, slice_); in Next()
124 g_core_codegen_interface->grpc_slice_buffer_pop(slice_buffer_); in BackUp()
128 backup_slice_ = g_core_codegen_interface->grpc_slice_split_tail( in BackUp()
130 g_core_codegen_interface->grpc_slice_buffer_add(slice_buffer_, slice_); in BackUp()
|
| D | completion_queue.h | 89 extern CoreCodegenInterface* g_core_codegen_interface;
111 g_core_codegen_interface->grpc_completion_queue_destroy(cq_); in ~CompletionQueue()
172 g_core_codegen_interface->gpr_inf_future( in Next()
239 cq_ = g_core_codegen_interface->grpc_completion_queue_create( in CompletionQueue()
240 g_core_codegen_interface->grpc_completion_queue_factory_lookup( in CompletionQueue()
301 g_core_codegen_interface->gpr_inf_future(GPR_CLOCK_REALTIME); in Pluck()
302 auto ev = g_core_codegen_interface->grpc_completion_queue_pluck( in Pluck()
321 auto deadline = g_core_codegen_interface->gpr_time_0(GPR_CLOCK_REALTIME); in TryPluck()
322 auto ev = g_core_codegen_interface->grpc_completion_queue_pluck( in TryPluck()
337 auto ev = g_core_codegen_interface->grpc_completion_queue_pluck( in TryPluck()
|
| D | proto_buffer_reader.h | 38 extern CoreCodegenInterface* g_core_codegen_interface;
55 !g_core_codegen_interface->grpc_byte_buffer_reader_init( in ProtoBufferReader()
64 g_core_codegen_interface->grpc_byte_buffer_reader_destroy(&reader_); in ~ProtoBufferReader()
84 if (!g_core_codegen_interface->grpc_byte_buffer_reader_next(&reader_, in Next()
88 g_core_codegen_interface->grpc_slice_unref(slice_); in Next()
|
| D | proto_utils.h | 41 extern CoreCodegenInterface* g_core_codegen_interface;
61 return g_core_codegen_interface->ok(); in GenericSerialize()
65 ? g_core_codegen_interface->ok() in GenericSerialize()
79 Status result = g_core_codegen_interface->ok(); in GenericDeserialize()
|
| D | byte_buffer.h | 82 buffer_ = g_core_codegen_interface->grpc_raw_byte_buffer_create( in ByteBuffer()
92 g_core_codegen_interface->grpc_byte_buffer_destroy(buffer_); in ~ByteBuffer()
104 g_core_codegen_interface->grpc_byte_buffer_destroy(buffer_); in Clear()
113 buffer_ = g_core_codegen_interface->grpc_byte_buffer_copy(buffer_); in Duplicate()
124 : g_core_codegen_interface->grpc_byte_buffer_length(buffer_); in Length()
|
| D | callback_common.h | 70 g_core_codegen_interface->grpc_call_ref(call); in CallbackWithStatusTag()
105 g_core_codegen_interface->grpc_call_unref(call_); in Run()
127 g_core_codegen_interface->grpc_call_ref(call); in CallbackWithSuccessTag()
157 g_core_codegen_interface->grpc_call_unref(call_); in Run()
|