/dports/devel/pickle/pickle-4.20/src/ |
H A D | stk500v2.c | 116 uint16_t msgsize, i; in stk500v2_recv() local 166 if (msgsize > STK_LEN) { in stk500v2_recv() 197 msgsize--; in stk500v2_recv() 200 for (i = 0; i < msgsize; ++i) in stk500v2_recv() 210 return msgsize; in stk500v2_recv() 234 header[2] = msgsize >> 8; in stk500v2_send() 235 header[3] = msgsize & 0xFF; in stk500v2_send() 248 for (i = 0; i < msgsize; ++i) in stk500v2_send() 252 stk_msg[msgsize] = sum; in stk500v2_send() 258 if (rc != msgsize--) in stk500v2_send() [all …]
|
/dports/net/mpich/mpich-3.4.3/test/mpi/pt2pt/ |
H A D | bsendpending.c | 21 int i, msgsize, bufsize, outsize; in main() local 32 msgsize = 128 * 1024; in main() 33 msg1 = (unsigned char *) malloc(3 * msgsize); in main() 34 msg2 = msg1 + msgsize; in main() 35 msg3 = msg2 + msgsize; in main() 50 bufsize = 3 * (MPI_BSEND_OVERHEAD + msgsize); in main() 60 for (i = 0; i < msgsize; i++) { in main() 67 MPI_Bsend(msg1, msgsize, MPI_UNSIGNED_CHAR, dest, 0, comm); in main() 68 MPI_Bsend(msg2, msgsize, MPI_UNSIGNED_CHAR, dest, 0, comm); in main() 90 for (i = 0; i < msgsize; i++) { in main() [all …]
|
/dports/net/mpich2/mpich2-1.5/test/mpi/pt2pt/ |
H A D | bsendpending.c | 22 int i, msgsize, bufsize, outsize; in main() local 33 msgsize = 128 * 1024; in main() 34 msg1 = (unsigned char *)malloc( 3 * msgsize ); in main() 35 msg2 = msg1 + msgsize; in main() 36 msg3 = msg2 + msgsize; in main() 50 bufsize = 3 * (MPI_BSEND_OVERHEAD + msgsize); in main() 61 for (i=0; i<msgsize; i++) { in main() 68 MPI_Bsend( msg1, msgsize, MPI_CHAR, dest, 0, comm ); in main() 69 MPI_Bsend( msg2, msgsize, MPI_CHAR, dest, 0, comm ); in main() 91 for (i=0; i<msgsize; i++) { in main() [all …]
|
/dports/net/nng/nng-1.5.2/src/tools/perf/ |
H A D | perf.c | 248 long int msgsize; in do_local_lat() local 258 latency_server(argv[0], msgsize, trips); in do_local_lat() 264 int msgsize; in do_remote_lat() local 274 latency_client(argv[0], msgsize, trips); in do_remote_lat() 280 int msgsize; in do_local_thr() local 296 int msgsize; in do_remote_thr() local 311 int msgsize; member 529 if (nng_msg_len(msg) != msgsize) { in latency_server() 531 msgsize); in latency_server() 584 if (nng_msg_len(msg) != msgsize) { in throughput_server() [all …]
|
/dports/net/openmpi/openmpi-4.1.1/orte/test/system/ |
H A D | iof_stress.c | 16 int msgsize; in main() local 45 while (0 != (msgsize = read(0, msg, ORTE_IOF_BASE_MSG_MAX))) { in main() 46 if (msgsize > 0) { in main() 47 msg[msgsize] = '\n'; in main() 48 write(1, msg, msgsize); in main() 61 msgsize = 10; in main() 62 msg[msgsize-1] = '\n'; in main() 64 write(1, msg, msgsize); in main()
|
/dports/net/openmpi3/openmpi-3.1.6/orte/test/system/ |
H A D | iof_stress.c | 16 int msgsize; in main() local 45 while (0 != (msgsize = read(0, msg, ORTE_IOF_BASE_MSG_MAX))) { in main() 46 if (msgsize > 0) { in main() 47 msg[msgsize] = '\n'; in main() 48 write(1, msg, msgsize); in main() 61 msgsize = 10; in main() 62 msg[msgsize-1] = '\n'; in main() 64 write(1, msg, msgsize); in main()
|
/dports/mail/courier/courier-0.65.3/maildrop/ |
H A D | message.C | 10 extra_headers(0), extra_headersptr(0), msgsize(0) in Message() 34 msgsize=0; in Init() 46 (msgsize=mseek(fd, 0, SEEK_CUR)) >= 0 && msgsize > SMALLMSG) in Init() 73 msgsize=0; in Init() 87 msgsize += msglines; in Init() 110 msgsize=0; in Init() 118 msgsize += cnt; in Init() 141 if ((off_t)mio.write(buffer, msgsize) != msgsize) in Init() 150 msgsize += cnt; in Init() 229 if (bufptr >= buffer + msgsize) in appendline() [all …]
|
H A D | message.h | 56 off_t msgsize; variable 99 if (bufptr >= buffer + msgsize) return (-1); in peek() 123 if (bufptr >= buffer + msgsize) return (-1); in get_c() 170 if (n > msgsize) n=msgsize; in seek() 177 off_t s=msgsize; in MessageSize()
|
/dports/www/uwsgi/uwsgi-2.0.20/plugins/emperor_amqp/ |
H A D | emperor_amqp.c | 17 uint64_t msgsize; in uwsgi_imperial_monitor_amqp_event() local 22 char *config = uwsgi_amqp_consume(ues->fd, &msgsize, &amqp_routing_key); in uwsgi_imperial_monitor_amqp_event() 41 ui_current->config_len = msgsize; in uwsgi_imperial_monitor_amqp_event() 42 if (!msgsize) { in uwsgi_imperial_monitor_amqp_event() 51 if (msgsize > 0) { in uwsgi_imperial_monitor_amqp_event() 52 emperor_add(ues, amqp_routing_key, uwsgi_now(), config, msgsize, 0, 0, NULL); in uwsgi_imperial_monitor_amqp_event() 63 if (msgsize >= 0xff || !msgsize) goto end; in uwsgi_imperial_monitor_amqp_event() 65 char *config_file = uwsgi_concat2n(config, msgsize, "", 0); in uwsgi_imperial_monitor_amqp_event()
|
/dports/mail/maildrop/maildrop-3.0.3/libs/maildrop/ |
H A D | message.C | 36 extra_headers(0), extra_headersptr(0), msgsize(0), in Message() 69 msgsize=0; in Init() 84 (msgsize=mseek(fd, 0, SEEK_CUR)) >= 0 && msgsize > SMALLMSG) in Init() 112 msgsize=0; in Init() 128 msgsize += msglines; in Init() 152 msgsize=0; in Init() 160 msgsize += cnt; in Init() 183 if ((off_t)mio.write(buffer, msgsize) != msgsize) in Init() 192 msgsize += cnt; in Init() 266 if (bufptr >= buffer + msgsize) in appendline() [all …]
|
H A D | message.h | 56 off_t msgsize; variable 105 if (bufptr >= buffer + msgsize) return (-1); in peek() 129 if (bufptr >= buffer + msgsize) return (-1); in get_c() 174 if (n > msgsize) n=msgsize; in seek() 181 off_t s=msgsize; in MessageSize()
|
/dports/games/spring/spring_98.0/rts/Net/ |
H A D | AutohostInterface.cpp | 193 const boost::uint32_t msgsize = in SendStartPlaying() local 199 std::vector<boost::uint8_t> buffer(msgsize); in SendStartPlaying() 204 memcpy(&buffer[pos], &msgsize, sizeof(msgsize)); in SendStartPlaying() 205 pos += sizeof(msgsize); in SendStartPlaying() 212 assert(int(pos + demoName.size()) == int(msgsize)); in SendStartPlaying() 220 std::vector<boost::uint8_t> buffer(msgsize); in SendGameOver() 222 buffer[1] = msgsize; in SendGameOver() 235 std::vector<boost::uint8_t> buffer(msgsize); in SendPlayerJoined() 262 std::vector<boost::uint8_t> buffer(msgsize); in SendPlayerChat() 283 std::vector<boost::uint8_t> buffer(msgsize); in Message() [all …]
|
/dports/devel/rudiments/rudiments-1.2.2/test/ |
H A D | tlsserver.cpp | 169 uint64_t msgsize; in main() local 170 ssize_t sizeread=fd->read(&msgsize); in main() 193 unsigned char *msg=new unsigned char[msgsize]; in main() 194 sizeread=fd->read(msg,msgsize); in main() 211 } else if (sizeread!=(ssize_t)msgsize) { in main() 220 "(size=%d):\n",msgsize); in main() 222 (msgsize<=70)?msgsize:70); in main() 223 if (msgsize>70) { in main() 229 ssize_t sizewritten=fd->write(msgsize); in main() 254 sizewritten=fd->write(msg,msgsize); in main() [all …]
|
H A D | gssserver.cpp | 236 uint64_t msgsize; in main() local 237 ssize_t sizeread=fd->read(&msgsize); in main() 262 unsigned char *msg=new unsigned char[msgsize]; in main() 263 sizeread=fd->read(msg,msgsize); in main() 281 } else if (sizeread!=(ssize_t)msgsize) { in main() 291 "(size=%d):\n ",msgsize); in main() 293 (msgsize<=70)?msgsize:70); in main() 294 if (msgsize>70) { in main() 300 ssize_t sizewritten=fd->write(msgsize); in main() 327 sizewritten=fd->write(msg,msgsize); in main() [all …]
|
/dports/games/cdogs-sdl/cdogs-sdl-1.0.1/src/proto/nanopb/tests/mem_release/ |
H A D | mem_release.c | 46 size_t msgsize; in test_TestMessage() local 61 msgsize = stream.bytes_written; in test_TestMessage() 66 fwrite(buffer, 1, msgsize, stdout); in test_TestMessage() 82 stream = pb_istream_from_buffer(buffer, msgsize); in test_TestMessage() 94 TEST(ostream.bytes_written == msgsize); in test_TestMessage() 95 TEST(memcmp(buffer, buffer2, msgsize) == 0); in test_TestMessage() 117 size_t msgsize; in test_OneofMessage() local 173 msgsize = stream.bytes_written; in test_OneofMessage() 178 pb_istream_t stream = pb_istream_from_buffer(buffer, msgsize); in test_OneofMessage() 214 const size_t msgsize = sizeof(buffer); in test_Garbage() local [all …]
|
/dports/net/netatalk3/netatalk-3.1.12/etc/afpd/ |
H A D | messages.c | 115 uint16_t msgsize; in afp_getsrvrmesg() local 122 msgsize = MAX(obj->dsi->attn_quantum, MAXMESGSIZE); in afp_getsrvrmesg() 162 if (msglen > msgsize) in afp_getsrvrmesg() 163 msglen = msgsize; in afp_getsrvrmesg() 167 message, msglen, localized_message, msgsize)) ) in afp_getsrvrmesg() 180 msgsize = htons(outlen); in afp_getsrvrmesg() 181 memcpy(rbuf, &msgsize, sizeof(msgsize)); in afp_getsrvrmesg() 182 *rbuflen += sizeof(msgsize); in afp_getsrvrmesg()
|
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/utils/cacheutils/ |
H A D | cacheutils.cpp | 155 const int msgsize = sizeof(ISMPacketHeader); in flushPrimProcCache() local 156 uint8_t msgbuf[msgsize]; in flushPrimProcCache() 161 ByteStream bs(msgbuf, msgsize); in flushPrimProcCache() 190 scoped_array<uint8_t> msgbuf(new uint8_t[msgsize]); in flushPrimProcBlocks() 208 ByteStream bs(msgbuf.get(), msgsize); in flushPrimProcBlocks() 303 const int msgsize = sizeof(ISMPacketHeader); in dropPrimProcFdCache() local 304 uint8_t msgbuf[msgsize]; in dropPrimProcFdCache() 308 ByteStream bs(msgbuf, msgsize); in dropPrimProcFdCache() 325 const int msgsize = sizeof(ISMPacketHeader); in purgePrimProcFdCache() local 326 uint8_t msgbuf[msgsize]; in purgePrimProcFdCache() [all …]
|
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/utils/cacheutils/ |
H A D | cacheutils.cpp | 155 const int msgsize = sizeof(ISMPacketHeader); in flushPrimProcCache() local 156 uint8_t msgbuf[msgsize]; in flushPrimProcCache() 161 ByteStream bs(msgbuf, msgsize); in flushPrimProcCache() 190 scoped_array<uint8_t> msgbuf(new uint8_t[msgsize]); in flushPrimProcBlocks() 208 ByteStream bs(msgbuf.get(), msgsize); in flushPrimProcBlocks() 303 const int msgsize = sizeof(ISMPacketHeader); in dropPrimProcFdCache() local 304 uint8_t msgbuf[msgsize]; in dropPrimProcFdCache() 308 ByteStream bs(msgbuf, msgsize); in dropPrimProcFdCache() 325 const int msgsize = sizeof(ISMPacketHeader); in purgePrimProcFdCache() local 326 uint8_t msgbuf[msgsize]; in purgePrimProcFdCache() [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/third_party/nanopb/tests/mem_release/ |
H A D | mem_release.c | 46 size_t msgsize; in test_TestMessage() local 61 msgsize = stream.bytes_written; in test_TestMessage() 66 fwrite(buffer, 1, msgsize, stdout); in test_TestMessage() 82 stream = pb_istream_from_buffer(buffer, msgsize); in test_TestMessage() 94 TEST(ostream.bytes_written == msgsize); in test_TestMessage() 95 TEST(memcmp(buffer, buffer2, msgsize) == 0); in test_TestMessage() 117 size_t msgsize; in test_OneofMessage() local 151 msgsize = stream.bytes_written; in test_OneofMessage() 156 pb_istream_t stream = pb_istream_from_buffer(buffer, msgsize); in test_OneofMessage()
|
/dports/databases/db18/db-18.1.40/src/repmgr/ |
H A D | repmgr_queue.c | 100 u_int32_t msgsize; local 142 msgsize = (u_int32_t)m->size; 143 while (msgsize >= GIGABYTE) { 146 msgsize -= GIGABYTE; 148 if (db_rep->input_queue.bytes < msgsize) { 153 db_rep->input_queue.bytes -= msgsize; 228 u_int32_t msgsize; local 266 msgsize = (u_int32_t)msg->size; 267 while (msgsize >= GIGABYTE) { 268 msgsize -= GIGABYTE; [all …]
|
/dports/net/olsrd/olsrd-0.9.8/src/ |
H A D | olsr.c | 323 int msgsize; in olsr_forward_message() local 379 msgsize = ntohs(m->v4.olsr_msgsize); in olsr_forward_message() 396 if (net_outbuffer_push(ifn, m, msgsize) != msgsize) { in olsr_forward_message() 402 if (net_outbuffer_push(ifn, m, msgsize) != msgsize) { in olsr_forward_message() 403 …OLSR_PRINTF(1, "Received message to big to be forwarded in %s(%d bytes)!", ifn->int_name, msgsize); in olsr_forward_message() 404 …(OLSR_LOG_ERR, "Received message to big to be forwarded on %s(%d bytes)!", ifn->int_name, msgsize); in olsr_forward_message() 411 if (net_outbuffer_push(ifn, m, msgsize) != msgsize) { in olsr_forward_message() 412 …OLSR_PRINTF(1, "Received message to big to be forwarded in %s(%d bytes)!", ifn->int_name, msgsize); in olsr_forward_message() 413 …(OLSR_LOG_ERR, "Received message to big to be forwarded on %s(%d bytes)!", ifn->int_name, msgsize); in olsr_forward_message()
|
/dports/net/nmsg/nmsg-1.0.1/nmsg/ |
H A D | input_nmsg.c | 265 ssize_t bytes_avail, msgsize = 0; in _input_nmsg_read_container_file() local 270 res = read_file(input, &msgsize); in _input_nmsg_read_container_file() 276 if (bytes_avail < msgsize) { in _input_nmsg_read_container_file() 286 input->stream->buf->pos += msgsize; in _input_nmsg_read_container_file() 294 ssize_t msgsize; in _input_nmsg_read_container_sock() local 315 &msgsize, in _input_nmsg_read_container_sock() 328 input->stream->buf->pos += msgsize; in _input_nmsg_read_container_sock() 359 ssize_t msgsize = 0; in _input_nmsg_read_container_zmq() local 442 load_net32(buf, msgsize); in _input_nmsg_deserialize_header() 528 load_net16(buf->pos, msgsize); in read_file() [all …]
|
/dports/net/libzmq4/zeromq-4.3.4/tests/ |
H A D | test_stream_exceeds_buffer.cpp | 39 const int msgsize = 8193; in test_stream_exceeds_buffer() local 40 char sndbuf[msgsize] = "\xde\xad\xbe\xef"; in test_stream_exceeds_buffer() 41 unsigned char rcvbuf[msgsize]; in test_stream_exceeds_buffer() 54 TEST_ASSERT_EQUAL_INT (msgsize, send (client_sock, sndbuf, msgsize, 0)); in test_stream_exceeds_buffer()
|
/dports/net/mpich/mpich-3.4.3/src/mpi/coll/iallreduce/ |
H A D | iallreduce_tsp_tree_algos.h | 120 int msgsize = (j == 0) ? chunk_size_floor : chunk_size_ceil; in MPIR_TSP_Iallreduce_sched_intra_tree() local 149 recv_id[i] = MPIR_TSP_sched_irecv(recv_address, msgsize, datatype, child, tag, comm, in MPIR_TSP_Iallreduce_sched_intra_tree() 157 reduce_id[i] = MPIR_TSP_sched_reduce_local(recv_address, reduce_address, msgsize, in MPIR_TSP_Iallreduce_sched_intra_tree() 169 MPIR_TSP_sched_reduce_local(reduce_address, recv_address, msgsize, datatype, op, in MPIR_TSP_Iallreduce_sched_intra_tree() 172 MPIR_TSP_sched_localcopy(recv_address, msgsize, datatype, reduce_address, in MPIR_TSP_Iallreduce_sched_intra_tree() 173 msgsize, datatype, sched, 1, &reduce_id[i]); in MPIR_TSP_Iallreduce_sched_intra_tree() 189 MPIR_TSP_sched_isend(reduce_address, msgsize, datatype, my_tree.parent, tag, comm, in MPIR_TSP_Iallreduce_sched_intra_tree() 199 MPIR_TSP_sched_irecv(reduce_address, msgsize, datatype, in MPIR_TSP_Iallreduce_sched_intra_tree() 207 MPIR_TSP_sched_imcast(reduce_address, msgsize, datatype, in MPIR_TSP_Iallreduce_sched_intra_tree() 211 offset += msgsize; in MPIR_TSP_Iallreduce_sched_intra_tree()
|
/dports/net/dante/dante-1.4.3/lib/ |
H A D | udp_util.c | 50 udpheader_add(host, msg, len, msgsize) in udpheader_add() argument 54 const size_t msgsize; 63 if (msgsize < (size_t)(*len + HEADERSIZE_UDP(&header))) { 69 (unsigned long)msgsize); 80 (unsigned long)msgsize);
|