Home
last modified time | relevance | path

Searched refs:msgsize (Results 1 – 25 of 583) sorted by relevance

12345678910>>...24

/dports/devel/pickle/pickle-4.20/src/
H A Dstk500v2.c116 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 Dbsendpending.c21 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 Dbsendpending.c22 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 Dperf.c248 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 Diof_stress.c16 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 Diof_stress.c16 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 Dmessage.C10 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 Dmessage.h56 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 Demperor_amqp.c17 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 Dmessage.C36 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 Dmessage.h56 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 DAutohostInterface.cpp193 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 Dtlsserver.cpp169 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 Dgssserver.cpp236 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 Dmem_release.c46 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 Dmessages.c115 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 Dcacheutils.cpp155 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 Dcacheutils.cpp155 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 Dmem_release.c46 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 Drepmgr_queue.c100 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 Dolsr.c323 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 Dinput_nmsg.c265 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 Dtest_stream_exceeds_buffer.cpp39 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 Diallreduce_tsp_tree_algos.h120 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 Dudp_util.c50 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);

12345678910>>...24