Home
last modified time | relevance | path

Searched refs:iovector (Results 1 – 25 of 41) sorted by relevance

12

/dports/net/opentracker/opentracker-0.2017.08.13/
H A Dot_iovec.c22 *iovector = new_ptr; in iovec_increase()
26 ((*iovector)[*iovec_entries]).iov_base = new_ptr; in iovec_increase()
27 ((*iovector)[*iovec_entries]).iov_len = new_alloc; in iovec_increase()
32 void iovec_free( int *iovec_entries, struct iovec **iovector ) { in iovec_free() argument
35 munmap( ((*iovector)[i]).iov_base, ((*iovector)[i]).iov_len ); in iovec_free()
42 char * base = (char*)((*iovector)[ *iovec_entries - 1 ]).iov_base; in iovec_fixlast()
46 old_alloc = ((*iovector)[ *iovec_entries - 1 ]).iov_len; in iovec_fixlast()
53 ((*iovector)[*iovec_entries - 1 ]).iov_len = new_alloc; in iovec_fixlast()
59 iovec_fixlast( iovec_entries, iovector, last_ptr ); in iovec_fix_increase_or_free()
62 iovec_free( iovec_entries, iovector ); in iovec_fix_increase_or_free()
[all …]
H A Dot_sync.c73 static void sync_make( int *iovec_entries, struct iovec **iovector ) { in sync_make() argument
79 *iovector = NULL; in sync_make()
80 if( !( r = iovec_increase( iovec_entries, iovector, OT_SYNC_CHUNK_SIZE ) ) ) in sync_make()
107 if( !( r = iovec_fix_increase_or_free( iovec_entries, iovector, r, OT_SYNC_CHUNK_SIZE ) ) ) in sync_make()
128 iovec_fixlast( iovec_entries, iovector, r ); in sync_make()
136 struct iovec *iovector; in sync_worker() local
143 sync_make( &iovec_entries, &iovector ); in sync_worker()
144 stats_issue_event( EVENT_SYNC_OUT, FLAG_TCP, iovec_length( &iovec_entries, &iovector) ); in sync_worker()
145 if( mutex_workqueue_pushresult( taskid, iovec_entries, iovector ) ) in sync_worker()
146 iovec_free( &iovec_entries, &iovector ); in sync_worker()
H A Dot_fullscrape.c47 static void fullscrape_make( int *iovec_entries, struct iovec **iovector, ot_tasktype mode );
58 struct iovec *iovector; in fullscrape_worker() local
65 fullscrape_make( &iovec_entries, &iovector, tasktype ); in fullscrape_worker()
66 if( mutex_workqueue_pushresult( taskid, iovec_entries, iovector ) ) in fullscrape_worker()
67 iovec_free( &iovec_entries, &iovector ); in fullscrape_worker()
87 static int fullscrape_increase( int *iovec_entries, struct iovec **iovector, in fullscrape_increase() argument
90 if( !( *r = iovec_fix_increase_or_free( iovec_entries, iovector, *r, OT_SCRAPE_CHUNK_SIZE ) ) ) { in fullscrape_increase()
119 static void fullscrape_make( int *iovec_entries, struct iovec **iovector, ot_tasktype mode ) { in fullscrape_make() argument
129 *iovector = NULL; in fullscrape_make()
130 if( !( r = iovec_increase( iovec_entries, iovector, OT_SCRAPE_CHUNK_SIZE ) ) ) in fullscrape_make()
[all …]
H A Dot_iovec.h11 void *iovec_increase( int *iovec_entries, struct iovec **iovector, size_t new_alloc );
12 void iovec_fixlast( int *iovec_entries, struct iovec **iovector, void *last_ptr );
13 void iovec_free( int *iovec_entries, struct iovec **iovector );
15 size_t iovec_length( int *iovec_entries, struct iovec **iovector );
17 void *iovec_fix_increase_or_free( int *iovec_entries, struct iovec **iovector, void *last_ptr, siz…
H A Dot_stats.c41 static void stats_make( int *iovec_entries, struct iovec **iovector, ot_tasktype mode );
517 iovec_fixlast( iovec_entries, iovector, r ); in stats_return_fulllog()
608 *iovector = NULL; in stats_make()
609 if( !( r = iovec_increase( iovec_entries, iovector, OT_STATS_TMPSIZE ) ) ) in stats_make()
626 case TASK_STATS_FULLLOG: stats_return_fulllog( iovec_entries, iovector, r ); in stats_make()
630 iovec_free(iovec_entries, iovector); in stats_make()
633 iovec_fixlast( iovec_entries, iovector, r ); in stats_make()
745 struct iovec *iovector; in stats_worker() local
752 stats_make( &iovec_entries, &iovector, tasktype ); in stats_worker()
753 if( mutex_workqueue_pushresult( taskid, iovec_entries, iovector ) ) in stats_worker()
[all …]
H A Dot_mutex.h72 int mutex_workqueue_pushresult( ot_taskid taskid, int iovec_entries, struct iovec *iovector );
73 int64 mutex_workqueue_popresult( int *iovec_entries, struct iovec ** iovector );
H A Dot_http.c117 …ovecdata( const int64 sock, struct ot_workstruct *ws, int iovec_entries, struct iovec *iovector ) { in http_sendiovecdata() argument
121 size_t header_size, size = iovec_length( &iovec_entries, &iovector ); in http_sendiovecdata()
126 iovec_free( &iovec_entries, &iovector ); in http_sendiovecdata()
144 iovec_free( &iovec_entries, &iovector ); in http_sendiovecdata()
160 iob_addbuf_munmap( &cookie->batch, iovector[i].iov_base, iovector[i].iov_len ); in http_sendiovecdata()
161 free( iovector ); in http_sendiovecdata()
H A Dot_http.h23 …endiovecdata( const int64 s, struct ot_workstruct *ws, int iovec_entries, struct iovec *iovector );
/dports/devel/pecl-swoole/swoole-4.8.5/tests/swoole_socket_coro/
H A DwriteVectorAll.phpt15 $iovector = [];
19 $iovector[$i] = str_repeat(get_safe_random(1024), 128);
20 $totalLength += strlen($iovector[$i]);
21 $packedStr .= $iovector[$i];
41 global $iovector, $totalLength;
45 $ret = $conn->writeVectorAll($iovector);
H A Dwritev_eagain.phpt16 $iovector = [];
20 $iovector[$i] = str_repeat(get_safe_random(1024), 128);
21 $totalLength += strlen($iovector[$i]);
22 $packedStr .= $iovector[$i];
45 global $iovector, $totalLength;
49 $ret = $conn->writeVectorAll($iovector);
H A DwriteVectorAll_ssl.phpt15 $iovector = [];
20 $iovector[$i] = str_repeat(get_safe_random(1024), 128);
21 $totalLength += strlen($iovector[$i]);
22 $packedStr .= $iovector[$i];
29 global $totalLength, $iovector;
36 $ret = $conn->writeVectorAll($iovector);
H A DwriteVector_ssl_eagain.phpt16 $iovector = [];
21 $iovector[$i] = str_repeat(get_safe_random(1024), 128);
22 $totalLength += strlen($iovector[$i]);
23 $packedStr .= $iovector[$i];
30 global $totalLength, $iovector;
37 $ret = $conn->writeVectorAll($iovector);
H A DreadVectorAll_ssl.phpt15 $iovector = [];
19 $iovector[$i] = str_repeat(get_safe_random(1024), 128);
20 $totalLength += strlen($iovector[$i]);
21 $packedStr .= $iovector[$i];
44 global $totalLength, $iovector;
63 Assert::eq($conn->readVectorAll($iov), $iovector);
H A DreadVectorAll.phpt15 $iovector = [];
20 $iovector[$i] = str_repeat(get_safe_random(1024), 128);
21 $totalLength += strlen($iovector[$i]);
22 $packedStr .= $iovector[$i];
37 global $packedStr, $iovector, $totalLength2;
44 Assert::eq($conn->readVectorAll($iov), $iovector);
H A DreadVector_ssl_eagain.phpt16 $iovector = [];
20 $iovector[$i] = str_repeat(get_safe_random(1024), 128);
21 $totalLength += strlen($iovector[$i]);
22 $packedStr .= $iovector[$i];
46 global $totalLength, $iovector;
65 Assert::eq($conn->readVectorAll($iov), $iovector);
H A Dreadv_eagain.phpt16 $iovector = [];
21 $iovector[$i] = str_repeat(get_safe_random(1024), 128);
22 $totalLength += strlen($iovector[$i]);
23 $packedStr .= $iovector[$i];
38 global $packedStr, $iovector, $totalLength2;
45 Assert::eq($conn->readVectorAll($iov), $iovector);
H A Dcheck_writev_readv_param_type.phpt16 $iovector = [1];
17 $conn->writeVectorAll($iovector);
24 $iovector = [1, '!'];
25 $conn->readVectorAll($iovector);
H A Diov_max.phpt15 $iovector = [];
19 $iovector[$i] = 'a';
27 Assert::false($conn->writeVectorAll($iovector));
/dports/net/libiscsi/libiscsi-1.19.0/lib/
H A Dsocket.c514 if (iovector->iov == NULL) { in iscsi_iovector_readv_writev()
519 if (pos < iovector->offset) { in iscsi_iovector_readv_writev()
526 if (iovector->niov <= iovector->consumed) { in iscsi_iovector_readv_writev()
535 iov = &iovector->iov[iovector->consumed]; in iscsi_iovector_readv_writev()
536 pos -= iovector->offset; in iscsi_iovector_readv_writev()
540 iovector->offset += iov->iov_len; in iscsi_iovector_readv_writev()
541 iovector->consumed++; in iscsi_iovector_readv_writev()
543 if (iovector->niov <= iovector->consumed) { in iscsi_iovector_readv_writev()
547 iov = &iovector->iov[iovector->consumed]; in iscsi_iovector_readv_writev()
558 if (iovector->niov < iovector->consumed + niov) { in iscsi_iovector_readv_writev()
[all …]
H A Dscsi-lowlevel.c4111 iovector->offset = 0; in scsi_task_reset_iov()
4112 iovector->consumed = 0; in scsi_task_reset_iov()
4124 if (iovector->iov == NULL) { in scsi_iovector_add()
4126 if (iovector->iov == NULL) { in scsi_iovector_add()
4133 if (iovector->nalloc < iovector->niov + 1) { in scsi_iovector_add()
4135 iovector->iov = scsi_malloc(task, 2 * iovector->nalloc * sizeof(struct iovec)); in scsi_iovector_add()
4139 memcpy(iovector->iov, old_iov, iovector->niov * sizeof(struct iovec)); in scsi_iovector_add()
4140 iovector->nalloc <<= 1; in scsi_iovector_add()
4143 iovector->iov[iovector->niov].iov_len = len; in scsi_iovector_add()
4144 iovector->iov[iovector->niov].iov_base = buf; in scsi_iovector_add()
[all …]
/dports/net/quagga/quagga-1.2.4/zebra/
H A Dirdp_packet.c280 struct iovec iovector; in send_packet() local
346 iovector.iov_base = (void *) buf; in send_packet()
347 iovector.iov_len = ip->ip_len; in send_packet()
351 msg->msg_iov = &iovector; in send_packet()
/dports/net/frr7-pythontools/frr-frr-7.5.1/zebra/
H A Dirdp_packet.c284 struct iovec iovector; in send_packet() local
353 iovector.iov_base = (void *)buf; in send_packet()
354 iovector.iov_len = ip->ip_len; in send_packet()
358 msg->msg_iov = &iovector; in send_packet()
/dports/net/frr7/frr-frr-7.5.1/zebra/
H A Dirdp_packet.c284 struct iovec iovector; in send_packet() local
353 iovector.iov_base = (void *)buf; in send_packet()
354 iovector.iov_len = ip->ip_len; in send_packet()
358 msg->msg_iov = &iovector; in send_packet()
/dports/lang/spidermonkey60/firefox-60.9.0/media/webrtc/trunk/webrtc/p2p/quic/
H A Dreliablequicstream_unittest.cc66 QuicIOVector iovector, in WritevData() argument
74 const char* data = reinterpret_cast<const char*>(iovector.iov->iov_base); in WritevData()
75 size_t len = iovector.total_length; in WritevData()
/dports/misc/mc/mc-4.8.27/lib/search/
H A Dregex.c350 lc_mc_search->iovector, MC_SEARCH__NUM_REPLACE_ARGS); in mc_search__regex_found_cond_one()
440 fnd_start = lc_mc_search->iovector[lc_index * 2 + 0]; in mc_search_regex__get_token_by_num()
441 fnd_end = lc_mc_search->iovector[lc_index * 2 + 1]; in mc_search_regex__get_token_by_num()
962 start_pos = lc_mc_search->iovector[0]; in mc_search__run_regex()
963 end_pos = lc_mc_search->iovector[1]; in mc_search__run_regex()

12