/dports/net/opentracker/opentracker-0.2017.08.13/ |
H A D | ot_iovec.c | 22 *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 D | ot_sync.c | 73 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 D | ot_fullscrape.c | 47 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 D | ot_iovec.h | 11 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 D | ot_stats.c | 41 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 D | ot_mutex.h | 72 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 D | ot_http.c | 117 …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 D | ot_http.h | 23 …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 D | writeVectorAll.phpt | 15 $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 D | writev_eagain.phpt | 16 $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 D | writeVectorAll_ssl.phpt | 15 $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 D | writeVector_ssl_eagain.phpt | 16 $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 D | readVectorAll_ssl.phpt | 15 $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 D | readVectorAll.phpt | 15 $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 D | readVector_ssl_eagain.phpt | 16 $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 D | readv_eagain.phpt | 16 $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 D | check_writev_readv_param_type.phpt | 16 $iovector = [1]; 17 $conn->writeVectorAll($iovector); 24 $iovector = [1, '!']; 25 $conn->readVectorAll($iovector);
|
H A D | iov_max.phpt | 15 $iovector = []; 19 $iovector[$i] = 'a'; 27 Assert::false($conn->writeVectorAll($iovector));
|
/dports/net/libiscsi/libiscsi-1.19.0/lib/ |
H A D | socket.c | 514 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 D | scsi-lowlevel.c | 4111 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 D | irdp_packet.c | 280 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 D | irdp_packet.c | 284 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 D | irdp_packet.c | 284 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 D | reliablequicstream_unittest.cc | 66 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 D | regex.c | 350 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()
|