Fixed type in selftest
This commit is contained in:
@@ -370,6 +370,7 @@ void wait_until_everyone_is_ready(struct sockaddr *local_addr, struct sockaddr *
|
|||||||
while(connected == false) {
|
while(connected == false) {
|
||||||
if ((err = CONNECT(conn_fd, (const struct sockaddr *)remote_addr, sizeof(*remote_addr))) < 0) {
|
if ((err = CONNECT(conn_fd, (const struct sockaddr *)remote_addr, sizeof(*remote_addr))) < 0) {
|
||||||
if (errno == EISCONN) {
|
if (errno == EISCONN) {
|
||||||
|
DEBUG_TEST("connected");
|
||||||
connected = true;
|
connected = true;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -380,16 +381,20 @@ void wait_until_everyone_is_ready(struct sockaddr *local_addr, struct sockaddr *
|
|||||||
struct sockaddr_in client;
|
struct sockaddr_in client;
|
||||||
socklen_t client_addrlen = sizeof(sockaddr_in);
|
socklen_t client_addrlen = sizeof(sockaddr_in);
|
||||||
if ((accepted_fd = ACCEPT(listen_fd, (struct sockaddr *)&client, &client_addrlen)) < 0) {
|
if ((accepted_fd = ACCEPT(listen_fd, (struct sockaddr *)&client, &client_addrlen)) < 0) {
|
||||||
DEBUG_TEST("errno = %d", errno);}
|
DEBUG_TEST("errno = %d", errno);
|
||||||
|
}
|
||||||
else {
|
else {
|
||||||
|
DEBUG_TEST("connected");
|
||||||
connected = true;
|
connected = true;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
sleep(1);
|
sleep(1);
|
||||||
}
|
}
|
||||||
close(listen_fd);
|
DEBUG_TEST("closing");
|
||||||
close(conn_fd);
|
CLOSE(listen_fd);
|
||||||
close(accepted_fd);
|
CLOSE(conn_fd);
|
||||||
|
CLOSE(accepted_fd);
|
||||||
|
DEBUG_TEST("returning");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user