www.pudn.com > Tornado_Train_Workshop_demo_program.rar > seqServer.c

/* seqServer - sequentially print a message to service client requests */ 
 
/* Copyright 1984-1993 Wind River Systems, Inc. */ 
 
/* 
modification history 
-------------------- 
01b,06dec94,bss  cleaned up. 
01a,???????,???  written. 
*/ 
 
/* 
DESCRIPTION 
 
This server is a simple example of a TCP server.  After 
setting up a TCP socket, seqServer goes into an infinite loop, 
processing client requests sequentially. 
*/ 
 
/* includes */ 
 
#include "vxWorks.h" 
#include "advTCPLab.h" 
#include "errno.h" 
#include "inetLib.h" 
#include "ioLib.h" 
#include "netinet/in.h" 
#include "sockLib.h" 
#include "stdio.h" 
#include "string.h" 
#include "sys/socket.h" 
#include "sys/types.h" 
#include "taskLib.h" 
 
/* defines */ 
 
#define MAX_MSG_LEN 80 
 
#define CON_SLAVE_PRIORITY	  100 
#define CON_SLAVE_OPTIONS	   0 
#define CON_SLAVE_STACK_SIZE	6000 
 
/* typedefs */ 
 
typedef int SOCK_FD; 
 
/* forward declarations */ 
 
LOCAL void doRequest(SOCK_FD sock, struct sockaddr_in *pClientAddr); 
LOCAL void error (char * pStr); 
 
/******************************************************************************* 
 * 
 * vxServer - accepts client requests and processes them 
 * 
 */ 
 
int vxServer(void) 
	{ 
    int 				clientAddrLength; 
	SOCK_FD             sockFd;     /* used to accept clients' requests */ 
	SOCK_FD             newSockFd;  /* connected to new client */ 
	struct sockaddr_in  clientAddr; 
	struct sockaddr_in  srvAddr; 
 
	clientAddrLength = sizeof (clientAddr); 
 
	/* Create a socket */ 
	if ( (sockFd = socket (PF_INET, SOCK_STREAM, IPPROTO_TCP)) < 0 ) 
		error ("Socket failed"); 
 
	/*  
	 * Bind to a well known address. INADDR_ANY says any network 
	 * interface will do. hton?() routines put things in network 
	 * byte order  
	 */ 
 
	bzero ((char *)&srvAddr, sizeof(srvAddr)); 
	srvAddr.sin_family		= AF_INET; 
	srvAddr.sin_port		= htons (SRV_PORT); 
	srvAddr.sin_addr.s_addr = INADDR_ANY; 
 
	if (bind (sockFd, (struct sockaddr *) &srvAddr, sizeof(srvAddr)) < 0) 
		{ 
		close (sockFd); 
		error ("Bind failed"); 
		} 
 
	/* Queue uo to five requests (max allowed by TCP) */ 
	if (listen (sockFd, 5) < 0) 
		{ 
		close (sockFd); 
		error ("Listen failed"); 
		} 
 
	/* Service requests */ 
	FOREVER  
		{ 
		newSockFd = accept (sockFd, (struct sockaddr *) &clientAddr, 
							&clientAddrLength); 
		if (newSockFd < 0) 
			{ 
			close (sockFd); 
			error ("Accept failed"); 
			} 
 
		doRequest (newSockFd, &clientAddr); 
		} 
	} 
 
 
/************************************************************************ 
 * 
 * doRequest - read the clients requests from the socket and honor them. 
 * 
 * In a more typical application, this routine would fork of anouther 
 * process to handle the request. 
 * 
 */ 
 
void doRequest  
	( 
	SOCK_FD sock, 
	struct sockaddr_in *pClientAddr 
	) 
	{ 
	char 	buf [MAX_MSG_LEN]; 
	int 	msgSize; 
	char 	clientInet [INET_ADDR_LEN]; 
	u_short clientPort; 
 
	inet_ntoa_b (pClientAddr->sin_addr, clientInet); 
	clientPort = ntohs (pClientAddr->sin_port); 
 
	FOREVER 
		{ 
		msgSize = read (sock, buf, MAX_MSG_LEN); 
 
		/* Read error ? */ 
		if (msgSize < 0) 
			{ 
			close (sock); 
			error ("Read failed"); 
			} 
 
		/* Connection closed ? */ 
		else if (msgSize == 0) 
			{ 
			close (sock); 
			break; 
			} 
 
		/* Print client message and send reply */ 
		else 
			{ 
			printf ("Task %s servicing client from inet %s, port %d\n\n", 
				taskName(0), clientInet, clientPort); 
			} 
		} 
	} 
 
 
/******************************************************************************* 
 * 
 * error - aborts a task on an error  
 * 
 * This funcion displays the reason a task crashed  
 * and terminates that task. 
 */ 
 
LOCAL void error (char * pStr) 
	{ 
	perror (pStr); 
	exit (1); 
	}