I think you worry about wrong things. To begin with, why do initialize the
listener passing a delegate? You can certainly do so, but it will only make
your code more obscure.
>
I was really wondering if anyone was familiar with the "best way" to stop
from this sort of loop
>
there must be a button or a switch on the front panel of your PC, or you can
just pull the AC cord. Seriously, whatever loops your program runs, or the
framework runs on your program behalf, will be exited once you stop the
service. If you want a graceful exit, then stop accepting new connections,
close all worker sockets, close the listener socket. The best way of
disconnecting connected clients is calling ShutDown() followed by
BeginDisconnect () end call socket.Close() from EndDisconnect() .
BeginDisconnect ()/EndDisconnect() are supported only on XP and higher. You
could get away with socket.Shutdown () / socket.Close() with proper error
interception in callback methods.
>
I would like this to become a window's service, so I want to listen for
incoming connections until the service is stopped.
>
in my opinion this would require much cleaner code.
Michael
<da*********@gm ail.comwrote in message
news:11******** *************@8 g2000cwh.google groups.com...
On Mar 1, 10:10 am, "Michael Rubinstein"
<mSPAM_REMOVEr@ m®ubinstein.com wrote:
<
It does an infinite loop this way...
Does it bother you? Instead of closing the listening socket, you can put a
limit on the number of client connections and issue BeginAccept() only
until
that limit is reached. Normally you would close the listening socket only
after you have no clients connected and done with TCP.
Michael
<darthgha...@gm ail.comwrote in message
news:11******** **************@ p10g2000cwp.goo glegroups.com.. .
I've created a class to listen to all interfaces and do a
BeginAccept(). Once it gets a connection, it passes the connected
socket off and stores it in a List. Next, it continues to listen for
more incoming connections and does the BeginAccpet() again. It does
an infinite loop this way. My question is: What is the best way to
stop this? I thought about putting a boolean in there, but then what
if it's still waiting for an incoming connection? Can I just close
the socket?
Here is my code for reference:
public class Listener
{
private Socket m_listener;
private ConnectionCallb ack m_callBack;
public Listener(Connec tionCallback callme)
{
m_callBack = callme;
}
public void AcceptNewConnec tions()
{
this.AcceptNewC onnections(2200 );
}
public void AcceptNewConnec tions(int port)
{
IPEndPoint theEnd = new IPEndPoint(IPAd dress.Any, port);
m_listener = new Socket(AddressF amily.InterNetw ork,
SocketType.Stre am, ProtocolType.Tc p);
m_listener.Bind (theEnd);
Console.WriteLi ne("Binding to " +
theEnd.Address. ToString() + " on port " + theEnd.Port.ToS tring());
m_listener.List en(20); //TODO: make this
configurable
Console.WriteLi ne("Now listening");
AsyncCallback callme = new AsyncCallback(A ddWorkerSocket) ;
m_listener.Begi nAccept(callme, m_listener);
}
private void AddWorkerSocket (IAsyncResult ar)
{
Console.WriteLi ne("Got a Connection");
Socket hold = (Socket)ar.Asyn cState;
Socket work = hold.EndAccept( ar);
if (work.Connected )
{
Console.WriteLi ne("Accepted a connection from " +
work.RemoteEndP oint.ToString() );
m_callBack(work );
}
AsyncCallback callMe = new AsyncCallback(A ddWorkerSocket) ;
hold.BeginAccep t(callMe, hold);
}
}
I was hoping for an infinite loop, sort of. I would like this to
become a window's service, so I want to listen for incoming
connections until the service is stopped. I was really wondering if
anyone was familiar with the "best way" to stop from this sort of
loop. I have modified the code slightly so that when the service
stops, the list of sockets is looped through. While looping through
the sockets, I call Socket.Close() in order to try to clean up my
mess. It seems to work without throwing any exceptions, but I am just
wondering if this is the right way to do things.
Thanks again for your time and comments. Here is the modified code:
public delegate void ConnectionCallb ack(Socket sockMe);
public class Controller
{
private Listener m_listen;
private List<Socketm_wo kerList;
//need a connection
//private List<Connection connectList;
public Controller()
{
m_wokerList = new List<Socket>(20 ); //TODO: make
this configurable
}
public void Start()
{
m_listen = new Listener(new
ConnectionCallb ack(this.AddSoc ketToList));
m_listen.Accept NewConnections( );
}
public void AddSocketToList (Socket sock)
{
Console.WriteLi ne("Got a socket and adding it to the list
of workers");
m_wokerList.Add (sock);
Console.WriteLi ne("There are now " +
m_wokerList.Cou nt.ToString() + " sockets in the list.");
if (m_wokerList[m_wokerList.Cou nt - 1].Connected)
{
Console.WriteLi ne("The last socket is connected to" +
m_wokerList[m_wokerList.Cou nt - 1].RemoteEndPoint .ToString());
}
else
{
Console.WriteLi ne("The last socket is NOT connected");
}
}
public void Stop()
{
foreach (Socket closeSock in m_wokerList)
{
closeSock.Close ();
}
m_listen.StopLi stening();
}
}
public class Listener
{
private Socket m_listener;
private ConnectionCallb ack m_callBack;
public Listener(Connec tionCallback callme)
{
m_callBack = callme;
}
public void AcceptNewConnec tions()
{
this.AcceptNewC onnections(2200 );
}
public void AcceptNewConnec tions(int port)
{
IPEndPoint theEnd = new IPEndPoint(IPAd dress.Any, port);
m_listener = new Socket(AddressF amily.InterNetw ork,
SocketType.Stre am, ProtocolType.Tc p);
m_listener.Bind (theEnd);
Console.WriteLi ne("Binding to " +
theEnd.Address. ToString() + " on port " + theEnd.Port.ToS tring());
m_listener.List en(20); //TODO: make this
configurable
Console.WriteLi ne("Now listening");
AsyncCallback callme = new AsyncCallback(A ddWorkerSocket) ;
m_listener.Begi nAccept(callme, m_listener);
}
private void AddWorkerSocket (IAsyncResult ar)
{
Console.WriteLi ne("Got a Connection");
Socket hold = (Socket)ar.Asyn cState;
Socket work = hold.EndAccept( ar);
if (work.Connected )
{
Console.WriteLi ne("Accepted a connection from " +
work.RemoteEndP oint.ToString() );
m_callBack(work );
}
AsyncCallback callMe = new AsyncCallback(A ddWorkerSocket) ;
hold.BeginAccep t(callMe, hold);
}
public void StopListening()
{
m_listener.Clos e();
}
}
