tcpsvr.c File Reference

#include <winsock2.h>
#include <stdio.h>
#include <string.h>
#include <io.h>

Include dependency graph for tcpsvr.c:

Go to the source code of this file.

Macros
#define	SUCCESS   0
#define	ERROR   1
#define	END_LINE   0x0A
#define	SERVER_PORT   23
#define	MAX_MSG   100

Functions
int	read_line ()
int	main (int argc, char *argv[])
int	read_line (int newSd, char *line_to_return)

Macro Definition Documentation

END_LINE

#define END_LINE   0x0A

Definition at line 22 of file tcpsvr.c.

ERROR

#define ERROR   1

Definition at line 20 of file tcpsvr.c.

MAX_MSG

#define MAX_MSG   100

Definition at line 24 of file tcpsvr.c.

SERVER_PORT

#define SERVER_PORT   23

Definition at line 23 of file tcpsvr.c.

SUCCESS

#define SUCCESS   0

Definition at line 19 of file tcpsvr.c.

Function Documentation

main()

int main	(	int argc	,
		char *	argv[]
	)

Definition at line 29 of file tcpsvr.c.

                                  {
 
  WORD       wVersionRequested;
  WSADATA    WsaData;
  INT        Status;
  int sd, newSd, cliLen;
 
  struct sockaddr_in cliAddr, servAddr;
  char line[MAX_MSG];
 
    wVersionRequested = MAKEWORD(2, 2);
 
    Status = WSAStartup(wVersionRequested, &WsaData);
    if (Status != 0) {
        printf("Could not initialize winsock dll.\n");
        return FALSE;
    }
 
  /* create socket */
  sd = socket(AF_INET, SOCK_STREAM, 0);
   if(sd<0) {
    perror("cannot open socket ");
    WSACleanup();
    return ERROR;
  }
 
  /* bind server port */
  servAddr.sin_family = AF_INET;
  servAddr.sin_addr.s_addr = htonl(INADDR_ANY);
  servAddr.sin_port = htons(SERVER_PORT);
 
  if(bind(sd, (struct sockaddr *) &servAddr, sizeof(servAddr))<0) {
    perror("cannot bind port ");
    WSACleanup();
    return ERROR;
  }
 
  listen(sd,5);
 
  while(1) {
 
    printf("%s: \n"
          "To start test, Please telnet to localhost (127.0.0.1) port 23 \n"
          "When connected input raw data followed by End of Line\n"
          "Test is now running on TCP port %u\n",argv[0],SERVER_PORT);
 
    cliLen = sizeof(cliAddr);
    newSd = accept(sd, (struct sockaddr *) &cliAddr, &cliLen);
    if(newSd<0) {
      perror("cannot accept connection ");
      WSACleanup();
      return ERROR;
    }
 
    /* init line */
    memset(line,0x0,MAX_MSG);
 
    /* receive segments */
    while(read_line(newSd,line)!=ERROR) {
 
      printf("%s: received from %s:TCP%d : %s\n", argv[0],
         inet_ntoa(cliAddr.sin_addr),
         ntohs(cliAddr.sin_port), line);
      /* init line */
      memset(line,0x0,MAX_MSG);
 
    } /* while(read_line) */
 
  } /* while (1) */
 
}

read_line() [1/2]

int read_line

(

)

Referenced by compute_rect(), HTTP_GetResponseHeaders(), ID3DXFontImpl_DrawTextW(), main(), read_reply(), and run_helper().

read_line() [2/2]

int read_line	(	int	newSd,
		char *	line_to_return
	)

Definition at line 114 of file tcpsvr.c.

                                               {
 
  static int rcv_ptr=0;
  static char rcv_msg[MAX_MSG];
  static int n;
  int offset;
 
  offset=0;
 
  while(1) {
    if(rcv_ptr==0) {
      /* read data from socket */
      memset(rcv_msg,0x0,MAX_MSG); /* init buffer */
      n = recv(newSd, rcv_msg, MAX_MSG, 0); /* wait for data */
      if (n<0) {
    perror(" cannot receive data ");
    return ERROR;
      } else if (n==0) {
    printf(" connection closed by client\n");
    closesocket(newSd);
        WSACleanup();
    return ERROR;
      }
    }
 
    /* if new data read on socket */
    /* OR */
    /* if another line is still in buffer */
 
    /* copy line into 'line_to_return' */
    while(*(rcv_msg+rcv_ptr)!=END_LINE && rcv_ptr<n) {
      memcpy(line_to_return+offset,rcv_msg+rcv_ptr,1);
      offset++;
      rcv_ptr++;
    }
 
    /* end of line + end of buffer => return line */
    if(rcv_ptr==n-1) {
      /* set last byte to END_LINE */
      *(line_to_return+offset)=END_LINE;
      rcv_ptr=0;
      return ++offset;
    }
 
    /* end of line but still some data in buffer => return line */
    if(rcv_ptr <n-1) {
      /* set last byte to END_LINE */
      *(line_to_return+offset)=END_LINE;
      rcv_ptr++;
      return ++offset;
    }
 
    /* end of buffer but line is not ended => */
    /*  wait for more data to arrive on socket */
    if(rcv_ptr == n) {
      rcv_ptr = 0;
    }
 
  } /* while */
}