Home
last modified time | relevance | path

Searched refs:msgsize (Results 26 – 50 of 583) sorted by relevance

12345678910>>...24

/dports/net/mpich/mpich-3.4.3/src/mpid/ch3/src/
H A Dch3u_request.c90 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 Drss_engine.py26 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 Dwh_engine.py25 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 Dabstract_engine.py39 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 Drss_engine.py26 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 Dwh_engine.py25 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 Dabstract_engine.py39 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 Dmock_engine.py25 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 Dwh_engine.py25 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 Drss_engine.py26 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 Dabstract_engine.py39 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 Dbaseclient.cpp107 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 Dbaseclient.cpp107 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 Dbaseclient.cpp107 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 Dcs_base_fortran.c100 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 Dparser.c272 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 Diof_delay.c15 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 Diof_delay.c15 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 Direduce_tsp_tree_algos.h168 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 D0038-performance.c47 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 D0038-performance.c47 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 D0038-performance.c47 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 Dcmsgs.pas49 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 Dcmsgs.pas49 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 Dcmsgs.pas49 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 …]

12345678910>>...24