| /dports/net/py-eventlet/eventlet-0.33.0/eventlet/green/ |
| H A D | zmq.py | 281 if flags & NOBLOCK:
293 flags |= NOBLOCK
315 if flags & NOBLOCK:
329 if flags & NOBLOCK:
343 if flags & NOBLOCK:
357 if flags & NOBLOCK:
371 if flags & NOBLOCK:
390 flags |= NOBLOCK
417 if flags & NOBLOCK:
431 if flags & NOBLOCK:
[all …]
|
| /dports/net/py-pyzmq/pyzmq-22.3.0/zmq/tests/ |
| H A D | test_error.py | 29 self.assertRaises(Again, s.recv, zmq.NOBLOCK)
30 self.assertRaisesErrno(zmq.EAGAIN, s.recv, zmq.NOBLOCK)
37 self.assertRaises(ContextTerminated, s.recv, zmq.NOBLOCK)
38 self.assertRaisesErrno(zmq.TERM, s.recv, zmq.NOBLOCK)
|
| H A D | test_pubsub.py | 34 self.assertRaisesErrno(zmq.EAGAIN, s2.recv, zmq.NOBLOCK)
|
| H A D | test_log.py | 102 self.assertRaisesErrno(zmq.EAGAIN, sub.recv, zmq.NOBLOCK)
120 self.assertRaisesErrno(zmq.EAGAIN, sub_only_info.recv, zmq.NOBLOCK)
|
| /dports/net/cloud-init/cloud-init-21.4/cloudinit/config/ |
| H A D | cc_resizefs.py | 22 NOBLOCK = "noblock" variable
48 'enum': [True, False, NOBLOCK],
205 if not util.translate_bool(resize_root, addons=[NOBLOCK]):
258 if resize_root == NOBLOCK:
269 if resize_root == NOBLOCK:
|
| /dports/lang/chez-scheme/ChezScheme-9.5.4/c/ |
| H A D | version.h | 23 #define NOBLOCK O_NONBLOCK macro
59 #define NOBLOCK O_NONBLOCK macro
94 #define NOBLOCK O_NONBLOCK macro
129 #define NOBLOCK O_NONBLOCK macro
163 #define NOBLOCK O_NONBLOCK macro
260 #define NOBLOCK O_NONBLOCK macro
295 #define NOBLOCK O_NONBLOCK macro
328 #define NOBLOCK O_NONBLOCK macro
361 #define NOBLOCK O_NONBLOCK macro
|
| H A D | new-io.c | 558 if (!(fcntl_flags & NOBLOCK)) (void) fcntl(fd, F_SETFL, fcntl_flags | NOBLOCK); in S_bytevector_read_nb()
563 if (!(fcntl_flags & NOBLOCK)) (void) fcntl(fd, F_SETFL, fcntl_flags); in S_bytevector_read_nb()
722 return Sboolean(NOBLOCK & fcntl_flags); in S_get_fd_non_blocking()
746 if (fcntl_flags & NOBLOCK) { in S_set_fd_non_blocking()
749 if (0 == fcntl(fd, F_SETFL, fcntl_flags | NOBLOCK)) { in S_set_fd_non_blocking()
754 if (!(fcntl_flags & NOBLOCK)) { in S_set_fd_non_blocking()
757 if (0 == fcntl(fd, F_SETFL, fcntl_flags & ~NOBLOCK)) { in S_set_fd_non_blocking()
|
| /dports/lang/racket/racket-8.3/src/ChezScheme/c/ |
| H A D | version.h | 46 #define NOBLOCK O_NONBLOCK macro
83 #define NOBLOCK O_NONBLOCK macro
115 #define NOBLOCK O_NONBLOCK macro
213 #define NOBLOCK O_NONBLOCK macro
244 #define NOBLOCK O_NONBLOCK macro
292 #define NOBLOCK O_NONBLOCK macro
321 #define NOBLOCK O_NONBLOCK macro
|
| H A D | new-io.c | 556 if (!(fcntl_flags & NOBLOCK)) (void) fcntl(fd, F_SETFL, fcntl_flags | NOBLOCK); in S_bytevector_read_nb()
561 if (!(fcntl_flags & NOBLOCK)) (void) fcntl(fd, F_SETFL, fcntl_flags); in S_bytevector_read_nb()
720 return Sboolean(NOBLOCK & fcntl_flags); in S_get_fd_non_blocking()
744 if (fcntl_flags & NOBLOCK) { in S_set_fd_non_blocking()
747 if (0 == fcntl(fd, F_SETFL, fcntl_flags | NOBLOCK)) { in S_set_fd_non_blocking()
752 if (!(fcntl_flags & NOBLOCK)) { in S_set_fd_non_blocking()
755 if (0 == fcntl(fd, F_SETFL, fcntl_flags & ~NOBLOCK)) { in S_set_fd_non_blocking()
|
| /dports/lang/racket-minimal/racket-8.3/src/ChezScheme/c/ |
| H A D | version.h | 46 #define NOBLOCK O_NONBLOCK macro
83 #define NOBLOCK O_NONBLOCK macro
115 #define NOBLOCK O_NONBLOCK macro
213 #define NOBLOCK O_NONBLOCK macro
244 #define NOBLOCK O_NONBLOCK macro
292 #define NOBLOCK O_NONBLOCK macro
321 #define NOBLOCK O_NONBLOCK macro
|
| H A D | new-io.c | 556 if (!(fcntl_flags & NOBLOCK)) (void) fcntl(fd, F_SETFL, fcntl_flags | NOBLOCK); in S_bytevector_read_nb()
561 if (!(fcntl_flags & NOBLOCK)) (void) fcntl(fd, F_SETFL, fcntl_flags); in S_bytevector_read_nb()
720 return Sboolean(NOBLOCK & fcntl_flags); in S_get_fd_non_blocking()
744 if (fcntl_flags & NOBLOCK) { in S_set_fd_non_blocking()
747 if (0 == fcntl(fd, F_SETFL, fcntl_flags | NOBLOCK)) { in S_set_fd_non_blocking()
752 if (!(fcntl_flags & NOBLOCK)) { in S_set_fd_non_blocking()
755 if (0 == fcntl(fd, F_SETFL, fcntl_flags & ~NOBLOCK)) { in S_set_fd_non_blocking()
|
| /dports/net/py-pyzmq/pyzmq-22.3.0/perf/ |
| H A D | perf.py | 82 block = zmq.NOBLOCK if poll else 0
112 block = zmq.NOBLOCK if poll else 0
165 flags = zmq.NOBLOCK if poll else 0
198 flags = zmq.NOBLOCK if poll else 0
|
| /dports/net/py-pyzmq/pyzmq-22.3.0/zmq/green/ |
| H A D | core.py | 214 if flags & zmq.NOBLOCK:
222 flags |= zmq.NOBLOCK
248 if flags & zmq.NOBLOCK:
256 flags |= zmq.NOBLOCK
|
| /dports/devel/py-curio/curio-1.5/examples/ |
| H A D | curio_zmq.py | 87 return super().send(data, flags | zmq.NOBLOCK, copy, track)
94 return super().recv(flags | zmq.NOBLOCK, copy, track)
|
| /dports/games/manaplus/manaplus-2.1.3.17/src/enums/input/ |
| H A D | inputcondition.h | 50 NOBLOCK = 262144U, // no blocked move (trick dead) enumerator
|
| /dports/net-mgmt/pmacct/pmacct-1.7.5/telemetry/decoders/v3/zmq_modules/ |
| H A D | zmq_exporter.py | 37 self.flags = zmq.NOBLOCK
|
| /dports/editors/picpas/PicPas-7940bc3/txpres/Demo6 - IDE con compilador a ASM8086/pas32v25/INC/ |
| H A D | DPMI.INC | 29 .NOBLOCK
|
| /dports/games/wizznic/Wizznic-1.1/src/ |
| H A D | defs.h | 107 #define NOBLOCK 0 macro
|
| /dports/finance/py-python-obelisk/python-obelisk-0.1.3/obelisk/ |
| H A D | zmq_fallback.py | 31 data = self._socket.recv(flags=zmq.NOBLOCK)
|
| /dports/devel/py-spyder/spyder-3.2.7/spyder/utils/introspection/ |
| H A D | plugin_client.py | 171 resp = self.socket.recv_pyobj(flags=zmq.NOBLOCK)
193 self.socket.send_pyobj(obj, zmq.NOBLOCK)
|
| /dports/shells/pdksh/pdksh-5.2.14/ |
| H A D | tree.h | 7 #define NOBLOCK ((struct op *)NULL) macro
|
| /dports/multimedia/openshot/openshot-qt-2.6.1/src/classes/ |
| H A D | logger_libopenshot.py | 91 msg = self.socket.recv(zmq.NOBLOCK)
|
| /dports/lang/mit-scheme/mit-scheme-9.2/src/microcode/ |
| H A D | uxsig.c | 247 #define NOBLOCK 2 macro
335 defsignal (SIGKILL, "SIGKILL", dfl_terminate, (NOIGNORE | NOBLOCK | NOCATCH)); in initialize_signal_descriptors()
349 defsignal (SIGSTOP, "SIGSTOP", dfl_stop, (NOIGNORE | NOBLOCK | NOCATCH)); in initialize_signal_descriptors()
351 defsignal (SIGCONT, "SIGCONT", dfl_ignore, (NOIGNORE | NOBLOCK)); in initialize_signal_descriptors()
|
| /dports/sysutils/py-salt/salt-3004.1/tests/pytests/functional/logging/handlers/ |
| H A D | test_logstash_mod.py | 80 received_log = zmq_server.recv(zmq.NOBLOCK)
|
| /dports/net/py-pyzmq/pyzmq-22.3.0/zmq/backend/cython/ |
| H A D | socket.pyx | 723 With flags=NOBLOCK, this raises :class:`ZMQError` if the queue is full;
733 0, NOBLOCK, SNDMORE, or NOBLOCK|SNDMORE.
756 if NOBLOCK is set and the outgoing queue is full).
786 With flags=NOBLOCK, this raises :class:`ZMQError` if no messages have
793 0 or NOBLOCK.
812 NOBLOCK is set and no new messages have arrived).
|