| /dports/net/samba412/samba-4.12.15/lib/util/ |
| H A D | msghdr.c | 202 ssize_t msghdr_copy(struct msghdr_buf *msg, size_t msgsize, in msghdr_copy() argument
210 bufsize = (msgsize > offsetof(struct msghdr_buf, buf)) ? in msghdr_copy()
211 msgsize - offsetof(struct msghdr_buf, buf) : 0; in msghdr_copy()
|
| /dports/mail/courier/courier-0.65.3/maildrop/ |
| H A D | formatmbox.C | 30 msgsize=0; in Init()
122 msgsize += msglinebuf.Length(); in GetLineBuffer()
|
| /dports/mail/maildrop/maildrop-3.0.3/libs/maildrop/ |
| H A D | formatmbox.C | 29 msgsize=0; in Init()
120 msgsize += msglinebuf.Length(); in GetLineBuffer()
|
| /dports/net/librdkafka/librdkafka-1.8.2/tests/ |
| H A D | 0101-fetch-from-follower.cpp | 280 const int msgsize = 100; in do_fff_test() local
283 test_produce_msgs_easy_size(topic_str.c_str(), 0, 0, msgcnt, msgsize); in do_fff_test()
383 test_assert(TestEvent2Cb::rxbytes[client_rack_id] > msgcnt * msgsize, in do_fff_test()
384 … tostr() << "expecting rxbytes of client.rack broker to be at least " << msgcnt * msgsize in do_fff_test()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
| H A D | 0101-fetch-from-follower.cpp | 280 const int msgsize = 100; in do_fff_test() local
283 test_produce_msgs_easy_size(topic_str.c_str(), 0, 0, msgcnt, msgsize); in do_fff_test()
383 test_assert(TestEvent2Cb::rxbytes[client_rack_id] > msgcnt * msgsize, in do_fff_test()
384 … tostr() << "expecting rxbytes of client.rack broker to be at least " << msgcnt * msgsize in do_fff_test()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
| H A D | 0101-fetch-from-follower.cpp | 280 const int msgsize = 100;
283 test_produce_msgs_easy_size(topic_str.c_str(), 0, 0, msgcnt, msgsize);
383 test_assert(TestEvent2Cb::rxbytes[client_rack_id] > msgcnt * msgsize,
384 … tostr() << "expecting rxbytes of client.rack broker to be at least " << msgcnt * msgsize
|
| /dports/databases/xtrabackup/percona-xtrabackup-2.4.21/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/ |
| H A D | xcom_transport.c | 1311 void get_header_1_0(unsigned char header_buf[], uint32_t *msgsize, in get_header_1_0() argument
1314 *msgsize = get_32(LENGTH_PTR(header_buf)); in get_header_1_0()
1319 void put_header_1_0(unsigned char header_buf[], uint32_t msgsize, in put_header_1_0() argument
1322 put_32(LENGTH_PTR(header_buf), msgsize); in put_header_1_0()
1337 uint32_t msgsize; in read_msg() local
1399 ep->bytes = calloc(1, ep->msgsize); in read_msg()
1406 TASK_CALL(read_bytes(rfd, ep->bytes, ep->msgsize, s, &ep->n)); in read_msg()
1435 uint32_t msgsize; in buffered_read_msg() local
1499 ep->bytes = calloc(1, ep->msgsize); in buffered_read_msg()
1530 uint32_t msgsize; in recv_proto() local
[all …]
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/ |
| H A D | xcom_transport.c | 1327 void get_header_1_0(unsigned char header_buf[], uint32_t *msgsize, in get_header_1_0() argument
1330 *msgsize = get_32(LENGTH_PTR(header_buf)); in get_header_1_0()
1335 void put_header_1_0(unsigned char header_buf[], uint32_t msgsize, in put_header_1_0() argument
1338 put_32(LENGTH_PTR(header_buf), msgsize); in put_header_1_0()
1353 uint32_t msgsize; in read_msg() local
1415 ep->bytes = calloc(1, ep->msgsize); in read_msg()
1422 TASK_CALL(read_bytes(rfd, ep->bytes, ep->msgsize, s, &ep->n)); in read_msg()
1451 uint32_t msgsize; in buffered_read_msg() local
1515 ep->bytes = calloc(1, ep->msgsize); in buffered_read_msg()
1546 uint32_t msgsize; in recv_proto() local
[all …]
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/ |
| H A D | xcom_transport.c | 1327 void get_header_1_0(unsigned char header_buf[], uint32_t *msgsize, in get_header_1_0() argument
1330 *msgsize = get_32(LENGTH_PTR(header_buf)); in get_header_1_0()
1335 void put_header_1_0(unsigned char header_buf[], uint32_t msgsize, in put_header_1_0() argument
1338 put_32(LENGTH_PTR(header_buf), msgsize); in put_header_1_0()
1353 uint32_t msgsize; in read_msg() local
1415 ep->bytes = calloc(1, ep->msgsize); in read_msg()
1422 TASK_CALL(read_bytes(rfd, ep->bytes, ep->msgsize, s, &ep->n)); in read_msg()
1451 uint32_t msgsize; in buffered_read_msg() local
1515 ep->bytes = calloc(1, ep->msgsize); in buffered_read_msg()
1546 uint32_t msgsize; in recv_proto() local
[all …]
|
| /dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/ |
| H A D | xcom_transport.c | 1311 void get_header_1_0(unsigned char header_buf[], uint32_t *msgsize, in get_header_1_0() argument
1314 *msgsize = get_32(LENGTH_PTR(header_buf)); in get_header_1_0()
1319 void put_header_1_0(unsigned char header_buf[], uint32_t msgsize, in put_header_1_0() argument
1322 put_32(LENGTH_PTR(header_buf), msgsize); in put_header_1_0()
1337 uint32_t msgsize; in read_msg() local
1399 ep->bytes = calloc(1, ep->msgsize); in read_msg()
1406 TASK_CALL(read_bytes(rfd, ep->bytes, ep->msgsize, s, &ep->n)); in read_msg()
1435 uint32_t msgsize; in buffered_read_msg() local
1499 ep->bytes = calloc(1, ep->msgsize); in buffered_read_msg()
1530 uint32_t msgsize; in recv_proto() local
[all …]
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/ |
| H A D | xcom_transport.c | 1327 void get_header_1_0(unsigned char header_buf[], uint32_t *msgsize, in get_header_1_0() argument
1330 *msgsize = get_32(LENGTH_PTR(header_buf)); in get_header_1_0()
1335 void put_header_1_0(unsigned char header_buf[], uint32_t msgsize, in put_header_1_0() argument
1338 put_32(LENGTH_PTR(header_buf), msgsize); in put_header_1_0()
1353 uint32_t msgsize; in read_msg() local
1415 ep->bytes = calloc(1, ep->msgsize); in read_msg()
1422 TASK_CALL(read_bytes(rfd, ep->bytes, ep->msgsize, s, &ep->n)); in read_msg()
1451 uint32_t msgsize; in buffered_read_msg() local
1515 ep->bytes = calloc(1, ep->msgsize); in buffered_read_msg()
1546 uint32_t msgsize; in recv_proto() local
[all …]
|
| /dports/databases/mysql57-client/mysql-5.7.36/rapid/plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/ |
| H A D | xcom_transport.c | 1311 void get_header_1_0(unsigned char header_buf[], uint32_t *msgsize, in get_header_1_0() argument
1314 *msgsize = get_32(LENGTH_PTR(header_buf)); in get_header_1_0()
1319 void put_header_1_0(unsigned char header_buf[], uint32_t msgsize, in put_header_1_0() argument
1322 put_32(LENGTH_PTR(header_buf), msgsize); in put_header_1_0()
1337 uint32_t msgsize; in read_msg() local
1399 ep->bytes = calloc(1, ep->msgsize); in read_msg()
1406 TASK_CALL(read_bytes(rfd, ep->bytes, ep->msgsize, s, &ep->n)); in read_msg()
1435 uint32_t msgsize; in buffered_read_msg() local
1499 ep->bytes = calloc(1, ep->msgsize); in buffered_read_msg()
1530 uint32_t msgsize; in recv_proto() local
[all …]
|
| /dports/mail/nmh/nmh-1.7.1/uip/ |
| H A D | fmttest.c | 124 int colwidth = -1, msgnum = -1, msgcur = -1, msgsize = -1, msgunseen = -1; in main() local
254 msgsize = atoi(cp); in main()
333 dat[2] = msgsize; in main()
474 int i, msgnum, msgsize = dat[2], num = dat[0], cur = dat[1]; in process_messages() local
492 process_single_file(in, comps, dat, msgsize, fmt, buffer, in process_messages()
572 process_single_file(in, comps, dat, msgsize, fmt, buffer, in process_messages()
586 process_single_file(FILE *in, struct msgs_array *comps, int *dat, int msgsize, in process_single_file() argument
600 if (msgsize == -1) { in process_single_file()
|
| /dports/www/uwsgi/uwsgi-2.0.20/plugins/emperor_amqp/ |
| H A D | amqp.c | 101 char *uwsgi_amqp_consume(int fd, uint64_t *msgsize, char **routing_key) { in uwsgi_amqp_consume() argument
155 ptr = amqp_get_longlong(ptr, watermark, msgsize); if (!ptr) goto clear2; in uwsgi_amqp_consume()
162 char *fullbody = uwsgi_malloc(*msgsize); in uwsgi_amqp_consume()
165 while(current_size < *msgsize) { in uwsgi_amqp_consume()
174 if (fh.size+current_size > *msgsize) { in uwsgi_amqp_consume()
|
| /dports/mail/qsheff/qsheff-II-2.1-r3/src/ |
| H A D | smtp.h | 14 int msgsize; variable
|
| /dports/databases/postgresql96-server/postgresql-9.6.24/src/bin/pg_dump/ |
| H A D | parallel.c | 1598 int msgsize, in readMessageFromPipe() local
1613 msgsize = 0; in readMessageFromPipe()
1616 Assert(msgsize < bufsize); in readMessageFromPipe()
1617 ret = piperead(fd, msg + msgsize, 1); in readMessageFromPipe()
1623 if (msg[msgsize] == '\0') in readMessageFromPipe()
1626 msgsize++; in readMessageFromPipe()
1627 if (msgsize == bufsize) /* enlarge buffer if needed */ in readMessageFromPipe()
|
| /dports/databases/postgresql96-pltcl/postgresql-9.6.24/src/bin/pg_dump/ |
| H A D | parallel.c | 1598 int msgsize, in readMessageFromPipe() local
1613 msgsize = 0; in readMessageFromPipe()
1616 Assert(msgsize < bufsize); in readMessageFromPipe()
1617 ret = piperead(fd, msg + msgsize, 1); in readMessageFromPipe()
1623 if (msg[msgsize] == '\0') in readMessageFromPipe()
1626 msgsize++; in readMessageFromPipe()
1627 if (msgsize == bufsize) /* enlarge buffer if needed */ in readMessageFromPipe()
|
| /dports/databases/pglogical/pglogical-REL2_4_0/pglogical_dump/ |
| H A D | parallel.c | 1267 int msgsize, in readMessageFromPipe() local
1286 msgsize = 0; in readMessageFromPipe()
1289 Assert(msgsize <= bufsize); in readMessageFromPipe()
1290 ret = piperead(fd, msg + msgsize, 1); in readMessageFromPipe()
1298 if (msg[msgsize] == '\0') in readMessageFromPipe()
1301 msgsize++; in readMessageFromPipe()
1302 if (msgsize == bufsize) in readMessageFromPipe()
|
| /dports/databases/postgresql96-plpython/postgresql-9.6.24/src/bin/pg_dump/ |
| H A D | parallel.c | 1598 int msgsize, in readMessageFromPipe() local
1613 msgsize = 0; in readMessageFromPipe()
1616 Assert(msgsize < bufsize); in readMessageFromPipe()
1617 ret = piperead(fd, msg + msgsize, 1); in readMessageFromPipe()
1623 if (msg[msgsize] == '\0') in readMessageFromPipe()
1626 msgsize++; in readMessageFromPipe()
1627 if (msgsize == bufsize) /* enlarge buffer if needed */ in readMessageFromPipe()
|
| /dports/databases/postgresql12-client/postgresql-12.9/src/bin/pg_dump/ |
| H A D | parallel.c | 1671 int msgsize, in readMessageFromPipe() local
1686 msgsize = 0; in readMessageFromPipe()
1689 Assert(msgsize < bufsize); in readMessageFromPipe()
1690 ret = piperead(fd, msg + msgsize, 1); in readMessageFromPipe()
1696 if (msg[msgsize] == '\0') in readMessageFromPipe()
1699 msgsize++; in readMessageFromPipe()
1700 if (msgsize == bufsize) /* enlarge buffer if needed */ in readMessageFromPipe()
|
| /dports/databases/postgresql14-pltcl/postgresql-14.1/src/bin/pg_dump/ |
| H A D | parallel.c | 1670 int msgsize, in readMessageFromPipe() local
1685 msgsize = 0; in readMessageFromPipe()
1688 Assert(msgsize < bufsize); in readMessageFromPipe()
1689 ret = piperead(fd, msg + msgsize, 1); in readMessageFromPipe()
1695 if (msg[msgsize] == '\0') in readMessageFromPipe()
1698 msgsize++; in readMessageFromPipe()
1699 if (msgsize == bufsize) /* enlarge buffer if needed */ in readMessageFromPipe()
|
| /dports/databases/postgresql14-docs/postgresql-14.1/src/bin/pg_dump/ |
| H A D | parallel.c | 1670 int msgsize, in readMessageFromPipe() local
1685 msgsize = 0; in readMessageFromPipe()
1688 Assert(msgsize < bufsize); in readMessageFromPipe()
1689 ret = piperead(fd, msg + msgsize, 1); in readMessageFromPipe()
1695 if (msg[msgsize] == '\0') in readMessageFromPipe()
1698 msgsize++; in readMessageFromPipe()
1699 if (msgsize == bufsize) /* enlarge buffer if needed */ in readMessageFromPipe()
|
| /dports/databases/postgresql14-server/postgresql-14.1/src/bin/pg_dump/ |
| H A D | parallel.c | 1670 int msgsize, in readMessageFromPipe() local
1685 msgsize = 0; in readMessageFromPipe()
1688 Assert(msgsize < bufsize); in readMessageFromPipe()
1689 ret = piperead(fd, msg + msgsize, 1); in readMessageFromPipe()
1695 if (msg[msgsize] == '\0') in readMessageFromPipe()
1698 msgsize++; in readMessageFromPipe()
1699 if (msgsize == bufsize) /* enlarge buffer if needed */ in readMessageFromPipe()
|
| /dports/databases/postgresql14-plpython/postgresql-14.1/src/bin/pg_dump/ |
| H A D | parallel.c | 1670 int msgsize, in readMessageFromPipe() local
1685 msgsize = 0; in readMessageFromPipe()
1688 Assert(msgsize < bufsize); in readMessageFromPipe()
1689 ret = piperead(fd, msg + msgsize, 1); in readMessageFromPipe()
1695 if (msg[msgsize] == '\0') in readMessageFromPipe()
1698 msgsize++; in readMessageFromPipe()
1699 if (msgsize == bufsize) /* enlarge buffer if needed */ in readMessageFromPipe()
|
| /dports/databases/postgresql14-plperl/postgresql-14.1/src/bin/pg_dump/ |
| H A D | parallel.c | 1670 int msgsize, in readMessageFromPipe() local
1685 msgsize = 0; in readMessageFromPipe()
1688 Assert(msgsize < bufsize); in readMessageFromPipe()
1689 ret = piperead(fd, msg + msgsize, 1); in readMessageFromPipe()
1695 if (msg[msgsize] == '\0') in readMessageFromPipe()
1698 msgsize++; in readMessageFromPipe()
1699 if (msgsize == bufsize) /* enlarge buffer if needed */ in readMessageFromPipe()
|