96 	int len = 0;  in read_data()  local
99 	len = read(pfd, buf, size);  in read_data()
101 	if (len < 0)  in read_data()
104 	return len;  in read_data()
179 	socklen_t len = sizeof(consumer_addr);  in main()  local
211 	pfd = accept(lfd, (struct sockaddr *) &paddr, &len);  in main()
224 	len = read_data(pfd, buf, 1024);  in main()
225 	if (!signal_recvd || len != 63 || oob != '@') {  in main()
226 		fprintf(stderr, "Test 1 failed sigurg %d len %d %c\n",  in main()
227 			 signal_recvd, len, oob);  in main()
240 	len = 0;  in main()
241 	while (len < 70)  in main()
242 		len = recv(pfd, buf, 1024, MSG_PEEK);  in main()
243 	len = read_data(pfd, buf, 1024);  in main()
245 	if (!signal_recvd || len != 127 || oob != '#') {  in main()
246 		fprintf(stderr, "Test 2 failed, sigurg %d len %d OOB %c\n",  in main()
247 		signal_recvd, len, oob);  in main()
263 	len = 0;  in main()
265 	while (len < 150)  in main()
266 		len = recv(pfd, buf, 1024, MSG_PEEK);  in main()
267 	len = read_data(pfd, buf, 1024);  in main()
271 	if (!signal_recvd || len != 127 || oob != '%' || atmark != 1) {  in main()
273 			"Test 3 failed, sigurg %d len %d OOB %c atmark %d\n",  in main()
274 			signal_recvd, len, oob, atmark);  in main()
280 	len = read_data(pfd, buf, 1024);  in main()
281 	if (len != 64) {  in main()
282 		fprintf(stderr, "Test 3.1 failed, sigurg %d len %d OOB %c\n",  in main()
283 			signal_recvd, len, oob);  in main()
303 	len = read_data(pfd, buf, 1024);  in main()
304 	if ((len == -1) && (errno == 11))  in main()
305 		len = 0;  in main()
309 	if (!signal_recvd || len != 0 || oob != '@') {  in main()
310 		fprintf(stderr, "Test 4 failed, sigurg %d len %d OOB %c\n",  in main()
311 			 signal_recvd, len, oob);  in main()
335 	len = read_data(pfd, buf, 1024);  in main()
337 	if (!signal_recvd || len != 63) {  in main()
338 		fprintf(stderr, "Test 1 Inline failed, sigurg %d len %d\n",  in main()
339 			signal_recvd, len);  in main()
343 	len = read_data(pfd, buf, 1024);  in main()
345 	if (len != 1) {  in main()
347 			 "Test 1.1 Inline failed, sigurg %d len %d oob %c\n",  in main()
348 			 signal_recvd, len, oob);  in main()
364 	len = 0;  in main()
366 	while (len < 70)  in main()
367 		len = recv(pfd, buf, 1024, MSG_PEEK);  in main()
368 	len = read_data(pfd, buf, 1024);  in main()
370 	if (len != 127 || atmark != 1 || !signal_recvd) {  in main()
371 		fprintf(stderr, "Test 2 Inline failed, len %d atmark %d\n",  in main()
372 			 len, atmark);  in main()
376 	len = read_data(pfd, buf, 1024);  in main()
378 	if (len != 1 || buf[0] != '#' || atmark == 1) {  in main()
379 		fprintf(stderr, "Test 2.1 Inline failed, len %d data %c atmark %d\n",  in main()
380 			len, buf[0], atmark);  in main()
396 	len = 0;  in main()
398 	while (len < 126)  in main()
399 		len = recv(pfd, buf, 1024, MSG_PEEK);  in main()
400 	len = read_data(pfd, buf, 1024);  in main()
402 	if (!signal_recvd || len != 127 || !atmark) {  in main()
404 			 "Test 3 Inline failed, sigurg %d len %d data %c\n",  in main()
405 			 signal_recvd, len, buf[0]);  in main()
409 	len = read_data(pfd, buf, 1024);  in main()
411 	if (len != 65 || buf[0] != '%' || atmark != 0) {  in main()
413 			 "Test 3.1 Inline failed, len %d oob %c atmark %d\n",  in main()
414 			 len, buf[0], atmark);  in main()
428 	len = read_data(pfd, buf, 1024);  in main()
429 	if (!signal_recvd || len != 1 || buf[0] != '@') {  in main()
431 			"Test 4 Inline failed, signal %d len %d data %c\n",  in main()
432 		signal_recvd, len, buf[0]);  in main()