thread_ping.cpp

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

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

#include <vcl.h>
#pragma hdrstop

#include "THREAD_ping.h"
#include "function_1.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 TCriticalSection *ping_CriticalSection;//全局临界变量

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

//PING线程的结束处理事件
void __fastcall Tmy_thread1::ThreadDone(TObject * Sender)
{
  ((Tmy_thread1*)Sender)->FPing->Free();
  ping_thread_no--;
  main_f->Edit14->Text=IntToStr(ping_thread_no);
  if (ping_thread_no==0)
   { main_f->Edit7->Text="查找完成...";
     main_f->Bar->Max=main_f->tree_ping->Items->Count;
     if (share_thread_no>0)
       main_f->Bar->Position=share_ip_no;
      else
       main_f->Bar->Position=0;
   }
}

__fastcall Tmy_thread1::Tmy_thread1(TPing *thread_Ping,bool CreateSuspended)
        : TThread(CreateSuspended)
{
  FPing=thread_Ping;
  OnTerminate =ThreadDone;
  FreeOnTerminate = True;
  FPing->OnEchoReply=PingEchoReply;
  ping_thread_no++;
  main_f->Edit14->Text=IntToStr(ping_thread_no);
}
//---------------------------------------------------------------------------
void __fastcall Tmy_thread1::Execute()
{
   int no;

  while (thread_run)
   {
   ping_CriticalSection->Enter();//进入临界状态
       no=cur_ip;
       cur_ip++;
   ping_CriticalSection->Leave();//析放临界状态

   if ((ping_ip_start+no)<=ping_ip_stop)
    {
      FPing->Address=iptostr(ping_ip_start+no);
      FPing->Ping();
    } else break;
  }
}
void __fastcall Tmy_thread1::PingEchoReply(TObject *Sender, TObject *Icmp,
      int Error)
{
  Synchronize(set_bar);
  if (Error==1) Synchronize(set_str);
    else
     if (main_f->CheckBox5->Checked) Synchronize(set_str2);
}

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


void __fastcall Tmy_thread1::set_bar()
{
  main_f->Edit7->Text=FPing->Address;
  main_f->Bar->Position=cur_ip;
}

void __fastcall Tmy_thread1::set_str()
{
  TTreeNode *temp_node;
  temp_node=main_f->tree_ping->Items->Add(NULL,FPing->Address);
  temp_node->ImageIndex=0;
  temp_node->SelectedIndex=0;

//  main_f->ListBox1->Items->Add(FPing->Address);
  main_f->Edit9->Text=IntToStr(StrToInt(main_f->Edit9->Text)+1);
  if (main_f->share_check->Checked) creat_share();//自动找共享资料
}

void __fastcall Tmy_thread1::set_str2()
{
  TTreeNode *temp_node;
  temp_node=main_f->tree_ping->Items->Add(NULL,FPing->Address);
  temp_node->ImageIndex=1;
  temp_node->SelectedIndex=1;

//  main_f->ListBox1->Items->Add(FPing->Address);
  main_f->Edit9->Text=IntToStr(StrToInt(main_f->Edit9->Text)+1);
  if (main_f->share_check->Checked) creat_share();//自动找共享资料
}