Home
last modified time | relevance | path

Searched refs:msg_ (Results 1 – 25 of 1954) sorted by relevance

12345678910>>...79

/dports/databases/xapian-core12/xapian-core-1.2.25/include/xapian/
H A Derror.h139 : Error(msg_, context_, type_, error_string_) {} in LogicError()
145 : Error(msg_, context_, type_, errno_) {} in LogicError()
161 : Error(msg_, context_, type_, error_string_) {} in RuntimeError()
167 : Error(msg_, context_, type_, errno_) {} in RuntimeError()
215 : LogicError(msg_, context_, type_, errno_) {} in AssertionError()
257 : LogicError(msg_, context_, type_, errno_) {} in InvalidArgumentError()
299 : LogicError(msg_, context_, type_, errno_) {} in InvalidOperationError()
340 : LogicError(msg_, context_, type_, errno_) {} in UnimplementedError()
381 : RuntimeError(msg_, context_, type_, errno_) {} in DatabaseError()
683 : RuntimeError(msg_, context_, type_, errno_) {} in DocNotFoundError()
[all …]
/dports/databases/xapian-core/xapian-core-1.4.18/include/xapian/
H A Derror.h160 : Error(msg_, context_, type_, error_string_) {} in LogicError()
166 : Error(msg_, context_, type_, errno_) {} in LogicError()
182 : Error(msg_, context_, type_, error_string_) {} in RuntimeError()
188 : Error(msg_, context_, type_, errno_) {} in RuntimeError()
236 : LogicError(msg_, context_, type_, errno_) {} in AssertionError()
278 : LogicError(msg_, context_, type_, errno_) {} in InvalidArgumentError()
320 : LogicError(msg_, context_, type_, errno_) {} in InvalidOperationError()
362 : LogicError(msg_, context_, type_, errno_) {} in UnimplementedError()
404 : RuntimeError(msg_, context_, type_, errno_) {} in DatabaseError()
711 : RuntimeError(msg_, context_, type_, errno_) {} in DocNotFoundError()
[all …]
/dports/devel/sdbus-cpp/sdbus-cpp-1.1.0/src/
H A DMessage.cpp46 : msg_(msg) in Message()
49 assert(msg_ != nullptr); in Message()
55 : msg_(msg) in Message()
58 assert(msg_ != nullptr); in Message()
69 if (msg_) in operator =()
72 msg_ = other.msg_; in operator =()
88 if (msg_) in operator =()
91 msg_ = other.msg_; in operator =()
92 other.msg_ = nullptr; in operator =()
103 if (msg_) in ~Message()
[all …]
/dports/net/freeswitch/freeswitch-1.10.3.-release/libs/sofia-sip/libsofia-sip-ua/msg/sofia-sip/
H A Dmsg_protos.h.in92 * msg_#xxxxxx#_t msg_#xxxxxx# = MSG_#XXXXXX#_INIT;
105 * msg_#xxxxxx#_t msg_#xxxxxx#;
107 * msg_#xxxxxx#_init(&msg_#xxxxxx#);
114 su_inline msg_#xxxxxx#_t *msg_#xxxxxx#_init(msg_#xxxxxx#_t x[1])
120 MSG_HEADER_INIT(x, msg_#xxxxxx#_class, sizeof(msg_#xxxxxx#_t))
164 * #xxxxxx# = msg_#xxxxxx#_dup(home, msg->msg_#xxxxxx#);
176 msg_#xxxxxx#_t *msg_#xxxxxx#_dup(su_home_t *home,
182 msg_#xxxxxx#_t *msg_#xxxxxx#_dup(su_home_t *home,
211 * #xxxxxx# = msg_#xxxxxx#_copy(home, msg->msg_#xxxxxx#);
222 msg_#xxxxxx#_t *msg_#xxxxxx#_copy(su_home_t *home,
[all …]
H A Dmsg_mime_protos.h.in103 * msg_#xxxxxx#_t msg_#xxxxxx# = MSG_#XXXXXX#_INIT;
116 * msg_#xxxxxx#_t msg_#xxxxxx#;
118 * msg_#xxxxxx#_init(&msg_#xxxxxx#);
125 su_inline msg_#xxxxxx#_t *msg_#xxxxxx#_init(msg_#xxxxxx#_t x[1])
131 MSG_HEADER_INIT(x, msg_#xxxxxx#_class, sizeof(msg_#xxxxxx#_t))
175 * #xxxxxx# = msg_#xxxxxx#_dup(home, msg->msg_#xxxxxx#);
187 msg_#xxxxxx#_t *msg_#xxxxxx#_dup(su_home_t *home,
192 msg_#xxxxxx#_t *msg_#xxxxxx#_dup(su_home_t *home,
221 * #xxxxxx# = msg_#xxxxxx#_copy(home, msg->msg_#xxxxxx#);
232 msg_#xxxxxx#_t *msg_#xxxxxx#_copy(su_home_t *home,
[all …]
/dports/net/sofia-sip/sofia-sip-1.13.4/libsofia-sip-ua/msg/sofia-sip/
H A Dmsg_protos.h.in92 * msg_#xxxxxx#_t msg_#xxxxxx# = MSG_#XXXXXX#_INIT;
105 * msg_#xxxxxx#_t msg_#xxxxxx#;
107 * msg_#xxxxxx#_init(&msg_#xxxxxx#);
114 su_inline msg_#xxxxxx#_t *msg_#xxxxxx#_init(msg_#xxxxxx#_t x[1])
120 MSG_HEADER_INIT(x, msg_#xxxxxx#_class, sizeof(msg_#xxxxxx#_t))
164 * #xxxxxx# = msg_#xxxxxx#_dup(home, msg->msg_#xxxxxx#);
176 msg_#xxxxxx#_t *msg_#xxxxxx#_dup(su_home_t *home,
182 msg_#xxxxxx#_t *msg_#xxxxxx#_dup(su_home_t *home,
211 * #xxxxxx# = msg_#xxxxxx#_copy(home, msg->msg_#xxxxxx#);
222 msg_#xxxxxx#_t *msg_#xxxxxx#_copy(su_home_t *home,
[all …]
H A Dmsg_mime_protos.h.in103 * msg_#xxxxxx#_t msg_#xxxxxx# = MSG_#XXXXXX#_INIT;
116 * msg_#xxxxxx#_t msg_#xxxxxx#;
118 * msg_#xxxxxx#_init(&msg_#xxxxxx#);
125 su_inline msg_#xxxxxx#_t *msg_#xxxxxx#_init(msg_#xxxxxx#_t x[1])
131 MSG_HEADER_INIT(x, msg_#xxxxxx#_class, sizeof(msg_#xxxxxx#_t))
175 * #xxxxxx# = msg_#xxxxxx#_dup(home, msg->msg_#xxxxxx#);
187 msg_#xxxxxx#_t *msg_#xxxxxx#_dup(su_home_t *home,
192 msg_#xxxxxx#_t *msg_#xxxxxx#_dup(su_home_t *home,
221 * #xxxxxx# = msg_#xxxxxx#_copy(home, msg->msg_#xxxxxx#);
232 msg_#xxxxxx#_t *msg_#xxxxxx#_copy(su_home_t *home,
[all …]
/dports/net/libzmq4/zeromq-4.3.4/src/
H A Dreq.cpp55 int zmq::req_t::xsend (msg_t *msg_) in xsend() argument
118 int rc = dealer_t::xsend (msg_); in xsend()
131 int zmq::req_t::xrecv (msg_t *msg_) in xrecv() argument
143 int rc = recv_reply_pipe (msg_); in xrecv()
162 int rc = recv_reply_pipe (msg_); in xrecv()
166 if (unlikely (!(msg_->flags () & msg_t::more) || msg_->size () != 0)) { in xrecv()
178 const int rc = recv_reply_pipe (msg_); in xrecv()
183 if (!(msg_->flags () & msg_t::more)) { in xrecv()
290 if (msg_->size () == 0) { in push_msg()
297 if (msg_->flags () == msg_t::more && msg_->size () == 0) { in push_msg()
[all …]
H A Dcurve_mechanism_base.cpp62 return curve_encoding_t::encode (msg_); in encode()
109 const size_t size = msg_->size (); in check_validity()
145 if (msg_->is_subscribe () || msg_->is_cancel ()) { in encode()
189 if (msg_->size () > 0) in encode()
191 msg_->size ()); in encode()
204 msg_->move (msg_box); in encode()
215 rc = msg_->close (); in encode()
287 msg_->shrink (plaintext_size); in decode()
289 rc = msg_->close (); in decode()
297 if (msg_->size () > 0) { in decode()
[all …]
H A Dxsub.cpp117 int zmq::xsub_t::xsend (msg_t *msg_) in xsend() argument
119 size_t size = msg_->size (); in xsend()
138 if (!msg_->is_subscribe ()) { in xsend()
148 if (!msg_->is_cancel ()) { in xsend()
159 int rc = msg_->close (); in xsend()
161 rc = msg_->init (); in xsend()
173 int zmq::xsub_t::xrecv (msg_t *msg_) in xrecv() argument
190 int rc = _fq.recv (msg_); in xrecv()
207 rc = _fq.recv (msg_); in xrecv()
252 bool zmq::xsub_t::match (msg_t *msg_) in match() argument
[all …]
H A Dgssapi_mechanism_base.cpp78 if (msg_->flags () & msg_t::more) in encode_message()
80 if (msg_->flags () & msg_t::command) in encode_message()
88 memcpy (plaintext_buffer + 1, msg_->data (), msg_->size ()); in encode_message()
91 plaintext.length = msg_->size () + 1; in encode_message()
100 int rc = msg_->close (); in encode_message()
128 size_t bytes_left = msg_->size (); in decode_message()
193 rc = msg_->close (); in decode_message()
201 msg_->set_flags (msg_t::more); in decode_message()
258 size_t bytes_left = msg_->size (); in process_initiate()
321 return encode_message (msg_); in produce_ready()
[all …]
H A Dplain_server.cpp67 produce_welcome (msg_); in next_handshake_command()
71 produce_ready (msg_); in next_handshake_command()
75 produce_error (msg_); in next_handshake_command()
91 rc = process_hello (msg_); in process_handshake_command()
94 rc = process_initiate (msg_); in process_handshake_command()
105 rc = msg_->close (); in process_handshake_command()
107 rc = msg_->init (); in process_handshake_command()
113 int zmq::plain_server_t::process_hello (msg_t *msg_) in process_hello() argument
115 int rc = check_basic_command_structure (msg_); in process_hello()
120 size_t bytes_left = msg_->size (); in process_hello()
[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_);
103 LIBZMQ_UNUSED (msg_); in process_command_message()
108 LIBZMQ_UNUSED (msg_); in produce_ping_message()
113 LIBZMQ_UNUSED (msg_); in process_heartbeat_message()
118 LIBZMQ_UNUSED (msg_); in produce_pong_message()
[all …]
/dports/net/py-pyzmq/pyzmq-22.3.0/bundled/zeromq/src/
H A Dreq.cpp55 int zmq::req_t::xsend (msg_t *msg_) in xsend() argument
118 int rc = dealer_t::xsend (msg_); in xsend()
131 int zmq::req_t::xrecv (msg_t *msg_) in xrecv() argument
143 int rc = recv_reply_pipe (msg_); in xrecv()
162 int rc = recv_reply_pipe (msg_); in xrecv()
166 if (unlikely (!(msg_->flags () & msg_t::more) || msg_->size () != 0)) { in xrecv()
178 const int rc = recv_reply_pipe (msg_); in xrecv()
183 if (!(msg_->flags () & msg_t::more)) { in xrecv()
290 if (msg_->size () == 0) { in push_msg()
297 if (msg_->flags () == msg_t::more && msg_->size () == 0) { in push_msg()
[all …]
H A Dcurve_mechanism_base.cpp62 return curve_encoding_t::encode (msg_); in encode()
109 const size_t size = msg_->size (); in check_validity()
145 if (msg_->is_subscribe () || msg_->is_cancel ()) { in encode()
189 if (msg_->size () > 0) in encode()
191 msg_->size ()); in encode()
204 msg_->move (msg_box); in encode()
215 rc = msg_->close (); in encode()
287 msg_->shrink (plaintext_size); in decode()
289 rc = msg_->close (); in decode()
297 if (msg_->size () > 0) { in decode()
[all …]
H A Dxsub.cpp117 int zmq::xsub_t::xsend (msg_t *msg_) in xsend() argument
119 size_t size = msg_->size (); in xsend()
138 if (!msg_->is_subscribe ()) { in xsend()
148 if (!msg_->is_cancel ()) { in xsend()
159 int rc = msg_->close (); in xsend()
161 rc = msg_->init (); in xsend()
173 int zmq::xsub_t::xrecv (msg_t *msg_) in xrecv() argument
190 int rc = _fq.recv (msg_); in xrecv()
207 rc = _fq.recv (msg_); in xrecv()
252 bool zmq::xsub_t::match (msg_t *msg_) in match() argument
[all …]
H A Dgssapi_mechanism_base.cpp78 if (msg_->flags () & msg_t::more) in encode_message()
80 if (msg_->flags () & msg_t::command) in encode_message()
88 memcpy (plaintext_buffer + 1, msg_->data (), msg_->size ()); in encode_message()
91 plaintext.length = msg_->size () + 1; in encode_message()
100 int rc = msg_->close (); in encode_message()
128 size_t bytes_left = msg_->size (); in decode_message()
193 rc = msg_->close (); in decode_message()
201 msg_->set_flags (msg_t::more); in decode_message()
258 size_t bytes_left = msg_->size (); in process_initiate()
321 return encode_message (msg_); in produce_ready()
[all …]
H A Dplain_server.cpp67 produce_welcome (msg_); in next_handshake_command()
71 produce_ready (msg_); in next_handshake_command()
75 produce_error (msg_); in next_handshake_command()
91 rc = process_hello (msg_); in process_handshake_command()
94 rc = process_initiate (msg_); in process_handshake_command()
105 rc = msg_->close (); in process_handshake_command()
107 rc = msg_->init (); in process_handshake_command()
113 int zmq::plain_server_t::process_hello (msg_t *msg_) in process_hello() argument
115 int rc = check_basic_command_structure (msg_); in process_hello()
120 size_t bytes_left = msg_->size (); in process_hello()
[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_);
103 LIBZMQ_UNUSED (msg_); in process_command_message()
108 LIBZMQ_UNUSED (msg_); in produce_ping_message()
113 LIBZMQ_UNUSED (msg_); in process_heartbeat_message()
118 LIBZMQ_UNUSED (msg_); in produce_pong_message()
[all …]
/dports/textproc/fcitx5/fcitx5-5.0.11/src/lib/fcitx-utils/dbus/sdbus/
H A Dmessage.cpp51 if (sd_bus_message_new_method_return(d->msg_, &msgD->msg_) < 0) { in FCITX_DEFINE_DEFAULT_DTOR_AND_MOVE()
64 int r = sd_bus_message_new_method_error(d->msg_, &msgD->msg_, &error); in createError()
80 if (d->msg_) { in setDestination()
87 if (!d->msg_) { in destination()
95 if (!d->msg_) { in sender()
103 if (!d->msg_) { in member()
112 if (!d->msg_) { in interface()
132 if (d->msg_) { in errorName()
141 if (d->msg_) { in errorMessage()
150 return d->msg_; in nativeHandle()
[all …]
/dports/devel/libxs/libxs-1.2.0/src/
H A Dreq.cpp68 int rc = xreq_t::xsend (msg_, flags_); in xsend()
93 rc = xreq_t::xrecv (msg_, flags_); in xrecv()
98 if (unlikely (!(msg_->flags () & msg_t::more) || msg_->size () != 0)) { in xrecv()
105 msg_->close (); in xrecv()
106 msg_->init (); in xrecv()
114 rc = xreq_t::xrecv (msg_, flags_); in xrecv()
119 if (!(msg_->flags () & msg_t::more)) { in xrecv()
159 int xs::req_session_t::write (msg_t *msg_) in write() argument
163 if (msg_->flags () == msg_t::more && msg_->size () == 0) { in write()
171 if (msg_->flags () == 0) { in write()
[all …]
H A Dxrep.cpp130 blob_t identity ((unsigned char*) msg_->data (), msg_->size ()); in xsend()
149 int rc = msg_->close (); in xsend()
151 rc = msg_->init (); in xsend()
170 int rc = msg_->close (); in xsend()
175 int rc = msg_->init (); in xsend()
189 msg_->set_flags (msg_t::more); in xrecv()
218 if (msg_->size () != 0) { in xrecv()
222 blob_t identity ((unsigned char*) msg_->data (), msg_->size ()); in xrecv()
256 int rc = prefetched_msg.move (*msg_); in xrecv()
259 rc = msg_->close (); in xrecv()
[all …]
/dports/net/fbzmq/fbzmq-2021.12.27.00/fbzmq/zmq/
H A DMessage.cpp26 const int rc = zmq_msg_init(&msg_); in Message()
33 zmq_msg_close(&(msg.msg_)); in allocate()
44 zmq_msg_close(&(msg.msg_)); in wrapBuffer()
48 &msg.msg_, in wrapBuffer()
67 std::swap(msg_, tmp.msg_); in operator =()
72 zmq_msg_init(&msg_); in Message()
73 const int rc = zmq_msg_move(&msg_, &(other.msg_)); in Message()
78 const int rc = zmq_msg_close(&msg_); in ~Message()
83 zmq_msg_init(&msg_); in Message()
84 const int rc = zmq_msg_copy(&msg_, const_cast<zmq_msg_t*>(&(other.msg_))); in Message()
[all …]
/dports/graphics/urho3d/Urho3D-1.7.1/Source/Urho3D/Network/
H A DConnection.cpp185 msg_.Clear(); in SetScene()
271 msg_.Clear(); in SendClientUpdate()
307 msg_.Clear(); in SendRemoteEvents()
340 msg_.Clear(); in SendPackages()
923 msg_.Clear(); in ProcessSceneLoaded()
1075 msg_.Clear(); in SendPackageToClient()
1099 msg_.Clear(); in HandleAsyncLoadFinished()
1155 msg_.Clear(); in ProcessNewNode()
1465 msg_.Clear(); in RequestPackage()
1474 msg_.Clear(); in SendPackageError()
[all …]
/dports/net/freeswitch/freeswitch-1.10.3.-release/libs/sofia-sip/libsofia-sip-ua/msg/
H A Dtest_protos.h.in170 * msg_#xxxxxx#_t msg_#xxxxxx# = MSG_#XXXXXX#_INIT;
183 * msg_#xxxxxx#_t msg_#xxxxxx#;
185 * msg_#xxxxxx#_init(&msg_#xxxxxx#);
191 su_inline msg_#xxxxxx#_t *msg_#xxxxxx#_init(msg_#xxxxxx#_t x[1])
193 return MSG_HEADER_INIT(x, msg_#xxxxxx#_class, sizeof(msg_#xxxxxx#_t));
197 MSG_HEADER_INIT(x, msg_#xxxxxx#_class, sizeof(msg_#xxxxxx#_t))
242 * #xxxxxx# = msg_#xxxxxx#_dup(home, tst->msg_#xxxxxx#);
251 msg_#xxxxxx#_t *msg_#xxxxxx#_dup(su_home_t *home, msg_#xxxxxx#_t const *hdr);
273 * #xxxxxx# = msg_#xxxxxx#_copy(home, tst->msg_#xxxxxx#);
281 msg_#xxxxxx#_t *msg_#xxxxxx#_copy(su_home_t *home,
[all …]

12345678910>>...79