thread_sql_ping.cpp

VC++编写的类似Sniffer的网络数据包监听程序

//---------------------------------------------------------------------------

#include <vcl.h>
#pragma hdrstop

#include "thread_sql_ping.h"
#include "function_1.h"
#include "tlookup_name.h"
#include "main.h"
#include "syncobjs.hpp"
#pragma package(smart_init)

extern unsigned long ping_ip_start;
extern unsigned long ping_ip_stop;//开始,结束的ip
extern int cur_ip;//已工作的ip数
extern int ping_thread_no;//已工作的ip数
extern boolean thread_run;//已工作的ip数
extern int share_thread_no;//share线程数量
extern int share_ip_no;//share工作的位置指示
extern boolean only_ping;
extern int scan_thread_no;//scan的线程
extern TStringList * main_list;

extern TCriticalSection *ping_CriticalSection;//全局临界变量

//---------------------------------------------------------------------------

//PING线程的结束处理事件
void __fastcall Tmy_sql_ping::ThreadDone(TObject * Sender)
{
  ((Tmy_sql_ping*)Sender)->Fscan_port->Free();
  ping_thread_no--;
  main_f->Edit24->Text=IntToStr(ping_thread_no);
  if (ping_thread_no==0)
   {
    main_f->Bar->Max=main_list->Count;
    main_f->Bar->Position=0;
   }

}

__fastcall Tmy_sql_ping::Tmy_sql_ping(bool CreateSuspended): TThread(CreateSuspended)
{
  Fscan_port=new Tscan_port(main_f);

  Fscan_port->Port=main_f->Edit27->Text;
  OnTerminate =ThreadDone;
  FreeOnTerminate = True;
  Fscan_port->OnScan=scanOnScan;
  ping_thread_no++;
}
//---------------------------------------------------------------------------
void __fastcall Tmy_sql_ping::Execute()
{
   int no;
  while (thread_run){
   ping_CriticalSection->Enter();//进入临界状态
       no=cur_ip;
       cur_ip++;
     main_f->Edit24->Text=IntToStr(ping_thread_no);
   ping_CriticalSection->Leave();//析放临界状态

   if ((ping_ip_start+no)<=ping_ip_stop)
     {
      Fscan_port->Address=iptostr(ping_ip_start+no);
      Fscan_port->scan();
     } else break;
  }
}

void __fastcall Tmy_sql_ping::scanOnScan(TObject *Sender, int Error)
{
  Synchronize(set_bar);
  if (Error==0) Synchronize(set_str);
}

//---------------------------------------------------------------------------


void __fastcall Tmy_sql_ping::set_bar()
{
  main_f->Edit19->Text=Fscan_port->Address;
  main_f->Bar->Position=cur_ip;
}

void __fastcall Tmy_sql_ping::set_str()
{
  main_f->ListBox2->Items->Add(Fscan_port->Address);
  main_f->Edit21->Text=IntToStr((StrToInt(main_f->Edit21->Text)+1));
}