Home
last modified time | relevance | path

Searched refs:msg_t (Results 1 – 25 of 931) sorted by relevance

12345678910>>...38

/dports/net/freeswitch/freeswitch-1.10.3.-release/libs/sofia-sip/libsofia-sip-ua/msg/sofia-sip/
H A Dmsg.h43 SOFIAPUBFUN void msg_destroy(msg_t *);
45 SOFIAPUBFUN msg_t *msg_copy(msg_t *);
46 SOFIAPUBFUN msg_t *msg_dup(msg_t const *);
51 msg_t *msg, msg_pub_t *pub, int flags,
54 SOFIAPUBFUN void msg_set_parent(msg_t *kid, msg_t *dad);
56 SOFIAPUBFUN msg_t *msg_ref_create(msg_t *);
57 SOFIAPUBFUN void msg_ref_destroy(msg_t *);
63 SOFIAPUBFUN int msg_extract(msg_t *msg);
70 SOFIAPUBFUN int msg_prepare(msg_t *msg);
71 SOFIAPUBFUN void msg_unprepare(msg_t *msg);
[all …]
H A Dmsg_addr.h47 SOFIAPUBFUN void msg_addr_zero(msg_t *msg);
48 SOFIAPUBFUN su_addrinfo_t *msg_addrinfo(msg_t *msg);
50 SOFIAPUBFUN su_sockaddr_t *msg_addr(msg_t *msg);
55 SOFIAPUBFUN void msg_addr_copy(msg_t *dst, msg_t const *src);
57 SOFIAPUBFUN int msg_errno(msg_t const *msg);
58 SOFIAPUBFUN void msg_set_errno(msg_t *msg, int err);
78 SOFIAPUBFUN issize_t msg_recv_iovec(msg_t *msg,
85 SOFIAPUBFUN msg_t *msg_next(msg_t *msg);
87 SOFIAPUBFUN int msg_set_next(msg_t *msg, msg_t *next);
89 SOFIAPUBFUN void msg_clear_committed(msg_t *msg);
[all …]
H A Dmsg_buffer.h44 SOFIAPUBFUN void *msg_buf_alloc(msg_t *msg, usize_t size);
45 SOFIAPUBFUN void *msg_buf_exact(msg_t *msg, usize_t size);
46 SOFIAPUBFUN usize_t msg_buf_commit(msg_t *msg, usize_t size, int eos);
47 SOFIAPUBFUN usize_t msg_buf_committed(msg_t const *msg);
48 SOFIAPUBFUN void *msg_buf_committed_data(msg_t const *msg);
49 SOFIAPUBFUN usize_t msg_buf_size(msg_t const *msg);
51 SOFIAPUBFUN void *msg_buf_move(msg_t *dst, msg_t const *src);
53 SOFIAPUBFUN void msg_buf_set(msg_t *msg, void *b, usize_t size);
/dports/net/sofia-sip/sofia-sip-1.13.4/libsofia-sip-ua/msg/sofia-sip/
H A Dmsg.h43 SOFIAPUBFUN void msg_destroy(msg_t *);
45 SOFIAPUBFUN msg_t *msg_copy(msg_t *);
46 SOFIAPUBFUN msg_t *msg_dup(msg_t const *);
51 msg_t *msg, msg_pub_t *pub, int flags,
54 SOFIAPUBFUN void msg_set_parent(msg_t *kid, msg_t *dad);
56 SOFIAPUBFUN msg_t *msg_ref_create(msg_t *);
57 SOFIAPUBFUN void msg_ref_destroy(msg_t *);
63 SOFIAPUBFUN int msg_extract(msg_t *msg);
70 SOFIAPUBFUN int msg_prepare(msg_t *msg);
71 SOFIAPUBFUN void msg_unprepare(msg_t *msg);
[all …]
H A Dmsg_addr.h47 SOFIAPUBFUN void msg_addr_zero(msg_t *msg);
48 SOFIAPUBFUN su_addrinfo_t *msg_addrinfo(msg_t *msg);
50 SOFIAPUBFUN su_sockaddr_t *msg_addr(msg_t *msg);
55 SOFIAPUBFUN void msg_addr_copy(msg_t *dst, msg_t const *src);
57 SOFIAPUBFUN int msg_errno(msg_t const *msg);
58 SOFIAPUBFUN void msg_set_errno(msg_t *msg, int err);
78 SOFIAPUBFUN issize_t msg_recv_iovec(msg_t *msg,
85 SOFIAPUBFUN msg_t *msg_next(msg_t *msg);
87 SOFIAPUBFUN int msg_set_next(msg_t *msg, msg_t *next);
89 SOFIAPUBFUN void msg_clear_committed(msg_t *msg);
[all …]
H A Dmsg_buffer.h44 SOFIAPUBFUN void *msg_buf_alloc(msg_t *msg, usize_t size);
45 SOFIAPUBFUN void *msg_buf_exact(msg_t *msg, usize_t size);
46 SOFIAPUBFUN usize_t msg_buf_commit(msg_t *msg, usize_t size, int eos);
47 SOFIAPUBFUN usize_t msg_buf_committed(msg_t const *msg);
48 SOFIAPUBFUN void *msg_buf_committed_data(msg_t const *msg);
49 SOFIAPUBFUN usize_t msg_buf_size(msg_t const *msg);
51 SOFIAPUBFUN void *msg_buf_move(msg_t *dst, msg_t const *src);
53 SOFIAPUBFUN void msg_buf_set(msg_t *msg, void *b, usize_t size);
/dports/mail/qsf/qsf-1.2.7/src/tests/
H A Dmain.c16 int spam_test_gtube(opts_t, msg_t, spam_t);
17 int spam_test_attachment_scr(opts_t, msg_t, spam_t);
18 int spam_test_attachment_pif(opts_t, msg_t, spam_t);
19 int spam_test_attachment_exe(opts_t, msg_t, spam_t);
20 int spam_test_attachment_vbs(opts_t, msg_t, spam_t);
21 int spam_test_attachment_vba(opts_t, msg_t, spam_t);
22 int spam_test_attachment_lnk(opts_t, msg_t, spam_t);
23 int spam_test_attachment_com(opts_t, msg_t, spam_t);
24 int spam_test_attachment_bat(opts_t, msg_t, spam_t);
40 int spam_test_html_font(opts_t, msg_t, spam_t);
[all …]
/dports/net/libzmq4/zeromq-4.3.4/src/
H A Dmsg.cpp51 bool zmq::msg_t::check () const in check()
56 int zmq::msg_t::init (void *data_, in init()
77 int zmq::msg_t::init () in init()
206 int zmq::msg_t::init_delimiter () in init_delimiter()
217 int zmq::msg_t::init_join () in init_join()
228 int zmq::msg_t::init_leave () in init_leave()
269 int zmq::msg_t::close () in close()
332 int zmq::msg_t::move (msg_t &src_) in move()
353 int zmq::msg_t::copy (msg_t &src_) in copy()
391 void *zmq::msg_t::data () in data()
[all …]
H A Dstream_engine_base.hpp86 int next_handshake_command (msg_t *msg_);
87 int process_handshake_command (msg_t *msg_);
89 int pull_msg_from_session (msg_t *msg_);
90 int push_msg_to_session (msg_t *msg_);
92 int pull_and_encode (msg_t *msg_);
93 virtual int decode_and_push (msg_t *msg_);
94 int push_one_then_decode_and_push (msg_t *msg_);
106 virtual int produce_ping_message (msg_t *msg_) in produce_ping_message()
116 virtual int produce_pong_message (msg_t *msg_) in produce_pong_message()
187 int write_credential (msg_t *msg_);
[all …]
H A Dreq.cpp55 int zmq::req_t::xsend (msg_t *msg_) in xsend()
76 msg_t id; in xsend()
80 id.set_flags (msg_t::more); in xsend()
88 msg_t bottom; in xsend()
91 bottom.set_flags (msg_t::more); in xsend()
105 msg_t drop; in xsend()
131 int zmq::req_t::xrecv (msg_t *msg_) in xrecv()
183 if (!(msg_->flags () & msg_t::more)) { in xrecv()
247 int zmq::req_t::recv_reply_pipe (msg_t *msg_) in recv_reply_pipe()
273 int zmq::req_session_t::push_msg (msg_t *msg_) in push_msg()
[all …]
/dports/net/py-pyzmq/pyzmq-22.3.0/bundled/zeromq/src/
H A Dmsg.cpp51 bool zmq::msg_t::check () const in check()
56 int zmq::msg_t::init (void *data_, in init()
77 int zmq::msg_t::init () in init()
206 int zmq::msg_t::init_delimiter () in init_delimiter()
217 int zmq::msg_t::init_join () in init_join()
228 int zmq::msg_t::init_leave () in init_leave()
269 int zmq::msg_t::close () in close()
332 int zmq::msg_t::move (msg_t &src_) in move()
353 int zmq::msg_t::copy (msg_t &src_) in copy()
391 void *zmq::msg_t::data () in data()
[all …]
H A Dstream_engine_base.hpp86 int next_handshake_command (msg_t *msg_);
87 int process_handshake_command (msg_t *msg_);
89 int pull_msg_from_session (msg_t *msg_);
90 int push_msg_to_session (msg_t *msg_);
92 int pull_and_encode (msg_t *msg_);
93 virtual int decode_and_push (msg_t *msg_);
94 int push_one_then_decode_and_push (msg_t *msg_);
106 virtual int produce_ping_message (msg_t *msg_) in produce_ping_message()
116 virtual int produce_pong_message (msg_t *msg_) in produce_pong_message()
187 int write_credential (msg_t *msg_);
[all …]
H A Dreq.cpp55 int zmq::req_t::xsend (msg_t *msg_) in xsend()
76 msg_t id; in xsend()
80 id.set_flags (msg_t::more); in xsend()
88 msg_t bottom; in xsend()
91 bottom.set_flags (msg_t::more); in xsend()
105 msg_t drop; in xsend()
131 int zmq::req_t::xrecv (msg_t *msg_) in xrecv()
183 if (!(msg_->flags () & msg_t::more)) { in xrecv()
247 int zmq::req_t::recv_reply_pipe (msg_t *msg_) in recv_reply_pipe()
273 int zmq::req_session_t::push_msg (msg_t *msg_) in push_msg()
[all …]
/dports/devel/libxs/libxs-1.2.0/src/
H A Dmsg.cpp39 bool xs::msg_t::check () in check()
44 int xs::msg_t::init () in init()
98 int xs::msg_t::init_delimiter () in init_delimiter()
105 int xs::msg_t::close () in close()
138 int xs::msg_t::move (msg_t &src_) in move()
159 int xs::msg_t::copy (msg_t &src_) in copy()
189 void *xs::msg_t::data () in data()
205 size_t xs::msg_t::size () in size()
221 unsigned char xs::msg_t::flags () in flags()
236 bool xs::msg_t::is_delimiter () in is_delimiter()
[all …]
/dports/net/freeswitch/freeswitch-1.10.3.-release/libs/sofia-sip/libsofia-sip-ua/msg/
H A Dmsg.c102 msg_t *msg_ref_create(msg_t *msg) in msg_ref_create()
123 void msg_set_parent(msg_t *kid, msg_t *dad) in msg_set_parent()
126 msg_t *step_dad = kid->m_parent; in msg_set_parent()
143 void msg_ref_destroy(msg_t *ref) in msg_ref_destroy()
154 void msg_destroy(msg_t *msg) in msg_destroy()
156 msg_t *parent; in msg_destroy()
183 msg_pub_t *msg_object(msg_t const *msg) in msg_object()
243 void msg_addr_zero(msg_t *msg) in msg_addr_zero()
258 su_sockaddr_t *msg_addr(msg_t *msg) in msg_addr()
345 void msg_addr_copy(msg_t *dst, msg_t const *src) in msg_addr_copy()
[all …]
/dports/net/sofia-sip/sofia-sip-1.13.4/libsofia-sip-ua/msg/
H A Dmsg.c102 msg_t *msg_ref_create(msg_t *msg) in msg_ref_create()
123 void msg_set_parent(msg_t *kid, msg_t *dad) in msg_set_parent()
126 msg_t *step_dad = kid->m_parent; in msg_set_parent()
143 void msg_ref_destroy(msg_t *ref) in msg_ref_destroy()
154 void msg_destroy(msg_t *msg) in msg_destroy()
156 msg_t *parent; in msg_destroy()
183 msg_pub_t *msg_object(msg_t const *msg) in msg_object()
243 void msg_addr_zero(msg_t *msg) in msg_addr_zero()
258 su_sockaddr_t *msg_addr(msg_t *msg) in msg_addr()
345 void msg_addr_copy(msg_t *dst, msg_t const *src) in msg_addr_copy()
[all …]
/dports/mail/qsf/qsf-1.2.7/src/include/
H A Dmessage.h17 typedef struct msg_s *msg_t; typedef
45 msg_t msg_parse(opts_t);
46 void msg_spamsubject(msg_t, char *);
47 void msg_spamheader(msg_t, char *, double);
49 void msg_spamlevelheader(msg_t, double, double);
50 void msg_dump(msg_t);
51 void msg_free(msg_t);
57 int msg_addcontent(opts_t, msg_t, char *, long);
58 msg_t msg_alloc(opts_t);
59 int msg_read(opts_t, msg_t);
[all …]
/dports/lang/mit-scheme/mit-scheme-9.2/src/microcode/
H A Dos2msg.h122 } msg_t; typedef
124 #define _MSG(m) ((msg_t *) (m))
141 typedef msg_t * (* qid_receive_filter_t) (msg_t *);
159 extern void OS2_destroy_message (msg_t *);
160 extern void OS2_send_message (qid_t, msg_t *);
161 extern msg_t * OS2_receive_message (qid_t, int, int);
164 extern msg_t * OS2_message_transaction (qid_t, msg_t *, msg_type_t);
165 extern void OS2_unread_message (qid_t, msg_t *);
195 typedef msg_t sm_timer_event_t;
196 typedef msg_t sm_init_t;
[all …]
/dports/games/ioquake3-server/ioquake3-1.36/code/qcommon/
H A Dqcommon.h51 } msg_t; typedef
55 void MSG_Clear (msg_t *buf);
57 void MSG_Bitstream( msg_t *buf );
63 void MSG_Copy(msg_t *buf, byte *data, int length, msg_t *src);
80 void MSG_BeginReading (msg_t *sb);
85 int MSG_ReadChar (msg_t *sb);
86 int MSG_ReadByte (msg_t *sb);
87 int MSG_ReadShort (msg_t *sb);
88 int MSG_ReadLong (msg_t *sb);
89 float MSG_ReadFloat (msg_t *sb);
[all …]
/dports/games/ioquake3/ioquake3-1.36/code/qcommon/
H A Dqcommon.h51 } msg_t; typedef
55 void MSG_Clear (msg_t *buf);
57 void MSG_Bitstream( msg_t *buf );
63 void MSG_Copy(msg_t *buf, byte *data, int length, msg_t *src);
80 void MSG_BeginReading (msg_t *sb);
85 int MSG_ReadChar (msg_t *sb);
86 int MSG_ReadByte (msg_t *sb);
87 int MSG_ReadShort (msg_t *sb);
88 int MSG_ReadLong (msg_t *sb);
89 float MSG_ReadFloat (msg_t *sb);
[all …]
/dports/games/evq3/evq3/code/qcommon/
H A Dqcommon.h51 } msg_t; typedef
55 void MSG_Clear (msg_t *buf);
57 void MSG_Bitstream( msg_t *buf );
63 void MSG_Copy(msg_t *buf, byte *data, int length, msg_t *src);
80 void MSG_BeginReading (msg_t *sb);
85 int MSG_ReadChar (msg_t *sb);
86 int MSG_ReadByte (msg_t *sb);
87 int MSG_ReadShort (msg_t *sb);
88 int MSG_ReadLong (msg_t *sb);
89 float MSG_ReadFloat (msg_t *sb);
[all …]
/dports/games/worldofpadman/worldofpadman-1.2.20080621/code/qcommon/
H A Dqcommon.h51 } msg_t; typedef
55 void MSG_Clear (msg_t *buf);
57 void MSG_Bitstream( msg_t *buf );
63 void MSG_Copy(msg_t *buf, byte *data, int length, msg_t *src);
80 void MSG_BeginReading (msg_t *sb);
85 int MSG_ReadChar (msg_t *sb);
86 int MSG_ReadByte (msg_t *sb);
87 int MSG_ReadShort (msg_t *sb);
88 int MSG_ReadLong (msg_t *sb);
89 float MSG_ReadFloat (msg_t *sb);
[all …]
/dports/games/tremulous/tremulous/tremulous-1.1.0-src/src/qcommon/
H A Dqcommon.h52 } msg_t; typedef
56 void MSG_Clear (msg_t *buf);
58 void MSG_Bitstream( msg_t *buf );
64 void MSG_Copy(msg_t *buf, byte *data, int length, msg_t *src);
81 void MSG_BeginReading (msg_t *sb);
86 int MSG_ReadChar (msg_t *sb);
87 int MSG_ReadByte (msg_t *sb);
88 int MSG_ReadShort (msg_t *sb);
89 int MSG_ReadLong (msg_t *sb);
90 float MSG_ReadFloat (msg_t *sb);
[all …]
/dports/devel/onetbb/oneTBB-2021.4.0/test/tbb/
H A Dtest_join_node.cpp129 using msg_t = tbb::flow::continue_msg; in test_follows_and_precedes_api() typedef
130 using JoinOutputType = std::tuple<msg_t, msg_t, msg_t>; in test_follows_and_precedes_api()
132 std::array<msg_t, 3> messages_for_follows = { {msg_t(), msg_t(), msg_t()} }; in test_follows_and_precedes_api()
133 std::vector<msg_t> messages_for_precedes = {msg_t(), msg_t(), msg_t()}; in test_follows_and_precedes_api()
136 …<msg_t, tbb::flow::join_node<JoinOutputType>, tbb::flow::buffer_node<msg_t>>(messages_for_follows); in test_follows_and_precedes_api()
140 …<msg_t, tbb::flow::join_node<JoinOutputType, tbb::flow::reserving>, tbb::flow::buffer_node<msg_t>>… in test_follows_and_precedes_api()
141 auto b = [](msg_t) { return msg_t(); }; in test_follows_and_precedes_api() argument
144 std::size_t hash(msg_t) const { return 0; } in test_follows_and_precedes_api()
145 bool equal(msg_t, msg_t) const { return true; } in test_follows_and_precedes_api() argument
148 …<msg_t, tbb::flow::join_node<JoinOutputType, tbb::flow::key_matching<msg_t, hash_compare>>, tbb::f… in test_follows_and_precedes_api()
[all …]
/dports/games/openarena/openarena-engine-source-0.8.8/code/qcommon/
H A Dqcommon.h51 } msg_t; typedef
55 void MSG_Clear (msg_t *buf);
57 void MSG_Bitstream( msg_t *buf );
63 void MSG_Copy(msg_t *buf, byte *data, int length, msg_t *src);
81 void MSG_BeginReading (msg_t *sb);
86 int MSG_ReadChar (msg_t *sb);
87 int MSG_ReadByte (msg_t *sb);
88 int MSG_ReadShort (msg_t *sb);
89 int MSG_ReadLong (msg_t *sb);
90 float MSG_ReadFloat (msg_t *sb);
[all …]

12345678910>>...38