unit-tests: Use send/recv on socket in watcher tests
Windows does not support read/write on sockets.
This commit is contained in:
@@ -48,7 +48,7 @@ START_TEST(test_read)
|
|||||||
|
|
||||||
for (c = 'a'; c <= 'z'; c++)
|
for (c = 'a'; c <= 'z'; c++)
|
||||||
{
|
{
|
||||||
ck_assert_int_eq(write(fd[1], &c, 1), 1);
|
ck_assert_int_eq(send(fd[1], &c, 1, 0), 1);
|
||||||
while (testbuf[0] != c)
|
while (testbuf[0] != c)
|
||||||
{
|
{
|
||||||
sched_yield();
|
sched_yield();
|
||||||
@@ -84,7 +84,7 @@ START_TEST(test_write)
|
|||||||
|
|
||||||
lib->watcher->add(lib->watcher, fd[1], WATCHER_WRITE, writecb, &in);
|
lib->watcher->add(lib->watcher, fd[1], WATCHER_WRITE, writecb, &in);
|
||||||
|
|
||||||
ck_assert_int_eq(read(fd[0], &out, 1), 1);
|
ck_assert_int_eq(recv(fd[0], &out, 1, 0), 1);
|
||||||
ck_assert_int_eq(out, in);
|
ck_assert_int_eq(out, in);
|
||||||
|
|
||||||
lib->watcher->remove(lib->watcher, fd[1]);
|
lib->watcher->remove(lib->watcher, fd[1]);
|
||||||
@@ -123,7 +123,7 @@ START_TEST(test_multiread)
|
|||||||
{
|
{
|
||||||
for (in = 'a'; in <= 'z'; in++)
|
for (in = 'a'; in <= 'z'; in++)
|
||||||
{
|
{
|
||||||
ck_assert_int_eq(write(fd[i][1], &in, 1), 1);
|
ck_assert_int_eq(send(fd[i][1], &in, 1, 0), 1);
|
||||||
while (out[i] != in)
|
while (out[i] != in)
|
||||||
{
|
{
|
||||||
sched_yield();
|
sched_yield();
|
||||||
@@ -171,7 +171,7 @@ START_TEST(test_multiwrite)
|
|||||||
{
|
{
|
||||||
for (i = 0; i < countof(fd); i++)
|
for (i = 0; i < countof(fd); i++)
|
||||||
{
|
{
|
||||||
ck_assert_int_eq(read(fd[i][0], &out, 1), 1);
|
ck_assert_int_eq(recv(fd[i][0], &out, 1, 0), 1);
|
||||||
ck_assert_int_eq(out, i);
|
ck_assert_int_eq(out, i);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user