diff options
Diffstat (limited to 'cs/src/IceSSL/AcceptorI.cs')
| -rwxr-xr-x | cs/src/IceSSL/AcceptorI.cs | 280 |
1 files changed, 140 insertions, 140 deletions
diff --git a/cs/src/IceSSL/AcceptorI.cs b/cs/src/IceSSL/AcceptorI.cs index 1a4b011da28..2ce09404d5b 100755 --- a/cs/src/IceSSL/AcceptorI.cs +++ b/cs/src/IceSSL/AcceptorI.cs @@ -19,159 +19,159 @@ namespace IceSSL class AcceptorI : IceInternal.Acceptor { - public virtual Socket fd() - { - return fd_; - } - - public virtual void close() - { + public virtual Socket fd() + { + return fd_; + } + + public virtual void close() + { Socket fd; - lock(this) - { - fd = fd_; - fd_ = null; - } - if(fd != null) - { - if(instance_.networkTraceLevel() >= 1) - { - string s = "stopping to accept ssl connections at " + ToString(); - logger_.trace(instance_.networkTraceCategory(), s); - } - - try - { - fd.Close(); - } - catch(System.Exception) - { - // Ignore. - } - } - } - - public virtual void listen() - { - IceInternal.Network.doListen(fd_, backlog_); - - if(instance_.networkTraceLevel() >= 1) - { - string s = "accepting ssl connections at " + ToString(); - logger_.trace(instance_.networkTraceCategory(), s); - } - } - - public virtual IceInternal.Transceiver accept(int timeout) - { - Debug.Assert(timeout == -1); // Always called with -1 for thread-per-connection. + lock(this) + { + fd = fd_; + fd_ = null; + } + if(fd != null) + { + if(instance_.networkTraceLevel() >= 1) + { + string s = "stopping to accept ssl connections at " + ToString(); + logger_.trace(instance_.networkTraceCategory(), s); + } + + try + { + fd.Close(); + } + catch(System.Exception) + { + // Ignore. + } + } + } + + public virtual void listen() + { + IceInternal.Network.doListen(fd_, backlog_); + + if(instance_.networkTraceLevel() >= 1) + { + string s = "accepting ssl connections at " + ToString(); + logger_.trace(instance_.networkTraceCategory(), s); + } + } + + public virtual IceInternal.Transceiver accept(int timeout) + { + Debug.Assert(timeout == -1); // Always called with -1 for thread-per-connection. - // - // The plugin may not be fully initialized. - // - if(!instance_.initialized()) - { - Ice.PluginInitializationException ex = new Ice.PluginInitializationException(); - ex.reason = "IceSSL: plugin is not initialized"; - throw ex; - } + // + // The plugin may not be fully initialized. + // + if(!instance_.initialized()) + { + Ice.PluginInitializationException ex = new Ice.PluginInitializationException(); + ex.reason = "IceSSL: plugin is not initialized"; + throw ex; + } - Socket fd = IceInternal.Network.doAccept(fd_, timeout); - IceInternal.Network.setBlock(fd, true); // SSL requires a blocking socket. + Socket fd = IceInternal.Network.doAccept(fd_, timeout); + IceInternal.Network.setBlock(fd, true); // SSL requires a blocking socket. - if(instance_.networkTraceLevel() >= 1) - { - string s = "attempting to accept ssl connection\n" + IceInternal.Network.fdToString(fd); - logger_.trace(instance_.networkTraceCategory(), s); - } + if(instance_.networkTraceLevel() >= 1) + { + string s = "attempting to accept ssl connection\n" + IceInternal.Network.fdToString(fd); + logger_.trace(instance_.networkTraceCategory(), s); + } - return new TransceiverI(instance_, fd, adapterName_); - } + return new TransceiverI(instance_, fd, adapterName_); + } - public virtual void connectToSelf() - { - Socket fd = IceInternal.Network.createSocket(false); - IceInternal.Network.setBlock(fd, false); - IceInternal.Network.doConnect(fd, addr_, -1); - IceInternal.Network.closeSocket(fd); - } + public virtual void connectToSelf() + { + Socket fd = IceInternal.Network.createSocket(false); + IceInternal.Network.setBlock(fd, false); + IceInternal.Network.doConnect(fd, addr_, -1); + IceInternal.Network.closeSocket(fd); + } - public override string ToString() - { - return IceInternal.Network.addrToString(addr_); - } - - internal bool equivalent(string host, int port) - { - EndPoint addr = IceInternal.Network.getAddress(host, port); - return addr.Equals(addr_); - } + public override string ToString() + { + return IceInternal.Network.addrToString(addr_); + } + + internal bool equivalent(string host, int port) + { + EndPoint addr = IceInternal.Network.getAddress(host, port); + return addr.Equals(addr_); + } - internal virtual int effectivePort() - { - return addr_.Port; - } + internal virtual int effectivePort() + { + return addr_.Port; + } - internal - AcceptorI(Instance instance, string adapterName, string host, int port) - { - instance_ = instance; - adapterName_ = adapterName; - logger_ = instance.communicator().getLogger(); - backlog_ = 0; + internal + AcceptorI(Instance instance, string adapterName, string host, int port) + { + instance_ = instance; + adapterName_ = adapterName; + logger_ = instance.communicator().getLogger(); + backlog_ = 0; - // - // .NET requires that a certificate be supplied. - // - X509Certificate2Collection certs = instance.certs(); - if(certs.Count == 0) - { - Ice.SecurityException ex = new Ice.SecurityException(); - ex.reason = "IceSSL: certificate required for server endpoint"; - throw ex; - } + // + // .NET requires that a certificate be supplied. + // + X509Certificate2Collection certs = instance.certs(); + if(certs.Count == 0) + { + Ice.SecurityException ex = new Ice.SecurityException(); + ex.reason = "IceSSL: certificate required for server endpoint"; + throw ex; + } - if(backlog_ <= 0) - { - backlog_ = 5; - } - - try - { - fd_ = IceInternal.Network.createSocket(false); - IceInternal.Network.setBlock(fd_, false); - addr_ = IceInternal.Network.getAddress(host, port); - if(instance_.networkTraceLevel() >= 2) - { - string s = "attempting to bind to ssl socket " + ToString(); - logger_.trace(instance_.networkTraceCategory(), s); - } - addr_ = IceInternal.Network.doBind(fd_, addr_); - } - catch(System.Exception) - { - fd_ = null; - throw; - } - } - + if(backlog_ <= 0) + { + backlog_ = 5; + } + + try + { + fd_ = IceInternal.Network.createSocket(false); + IceInternal.Network.setBlock(fd_, false); + addr_ = IceInternal.Network.getAddress(host, port); + if(instance_.networkTraceLevel() >= 2) + { + string s = "attempting to bind to ssl socket " + ToString(); + logger_.trace(instance_.networkTraceCategory(), s); + } + addr_ = IceInternal.Network.doBind(fd_, addr_); + } + catch(System.Exception) + { + fd_ = null; + throw; + } + } + #if DEBUG - ~AcceptorI() - { - /* - lock(this) - { - IceUtil.Assert.FinalizerAssert(fd_ == null); - } - */ - } + ~AcceptorI() + { + /* + lock(this) + { + IceUtil.Assert.FinalizerAssert(fd_ == null); + } + */ + } #endif - private Instance instance_; - private string adapterName_; - private Ice.Logger logger_; - private Socket fd_; - private int backlog_; - private IPEndPoint addr_; + private Instance instance_; + private string adapterName_; + private Ice.Logger logger_; + private Socket fd_; + private int backlog_; + private IPEndPoint addr_; } } |