diff options
-rw-r--r-- | proxy.c | 8 |
1 files changed, 5 insertions, 3 deletions
@@ -32,10 +32,12 @@ | |||
32 | #include "ot_mutex.h" | 32 | #include "ot_mutex.h" |
33 | #include "ot_stats.h" | 33 | #include "ot_stats.h" |
34 | 34 | ||
35 | #ifndef WANT_SYNC_LIVE | ||
35 | #define WANT_SYNC_LIVE | 36 | #define WANT_SYNC_LIVE |
37 | #endif | ||
36 | #include "ot_livesync.h" | 38 | #include "ot_livesync.h" |
37 | 39 | ||
38 | ot_ip6 g_serverip; | 40 | ot_ip6 g_serverip; |
39 | uint16_t g_serverport = 9009; | 41 | uint16_t g_serverport = 9009; |
40 | uint32_t g_tracker_id; | 42 | uint32_t g_tracker_id; |
41 | char groupip_1[4] = { 224,0,23,5 }; | 43 | char groupip_1[4] = { 224,0,23,5 }; |
@@ -59,7 +61,7 @@ int g_self_pipe[2]; | |||
59 | /* So after each bucket wait 1 / OT_BUCKET_COUNT intervals */ | 61 | /* So after each bucket wait 1 / OT_BUCKET_COUNT intervals */ |
60 | #define OT_SYNC_SLEEP ( ( ( OT_SYNC_INTERVAL_MINUTES ) * 60 * 1000000 ) / ( OT_BUCKET_COUNT ) ) | 62 | #define OT_SYNC_SLEEP ( ( ( OT_SYNC_INTERVAL_MINUTES ) * 60 * 1000000 ) / ( OT_BUCKET_COUNT ) ) |
61 | 63 | ||
62 | enum { OT_SYNC_PEER = 0xbeef }; | 64 | enum { OT_SYNC_PEER }; |
63 | enum { FLAG_SERVERSOCKET = 1 }; | 65 | enum { FLAG_SERVERSOCKET = 1 }; |
64 | 66 | ||
65 | /* For incoming packets */ | 67 | /* For incoming packets */ |
@@ -614,7 +616,7 @@ static void * streamsync_worker( void * args ) { | |||
614 | mem = 3 * ( 4 + 1 + 1 + 2 ) + ( count_one + count_two ) * 19 + count_def * 20 + | 616 | mem = 3 * ( 4 + 1 + 1 + 2 ) + ( count_one + count_two ) * 19 + count_def * 20 + |
615 | ( count_one + 2 * count_two + count_peers ) * 7; | 617 | ( count_one + 2 * count_two + count_peers ) * 7; |
616 | 618 | ||
617 | fprintf( stderr, "Mem: %d\n", mem ); | 619 | fprintf( stderr, "Mem: %zd\n", mem ); |
618 | 620 | ||
619 | ptr = ptr_a = ptr_b = ptr_c = malloc( mem ); | 621 | ptr = ptr_a = ptr_b = ptr_c = malloc( mem ); |
620 | if( !ptr ) goto unlock_continue; | 622 | if( !ptr ) goto unlock_continue; |