Loading prrt/time-protocol.h +2 −2 Original line number Diff line number Diff line Loading @@ -109,7 +109,7 @@ static inline void _close(socket_t conn) typedef PrrtSocket *socket_t; static inline socket_t _open_sender(struct arguments *args) { PrrtSocket *s = PrrtSocket_create(300 * 1000); PrrtSocket *s = PrrtSocket_create(args->size, 300 * 1000); s->withTimestamp = true; assert(s != NULL && "Socket create failed."); Loading @@ -124,7 +124,7 @@ static inline socket_t _open_sender(struct arguments *args) { } static inline socket_t _open_receiver(struct arguments *args) { socket_t s = PrrtSocket_create(HALF_TIMESTAMP - 1); socket_t s = PrrtSocket_create(args->size, HALF_TIMESTAMP - 1); assert(s != NULL && "Could not create socket."); if (args->thread_pinning) { Loading Loading
prrt/time-protocol.h +2 −2 Original line number Diff line number Diff line Loading @@ -109,7 +109,7 @@ static inline void _close(socket_t conn) typedef PrrtSocket *socket_t; static inline socket_t _open_sender(struct arguments *args) { PrrtSocket *s = PrrtSocket_create(300 * 1000); PrrtSocket *s = PrrtSocket_create(args->size, 300 * 1000); s->withTimestamp = true; assert(s != NULL && "Socket create failed."); Loading @@ -124,7 +124,7 @@ static inline socket_t _open_sender(struct arguments *args) { } static inline socket_t _open_receiver(struct arguments *args) { socket_t s = PrrtSocket_create(HALF_TIMESTAMP - 1); socket_t s = PrrtSocket_create(args->size, HALF_TIMESTAMP - 1); assert(s != NULL && "Could not create socket."); if (args->thread_pinning) { Loading