| /dports/net-p2p/bitmark/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/examples/ |
| H A D | ppworker.go | 26 // Helper function that returns a new configured socket
27 // connected to the Paranoid Pirate queue
29 func s_worker_socket() (*zmq.Socket, *zmq.Poller) {
43 // We have a single task, which implements the worker side of the
62 break // Interrupted
|
| /dports/net-p2p/bitmark-daemon/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/examples/ |
| H A D | ppqueue.go | 25 type worker_t struct { struct
26 identity string // Identity of worker
27 id_string string // Printable identity
28 expire time.Time // Expires at this time
42 func s_worker_ready(self worker_t, workers []worker_t) []worker_t {
61 func s_workers_purge(workers []worker_t) []worker_t {
|
| /dports/net-p2p/bitmark-recorder/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/examples/ |
| H A D | ppqueue.go | 25 type worker_t struct { struct
26 identity string // Identity of worker
27 id_string string // Printable identity
28 expire time.Time // Expires at this time
42 func s_worker_ready(self worker_t, workers []worker_t) []worker_t {
61 func s_workers_purge(workers []worker_t) []worker_t {
|
| /dports/net-p2p/bitmark-cli/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/examples/ |
| H A D | ppqueue.go | 25 type worker_t struct { struct
26 identity string // Identity of worker
27 id_string string // Printable identity
28 expire time.Time // Expires at this time
42 func s_worker_ready(self worker_t, workers []worker_t) []worker_t {
61 func s_workers_purge(workers []worker_t) []worker_t {
|
| /dports/net/aprsc/aprsc-2.1.10.gd72a17c/src/ |
| H A D | worker.h | 427 struct worker_t { struct
428 struct worker_t *next; argument
429 struct worker_t **prevp; argument
431 int id; /* sequential id for thread */
432 pthread_t th; /* the thread itself */
434 int shutting_down; /* should I shut down? */
459 struct pbuf_t *pbuf_incoming_local;
460 struct pbuf_t **pbuf_incoming_local_last;
463 struct pbuf_t *pbuf_incoming;
464 struct pbuf_t **pbuf_incoming_last;
[all …]
|
| /dports/net/arataga/so5extra-v.1.4.1/dev/sample/so_5_extra/mboxes/round_robin/simple/ |
| H A D | main.cpp | 10 class worker_t final : public so_5::agent_t class
13 worker_t( in worker_t() function in worker_t
|
| /dports/graphics/mupdf/mupdf-1.18.0-source/source/tools/ |
| H A D | muraster.c | 353 typedef struct worker_t { struct
368 } worker_t; argument
|
| H A D | mudraw.c | 268 typedef struct worker_t { struct
285 } worker_t; argument
|
| /dports/net/arataga/so5extra-v.1.4.1/dev/sample/so_5_extra/mboxes/broadcast/simple/ |
| H A D | main.cpp | 14 class worker_t final : public so_5::agent_t class
20 worker_t( context_t ctx, std::string name ) in worker_t() function in worker_t
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/testing/v1/inline_ns/ |
| H A D | main.cpp | 10 class worker_t final : public so_5::agent_t class
19 worker_t( context_t ctx, const so_5::mbox_t & control_mbox ) in worker_t() function in worker_t
|
| /dports/net/arataga/so5extra-v.1.4.1/dev/sample/so_5_extra/shutdowner/simple/ |
| H A D | main.cpp | 79 class worker_t final : public so_5::agent_t class
91 worker_t( in worker_t() function in worker_t
|
| /dports/devel/valgrind-lts/valgrind-dragonfly-dragonfly/none/tests/darwin/ |
| H A D | bug228343.c | 11 typedef void *(*worker_t)(void*); typedef
|
| /dports/devel/valgrind/valgrind-dragonfly-dragonfly/none/tests/darwin/ |
| H A D | bug228343.c | 11 typedef void *(*worker_t)(void*); typedef
|
| /dports/textproc/the_silver_searcher/the_silver_searcher-2.2.0/src/ |
| H A D | main.c | 34 } worker_t; typedef
|
| /dports/math/e-antic/e-antic-1.0.0-rc.13/libeantic/upstream/antic/fmpz_poly/ |
| H A D | taylor_shift_divconquer.c | 27 worker_t; typedef
|
| /dports/math/e-antic/flint2-ae7ec89/fmpz_poly/ |
| H A D | taylor_shift_divconquer.c | 27 worker_t; typedef
|
| /dports/math/flint2/flint-2.8.4/fmpz_poly/ |
| H A D | taylor_shift_divconquer.c | 27 worker_t; typedef
|
| /dports/math/cppad/CppAD-20210000.8/example/multi_thread/bthread/ |
| H A D | a11c_bthread.cpp | 43 class worker_t class
|
| /dports/lang/gcc12-devel/gcc-12-20211205/libsanitizer/lsan/ |
| H A D | lsan_mac.cpp | 59 typedef void *(*worker_t)(void *block); typedef
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/llvm/compiler-rt/lib/lsan/ |
| H A D | lsan_mac.cpp | 59 typedef void *(*worker_t)(void *block); typedef
|
| /dports/devel/tinygo/tinygo-0.14.1/lib/compiler-rt/lib/lsan/ |
| H A D | lsan_mac.cc | 60 typedef void *(*worker_t)(void *block); typedef
|
| /dports/lang/gcc8/gcc-8.5.0/libsanitizer/lsan/ |
| H A D | lsan_mac.cc | 58 typedef void *(*worker_t)(void *block); typedef
|
| /dports/devel/wasi-libcxx/llvm-project-13.0.1.src/compiler-rt/lib/lsan/ |
| H A D | lsan_mac.cpp | 59 typedef void *(*worker_t)(void *block); typedef
|
| /dports/lang/gcc10/gcc-10.3.0/libsanitizer/lsan/ |
| H A D | lsan_mac.cpp | 59 typedef void *(*worker_t)(void *block); typedef
|
| /dports/devel/riscv64-none-elf-gcc/gcc-8.4.0/libsanitizer/lsan/ |
| H A D | lsan_mac.cc | 58 typedef void *(*worker_t)(void *block); typedef
|