BBS水木清华站∶精华区

发信人: Calvin (灵飞), 信区: Linux 
标  题: [技术]FreeProxyVerify for FreeBSD 
发信站: BBS 水木清华站 (Tue Jul  7 16:07:47 1998) 
 
标  题: [技术]FreeProxyVerify for FreeBSD 
发信站: 华南网木棉站 (Thu Jul  2 11:21:23 1998), 转信 
 
/* Free Proxy 验证程序 ,for UNIX                        */ 
/* Author:  Happy(Netguy)                               */ 
/*                                                      */ 
/*  1998.07.02 calvin注:                                */ 
/*  原来版本在Solaris上,我将它改到FreeBSD上来. :)       */ 
/*                                                      */ 
 
//#define  DEBUG 
 
#include <stdio.h> 
#include <string.h> 
#include <netinet/in.h> 
#include <sys/types.h> 
#include <sys/socket.h> 
#include <sys/signal.h> 
#include <sys/time.h> 
#include <fcntl.h> 
#include <unistd.h> 
#include <sys/ioctl.h> 
 
#define ZERO  (struct fd_set *)0 
#define BUFLEN  256                
 
#ifdef  DEBUG 
     int tmp; 
#endif 
 
char            target[]="GET 
http://www.digital.com/index.html\n";/*HTTP命令*/ 
char            result[80];       /* 存放过滤结果的文件的名字 */ 
char            buf[BUFLEN];      /* 缓冲区                   */ 
FILE            *f,*out;          /* 输入文件和输出文件       */ 
int             port;             /* server的端口号           */ 
int             status=-1;        /* read,write,select的返回值*/ 
char            serverName[30];   /* server的IP字符串         */ 
u_char          p1,p2,p3,p4;      /* IP地址的四个部分         */ 
int             sockfd=-1;        /* socket描述符             */ 
struct timeval  timeout={2,0};    /* 超时限制                 */ 
struct fd_set   rmask,wmask;      /* socket的读写屏蔽         */ 
struct          sockaddr_in host; 
u_long          serverAddr;       /* server的IP地址           */ 
int             counter;          /* 输入文件的行数           */ 
int             i;                /* 文件描述符               */ 
 
 
void killHandle(void)                /* 处理SIGTERM信号       */ 
{   
   fprintf(out,"killed at %s\t%d\n",serverName,port); 
   exit(0); 

 
#ifdef DEBUG 
   void sigpipeHandle(void) 
   { fprintf(out,"SIGPIPE at  %s\t%d\n",serverName,port); 
   } 
#endif 
 
  
main(int argc,char **argv) 
{  
 
  if(argc!=3) { printf("Usage: %s   dataFileName  
number\n",argv[0]);exit(-1); } 
 
  f=fopen(argv[1],"rb");       /* 作为输入的数据文件  */ 
  if(! f) { fprintf(stdout,"open file error\n"); exit(-1); } 
 
  strcpy(result,argv[1]); 
  strcat(result,".ok"); 
  out=fopen(result,"a");       /* 存放结果的输出文件 */ 
  if(! out) { fprintf(stdout,"open file error\n"); exit(-1); } 
 
  counter=atoi(argv[2]);                            /* 输入文件的行数  */ 
  fprintf(stdout,"Free proxy filter...\n"); 
  fprintf(stdout,"\tInput file:\t%s\n",argv[1]); 
  fprintf(stdout,"\tTotal    :\t%s\n",argv[2]); 
  fprintf(stdout,"written by Netguy(造梦人)\n"); 
 
  signal(SIGTERM,killHandle); 
 
#ifdef DEBUG                          /* 处理SIGPIPE信号   */ 
  signal(SIGPIPE,sigpipeHandle); 
#else 
  signal(SIGPIPE,SIG_IGN); 
#endif 
 
  switch(fork( )) 
  { case 0:                                         /* 子进程继续 */ 
         break;               
    case -1:                                        /* 出错   */ 
         perror("fork( )"); 
         exit(-1); 
    default:                 
         fclose(out);                              /* 父进程退出 */ 
         fclose(f); 
         exit(0); 
  } 
   
  setpgrp(0, getpgrp());      /* 脱离终端组和进程组,成为后台进程 */ 
                              /* calvin修改... 19980702 */ 
  i=open("/dev/tty",O_RDWR); 
  if(i>=0) 
  {  ioctl(i,TIOCNOTTY,0); 
     close(i); 
  } 
  else { fprintf(out,"TTY eacape error\n"); fflush(out); } 
 
  for ( ;counter >0;counter--) 
  { 
        fscanf(f,"%s%d",serverName,& port);         /* 从输入文件里读一行 */ 
 
#ifdef  DEBUG 
        fprintf(out,"%s\t%d ...\n",serverName,port); 
#endif 
 
        bzero((char *)& host,sizeof(host)); 
        serverAddr=inet_addr(serverName); 
        host.sin_family=AF_INET; 
        host.sin_addr.s_addr=htonl(serverAddr); 
        host.sin_port=htons(port); 
 
        if ( (sockfd=socket(AF_INET,SOCK_STREAM,0))<0 ) 
        { fprintf(out," Error open socket at %s %d\n",serverName,port); 
          exit(-1); 
        } 
 
        /* 非阻塞式O_NDELAY = FNDELAY = O_NONBLOCK */ 
        if(fcntl(sockfd,F_SETFL,O_NDELAY) < 0 ) 
        { fprintf(out,"fcntl() error at %s %d\n",serverName,port); 
          exit(-1); 
        } 
 
        status=connect(sockfd,(struct sockaddr *)& host,sizeof(host)); 
 
        timeout.tv_sec=2; 
        timeout.tv_usec=0;                          /* 超时限制 */ 
        FD_ZERO( & wmask); 
        FD_SET(sockfd,& wmask); 
        status=select(sockfd+1,ZERO,& wmask, ZERO,& timeout); 
        switch(status) 
        { case -1: 
                  fprintf(out,"select error\n"); 
                  exit(-1); 
          case 0:                                    /* 连接超时 */ 
                  close(sockfd); 
                  continue; 
          default:                                   /* 连上了 */ 
                  if(  FD_ISSET(sockfd,& wmask) )    /* 管套可写吗  */ 
                       break; 
                  else 
                  { close(sockfd);              
                    continue; 
                  } 
         } 
        /* 下面一句可能会收到SIGPIPE信号,须忽略此信号 */ 
        status=write(sockfd,target,sizeof(target)); /* 写入GET命令给server */ 
 
        timeout.tv_sec=10; 
        timeout.tv_usec=0;                    /* 超时限制 */ 
        FD_ZERO( & rmask); 
        FD_SET(sockfd,& rmask); 
        status=select(sockfd+1,& rmask,ZERO,ZERO,& timeout); 
        switch(status) 
        { case -1: 
                  fprintf(out,"select error\n"); 
                  exit(-1); 
          case 0:                               /* 超时了 */ 
                  close(sockfd); 
                  continue; 
          default:                              /* 连上了 */ 
              if(  FD_ISSET(sockfd,& rmask) ) 
              { 
                 bzero(buf,BUFLEN);                /* 清缓冲区           */ 
                 status=read(sockfd,buf,BUFLEN);   /* 读server的返回结果 */ 
                 close(sockfd); 
                 if(status<=0)  continue;          /* 没读到东西         */ 
 
#ifdef DEBUG 
                 for(tmp=0;tmp<status;tmp++) fputc(buf[tmp],out); 
#endif 
    
/* 下面的语句采用Digital公司的主页作为判断free proxy的依据.如果其主页内容变 
   了,那麽相应的程序段也要改变 
 */ 
                 if( ! strncmp((buf+22),"Digital",7) )   /* 是free proxy吗 ? 
*/ 
                 { 
                    fprintf(out,"free\t%s\t%d\n",serverName,port); 
                    fflush(out); 
                 } 
               } 
               else close(sockfd); 
        }        
  } 
  fclose(f); 
  fprintf(out,"Free proxy filter done.\n"); 
  fclose(out); 

 
-- 
    Email: [email protected] 
   ______          __         _  
  / ____/ ____ _  / /_   __  (_)  ____ 
 / /     / __ `/ / /| | / / / /  / __ \ 
/ /___  / /_/ / / / | |/ / / /  / / / / 
\____/  \__,_/ /_/  |___/ /_/  /_/ /_/ 
 
※ 来源:·BBS 水木清华站 bbs.net.tsinghua.edu.cn·[FROM: 202.38.212.86] 

BBS水木清华站∶精华区