| /dports/net/opentracker/opentracker-0.2017.08.13/ |
| H A D | ot_iovec.c | 26 ((*iovector)[*iovec_entries]).iov_base = new_ptr; in iovec_increase()
27 ((*iovector)[*iovec_entries]).iov_len = new_alloc; in iovec_increase()
28 ++*iovec_entries; in iovec_increase()
34 for( i=0; i<*iovec_entries; ++i ) in iovec_free()
36 *iovec_entries = 0; in iovec_free()
44 if( !*iovec_entries ) return; 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
78 *iovec_entries = 0; 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()
135 int iovec_entries; 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 );
57 int iovec_entries; 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
128 *iovec_entries = 0; 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_mutex.c | 120 int iovec_entries; member
155 task->iovec_entries = 0; in mutex_workqueue_pushtask()
186 for( i=0; i<(*task)->iovec_entries; ++i ) in mutex_workqueue_canceltask()
259 int mutex_workqueue_pushresult( ot_taskid taskid, int iovec_entries, struct iovec *iovec ) { in mutex_workqueue_pushresult() argument
273 task->iovec_entries = iovec_entries; in mutex_workqueue_pushresult()
289 int64 mutex_workqueue_popresult( int *iovec_entries, struct iovec ** iovec ) { in mutex_workqueue_popresult() argument
305 *iovec_entries = (*task)->iovec_entries; in mutex_workqueue_popresult()
|
| 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()
607 *iovec_entries = 0; 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()
744 int iovec_entries; 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 ssize_t http_sendiovecdata( const int64 sock, struct ot_workstruct *ws, int iovec_entries, struct i… 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()
137 if( !iovec_entries ) { in http_sendiovecdata()
144 iovec_free( &iovec_entries, &iovector ); in http_sendiovecdata()
159 for( i=0; i<iovec_entries; ++i ) in http_sendiovecdata()
|
| H A D | ot_http.h | 23 ssize_t http_sendiovecdata( const int64 s, struct ot_workstruct *ws, int iovec_entries, struct iove…
|
| H A D | opentracker.c | 248 int iovec_entries; in server_mainloop() local
278 while( ( sock = mutex_workqueue_popresult( &iovec_entries, &iovector ) ) != -1 ) in server_mainloop()
279 http_sendiovecdata( sock, &ws, iovec_entries, iovector ); in server_mainloop()
|
| H A D | opentracker-ipv6.c | 248 int iovec_entries; in server_mainloop() local
278 while( ( sock = mutex_workqueue_popresult( &iovec_entries, &iovector ) ) != -1 ) in server_mainloop()
279 http_sendiovecdata( sock, &ws, iovec_entries, iovector ); in server_mainloop()
|