473,395 Members | 1,471 Online
Bytes | Software Development & Data Engineering Community
Post Job

Home Posts Topics Members FAQ

home > topics > c# / c sharp > questions > problem ... .sockets and threads (ip scanning)

Join Bytes to post your question to a community of 473,395 software developers and data experts.

Problem ... .Sockets and Threads (IP Scanning)

Hi, I'm trying to build an IP Scanner inc c# for a specific port (80)
and for specific IP Ranges.

For example 24.36.148.1 to 24.36.148.255

My first step was to use TcpClient, but there are nothing to control
Timeout Connection... and I wasn't interested to wait 25-30sec for each
ip.

After some search, it's look like Socket was the solution with
BeginConnect. After a first look, I thought that all worked perfectly,
but after a second look... I noticed that after some scan... approx. 10
or 15, nothing work...
If I set maximum thread to 1, it works, this it what I got:
24.36.148.10--->Close
24.36.148.23--->Close
24.36.148.24--->Close
24.36.148.28--->Close
24.36.148.66--->Close
24.36.148.70--->Close
24.36.148.77--->Close
24.36.148.116--->Close
24.36.148.121--->Close
24.36.148.126--->Close
24.36.148.130--->Close
24.36.148.132--->Close
24.36.148.137--->Close
24.36.148.146--->Close
24.36.148.147--->Close
24.36.148.148--->Close
24.36.148.154--->Close
24.36.148.164--->Close
24.36.148.177--->Close
24.36.148.180--->Open
24.36.148.197--->Close
24.36.148.199--->Close
24.36.148.202--->Close
24.36.148.213--->Close
24.36.148.216--->Close
24.36.148.234--->Close
24.36.148.241--->Close
24.36.148.251--->Close

where the only one with Port 80 open is "24.36.148.180--->Open"
and where "Close" means "the remote host is reachable, but refuses
connections on a port"

If I set maximum Thread to 5 or something else better... the only thing
I got is :
24.36.148.10--->Close

Nothing else..... like if Socket doesn't work when they are too many
socket open...
But I tried by anything I know to kill the bad sockets

Here is my code :
PortScanner Class :
Expand|Select|Wrap|Line Numbers
  1. public class PortScanner
  2. {
  3. private int m_iPort = 0;
  4. private bool m_bTimeOut = false;
  5. private string m_sStatus = "Not connected";
  6. private IPAddress m_oIPAddress;
  7. private AutoResetEvent m_oARSConnectDone = new AutoResetEvent(false);
  8.  
  9. public PortScanner(long iIP)
  10. {
  11. m_oIPAddress = new IPAddress(iIP);
  12. m_iPort = 80;
  13. }
  14. public int Port
  15. {
  16. get{ return m_iPort; }
  17. }
  18. public string IP
  19. {
  20. get{ return m_oIPAddress.ToString(); }
  21. }
  22. private void ConnectCallback(IAsyncResult ar)
  23. {
  24. if(m_bTimeOut)
  25. return;
  26.  
  27. Socket oSocket = (Socket)ar.AsyncState;
  28. try
  29. {
  30. // Complete the connection.
  31. oSocket.EndConnect(ar);
  32. m_sStatus = "Open";
  33. }
  34. catch
  35. {
  36. // The EndConnect method will throw a SocetException if the remote
  37. // host is reachable, but refuses connections on a port.
  38. m_sStatus = "Close";
  39. }
  40. finally
  41. {
  42. if (oSocket.Connected)
  43. oSocket.Shutdown(SocketShutdown.Both);
  44. oSocket.Close();
  45. oSocket=null;
  46. m_oARSConnectDone.Set(); //tell the main thread that the callback
  47. has been finished.
  48. Console.WriteLine(m_oIPAddress.ToString() + "--->" + m_sStatus);
  49. }
  50. }
  51.  
  52. // initiate a connection to the port.
  53. public void Scan()
  54. {
  55. try
  56. {
  57. m_bTimeOut = false;
  58. Socket oScanningIpPort = new Socket(AddressFamily.InterNetwork,
  59. SocketType.Stream, ProtocolType.Tcp);
  60. oScanningIpPort.BeginConnect(new IPEndPoint(m_oIPAddress, m_iPort),
  61. new AsyncCallback(ConnectCallback), oScanningIpPort);
  62. if(!m_oARSConnectDone.WaitOne(10000, true))
  63. {
  64. m_bTimeOut = true;
  65. oScanningIpPort.Close();
  66. oScanningIpPort = null;
  67. }
  68. m_oARSConnectDone.Close();
  69. }
  70. catch(SocketException ex)
  71. {
  72. Console.WriteLine(ex.ErrorCode);
  73. }
  74. }
  75. }
  76.  
  77.  
Main Code :
StartHTTPScanning -is called by a Form Button
Expand|Select|Wrap|Line Numbers
  1. private Thread m_oThreadScanning;
  2. private Queue m_queueIP = new Queue();
  3.  
  4. //flag to be used to tell the HTTP Scan Thread that IP is still
  5. enqueuing
  6. private bool m_bEnqueuingIP;
  7.  
  8. private int m_iMaxRunning = 10;
  9. //        private int m_iMaxRunning = 255;
  10.  
  11. // flag to be used to stop all running threads when user request to
  12. stop
  13. bool m_bRunning = true;
  14.  
  15. private void EnqueuingIP()
  16. {
  17. m_bEnqueuingIP = true;
  18. XmlDocument xDocLstIPs = new XmlDocument();
  19. xDocLstIPs.Load("IPRange.xml");
  20.  
  21. XmlNodeList xLstNdIPs = xDocLstIPs.SelectNodes("/RangeIPs/RangeIP");
  22. foreach(XmlElement xElemDomain in xLstNdIPs)
  23. {
  24. try
  25. {
  26. Int64 iStartIP =
  27. long.Parse(xElemDomain.GetAttribute("start").ToString());
  28. Int64 iEndIP =
  29. long.Parse(xElemDomain.GetAttribute("end").ToString());
  30. while(iStartIP <= iEndIP)
  31. {
  32. m_queueIP.Enqueue(iStartIP);
  33. iStartIP++;
  34. }
  35. }
  36. catch(Exception ex)
  37. {
  38. MessageBox.Show(ex.Message);
  39. }
  40. Thread.Sleep(2000);
  41. }
  42.  
  43. //end enqueuing
  44. m_bEnqueuingIP = false;
  45. }
  46.  
  47. public void HTTPScanRunFunction()
  48. {
  49. while(m_bRunning && (m_queueIP.Count 0 || m_bEnqueuingIP) &&
  50. int.Parse(Thread.CurrentThread.Name) < m_iMaxRunning)
  51. {
  52.  
  53. if(m_queueIP.Count == 0 && m_bEnqueuingIP)
  54. {
  55. Thread.Sleep(500);
  56. continue;
  57. }
  58. long iIP = 0;
  59. lock(m_queueIP)
  60. {
  61. iIP = Convert.ToInt64(m_queueIP.Dequeue());
  62. }
  63. if(iIP == 0)
  64. continue;
  65.  
  66. PortScanner oPortScanner =  new PortScanner(iIP);
  67.  
  68. // update thread information in the threads view list
  69. ListViewItem itemLog;
  70. itemLog =
  71. listViewThreads.Items[int.Parse(Thread.CurrentThread.Name)];
  72. itemLog.SubItems[0].Text = oPortScanner.IP.ToString();
  73. itemLog.SubItems[1].Text = oPortScanner.Port.ToString();
  74. itemLog.ImageIndex = 1;
  75. itemLog.BackColor = Color.WhiteSmoke;
  76.  
  77. // initialize status to Connect
  78. itemLog.SubItems[2].Text = "Scanning";
  79. itemLog.ForeColor = Color.Green;
  80.  
  81. oPortScanner.Scan();
  82.  
  83. if(m_bRunning == false)
  84. itemLog.SubItems[2].Text = "Stop";
  85.  
  86. itemLog.ImageIndex = 0;
  87. itemLog.SubItems[0].Text = "";
  88. itemLog.SubItems[1].Text = "";
  89. itemLog.SubItems[2].Text = "";
  90.  
  91. oPortScanner = null;
  92. }
  93.  
  94. }
  95.  
  96. private void HTTPScanning()
  97. {
  98. // start parsing thread
  99. Thread oThreadEnqueuingIP = new Thread(new ThreadStart(EnqueuingIP));
  100. oThreadEnqueuingIP.Name = "ThreadEnqueuingIP";
  101. oThreadEnqueuingIP.Start();
  102.  
  103. // create the threads
  104. Thread[] threadsRun = new Thread[ m_iMaxRunning ];
  105. int nIndex = 0;
  106. for(nIndex = 0; nIndex < m_iMaxRunning; nIndex ++)
  107. {
  108. // check if thread not created or not suspended
  109. if(threadsRun[nIndex] == null || threadsRun[nIndex].ThreadState !=
  110. ThreadState.Suspended)
  111. {
  112. threadsRun[nIndex] = new Thread( new ThreadStart(
  113. HTTPScanRunFunction ) );
  114.  
  115. // set thread name equal to its index
  116. threadsRun[nIndex].Name = nIndex.ToString();
  117.  
  118. lock(listViewThreads)
  119. {
  120. // add a new line in the view for the new thread
  121. ListViewItem item =
  122. listViewThreads.Items.Add(threadsRun[nIndex].Name, 0);
  123. string[] subItems = { "", "", "" };
  124. item.SubItems.AddRange(subItems);
  125. }
  126.  
  127. Thread.Sleep(200);
  128. // start the thread
  129. threadsRun[nIndex].Start();
  130.  
  131. }
  132. // check if the thread is suspended
  133. else if(threadsRun[nIndex].ThreadState == ThreadState.Suspended)
  134. {
  135. // resume the thread
  136. threadsRun[nIndex].Resume();
  137. }
  138. }
  139.  
  140. // wait for all of them to finish
  141. for ( nIndex = 0; nIndex < threadsRun.Length; nIndex ++ )
  142. threadsRun[nIndex].Join();
  143.  
  144.  
  145. this.toolBarButtonContinue.Enabled = true;
  146. this.toolBarButtonPause.Enabled = false;
  147. }
  148.  
  149. private void StartHTTPScanning()
  150. {
  151. // start parsing thread
  152. m_oThreadScanning = new Thread(new ThreadStart(HTTPScanning));
  153. m_oThreadScanning.Start();
  154. }
  155.  
Jan 24 '07 #1
2 4510
jgbid,

It looks to me that:

a) your thread control stuff looks kinda hard to maintain for me, besides
that it is my best shot for the code you sent. If you have just one thread
working, it means that you are not multi threading at all. Why don't you
take a look on this framework:
http://www.codeproject.com/cs/thread...threadpool.asp. I've used this
for quite some time and it has saved my life.
b) on the worker thread, instead of using asynchronous calls, use
synchronous. I am pretty sure it will be easier to maintain and to test.

I hope it helps!
--
Regards,
Robson Siqueira
Enterprise Architect
"jgbid" <jg******@yahoo.cawrote in message
news:11********************@v45g2000cwv.googlegrou ps.com...
Hi, I'm trying to build an IP Scanner inc c# for a specific port (80)
and for specific IP Ranges.

For example 24.36.148.1 to 24.36.148.255

My first step was to use TcpClient, but there are nothing to control
Timeout Connection... and I wasn't interested to wait 25-30sec for each
ip.

After some search, it's look like Socket was the solution with
BeginConnect. After a first look, I thought that all worked perfectly,
but after a second look... I noticed that after some scan... approx. 10
or 15, nothing work...
If I set maximum thread to 1, it works, this it what I got:
24.36.148.10--->Close
24.36.148.23--->Close
24.36.148.24--->Close
24.36.148.28--->Close
24.36.148.66--->Close
24.36.148.70--->Close
24.36.148.77--->Close
24.36.148.116--->Close
24.36.148.121--->Close
24.36.148.126--->Close
24.36.148.130--->Close
24.36.148.132--->Close
24.36.148.137--->Close
24.36.148.146--->Close
24.36.148.147--->Close
24.36.148.148--->Close
24.36.148.154--->Close
24.36.148.164--->Close
24.36.148.177--->Close
24.36.148.180--->Open
24.36.148.197--->Close
24.36.148.199--->Close
24.36.148.202--->Close
24.36.148.213--->Close
24.36.148.216--->Close
24.36.148.234--->Close
24.36.148.241--->Close
24.36.148.251--->Close

where the only one with Port 80 open is "24.36.148.180--->Open"
and where "Close" means "the remote host is reachable, but refuses
connections on a port"

If I set maximum Thread to 5 or something else better... the only thing
I got is :
24.36.148.10--->Close

Nothing else..... like if Socket doesn't work when they are too many
socket open...
But I tried by anything I know to kill the bad sockets

Here is my code :
PortScanner Class :
Expand|Select|Wrap|Line Numbers
  1. public class PortScanner
  2. {
  3. private int m_iPort = 0;
  4. private bool m_bTimeOut = false;
  5. private string m_sStatus = "Not connected";
  6. private IPAddress m_oIPAddress;
  7. private AutoResetEvent m_oARSConnectDone = new AutoResetEvent(false);
  9. public PortScanner(long iIP)
  10. {
  11. m_oIPAddress = new IPAddress(iIP);
  12. m_iPort = 80;
  13. }
  14. public int Port
  15. {
  16. get{ return m_iPort; }
  17. }
  18. public string IP
  19. {
  20. get{ return m_oIPAddress.ToString(); }
  21. }
  22. private void ConnectCallback(IAsyncResult ar)
  23. {
  24. if(m_bTimeOut)
  25. return;
  27. Socket oSocket = (Socket)ar.AsyncState;
  28. try
  29. {
  30. // Complete the connection.
  31. oSocket.EndConnect(ar);
  32. m_sStatus = "Open";
  33. }
  34. catch
  35. {
  36. // The EndConnect method will throw a SocetException if the remote
  37. // host is reachable, but refuses connections on a port.
  38. m_sStatus = "Close";
  39. }
  40. finally
  41. {
  42. if (oSocket.Connected)
  43. oSocket.Shutdown(SocketShutdown.Both);
  44. oSocket.Close();
  45. oSocket=null;
  46. m_oARSConnectDone.Set(); //tell the main thread that the callback
  47. has been finished.
  48. Console.WriteLine(m_oIPAddress.ToString() + "--->" + m_sStatus);
  49. }
  50. }
  52. // initiate a connection to the port.
  53. public void Scan()
  54. {
  55. try
  56. {
  57. m_bTimeOut = false;
  58. Socket oScanningIpPort = new Socket(AddressFamily.InterNetwork,
  59. SocketType.Stream, ProtocolType.Tcp);
  60. oScanningIpPort.BeginConnect(new IPEndPoint(m_oIPAddress, m_iPort),
  61. new AsyncCallback(ConnectCallback), oScanningIpPort);
  62. if(!m_oARSConnectDone.WaitOne(10000, true))
  63. {
  64. m_bTimeOut = true;
  65. oScanningIpPort.Close();
  66. oScanningIpPort = null;
  67. }
  68. m_oARSConnectDone.Close();
  69. }
  70. catch(SocketException ex)
  71. {
  72. Console.WriteLine(ex.ErrorCode);
  73. }
  74. }
  75. }
  77.  
Main Code :
StartHTTPScanning -is called by a Form Button
Expand|Select|Wrap|Line Numbers
  1. private Thread m_oThreadScanning;
  2. private Queue m_queueIP = new Queue();
  4. //flag to be used to tell the HTTP Scan Thread that IP is still
  5. enqueuing
  6. private bool m_bEnqueuingIP;
  8. private int m_iMaxRunning = 10;
  9. // private int m_iMaxRunning = 255;
  11. // flag to be used to stop all running threads when user request to
  12. stop
  13. bool m_bRunning = true;
  15. private void EnqueuingIP()
  16. {
  17. m_bEnqueuingIP = true;
  18. XmlDocument xDocLstIPs = new XmlDocument();
  19. xDocLstIPs.Load("IPRange.xml");
  21. XmlNodeList xLstNdIPs = xDocLstIPs.SelectNodes("/RangeIPs/RangeIP");
  22. foreach(XmlElement xElemDomain in xLstNdIPs)
  23. {
  24. try
  25. {
  26. Int64 iStartIP =
  27. long.Parse(xElemDomain.GetAttribute("start").ToString());
  28. Int64 iEndIP =
  29. long.Parse(xElemDomain.GetAttribute("end").ToString());
  30. while(iStartIP <= iEndIP)
  31. {
  32. m_queueIP.Enqueue(iStartIP);
  33. iStartIP++;
  34. }
  35. }
  36. catch(Exception ex)
  37. {
  38. MessageBox.Show(ex.Message);
  39. }
  40. Thread.Sleep(2000);
  41. }
  43. //end enqueuing
  44. m_bEnqueuingIP = false;
  45. }
  47. public void HTTPScanRunFunction()
  48. {
  49. while(m_bRunning && (m_queueIP.Count 0 || m_bEnqueuingIP) &&
  50. int.Parse(Thread.CurrentThread.Name) < m_iMaxRunning)
  51. {
  53. if(m_queueIP.Count == 0 && m_bEnqueuingIP)
  54. {
  55. Thread.Sleep(500);
  56. continue;
  57. }
  58. long iIP = 0;
  59. lock(m_queueIP)
  60. {
  61. iIP = Convert.ToInt64(m_queueIP.Dequeue());
  62. }
  63. if(iIP == 0)
  64. continue;
  66. PortScanner oPortScanner =  new PortScanner(iIP);
  68. // update thread information in the threads view list
  69. ListViewItem itemLog;
  70. itemLog =
  71. listViewThreads.Items[int.Parse(Thread.CurrentThread.Name)];
  72. itemLog.SubItems[0].Text = oPortScanner.IP.ToString();
  73. itemLog.SubItems[1].Text = oPortScanner.Port.ToString();
  74. itemLog.ImageIndex = 1;
  75. itemLog.BackColor = Color.WhiteSmoke;
  77. // initialize status to Connect
  78. itemLog.SubItems[2].Text = "Scanning";
  79. itemLog.ForeColor = Color.Green;
  81. oPortScanner.Scan();
  83. if(m_bRunning == false)
  84. itemLog.SubItems[2].Text = "Stop";
  86. itemLog.ImageIndex = 0;
  87. itemLog.SubItems[0].Text = "";
  88. itemLog.SubItems[1].Text = "";
  89. itemLog.SubItems[2].Text = "";
  91. oPortScanner = null;
  92. }
  94. }
  96. private void HTTPScanning()
  97. {
  98. // start parsing thread
  99. Thread oThreadEnqueuingIP = new Thread(new ThreadStart(EnqueuingIP));
  100. oThreadEnqueuingIP.Name = "ThreadEnqueuingIP";
  101. oThreadEnqueuingIP.Start();
  103. // create the threads
  104. Thread[] threadsRun = new Thread[ m_iMaxRunning ];
  105. int nIndex = 0;
  106. for(nIndex = 0; nIndex < m_iMaxRunning; nIndex ++)
  107. {
  108. // check if thread not created or not suspended
  109. if(threadsRun[nIndex] == null || threadsRun[nIndex].ThreadState !=
  110. ThreadState.Suspended)
  111. {
  112. threadsRun[nIndex] = new Thread( new ThreadStart(
  113. HTTPScanRunFunction ) );
  115. // set thread name equal to its index
  116. threadsRun[nIndex].Name = nIndex.ToString();
  118. lock(listViewThreads)
  119. {
  120. // add a new line in the view for the new thread
  121. ListViewItem item =
  122. listViewThreads.Items.Add(threadsRun[nIndex].Name, 0);
  123. string[] subItems = { "", "", "" };
  124. item.SubItems.AddRange(subItems);
  125. }
  127. Thread.Sleep(200);
  128. // start the thread
  129. threadsRun[nIndex].Start();
  131. }
  132. // check if the thread is suspended
  133. else if(threadsRun[nIndex].ThreadState == ThreadState.Suspended)
  134. {
  135. // resume the thread
  136. threadsRun[nIndex].Resume();
  137. }
  138. }
  140. // wait for all of them to finish
  141. for ( nIndex = 0; nIndex < threadsRun.Length; nIndex ++ )
  142. threadsRun[nIndex].Join();
  145. this.toolBarButtonContinue.Enabled = true;
  146. this.toolBarButtonPause.Enabled = false;
  147. }
  149. private void StartHTTPScanning()
  150. {
  151. // start parsing thread
  152. m_oThreadScanning = new Thread(new ThreadStart(HTTPScanning));
  153. m_oThreadScanning.Start();
  154. }
  155.  

Jan 24 '07 #2
Hi Robson, thanks to trying to help me... I tried the script you told
me, but I have the same problem with "normal thread".. even if I kill
it(i tried anything I could to kill it... shutdown, close, dispose,
null, etc.), the Thread CallBack function is executed at the end even
if I set a Wait Delay to 0 sec.

I mean :
If I create a Thread with your framework (or with a normal thread) and
I set the timeout of this thread to 5sec.
When it is created, the callback function is called.
In this function, there are a synchronous Socket Connection with
TcpClient on a inactive host. (TcpClient.Connect)
After 5sec, the main thread is terminated, I shutdown it, but the
thread is still active.. after 25sec, TcpClient.Connect has a timeout
(SocketException).. and I catch an error in the callBack function..
What I want to do... is stop the thread and the callback function,
because I want to loop over thousound of IP Address.. so I can't just
wait 25sec for each ip...
It's why I'd like to have about 50 threads for each to scan an IP...
but with a timeout of 5sec (instead of 25sec)
this is the example for 15 threads.... what I don't understand is that
the first 10 is about 5sec ... but the others are 30sec and more....

They are 15 threads calling Scan2 until the IP Queue is empty
public void Scan2()
{
TcpClient oScanningIpPort = new TcpClient();
SmartThreadPool smartThreadPool = new SmartThreadPool();
smartThreadPool.Name = m_oIPAddress.ToString();

IWorkItemResult wir = smartThreadPool.QueueWorkItem(new
WorkItemCallback(this.DoRealWork), oScanningIpPort);
smartThreadPool.WaitForIdle(5000);

smartThreadPool.Shutdown();
smartThreadPool.Cancel();
smartThreadPool.Dispose();
oScanningIpPort.Close();
oScanningIpPort = null;
}
private object DoRealWork(object state)
{
TcpClient oScanningIpPort = (TcpClient) state;
DateTime dtNow = DateTime.Now;
try
{
oScanningIpPort.Connect(m_oIPAddress, m_iPort);
m_sStatus = "Open";
}
catch
{
m_sStatus = "Close";
// Console.WriteLine(m_oIPAddress.ToString() + "=" + m_sStatus);
}
finally
{
Console.WriteLine(m_oIPAddress.ToString() + "=" + m_sStatus + " -->
Time : " + Convert.ToString(DateTime.Now - dtNow));
}
return m_sStatus;
}

Thats what I got in the console screen
N.B ----The time at end it's the time execution between the Connect
Call and The End of the call...
The first 12 works within 5 secs... and look at the others

The thread 'STP 24.36.148.1 Thread #0' (0x1c4c) has exited with code 0
(0x0).
The thread 'STP 24.36.148.2 Thread #0' (0xbd4) has exited with code 0
(0x0).
The thread 'STP 24.36.148.3 Thread #0' (0x1a24) has exited with code 0
(0x0).
24.36.148.1=Close --Time : 00:00:05.4062500
24.36.148.2=Close --Time : 00:00:05.2343750
24.36.148.3=Close --Time : 00:00:05.0468750
The thread 'STP 24.36.148.4 Thread #0' (0x1464) has exited with code 0
(0x0).
24.36.148.4=Close --Time : 00:00:05
The thread 'STP 24.36.148.5 Thread #0' (0x194) has exited with code 0
(0x0).
24.36.148.5=Close --Time : 00:00:05
The thread 'STP 24.36.148.6 Thread #0' (0x1c68) has exited with code 0
(0x0).
24.36.148.6=Close --Time : 00:00:05
The thread 'STP 24.36.148.7 Thread #0' (0x1988) has exited with code 0
(0x0).
24.36.148.7=Close --Time : 00:00:05
The thread 'STP 24.36.148.8 Thread #0' (0x24cc) has exited with code 0
(0x0).
24.36.148.8=Close --Time : 00:00:05
The thread 'STP 24.36.148.9 Thread #0' (0x106c) has exited with code 0
(0x0).
24.36.148.9=Close --Time : 00:00:05
The thread 'STP 24.36.148.11 Thread #0' (0xd80) has exited with code 0
(0x0).
24.36.148.11=Close --Time : 00:00:05
The thread 'STP 24.36.148.13 Thread #0' (0xd34) has exited with code 0
(0x0).
24.36.148.13=Close --Time : 00:00:14.0156250
24.36.148.12=Close --Time : 00:00:34.0625000
24.36.148.14=Close --Time : 00:00:33.6562500
24.36.148.15=Close --Time : 00:00:33.4531250
The thread 'STP 24.36.148.12 Thread #0' (0x1724) has exited with code 0
(0x0).
The thread 'STP 24.36.148.14 Thread #0' (0xbec) has exited with code 0
(0x0).
The thread 'STP 24.36.148.15 Thread #0' (0x19f8) has exited with code 0
(0x0).
24.36.148.17=Close --Time : 00:00:31.3281250
24.36.148.16=Close --Time : 00:00:31.3593750
24.36.148.18=Close --Time : 00:00:31.3281250
The thread 'STP 24.36.148.16 Thread #0' (0x1344) has exited with code 0
(0x0).
The thread 'STP 24.36.148.17 Thread #0' (0xb5c) has exited with code 0
(0x0).
The thread 'STP 24.36.148.18 Thread #0' (0x14a4) has exited with code 0
(0x0).
24.36.148.19=Close --Time : 00:00:31.8125000
24.36.148.20=Close --Time : 00:00:31.6562500
24.36.148.21=Close --Time : 00:00:31.4531250
The thread 'STP 24.36.148.19 Thread #0' (0xac4) has exited with code 0
(0x0).
The thread 'STP 24.36.148.20 Thread #0' (0x2510) has exited with code 0
(0x0).
The thread 'STP 24.36.148.21 Thread #0' (0xd14) has exited with code 0
(0x0).
The thread 'STP 24.36.148.23 Thread #0' (0x850) has exited with code 0
(0x0).
The thread 'STP 24.36.148.24 Thread #0' (0x13d4) has exited with code 0
(0x0).
24.36.148.23=Close --Time : 00:00:31.1250000
24.36.148.24=Close --Time : 00:00:30.9375000
The thread 'STP 24.36.148.22 Thread #0' (0x1f2c) has exited with code 0
(0x0).
24.36.148.22=Close --Time : 00:00:31.7500000
The thread 'STP 24.36.148.28 Thread #0' (0x900) has exited with code 0
(0x0).
24.36.148.28=Close --Time : 00:00:30.4375000
The thread 'STP 24.36.148.25 Thread #0' (0x1248) has exited with code 0
(0x0).
24.36.148.25=Close --Time : 00:00:50.6562500
The thread 'STP 24.36.148.27 Thread #0' (0x1674) has exited with code 0
(0x0).
The thread 'STP 24.36.148.26 Thread #0' (0x21ec) has exited with code 0
(0x0).
24.36.148.27=Close --Time : 00:00:50.5781250
24.36.148.26=Close --Time : 00:00:50.7656250
24.36.148.30=Close --Time : 00:00:50.4843750
24.36.148.31=Close --Time : 00:00:47.8906250
24.36.148.29=Close --Time : 00:00:50.6875000
24.36.148.32=Close --Time : 00:00:47.8906250
The thread 'STP 24.36.148.29 Thread #0' (0x1878) has exited with code 0
(0x0).
The thread 'STP 24.36.148.31 Thread #0' (0x1c40) has exited with code 0
(0x0).
The thread 'STP 24.36.148.30 Thread #0' (0xcc8) has exited with code 0
(0x0).
The thread 'STP 24.36.148.32 Thread #0' (0x1d94) has exited with code 0
(0x0).
The thread 'STP 24.36.148.33 Thread #0' (0xdd0) has exited with code 0
(0x0).
24.36.148.33=Close --Time : 00:00:47.9062500

........................

The thread 'STP 24.36.148.44 Thread #0' (0x19dc) has exited with code 0
(0x0).
The thread 'STP 24.36.148.45 Thread #0' (0x205c) has exited with code 0
(0x0).
24.36.148.45=Close --Time : 00:01:07.0937500
The thread '1' (0x1b78) has exited with code 0 (0x0).
The thread '0' (0x1a20) has exited with code 0 (0x0).
The thread '2' (0x10f0) has exited with code 0 (0x0).
The thread '9' (0x158c) has exited with code 0 (0x0).
The thread '3' (0x2450) has exited with code 0 (0x0).
The thread '4' (0x1458) has exited with code 0 (0x0).
The thread '5' (0x380) has exited with code 0 (0x0).
The thread '6' (0x234c) has exited with code 0 (0x0).
The thread '7' (0xc70) has exited with code 0 (0x0).
The thread '8' (0x94) has exited with code 0 (0x0).
The thread '10' (0x1da0) has exited with code 0 (0x0).
The thread '11' (0xfe0) has exited with code 0 (0x0).
The thread '12' (0xa08) has exited with code 0 (0x0).
The thread '13' (0x229c) has exited with code 0 (0x0).
The thread '14' (0x16ec) has exited with code 0 (0x0).
The thread '<No Name>' (0x231c) has exited with code 0 (0x0).
The thread 'STP 24.36.148.46 Thread #0' (0x4dc) has exited with code 0
(0x0).
24.36.148.46=Close --Time : 00:01:23.9218750
The thread 'STP 24.36.148.47 Thread #0' (0x35c) has exited with code 0
(0x0).
24.36.148.47=Close --Time : 00:01:24.4062500
The thread 'STP 24.36.148.48 Thread #0' (0xe30) has exited with code 0
(0x0).
24.36.148.48=Close --Time : 00:01:24.5000000
24.36.148.51=Close --Time : 00:01:24.5312500
24.36.148.49=Close --Time : 00:01:24.8906250
24.36.148.50=Close --Time : 00:01:24.7343750
The thread 'STP 24.36.148.49 Thread #0' (0x15cc) has exited with code 0
(0x0).
The thread 'STP 24.36.148.50 Thread #0' (0xa48) has exited with code 0
(0x0).
The thread 'STP 24.36.148.52 Thread #0' (0x7c0) has exited with code 0
(0x0).
The thread 'STP 24.36.148.51 Thread #0' (0x1294) has exited with code 0
(0x0).
The thread 'STP 24.36.148.53 Thread #0' (0x8c8) has exited with code 0
(0x0).
24.36.148.52=Close --Time : 00:01:24.3437500
24.36.148.53=Close --Time : 00:01:24.1875000

..........

The thread 'STP 24.36.148.209 Thread #0' (0x1084) has exited with code
0 (0x0).
24.36.148.209=Close --Time : 00:05:29.4218750
The thread 'STP 24.36.148.210 Thread #0' (0x9a4) has exited with code 0
(0x0).
24.36.148.210=Close --Time : 00:05:29.4218750
The thread 'STP 24.36.148.211 Thread #0' (0x558) has exited with code 0
(0x0).
24.36.148.211=Close --Time : 00:05:28.0937500

.............

24.36.148.253=Close --Time : 00:06:38.6093750
The thread 'STP 24.36.148.254 Thread #0' (0x1f00) has exited with code
0 (0x0).
24.36.148.254=Close --Time : 00:06:38.7187500
The thread 'STP 24.36.148.255 Thread #0' (0x1a5c) has exited with code
0 (0x0).
24.36.148.255=Close --Time : 00:06:38.6093750

I don't undertand......

On 24 jan, 16:31, "Robson Siqueira" <rob...@robsonfelix.comwrote:
jgbid,

It looks to me that:

a) your thread control stuff looks kinda hard to maintain for me, besides
that it is my best shot for the code you sent. If you have just one thread
working, it means that you are not multi threading at all. Why don't you
take a look on this framework:http://www.codeproject.com/cs/thread...threadpool.asp. I've used this
for quite some time and it has saved my life.
b) on the worker thread, instead of using asynchronous calls, use
synchronous. I am pretty sure it will be easier to maintain and to test.

I hope it helps!
--
Regards,
Robson Siqueira
Enterprise Architect"jgbid" <jgbid...@yahoo.cawrote in messagenews:11********************@v45g2000cwv.goo glegroups.com...
Hi, I'm trying to build an IP Scanner inc c# for a specific port (80)
and for specific IP Ranges.
For example 24.36.148.1 to 24.36.148.255
My first step was to use TcpClient, but there are nothing to control
Timeout Connection... and I wasn't interested to wait 25-30sec for each
ip.
After some search, it's look like Socket was the solution with
BeginConnect. After a first look, I thought that all worked perfectly,
but after a second look... I noticed that after some scan... approx. 10
or 15, nothing work...
If I set maximum thread to 1, it works, this it what I got:
24.36.148.10--->Close
24.36.148.23--->Close
24.36.148.24--->Close
24.36.148.28--->Close
24.36.148.66--->Close
24.36.148.70--->Close
24.36.148.77--->Close
24.36.148.116--->Close
24.36.148.121--->Close
24.36.148.126--->Close
24.36.148.130--->Close
24.36.148.132--->Close
24.36.148.137--->Close
24.36.148.146--->Close
24.36.148.147--->Close
24.36.148.148--->Close
24.36.148.154--->Close
24.36.148.164--->Close
24.36.148.177--->Close
24.36.148.180--->Open
24.36.148.197--->Close
24.36.148.199--->Close
24.36.148.202--->Close
24.36.148.213--->Close
24.36.148.216--->Close
24.36.148.234--->Close
24.36.148.241--->Close
24.36.148.251--->Close
where the only one with Port 80 open is "24.36.148.180--->Open"
and where "Close" means "the remote host is reachable, but refuses
connections on a port"
If I set maximum Thread to 5 or something else better... the only thing
I got is :
24.36.148.10--->Close
Nothing else..... like if Socket doesn't work when they are too many
socket open...
But I tried by anything I know to kill the bad sockets
Here is my code :
PortScanner Class :
Expand|Select|Wrap|Line Numbers
  1.  public class PortScanner
  2.  {
  3.  private int m_iPort = 0;
  4.  private bool m_bTimeOut = false;
  5.  private string m_sStatus = "Not connected";
  6.  private IPAddress m_oIPAddress;
  7.  private AutoResetEvent m_oARSConnectDone = new AutoResetEvent(false);
Expand|Select|Wrap|Line Numbers
  2.         
  3.                  public PortScanner(long iIP)
  4.  {
  5.  m_oIPAddress = new IPAddress(iIP);
  6.  m_iPort = 80;
  7.  }
  8.  public int Port
  9.  {
  10.  get{ return m_iPort; }
  11.  }
  12.  public string IP
  13.  {
  14.  get{ return m_oIPAddress.ToString(); }
  15.  }
  16.  private void ConnectCallback(IAsyncResult ar)
  17.  {
  18.  if(m_bTimeOut)
  19.  return;
  •  
  •         
  •                  Socket oSocket = (Socket)ar.AsyncState;
  •  try
  •  {
  •  // Complete the connection.
  •  oSocket.EndConnect(ar);
  •  m_sStatus = "Open";
  •  }
  •  catch
  •  {
  •  // The EndConnect method will throw a SocetException if the remote
  •  // host is reachable, but refuses connections on a port.
  •  m_sStatus = "Close";
  •  }
  •  finally
  •  {
  •  if (oSocket.Connected)
  •  oSocket.Shutdown(SocketShutdown.Both);
  •  oSocket.Close();
  •  oSocket=null;
  •  m_oARSConnectDone.Set(); //tell the main thread that the callback
  •  has been finished.
  •  Console.WriteLine(m_oIPAddress.ToString() + "--->" + m_sStatus);
  •  }
  •  }
  •  
  •         
  •                  // initiate a connection to the port.
  •  public void Scan()
  •  {
  •  try
  •  {
  •  m_bTimeOut = false;
  •  Socket oScanningIpPort = new Socket(AddressFamily.InterNetwork,
  •  SocketType.Stream, ProtocolType.Tcp);
  •  oScanningIpPort.BeginConnect(new IPEndPoint(m_oIPAddress, m_iPort),
  •  new AsyncCallback(ConnectCallback), oScanningIpPort);
  •  if(!m_oARSConnectDone.WaitOne(10000, true))
  •  {
  •  m_bTimeOut = true;
  •  oScanningIpPort.Close();
  •  oScanningIpPort = null;
  •  }
  •  m_oARSConnectDone.Close();
  •  }
  •  catch(SocketException ex)
  •  {
  •  Console.WriteLine(ex.ErrorCode);
  •  }
  •  }
  •  }
  •  
  •         
  •  
  •  
  •  
    • Main Code :
    StartHTTPScanning -is called by a Form Button
    Expand|Select|Wrap|Line Numbers
    1.  private Thread m_oThreadScanning;
    2.  private Queue m_queueIP = new Queue();
    Expand|Select|Wrap|Line Numbers
    2.         
    3.                  //flag to be used to tell the HTTP Scan Thread that IP is still
    4.  enqueuing
    5.  private bool m_bEnqueuingIP;
    7.  
    9.         
    10.                  private int m_iMaxRunning = 10;
    11.  // private int m_iMaxRunning = 255;
    13.  
    15.         
    16.                  // flag to be used to stop all running threads when user request to
    17.  stop
    18.  bool m_bRunning = true;
    20.  
    22.         
    23.                  private void EnqueuingIP()
    24.  {
    25.  m_bEnqueuingIP = true;
    26.  XmlDocument xDocLstIPs = new XmlDocument();
    27.  xDocLstIPs.Load("IPRange.xml");
    29.  
    31.         
    32.                  XmlNodeList xLstNdIPs = xDocLstIPs.SelectNodes("/RangeIPs/RangeIP");
    33.  foreach(XmlElement xElemDomain in xLstNdIPs)
    34.  {
    35.  try
    36.  {
    37.  Int64 iStartIP =
    38.  long.Parse(xElemDomain.GetAttribute("start").ToString());
    39.  Int64 iEndIP =
    40.  long.Parse(xElemDomain.GetAttribute("end").ToString());
    41.  while(iStartIP <= iEndIP)
    42.  {
    43.  m_queueIP.Enqueue(iStartIP);
    44.  iStartIP++;
    45.  }
    46.  }
    47.  catch(Exception ex)
    48.  {
    49.  MessageBox.Show(ex.Message);
    50.  }
    51.  Thread.Sleep(2000);
    52.  }
    54.  
    56.         
    57.                  //end enqueuing
    58.  m_bEnqueuingIP = false;
    59.  }
    61.  
    63.         
    64.                  public void HTTPScanRunFunction()
    65.  {
    66.  while(m_bRunning && (m_queueIP.Count 0 || m_bEnqueuingIP) &&
    67.  int.Parse(Thread.CurrentThread.Name) < m_iMaxRunning)
    68.  {
    70.  
    72.         
    73.                  if(m_queueIP.Count == 0 && m_bEnqueuingIP)
    74.  {
    75.  Thread.Sleep(500);
    76.  continue;
    77.  }
    78.  long iIP = 0;
    79.  lock(m_queueIP)
    80.  {
    81.  iIP = Convert.ToInt64(m_queueIP.Dequeue());
    82.  }
    83.  if(iIP == 0)
    84.  continue;
    86.  
    88.         
    89.                  PortScanner oPortScanner =  new PortScanner(iIP);
    91.  
    93.         
    94.                  // update thread information in the threads view list
    95.  ListViewItem itemLog;
    96.  itemLog =
    97.  listViewThreads.Items[int.Parse(Thread.CurrentThread.Name)];
    98.  itemLog.SubItems[0].Text = oPortScanner.IP.ToString();
    99.  itemLog.SubItems[1].Text = oPortScanner.Port.ToString();
    100.  itemLog.ImageIndex = 1;
    101.  itemLog.BackColor = Color.WhiteSmoke;
    103.  
    105.         
    106.                  // initialize status to Connect
    107.  itemLog.SubItems[2].Text = "Scanning";
    108.  itemLog.ForeColor = Color.Green;
    110.  
    112.         
    113.                  oPortScanner.Scan();
    115.  
    117.         
    118.                  if(m_bRunning == false)
    119.  itemLog.SubItems[2].Text = "Stop";
    121.  
    123.         
    124.                  itemLog.ImageIndex = 0;
    125.  itemLog.SubItems[0].Text = "";
    126.  itemLog.SubItems[1].Text = "";
    127.  itemLog.SubItems[2].Text = "";
    129.  
    131.         
    132.                  oPortScanner = null;
    133.  }
    135.  
    137.         
    138.                  }
    140.  
    142.         
    143.                  private void HTTPScanning()
    144.  {
    145.  // start parsing thread
    146.  Thread oThreadEnqueuingIP = new Thread(new ThreadStart(EnqueuingIP));
    147.  oThreadEnqueuingIP.Name = "ThreadEnqueuingIP";
    148.  oThreadEnqueuingIP.Start();
    150.  
    152.         
    153.                  // create the threads
    154.  Thread[] threadsRun = new Thread[ m_iMaxRunning ];
    155.  int nIndex = 0;
    156.  for(nIndex = 0; nIndex < m_iMaxRunning; nIndex ++)
    157.  {
    158.  // check if thread not created or not suspended
    159.  if(threadsRun[nIndex] == null || threadsRun[nIndex].ThreadState !=
    160.  ThreadState.Suspended)
    161.  {
    162.  threadsRun[nIndex] = new Thread( new ThreadStart(
    163.  HTTPScanRunFunction ) );
    165.  
    167.         
    168.                  // set thread name equal to its index
    169.  threadsRun[nIndex].Name = nIndex.ToString();
    171.  
    173.         
    174.                  lock(listViewThreads)
    175.  {
    176.  // add a new line in the view for the new thread
    177.  ListViewItem item =
    178.  listViewThreads.Items.Add(threadsRun[nIndex].Name, 0);
    179.  string[] subItems = { "", "", "" };
    180.  item.SubItems.AddRange(subItems);
    181.  }
    183.  
    185.         
    186.                  Thread.Sleep(200);
    187.  // start the thread
    188.  threadsRun[nIndex].Start();
    190.  
    192.         
    193.                  }
    194.  // check if the thread is suspended
    195.  else if(threadsRun[nIndex].ThreadState == ThreadState.Suspended)
    196.  {
    197.  // resume the thread
    198.  threadsRun[nIndex].Resume();
    199.  }
    200.  }
    202.  
    204.         
    205.                  // wait for all of them to finish
    206.  for ( nIndex = 0; nIndex < threadsRun.Length; nIndex ++ )
    207.  threadsRun[nIndex].Join();
    209.  
    211.         
    212.                  this.toolBarButtonContinue.Enabled = true;
    213.  this.toolBarButtonPause.Enabled = false;
    214.  }
    216.  
    218.         
    219.                  private void StartHTTPScanning()
    220.  {
    221.  // start parsing thread
    222.  m_oThreadScanning = new Thread(new ThreadStart(HTTPScanning));
    223.  m_oThreadScanning.Start();
    224.  }
    226.  
    227.  
    - Masquer le texte des messages précédents -- Afficher le texte des messages précédents -
    Jan 25 '07 #3
    New Post

    This thread has been closed and replies have been disabled. Please start a new discussion.

    Similar topics

    0
    Help needed in problem with Threads and sockets.
    by: Gonçalo Rodrigues | last post by:
    Hi, I have a problem with threads and sockets. I'll try to describe the problem in words with pseudo-code. I've been working on a few classes to make it easier to work with threads. This...
    Python
    3
    Problem with threads and signals
    by: Sebastian Meyer | last post by:
    Hi Newsgroup, i have some problems with using threads and signals in one program. In my program i have three threads running, one for checking a directory at a specified interval to see if new...
    Python
    2
    Problem with threads
    by: Stephan Popp | last post by:
    Hi all, I've got a problem with stopping python-threads. I'm starting a thread with twisteds reactor.deferToThread which start a methodcall in a seperate thread. In this thread a swig-wrapped c++...
    Python
    3
    Problem: sockets
    by: Manuel Hegemann | last post by:
    Hallo, in meinem Schulprojekt, soll eine Datei, jedesmal wenn Sie aktualisiert wird auf nen FTP-Server oder für den Test auf nen Netzwerkserver gespeichert werden. Das Problem ist, dass ich noch...
    C / C++
    4
    Problem with threads...
    by: Nurchi BECHED | last post by:
    Hello, my dearest respected brother, All! I am writing an application which uses printer port to play with LEDs for now and something else later... I created a button which makes LEDs...
    C# / C Sharp
    0
    Problem in Threads running in VB.NET
    by: Mamatha | last post by:
    Hi I have application in VB.NET,In that application threads are created dynamically and displays URLs of a webpage in the listview.At the time of running each thread their URL values are stored...
    Visual Basic .NET
    5
    PROBLEM WITH THREADS - WIN 2003
    by: Mr | last post by:
    Hi We have a application with Framework 1.1 and Vs .NET 2003. the application has a service with pooling; like a File system Watcher, but works. the system works fine in the development...
    C# / C Sharp
    2
    problem regarding threads, invoke and class libraries
    by: ThunderMusic | last post by:
    Hi, I have a class library with some classes... One of those classes fire events from a different thread. When I try to display the information contained in the event args of this event in my UI,...
    .NET Framework
    3
    problem with threads
    by: _nabuchodonozor | last post by:
    Hi, its me again:P I'm writing my own mp3 player. I have loop which looks: while (trackBar1.Value != TrackLength) { TrackBar1.Value = TrackPosition(); } This loop set position to the...
    C# / C Sharp
    0
    How to turn on java script in a villaon keypad mobile phone
    by: Charles Arthur | last post by:
    How do i turn on java script on a villaon, callus and itel keypad mobile phone
    Java
    0
    Batch import of multiple excel files into the database
    by: ryjfgjl | last post by:
    If we have dozens or hundreds of excel to import into the database, if we use the excel import function provided by database editors such as navicat, it will be extremely tedious and time-consuming...
    Data Management
    0
    Merging data from multiple Excel files
    by: ryjfgjl | last post by:
    In our work, we often receive Excel tables with data in the same format. If we want to analyze these data, it can be difficult to analyze them because the data is spread across multiple Excel files...
    Data Management
    1
    Looking to do Android software development, any suggestions? Is flutter better?
    by: nemocccc | last post by:
    hello, everyone, I want to develop a software for my android phone for daily needs, any suggestions?
    General
    1
    Is that possible of reading the .csv file in column wise and the column have different lengths ?
    by: Sonnysonu | last post by:
    This is the data of csv file 1 2 3 1 2 3 1 2 3 1 2 3 2 3 2 3 3 the lengths should be different i have to store the data by column-wise with in the specific length. suppose the i have to...
    C / C++
    0
    Changing the language in Windows 10
    by: Hystou | last post by:
    Most computers default to English, but sometimes we require a different language, especially when relocating. Forgot to request a specific language before your computer shipped? No problem! You can...
    Windows Server
    0
    Oralloy
    Problem With Comparison Operator <=> in G++
    by: Oralloy | last post by:
    Hello folks, I am unable to find appropriate documentation on the type promotion of bit-fields when using the generalised comparison operator "<=>". The problem is that using the GNU compilers,...
    C / C++
    0
    jinu1996
    Maximizing Business Potential: The Nexus of Website Design and Digital Marketing
    by: jinu1996 | last post by:
    In today's digital age, having a compelling online presence is paramount for businesses aiming to thrive in a competitive landscape. At the heart of this digital strategy lies an intricately woven...
    Online Marketing
    0
    The easy way to turn off automatic updates for Windows 10/11
    by: Hystou | last post by:
    Overview: Windows 11 and 10 have less user interface control over operating system update behaviour than previous versions of Windows. In Windows 11 and 10, there is no way to turn off the Windows...
    Windows Server

    By using Bytes.com and it's services, you agree to our Privacy Policy and Terms of Use.

    To disable or enable advertisements and analytics tracking please visit the manage ads & tracking page.

    BYTES.COM © 2024
    About Bytes
    Terms Of Use
    Privacy Policy
    Sitemap
    Advertise on Bytes:
    Post a Job
    Sponsored Posts
    Platinum & Gold Sponsors
    Hire Now!