Functions — github.com/Tradias/asio-grpc

CodeHub MCPcopy Create free account

hub / github.com/Tradias/asio-grpc / functions

Functions1,223 in github.com/Tradias/asio-grpc

⨍ Functions 1,223◇ Types & classes 582

↓ 1 callersFunctionmake_shutdown_request

The Shutdown endpoint is used by unit tests.

example/streaming-client.cpp:216

↓ 1 callersFunctionmake_shutdown_request

example/generic-client.cpp:190

↓ 1 callersFunctionmake_shutdown_request

--------------------------------------------------- The Shutdown endpoint is used by unit tests. ---------------------------------------------------

example/async-generator-client.cpp:57

↓ 1 callersFunctionmake_shutdown_request

example/unifex-client.cpp:182

↓ 1 callersFunctionmake_tcp_request

A simple tcp request that will be handled by the io_context

example/share-io-context-client.cpp:40

↓ 1 callersMethodmax_size_reached

src/agrpc/detail/pool_resource.hpp:114

↓ 1 callersMethodnext

example/multi-threaded-client.cpp:44

↓ 1 callersMethodonUserPreferenceChanged

doc/doxygen-awesome-darkmode-toggle.js:120

↓ 1 callersMethodon_user_done

src/agrpc/server_callback.hpp:290

↓ 1 callersMethodon_write_done

src/agrpc/detail/health_check_service.hpp:93

↓ 1 callersFunctionoperation_aborted_error_code

src/agrpc/detail/asio_forward.hpp:101

↓ 1 callersMethodperform_request_and_repeat

src/agrpc/detail/register_yield_rpc_handler.hpp:88

↓ 1 callersFunctionperform_under_file_lock

test/utils/utils/free_port.cpp:81

↓ 1 callersFunctionperform_under_global_lock

test/utils/utils/free_port.cpp:39

↓ 1 callersFunctionpost_some

test/src/test_grpc_context_17.cpp:648

↓ 1 callersMethodprepend

Returns true if the producer is inactive and needs to be woken up. The calling thread has responsibility for waking up the producer.

src/agrpc/detail/atomic_intrusive_queue.hpp:77

↓ 1 callersFunctionprepend_error_code_and_apply_impl

src/agrpc/detail/prepend_error_code.hpp:58

↓ 1 callersFunctionprepend_to_tuple_impl

src/agrpc/detail/tuple.hpp:130

↓ 1 callersMethodput_into_scratch_space

src/agrpc/detail/basic_sender.hpp:196

↓ 1 callersFunctionquery_execution_context

src/agrpc/detail/query_grpc_context.hpp:38

↓ 1 callersFunctionread_and_increment_port

test/utils/utils/free_port.cpp:88

↓ 1 callersFunctionreader

This function will read one requests from the client at a time. Note that gRPC only allows calling agrpc::read after a previous read has completed.

example/streaming-server.cpp:159

↓ 1 callersFunctionreader

example/generic-server.cpp:81

↓ 1 callersFunctionrecreate_if_old

test/utils/utils/free_port.cpp:55

↓ 1 callersFunctionrecursively_post

test/src/test_grpc_context_17.cpp:758

↓ 1 callersMethodregister_and_perform_requests

test/src/test_server_rpc_20.cpp:86

↓ 1 callersFunctionregister_handlers

example/snippets/server.cpp:104

↓ 1 callersFunctionregister_request_handler

example/multi-threaded-server.cpp:37

↓ 1 callersFunctionregister_request_handler

example/multi-threaded-alternative-server.cpp:35

↓ 1 callersFunctionregister_rpc_handler

A unary RPC request that will be handled by the GrpcContext.

example/main-io-context-server.cpp:51

↓ 1 callersFunctionregister_rpc_handler_asio_completion_trampoline

src/agrpc/detail/register_rpc_handler_asio_base.hpp:113

↓ 1 callersFunctionregister_shutdown_request_handler

example/unifex-server.cpp:113

↓ 1 callersFunctionregister_unary_request_handler

example/unifex-server.cpp:49

↓ 1 callersMethodrelease

src/agrpc/detail/allocate.hpp:76

↓ 1 callersMethodrelease_already_max_aligned

src/agrpc/detail/pool_resource.hpp:57

↓ 1 callersFunctionrelease_rpc_handler_operation_guard

src/agrpc/detail/register_sender_rpc_handler.hpp:113

↓ 1 callersMethodreplenish

src/agrpc/detail/pool_resource.hpp:138

↓ 1 callersMethodreset

src/agrpc/detail/client_callback.hpp:76

↓ 1 callersMethodreset

src/agrpc/detail/stop_callback_lifetime.hpp:38

↓ 1 callersFunctionresponse_processor

example/unifex-client.cpp:73

↓ 1 callersMethodrestore_scratch_space

src/agrpc/detail/basic_sender.hpp:203

↓ 1 callersFunctionrfind

src/agrpc/detail/algorithm.hpp:66

↓ 1 callersMethodrun

src/agrpc/detail/health_check_service.hpp:66

↓ 1 callersFunctionrun_completion_queue

src/agrpc/run.hpp:308

↓ 1 callersFunctionrun_descriptor

test/cmake/superbuild/src/descriptor.cpp:21

↓ 1 callersFunctionrun_grpc_context_for_sender

example/unifex-client.cpp:204

↓ 1 callersFunctionrun_grpc_context_for_sender

example/unifex-server.cpp:138

↓ 1 callersMethodrun_io_context_detached

test/utils/utils/io_context_test.cpp:32

↓ 1 callersFunctionrun_out_var

test/cmake/superbuild/src/out_var.cpp:23

↓ 1 callersMethodrun_server_immediate_cancellation

test/utils/utils/client_rpc_test.hpp:119

↓ 1 callersFunctionrun_target

test/cmake/superbuild/src/target.cpp:21

↓ 1 callersMethodrunning_in_this_thread

* @brief Determine whether the GrpcContext is running in the current thread * * Thread-safe */

src/agrpc/grpc_executor.hpp:152

↓ 1 callersMethodsend_health

src/agrpc/detail/health_check_service.hpp:73

↓ 1 callersMethodserver_done

test/src/test_callback_sender_receiver.cpp:45

↓ 1 callersFunctionserver_streaming

[client-rpc-server-streaming-callback] */

example/snippets/client_callback.cpp:93

↓ 1 callersFunctionserver_streaming_example

[unifex-server-streaming-client-side] */

example/snippets/unifex_client.cpp:26

↓ 1 callersFunctionserver_streaming_notify_when_done_request_handler

example/streaming-server.cpp:106

↓ 1 callersMethodset_completed

src/agrpc/detail/server_write_reactor.hpp:114

↓ 1 callersMethodset_deallocate_function

src/agrpc/detail/ref_counted_reactor.hpp:70

↓ 1 callersMethodset_done

test/utils/utils/asio_utils.hpp:94

↓ 1 callersMethodset_done

src/agrpc/detail/submit.hpp:47

↓ 1 callersMethodset_size

src/agrpc/detail/name.hpp:68

↓ 1 callersMethodsignal

src/agrpc/detail/manual_reset_event.hpp:68

↓ 1 callersFunctionspawn

src/agrpc/detail/register_yield_rpc_handler.hpp:39

↓ 1 callersFunctionspawn_all_void

example/helper/yield_helper.hpp:102

↓ 1 callersMethodspawn_client_functions

test/utils/utils/client_rpc_test.hpp:55

↓ 1 callersFunctionspawn_many

test/utils/utils/asio_utils.hpp:222

↓ 1 callersMethodstop

src/agrpc/detail/atomic_bool_stop_context.hpp:74

↓ 1 callersFunctionsubmit_sender_implementation_operation

src/agrpc/detail/sender_implementation_operation.hpp:137

↓ 1 callersFunctionsubmit_to_function

src/agrpc/detail/submit.hpp:75

↓ 1 callersMethodtest_check_default_service

test/src/test_health_check_service_17.cpp:79

↓ 1 callersMethodtest_check_non_existent_service

test/src/test_health_check_service_17.cpp:94

↓ 1 callersMethodtest_watch_and_accept_rpc_then_destruct

test/src/test_health_check_service_17.cpp:223

↓ 1 callersMethodtest_watch_and_cause_serving_status_update_to_fail

test/src/test_health_check_service_17.cpp:203

↓ 1 callersMethodtest_watch_and_client_cancel

test/src/test_health_check_service_17.cpp:180

↓ 1 callersMethodtest_watch_and_shutdown_health_check_service

test/src/test_health_check_service_17.cpp:155

↓ 1 callersMethodtest_watch_default_service_and_change_serving_status

test/src/test_health_check_service_17.cpp:107

↓ 1 callersMethodtest_watch_non_existent_service

test/src/test_health_check_service_17.cpp:127

↓ 1 callersFunctionunary

[client-rpc-unary-callback] */

example/snippets/client_callback.cpp:36

↓ 1 callersFunctionwait_some

test/src/test_grpc_context_17.cpp:639

↓ 1 callersFunctionwriter

The writer will pick up reads from the reader through the channel and switch to the thread_pool to compute their response.

example/streaming-server.cpp:179

↓ 1 callersFunctionwriter

example/generic-server.cpp:102

FunctionAGRPC_CATCH

src/agrpc/detail/register_sender_rpc_handler.hpp:347

MethodAGRPC_CATCH

src/agrpc/detail/register_callback_rpc_handler.hpp:68

MethodAGRPC_CATCH

src/agrpc/detail/sender_create.hpp:48

MethodAGRPC_CATCH

src/agrpc/detail/register_coroutine_rpc_handler.hpp:88

MethodAGRPC_CATCH

src/agrpc/detail/register_sender_rpc_handler.hpp:299

MethodAGRPC_CATCH

src/agrpc/detail/register_yield_rpc_handler.hpp:75

FunctionAGRPC_UNLIKELY

src/agrpc/detail/sender_implementation_operation.hpp:140

FunctionAGRPC_UNLIKELY

src/agrpc/detail/create_and_submit_no_arg_operation.hpp:32

MethodAGRPC_UNLIKELY

src/agrpc/detail/basic_sender.hpp:220

MethodAGRPC_UNLIKELY

src/agrpc/detail/rethrow_first_arg.hpp:31

MethodAGRPC_UNLIKELY

src/agrpc/detail/server_write_reactor.hpp:131

MethodAlarmCancellationFunction

src/agrpc/detail/alarm.hpp:47

MethodAllocationGuard

src/agrpc/detail/allocate.hpp:46

MethodAllocatorBinder

src/agrpc/detail/bind_allocator.hpp:38

MethodAsyncGeneratorServerStreamingRPCHandler

example/async-generator-server.cpp:41

MethodAtomicBoolStopFunction

src/agrpc/detail/atomic_bool_stop_context.hpp:39

MethodAtomicIntrusiveQueue

src/agrpc/detail/atomic_intrusive_queue.hpp:34

MethodBasicAlarm

* @brief Construct a BasicAlarm from an executor */

src/agrpc/alarm.hpp:57

← previous next →301–400 of 1,223, ranked by callers