| /third_party/boost/libs/asio/test/execution/ |
| D | context_as.cpp | 78 io_context io_ctx; in context_as_executor_query_test() local
81 &boost::asio::query(io_ctx.get_executor(), in context_as_executor_query_test()
83 == &io_ctx); in context_as_executor_query_test()
87 > ex3 = io_ctx.get_executor(); in context_as_executor_query_test()
92 == &io_ctx); in context_as_executor_query_test()
96 == &io_ctx); in context_as_executor_query_test()
99 &boost::asio::query(io_ctx.get_executor(), in context_as_executor_query_test()
101 == &io_ctx); in context_as_executor_query_test()
105 > ex4 = io_ctx.get_executor(); in context_as_executor_query_test()
110 == &io_ctx); in context_as_executor_query_test()
[all …]
|
| /third_party/ltp/testcases/kernel/io/aio/ |
| D | aio01.c | 80 io_context_t io_ctx; /* I/O Context */ variable
134 TEST(io_submit(io_ctx, 1, iocbs)); in main()
142 while (io_getevents(io_ctx, 1, 1, &event, &ts) != 1) ; in main()
165 TEST(io_submit(io_ctx, 1, iocbs)); in main()
173 while (io_getevents(io_ctx, 1, 1, &event, &ts) != 1) ; in main()
196 TEST(io_submit(io_ctx, 1, iocbs)); in main()
204 while (io_getevents(io_ctx, 1, 1, &event, &ts) != 1) ; in main()
227 TEST(io_submit(io_ctx, 1, iocbs)); in main()
235 while (io_getevents(io_ctx, 1, 1, &event, &ts) != 1) ; in main()
258 TEST(io_submit(io_ctx, 1, iocbs)); in main()
[all …]
|
| /third_party/mbedtls/programs/ssl/ |
| D | ssl_test_common_source.c | 206 io_ctx_t *io_ctx = (io_ctx_t*) ctx; in recv_cb() local
211 ret = delayed_recv( io_ctx->net, buf, len ); in recv_cb()
213 ret = mbedtls_net_recv( io_ctx->net, buf, len ); in recv_cb()
223 if( ssl_check_record( io_ctx->ssl, buf, recv_len ) != 0 ) in recv_cb()
233 io_ctx_t *io_ctx = (io_ctx_t*) ctx; in recv_timeout_cb() local
237 ret = mbedtls_net_recv_timeout( io_ctx->net, buf, len, timeout ); in recv_timeout_cb()
247 if( ssl_check_record( io_ctx->ssl, buf, recv_len ) != 0 ) in recv_timeout_cb()
256 io_ctx_t *io_ctx = (io_ctx_t*) ctx; in send_cb() local
259 return( delayed_send( io_ctx->net, buf, len ) ); in send_cb()
261 return( mbedtls_net_send( io_ctx->net, buf, len ) ); in send_cb()
|
| D | ssl_client2.c | 654 io_ctx_t io_ctx; in main() local
2014 io_ctx.ssl = &ssl; in main()
2015 io_ctx.net = &server_fd; in main()
2016 mbedtls_ssl_set_bio( &ssl, &io_ctx, send_cb, recv_cb, in main()
|
| D | ssl_server2.c | 1289 io_ctx_t io_ctx; in main() local
3026 io_ctx.ssl = &ssl; in main()
3027 io_ctx.net = &client_fd; in main()
3028 mbedtls_ssl_set_bio( &ssl, &io_ctx, send_cb, recv_cb, in main()
|
| /third_party/boost/libs/fiber/examples/asio/ |
| D | autoecho.cpp | 156 void server( std::shared_ptr< boost::asio::io_context > const& io_ctx, tcp::acceptor & a) { in server() argument
160 socket_ptr socket( new tcp::socket( * io_ctx) ); in server()
174 io_ctx->stop(); in server()
181 void client( std::shared_ptr< boost::asio::io_context > const& io_ctx, tcp::acceptor & a, in client() argument
185 tcp::resolver resolver( * io_ctx); in client()
188 tcp::socket s( * io_ctx); in client()
233 … std::shared_ptr< boost::asio::io_context > io_ctx = std::make_shared< boost::asio::io_context >(); in main() local
234 boost::fibers::use_scheduling_algorithm< boost::fibers::asio::round_robin >( io_ctx); in main()
239 tcp::acceptor a( * io_ctx, tcp::endpoint( tcp::v4(), 9999) ); in main()
240 boost::fibers::fiber( server, io_ctx, std::ref( a) ).detach(); in main()
[all …]
|
| D | round_robin.hpp | 54 service( boost::asio::io_context & io_ctx) : in service()
55 boost::asio::io_context::service( io_ctx), in service()
56 work_{ new boost::asio::io_context::work( io_ctx) } { in service()
72 io_ctx_( io_ctx), in round_robin()
|
| /third_party/ltp/testcases/kernel/io/ltp-aiodio/ |
| D | aio-stress.c | 217 io_context_t io_ctx; member
496 nr = io_getevents(t->io_ctx, min_nr, t->num_global_events, t->events, in read_some_events()
499 nr = io_getevents(t->io_ctx, t->num_global_events, t->events, NULL); in read_some_events()
559 while (io_getevents(t->io_ctx, 1, 1, &event, NULL) > 0) {
561 while (io_getevents(t->io_ctx, 1, &event, NULL) > 0) {
763 ret = io_submit(t->io_ctx, num_ios, my_iocbs);
936 void aio_setup(io_context_t * io_ctx, int n) argument
938 int res = io_queue_init(n, io_ctx);
1123 aio_setup(&t->io_ctx, 512);
1231 io_queue_release(t->io_ctx);
|
| /third_party/boost/libs/log/src/ |
| D | syslog_backend.cpp | 320 …explicit syslog_udp_socket(asio::io_context& io_ctx, asio::ip::udp const& protocol, asio::ip::udp:…
321 m_Socket(io_ctx)
|