Attachment 158189 Details for Bug 244708 – Userland test program

Userland test program

test.c (text/x-csrc), 2.07 KB, created by Christine Caulfield on 2007-06-29 09:19:25 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: Christine Caulfield

Created: 2007-06-29 09:19:25 UTC

Size: 2.07 KB

patch

obsolete

>#include <pthread.h>
>#include <sys/socket.h>
>#include <netinet/in.h>
>#include <sys/types.h>
>#include <stdio.h>
>#include <stdlib.h>
>#include <unistd.h>
>#include <string.h>
>#include <arpa/inet.h>
>#include <errno.h>
>
>int writelen = 6;
>
>int tcp_port = 21164;
>int listen_fd = 0;
>int read_fd;
>
>static int start_listen()
>{
>	struct sockaddr_in addr;
>	socklen_t len;
>
>	listen_fd = socket(AF_INET, SOCK_STREAM, 0);
>
>	if (listen_fd < 0)
>	{
>		return -1;
>	}
>	else
>	{
>		int one = 1;
>		setsockopt(listen_fd, SOL_SOCKET, SO_REUSEADDR, &one, sizeof(int));
>	}
>
>	memset(&addr, 0, sizeof(addr)); // Bind to INADDR_ANY
>	addr.sin_family = AF_INET;
>	addr.sin_port = htons(tcp_port);
>
>	if (bind(listen_fd, (struct sockaddr *)&addr, sizeof(addr)) < 0)
>	{
>		perror("Can't bind to port");
>		close(listen_fd);
>		exit(1);
>	}
>
>	listen(listen_fd, 5);
>
>	read_fd = accept(listen_fd, (struct sockaddr *)&addr, &len);
>	return 0;
>}
>
>static int connect_node(const char *node)
>{
>	int fd;
>	struct sockaddr_in addr;
>
>	fd = socket(PF_INET, SOCK_STREAM, 0);
>	if (fd < 0)
>	{
>		perror("Unable to create new socket");
>		return -1;
>	}
>
>	addr.sin_family = AF_INET;
>	inet_pton(AF_INET, node, &addr.sin_addr);
>	addr.sin_port = htons(tcp_port);
>
>	if (connect(fd, (struct sockaddr *)&addr, sizeof(struct sockaddr_in)) < 0)
>	{
>		if (errno != ECONNREFUSED)
>		{
>			perror("Unable to connect to remote node");
>		}
>		close(fd);
>		exit(1);
>	}
>
>	read_fd = fd;
>	return 0;
>}
>
>static void server()
>{
>	char buf[1024];
>	int len;
>
>	while (1)
>	{
>		len = read(read_fd, buf, writelen);
>		if (len && buf[0])
>			write(read_fd, "REPLY", writelen); // Reply if requested.
>
>		if (len == 0) // EOF - quit
>			exit(0);
>	}
>}
>
>static void client()
>{
>	char buf[1024];
>	int len;
>	int i;
>
>	while (1)
>	{
>		for (i=0; i<2; i++)
>		{
>			if (write(read_fd, "HELLO", 6) < 1)
>			{
>				perror("write");
>				exit(1);
>			}
>			len = read(read_fd, buf, writelen);
>			if (len == 0)
>				exit(0);
>		}
>
>		write(read_fd, "\0IGNORE", writelen); // No reply wanted
>	}
>}
>
>int main(int argc, char *argv[])
>{
>
>	if (argc <= 1)
>	{
>		start_listen();
>		server();
>	}
>	else
>	{
>		connect_node(argv[1]);
>		client();
>	}
>	return 0;
>}

Actions: View

Attachments on bug 244708: 157305 | 157306 | 157391 | 157531 | 157628 | 158189 | 158327