/dports/net/mpich/mpich-3.4.3/src/mpid/ch3/src/ |
H A D | ch3u_request.c | 90 last = sreq->dev.msgsize; in MPIDI_CH3U_Request_load_send_iov() 111 if (last == sreq->dev.msgsize) in MPIDI_CH3U_Request_load_send_iov() 170 if (last == sreq->dev.msgsize) in MPIDI_CH3U_Request_load_send_iov() 263 last = rreq->dev.msgsize; in MPIDI_CH3U_Request_load_recv_iov() 297 rreq->dev.msgsize = rreq->dev.msg_offset; in MPIDI_CH3U_Request_load_recv_iov() 317 (last == rreq->dev.msgsize || in MPIDI_CH3U_Request_load_recv_iov() 345 rreq->dev.msgsize - rreq->dev.msg_offset); in MPIDI_CH3U_Request_load_recv_iov() 420 if (rreq->dev.msgsize < tmpbuf_last) in MPIDI_CH3U_Request_unpack_srbuf() 422 tmpbuf_last = (int)rreq->dev.msgsize; in MPIDI_CH3U_Request_unpack_srbuf() 438 rreq->dev.msgsize = rreq->dev.msg_offset; in MPIDI_CH3U_Request_unpack_srbuf() [all …]
|
/dports/sysutils/tracker3/tracker-3.1.2/tests/estress/ |
H A D | rss_engine.py | 26 options = options.parse_options (graphic_mode=False, period=1, msgsize=2, timeout=0) 40 def __init__ (self, name, period, msgsize, timeout=0): argument 41 superKlass.__init__ (self, name, period, msgsize, timeout) 46 for i in range (0, self.msgsize): 54 self.msgsize,
|
H A D | wh_engine.py | 25 options = options.parse_options (graphic_mode=False, period=2, msgsize=1, timeout=0) 40 def __init__ (self, name, period, msgsize, timeout): argument 41 superKlass.__init__ (self, name, period, msgsize, timeout) 46 for i in range (0, self.msgsize): 56 self.msgsize,
|
H A D | abstract_engine.py | 39 def __init__ (self, name, period, msgsize, timeout): argument 41 AbstractTextEngine.__init__ (self, name, period, msgsize, timeout) 44 self.msgsize = msgsize 55 size_adj = gtk.Adjustment (msgsize, 1, 100, 1, 10, 0) 82 self.msgsize = int(self.size.get_value ())
|
/dports/sysutils/tracker-miners/tracker-miners-2.3.5/tests/estress/ |
H A D | rss_engine.py | 26 options = options.parse_options (graphic_mode=False, period=1, msgsize=2, timeout=0) 40 def __init__ (self, name, period, msgsize, timeout=0): argument 41 superKlass.__init__ (self, name, period, msgsize, timeout) 46 for i in range (0, self.msgsize): 54 self.msgsize,
|
H A D | wh_engine.py | 25 options = options.parse_options (graphic_mode=False, period=2, msgsize=1, timeout=0) 40 def __init__ (self, name, period, msgsize, timeout): argument 41 superKlass.__init__ (self, name, period, msgsize, timeout) 46 for i in range (0, self.msgsize): 56 self.msgsize,
|
H A D | abstract_engine.py | 39 def __init__ (self, name, period, msgsize, timeout): argument 41 AbstractTextEngine.__init__ (self, name, period, msgsize, timeout) 44 self.msgsize = msgsize 55 size_adj = gtk.Adjustment (msgsize, 1, 100, 1, 10, 0) 82 self.msgsize = int(self.size.get_value ())
|
H A D | mock_engine.py | 25 options = options.parse_options (graphic_mode=False, period=1, msgsize=2, timeout=0) 39 def __init__ (self, name, period, msgsize, timeout): argument 45 superKlass.__init__ (self, name, period, msgsize, timeout) 61 self.msgsize,
|
/dports/sysutils/tracker/tracker-2.3.4/tests/estress/ |
H A D | wh_engine.py | 25 options = options.parse_options (graphic_mode=False, period=2, msgsize=1, timeout=0) 40 def __init__ (self, name, period, msgsize, timeout): argument 41 superKlass.__init__ (self, name, period, msgsize, timeout) 46 for i in range (0, self.msgsize): 56 self.msgsize,
|
H A D | rss_engine.py | 26 options = options.parse_options (graphic_mode=False, period=1, msgsize=2, timeout=0) 40 def __init__ (self, name, period, msgsize, timeout=0): argument 41 superKlass.__init__ (self, name, period, msgsize, timeout) 46 for i in range (0, self.msgsize): 54 self.msgsize,
|
H A D | abstract_engine.py | 39 def __init__ (self, name, period, msgsize, timeout): argument 41 AbstractTextEngine.__init__ (self, name, period, msgsize, timeout) 44 self.msgsize = msgsize 55 size_adj = gtk.Adjustment (msgsize, 1, 100, 1, 10, 0) 82 self.msgsize = int(self.size.get_value ())
|
/dports/x11-toolkits/wxgtk31/wxWidgets-3.1.5/samples/sockets/ |
H A D | baseclient.cpp | 107 char* CreateBuffer(int *msgsize); 314 Client::CreateBuffer(int* msgsize) in CreateBuffer() argument 320 if ((*msgsize) > 250) in CreateBuffer() 323 int size = (*msgsize)/1024 + 1; in CreateBuffer() 329 *msgsize = size*1024; in CreateBuffer() 334 bufsize = (*msgsize)+2; in CreateBuffer() 337 buf[1] = (char)(*msgsize); in CreateBuffer() 345 char* buf = CreateBuffer(&msgsize); in StartWorker() 371 int msgsize = strlen(tmpbuf); in StartWorker() local 373 memset(buf+2,0x0,msgsize); in StartWorker() [all …]
|
/dports/x11-toolkits/wxgtk30/wxWidgets-3.0.5.1/samples/sockets/ |
H A D | baseclient.cpp | 107 char* CreateBuffer(int *msgsize); 314 Client::CreateBuffer(int* msgsize) in CreateBuffer() argument 320 if ((*msgsize) > 250) in CreateBuffer() 323 int size = (*msgsize)/1024 + 1; in CreateBuffer() 329 *msgsize = size*1024; in CreateBuffer() 334 bufsize = (*msgsize)+2; in CreateBuffer() 337 buf[1] = (char)(*msgsize); in CreateBuffer() 345 char* buf = CreateBuffer(&msgsize); in StartWorker() 371 int msgsize = strlen(tmpbuf); in StartWorker() local 373 memset(buf+2,0x0,msgsize); in StartWorker() [all …]
|
/dports/x11-toolkits/py-wxPython40/wxPython-4.0.7/ext/wxWidgets/samples/sockets/ |
H A D | baseclient.cpp | 107 char* CreateBuffer(int *msgsize); 314 Client::CreateBuffer(int* msgsize) in CreateBuffer() argument 320 if ((*msgsize) > 250) in CreateBuffer() 323 int size = (*msgsize)/1024 + 1; in CreateBuffer() 329 *msgsize = size*1024; in CreateBuffer() 334 bufsize = (*msgsize)+2; in CreateBuffer() 337 buf[1] = (char)(*msgsize); in CreateBuffer() 345 char* buf = CreateBuffer(&msgsize); in StartWorker() 371 int msgsize = strlen(tmpbuf); in StartWorker() local 373 memset(buf+2,0x0,msgsize); in StartWorker() [all …]
|
/dports/science/code_saturne/code_saturne-7.1.0/src/base/ |
H A D | cs_base_fortran.c | 100 int *msgsize 149 int msgsize; in _bft_printf_f() local 166 msgsize = vsprintf (cs_buf_print_f, format, arg_ptr); in _bft_printf_f() 168 msgsize = vsnprintf (cs_buf_print_f, CS_BUF_PRINT_F_SIZE, format, arg_ptr); in _bft_printf_f() 171 if (msgsize == -1 || msgsize > CS_BUF_PRINT_F_SIZE - 1) { in _bft_printf_f() 175 msgsize, CS_BUF_PRINT_F_SIZE); in _bft_printf_f() 189 CS_PROCF (csprnt, CSPRNT) (cs_buf_print_f, &msgsize); in _bft_printf_f() 191 return msgsize; in _bft_printf_f()
|
/dports/net/olsrd/olsrd-0.9.8/src/ |
H A D | parser.c | 272 uint32_t msgsize; in parse_packet() local 311 for (; count > 0; m = (union olsr_message *)((char *)m + (msgsize))) { in parse_packet() 320 msgsize = ntohs(m->v4.olsr_msgsize); in parse_packet() 324 msgsize = ntohs(m->v6.olsr_msgsize); in parse_packet() 329 if (msgsize < 8 + olsr_cnf->ipsize) { in parse_packet() 334 olsr_ip_to_string(&buf, msgorig), m->v4.olsr_msgtype, msgsize); in parse_packet() 337 olsr_ip_to_string(&buf, msgorig), m->v4.olsr_msgtype, msgsize); in parse_packet() 341 if ((msgsize % 4) != 0) { in parse_packet() 346 olsr_ip_to_string(&buf, msgorig), m->v4.olsr_msgtype, msgsize); in parse_packet() 353 if (msgsize > count) { in parse_packet() [all …]
|
/dports/net/openmpi/openmpi-4.1.1/orte/test/system/ |
H A D | iof_delay.c | 15 int msgsize; in main() local 46 msgsize = 10; in main() 47 msg[msgsize-1] = '\n'; in main() 55 write(i, msg, msgsize); in main()
|
/dports/net/openmpi3/openmpi-3.1.6/orte/test/system/ |
H A D | iof_delay.c | 15 int msgsize; in main() local 46 msgsize = 10; in main() 47 msg[msgsize-1] = '\n'; in main() 55 write(i, msg, msgsize); in main()
|
/dports/net/mpich/mpich-3.4.3/src/mpi/coll/ireduce/ |
H A D | ireduce_tsp_tree_algos.h | 168 int msgsize = (j == 0) ? chunk_size_floor : chunk_size_ceil; in MPIR_TSP_Ireduce_sched_intra_tree() local 197 recv_id[i] = MPIR_TSP_sched_irecv(recv_address, msgsize, datatype, child, tag, comm, in MPIR_TSP_Ireduce_sched_intra_tree() 205 reduce_id[i] = MPIR_TSP_sched_reduce_local(recv_address, reduce_address, msgsize, in MPIR_TSP_Ireduce_sched_intra_tree() 217 MPIR_TSP_sched_reduce_local(reduce_address, recv_address, msgsize, datatype, op, in MPIR_TSP_Ireduce_sched_intra_tree() 220 MPIR_TSP_sched_localcopy(recv_address, msgsize, datatype, reduce_address, in MPIR_TSP_Ireduce_sched_intra_tree() 221 msgsize, datatype, sched, 1, &reduce_id[i]); in MPIR_TSP_Ireduce_sched_intra_tree() 237 MPIR_TSP_sched_isend(reduce_address, msgsize, datatype, my_tree.parent, tag, comm, in MPIR_TSP_Ireduce_sched_intra_tree() 243 MPIR_TSP_sched_isend(reduce_address, msgsize, datatype, root, tag, comm, sched, in MPIR_TSP_Ireduce_sched_intra_tree() 246 MPIR_TSP_sched_irecv((char *) recvbuf + offset * extent, msgsize, datatype, in MPIR_TSP_Ireduce_sched_intra_tree() 251 offset += msgsize; in MPIR_TSP_Ireduce_sched_intra_tree()
|
/dports/net/librdkafka/librdkafka-1.8.2/tests/ |
H A D | 0038-performance.c | 47 const int msgsize = 100; in main_0038_performance() local 60 msgcnt = totsize / msgsize; in main_0038_performance() 63 msgcnt, (int)msgsize, topic, partition); in main_0038_performance() 75 test_produce_msgs(rk, rkt, testid, partition, 0, 1, NULL, msgsize); in main_0038_performance() 79 test_produce_msgs(rk, rkt, testid, partition, 1, msgcnt-1, NULL, msgsize); in main_0038_performance()
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
H A D | 0038-performance.c | 47 const int msgsize = 100; in main_0038_performance() local 60 msgcnt = totsize / msgsize; in main_0038_performance() 63 msgcnt, (int)msgsize, topic, partition); in main_0038_performance() 75 test_produce_msgs(rk, rkt, testid, partition, 0, 1, NULL, msgsize); in main_0038_performance() 79 test_produce_msgs(rk, rkt, testid, partition, 1, msgcnt-1, NULL, msgsize); in main_0038_performance()
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
H A D | 0038-performance.c | 47 const int msgsize = 100; 60 msgcnt = totsize / msgsize; 63 msgcnt, (int)msgsize, topic, partition); 75 test_produce_msgs(rk, rkt, testid, partition, 0, 1, NULL, msgsize); 79 test_produce_msgs(rk, rkt, testid, partition, 1, msgcnt-1, NULL, msgsize);
|
/dports/editors/fpc-ide/fpc-3.2.2/compiler/ |
H A D | cmsgs.pas | 49 msgsize, 118 msgsize:=0; 149 freemem(msgtxt,msgsize); 153 msgsize:=0; 162 msgsize:=n; 207 msgsize:=0; 217 inc(msgsize,length(s)+1); { +1 for linebreak } 238 inc(msgsize,j-i); 242 inc(msgsize,length(s)-i+1); 262 msgallocsize:=msgsize; [all …]
|
/dports/lang/fpc/fpc-3.2.2/compiler/ |
H A D | cmsgs.pas | 49 msgsize, 118 msgsize:=0; 149 freemem(msgtxt,msgsize); 153 msgsize:=0; 162 msgsize:=n; 207 msgsize:=0; 217 inc(msgsize,length(s)+1); { +1 for linebreak } 238 inc(msgsize,j-i); 242 inc(msgsize,length(s)-i+1); 262 msgallocsize:=msgsize; [all …]
|
/dports/lang/fpc-source/fpc-3.2.2/compiler/ |
H A D | cmsgs.pas | 49 msgsize, 118 msgsize:=0; 149 freemem(msgtxt,msgsize); 153 msgsize:=0; 162 msgsize:=n; 207 msgsize:=0; 217 inc(msgsize,length(s)+1); { +1 for linebreak } 238 inc(msgsize,j-i); 242 inc(msgsize,length(s)-i+1); 262 msgallocsize:=msgsize; [all …]
|