| /dports/devel/caf/actor-framework-0.18.5/libcaf_io/src/policy/ |
| H A D | tcp.cpp | 23 using caf::io::network::rw_state;
29 rw_state
39 return rw_state::failure; in read_some()
43 return rw_state::failure; in read_some()
47 return rw_state::success; in read_some()
50 rw_state
60 return rw_state::failure; in write_some()
64 return rw_state::success; in write_some()
|
| /dports/devel/caf/actor-framework-0.18.5/libcaf_io/src/io/network/ |
| H A D | stream.cpp | 138 bool stream::handle_read_result(rw_state read_result, size_t rb) { in handle_read_result()
140 case rw_state::failure: in handle_read_result()
144 case rw_state::indeterminate: in handle_read_result()
146 case rw_state::success: in handle_read_result()
157 case rw_state::want_read: in handle_read_result()
174 void stream::handle_write_result(rw_state write_result, size_t wb) { in handle_write_result()
176 case rw_state::failure: in handle_write_result()
180 case rw_state::indeterminate: in handle_write_result()
183 case rw_state::want_read: in handle_write_result()
192 case rw_state::success: in handle_write_result()
|
| /dports/devel/caf/actor-framework-0.18.5/libcaf_openssl/src/openssl/ |
| H A D | session.cpp | 86 rw_state session::do_some(int (*f)(SSL*, void*, int), size_t& result, void* buf, in do_some()
89 auto check_ssl_res = [&](int res) -> rw_state { in do_some()
94 return rw_state::failure; in do_some()
97 return rw_state::want_read; in do_some()
101 return rw_state::success; in do_some()
131 return rw_state::indeterminate; in do_some()
136 return rw_state::success; in do_some()
139 return handle_ssl_result(ret) ? rw_state::success : rw_state::failure; in do_some()
142 rw_state
148 rw_state session::write_some(size_t& result, native_socket, const void* buf, in write_some()
|
| H A D | middleman_actor.cpp | 75 rw_state read_some(size_t& result, native_socket fd, void* buf, size_t len) { in read_some()
80 rw_state
|
| /dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/misc/netstorage/ |
| H A D | object.cpp | 216 auto rw_state = StartRead(buffer.data(), buffer.size(), &bytes_read, &result); in Relocate() local
219 _ASSERT(rw_state); // Cannot be a nullptr if result check passed in Relocate()
229 rw_state->Close(); in Relocate()
246 if (rw_state->Eof()) break; in Relocate()
261 rw_state->Abort(); in Relocate()
272 rw_state->Close(); in Relocate()
346 INetStorageObjectState* rw_state = nullptr; in StartRead() local
350 rw_state = l->StartRead(buf, count, bytes_read, result); in StartRead()
352 if (!rw_state) throw 0; in StartRead()
354 EnterState(rw_state); in StartRead()
[all …]
|
| /dports/devel/caf/actor-framework-0.18.5/libcaf_openssl/caf/openssl/ |
| H A D | session.hpp | 33 using rw_state = io::network::rw_state; typedef
41 rw_state read_some(size_t& result, native_socket fd, void* buf, size_t len);
42 rw_state
52 rw_state do_some(int (*f)(SSL*, void*, int), size_t& result, void* buf,
|
| /dports/devel/caf/actor-framework-0.18.5/libcaf_io/caf/policy/ |
| H A D | tcp.hpp | 19 static io::network::rw_state
27 static io::network::rw_state
|
| /dports/math/libpgmath/flang-d07daf3/tools/flang1/flang1exe/ |
| H A D | fgraph.c | 1633 } rw_state; variable
1654 rw_state.std0.next = STD_NEXT(0); in rdilts()
1655 rw_state.std0.prev = STD_PREV(0); in rdilts()
1660 rw_state.std_before = 0; in rdilts()
1669 rw_state.std_after = 0; in rdilts()
1705 STD_NEXT(0) = rw_state.std0.next; in wrilts()
1706 STD_PREV(0) = rw_state.std0.prev; in wrilts()
1707 STD_NEXT(rw_state.std_before) = rw_state.std_after; in wrilts()
1708 STD_PREV(rw_state.std_after) = rw_state.std_before; in wrilts()
1712 p = rw_state.std_before; in wrilts()
[all …]
|
| /dports/security/libressl-static/libressl-3.3.5/tests/ |
| H A D | recordtest.c | 67 struct rw_state { struct
77 struct rw_state *rs = cb_arg; in read_cb() argument
98 struct rw_state *ws = cb_arg; in write_cb()
373 struct rw_state rs; in test_record_recv()
466 struct rw_state ws; in test_record_send()
|
| /dports/security/libressl/libressl-3.4.3/tests/ |
| H A D | recordtest.c | 67 struct rw_state { struct
77 struct rw_state *rs = cb_arg; in read_cb() argument
98 struct rw_state *ws = cb_arg; in write_cb()
373 struct rw_state rs; in test_record_recv()
466 struct rw_state ws; in test_record_send()
|
| /dports/www/obhttpd/libressl-3.4.1/tests/ |
| H A D | recordtest.c | 67 struct rw_state { struct
77 struct rw_state *rs = cb_arg; in read_cb() argument
98 struct rw_state *ws = cb_arg; in write_cb()
373 struct rw_state rs; in test_record_recv()
466 struct rw_state ws; in test_record_send()
|
| /dports/devel/caf/actor-framework-0.18.5/libcaf_io/caf/io/network/ |
| H A D | stream.hpp | 115 bool handle_read_result(rw_state read_result, size_t rb);
117 void handle_write_result(rw_state write_result, size_t wb);
|
| H A D | rw_state.hpp | 10 enum class rw_state { enum
|
| /dports/devel/pth-hard/pth-2.0.7/ |
| H A D | pth_sync.c | 153 rwlock->rw_state = PTH_RWLOCK_INITIALIZED; in pth_rwlock_init()
165 if (!(rwlock->rw_state & PTH_RWLOCK_INITIALIZED)) in pth_rwlock_acquire()
198 if (!(rwlock->rw_state & PTH_RWLOCK_INITIALIZED)) in pth_rwlock_release()
|
| H A D | pth.h.in | 300 int rw_state; member
|
| /dports/devel/pth/pth-2.0.7/ |
| H A D | pth_sync.c | 153 rwlock->rw_state = PTH_RWLOCK_INITIALIZED; in pth_rwlock_init()
165 if (!(rwlock->rw_state & PTH_RWLOCK_INITIALIZED)) in pth_rwlock_acquire()
198 if (!(rwlock->rw_state & PTH_RWLOCK_INITIALIZED)) in pth_rwlock_release()
|
| H A D | pth.h.in | 300 int rw_state; member
|
| /dports/devel/pthsem/pthsem-2.0.8/ |
| H A D | pth_sync.c | 153 rwlock->rw_state = PTH_RWLOCK_INITIALIZED; in pth_rwlock_init()
165 if (!(rwlock->rw_state & PTH_RWLOCK_INITIALIZED)) in pth_rwlock_acquire()
198 if (!(rwlock->rw_state & PTH_RWLOCK_INITIALIZED)) in pth_rwlock_release()
|
| /dports/net/gsocket/gsocket-1.4.28/lib/ |
| H A D | gsocket-engine.h | 7 int gs_ssl_continue(GS *gsocket, enum gs_rw_state_t rw_state);
|
| H A D | gsocket-ssl.c | 405 gs_ssl_continue(GS *gsocket, enum gs_rw_state_t rw_state) in gs_ssl_continue() argument
412 if (rw_state == GS_CAN_WRITE) in gs_ssl_continue()
|
| /dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbitmq_management/src/ |
| H A D | rabbit_mgmt_wm_definitions.erl | 274 rw_state() -> function
289 [filter_items(N, V, proplists:get_value(N, rw_state())) || {N, V} <- Items].
|
| /dports/devel/caf/actor-framework-0.18.5/libcaf_io/test/detail/ |
| H A D | prometheus_broker.cpp | 103 if (state == io::network::rw_state::failure) { in read_all()
|
| /dports/devel/valgrind-lts/valgrind-dragonfly-dragonfly/include/vki/ |
| H A D | vki-freebsd.h | 1962 vki_uint32_t rw_state; member
|
| H A D | vki-dragonfly.h | 2084 vki_uint32_t rw_state; member
|
| /dports/devel/valgrind/valgrind-dragonfly-dragonfly/include/vki/ |
| H A D | vki-freebsd.h | 1962 vki_uint32_t rw_state; member
|