| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/unittest/gunit/libmysqlgcs/xcom/ |
| H A D | gcs_xcom_statistics_interface-t.cc | 43 long message_length = 1000; in TEST_F() local
45 xcom_stats_if->update_message_sent(message_length); in TEST_F()
47 ASSERT_EQ(message_length, xcom_stats_if->get_total_bytes_sent()); in TEST_F()
52 long message_length = 1000; in TEST_F() local
54 xcom_stats_if->update_message_sent(message_length); in TEST_F()
55 xcom_stats_if->update_message_sent(message_length); in TEST_F()
57 EXPECT_EQ(message_length * 2, xcom_stats_if->get_total_bytes_sent()); in TEST_F()
62 long message_length = 1000; in TEST_F() local
64 xcom_stats_if->update_message_received(message_length); in TEST_F()
69 EXPECT_EQ(message_length, xcom_stats_if->get_max_message_length()); in TEST_F()
[all …]
|
| /dports/security/opensc/OpenSC-0.22.0/src/tests/p11test/ |
| H A D | p11test_case_readonly.c | 46 message, *message_length); in rsa_x_509_pad_message()
49 message, *message_length); in rsa_x_509_pad_message()
50 *message_length = pad_message_length; in rsa_x_509_pad_message()
201 &message_length, o, 1); in encrypt_decrypt_test()
266 int part = message_length / 3; in sign_message()
452 o->id_str, message_length); in verify_message_openssl()
476 o->id_str, message_length); in verify_message_openssl()
515 int part = message_length / 3; in verify_message()
524 message_length - part); in verify_message()
593 &message_length, o, 0); in sign_verify_test()
[all …]
|
| /dports/net/wireshark-lite/wireshark-3.6.1/epan/dissectors/ |
| H A D | packet-grpc.c | 227 guint32 compressed_flag, message_length; in dissect_grpc_message() local
240 message_length = length - 5; /* should be equal to tvb_get_ntohl(tvb, offset) */ in dissect_grpc_message()
243 if (message_length == 0) { in dissect_grpc_message()
251 tvbuff_t *uncompressed_tvb = tvb_child_uncompress(tvb, tvb, offset, message_length); in dissect_grpc_message()
254 grpc_tree, tvb, offset, message_length, ett_grpc_encoded_entity, in dissect_grpc_message()
256 compression_method == NULL ? "unknown" : compression_method, message_length in dissect_grpc_message()
267 tvb, offset, message_length); in dissect_grpc_message()
277 return offset + message_length; in dissect_grpc_message()
285 guint32 message_length; in dissect_grpc() local
311 message_length = tvb_get_ntohl(tvb, offset + 1); in dissect_grpc()
[all …]
|
| /dports/net/wireshark/wireshark-3.6.1/epan/dissectors/ |
| H A D | packet-grpc.c | 227 guint32 compressed_flag, message_length; in dissect_grpc_message() local
240 message_length = length - 5; /* should be equal to tvb_get_ntohl(tvb, offset) */ in dissect_grpc_message()
243 if (message_length == 0) { in dissect_grpc_message()
251 tvbuff_t *uncompressed_tvb = tvb_child_uncompress(tvb, tvb, offset, message_length); in dissect_grpc_message()
254 grpc_tree, tvb, offset, message_length, ett_grpc_encoded_entity, in dissect_grpc_message()
256 compression_method == NULL ? "unknown" : compression_method, message_length in dissect_grpc_message()
267 tvb, offset, message_length); in dissect_grpc_message()
277 return offset + message_length; in dissect_grpc_message()
285 guint32 message_length; in dissect_grpc() local
311 message_length = tvb_get_ntohl(tvb, offset + 1); in dissect_grpc()
[all …]
|
| /dports/net/tshark-lite/wireshark-3.6.1/epan/dissectors/ |
| H A D | packet-grpc.c | 227 guint32 compressed_flag, message_length;
240 message_length = length - 5; /* should be equal to tvb_get_ntohl(tvb, offset) */
243 if (message_length == 0) {
251 tvbuff_t *uncompressed_tvb = tvb_child_uncompress(tvb, tvb, offset, message_length);
254 grpc_tree, tvb, offset, message_length, ett_grpc_encoded_entity,
256 compression_method == NULL ? "unknown" : compression_method, message_length
267 tvb, offset, message_length);
277 return offset + message_length;
285 guint32 message_length;
311 message_length = tvb_get_ntohl(tvb, offset + 1);
[all …]
|
| /dports/net/tshark/wireshark-3.6.1/epan/dissectors/ |
| H A D | packet-grpc.c | 227 guint32 compressed_flag, message_length; in dissect_grpc_message() local
240 message_length = length - 5; /* should be equal to tvb_get_ntohl(tvb, offset) */ in dissect_grpc_message()
243 if (message_length == 0) { in dissect_grpc_message()
251 tvbuff_t *uncompressed_tvb = tvb_child_uncompress(tvb, tvb, offset, message_length); in dissect_grpc_message()
254 grpc_tree, tvb, offset, message_length, ett_grpc_encoded_entity, in dissect_grpc_message()
256 compression_method == NULL ? "unknown" : compression_method, message_length in dissect_grpc_message()
267 tvb, offset, message_length); in dissect_grpc_message()
277 return offset + message_length; in dissect_grpc_message()
285 guint32 message_length; in dissect_grpc() local
311 message_length = tvb_get_ntohl(tvb, offset + 1); in dissect_grpc()
[all …]
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/plugin/group_replication/libmysqlgcs/src/bindings/xcom/ |
| H A D | gcs_xcom_statistics_interface.cc | 68 unsigned long long message_length) { in update_message_sent() argument
70 total_bytes_sent += message_length; in update_message_sent()
73 void Gcs_xcom_statistics::update_message_received(long message_length) { in update_message_received() argument
74 max_message_length = max(max_message_length, message_length); in update_message_received()
77 if (min_message_length == 0) min_message_length = message_length; in update_message_received()
79 min_message_length = min(min_message_length, message_length); in update_message_received()
82 total_bytes_received += message_length; in update_message_received()
|
| /dports/databases/xtrabackup/percona-xtrabackup-2.4.21/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/ |
| H A D | gcs_xcom_statistics_interface.cc | 84 void Gcs_xcom_statistics::update_message_sent(unsigned long long message_length) in update_message_sent() argument
87 total_bytes_sent+= message_length; in update_message_sent()
91 void Gcs_xcom_statistics::update_message_received(long message_length) in update_message_received() argument
93 max_message_length= max(max_message_length, message_length); in update_message_received()
97 min_message_length= message_length; in update_message_received()
99 min_message_length= min(min_message_length, message_length); in update_message_received()
102 total_bytes_received+= message_length; in update_message_received()
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/ |
| H A D | gcs_xcom_statistics_interface.cc | 84 void Gcs_xcom_statistics::update_message_sent(unsigned long long message_length) in update_message_sent() argument
87 total_bytes_sent+= message_length; in update_message_sent()
91 void Gcs_xcom_statistics::update_message_received(long message_length) in update_message_received() argument
93 max_message_length= max(max_message_length, message_length); in update_message_received()
97 min_message_length= message_length; in update_message_received()
99 min_message_length= min(min_message_length, message_length); in update_message_received()
102 total_bytes_received+= message_length; in update_message_received()
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/ |
| H A D | gcs_xcom_statistics_interface.cc | 84 void Gcs_xcom_statistics::update_message_sent(unsigned long long message_length) in update_message_sent() argument
87 total_bytes_sent+= message_length; in update_message_sent()
91 void Gcs_xcom_statistics::update_message_received(long message_length) in update_message_received() argument
93 max_message_length= max(max_message_length, message_length); in update_message_received()
97 min_message_length= message_length; in update_message_received()
99 min_message_length= min(min_message_length, message_length); in update_message_received()
102 total_bytes_received+= message_length; in update_message_received()
|
| /dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/ |
| H A D | gcs_xcom_statistics_interface.cc | 84 void Gcs_xcom_statistics::update_message_sent(unsigned long long message_length) in update_message_sent() argument
87 total_bytes_sent+= message_length; in update_message_sent()
91 void Gcs_xcom_statistics::update_message_received(long message_length) in update_message_received() argument
93 max_message_length= max(max_message_length, message_length); in update_message_received()
97 min_message_length= message_length; in update_message_received()
99 min_message_length= min(min_message_length, message_length); in update_message_received()
102 total_bytes_received+= message_length; in update_message_received()
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/ |
| H A D | gcs_xcom_statistics_interface.cc | 84 void Gcs_xcom_statistics::update_message_sent(unsigned long long message_length) in update_message_sent() argument
87 total_bytes_sent+= message_length; in update_message_sent()
91 void Gcs_xcom_statistics::update_message_received(long message_length) in update_message_received() argument
93 max_message_length= max(max_message_length, message_length); in update_message_received()
97 min_message_length= message_length; in update_message_received()
99 min_message_length= min(min_message_length, message_length); in update_message_received()
102 total_bytes_received+= message_length; in update_message_received()
|
| /dports/databases/mysql57-client/mysql-5.7.36/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/ |
| H A D | gcs_xcom_statistics_interface.cc | 84 void Gcs_xcom_statistics::update_message_sent(unsigned long long message_length) in update_message_sent() argument
87 total_bytes_sent+= message_length; in update_message_sent()
91 void Gcs_xcom_statistics::update_message_received(long message_length) in update_message_received() argument
93 max_message_length= max(max_message_length, message_length); in update_message_received()
97 min_message_length= message_length; in update_message_received()
99 min_message_length= min(min_message_length, message_length); in update_message_received()
102 total_bytes_received+= message_length; in update_message_received()
|
| /dports/devel/grpc/grpc-1.42.0/tools/codegen/core/ |
| H A D | gen_server_registered_method_bad_client_test_body.py | 38 for message_length in range(0, 3):
39 for send_message_length in range(0, message_length + 1):
41 0, (message_length >> 24) & 0xff, (message_length >> 16) & 0xff,
42 (message_length >> 8) & 0xff, (message_length) & 0xff
46 payload) and send_message_length == message_length
|
| /dports/devel/grpc130/grpc-1.30.2/tools/codegen/core/ |
| H A D | gen_server_registered_method_bad_client_test_body.py | 38 for message_length in range(0, 3):
39 for send_message_length in range(0, message_length + 1):
41 0, (message_length >> 24) & 0xff, (message_length >> 16) & 0xff,
42 (message_length >> 8) & 0xff, (message_length) & 0xff
46 payload) and send_message_length == message_length
|
| /dports/devel/grpc134/grpc-1.34.1/tools/codegen/core/ |
| H A D | gen_server_registered_method_bad_client_test_body.py | 38 for message_length in range(0, 3):
39 for send_message_length in range(0, message_length + 1):
41 0, (message_length >> 24) & 0xff, (message_length >> 16) & 0xff,
42 (message_length >> 8) & 0xff, (message_length) & 0xff
46 payload) and send_message_length == message_length
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/tools/codegen/core/ |
| H A D | gen_server_registered_method_bad_client_test_body.py | 38 for message_length in range(0, 3):
39 for send_message_length in range(0, message_length + 1):
41 0, (message_length >> 24) & 0xff, (message_length >> 16) & 0xff,
42 (message_length >> 8) & 0xff, (message_length) & 0xff
46 payload) and send_message_length == message_length
|
| /dports/x11/lightdm/lightdm-1.30.0/liblightdm-gobject/ |
| H A D | greeter.c | 412 if (message_length - *offset < int_length ()) in read_int()
429 if (message_length - *offset < length) in read_string()
526 if (stated_length != message_length) in send_message()
535 gsize data_length = message_length; in send_message()
594 while (*offset < message_length) in handle_connected()
733 while (*offset < message_length) in handle_reset()
796 read_int (message, message_length, &offset); in handle_message()
910 gsize message_length; in from_server_cb() local
1042 gsize message_length; in lightdm_greeter_connect_to_daemon_sync() local
1676 gsize message_length; in lightdm_greeter_start_session_sync() local
[all …]
|
| /dports/sysutils/bareos-server/bareos-Release-20.0.3/core/src/filed/ |
| H A D | verify_vol.cc | 87 jcr->buf_size = sd->message_length; in DoVerifyVolume()
115 if (size != ((uint32_t)sd->message_length)) { in DoVerifyVolume()
117 sd->message_length, size); in DoVerifyVolume()
120 Dmsg1(30, "Got stream data, len=%d\n", sd->message_length); in DoVerifyVolume()
130 if ((int)SizeofPoolMemory(fname) < sd->message_length) { in DoVerifyVolume()
131 fname = ReallocPoolMemory(fname, sd->message_length + 1); in DoVerifyVolume()
134 if ((int)SizeofPoolMemory(lname) < sd->message_length) { in DoVerifyVolume()
135 lname = ReallocPoolMemory(lname, sd->message_length + 1); in DoVerifyVolume()
223 Dmsg2(20, "filed>dir: MD5 len=%d: msg=%s\n", dir->message_length, in DoVerifyVolume()
233 Dmsg2(20, "filed>dir: SHA1 len=%d: msg=%s\n", dir->message_length, in DoVerifyVolume()
[all …]
|
| /dports/sysutils/bareos18-client/bareos-Release-18.2.12/core/src/filed/ |
| H A D | verify_vol.cc | 84 jcr->buf_size = sd->message_length; in DoVerifyVolume()
110 if (size != ((uint32_t)sd->message_length)) { in DoVerifyVolume()
114 Dmsg1(30, "Got stream data, len=%d\n", sd->message_length); in DoVerifyVolume()
124 if ((int)SizeofPoolMemory(fname) < sd->message_length) { in DoVerifyVolume()
125 fname = ReallocPoolMemory(fname, sd->message_length + 1); in DoVerifyVolume()
128 if ((int)SizeofPoolMemory(lname) < sd->message_length) { in DoVerifyVolume()
129 lname = ReallocPoolMemory(lname, sd->message_length + 1); in DoVerifyVolume()
217 Dmsg2(20, "filed>dir: MD5 len=%d: msg=%s\n", dir->message_length, dir->msg); in DoVerifyVolume()
225 Dmsg2(20, "filed>dir: SHA1 len=%d: msg=%s\n", dir->message_length, dir->msg); in DoVerifyVolume()
233 Dmsg2(20, "filed>dir: SHA256 len=%d: msg=%s\n", dir->message_length, dir->msg); in DoVerifyVolume()
[all …]
|
| /dports/sysutils/bareos19-traymonitor/bareos-Release-19.2.11/core/src/filed/ |
| H A D | verify_vol.cc | 87 jcr->buf_size = sd->message_length; in DoVerifyVolume()
114 if (size != ((uint32_t)sd->message_length)) { in DoVerifyVolume()
116 sd->message_length, size); in DoVerifyVolume()
119 Dmsg1(30, "Got stream data, len=%d\n", sd->message_length); in DoVerifyVolume()
129 if ((int)SizeofPoolMemory(fname) < sd->message_length) { in DoVerifyVolume()
130 fname = ReallocPoolMemory(fname, sd->message_length + 1); in DoVerifyVolume()
133 if ((int)SizeofPoolMemory(lname) < sd->message_length) { in DoVerifyVolume()
134 lname = ReallocPoolMemory(lname, sd->message_length + 1); in DoVerifyVolume()
222 Dmsg2(20, "filed>dir: MD5 len=%d: msg=%s\n", dir->message_length, in DoVerifyVolume()
232 Dmsg2(20, "filed>dir: SHA1 len=%d: msg=%s\n", dir->message_length, in DoVerifyVolume()
[all …]
|
| /dports/sysutils/bareos19-server/bareos-Release-19.2.11/core/src/filed/ |
| H A D | verify_vol.cc | 87 jcr->buf_size = sd->message_length; in DoVerifyVolume()
114 if (size != ((uint32_t)sd->message_length)) { in DoVerifyVolume()
116 sd->message_length, size); in DoVerifyVolume()
119 Dmsg1(30, "Got stream data, len=%d\n", sd->message_length); in DoVerifyVolume()
129 if ((int)SizeofPoolMemory(fname) < sd->message_length) { in DoVerifyVolume()
130 fname = ReallocPoolMemory(fname, sd->message_length + 1); in DoVerifyVolume()
133 if ((int)SizeofPoolMemory(lname) < sd->message_length) { in DoVerifyVolume()
134 lname = ReallocPoolMemory(lname, sd->message_length + 1); in DoVerifyVolume()
222 Dmsg2(20, "filed>dir: MD5 len=%d: msg=%s\n", dir->message_length, in DoVerifyVolume()
232 Dmsg2(20, "filed>dir: SHA1 len=%d: msg=%s\n", dir->message_length, in DoVerifyVolume()
[all …]
|
| /dports/sysutils/bareos19-client/bareos-Release-19.2.11/core/src/filed/ |
| H A D | verify_vol.cc | 87 jcr->buf_size = sd->message_length; in DoVerifyVolume()
114 if (size != ((uint32_t)sd->message_length)) { in DoVerifyVolume()
116 sd->message_length, size); in DoVerifyVolume()
119 Dmsg1(30, "Got stream data, len=%d\n", sd->message_length); in DoVerifyVolume()
129 if ((int)SizeofPoolMemory(fname) < sd->message_length) { in DoVerifyVolume()
130 fname = ReallocPoolMemory(fname, sd->message_length + 1); in DoVerifyVolume()
133 if ((int)SizeofPoolMemory(lname) < sd->message_length) { in DoVerifyVolume()
134 lname = ReallocPoolMemory(lname, sd->message_length + 1); in DoVerifyVolume()
222 Dmsg2(20, "filed>dir: MD5 len=%d: msg=%s\n", dir->message_length, in DoVerifyVolume()
232 Dmsg2(20, "filed>dir: SHA1 len=%d: msg=%s\n", dir->message_length, in DoVerifyVolume()
[all …]
|
| /dports/sysutils/bareos-client/bareos-Release-20.0.3/core/src/filed/ |
| H A D | verify_vol.cc | 87 jcr->buf_size = sd->message_length; in DoVerifyVolume()
115 if (size != ((uint32_t)sd->message_length)) { in DoVerifyVolume()
117 sd->message_length, size); in DoVerifyVolume()
120 Dmsg1(30, "Got stream data, len=%d\n", sd->message_length); in DoVerifyVolume()
130 if ((int)SizeofPoolMemory(fname) < sd->message_length) { in DoVerifyVolume()
131 fname = ReallocPoolMemory(fname, sd->message_length + 1); in DoVerifyVolume()
134 if ((int)SizeofPoolMemory(lname) < sd->message_length) { in DoVerifyVolume()
135 lname = ReallocPoolMemory(lname, sd->message_length + 1); in DoVerifyVolume()
223 Dmsg2(20, "filed>dir: MD5 len=%d: msg=%s\n", dir->message_length, in DoVerifyVolume()
233 Dmsg2(20, "filed>dir: SHA1 len=%d: msg=%s\n", dir->message_length, in DoVerifyVolume()
[all …]
|
| /dports/sysutils/bareos-traymonitor/bareos-Release-20.0.3/core/src/filed/ |
| H A D | verify_vol.cc | 87 jcr->buf_size = sd->message_length; in DoVerifyVolume()
115 if (size != ((uint32_t)sd->message_length)) { in DoVerifyVolume()
117 sd->message_length, size); in DoVerifyVolume()
120 Dmsg1(30, "Got stream data, len=%d\n", sd->message_length); in DoVerifyVolume()
130 if ((int)SizeofPoolMemory(fname) < sd->message_length) { in DoVerifyVolume()
131 fname = ReallocPoolMemory(fname, sd->message_length + 1); in DoVerifyVolume()
134 if ((int)SizeofPoolMemory(lname) < sd->message_length) { in DoVerifyVolume()
135 lname = ReallocPoolMemory(lname, sd->message_length + 1); in DoVerifyVolume()
223 Dmsg2(20, "filed>dir: MD5 len=%d: msg=%s\n", dir->message_length, in DoVerifyVolume()
233 Dmsg2(20, "filed>dir: SHA1 len=%d: msg=%s\n", dir->message_length, in DoVerifyVolume()
[all …]
|