| /dports/comms/bforce-kst/bforce-0.22.8.kst7/source/bforce/ |
| H A D | prot_binkp.c | 117 bool recv_ready = FALSE; in binkp_outgoing() local
190 send_ready = recv_ready = FALSE; in binkp_outgoing()
192 if( tty_select(&recv_ready, (bpi.opos || bpi.n_msgs) ? in binkp_outgoing()
199 if( recv_ready && (recv_rc = binkp_recv(&bpi)) == BPMSG_EXIT ) in binkp_outgoing()
279 bool recv_ready = FALSE; in binkp_incoming() local
327 send_ready = recv_ready = FALSE; in binkp_incoming()
329 if( tty_select(&recv_ready, (bpi.opos || bpi.n_msgs) ? in binkp_incoming()
336 if( recv_ready && (recv_rc = binkp_recv(&bpi)) == BPMSG_EXIT ) in binkp_incoming()
393 bool recv_ready = FALSE; in binkp_transfer() local
454 recv_ready = send_ready = FALSE; in binkp_transfer()
[all …]
|
| H A D | prot_hydra.c | 1194 bool recv_ready = FALSE; in hydra_batch() local
1556 send_ready = recv_ready = FALSE; in hydra_batch()
1559 n = tty_xselect(&recv_ready, &send_ready, 10); in hydra_batch()
1561 n = tty_xselect(&recv_ready, NULL, 10); in hydra_batch()
1569 if( recv_ready && (recv_rc = hydra_recv(hi)) == HPKT_EXIT ) in hydra_batch()
|
| /dports/databases/twemproxy/twemproxy-0.5.0/src/ |
| H A D | nc_connection.c | 148 conn->recv_ready = 0; in _conn_get()
340 ASSERT(conn->recv_ready); in conn_recv()
349 conn->recv_ready = 0; in conn_recv()
356 conn->recv_ready = 0; in conn_recv()
367 conn->recv_ready = 0; in conn_recv()
371 conn->recv_ready = 0; in conn_recv()
|
| H A D | nc_proxy.c | 281 ASSERT(p->recv_active && p->recv_ready); in proxy_accept()
293 p->recv_ready = 0; in proxy_accept()
316 p->recv_ready = 0; in proxy_accept()
399 conn->recv_ready = 1; in proxy_recv()
405 } while (conn->recv_ready); in proxy_recv()
|
| H A D | nc_connection.h | 80 unsigned recv_ready:1; /* recv ready? */ member
|
| H A D | nc_message.c | 727 conn->recv_ready = 1; in msg_recv()
738 } while (conn->recv_ready); in msg_recv()
|
| /dports/science/dvc/dvc-0.30.1/dvc/remote/ssh/ |
| H A D | connection.py | 193 or channel.recv_ready()
201 if c.recv_ready():
215 and not stdout.channel.recv_ready()
|
| /dports/net/libzmq4/zeromq-4.3.4/src/ |
| H A D | gssapi_client.cpp | 112 state = recv_ready; in next_handshake_command()
121 if (state == recv_ready) { in process_handshake_command()
|
| H A D | gssapi_server.cpp | 84 state = recv_ready; in next_handshake_command()
111 if (state == recv_ready) { in process_handshake_command()
|
| H A D | gssapi_client.hpp | 62 recv_ready, enumerator
|
| H A D | gssapi_server.hpp | 67 recv_ready, enumerator
|
| /dports/net/py-pyzmq/pyzmq-22.3.0/bundled/zeromq/src/ |
| H A D | gssapi_client.cpp | 112 state = recv_ready; in next_handshake_command()
121 if (state == recv_ready) { in process_handshake_command()
|
| H A D | gssapi_server.cpp | 84 state = recv_ready; in next_handshake_command()
111 if (state == recv_ready) { in process_handshake_command()
|
| H A D | gssapi_client.hpp | 62 recv_ready, enumerator
|
| H A D | gssapi_server.hpp | 67 recv_ready, enumerator
|
| /dports/net/zmap/zmap-2.1.1/src/ |
| H A D | state.c | 65 .recv_ready = 0
|
| H A D | state.h | 117 int recv_ready; member
|
| H A D | recv.c | 153 zconf.recv_ready = 1; in recv_run()
|
| /dports/devel/dulwich/dulwich-0.19.16/dulwich/contrib/ |
| H A D | paramiko_vendor.py | 51 return self.channel.recv_ready()
|
| /dports/net/py-libcloud/apache-libcloud-3.4.1/test/compute/ |
| H A D | test_ssh_client.py | 477 chan.recv_ready.side_effect = [True, True, False]
490 chan.recv_ready.side_effect = [True, True, False]
531 chan.recv_ready.side_effect = [True, True, True, True, False]
559 chan.recv_ready.side_effect = [True, True, True, False]
|
| /dports/net/nsq/nsq-1.2.1/bench/ |
| H A D | bench.py | 64 if chan.recv_ready():
228 if chan.recv_ready():
|
| /dports/sysutils/ansible2/ansible-2.9.27/lib/ansible/modules/network/panos/ |
| H A D | _panos_cert_gen_ssh.py | 102 if shell.recv_ready():
|
| H A D | _panos_admpwd.py | 96 if shell.recv_ready():
|
| /dports/net/dpinger/dpinger-3.0/ |
| H A D | dpinger.c | 191 static unsigned int recv_ready = 0; variable
343 } while (recv_ready == 0); in send_thread()
396 recv_ready = 1; in recv_thread()
|
| /dports/devel/pytype/pytype-2021.9.9/pytype/typeshed/stubs/paramiko/paramiko/ |
| H A D | channel.pyi | 74 def recv_ready(self) -> bool: ...
|