/* Retrieve socket's port number. */
sin_len = sizeof sin;
- if (getsockname(fd, &sin, &sin_len) < 0) {
+ if (getsockname(fd, (struct sockaddr *)&sin, &sin_len) < 0) {
ovs_fatal(errno, "failed to read TCP socket name");
}
if (sin_len != sizeof sin || sin.sin_family != AF_INET) {
fpv_create(type, &fpv);
assert(!vconn_open(fpv.vconn_name, OFP_VERSION, &vconn));
fpv_close(&fpv);
+ vconn_run(vconn);
assert(vconn_connect(vconn) == expected_error);
vconn_close(vconn);
fpv_destroy(&fpv);
fpv_create(type, &fpv);
assert(!vconn_open(fpv.vconn_name, OFP_VERSION, &vconn));
+ vconn_run(vconn);
close(fpv_accept(&fpv));
fpv_close(&fpv);
assert(vconn_connect(vconn) == expected_error);
fpv_create(type, &fpv);
assert(!vconn_open(fpv.vconn_name, OFP_VERSION, &vconn));
+ vconn_run(vconn);
fd = fpv_accept(&fpv);
fpv_destroy(&fpv);
assert(!set_nonblocking(fd));
assert(errno == EAGAIN);
}
+ vconn_run(vconn);
assert(vconn_connect(vconn) == EAGAIN);
+ vconn_run_wait(vconn);
vconn_connect_wait(vconn);
poll_fd_wait(fd, POLLIN);
poll_block();
fpv_create(type, &fpv);
assert(!vconn_open(fpv.vconn_name, OFP_VERSION, &vconn));
+ vconn_run(vconn);
fd = fpv_accept(&fpv);
fpv_destroy(&fpv);
- write(fd, out, out_size);
+ assert(write(fd, out, out_size) == out_size);
assert(!set_nonblocking(fd));
}
}
+ vconn_run(vconn);
if (!connected) {
int error = vconn_connect(vconn);
if (error == expect_connect_error) {
break;
}
+ vconn_run_wait(vconn);
if (!connected) {
vconn_connect_wait(vconn);
}