diff options
Diffstat (limited to 'ot_sync.c')
| -rw-r--r-- | ot_sync.c | 4 |
1 files changed, 2 insertions, 2 deletions
| @@ -23,7 +23,7 @@ | |||
| 23 | #include "ot_stats.h" | 23 | #include "ot_stats.h" |
| 24 | #include "ot_iovec.h" | 24 | #include "ot_iovec.h" |
| 25 | 25 | ||
| 26 | #ifdef WANT_TRACKER_SYNC | 26 | #ifdef WANT_SYNC_BATCH |
| 27 | 27 | ||
| 28 | #define OT_SYNC_CHUNK_SIZE (512*1024) | 28 | #define OT_SYNC_CHUNK_SIZE (512*1024) |
| 29 | 29 | ||
| @@ -141,7 +141,7 @@ static void * sync_worker( void * args) { | |||
| 141 | ot_tasktype tasktype = TASK_SYNC_OUT; | 141 | ot_tasktype tasktype = TASK_SYNC_OUT; |
| 142 | ot_taskid taskid = mutex_workqueue_poptask( &tasktype ); | 142 | ot_taskid taskid = mutex_workqueue_poptask( &tasktype ); |
| 143 | sync_make( &iovec_entries, &iovector ); | 143 | sync_make( &iovec_entries, &iovector ); |
| 144 | stats_issue_event( EVENT_SYNC_OUT, 1, iovec_length( &iovec_entries, &iovector) ); | 144 | stats_issue_event( EVENT_SYNC_OUT, FLAG_TCP, iovec_length( &iovec_entries, &iovector) ); |
| 145 | if( mutex_workqueue_pushresult( taskid, iovec_entries, iovector ) ) | 145 | if( mutex_workqueue_pushresult( taskid, iovec_entries, iovector ) ) |
| 146 | iovec_free( &iovec_entries, &iovector ); | 146 | iovec_free( &iovec_entries, &iovector ); |
| 147 | } | 147 | } |
