Loading prrt/proto/socket.c +1 −1 Original line number Diff line number Diff line Loading @@ -252,7 +252,7 @@ bool PrrtSocket_closing(PrrtSocket *s) { return atomic_load_explicit(&s->closing, memory_order_acquire); } void inline PrrtSocket_pace(PrrtSocket *s) { void PrrtSocket_pace(PrrtSocket *s) { if (s->pacingEnabled && s->nextSendTime != 0) { debug(DEBUG_DATATRANSMITTER, "About to check for pacing."); prrtTimeDifference_t diff = 0; Loading prrt/proto/socket.h +1 −1 Original line number Diff line number Diff line Loading @@ -125,7 +125,7 @@ int32_t PrrtSocket_receive_ordered(PrrtSocket *s, void *buf_ptr, struct sockaddr int32_t PrrtSocket_receive_ordered_wait(PrrtSocket *s, void *buf_ptr, struct sockaddr* addr, prrtTimedelta_t time_window_us); int32_t PrrtSocket_receive_ordered_timedwait(PrrtSocket *s, void *buf_ptr, struct sockaddr* addr, prrtTimedelta_t time_window_us, struct timespec* deadline); void inline PrrtSocket_pace(PrrtSocket *s); void PrrtSocket_pace(PrrtSocket *s); bool PrrtSocket_cleanup(PrrtSocket *s); Loading Loading
prrt/proto/socket.c +1 −1 Original line number Diff line number Diff line Loading @@ -252,7 +252,7 @@ bool PrrtSocket_closing(PrrtSocket *s) { return atomic_load_explicit(&s->closing, memory_order_acquire); } void inline PrrtSocket_pace(PrrtSocket *s) { void PrrtSocket_pace(PrrtSocket *s) { if (s->pacingEnabled && s->nextSendTime != 0) { debug(DEBUG_DATATRANSMITTER, "About to check for pacing."); prrtTimeDifference_t diff = 0; Loading
prrt/proto/socket.h +1 −1 Original line number Diff line number Diff line Loading @@ -125,7 +125,7 @@ int32_t PrrtSocket_receive_ordered(PrrtSocket *s, void *buf_ptr, struct sockaddr int32_t PrrtSocket_receive_ordered_wait(PrrtSocket *s, void *buf_ptr, struct sockaddr* addr, prrtTimedelta_t time_window_us); int32_t PrrtSocket_receive_ordered_timedwait(PrrtSocket *s, void *buf_ptr, struct sockaddr* addr, prrtTimedelta_t time_window_us, struct timespec* deadline); void inline PrrtSocket_pace(PrrtSocket *s); void PrrtSocket_pace(PrrtSocket *s); bool PrrtSocket_cleanup(PrrtSocket *s); Loading