| /dports/www/restbed/restbed-4.8/source/corvusoft/restbed/detail/ |
| H A D | ipc_socket_impl.cpp | 57 m_strand( make_shared< io_service::strand > ( m_io_service ) ), in IPCSocketImpl()
106 m_strand->post([this, data, callback] { write_helper(data, callback); }); in start_write()
121 m_strand->post([this, length, success, failure] { in start_read()
128 m_strand->post([this, data, length, callback] in start_read()
136 m_strand->post([this, data, delimiter, callback] in start_read()
189 …m_timer->async_wait( m_strand->wrap( bind( &IPCSocketImpl::connection_timeout_handler, this, share… in write()
231 …m_timer->async_wait( m_strand->wrap( bind( &IPCSocketImpl::connection_timeout_handler, this, share… in write()
263 …m_timer->async_wait( m_strand->wrap( bind( &IPCSocketImpl::connection_timeout_handler, this, share… in read()
295 …m_timer->async_wait( m_strand->wrap( bind( &IPCSocketImpl::connection_timeout_handler, this, share… in read()
319 …m_timer->async_wait( m_strand->wrap( bind( &IPCSocketImpl::connection_timeout_handler, this, share… in read()
[all …]
|
| H A D | socket_impl.cpp | 59 m_strand( make_shared< io_service::strand > ( m_io_service ) ), in SocketImpl()
76 m_strand( make_shared< io_service::strand > ( m_io_service ) ), in SocketImpl()
163 m_strand->post([this, data, callback] { write_helper(data, callback); }); in start_write()
178 m_strand->post([this, length, success, failure] { in start_read()
185 m_strand->post([this, data, length, callback] in start_read()
193 m_strand->post([this, data, delimiter, callback] in start_read()
322 m_strand( make_shared< io_service::strand > ( m_io_service ) ), in SocketImpl()
353 …m_timer->async_wait( m_strand->wrap( bind( &SocketImpl::connection_timeout_handler, this, shared_f… in write()
430 …m_timer->async_wait( m_strand->wrap( bind( &SocketImpl::connection_timeout_handler, this, shared_f… in write()
486 …m_timer->async_wait( m_strand->wrap( bind( &SocketImpl::connection_timeout_handler, this, shared_f… in read()
[all …]
|
| /dports/games/pokerth/pokerth-1.1.2-rc/src/third_party/websocketpp/websocketpp/transport/asio/security/ |
| H A D | tls.hpp | 200 m_strand = strand; in init_asio()
267 if (m_strand) { in post_init()
270 m_strand->wrap(lib::bind( in post_init()
329 if (m_strand) { in async_shutdown()
330 m_socket->async_shutdown(m_strand->wrap(callback)); in async_shutdown()
395 strand_ptr m_strand; member in websocketpp::transport::asio::tls_socket::connection
|
| /dports/devel/websocketpp/websocketpp-0.8.2/websocketpp/transport/asio/security/ |
| H A D | tls.hpp | 203 m_strand = strand; in init_asio()
266 if (m_strand) { in post_init()
269 m_strand->wrap(lib::bind( in post_init()
328 if (m_strand) { in async_shutdown()
329 m_socket->async_shutdown(m_strand->wrap(callback)); in async_shutdown()
385 strand_ptr m_strand; member in websocketpp::transport::asio::tls_socket::connection
|
| /dports/multimedia/musikcube/musikcube-0.96.7/src/3rdparty/include/websocketpp/transport/asio/security/ |
| H A D | tls.hpp | 203 m_strand = strand; in init_asio()
266 if (m_strand) { in post_init()
269 m_strand->wrap(lib::bind( in post_init()
328 if (m_strand) { in async_shutdown()
329 m_socket->async_shutdown(m_strand->wrap(callback)); in async_shutdown()
385 strand_ptr m_strand; member in websocketpp::transport::asio::tls_socket::connection
|
| /dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/include/algo/gnomon/ |
| H A D | aligncollapser.hpp | 61 …SIntron(int a, int b, int strand, bool oriented, const string& sig) : m_range(a,b), m_strand(stran… in SIntron()
65 else if(m_oriented && m_strand != i.m_strand) in operator <()
66 return m_strand < i.m_strand; in operator <()
72 int m_strand; member
|
| H A D | gnomon_model.hpp | 104 SSource() : m_strand(ePlus) {} in SSource()
107 EStrand m_strand; member
397 …_id(id), m_status(0), m_ident(0), m_weight(1), m_expecting_hole(false), m_strand(s), m_geneid(0), … in CGeneModel()
460 void SetStrand(EStrand s) { m_strand = s; } in SetStrand()
461 EStrand Strand() const { return m_strand; } in Strand()
599 EStrand m_strand; member in CGeneModel
|
| /dports/net/arataga/so5extra-v.1.4.1/dev/test/so_5_extra/disp/asio_thread_pool/multifile_hello/ |
| H A D | a.cpp | 10 , m_strand( io_svc ) in test_agent()
21 strand() noexcept { return m_strand; } in strand()
24 asio::io_context::strand m_strand; member in test_coop_a::test_agent
|
| H A D | b.cpp | 10 , m_strand( io_svc ) in test_agent()
23 strand() noexcept { return m_strand; } in strand()
26 asio::io_context::strand m_strand; member in test_coop_b::test_agent
|
| /dports/biology/ncbi-toolkit/ncbi/tools/ |
| H A D | sim2.c | 24 Uint1 m_strand, s_strand; in SIM2() local
83 m_strand = SeqLocStrand(cslp1); in SIM2()
95 Change_Loc_Strand(cslp1, m_strand); in SIM2()
105 Change_Loc_Strand(cslp1, m_strand); in SIM2()
136 Change_Loc_Strand(cslp1, m_strand); in SIM2()
|
| /dports/net-p2p/amule/aMule-2.3.3/src/ |
| H A D | LibSocketAsio.cpp | 103 m_strand(s_io_service), in CAsioSocketImpl()
268 m_strand.dispatch(boost::bind(& CAsioSocketImpl::DispatchWrite, this, nbytes)); in Write()
282 m_strand.dispatch(boost::bind(& CAsioSocketImpl::DispatchClose, this)); in Close()
541 m_strand.dispatch(boost::bind(& CAsioSocketImpl::DispatchBackgroundRead, this)); in StartBackgroundRead()
621 io_service::strand m_strand; // handle synchronisation in io_service thread pool member in CAsioSocketImpl
785 m_strand(s_io_service) in CAsioSocketServerImpl()
878 m_strand.post(boost::bind(& CAsioSocketServerImpl::StartAccept, this)); in HandleAccept()
889 io_service::strand m_strand; // handle synchronisation in io_service thread pool member in CAsioSocketServerImpl
970 m_strand(s_io_service), in CAsioUDPSocketImpl()
1038 m_strand.dispatch(boost::bind(& CAsioUDPSocketImpl::DispatchClose, this)); in Close()
[all …]
|
| /dports/net-p2p/amule-devel/aMule-SVN-r11065/src/ |
| H A D | LibSocketAsio.cpp | 104 m_strand(s_io_service), in CAsioSocketImpl()
269 m_strand.dispatch(boost::bind(& CAsioSocketImpl::DispatchWrite, this, nbytes)); in Write()
283 m_strand.dispatch(boost::bind(& CAsioSocketImpl::DispatchClose, this)); in Close()
542 m_strand.dispatch(boost::bind(& CAsioSocketImpl::DispatchBackgroundRead, this)); in StartBackgroundRead()
622 io_service::strand m_strand; // handle synchronisation in io_service thread pool member in CAsioSocketImpl
786 m_strand(s_io_service) in CAsioSocketServerImpl()
879 m_strand.post(boost::bind(& CAsioSocketServerImpl::StartAccept, this)); in HandleAccept()
890 io_service::strand m_strand; // handle synchronisation in io_service thread pool member in CAsioSocketServerImpl
971 m_strand(s_io_service), in CAsioUDPSocketImpl()
1039 m_strand.dispatch(boost::bind(& CAsioUDPSocketImpl::DispatchClose, this)); in Close()
[all …]
|
| /dports/games/pokerth/pokerth-1.1.2-rc/src/third_party/websocketpp/websocketpp/transport/asio/ |
| H A D | connection.hpp | 320 new_timer->async_wait(m_strand->wrap(lib::bind( in set_timer()
366 return m_strand; in get_strand()
464 m_strand = lib::make_shared<lib::asio::io_service::strand>( in init_asio()
632 m_strand->wrap(lib::bind( in proxy_write()
716 m_strand->wrap(lib::bind( in proxy_read()
844 m_strand->wrap(make_custom_alloc_handler( in async_read_at_least()
913 m_strand->wrap(make_custom_alloc_handler( in async_write()
950 m_strand->wrap(make_custom_alloc_handler( in async_write()
1015 m_io_service->post(m_strand->wrap(handler)); in interrupt()
1024 m_io_service->post(m_strand->wrap(handler)); in dispatch()
[all …]
|
| /dports/devel/websocketpp/websocketpp-0.8.2/websocketpp/transport/asio/ |
| H A D | connection.hpp | 321 new_timer->async_wait(m_strand->wrap(lib::bind( in set_timer()
367 return m_strand; in get_strand()
465 m_strand.reset(new lib::asio::io_service::strand(*io_service)); in init_asio()
632 m_strand->wrap(lib::bind( in proxy_write()
716 m_strand->wrap(lib::bind( in proxy_read()
844 m_strand->wrap(make_custom_alloc_handler( in async_read_at_least()
913 m_strand->wrap(make_custom_alloc_handler( in async_write()
950 m_strand->wrap(make_custom_alloc_handler( in async_write()
1015 m_io_service->post(m_strand->wrap(handler)); in interrupt()
1024 m_io_service->post(m_strand->wrap(handler)); in dispatch()
[all …]
|
| /dports/multimedia/musikcube/musikcube-0.96.7/src/3rdparty/include/websocketpp/transport/asio/ |
| H A D | connection.hpp | 321 new_timer->async_wait(m_strand->wrap(lib::bind( in set_timer()
367 return m_strand; in get_strand()
465 m_strand.reset(new lib::asio::io_service::strand(*io_service)); in init_asio()
632 m_strand->wrap(lib::bind( in proxy_write()
716 m_strand->wrap(lib::bind( in proxy_read()
844 m_strand->wrap(make_custom_alloc_handler( in async_read_at_least()
913 m_strand->wrap(make_custom_alloc_handler( in async_write()
950 m_strand->wrap(make_custom_alloc_handler( in async_write()
1015 m_io_service->post(m_strand->wrap(handler)); in interrupt()
1024 m_io_service->post(m_strand->wrap(handler)); in dispatch()
[all …]
|
| /dports/devel/RStudio/rstudio-2021.09.1-372/src/cpp/ext/websocketpp/transport/asio/security/ |
| H A D | tls.hpp | 202 m_strand = strand; in init_asio()
237 if (m_strand) { in post_init()
240 m_strand->wrap(lib::bind( in post_init()
339 strand_ptr m_strand; member in websocketpp::transport::asio::tls_socket::connection
|
| /dports/devel/RStudio/rstudio-2021.09.1-372/src/cpp/ext/websocketpp/transport/asio/ |
| H A D | connection.hpp | 304 new_timer->async_wait(m_strand->wrap(lib::bind( in set_timer()
350 return m_strand; in get_strand()
425 m_strand = lib::make_shared<boost::asio::io_service::strand>( in init_asio()
428 m_async_read_handler = m_strand->wrap(lib::bind( in init_asio()
432 m_async_write_handler = m_strand->wrap(lib::bind( in init_asio()
443 lib::error_code ec = socket_con_type::init_asio(io_service, m_strand, in init_asio()
614 m_strand->wrap(lib::bind( in proxy_write()
698 m_strand->wrap(lib::bind( in proxy_read()
974 m_io_service->post(m_strand->wrap(handler)); in interrupt()
983 m_io_service->post(m_strand->wrap(handler)); in dispatch()
[all …]
|
| /dports/editors/encryptpad/EncryptPad-0.5.0.1/deps/botan/src/cli/ |
| H A D | tls_proxy.cpp | 149 : m_strand(io) in tls_proxy_session()
187 m_strand.wrap( in client_read()
248 m_strand.wrap( in tls_emit_data()
273 m_strand.wrap( in proxy_write_to_server()
311 m_strand.wrap( in server_read()
344 boost::asio::io_service::strand m_strand; member in Botan_CLI::__anon322456e30111::tls_proxy_session
|
| H A D | tls_http_server.cpp | 208 : m_strand(io) in TLS_Asio_HTTP_Session()
233 m_strand.wrap( in client_read()
335 m_strand.wrap( in tls_emit_data()
409 boost::asio::io_service::strand m_strand; member in Botan_CLI::__anonff818ad70111::TLS_Asio_HTTP_Session
|
| /dports/mail/thunderbird/thunderbird-91.8.0/comm/third_party/botan/src/cli/ |
| H A D | tls_proxy.cpp | 149 : m_strand(io) in tls_proxy_session()
187 m_strand.wrap( in client_read()
248 m_strand.wrap( in tls_emit_data()
273 m_strand.wrap( in proxy_write_to_server()
311 m_strand.wrap( in server_read()
344 boost::asio::io_service::strand m_strand; member in Botan_CLI::__anone8b30b450111::tls_proxy_session
|
| H A D | tls_http_server.cpp | 208 : m_strand(io) in TLS_Asio_HTTP_Session()
233 m_strand.wrap( in client_read()
335 m_strand.wrap( in tls_emit_data()
409 boost::asio::io_service::strand m_strand; member in Botan_CLI::__anon531280b90111::TLS_Asio_HTTP_Session
|
| /dports/security/botan2/Botan-2.18.2/src/cli/ |
| H A D | tls_proxy.cpp | 149 : m_strand(io) in tls_proxy_session()
187 m_strand.wrap( in client_read()
248 m_strand.wrap( in tls_emit_data()
273 m_strand.wrap( in proxy_write_to_server()
311 m_strand.wrap( in server_read()
344 boost::asio::io_service::strand m_strand; member in Botan_CLI::__anon59c081e20111::tls_proxy_session
|
| H A D | tls_http_server.cpp | 208 : m_strand(io) in TLS_Asio_HTTP_Session()
233 m_strand.wrap( in client_read()
335 m_strand.wrap( in tls_emit_data()
409 boost::asio::io_service::strand m_strand; member in Botan_CLI::__anon2757b9160111::TLS_Asio_HTTP_Session
|
| /dports/net/arataga/so5extra-v.1.4.1/dev/so_5_extra/disp/asio_thread_pool/ |
| H A D | pub.hpp | 844 , m_strand{ strand }
848 strand() noexcept { return m_strand.get(); } in strand()
852 outliving_reference_t< ::asio::io_context::strand > m_strand; member in so_5::extra::disp::asio_thread_pool::impl::binder_with_external_strand_t
875 , m_strand{ m_dispatcher->io_context() }
879 strand() noexcept { return m_strand; } in strand()
883 ::asio::io_context::strand m_strand;
|
| /dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/algo/gnomon/ |
| H A D | hmm.hpp | 279 EStrand Strand() const { return m_strand; } in Strand()
280 bool isPlus() const { return (m_strand == ePlus); } in isPlus()
281 bool isMinus() const { return (m_strand == eMinus); } in isMinus()
300 EStrand m_strand; member in CHMM_State
|