| /dports/x11-toolkits/libunique3/libunique-3.0.2/unique/ |
| H A D | uniquemessage.c | 100 *retval = *message_data; in unique_message_data_copy()
102 if (message_data->data) in unique_message_data_copy()
105 memcpy (retval->data, message_data->data, message_data->length + 1); in unique_message_data_copy()
123 if (G_LIKELY (message_data)) in unique_message_data_free()
126 g_free (message_data->data); in unique_message_data_free()
152 g_free (message_data->data); in unique_message_data_set()
196 return message_data->data; in unique_message_data_get()
302 if (message_data->length == 0) in message_data_get_text_plain()
306 len = message_data->length; in message_data_get_text_plain()
500 return g_memdup (message_data->data, message_data->length + 1); in unique_message_data_get_filename()
[all …]
|
| H A D | uniquemessage.h | 45 UniqueMessageData * unique_message_data_copy (UniqueMessageData *message_data);
46 void unique_message_data_free (UniqueMessageData *message_data);
48 void unique_message_data_set (UniqueMessageData *message_data,
51 const guchar * unique_message_data_get (UniqueMessageData *message_data,
54 gboolean unique_message_data_set_text (UniqueMessageData *message_data,
57 gchar * unique_message_data_get_text (UniqueMessageData *message_data);
58 gboolean unique_message_data_set_uris (UniqueMessageData *message_data,
60 gchar ** unique_message_data_get_uris (UniqueMessageData *message_data);
61 void unique_message_data_set_filename (UniqueMessageData *message_data,
63 gchar * unique_message_data_get_filename (UniqueMessageData *message_data);
[all …]
|
| /dports/x11-toolkits/unique/libunique-1.1.6/unique/ |
| H A D | uniquemessage.c | 101 *retval = *message_data; in unique_message_data_copy()
103 if (message_data->data) in unique_message_data_copy()
106 memcpy (retval->data, message_data->data, message_data->length + 1); in unique_message_data_copy()
124 if (G_LIKELY (message_data)) in unique_message_data_free()
127 g_free (message_data->data); in unique_message_data_free()
153 g_free (message_data->data); in unique_message_data_set()
171 message_data->length = length; in unique_message_data_set()
197 return message_data->data; in unique_message_data_get()
304 len = message_data->length; in message_data_get_text_plain()
496 return g_memdup (message_data->data, message_data->length); in unique_message_data_get_filename()
[all …]
|
| H A D | uniquemessage.h | 45 UniqueMessageData * unique_message_data_copy (UniqueMessageData *message_data);
46 void unique_message_data_free (UniqueMessageData *message_data);
48 void unique_message_data_set (UniqueMessageData *message_data,
51 const guchar *unique_message_data_get (UniqueMessageData *message_data,
54 gboolean unique_message_data_set_text (UniqueMessageData *message_data,
57 gchar * unique_message_data_get_text (UniqueMessageData *message_data);
58 gboolean unique_message_data_set_uris (UniqueMessageData *message_data,
60 gchar ** unique_message_data_get_uris (UniqueMessageData *message_data);
61 void unique_message_data_set_filename (UniqueMessageData *message_data,
63 gchar * unique_message_data_get_filename (UniqueMessageData *message_data);
[all …]
|
| /dports/dns/yadifa/yadifa-2.5.3-10333/lib/dnscore/include/dnscore/ |
| H A D | message.h | 231 struct message_data struct
285 typedef struct message_data message_data; argument
289 message_data message;
320 const message_data *mesg;
1014 static inline void message_tsig_copy_from(message_data *mesg, const message_data *source) in message_tsig_copy_from()
1084 int message_process(message_data *);
1265 static inline void message_copy_sender_from(message_data *mesg, const message_data *original) in message_copy_sender_from()
1818 void message_init(message_data* mesg);
1836 void message_finalize(message_data *mesg);
1838 void message_free(message_data *mesg);
[all …]
|
| H A D | tsig.h | 146 struct message_data;
167 ya_result tsig_sign_tcp_next_message(struct message_data *mesg);
173 ya_result tsig_sign_tcp_last_message(struct message_data *mesg);
191 ya_result tsig_sign_tcp_next_message(struct message_data *mesg);
197 ya_result tsig_sign_tcp_last_message(struct message_data *mesg);
205 void tsig_verify_tcp_last_message(struct message_data *mesg);
236 ya_result tsig_extract_and_process(struct message_data *mesg);
245 ya_result tsig_sign_answer(struct message_data *mesg);
254 ya_result tsig_sign_query(struct message_data *mesg);
259 ya_result tsig_append_error(struct message_data *mesg);
[all …]
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/unittest/gunit/libmysqlgcs/interface/ |
| H A D | gcs_message-t.cc | 120 delete message_data; in TEST_F()
127 message_data->append_to_payload( in TEST_F()
132 delete message_data; in TEST_F()
141 message_data->append_to_header( in TEST_F()
159 delete message_data; in TEST_F()
168 message_data->append_to_header( in TEST_F()
194 delete message_data; in TEST_F()
203 message_data->append_to_header( in TEST_F()
235 delete message_data; in TEST_F()
244 message_data->append_to_header( in TEST_F()
[all …]
|
| /dports/devel/aws-c-event-stream/aws-c-event-stream-0.2.7/tests/ |
| H A D | event_stream_rpc_server_connection_test.c | 257 …aws_byte_buf_init_copy(&message_data->payload_cpy, message_data->allocator, message_args->payload); in s_on_recieved_protocol_message()
305 … payload.buffer, payload.len, message_data->payload_cpy.buffer, message_data->payload_cpy.len); in s_do_connect()
420 payload.buffer, payload.len, message_data.payload_cpy.buffer, message_data.payload_cpy.len); in s_test_event_stream_rpc_server_connection_connect_reject_flow()
583 payload.buffer, payload.len, message_data.payload_cpy.buffer, message_data.payload_cpy.len); in s_test_event_stream_rpc_server_connection_messages_before_connect_ack_sent()
588 AWS_ZERO_STRUCT(message_data); in s_test_event_stream_rpc_server_connection_messages_before_connect_ack_sent()
998 &message_data->last_seen_operation_name, message_data->allocator, operation_name); in s_on_incoming_stream()
1012 …aws_byte_buf_init_copy(&message_data->payload_cpy, message_data->allocator, message_args->payload); in s_on_continuation_message()
1086 payload.buffer, payload.len, message_data.payload_cpy.buffer, message_data.payload_cpy.len); in s_test_event_stream_rpc_server_connection_continuation_messages_flow()
1116 message_data.continuation_token, &message_args, s_on_message_flush_fn, &message_data)); in s_test_event_stream_rpc_server_connection_continuation_messages_flow()
1474 payload.buffer, payload.len, message_data.payload_cpy.buffer, message_data.payload_cpy.len); in s_test_event_stream_rpc_server_connection_continuation_reused_stream_id_fails()
[all …]
|
| /dports/devel/caf/actor-framework-0.18.5/libcaf_core/src/detail/ |
| H A D | message_data.cpp | 20 message_data::message_data(type_id_list types) noexcept in message_data() function in caf::detail::message_data
25 message_data::~message_data() noexcept { in ~message_data()
43 message_data* message_data::copy() const { in copy()
48 auto total_size = sizeof(message_data) + storage_size; in copy()
52 intrusive_ptr<message_data> ptr{new (vptr) message_data(types_), false}; in copy()
65 intrusive_ptr<message_data>
66 message_data::make_uninitialized(type_id_list types) { in make_uninitialized()
71 auto total_size = sizeof(message_data) + storage_size; in make_uninitialized()
75 return {new (vptr) message_data(types), false}; in make_uninitialized()
78 byte* message_data::at(size_t index) noexcept { in at()
[all …]
|
| /dports/x11-toolkits/unique/libunique-1.1.6/unique/bacon/ |
| H A D | uniquemessage-bacon.c | 15 UniqueMessageData *message_data, in unique_message_data_pack() argument
38 if (message_data->data) in unique_message_data_pack()
66 if (message_data->startup_id) in unique_message_data_pack()
103 UniqueMessageData *message_data = NULL; in unique_message_data_unpack() local
116 message_data = g_slice_new (UniqueMessageData); in unique_message_data_unpack()
122 message_data->length = strlen (buf); in unique_message_data_unpack()
127 message_data->data = NULL; in unique_message_data_unpack()
128 message_data->length = 0; in unique_message_data_unpack()
140 message_data->startup_id = g_strdup (buf); in unique_message_data_unpack()
144 message_data->startup_id = NULL; in unique_message_data_unpack()
[all …]
|
| /dports/x11-toolkits/libunique3/libunique-3.0.2/unique/bacon/ |
| H A D | uniquemessage-bacon.c | 15 UniqueMessageData *message_data, in unique_message_data_pack() argument
38 if (message_data->data) in unique_message_data_pack()
66 if (message_data->startup_id) in unique_message_data_pack()
103 UniqueMessageData *message_data = NULL; in unique_message_data_unpack() local
116 message_data = g_slice_new (UniqueMessageData); in unique_message_data_unpack()
122 message_data->length = strlen (buf); in unique_message_data_unpack()
127 message_data->data = NULL; in unique_message_data_unpack()
128 message_data->length = 0; in unique_message_data_unpack()
140 message_data->startup_id = g_strdup (buf); in unique_message_data_unpack()
144 message_data->startup_id = NULL; in unique_message_data_unpack()
[all …]
|
| /dports/net/py-impacket/impacket-0.9.17/impacket/ |
| H A D | NDP.py | 35 message_data = struct.pack('>L', 0) #Reserved bytes
36 return class_object.__build_message(NDP.ROUTER_SOLICITATION, message_data)
53 message_data = struct.pack('>L', 0) #Reserved bytes
54 message_data += target_address.as_bytes().tostring()
69 message_data += target_address.as_bytes().tostring()
75 message_data = struct.pack('>L', 0)# Reserved bytes
76 message_data += target_address.as_bytes().tostring()
77 message_data += destination_address.as_bytes().tostring()
78 return class_object.__build_message(NDP.REDIRECT, message_data)
82 def __build_message(class_object, type, message_data): argument
[all …]
|
| /dports/devel/caf/actor-framework-0.18.5/libcaf_core/caf/detail/ |
| H A D | message_data.hpp | 33 class CAF_CORE_EXPORT message_data { class
37 message_data() = delete;
39 message_data(const message_data&) = delete;
41 message_data& operator=(const message_data&) = delete;
44 explicit message_data(type_id_list types) noexcept;
46 ~message_data() noexcept;
48 message_data* copy() const;
63 this->~message_data(); in deref()
64 free(const_cast<message_data*>(this)); in deref()
192 inline void intrusive_ptr_add_ref(const message_data* ptr) { in intrusive_ptr_add_ref()
[all …]
|
| /dports/net/guacamole-server/guacamole-server-1.3.0/src/guacd/ |
| H A D | move-fd.c | 37 char message_data[] = {'G'}; in guacd_send_fd() local
41 io_vector[0].iov_base = message_data; in guacd_send_fd()
42 io_vector[0].iov_len = sizeof(message_data); in guacd_send_fd()
61 return (sendmsg(sock, &message, 0) == sizeof(message_data)); in guacd_send_fd()
70 char message_data[1]; in guacd_recv_fd() local
74 io_vector[0].iov_base = message_data; in guacd_recv_fd()
75 io_vector[0].iov_len = sizeof(message_data); in guacd_recv_fd()
86 if (recvmsg(sock, &message, 0) == sizeof(message_data)) { in guacd_recv_fd()
89 if (message_data[0] != 'G') { in guacd_recv_fd()
|
| /dports/devel/aws-c-event-stream/aws-c-event-stream-0.2.7/source/ |
| H A D | event_stream_channel_handler.c | 56 message->message_data.len); in s_process_read_message()
247 message_data->on_message_written(message_data->message, err_code, message_data->user_data); in s_on_message_write_completed_fn()
248 aws_mem_release(message_data->allocator, message_data); in s_on_message_write_completed_fn()
254 struct message_write_data *message_data = arg; in s_write_handler_message() local
283 message_data->on_message_written(message, error_code, message_data->user_data); in s_write_handler_message()
284 aws_mem_release(message_data->allocator, message_data); in s_write_handler_message()
311 message_data->on_message_written(message, error_code, message_data->user_data); in s_write_handler_message()
312 aws_mem_release(message_data->allocator, message_data); in s_write_handler_message()
321 message_data->on_message_written( in s_write_handler_message()
322 message_data->message, AWS_ERROR_IO_OPERATION_CANCELLED, message_data->user_data); in s_write_handler_message()
[all …]
|
| /dports/x11-toolkits/libunique3/libunique-3.0.2/unique/gdbus/ |
| H A D | uniquebackend-gdbus.c | 83 UniqueMessageData message_data; in method_call_cb() local
107 message_data.data = len > 0 ? (guchar *) data : NULL; in method_call_cb()
108 message_data.length = (gint) len; in method_call_cb()
109 message_data.workspace = workspace; in method_call_cb()
110 message_data.startup_id = (char *) startup_id; in method_call_cb()
114 message_data.screen = gdk_screen_get_default (); in method_call_cb()
209 UniqueMessageData *message_data, in unique_backend_gdbus_send_message() argument
224 g_variant_builder_add (&builder, "s", message_data->data ? (char *) message_data->data : ""); in unique_backend_gdbus_send_message()
225 g_variant_builder_add (&builder, "u", (guint) message_data->length); in unique_backend_gdbus_send_message()
227 g_variant_builder_add (&builder, "u", (guint) message_data->workspace); in unique_backend_gdbus_send_message()
[all …]
|
| /dports/lang/opencoarrays/OpenCoarrays-2.9.0/src/tests/integration/pde_solvers/library/ |
| H A D | ForTrilinos_assertion_utility.F90 | 80 type(error_message) function new_message(message,message_data)
83 class(*), intent(in), optional :: message_data local
85 if (present(message_data)) then
86 select type(message_data)
88 new_message%chdata = message_data
90 new_message%rdata = message_data
92 new_message%rdata = message_data
94 new_message%ldata = message_data
96 new_message%cdata = message_data
98 allocate(new_message%odata,source = message_data)
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/blink/renderer/modules/push_messaging/ |
| H A D | push_message_data.cc | 34 const ArrayBufferOrArrayBufferViewOrUSVString& message_data) { in Create() argument
35 if (message_data.IsArrayBuffer() || message_data.IsArrayBufferView()) { in Create()
37 message_data.IsArrayBufferView() in Create()
38 ? message_data.GetAsArrayBufferView().View()->buffer() in Create()
39 : message_data.GetAsArrayBuffer(); in Create()
46 if (message_data.IsUSVString()) { in Create()
48 message_data.GetAsUSVString(), WTF::kNoUnencodables); in Create()
53 DCHECK(message_data.IsNull()); in Create()
|
| H A D | push_event.cc | 22 const ArrayBufferOrArrayBufferViewOrUSVString& message_data = in PushEvent() local
24 if (message_data.IsArrayBuffer() || message_data.IsArrayBufferView()) { in PushEvent()
26 message_data.IsArrayBufferView() in PushEvent()
27 ? message_data.GetAsArrayBufferView().View()->buffer() in PushEvent()
28 : message_data.GetAsArrayBuffer(); in PushEvent()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/blink/renderer/modules/push_messaging/ |
| H A D | push_message_data.cc | 34 const ArrayBufferOrArrayBufferViewOrUSVString& message_data) { in Create() argument
35 if (message_data.IsArrayBuffer() || message_data.IsArrayBufferView()) { in Create()
37 message_data.IsArrayBufferView() in Create()
38 ? message_data.GetAsArrayBufferView().View()->buffer() in Create()
39 : message_data.GetAsArrayBuffer(); in Create()
46 if (message_data.IsUSVString()) { in Create()
48 message_data.GetAsUSVString(), WTF::kNoUnencodables); in Create()
53 DCHECK(message_data.IsNull()); in Create()
|
| H A D | push_event.cc | 22 const ArrayBufferOrArrayBufferViewOrUSVString& message_data = in PushEvent() local
24 if (message_data.IsArrayBuffer() || message_data.IsArrayBufferView()) { in PushEvent()
26 message_data.IsArrayBufferView() in PushEvent()
27 ? message_data.GetAsArrayBufferView().View()->buffer() in PushEvent()
28 : message_data.GetAsArrayBuffer(); in PushEvent()
|
| /dports/lang/opencoarrays/OpenCoarrays-2.9.0/src/tests/integration/pde_solvers/coarrayBurgers/library/ |
| H A D | ForTrilinos_assertion_utility.F90 | 80 type(error_message) function new_message(message,message_data)
83 class(*), intent(in), optional :: message_data local
85 if (present(message_data)) then
86 select type(message_data)
88 new_message%chdata = message_data
90 new_message%rdata = message_data
92 new_message%idata = message_data
94 new_message%ldata = message_data
96 new_message%cdata = message_data
98 allocate(new_message%odata,source = message_data)
|
| /dports/net-im/beebeep/beebeep-code-r1476/src/core/ |
| H A D | Connection.cpp | 41 QByteArray message_data = Protocol::instance().fromMessage( m, protocolVersion() ); in sendMessage() local
42 if( message_data.size() > 524288 ) in sendMessage()
43 …< qPrintable( networkAddress().toString() ) << "is VERY VERY BIG:" << message_data.size() << "byte… in sendMessage()
47 …Debug() << qPrintable( networkAddress().toString() ) << "is sending this message:" << message_data; in sendMessage()
50 if( !sendData( message_data ) ) in sendMessage()
59 void Connection::parseData( const QByteArray& message_data ) in parseData() argument
61 if( message_data.size() > 524288 ) in parseData()
62 …< qPrintable( networkAddress().toString() ) << "is VERY VERY BIG:" << message_data.size() << "byte… in parseData()
64 Message m = Protocol::instance().toMessage( message_data, protocolVersion() ); in parseData()
|
| /dports/devel/caf/actor-framework-0.18.5/libcaf_core/caf/ |
| H A D | message.hpp | 28 using data_ptr = intrusive_cow_ptr<detail::message_data>;
52 auto ptr = detail::message_data::make_uninitialized(types); in concat()
77 detail::message_data& data() { in data()
82 const detail::message_data& data() const noexcept { in data()
87 const detail::message_data& cdata() const noexcept { in cdata()
92 detail::message_data* ptr() noexcept { in ptr()
97 const detail::message_data* ptr() const noexcept { in ptr()
102 const detail::message_data* cptr() const noexcept { in cptr()
170 void reset(detail::message_data* new_ptr = nullptr, in reset()
217 auto raw_ptr = new (vptr) message_data(types); in make_message()
[all …]
|
| /dports/dns/yadifa/yadifa-2.5.3-10333/sbin/yadifad/ |
| H A D | log_query.h | 67 typedef void log_query_function(int, message_data*);
72 void log_query_bind(int socket_fd, message_data *mesg);
74 void log_query_yadifa(int socket_fd, message_data *mesg);
77 log_query_both(int socket_fd, message_data *mesg) in log_query_both()
84 log_query_none(int socket_fd, message_data *mesg) in log_query_none()
|