save state

prrt/proto/socket.c

@@ -21,6 +21,8 @@
 #include "socket.h"
 #include "timer.h"
 
+FILE *prrt_debug_log;
+
 static inline prrtPacketLength_t deliver_packet(const PrrtSocket *s, void *buffer, PrrtPacket *packet, struct sockaddr* addr) {
     size_t timespec_size = sizeof(struct timespec);
     prrtPacketLength_t len = 0;
@@ -137,6 +139,8 @@ PrrtSocket *PrrtSocket_create(prrtByteCount_t maximum_payload_size, prrtTimedelt
     s->prrtReceivePace = PrrtPace_create();
     s->appDeliverPace = PrrtPace_create();
     
+    prrt_debug_log = stderr;
+
     return s;
 
     error:

prrt/proto/stores/pace.c

@@ -9,9 +9,9 @@ PrrtPace* PrrtPace_create(void) {
     PrrtPace* pace = (PrrtPace*) calloc(1, sizeof(PrrtPace));
     check_mem(pace);
     prrtTimedelta_t filterLength_us = 2 * 1000 * 1000; // 2 seconds
-    pace->internalPace = PrrtPaceFilter_create(filterLength_us, FILTER_TYPE_MAX);
-    pace->dependentPace = PrrtPaceFilter_create(filterLength_us, FILTER_TYPE_MAX);
-    pace->externalPace = PrrtPaceFilter_create(filterLength_us, FILTER_TYPE_MAX);
+    pace->internalPace = PrrtPaceFilter_create(filterLength_us, FILTER_TYPE_MIN);
+    pace->dependentPace = PrrtPaceFilter_create(filterLength_us, FILTER_TYPE_MIN);
+    pace->externalPace = PrrtPaceFilter_create(filterLength_us, FILTER_TYPE_MIN);
 
     pace->totalPauseDuration_ns = 0;
     pace->initialized = false;

prrt/util/dbg.h

@@ -22,8 +22,10 @@
 #define DEBUG_FEEDBACK        0
 #define DEBUG_TIMERECEIVER    1
 
+extern FILE *prrt_debug_log;
+
 #ifdef DEBUG
-#define debug(DOMAIN, M, ...) do { if (DEBUG_ALL||(DOMAIN)) fprintf(stderr, "DEBUG %-20s %s:%d: " M "\n", #DOMAIN + 6, __FILE__, __LINE__, ##__VA_ARGS__); } while (0)
+#define debug(DOMAIN, M, ...) do { if (DEBUG_ALL||(DOMAIN)) fprintf(prrt_debug_log, "DEBUG %-20s %s:%d: " M "\n", #DOMAIN + 6, __FILE__, __LINE__, ##__VA_ARGS__); } while (0)
 #else
 #define debug(DOMAIN, M, ...)
 #endif