| /dports/devel/xeus/xeus-0.24.4/include/xeus/ |
| H A D | xserver.hpp | 35 using listener = std::function<void(zmq::multipart_t&)>;
36 using internal_listener = std::function<zmq::multipart_t(zmq::multipart_t&)>;
48 void send_shell(zmq::multipart_t& message);
49 void send_control(zmq::multipart_t& message);
50 void send_stdin(zmq::multipart_t& message);
51 void publish(zmq::multipart_t& message, channel c);
53 void start(zmq::multipart_t& message);
67 void notify_shell_listener(zmq::multipart_t& message);
69 void notify_stdin_listener(zmq::multipart_t& message);
70 zmq::multipart_t notify_internal_listener(zmq::multipart_t& message);
[all …]
|
| H A D | xserver_zmq.hpp | 40 void send_shell_impl(zmq::multipart_t& message) override;
41 void send_control_impl(zmq::multipart_t& message) override;
42 void send_stdin_impl(zmq::multipart_t& message) override;
43 void publish_impl(zmq::multipart_t& message, channel c) override;
45 void start_impl(zmq::multipart_t& message) override;
|
| H A D | xmessage.hpp | 56 void deserialize(zmq::multipart_t& wire_msg, const xauthentication& auth);
57 void serialize(zmq::multipart_t& wire_msg,
95 void deserialize(zmq::multipart_t& wire_msg, const xauthentication& auth);
96 void serialize(zmq::multipart_t& wire_msg,
129 void deserialize(zmq::multipart_t& wire_msg, const xauthentication& auth);
130 void serialize(zmq::multipart_t& wire_msg,
|
| H A D | xserver_zmq_split.hpp | 49 void send_shell_impl(zmq::multipart_t& message) override;
50 void send_control_impl(zmq::multipart_t& message) override;
51 void send_stdin_impl(zmq::multipart_t& message) override;
52 void publish_impl(zmq::multipart_t& message, channel c) override;
|
| H A D | xserver_control_main.hpp | 29 void start_impl(zmq::multipart_t& message) override;
|
| H A D | xserver_shell_main.hpp | 28 void start_impl(zmq::multipart_t& message) override;
|
| /dports/devel/xeus/xeus-0.24.4/src/ |
| H A D | xserver.cpp | 25 void xserver::send_shell(zmq::multipart_t& message) in send_shell()
30 void xserver::send_control(zmq::multipart_t& message) in send_control()
35 void xserver::send_stdin(zmq::multipart_t& message) in send_stdin()
40 void xserver::publish(zmq::multipart_t& message, channel c) in publish()
45 void xserver::start(zmq::multipart_t& message) in start()
88 void xserver::notify_shell_listener(zmq::multipart_t& message) in notify_shell_listener()
93 void xserver::notify_control_listener(zmq::multipart_t& message) in notify_control_listener()
98 void xserver::notify_stdin_listener(zmq::multipart_t& message) in notify_stdin_listener()
103 zmq::multipart_t xserver::notify_internal_listener(zmq::multipart_t& message) in notify_internal_listener()
|
| H A D | xshell.cpp | 67 zmq::multipart_t wire_msg; in run()
75 zmq::multipart_t wire_msg; in run()
85 zmq::multipart_t wire_reply = p_server->notify_internal_listener(wire_msg); in run()
92 void xshell::send_shell(zmq::multipart_t& message) in send_shell()
97 void xshell::send_stdin(zmq::multipart_t& message) in send_stdin()
100 zmq::multipart_t wire_msg; in send_stdin()
105 void xshell::publish(zmq::multipart_t& message) in publish()
114 zmq::multipart_t wire_msg; in abort_queue()
126 void xshell::reply_to_controller(zmq::multipart_t& message) in reply_to_controller()
|
| H A D | xserver_zmq.cpp | 57 void xserver_zmq::send_shell_impl(zmq::multipart_t& message) in send_shell_impl()
62 void xserver_zmq::send_control_impl(zmq::multipart_t& message) in send_control_impl()
67 void xserver_zmq::send_stdin_impl(zmq::multipart_t& message) in send_stdin_impl()
70 zmq::multipart_t wire_msg; in send_stdin_impl()
75 void xserver_zmq::publish_impl(zmq::multipart_t& message, channel) in publish_impl()
80 void xserver_zmq::start_impl(zmq::multipart_t& message) in start_impl()
120 zmq::multipart_t wire_msg; in poll()
127 zmq::multipart_t wire_msg; in poll()
137 zmq::multipart_t wire_msg; in abort_queue_impl()
|
| H A D | xshell.hpp | 26 using listener = std::function<void(zmq::multipart_t&)>;
42 void send_shell(zmq::multipart_t& message);
43 void send_stdin(zmq::multipart_t& message);
44 void publish(zmq::multipart_t& message);
47 void reply_to_controller(zmq::multipart_t& message);
|
| H A D | xkernel_core.hpp | 55 zmq::multipart_t build_start_msg() const;
57 void dispatch_shell(zmq::multipart_t& wire_msg);
58 void dispatch_control(zmq::multipart_t& wire_msg);
59 void dispatch_stdin(zmq::multipart_t& wire_msg);
60 zmq::multipart_t dispatch_internal(zmq::multipart_t& wire_msg);
80 void dispatch(zmq::multipart_t& wire_msg, channel c);
115 void abort_request(zmq::multipart_t& wire_msg);
|
| H A D | xcontrol.hpp | 27 using listener = std::function<void(zmq::multipart_t&)>;
45 void send_control(zmq::multipart_t& message);
46 void publish(zmq::multipart_t& message);
|
| H A D | xserver_zmq_split.cpp | 51 void xserver_zmq_split::send_shell_impl(zmq::multipart_t& message) in send_shell_impl()
56 void xserver_zmq_split::send_control_impl(zmq::multipart_t& message) in send_control_impl()
61 void xserver_zmq_split::send_stdin_impl(zmq::multipart_t& message) in send_stdin_impl()
66 void xserver_zmq_split::publish_impl(zmq::multipart_t& message, channel c) in publish_impl()
|
| H A D | xkernel_core.cpp | 91 zmq::multipart_t xkernel_core::build_start_msg() const in build_start_msg()
93 zmq::multipart_t start_msg; in build_start_msg()
110 void xkernel_core::dispatch_shell(zmq::multipart_t& wire_msg) in dispatch_shell()
115 void xkernel_core::dispatch_control(zmq::multipart_t& wire_msg) in dispatch_control()
120 void xkernel_core::dispatch_stdin(zmq::multipart_t& wire_msg) in dispatch_stdin()
139 zmq::multipart_t xkernel_core::dispatch_internal(zmq::multipart_t& wire_msg) in dispatch_internal()
153 zmq::multipart_t wire_msg; in publish_message()
169 zmq::multipart_t wire_msg; in send_stdin()
201 void xkernel_core::dispatch(zmq::multipart_t& wire_msg, channel c) in dispatch()
427 zmq::multipart_t wire_msg; in send_reply()
[all …]
|
| H A D | xcontrol.cpp | 61 zmq::multipart_t wire_msg; in run()
75 void xcontrol::send_control(zmq::multipart_t& message) in send_control()
80 void xcontrol::publish(zmq::multipart_t& message) in publish()
|
| H A D | xmessage.cpp | 62 void xmessage_base::deserialize(zmq::multipart_t& wire_msg, const xauthentication& auth) in deserialize()
87 void xmessage_base::serialize(zmq::multipart_t& wire_msg, in serialize()
153 void xmessage::deserialize(zmq::multipart_t& wire_msg, const xauthentication& auth) in deserialize()
173 void xmessage::serialize(zmq::multipart_t& wire_msg, in serialize()
205 void xpub_message::deserialize(zmq::multipart_t& wire_msg, const xauthentication& auth) in deserialize()
213 void xpub_message::serialize(zmq::multipart_t& wire_msg, in serialize()
|
| H A D | xtrivial_messenger.cpp | 29 zmq::multipart_t wire_msg(message.dump()); in send_to_shell_impl()
30 zmq::multipart_t wire_rep = p_server->notify_internal_listener(wire_msg); in send_to_shell_impl()
|
| H A D | xheartbeat.cpp | 52 zmq::multipart_t wire_msg; in run()
60 zmq::multipart_t wire_msg; in run()
|
| H A D | xpublisher.cpp | 56 zmq::multipart_t wire_msg; in run()
64 zmq::multipart_t wire_msg; in run()
|
| H A D | xzmq_messenger.cpp | 61 zmq::multipart_t wire_msg(message.dump()); in send_to_shell_impl()
63 zmq::multipart_t wire_reply; in send_to_shell_impl()
|
| H A D | xserver_control_main.cpp | 31 void xserver_control_main::start_impl(zmq::multipart_t& message) in start_impl()
|
| H A D | xserver_shell_main.cpp | 32 void xserver_shell_main::start_impl(zmq::multipart_t& message) in start_impl()
|
| /dports/net/cppzmq/cppzmq-4.8.1/tests/ |
| H A D | multipart.cpp | 8 zmq::multipart_t *,
13 zmq::multipart_t *,
42 multipart_t multipart;
66 multipart_t copy = multipart.clone();
87 multipart_t emptyMessage1 {};
88 multipart_t emptyMessage2 {};
158 multipart_t head("One", 3);
166 multipart_t tmp(message_t("Fifty", 5));
169 multipart_t mid = multipart_t::create(49.0f);
174 multipart_t merged(std::move(mid));
[all …]
|
| H A D | codec_multipart.cpp | 10 multipart_t mmsg;
14 multipart_t mmsg2;
24 multipart_t mmsg;
33 multipart_t mmsg2;
48 multipart_t mmsg;
71 multipart_t::decode(wrong_size),
85 multipart_t::decode(wrong_size),
178 multipart_t mmsg;
188 multipart_t mmsg2;
198 multipart_t mmsg;
[all …]
|
| /dports/net/cppzmq/cppzmq-4.8.1/ |
| H A D | zmq_addon.hpp | 316 class multipart_t class
331 multipart_t() {} in multipart_t() function in zmq::multipart_t
346 multipart_t(multipart_t &&other) { m_parts = std::move(other.m_parts); } in multipart_t() function in zmq::multipart_t
349 multipart_t &operator=(multipart_t &&other) in operator =()
437 void prepend(multipart_t &&other) in prepend()
444 void append(multipart_t &&other) in append()
567 multipart_t multipart; in create()
573 multipart_t clone() const in clone()
575 multipart_t multipart; in clone()
649 multipart_t tmp; in decode()
[all …]
|