Commit 42e04a48 authored by Andreas Schmidt's avatar Andreas Schmidt
Browse files

Ordered wait.

parent 4762a168

prrt/time-protocol.h

+2 −2
Original line number Diff line number Diff line
@@ -106,7 +106,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(true, 20 * 1000);

    PrrtSocket *s = PrrtSocket_create(true, 10 * 1000);

    assert(s != NULL && "Socket create failed.");



    if (args->thread_pinning) {
@@ -136,7 +136,7 @@ static inline void _send(socket_t conn, const char *buf, size_t size) { 
}



static inline ssize_t _recv(socket_t conn, char *buf, size_t size) {

    return PrrtSocket_receive_asap_wait(conn, buf);

    return PrrtSocket_receive_ordered_wait(conn, buf, 5 * 1000);

}



static inline void _close(socket_t conn) {