/dports/databases/xapian-core12/xapian-core-1.2.25/include/xapian/ |
H A D | error.h | 139 : 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 D | error.h | 160 : 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 D | Message.cpp | 46 : 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 D | msg_protos.h.in | 92 * 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 D | msg_mime_protos.h.in | 103 * 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 D | msg_protos.h.in | 92 * 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 D | msg_mime_protos.h.in | 103 * 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 D | req.cpp | 55 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 D | curve_mechanism_base.cpp | 62 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 D | xsub.cpp | 117 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 D | gssapi_mechanism_base.cpp | 78 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 D | plain_server.cpp | 67 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 D | stream_engine_base.hpp | 86 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 D | req.cpp | 55 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 D | curve_mechanism_base.cpp | 62 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 D | xsub.cpp | 117 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 D | gssapi_mechanism_base.cpp | 78 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 D | plain_server.cpp | 67 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 D | stream_engine_base.hpp | 86 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 D | message.cpp | 51 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 D | req.cpp | 68 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 D | xrep.cpp | 130 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 D | Message.cpp | 26 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 D | Connection.cpp | 185 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 D | test_protos.h.in | 170 * 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 …]
|