sockets.c
上传用户:seven77cht
上传日期:2007-01-04
资源大小:486k
文件大小:8k
源码类别:

浏览器

开发平台:

Unix_Linux

  1. /***************************************
  2.   $Header: /home/amb/wwwoffle/RCS/sockets.c 2.9 1999/07/05 18:46:16 amb Exp $
  3.   WWWOFFLE - World Wide Web Offline Explorer - Version 2.5.
  4.   Socket manipulation routines.
  5.   ******************/ /******************
  6.   Written by Andrew M. Bishop
  7.   This file Copyright 1996,97,98,99 Andrew M. Bishop
  8.   It may be distributed under the GNU Public License, version 2, or
  9.   any higher version.  See section COPYING of the GNU Public license
  10.   for conditions under which this file may be redistributed.
  11.   ***************************************/
  12. #include <stdio.h>
  13. #include <string.h>
  14. #include <errno.h>
  15. #include <unistd.h>
  16. #include <fcntl.h>
  17. #include <sys/time.h>
  18. #include <netdb.h>
  19. #include <sys/param.h>
  20. #include <sys/types.h>
  21. #include <sys/stat.h>
  22. #include <sys/socket.h>
  23. #include <netinet/in.h>
  24. #include <arpa/inet.h>
  25. #include "errors.h"
  26. #include "sockets.h"
  27. /*++++++++++++++++++++++++++++++++++++++
  28.   Opens a socket for a client.
  29.   int OpenClientSocket Returns the socket file descriptor.
  30.   char* host The name of the remote host.
  31.   int port The socket number.
  32.   int timeout The time to wait for the socket to connect.
  33.   ++++++++++++++++++++++++++++++++++++++*/
  34. int OpenClientSocket(char* host, int port,int timeout)
  35. {
  36.  int s;
  37.  int retval;
  38.  struct sockaddr_in server;
  39.  struct hostent* hp;
  40.  int noblock,flags;
  41.  server.sin_family=AF_INET;
  42.  server.sin_port=htons((unsigned short)port);
  43.  hp=gethostbyname(host);
  44.  if(!hp)
  45.    {
  46.     unsigned long int addr=inet_addr(host);
  47.     if(addr!=-1)
  48.        hp=gethostbyaddr((char*)addr,sizeof(addr),AF_INET);
  49.     if(!hp)
  50.       {errno=-1;PrintMessage(Warning,"Unknown host '%s' for server [%!s].",host);return(-1);}
  51.    }
  52.  memcpy((char*)&server.sin_addr,(char*)hp->h_addr,sizeof(server.sin_addr));
  53.  s=socket(PF_INET,SOCK_STREAM,0);
  54.  if(s==-1)
  55.    {PrintMessage(Warning,"Cannot create client socket [%!s].");return(-1);}
  56. #ifdef O_NONBLOCK
  57.  flags=fcntl(s,F_GETFL,0);
  58.  if(flags!=-1)
  59.     noblock=fcntl(s,F_SETFL,flags|O_NONBLOCK);
  60.  else
  61.     noblock=-1;
  62. #else
  63.  flags=1;
  64.  noblock=ioctl(s,FIONBIO,&flags);
  65. #endif
  66.  retval=connect(s,(struct sockaddr *)&server,sizeof(server));
  67.  if(retval==-1 && noblock!=-1 && errno==EINPROGRESS)
  68.    {
  69.     fd_set writefd;
  70.     struct timeval tv;
  71.     FD_ZERO(&writefd);
  72.     FD_SET(s,&writefd);
  73.     tv.tv_sec=timeout;
  74.     tv.tv_usec=0;
  75.     retval=select(s+1,NULL,&writefd,NULL,&tv);
  76.     if(retval>0)
  77.       {
  78.        int arglen=sizeof(int);
  79.        if(getsockopt(s,SOL_SOCKET,SO_ERROR,&retval,&arglen)<0)
  80.           retval=errno;
  81.        if(retval!=0)
  82.           errno=retval,retval=-1;
  83.        if(errno==EINPROGRESS)
  84.           errno=ETIMEDOUT;
  85.       }
  86.     else if(retval==0)
  87.        errno=ETIMEDOUT,retval=-1;
  88.    }
  89.  if(retval<0)
  90.    {
  91.     close(s);
  92.     s=-1;
  93.     PrintMessage(Warning,"Connect fail [%!s].");
  94.    }
  95.  else
  96.    {
  97. #ifdef O_NONBLOCK
  98.     flags=fcntl(s,F_GETFL,0);
  99.     if(flags!=-1)
  100.        fcntl(s,F_SETFL,flags&~O_NONBLOCK);
  101. #else
  102.     flags=0;
  103.     ioctl(s,FIONBIO,&flags);
  104. #endif
  105.    }
  106.  return(s);
  107. }
  108. /*++++++++++++++++++++++++++++++++++++++
  109.   Opens a socket for a server.
  110.   int OpenServerSocket Returns a socket to be a server.
  111.   int port The port number to use.
  112.   ++++++++++++++++++++++++++++++++++++++*/
  113. int OpenServerSocket(int port)
  114. {
  115.  int s;
  116.  int retval;
  117.  struct sockaddr_in server;
  118.  int reuse_addr=1;
  119.  s=socket(PF_INET,SOCK_STREAM,0);
  120.  if(s==-1)
  121.    {PrintMessage(Warning,"Cannot create server socket [%!s].");return(-1);}
  122.  setsockopt(s,SOL_SOCKET,SO_REUSEADDR,&reuse_addr,sizeof(reuse_addr));
  123.  server.sin_family=AF_INET;
  124.  server.sin_addr.s_addr=INADDR_ANY;
  125.  server.sin_port=htons((unsigned int)port);
  126.  retval=bind(s,(struct sockaddr*)&server,sizeof(server));
  127.  if(retval==-1)
  128.    {PrintMessage(Warning,"Failed to bind server socket [%!s].");return(-1);}
  129.  listen(s,4);
  130.  return(s);
  131. }
  132. /*++++++++++++++++++++++++++++++++++++++
  133.   Waits for a connection on the socket.
  134.   int AcceptConnect returns a socket with a remote connection on the end.
  135.   int socket Specifies the socket to check for.
  136.   ++++++++++++++++++++++++++++++++++++++*/
  137. int AcceptConnect(int socket)
  138. {
  139.  int s;
  140.  s=accept(socket,(struct sockaddr*)0,(int*)0);
  141.  if(s==-1)
  142.     PrintMessage(Warning,"Accept on server socket failed [%!s].");
  143.  return(s);
  144. }
  145. /*++++++++++++++++++++++++++++++++++++++
  146.   Determines the hostname and port number used for a socket on the other end.
  147.   int SocketRemoteName Returns 0 on success and -1 on failure.
  148.   int socket Specifies the socket to check.
  149.   char **name Returns the hostname.
  150.   char **ipname Returns the hostname as an IP address.
  151.   int *port Returns the port number.
  152.   ++++++++++++++++++++++++++++++++++++++*/
  153. int SocketRemoteName(int socket,char **name,char **ipname,int *port)
  154. {
  155.  struct sockaddr_in server;
  156.  int length=sizeof(server),retval;
  157.  static char host[MAXHOSTNAMELEN],ip[16];
  158.  struct hostent* hp=NULL;
  159.  retval=getpeername(socket,(struct sockaddr*)&server,&length);
  160.  if(retval==-1)
  161.     PrintMessage(Warning,"Failed to get socket peername [%!s].");
  162.  else
  163.    {
  164.     hp=gethostbyaddr((char*)&server.sin_addr,sizeof(server.sin_addr),AF_INET);
  165.     if(hp)
  166.        strcpy(host,hp->h_name);
  167.     else
  168.        strcpy(host,inet_ntoa(server.sin_addr));
  169.     strcpy(ip,inet_ntoa(server.sin_addr));
  170.     if(name)
  171.        *name=host;
  172. #ifdef __CYGWIN__
  173.     if(!strcmp(ip,"127.0.0.1"))
  174.        *name="localhost";
  175. #endif
  176.     if(ipname)
  177.        *ipname=ip;
  178.     if(port)
  179.        *port=ntohs(server.sin_port);
  180.    }
  181.  return(retval);
  182. }
  183. /*++++++++++++++++++++++++++++++++++++++
  184.   Determines the hostname and port number used for a socket on this end.
  185.   int SocketLocalName Returns 0 on success and -1 on failure.
  186.   int socket Specifies the socket to check.
  187.   char **name Returns the hostname.
  188.   char **ipname Returns the hostname as an IP address.
  189.   int *port Returns the port number.
  190.   ++++++++++++++++++++++++++++++++++++++*/
  191. int SocketLocalName(int socket,char **name,char **ipname,int *port)
  192. {
  193.  struct sockaddr_in server;
  194.  int length=sizeof(server),retval;
  195.  static char host[MAXHOSTNAMELEN],ip[16];
  196.  struct hostent* hp=NULL;
  197.  retval=getsockname(socket,(struct sockaddr*)&server,&length);
  198.  if(retval==-1)
  199.     PrintMessage(Warning,"Failed to get socket name [%!s].");
  200.  else
  201.    {
  202.     hp=gethostbyaddr((char*)&server.sin_addr,sizeof(server.sin_addr),AF_INET);
  203.     if(hp)
  204.        strcpy(host,hp->h_name);
  205.     else
  206.        strcpy(host,inet_ntoa(server.sin_addr));
  207.     strcpy(ip,inet_ntoa(server.sin_addr));
  208.     if(name)
  209.        *name=host;
  210. #ifdef __CYGWIN__
  211.     if(!strcmp(ip,"127.0.0.1"))
  212.        *name="localhost";
  213. #endif
  214.     if(ipname)
  215.        *ipname=ip;
  216.     if(port)
  217.        *port=ntohs(server.sin_port);
  218.    }
  219.  return(retval);
  220. }
  221. /*++++++++++++++++++++++++++++++++++++++
  222.   Closes a previously opened socket.
  223.   int CloseSocket Returns 0 on success, -1 on error.
  224.   int socket The socket to close
  225.   ++++++++++++++++++++++++++++++++++++++*/
  226. int CloseSocket(int socket)
  227. {
  228.  int retval=close(socket);
  229.  if(retval==-1)
  230.     PrintMessage(Warning,"Socket close failed [%!s].");
  231.  return(retval);
  232. }
  233. /*++++++++++++++++++++++++++++++++++++++
  234.   Get the Fully Qualified Domain Name for the local host.
  235.   char *GetFQDN Return the FQDN.
  236.   ++++++++++++++++++++++++++++++++++++++*/
  237. char *GetFQDN(void)
  238. {
  239.  static char fqdn[256],**h;
  240.  struct hostent* hp;
  241.  int type=hp->h_addrtype;
  242.  int length=hp->h_length;
  243.  char addr[sizeof(struct in_addr)];
  244.  /* Try gethostname(). */
  245.  if(gethostname(fqdn,255)==-1)
  246.    {PrintMessage(Warning,"Failed to get hostname [%!s].");return(NULL);}
  247.  if(strchr(fqdn,'.'))
  248.     return(fqdn);
  249.  /* Try gethostbyname(). */
  250.  hp=gethostbyname(fqdn);
  251.  if(!hp)
  252.    {errno=-1;PrintMessage(Warning,"Can't get IP address for host [%!s].");return(NULL);}
  253.  if(strchr(hp->h_name,'.'))
  254.    {
  255.     strcpy(fqdn,hp->h_name);
  256.     return(fqdn);
  257.    }
  258.  for(h=hp->h_aliases;*h;h++)
  259.     if(strchr(*h,'.'))
  260.       {
  261.        strcpy(fqdn,*h);
  262.        return(fqdn);
  263.       }
  264.  /* Try gethostbyaddr(). */
  265.  type=hp->h_addrtype;
  266.  length=hp->h_length;
  267.  memcpy(addr,(char*)hp->h_addr,sizeof(struct in_addr));
  268.  hp=gethostbyaddr(addr,length,type);
  269.  if(!hp)
  270.    {errno=-1;PrintMessage(Warning,"Can't get hostname for IP address [%!s].");return(NULL);}
  271.  if(strchr(hp->h_name,'.'))
  272.    {
  273.     strcpy(fqdn,hp->h_name);
  274.     return(fqdn);
  275.    }
  276.  for(h=hp->h_aliases;*h;h++)
  277.     if(strchr(*h,'.'))
  278.       {
  279.        strcpy(fqdn,*h);
  280.        return(fqdn);
  281.       }
  282.  strcpy(fqdn,hp->h_name);
  283.  return(fqdn);
  284. }