summaryrefslogtreecommitdiff
path: root/ot_sync.c
diff options
context:
space:
mode:
Diffstat (limited to 'ot_sync.c')
-rw-r--r--ot_sync.c9
1 files changed, 7 insertions, 2 deletions
diff --git a/ot_sync.c b/ot_sync.c
index 6964098..ac1664d 100644
--- a/ot_sync.c
+++ b/ot_sync.c
@@ -4,6 +4,7 @@
4/* System */ 4/* System */
5#include <sys/types.h> 5#include <sys/types.h>
6#include <sys/mman.h> 6#include <sys/mman.h>
7#include <sys/uio.h>
7#include <stdio.h> 8#include <stdio.h>
8#include <string.h> 9#include <string.h>
9#include <pthread.h> 10#include <pthread.h>
@@ -11,11 +12,14 @@
11/* Libowfat */ 12/* Libowfat */
12#include "scan.h" 13#include "scan.h"
13#include "byte.h" 14#include "byte.h"
15#include "io.h"
14 16
15/* Opentracker */ 17/* Opentracker */
16#include "trackerlogic.h" 18#include "trackerlogic.h"
17#include "ot_mutex.h" 19#include "ot_mutex.h"
18#include "ot_sync.h" 20#include "ot_sync.h"
21#include "ot_stats.h"
22#include "ot_iovec.h"
19 23
20#ifdef WANT_TRACKER_SYNC 24#ifdef WANT_TRACKER_SYNC
21 25
@@ -25,9 +29,9 @@
25 format: d4:syncd[..]ee 29 format: d4:syncd[..]ee
26 [..]: ( 20:01234567890abcdefghij16:XXXXYYYY )+ 30 [..]: ( 20:01234567890abcdefghij16:XXXXYYYY )+
27*/ 31*/
28int add_changeset_to_tracker( ot_byte *data, size_t len ) { 32int add_changeset_to_tracker( uint8_t *data, size_t len ) {
29 ot_hash *hash; 33 ot_hash *hash;
30 ot_byte *end = data + len; 34 uint8_t *end = data + len;
31 unsigned long peer_count; 35 unsigned long peer_count;
32 36
33 /* We do know, that the string is \n terminated, so it cant 37 /* We do know, that the string is \n terminated, so it cant
@@ -135,6 +139,7 @@ static void * sync_worker( void * args) {
135 ot_tasktype tasktype = TASK_SYNC_OUT; 139 ot_tasktype tasktype = TASK_SYNC_OUT;
136 ot_taskid taskid = mutex_workqueue_poptask( &tasktype ); 140 ot_taskid taskid = mutex_workqueue_poptask( &tasktype );
137 sync_make( &iovec_entries, &iovector ); 141 sync_make( &iovec_entries, &iovector );
142 stats_issue_event( EVENT_SYNC_OUT, 1, iovec_length( &iovec_entries, &iovector) );
138 if( mutex_workqueue_pushresult( taskid, iovec_entries, iovector ) ) 143 if( mutex_workqueue_pushresult( taskid, iovec_entries, iovector ) )
139 iovec_free( &iovec_entries, &iovector ); 144 iovec_free( &iovec_entries, &iovector );
140 } 145 }