summaryrefslogtreecommitdiff
path: root/lib/ccan/read_write_all/test/run-write_all.c
blob: e2baf48dfe79893a9729b749516ebcdd3704c61e (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
#include <ccan/read_write_all/read_write_all.h>
#include <ccan/tap/tap.h>
#include <unistd.h>
#include <sys/types.h>
#include <signal.h>
#include <limits.h>
#include <sys/wait.h>
#include <err.h>
#include <stdlib.h>
#include <string.h>
#include <stdio.h>

static ssize_t test_write(int fd, const void *buf, size_t count);
#define write test_write
#include <ccan/read_write_all/read_write_all.c>
#undef write

static ssize_t write_return;

static ssize_t test_write(int fd, const void *buf, size_t count)
{
	if (write_return == 0) {
		errno = ENOSPC;
		return 0;
	}

	if (write_return < 0) {
		errno = -write_return;
		/* Don't return EINTR more than once! */
		if (errno == EINTR)
			write_return = count;
		return -1;
	}

	if (write_return < count)
		return write_return;
	return count;
}

#define BUFSZ 1024

int main(int argc, char *argv[])
{
	char *buffer;

	buffer = malloc(BUFSZ);
	plan_tests(8);

	write_return = -ENOSPC;
	ok1(!write_all(100, buffer, BUFSZ));
	ok1(errno == ENOSPC);

	write_return = -EINTR;
	ok1(write_all(100, buffer, BUFSZ));
	ok1(errno == EINTR);

	write_return = 1;
	errno = 0;
	ok1(write_all(100, buffer, BUFSZ));
	ok1(errno == 0);

	write_return = BUFSZ;
	ok1(write_all(100, buffer, BUFSZ));
	ok1(errno == 0);
	free(buffer);

	return exit_status();
}