| /dports/devel/xeus/xeus-0.24.4/src/ |
| H A D | xauthentication.cpp | 38 zmq::message_t sign_impl(const zmq::message_t& header,
43 bool verify_impl(const zmq::message_t& signature,
44 const zmq::message_t& header,
46 const zmq::message_t& meta_data,
65 zmq::message_t sign_impl(const zmq::message_t& header,
70 bool verify_impl(const zmq::message_t& signature,
71 const zmq::message_t& header,
77 zmq::message_t xauthentication::sign(const zmq::message_t& header, in sign()
149 zmq::message_t openssl_xauthentication::sign_impl(const zmq::message_t& header, in sign_impl()
191 zmq::message_t no_xauthentication::sign_impl(const zmq::message_t& /*header*/, in sign_impl() argument
[all …]
|
| H A D | xmessage.cpp | 28 void parse_zmq_message(const zmq::message_t& msg, nl::json& json) in parse_zmq_message()
37 return zmq::message_t(buffer.c_str(), buffer.size()); in write_zmq_message()
50 bool xmessage_base::is_delimiter(zmq::message_t& frame) const in is_delimiter()
64 zmq::message_t signature = wire_msg.pop(); in deserialize()
65 zmq::message_t header = wire_msg.pop(); in deserialize()
66 zmq::message_t parent_header = wire_msg.pop(); in deserialize()
67 zmq::message_t metadata = wire_msg.pop(); in deserialize()
68 zmq::message_t content = wire_msg.pop(); in deserialize()
107 for (zmq::message_t& buffer : m_buffers) in serialize()
155 zmq::message_t frame = wire_msg.pop(); in deserialize()
[all …]
|
| /dports/mail/cyrus-imapd34/cyrus-imapd-3.4.2/imap/ |
| H A D | message.h | 222 typedef struct message message_t; typedef
276 extern message_t *message_new(void);
288 message_t *m);
296 message_t *m);
303 extern message_t *message_ref(message_t *m);
304 extern void message_unref(message_t **m);
345 extern int message_foreach_section(message_t *m,
362 extern uint32_t msg_size(const message_t *m);
363 extern uint32_t msg_uid(const message_t *m);
365 extern modseq_t msg_modseq(const message_t *m);
[all …]
|
| /dports/mail/cyrus-imapd32/cyrus-imapd-3.2.8/imap/ |
| H A D | message.h | 208 typedef struct message message_t; typedef
262 extern message_t *message_new(void);
274 message_t *m);
282 message_t *m);
289 extern message_t *message_ref(message_t *m);
290 extern void message_unref(message_t **m);
328 extern int message_foreach_section(message_t *m,
344 extern uint32_t msg_size(const message_t *m);
345 extern uint32_t msg_uid(const message_t *m);
347 extern modseq_t msg_modseq(const message_t *m);
[all …]
|
| /dports/mail/cyrus-imapd30/cyrus-imapd-3.0.16/imap/ |
| H A D | message.h | 199 typedef struct message message_t; typedef
248 extern message_t *message_new(void);
260 extern message_t *message_ref(message_t *m);
261 extern void message_unref(message_t **m);
269 extern int message_get_charset(message_t *m, int *csp);
297 extern int message_foreach_section(message_t *m,
311 extern uint32_t msg_size(const message_t *m);
312 extern uint32_t msg_uid(const message_t *m);
313 extern conversation_id_t msg_cid(const message_t *m);
314 extern modseq_t msg_modseq(const message_t *m);
[all …]
|
| /dports/net/cppzmq/cppzmq-4.8.1/tests/ |
| H A D | message.cpp | 27 zmq::message_t message1;
84 zmq::message_t msg(buf);
113 zmq::message_t hi_msg(zmq::message_t(data, strlen(data)));
118 zmq::message_t hi_msg;
135 zmq::message_t hi_msg;
184 const zmq::message_t a;
203 zmq::message_t msg;
210 zmq::message_t msg;
219 zmq::message_t msg;
227 zmq::message_t msg2;
[all …]
|
| H A D | send_multipart.cpp | 16 std::vector<zmq::message_t> imsgs;
22 std::array<zmq::message_t, 1> imsgs = {zmq::message_t(3)};
27 std::vector<zmq::message_t> omsgs;
35 std::array<zmq::message_t, 2> imsgs = {zmq::message_t(3), zmq::message_t(4)};
40 std::vector<zmq::message_t> omsgs;
55 std::vector<zmq::message_t> omsgs;
71 std::vector<zmq::message_t> omsgs;
83 std::array<zmq::message_t, 2> imsgs = {zmq::message_t(3), zmq::message_t(4)};
88 std::vector<zmq::message_t> msgs_vec;
95 std::forward_list<zmq::message_t> msgs_list;
[all …]
|
| H A D | recv_multipart.cpp | 16 std::vector<zmq::message_t> msgs;
27 std::vector<zmq::message_t> msgs;
36 std::vector<zmq::message_t> msgs;
45 std::vector<zmq::message_t> msgs;
52 std::vector<zmq::message_t> msgs;
70 std::array<zmq::message_t, 1> msgs;
79 std::array<zmq::message_t, 2> msgs;
90 std::array<zmq::message_t, 1> msgs;
99 std::array<zmq::message_t, 1> msgs;
108 std::array<zmq::message_t, 2> msgs;
[all …]
|
| /dports/devel/xeus/xeus-0.24.4/include/xeus/ |
| H A D | xauthentication.hpp | 33 zmq::message_t sign(const zmq::message_t& header,
34 const zmq::message_t& parent_header,
35 const zmq::message_t& meta_data,
36 const zmq::message_t& content) const;
38 bool verify(const zmq::message_t& signature,
39 const zmq::message_t& header,
40 const zmq::message_t& parent_header,
41 const zmq::message_t& meta_data,
42 const zmq::message_t& content) const;
50 virtual zmq::message_t sign_impl(const zmq::message_t& header,
[all …]
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/so_5/ |
| H A D | message.cpp | 14 message_t::message_t() in message_t() function in so_5::message_t
19 message_t::message_t( const message_t & other ) in message_t() function in so_5::message_t
25 message_t::message_t( message_t && other ) in message_t() function in so_5::message_t
31 message_t &
32 message_t::operator=( const message_t & other ) in operator =()
38 message_t &
39 message_t::operator=( message_t && other ) in operator =()
|
| H A D | message.hpp | 57 message_t();
58 message_t( const message_t & other );
59 message_t( message_t && other );
61 message_t &
62 operator=( const message_t & other );
63 message_t &
64 operator=( message_t && other );
133 message_t & what, in change_message_mutability()
178 const message_t & what ) in message_kind()
289 : public message_t
[all …]
|
| /dports/mail/libspamtest/libspamtest/ |
| H A D | msgstore.h | 99 } message_t; typedef
135 message_t *message_init(void);
140 void message_free(message_t *msg);
149 void message_clean_rcpt(message_t *msg);
163 long get_message_bodysize(message_t *msgt);
164 int get_message_bodychunks_count(message_t *msgt);
172 char *get_message_from(message_t *msg);
175 char *get_message_ip(message_t *msg);
178 int get_message_nrcpt(message_t*);
180 char *get_message_rcpt(message_t *msg, int i);
[all …]
|
| /dports/security/ophcrack/ophcrack-3.8.0/src/core/ |
| H A D | fsm.h | 76 message_t *fsm_next(fsm_t *fsm, message_t *msg);
79 message_t *fsm_handle_preload(fsm_t *fsm, message_t *msg);
80 message_t *fsm_handle_pause1(fsm_t *fsm, message_t *msg);
81 message_t *fsm_handle_pause2(fsm_t *fsm, message_t *msg);
82 message_t *fsm_handle_work1(fsm_t *fsm, message_t *msg);
83 message_t *fsm_handle_work2(fsm_t *fsm, message_t *msg);
|
| H A D | message.c | 70 message_t *message_alloc(msg_kind_t kind) { in message_alloc()
73 message_t *msg = (message_t*)malloc(sizeof(message_t)); in message_alloc()
84 void message_free(message_t *msg) { in message_free()
119 void message_add(message_t *msg) { in message_add()
131 message_t *msg = list_rem_tail(messages); in message_insert_first()
140 message_t *message_get(void) { in message_get()
144 message_t *msg = list_rem_head(msg_queue); in message_get()
150 message_t *message_tryget(void) { in message_tryget()
152 message_t *msg = 0; in message_tryget()
164 message_t *msg = message_alloc(msg_done); in message_done()
[all …]
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/so_5/impl/ |
| H A D | enveloped_msg_details.hpp | 115 case message_t::kind_t::signal : [[fallthrough]]; in invoke()
116 case message_t::kind_t::classical_message : [[fallthrough]]; in invoke()
117 case message_t::kind_t::user_type_message : in invoke()
124 case message_t::kind_t::enveloped_msg : in invoke()
140 message_t::kind_t msg_kind ) noexcept in demand_handler_for_invocation_type()
145 case message_t::kind_t::signal : [[fallthrough]]; in demand_handler_for_invocation_type()
147 case message_t::kind_t::user_type_message : in demand_handler_for_invocation_type()
151 case message_t::kind_t::enveloped_msg : in demand_handler_for_invocation_type()
194 case message_t::kind_t::signal : [[fallthrough]]; in invoke()
196 case message_t::kind_t::user_type_message : in invoke()
[all …]
|
| /dports/net/cppzmq/cppzmq-4.8.1/ |
| H A D | zmq_addon.hpp | 50 message_t msg; in recv_multipart_n()
220 message_t encode(const Range &parts) in encode()
236 message_t encoded(mmsg_size); in encode()
295 *out = message_t(source, part_size); in decode()
319 std::deque<message_t> m_parts;
401 message_t message; in recv()
421 message_t message = pop(); in send()
459 m_parts.push_back(message_t(src, size)); in addmem()
521 message_t pop() in pop()
529 message_t remove() in remove()
[all …]
|
| /dports/mail/esmtp/esmtp-1.2/ |
| H A D | message.h | 52 } message_t; typedef
55 message_t *message_new(void);
58 void message_free(message_t *m);
60 void message_set_reverse_path(message_t *message, const char *address);
62 void message_add_recipient(message_t *message, const char *address);
64 void message_set_envid(message_t *message, const char *address);
66 unsigned message_parse_headers(message_t *message);
68 size_t message_read(message_t *message, char *ptr, size_t size);
70 int message_eof(message_t *message);
|
| H A D | message.c | 20 message_t *message_new(void) in message_new()
22 message_t *message; in message_new()
24 message = (message_t *)xmalloc(sizeof(message_t)); in message_new()
26 memset(message, 0, sizeof(message_t)); in message_new()
38 void message_free(message_t *message) in message_free()
89 void message_set_envid(message_t *message, const char *address) in message_set_envid()
114 static void message_buffer_alloc(message_t *message) in message_buffer_alloc()
130 static char *message_buffer_readline(message_t *message) in message_buffer_readline()
151 static void message_buffer_fill(message_t *message) in message_buffer_fill()
253 int message_eof(message_t *message) in message_eof()
[all …]
|
| /dports/net/arataga/oess-2.2.3/doxygen/dox/ |
| H A D | stdsn_shptr.dox | 51 {type comm_protocol::message_t
104 class message_t :
107 OESS_SERIALIZER( message_t )
109 message_t()
114 virtual ~message_t()
142 message_t( const message_t & );
143 message_t &
144 operator=( const message_t & );
276 OESS_SERIALIZER( message_t )
303 OESS_SERIALIZER( message_t )
[all …]
|
| /dports/audio/gtick/gtick-0.5.5/src/ |
| H A D | threadtalk.c | 65 message_t* message; in comm_client_query()
67 message = (message_t*) g_malloc (sizeof(message_t)); in comm_client_query()
80 message_t* message = (message_t*) g_async_queue_try_pop(comm->client); in comm_client_try_get_reply()
117 message_t* message = (message_t*) g_async_queue_try_pop(comm->server); in comm_server_try_get_query()
135 message_t* message; in comm_server_send_response()
137 message = (message_t*) g_malloc (sizeof(message_t)); in comm_server_send_response()
|
| /dports/games/simutrans/simutrans-121.0/gui/ |
| H A D | message_frame_t.cc | 30 (1 << message_t::chat),
31 (1 << message_t::scenario),
32 (1 << message_t::problems),
33 (1 << message_t::traffic_jams) | (1 << message_t::warnings),
34 (1 << message_t::full),
35 (1 << message_t::city) | (1 << message_t::industry),
36 (1 << message_t::ai),
37 (1 << message_t::general) | (1 << message_t::new_vehicle)
|
| /dports/devel/sobjectizer/sobjectizer-v.5.7.2.5/dev/test/so_5/event_handler/deadletter_handler_formats/ |
| H A D | main.cpp | 10 struct msg_1 final : public so_5::message_t {};
11 struct msg_2 final : public so_5::message_t {};
12 struct msg_3 final : public so_5::message_t {};
13 struct msg_4 final : public so_5::message_t {};
14 struct msg_5 final : public so_5::message_t {};
15 struct msg_6 final : public so_5::message_t {};
16 struct msg_7 final : public so_5::message_t {};
17 struct msg_8 final : public so_5::message_t {};
18 struct msg_9 final : public so_5::message_t {};
19 struct msg_10 final : public so_5::message_t {};
[all …]
|
| /dports/devel/upp/upp/bazaar/ZMQ/lib/include/ |
| H A D | zmq.hpp | 71 class message_t : private zmq_msg_t class
77 inline message_t () in message_t() function in zmq::message_t
84 inline message_t (size_t size_) in message_t() function in zmq::message_t
91 inline message_t (void *data_, size_t size_, free_fn *ffn_, in message_t() function in zmq::message_t
99 inline ~message_t () in ~message_t()
136 inline void move (message_t *msg_) in move()
143 inline void copy (message_t *msg_) in copy()
164 message_t (const message_t&);
165 void operator = (const message_t&);
255 inline bool send (message_t &msg_, int flags_ = 0) in send()
[all …]
|
| /dports/audio/umurmur/umurmur-0.2.17/src/ |
| H A D | messages.h | 141 } message_t; typedef
144 int Msg_messageToNetwork(message_t *msg, uint8_t *buffer);
145 message_t *Msg_networkToMessage(uint8_t *data, int size);
146 void Msg_free(message_t *msg);
147 void Msg_inc_ref(message_t *msg);
149 message_t *Msg_CreateVoiceMsg(uint8_t *data, int size);
150 message_t *Msg_create(messageType_t messageType);
151 void Msg_banList_addEntry(message_t *msg, int index, uint8_t *address, uint32_t mask,
153 void Msg_banList_getEntry(message_t *msg, int index, uint8_t **address, uint32_t *mask,
155 message_t *Msg_banList_create(int n_bans);
|
| /dports/net/libzmq2/zeromq-2.2.0/include/ |
| H A D | zmq.hpp | 99 class message_t : private zmq_msg_t class
105 inline message_t () in message_t() function in zmq::message_t
112 inline message_t (size_t size_) in message_t() function in zmq::message_t
119 inline message_t (void *data_, size_t size_, free_fn *ffn_, in message_t() function in zmq::message_t
127 inline ~message_t () in ~message_t()
164 inline void move (message_t *msg_) in move()
171 inline void copy (message_t *msg_) in copy()
192 message_t (const message_t&);
193 void operator = (const message_t&);
319 inline bool send (message_t &msg_, int flags_ = 0) in send()
[all …]
|