mono/mcs/class/System/System.Net.Sockets/Socket.jvm.cs

// System.Net.Sockets.Socket.cs
//
// Authors:
//    Phillip Pearson ([email protected])
//    Dick Porter <[email protected]>
//	Gonzalo Paniagua Javier ([email protected])
//
// Copyright (C) 2001, 2002 Phillip Pearson and Ximian, Inc.
//    http://www.myelin.co.nz
// (c) 2004 Novell, Inc. (http://www.novell.com)
//

//
// Permission is hereby granted, free of charge, to any person obtaining
// a copy of this software and associated documentation files (the
// "Software"), to deal in the Software without restriction, including
// without limitation the rights to use, copy, modify, merge, publish,
// distribute, sublicense, and/or sell copies of the Software, and to
// permit persons to whom the Software is furnished to do so, subject to
// the following conditions:
// 
// The above copyright notice and this permission notice shall be
// included in all copies or substantial portions of the Software.
// 
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
// EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
// NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
// LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
// OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
// WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
//

using System.Collections;
using System.Collections.Generic;
using System.Net.Configuration;
using System.Runtime.InteropServices;
using System.Threading;

namespace System.Net.Sockets 
{
	public class Socket : IDisposable 
	{
		enum SocketOperation 
		{
			Accept,
			Connect,
			Receive,
			ReceiveFrom,
			Send,
			SendTo
		}

		[StructLayout (LayoutKind.Sequential)]
		private sealed class SocketAsyncResult: IAsyncResult 
		{
			/* Same structure in the runtime */
			public Socket Sock;
#if !TARGET_JVM
			public IntPtr handle;
#else
			public GHSocket handle;
#endif
			object state;
			AsyncCallback callback;
			WaitHandle waithandle;

			Exception delayedException;

			public EndPoint EndPoint;	// Connect,ReceiveFrom,SendTo
			public byte [] Buffer;		// Receive,ReceiveFrom,Send,SendTo
			public int Offset;		// Receive,ReceiveFrom,Send,SendTo
			public int Size;		// Receive,ReceiveFrom,Send,SendTo
			public SocketFlags SockFlags;	// Receive,ReceiveFrom,Send,SendTo

			// Return values
			Socket acc_socket;
			int total;

			bool completed_sync;
			bool completed;
			public bool blocking;
			internal int error;
			SocketOperation operation;
			public object ares;

			public SocketAsyncResult (Socket sock, object state, AsyncCallback callback, SocketOperation operation)
			{
				this.Sock = sock;
				this.blocking = sock.blocking;
				this.handle = sock.socket;
				this.state = state;
				this.callback = callback;
				this.operation = operation;
				SockFlags = SocketFlags.None;
			}

			public void CheckIfThrowDelayedException ()
			{
				if (delayedException != null)
					throw delayedException;

				if (error != 0)
					throw new SocketException (error);
			}

			void CompleteAllOnDispose (Queue queue)
			{
				object [] pending = queue.ToArray ();
				queue.Clear ();

				WaitCallback cb;
				for (int i = 0; i < pending.Length; i++) 
				{
					SocketAsyncResult ares = (SocketAsyncResult) pending [i];
					cb = new WaitCallback (ares.CompleteDisposed);
					ThreadPool.QueueUserWorkItem (cb, null);
				}
			}

			void CompleteDisposed (object unused)
			{
				Complete ();
			}

			public void Complete ()
			{
				if (operation != SocketOperation.Receive && Sock.disposed)
					delayedException = new ObjectDisposedException (Sock.GetType ().ToString ());

				IsCompleted = true;

				Queue queue = null;
				if (operation == SocketOperation.Receive || operation == SocketOperation.ReceiveFrom) 
				{
					queue = Sock.readQ;
				} 
				else if (operation == SocketOperation.Send || operation == SocketOperation.SendTo) 
				{
					queue = Sock.writeQ;
				}

				if (queue != null) 
				{
					SocketAsyncCall sac = null;
					SocketAsyncResult req = null;
					lock (queue) 
					{
						queue.Dequeue (); // remove ourselves
						if (queue.Count > 0) 
						{
							req = (SocketAsyncResult) queue.Peek ();
							if (!Sock.disposed) 
							{
								Worker worker = new Worker (req);
								sac = GetDelegate (worker, req.operation);
							} 
							else 
							{
								CompleteAllOnDispose (queue);
							}
						}
					}

					if (sac != null)
						sac.BeginInvoke (null, req);
				}

				if (callback != null)
					callback (this);
			}

			SocketAsyncCall GetDelegate (Worker worker, SocketOperation op)
			{
				switch (op) 
				{
					case SocketOperation.Receive:
						return new SocketAsyncCall (worker.Receive);
					case SocketOperation.ReceiveFrom:
						return new SocketAsyncCall (worker.ReceiveFrom);
					case SocketOperation.Send:
						return new SocketAsyncCall (worker.Send);
					case SocketOperation.SendTo:
						return new SocketAsyncCall (worker.SendTo);
					default:
						return null; // never happens
				}
			}

			public void Complete (bool synch)
			{
				completed_sync = synch;
				Complete ();
			}

			public void Complete (int total)
			{
				this.total = total;
				Complete ();
			}
			
			public void Complete (Exception e, bool synch)
			{
				completed_sync = synch;
				delayedException = e;
				Complete ();
			}

			public void Complete (Exception e)
			{
				delayedException = e;
				Complete ();
			}

			public void Complete (Socket s)
			{
				acc_socket = s;
				Complete ();
			}

			public object AsyncState 
			{
				get 
				{
					return state;
				}
			}

			public WaitHandle AsyncWaitHandle 
			{
				get 
				{
					lock (this) 
					{
						if (waithandle == null)
							waithandle = new ManualResetEvent (completed);
					}

					return waithandle;
				}
				set 
				{
					waithandle=value;
				}
			}

			public bool CompletedSynchronously 
			{
				get 
				{
					return(completed_sync);
				}
			}

			public bool IsCompleted 
			{
				get 
				{
					return(completed);
				}
				set 
				{
					completed=value;
					lock (this) 
					{
						if (waithandle != null && value) 
						{
							((ManualResetEvent) waithandle).Set ();
						}
					}
				}
			}
			
			public Socket Socket 
			{
				get 
				{
					return acc_socket;
				}
			}

			public int Total 
			{
				get 
				{
					return total;
				}
				set 
				{ 
					total = value; 
				}
			}
		}

		private sealed class Worker 
		{
			SocketAsyncResult result;

			public Worker (SocketAsyncResult ares)
			{
				this.result = ares;
			}
			
			public void Accept ()
			{
				Socket acc_socket = null;
				try 
				{
					acc_socket = result.Sock.Accept ();
				} 
				catch (Exception e) 
				{
					result.Complete (e);
					return;
				}

				result.Complete (acc_socket);
			}

			public void Connect ()
			{
				try 
				{
					result.Sock.Connect (result.EndPoint);
					result.Sock.connected = true;
				} 
				catch (Exception e) 
				{
					result.Complete (e);
					return;
				}

				result.Complete ();
			}

#if !TARGET_JVM
			public void Receive ()
			{
				// Actual recv() done in the runtime
				result.Complete ();
			}
#else
			public void Receive ()
			{
				int total = 0;
				try 
				{
					total = result.Sock.Receive_nochecks (result.Buffer,
						result.Offset,
						result.Size,
						result.SockFlags);
				} 
				catch (Exception e) 
				{
					result.Complete (e);
					return;
				}

				result.Complete (total);
			}
#endif

			public void ReceiveFrom ()
			{
				int total = 0;
				try 
				{
					total = result.Sock.ReceiveFrom_nochecks (result.Buffer,
						result.Offset,
						result.Size,
						result.SockFlags,
						ref result.EndPoint);
				} 
				catch (Exception e) 
				{
					result.Complete (e);
					return;
				}

				result.Complete (total);
			}

			int send_so_far;

			void UpdateSendValues (int last_sent)
			{
				if (result.error == 0) 
				{
					send_so_far += last_sent;
					result.Offset += last_sent;
					result.Size -= last_sent;
				}
			}

#if !TARGET_JVM
			public void Send ()
			{
				// Actual send() done in the runtime
				if (result.error == 0) 
				{
					UpdateSendValues (result.Total);
					if (result.Sock.disposed) 
					{
						result.Complete ();
						return;
					}

					if (result.Size > 0) 
					{
						SocketAsyncCall sac = new SocketAsyncCall (this.Send);
						sac.BeginInvoke (null, result);
						return; // Have to finish writing everything. See bug #74475.
					}
					result.Total = send_so_far;
				}
				result.Complete ();
			}
#else
			public void Send ()
			{
				int total = 0;
				try 
				{
					total = result.Sock.Send_nochecks (result.Buffer,
						result.Offset,
						result.Size,
						result.SockFlags);

					UpdateSendValues (total);
					if (result.Size > 0) 
					{
						SocketAsyncCall sac = new SocketAsyncCall (this.SendTo);
						sac.BeginInvoke (null, result);
						return; // Have to finish writing everything. See bug #74475.
					}
					result.Total = send_so_far;
				} 
				catch (Exception e) 
				{
					result.Complete (e);
					return;
				}

				result.Complete ();
			}
#endif

			public void SendTo ()
			{
				int total = 0;
				try 
				{
					total = result.Sock.SendTo_nochecks (result.Buffer,
						result.Offset,
						result.Size,
						result.SockFlags,
						result.EndPoint);

					UpdateSendValues (total);
					if (result.Size > 0) 
					{
						SocketAsyncCall sac = new SocketAsyncCall (this.SendTo);
						sac.BeginInvoke (null, result);
						return; // Have to finish writing everything. See bug #74475.
					}
					result.Total = send_so_far;
				} 
				catch (Exception e) 
				{
					result.Complete (e);
					return;
				}

				result.Complete ();
			}
		}

			
		/* the field "socket" is looked up by name by the runtime */
#if !TARGET_JVM
		private IntPtr socket;
#else
		private GHSocket socket;
#endif
		private AddressFamily address_family;
		private SocketType socket_type;
		private ProtocolType protocol_type;
		internal bool blocking=true;
		private Queue readQ = new Queue (2);
		private Queue writeQ = new Queue (2);
		

		delegate void SocketAsyncCall ();
		/*
		 *	These two fields are looked up by name by the runtime, don't change
		 *  their name without also updating the runtime code.
		 */
		private static int ipv4Supported = -1, ipv6Supported = -1;

		/* When true, the socket was connected at the time of
		 * the last IO operation
		 */
		private bool connected=false;
		/* true if we called Close_internal */
		private bool closed;
		internal bool disposed;

		/* Used in LocalEndPoint and RemoteEndPoint if the
		 * Mono.Posix assembly is available
		 */
		private static object unixendpoint=null;
		private static Type unixendpointtype=null;
		
		static void AddSockets (ArrayList sockets, IList list, string name)
		{
			if (list != null) 
			{
				foreach (Socket sock in list) 
				{
					if (sock == null) // MS throws a NullRef
						throw new ArgumentNullException (name, "Contains a null element");
					sockets.Add (sock);
				}
			}

			sockets.Add (null);
		}

#if !TARGET_JVM
		[MethodImplAttribute(MethodImplOptions.InternalCall)]
		private extern static void Select_internal (ref Socket [] sockets,
							int microSeconds,
							out int error);
#else
		private static void Select_internal (ref Socket [] sockets, int microSeconds, out int error)
		{
			GHSocketFactory.Select_internal(ref sockets, microSeconds, out error);
		}
#endif

		public static void Select (IList checkRead, IList checkWrite, IList checkError, int microSeconds)
		{
			ArrayList list = new ArrayList ();
			AddSockets (list, checkRead, "checkRead");
			AddSockets (list, checkWrite, "checkWrite");
			AddSockets (list, checkError, "checkError");

			if (list.Count == 3) 
			{
				throw new ArgumentNullException ("checkRead, checkWrite, checkError",
					"All the lists are null or empty.");
			}

			int error;
			/*
			 * The 'sockets' array contains: READ socket 0-n, null,
			 * 				 WRITE socket 0-n, null,
			 *				 ERROR socket 0-n, null
			 */
			Socket [] sockets = (Socket []) list.ToArray (typeof (Socket));
			Select_internal (ref sockets, microSeconds, out error);

			if (error != 0)
				throw new SocketException (error);

			if (checkRead != null)
				checkRead.Clear ();

			if (checkWrite != null)
				checkWrite.Clear ();

			if (checkError != null)
				checkError.Clear ();

			if (sockets == null)
				return;

			int mode = 0;
			int count = sockets.Length;
			IList currentList = checkRead;
			for (int i = 0; i < count; i++) 
			{
				Socket sock = sockets [i];
				if (sock == null) 
				{ // separator
					currentList = (mode == 0) ? checkWrite : checkError;
					mode++;
					continue;
				}

				if (currentList != null) 
				{
					sock.connected = true;
					currentList.Add (sock);
				}
			}
		}

#if !TARGET_JVM
		static Socket() 
		{
			Assembly ass;
			
			try {
				ass = Assembly.Load (Consts.AssemblyMono_Posix);
			} catch (FileNotFoundException) {
				return;
			}
				
			unixendpointtype=ass.GetType("Mono.Posix.UnixEndPoint");

			/* The endpoint Create() method is an instance
			 * method :-(
			 */
			Type[] arg_types=new Type[1];
			arg_types[0]=typeof(string);
			ConstructorInfo cons=unixendpointtype.GetConstructor(arg_types);

			object[] args=new object[1];
			args[0]="";

			unixendpoint=cons.Invoke(args);
		}
#endif

#if !TARGET_JVM
		// private constructor used by Accept, which already
		// has a socket handle to use
		private Socket(AddressFamily family, SocketType type,
			ProtocolType proto, IntPtr sock) 
#else
		// private constructor used by Accept, which already
		// has a socket handle to use
		private Socket(AddressFamily family, SocketType type,
			ProtocolType proto, GHSocket sock) 
		{
#endif
			address_family=family;
			socket_type=type;
			protocol_type=proto;
			
			socket=sock;
			connected=true;
		}


#if !TARGET_JVM
		// Creates a new system socket, returning the handle
		[MethodImplAttribute(MethodImplOptions.InternalCall)]
		private extern IntPtr Socket_internal(AddressFamily family,
			SocketType type,
			ProtocolType proto,
			out int error);
#else
		private GHSocket Socket_internal(AddressFamily family,
			SocketType type,
			ProtocolType proto,
			out int error)
		{
			return GHSocketFactory.Socket_internal(family, type, proto, out error);
		}
#endif	

		public Socket(AddressFamily family, SocketType type,
			ProtocolType proto) 
		{
			address_family=family;
			socket_type=type;
			protocol_type=proto;
			int error;
			
			socket=Socket_internal(family, type, proto, out error);
			if (error != 0) {
				throw new SocketException (error);
			}
		}

		public AddressFamily AddressFamily 
		{
			get 
			{
				return(address_family);
			}
		}

#if !TARGET_JVM
		// Returns the amount of data waiting to be read on socket
		[MethodImplAttribute(MethodImplOptions.InternalCall)]
		private extern static int Available_internal(IntPtr socket,
			out int error);
#else
		private int Available_internal(GHSocket socket,	out int error)
		{
			return socket.Available_internal(out error);
		}
#endif

		public int Available 
		{
			get 
			{
                		EnsureStillUsable();

				int ret, error;
				
				ret = Available_internal(socket, out error);

				if (error != 0) 
				{
					throw new SocketException (error);
				}

				return(ret);
			}
		}

#if !TARGET_JVM
		[MethodImplAttribute(MethodImplOptions.InternalCall)]
		private extern static void Blocking_internal(IntPtr socket,
			bool block,
			out int error);
#else
		private void Blocking_internal(GHSocket socket,	bool block,	out int error)
		{
			socket.Blocking_internal(block, out error);
		}
#endif

		public bool Blocking 
		{
			get 
			{
                		return(blocking);
			}
			set 
			{
                		EnsureStillUsable();

                		int error;
				
				Blocking_internal(socket, value, out error);

				if (error != 0) {
					throw new SocketException (error);
				}
				
				blocking=value;
			}
		}

		public bool Connected 
		{
			get 
			{
				return(connected);
			}
		}

#if !TARGET_JVM
		public IntPtr Handle 
		{
			get 
			{
				return(socket);
			}
		}
#else
		public IntPtr Handle 
		{
			get 
			{
				throw new NotImplementedException ();
			}
		}

		internal GHSocket GHHandle 
		{
			get 
			{
				return socket;
			}
		}
#endif

#if !TARGET_JVM
		// Returns the local endpoint details in addr and port
		[MethodImplAttribute(MethodImplOptions.InternalCall)]
		private extern static SocketAddress LocalEndPoint_internal(IntPtr socket, out int error);

		[MonoTODO("Support non-IP endpoints")]
		public EndPoint LocalEndPoint 
		{
			get 
			{
				if (disposed && closed)
					throw new ObjectDisposedException (GetType ().ToString ());

				SocketAddress sa;
				int error;
				
				sa=LocalEndPoint_internal(socket, out error);

				if (error != 0) {
					throw new SocketException (error);
				}

				if(sa.Family==AddressFamily.InterNetwork || sa.Family==AddressFamily.InterNetworkV6) {
					// Stupidly, EndPoint.Create() is an
					// instance method
					return new IPEndPoint(0, 0).Create(sa);
				} else if (sa.Family==AddressFamily.Unix &&
					   unixendpoint!=null) {
					return((EndPoint)unixendpointtype.InvokeMember("Create", BindingFlags.InvokeMethod|BindingFlags.Instance|BindingFlags.Public, null, unixendpoint, new object[] {sa}));
				} else {
					throw new NotImplementedException();
				}
			}
		}
#else
		private EndPoint LocalEndPoint_internal(GHSocket socket, out int error)
		{
			return socket.LocalEndPoint_internal(out error);
		}

		public EndPoint LocalEndPoint 
		{
			get 
			{
                		EnsureStillUsable();

				int error;

				EndPoint ret = LocalEndPoint_internal(socket, out error);

				if (error != 0) 
				{
					throw new SocketException (error);
				}

				return ret;
			}
		}
#endif

			public ProtocolType ProtocolType 
		{
			get 
			{
				return(protocol_type);
			}
		}

#if !TARGET_JVM
		// Returns the remote endpoint details in addr and port
		[MethodImplAttribute(MethodImplOptions.InternalCall)]
		private extern static SocketAddress RemoteEndPoint_internal(IntPtr socket, out int error);

		[MonoTODO("Support non-IP endpoints")]
		public EndPoint RemoteEndPoint 
		{
			get 
			{
				if (disposed && closed)
					throw new ObjectDisposedException (GetType ().ToString ());

				SocketAddress sa;
				int error;
				
				sa=RemoteEndPoint_internal(socket, out error);

				if (error != 0) {
					throw new SocketException (error);
				}

				if(sa.Family==AddressFamily.InterNetwork || sa.Family==AddressFamily.InterNetworkV6 ) {
					// Stupidly, EndPoint.Create() is an
					// instance method
					return new IPEndPoint(0, 0).Create(sa);
				} else if (sa.Family==AddressFamily.Unix &&
					   unixendpoint!=null) {
					return((EndPoint)unixendpointtype.InvokeMember("Create", BindingFlags.InvokeMethod|BindingFlags.Instance|BindingFlags.Public, null, unixendpoint, new object[] {sa}));
				} else {
					throw new NotImplementedException();
				}
			}
		}
#else
		private EndPoint RemoteEndPoint_internal(GHSocket socket, out int error)
		{
			return socket.RemoteEndPoint_internal(out error);
		}

		public EndPoint RemoteEndPoint 
		{
			get 
			{
                		EnsureStillUsable();

				int error;

				EndPoint ret = RemoteEndPoint_internal(socket, out error);

				if (error != 0) 
				{
					throw new SocketException (error);
				}

				return ret;
			}
		}
#endif

		public SocketType SocketType 
		{
			get 
			{
				return(socket_type);
			}
		}

#if NET_1_1
		public static bool SupportsIPv4 
		{
			get 
			{
				CheckProtocolSupport();
				return ipv4Supported == 1;
			}
		}

		public static bool SupportsIPv6 
		{
			get 
			{
				CheckProtocolSupport();
				return ipv6Supported == 1;
			}
		}
#else
		internal static bool SupportsIPv4 
		{
			get 
			{
				return true;
			}
		}

		internal static bool SupportsIPv6 
		{
			get 
			{
				return false;
			}
		}
#endif

		internal static void CheckProtocolSupport()
		{
			if(ipv4Supported == -1) 
			{
				try  
				{
					Socket tmp = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
					tmp.Close();

					ipv4Supported = 1;
				}
				catch 
				{
					ipv4Supported = 0;
				}
			}

			if(ipv6Supported == -1) 
			{
#if NET_2_0 && CONFIGURATION_DEP
				SettingsSection config;
				config = (SettingsSection) System.Configuration.ConfigurationManager.GetSection ("system.net/settings");
				if (config != null)
					ipv6Supported = config.Ipv6.Enabled ? -1 : 0;
#else
				NetConfig config = (NetConfig)System.Configuration.ConfigurationSettings.GetConfig("system.net/settings");

				if(config != null)
					ipv6Supported = config.ipv6Enabled?-1:0;
#endif
				if(ipv6Supported != 0) 
				{
					try 
					{
						Socket tmp = new Socket(AddressFamily.InterNetworkV6, SocketType.Stream, ProtocolType.Tcp);
						tmp.Close();

						ipv6Supported = 1;
					}
					catch { }
				}
			}
		}

#if !TARGET_JVM
		// Creates a new system socket, returning the handle
		[MethodImplAttribute(MethodImplOptions.InternalCall)]
		private extern static IntPtr Accept_internal(IntPtr sock,
			out int error);
#else
		private GHSocket Accept_internal(GHSocket sock,	out int error)
		{
			return sock.Accept_internal(out error);
		}
#endif

		public Socket Accept() 
		{
            		EnsureStillUsable();

			int error = 0;
#if !TARGET_JVM
			IntPtr sock = (IntPtr) (-1);
#else
			GHSocket sock = null;
#endif
			sock = Accept_internal(socket, out error);
			if (error != 0) {
				throw new SocketException (error);
			}
			
			Socket accepted = new Socket(this.AddressFamily,
						     this.SocketType,
						     this.ProtocolType, sock);

			accepted.Blocking = this.Blocking;
			return(accepted);
		}

		public IAsyncResult BeginAccept(AsyncCallback callback,
			object state) 
		{

            		EnsureStillUsable();

			SocketAsyncResult req = new SocketAsyncResult (this, state, callback, SocketOperation.Accept);
			Worker worker = new Worker (req);
			SocketAsyncCall sac = new SocketAsyncCall (worker.Accept);
			sac.BeginInvoke (null, req);
			return(req);
		}

		public IAsyncResult BeginConnect(EndPoint end_point,
			AsyncCallback callback,
			object state) 
		{

            		EnsureStillUsable();

			if (end_point == null)
				throw new ArgumentNullException ("end_point");

			SocketAsyncResult req = new SocketAsyncResult (this, state, callback, SocketOperation.Connect);
			req.EndPoint = end_point;

			// Bug #75154: Connect() should not succeed for .Any addresses.
			if (end_point is IPEndPoint) 
			{
				IPEndPoint ep = (IPEndPoint) end_point;
				if (ep.Address.Equals (IPAddress.Any) || ep.Address.Equals (IPAddress.IPv6Any)) 
				{
					req.Complete (new SocketException (10049), true);
					return req;
				}
			}

			int error = 0;
			if (!blocking) 
			{
#if !TARGET_JVM
				SocketAddress serial = end_point.Serialize ();
				Connect_internal (socket, serial, out error);
#else
				Connect_internal (socket, end_point, out error);
#endif
				if (error == 0) 
				{
					// succeeded synch
					connected = true;
					req.Complete (true);
				} 
				else if (error != 10036 && error != 10035) 
				{
					// error synch
					connected = false;
					req.Complete (new SocketException (error), true);
				}
			}

			if (blocking || error == 10036 || error == 10035) 
			{
				// continue asynch
				connected = false;
				Worker worker = new Worker (req);
				SocketAsyncCall sac = new SocketAsyncCall (worker.Connect);
				sac.BeginInvoke (null, req);
			}

			return(req);
		}

		public IAsyncResult BeginReceive(byte[] buffer, int offset,
			int size,
			SocketFlags socket_flags,
			AsyncCallback callback,
			object state) 
		{

            		EnsureStillUsable();

			if (buffer == null)
				throw new ArgumentNullException ("buffer");

			if (offset < 0 || offset > buffer.Length)
				throw new ArgumentOutOfRangeException ("offset");

			if (size < 0 || offset + size > buffer.Length)
				throw new ArgumentOutOfRangeException ("size");

			SocketAsyncResult req;
			lock (readQ) 
			{
				req = new SocketAsyncResult (this, state, callback, SocketOperation.Receive);
				req.Buffer = buffer;
				req.Offset = offset;
				req.Size = size;
				req.SockFlags = socket_flags;
				readQ.Enqueue (req);
				if (readQ.Count == 1) 
				{
					Worker worker = new Worker (req);
					SocketAsyncCall sac = new SocketAsyncCall (worker.Receive);
					sac.BeginInvoke (null, req);
				}
			}

			return req;
		}

		public IAsyncResult BeginReceiveFrom(byte[] buffer, int offset,
			int size,
			SocketFlags socket_flags,
			ref EndPoint remote_end,
			AsyncCallback callback,
			object state) 
		{
            		EnsureStillUsable();

			if (buffer == null)
				throw new ArgumentNullException ("buffer");

			if (offset < 0)
				throw new ArgumentOutOfRangeException ("offset must be >= 0");

			if (size < 0)
				throw new ArgumentOutOfRangeException ("size must be >= 0");

			if (offset + size > buffer.Length)
				throw new ArgumentOutOfRangeException ("offset + size exceeds the buffer length");

			SocketAsyncResult req;
			lock (readQ) 
			{
				req = new SocketAsyncResult (this, state, callback, SocketOperation.ReceiveFrom);
				req.Buffer = buffer;
				req.Offset = offset;
				req.Size = size;
				req.SockFlags = socket_flags;
				req.EndPoint = remote_end;
				readQ.Enqueue (req);
				if (readQ.Count == 1) 
				{
					Worker worker = new Worker (req);
					SocketAsyncCall sac = new SocketAsyncCall (worker.ReceiveFrom);
					sac.BeginInvoke (null, req);
				}
			}
			return req;
		}

		public IAsyncResult BeginSend (byte[] buffer, int offset, int size, SocketFlags socket_flags,
			AsyncCallback callback, object state)
		{
            		EnsureStillUsable();

			if (buffer == null)
				throw new ArgumentNullException ("buffer");

			if (offset < 0)
				throw new ArgumentOutOfRangeException ("offset must be >= 0");

			if (size < 0)
				throw new ArgumentOutOfRangeException ("size must be >= 0");

			if (offset + size > buffer.Length)
				throw new ArgumentOutOfRangeException ("offset + size exceeds the buffer length");

			SocketAsyncResult req;
			lock (writeQ) 
			{
				req = new SocketAsyncResult (this, state, callback, SocketOperation.Send);
				req.Buffer = buffer;
				req.Offset = offset;
				req.Size = size;
				req.SockFlags = socket_flags;
				writeQ.Enqueue (req);
				if (writeQ.Count == 1) 
				{
					Worker worker = new Worker (req);
					SocketAsyncCall sac = new SocketAsyncCall (worker.Send);
					sac.BeginInvoke (null, req);
				}
			}
			return req;
		}

		public IAsyncResult BeginSendTo(byte[] buffer, int offset,
			int size,
			SocketFlags socket_flags,
			EndPoint remote_end,
			AsyncCallback callback,
			object state) 
		{
            		EnsureStillUsable();

			if (buffer == null)
				throw new ArgumentNullException ("buffer");

			if (offset < 0)
				throw new ArgumentOutOfRangeException ("offset must be >= 0");

			if (size < 0)
				throw new ArgumentOutOfRangeException ("size must be >= 0");

			if (offset + size > buffer.Length)
				throw new ArgumentOutOfRangeException ("offset + size exceeds the buffer length");

			SocketAsyncResult req;
			lock (writeQ) 
			{
				req = new SocketAsyncResult (this, state, callback, SocketOperation.SendTo);
				req.Buffer = buffer;
				req.Offset = offset;
				req.Size = size;
				req.SockFlags = socket_flags;
				req.EndPoint = remote_end;
				writeQ.Enqueue (req);
				if (writeQ.Count == 1) 
				{
					Worker worker = new Worker (req);
					SocketAsyncCall sac = new SocketAsyncCall (worker.SendTo);
					sac.BeginInvoke (null, req);
				}
			}
			return req;
		}

#if !TARGET_JVM
		// Creates a new system socket, returning the handle
		[MethodImplAttribute(MethodImplOptions.InternalCall)]
		private extern static void Bind_internal(IntPtr sock,
							 SocketAddress sa,
							 out int error);

		public void Bind(EndPoint local_end) 
		{
			if (disposed && closed)
				throw new ObjectDisposedException (GetType ().ToString ());

			if(local_end==null) {
				throw new ArgumentNullException("local_end");
			}
			
			int error;
			
			Bind_internal(socket, local_end.Serialize(),
				      out error);

			if (error != 0) {
				throw new SocketException (error);
			}
		}
#else
		private void Bind_internal(GHSocket sock,
			EndPoint sa,
			out int error)
		{
			sock.Bind_internal(sa, out error);
		}

		public void Bind(EndPoint local_end) 
		{
            		EnsureStillUsable();

			if(local_end==null) {
				throw new ArgumentNullException("local_end");
			}
			
			int error;
			
			Bind_internal(socket, local_end,
				      out error);

			if (error != 0) {
				throw new SocketException (error);
			}
		}
#endif

#if !TARGET_JVM
		// Closes the socket
		[MethodImplAttribute(MethodImplOptions.InternalCall)]
		private extern static void Close_internal(IntPtr socket,
							  out int error);
#else
		private void Close_internal(GHSocket socket, out int error)
		{
			socket.Close_internal(out error);
		}
#endif	

		public void Close() 
		{
			((IDisposable) this).Dispose ();
		}

#if !TARGET_JVM
		// Connects to the remote address
		[MethodImplAttribute(MethodImplOptions.InternalCall)]
		private extern static void Connect_internal(IntPtr sock,
							    SocketAddress sa,
							    out int error);
#else
		private void Connect_internal(GHSocket sock,
			EndPoint sa,
			out int error)
		{
			sock.Connect_internal(sa, out error);
		}
#endif

		public void Connect(EndPoint remote_end) 
		{
			EnsureStillUsable();

			if(remote_end==null) {
				throw new ArgumentNullException("remote_end");
			}

			if (remote_end is IPEndPoint) {
				IPEndPoint ep = (IPEndPoint) remote_end;
				if (ep.Address.Equals (IPAddress.Any) || ep.Address.Equals (IPAddress.IPv6Any))
					throw new SocketException (10049);
			}

			int error = 0;

#if !TARGET_JVM
				Connect_internal (socket, remote_end.Serialize(), out error);
#else
				Connect_internal (socket, remote_end, out error);
#endif
			if (error != 0) {
				throw new SocketException (error);
			}
			
			connected=true;
		}	
	
#if TARGET_JVM
		public void ChangeToSSL()
		{
			try
			{
				GHSocket tmp = socket.ChangeToSSL(null);
				if (tmp != null)
				{
					socket = tmp;
				}
			}
			catch (Exception e)
			{
#if DEBUG 
				Console.WriteLine("Caught exception during ChangeToSSL: {0}, {1}", e.GetType(), e.Message);
#endif
				throw new SocketException(10045);
			}
		}
#endif		
		
		public Socket EndAccept(IAsyncResult result) 
		{
            		EnsureStillUsable();

			if (result == null)
				throw new ArgumentNullException ("result");

			SocketAsyncResult req = result as SocketAsyncResult;
			if (req == null)
				throw new ArgumentException ("Invalid IAsyncResult", "result");

			if (!result.IsCompleted)
				result.AsyncWaitHandle.WaitOne();

			req.CheckIfThrowDelayedException();
			return req.Socket;
		}

		public void EndConnect(IAsyncResult result) {
            		EnsureStillUsable();

			if (result == null)
				throw new ArgumentNullException ("result");

			SocketAsyncResult req = result as SocketAsyncResult;
			if (req == null)
				throw new ArgumentException ("Invalid IAsyncResult", "result");

			if (!result.IsCompleted)
				result.AsyncWaitHandle.WaitOne();

			req.CheckIfThrowDelayedException();
		}

#if NET_2_0
		[MonoNotSupported ("")]
		public void EndDisconnect (IAsyncResult asyncResult)
		{
			throw new NotImplementedException ();
		}
#endif

		public int EndReceive(IAsyncResult result) {
            		EnsureStillUsable();

			if (result == null)
				throw new ArgumentNullException ("result");

			SocketAsyncResult req = result as SocketAsyncResult;
			if (req == null)
				throw new ArgumentException ("Invalid IAsyncResult", "result");

			if (!result.IsCompleted)
				result.AsyncWaitHandle.WaitOne();

			req.CheckIfThrowDelayedException();
			return req.Total;
		}

		public int EndReceiveFrom(IAsyncResult result,
					  ref EndPoint end_point) 
        {
            		EnsureStillUsable();

			if (result == null)
				throw new ArgumentNullException ("result");

			SocketAsyncResult req = result as SocketAsyncResult;
			if (req == null)
				throw new ArgumentException ("Invalid IAsyncResult", "result");

			if (!result.IsCompleted)
				result.AsyncWaitHandle.WaitOne();

 			req.CheckIfThrowDelayedException();
			end_point = req.EndPoint;
			return req.Total;
		}

		public int EndSend(IAsyncResult result) {
            		EnsureStillUsable();

			if (result == null)
				throw new ArgumentNullException ("result");

			SocketAsyncResult req = result as SocketAsyncResult;
			if (req == null)
				throw new ArgumentException ("Invalid IAsyncResult", "result");

			if (!result.IsCompleted)
				result.AsyncWaitHandle.WaitOne();

			req.CheckIfThrowDelayedException();
			return req.Total;
		}

		public int EndSendTo(IAsyncResult result) {
            		EnsureStillUsable();

			if (result == null)
				throw new ArgumentNullException ("result");

			SocketAsyncResult req = result as SocketAsyncResult;
			if (req == null)
				throw new ArgumentException ("Invalid IAsyncResult", "result");

			if (!result.IsCompleted)
				result.AsyncWaitHandle.WaitOne();

			req.CheckIfThrowDelayedException();
			return req.Total;
		}

#if !TARGET_JVM
		[MethodImplAttribute(MethodImplOptions.InternalCall)]
		private extern static void GetSocketOption_obj_internal(IntPtr socket, SocketOptionLevel level, SocketOptionName name, out object obj_val, out int error);
		[MethodImplAttribute(MethodImplOptions.InternalCall)]
		private extern static void GetSocketOption_arr_internal(IntPtr socket, SocketOptionLevel level, SocketOptionName name, ref byte[] byte_val, out int error);
#else
		private void GetSocketOption_obj_internal(GHSocket socket, SocketOptionLevel level, 
			SocketOptionName name, out object obj_val, out int error)
		{
            		EnsureStillUsable();

            socket.GetSocketOption_obj_internal(level, name, out obj_val, out error);
		}
		private void GetSocketOption_arr_internal(GHSocket socket, SocketOptionLevel level, 
			SocketOptionName name, ref byte[] byte_val, out int error)
		{
            		EnsureStillUsable();

            socket.GetSocketOption_arr_internal(level, name, ref byte_val, out error);
		}
#endif

		public object GetSocketOption(SocketOptionLevel level,
					      SocketOptionName name) {
			object obj_val;
			int error;
			
			GetSocketOption_obj_internal(socket, level, name,
						     out obj_val, out error);

			if (error != 0) {
				throw new SocketException (error);
			}
			
			if(name==SocketOptionName.Linger) {
				return((LingerOption)obj_val);
			} else if (name==SocketOptionName.AddMembership ||
				   name==SocketOptionName.DropMembership) {
				return((MulticastOption)obj_val);
			} else if (obj_val is int) {
				return((int)obj_val);
			} else {
				return(obj_val);
			}
		}

		public void GetSocketOption(SocketOptionLevel level,
					    SocketOptionName name,
					    byte[] opt_value) {
			int error;
			
			GetSocketOption_arr_internal(socket, level, name,
						     ref opt_value, out error);

			if (error != 0) {
				throw new SocketException (error);
			}
		}

		public byte[] GetSocketOption(SocketOptionLevel level,
					      SocketOptionName name,
					      int length) {
			byte[] byte_val=new byte[length];
			int error;
			
			GetSocketOption_arr_internal(socket, level, name,
						     ref byte_val, out error);

			if (error != 0) {
				throw new SocketException (error);
			}

			return(byte_val);
		}

#if !TARGET_JVM
		// See Socket.IOControl, WSAIoctl documentation in MSDN. The
		// common options between UNIX and Winsock are FIONREAD,
		// FIONBIO and SIOCATMARK. Anything else will depend on the
		// system.
		[MethodImplAttribute(MethodImplOptions.InternalCall)]
		extern static int WSAIoctl (IntPtr sock, int ioctl_code,
					    byte [] input, byte [] output,
					    out int error);
#else
		int WSAIoctl (GHSocket sock, int ioctl_code,
			byte [] input, byte [] output,
			out int error)
		{
			return sock.WSAIoctl(ioctl_code, input, output, out error);
		}
#endif

		public int IOControl (int ioctl_code, byte [] in_value, byte [] out_value)
		{
			if (disposed)
				throw new ObjectDisposedException (GetType ().ToString ());

			int error;
			int result = WSAIoctl (socket, ioctl_code, in_value,
					       out_value, out error);

			if (error != 0) {
				throw new SocketException (error);
			}
			
			if (result == -1)
				throw new InvalidOperationException ("Must use Blocking property instead.");

			return result;
		}

#if NET_2_0
		[MonoNotSupported ("")]
		public int IOControl (IOControlCode ioControlCode, byte [] optionInValue, byte [] optionOutValue)
		{
			throw new NotImplementedException ();
		}
#endif

#if !TARGET_JVM
		[MethodImplAttribute(MethodImplOptions.InternalCall)]
		private extern static void Listen_internal(IntPtr sock,
							   int backlog,
							   out int error);
#else
		private void Listen_internal(GHSocket sock,
			int backlog,
			out int error)
		{
            		EnsureStillUsable();

            		sock.Listen_internal(backlog, out error);
		}
#endif

		public void Listen(int backlog) 
		{
			int error;
			
			Listen_internal(socket, backlog, out error);

			if (error != 0) {
				throw new SocketException (error);
			}
		}

#if !TARGET_JVM
		[MethodImplAttribute(MethodImplOptions.InternalCall)]
		extern static bool Poll_internal (IntPtr socket, SelectMode mode, int timeout, out int error);
#else
		bool Poll_internal (GHSocket socket, SelectMode mode, int timeout, out int error)
		{
			return socket.Poll_internal(mode, timeout, this, out error);
		}
#endif

		public bool Poll(int time_us, SelectMode mode) 
		{
		        EnsureStillUsable();

            		if (mode != SelectMode.SelectRead &&
			    mode != SelectMode.SelectWrite &&
			    mode != SelectMode.SelectError)
				throw new NotSupportedException ("'mode' parameter is not valid.");

			int error;
			bool result = Poll_internal (socket, mode, time_us, out error);
			if (error != 0)
				throw new SocketException (error);
			
			if (result == true) {
				/* Update the connected state; for
				 * non-blocking Connect()s this is
				 * when we can find out that the
				 * connect succeeded.
				 */
				connected = true;
			}

			return result;
		}
		
		public int Receive (byte [] buf)
		{
            		EnsureStillUsable();

            		if (buf == null)
				throw new ArgumentNullException ("buf");

			return Receive_nochecks (buf, 0, buf.Length, SocketFlags.None);
		}

		public int Receive (byte [] buf, SocketFlags flags)
		{
            		EnsureStillUsable();

            		if (buf == null)
				throw new ArgumentNullException ("buf");

			return Receive_nochecks (buf, 0, buf.Length, flags);
		}

		public int Receive (byte [] buf, int size, SocketFlags flags)
		{
            		EnsureStillUsable();

            		if (buf == null)
				throw new ArgumentNullException ("buf");

			if (size < 0 || size > buf.Length)
				throw new ArgumentOutOfRangeException ("size");

			return Receive_nochecks (buf, 0, size, flags);
		}

#if !TARGET_JVM
		[MethodImplAttribute(MethodImplOptions.InternalCall)]
		private extern static int Receive_internal(IntPtr sock,
							   byte[] buffer,
							   int offset,
							   int count,
							   SocketFlags flags,
							   out int error);
#else
		private int Receive_internal(GHSocket sock,
			byte[] buffer,
			int offset,
			int count,
			SocketFlags flags,
			out int error)
		{
			return sock.Receive_internal(buffer, offset, count, flags, out error);
		}
#endif

		public int Receive (byte [] buf, int offset, int size, SocketFlags flags)
		{
            		EnsureStillUsable();

            		if(buf==null) 
				throw new ArgumentNullException ("buf");

			if (offset < 0 || offset > buf.Length)
				throw new ArgumentOutOfRangeException ("offset");

			if (size < 0 || offset + size > buf.Length)
				throw new ArgumentOutOfRangeException ("size");

			return Receive_nochecks (buf, offset, size, flags);
		}
			
		int Receive_nochecks (byte [] buf, int offset, int size, SocketFlags flags)
		{
			int ret, error;
			ret = Receive_internal (socket, buf, offset, size, flags, out error);

			if(error != 0) {
				if (error != 10035 && error != 10036) // WSAEWOULDBLOCK && WSAEINPROGRESS
				connected=false;

				throw new SocketException (error);
			}
			
			connected=true;

			return ret;
		}

		public int ReceiveFrom (byte [] buf, ref EndPoint remote_end)
		{
			if (buf == null)
				throw new ArgumentNullException ("buf");

			if (remote_end == null)
				throw new ArgumentNullException ("remote_end");

			return ReceiveFrom_nochecks (buf, 0, buf.Length, SocketFlags.None, ref remote_end);
		}

		public int ReceiveFrom (byte [] buf, SocketFlags flags, ref EndPoint remote_end)
		{
			if (buf == null)
				throw new ArgumentNullException ("buf");

			if (remote_end == null)
				throw new ArgumentNullException ("remote_end");


			return ReceiveFrom_nochecks (buf, 0, buf.Length, flags, ref remote_end);
		}

		public int ReceiveFrom(byte[] buf, int size, SocketFlags flags,
					ref EndPoint remote_end)
		{
			if (buf == null)
				throw new ArgumentNullException ("buf");

			if (remote_end == null)
				throw new ArgumentNullException ("remote_end");

			if (size < 0 || size > buf.Length)
				throw new ArgumentOutOfRangeException ("size");

			return ReceiveFrom_nochecks (buf, 0, size, flags, ref remote_end);
		}

#if !TARGET_JVM
		[MethodImplAttribute(MethodImplOptions.InternalCall)]
		private extern static int RecvFrom_internal(IntPtr sock,
							    byte[] buffer,
							    int offset,
							    int count,
							    SocketFlags flags,
							    ref SocketAddress sockaddr,
							    out int error);
#else
		private int RecvFrom_internal(GHSocket sock,
			byte[] buffer,
			int offset,
			int count,
			SocketFlags flags,
			ref SocketAddress sockaddr,
			out int error)
		{
			return sock.RecvFrom_internal(buffer, offset, count, flags, ref sockaddr, out error);
		}

#endif

		public int ReceiveFrom(byte[] buf, int offset, int size, SocketFlags flags,
				       ref EndPoint remote_end) 
	    	{
	        	EnsureStillUsable();

        	    	if (buf == null)
				throw new ArgumentNullException ("buf");

			if (remote_end == null)
				throw new ArgumentNullException ("remote_end");

			if (offset < 0 || offset > buf.Length)
				throw new ArgumentOutOfRangeException ("offset");

			if (size < 0 || offset + size > buf.Length)
				throw new ArgumentOutOfRangeException ("size");

			return ReceiveFrom_nochecks (buf, offset, size, flags, ref remote_end);
		}

		int ReceiveFrom_nochecks (byte [] buf, int offset, int size, SocketFlags flags,
					  ref EndPoint remote_end)
		{
		        EnsureStillUsable();

            		SocketAddress sockaddr=remote_end.Serialize();
			int cnt, error;

			cnt = RecvFrom_internal (socket, buf, offset, size, flags, ref sockaddr, out error);

			if (error != 0) {
				if (error != 10035 && error != 10036) // WSAEWOULDBLOCK && WSAEINPROGRESS
				connected=false;

				throw new SocketException (error);
			}

			connected=true;
			
			// If sockaddr is null then we're a connection
			// oriented protocol and should ignore the
			// remote_end parameter (see MSDN
			// documentation for Socket.ReceiveFrom(...) )
			
			if ( sockaddr != null ) {
			// Stupidly, EndPoint.Create() is an
			// instance method
			remote_end=remote_end.Create(sockaddr);
			}

			return cnt;
		}

		public int Send (byte [] buf)
		{
	            EnsureStillUsable();

        	    if (buf == null)
				throw new ArgumentNullException ("buf");

		    return Send_nochecks (buf, 0, buf.Length, SocketFlags.None);
		}

		public int Send (byte [] buf, SocketFlags flags)
		{
	            EnsureStillUsable();

        	    if (buf == null)
				throw new ArgumentNullException ("buf");

		    return Send_nochecks (buf, 0, buf.Length, flags);
		}

		public int Send (byte [] buf, int size, SocketFlags flags)
		{
			EnsureStillUsable();

			if (buf == null)
				throw new ArgumentNullException ("buf");

			if (size < 0 || size > buf.Length)
				throw new ArgumentOutOfRangeException ("size");

			return Send_nochecks (buf, 0, size, flags);
		}

#if NET_2_0
		[MonoNotSupported ("")]
		public int Send (byte [] buffer, int offset, int size, SocketFlags socketFlags, out SocketError errorCode)
		{
			throw new NotImplementedException ();
		}

		[MonoNotSupported ("")]
		public int Send (IList<ArraySegment<byte>> buffers)
		{
			throw new NotImplementedException ();
		}

		[MonoNotSupported ("")]
		public int Send (IList<ArraySegment<byte>> buffers, SocketFlags socketFlags)
		{
			throw new NotImplementedException ();
		}

		//[CLSCompliantAttribute (false)]
		[MonoNotSupported ("")]
		public int Send (IList<ArraySegment<byte>> buffers, SocketFlags socketFlags, out SocketError errorCode)
		{
			throw new NotImplementedException ();
		}

		[MonoNotSupported ("")]
		public int Receive (byte [] buffer, int offset, int size, SocketFlags socketFlags, out SocketError errorCode)
		{
			throw new NotImplementedException ();
		}

		[MonoNotSupported ("")]
		public int Receive (IList<ArraySegment<byte>> buffers)
		{
			throw new NotImplementedException ();
		}

		//[CLSCompliantAttribute (false)]
		[MonoNotSupported ("")]
		public int Receive (IList<ArraySegment<byte>> buffers, SocketFlags socketFlags)
		{
			throw new NotImplementedException ();
		}

		//[CLSCompliantAttribute (false)]
		[MonoNotSupported ("")]
		public int Receive (IList<ArraySegment<byte>> buffers, SocketFlags socketFlags, out SocketError errorCode)
		{
			throw new NotImplementedException ();
		}

		[MonoNotSupported ("")]
		public int ReceiveMessageFrom (byte [] buffer, int offset, int size, ref SocketFlags socketFlags, ref EndPoint remoteEP, out IPPacketInformation ipPacketInformation)
		{
			throw new NotImplementedException ();
		}

		[MonoNotSupported ("")]
		public IAsyncResult BeginReceiveMessageFrom (byte [] buffer, int offset, int size, SocketFlags socketFlags, ref EndPoint remoteEP, AsyncCallback callback, Object state)
		{
			throw new NotImplementedException ();
		}

		[MonoNotSupported ("")]
		public int EndReceiveMessageFrom (IAsyncResult asyncResult, ref SocketFlags socketFlags, ref EndPoint endPoint, out IPPacketInformation ipPacketInformation)
		{
			throw new NotImplementedException ();
		}
#endif

#if !TARGET_JVM
		[MethodImplAttribute(MethodImplOptions.InternalCall)]
		private extern static int Send_internal(IntPtr sock,
							byte[] buf, int offset,
							int count,
							SocketFlags flags,
							out int error);
#else
		private int Send_internal(GHSocket sock,
			byte[] buf, int offset,
			int count,
			SocketFlags flags,
			out int error)
		{
			return sock.Send_internal(buf, offset, count, flags, out error);
		}
#endif

		public int Send (byte[] buf, int offset, int size, SocketFlags flags)
		{
			EnsureStillUsable();

			if (buf == null)
				throw new ArgumentNullException ("buffer");

			if (offset < 0 || offset > buf.Length)
				throw new ArgumentOutOfRangeException ("offset");

			if (size < 0 || offset + size > buf.Length)
				throw new ArgumentOutOfRangeException ("size");

			return Send_nochecks (buf, offset, size, flags);
		}

		int Send_nochecks (byte [] buf, int offset, int size, SocketFlags flags)
		{
			if (size == 0)
				return 0;

			int ret, error;

			ret = Send_internal (socket, buf, offset, size, flags, out error);

			if (error != 0) {
				if (error != 10035 && error != 10036) // WSAEWOULDBLOCK && WSAEINPROGRESS
				    connected = false;

				throw new SocketException (error);
			}
			connected = true;

			return ret;
		}

		public int SendTo (byte [] buffer, EndPoint remote_end)
		{
			EnsureStillUsable();

			if (buffer == null)
				throw new ArgumentNullException ("buffer");

			if (remote_end == null)
				throw new ArgumentNullException ("remote_end");

			return SendTo_nochecks (buffer, 0, buffer.Length, SocketFlags.None, remote_end);
		}

		public int SendTo (byte [] buffer, SocketFlags flags, EndPoint remote_end)
		{
			EnsureStillUsable();

			if (buffer == null)
				throw new ArgumentNullException ("buffer");

			if (remote_end == null)
				throw new ArgumentNullException ("remote_end");
				
			return SendTo_nochecks (buffer, 0, buffer.Length, flags, remote_end);
		}

		public int SendTo (byte [] buffer, int size, SocketFlags flags, EndPoint remote_end)
		{
			EnsureStillUsable();

			if (buffer == null)
				throw new ArgumentNullException ("buffer");

			if (remote_end == null)
				throw new ArgumentNullException ("remote_end");

			if (size < 0 || size > buffer.Length)
				throw new ArgumentOutOfRangeException ("size");

			return SendTo_nochecks (buffer, 0, size, flags, remote_end);
		}

#if !TARGET_JVM
		[MethodImplAttribute(MethodImplOptions.InternalCall)]
		private extern static int SendTo_internal(IntPtr sock,
							  byte[] buffer,
							  int offset,
							  int count,
							  SocketFlags flags,
							  SocketAddress sa,
							  out int error);
#else
		private int SendTo_internal(GHSocket sock,
			byte[] buffer,
			int offset,
			int count,
			SocketFlags flags,
			SocketAddress sa,
			out int error)
		{
			return sock.SendTo_internal(buffer, offset, count, flags, sa, out error);
		}
#endif

		public int SendTo(byte[] buffer, int offset, int size, SocketFlags flags, 
		           EndPoint remote_end) 
		{
			EnsureStillUsable();

			if (buffer == null)
				throw new ArgumentNullException ("buffer");

			if (remote_end == null)
				throw new ArgumentNullException("remote_end");

			if (offset < 0 || offset > buffer.Length)
				throw new ArgumentOutOfRangeException ("offset");

			if (size < 0 || offset + size > buffer.Length)
				throw new ArgumentOutOfRangeException ("size");

			return SendTo_nochecks (buffer, offset, size, flags, remote_end);
		}

		int SendTo_nochecks (byte [] buffer, int offset, int size, SocketFlags flags,
				   EndPoint remote_end)
		{
			SocketAddress sockaddr=remote_end.Serialize();

			int ret, error;

			ret = SendTo_internal (socket, buffer, offset, size, flags, sockaddr, out error);

			if (error != 0) {
				if (error != 10035 && error != 10036) // WSAEWOULDBLOCK && WSAEINPROGRESS
				connected=false;

				throw new SocketException (error);
			}

			connected=true;

			return ret;
		}

#if !TARGET_JVM
		[MethodImplAttribute(MethodImplOptions.InternalCall)]
		private extern static void SetSocketOption_internal (IntPtr socket, SocketOptionLevel level,
								     SocketOptionName name, object obj_val,
								     byte [] byte_val, int int_val,
								     out int error);
#else
		private void SetSocketOption_internal (GHSocket socket, SocketOptionLevel level,
			SocketOptionName name, object obj_val,
			byte [] byte_val, int int_val,
			out int error)
		{
			socket.SetSocketOption_internal(level, name, obj_val, byte_val, int_val, out error);
		}
#endif

		public void SetSocketOption (SocketOptionLevel level, SocketOptionName name, byte[] opt_value)
		{
			EnsureStillUsable();

			int error;
			
			SetSocketOption_internal(socket, level, name, null,
						 opt_value, 0, out error);

			if (error != 0) {
				throw new SocketException (error);
			}
		}

		public void SetSocketOption (SocketOptionLevel level, SocketOptionName name, int opt_value)
		{
			EnsureStillUsable();

			int error;
			
			SetSocketOption_internal(socket, level, name, null,
						 null, opt_value, out error);

			if (error != 0) {
				throw new SocketException (error);
			}
		}

		public void SetSocketOption (SocketOptionLevel level, SocketOptionName name, object opt_value)
		{

			EnsureStillUsable();

			if(opt_value==null) {
				throw new ArgumentNullException();
			}
			
			int error;
			/* From MS documentation on SetSocketOption: "For an
			 * option with a Boolean data type, specify a nonzero
			 * value to enable the option, and a zero value to
			 * disable the option."
			 * Booleans are only handled in 2.0
			 */

			if (opt_value is System.Boolean) {
#if NET_2_0
				bool bool_val = (bool) opt_value;
				int int_val = (bool_val) ? 1 : 0;

				SetSocketOption_internal (socket, level, name, null, null, int_val, out error);
#else
				throw new ArgumentException ("Use an integer 1 (true) or 0 (false) instead of a boolean.", "opt_value");
#endif
			} else {
				SetSocketOption_internal (socket, level, name, opt_value, null, 0, out error);
			}

			if (error != 0)
				throw new SocketException (error);
		}

#if NET_2_0
		public void SetSocketOption (SocketOptionLevel level, SocketOptionName name, bool optionValue) {
			EnsureStillUsable();

			int error;
			int int_val = (optionValue) ? 1 : 0;
			SetSocketOption_internal (socket, level, name, null, null, int_val, out error);
			if (error != 0)
				throw new SocketException (error);
		}
#endif
#if !TARGET_JVM
		[MethodImplAttribute(MethodImplOptions.InternalCall)]
		private extern static void Shutdown_internal(IntPtr socket, SocketShutdown how, out int error);
#else
		private void Shutdown_internal(GHSocket socket, SocketShutdown how, out int error)
		{
			socket.Shutdown_internal(how, out error);
		}
#endif

		public void Shutdown(SocketShutdown how) 
		{
			EnsureStillUsable();

            		int error;
			
			Shutdown_internal(socket, how, out error);

			if (error != 0) {
				throw new SocketException (error);
			}
		}

#if !TARGET_JVM
		public override int GetHashCode ()
		{ 
			return (int) socket; 
		}
#else
		public override int GetHashCode ()
		{ 
			if (socket == null)
				return -1;

			return socket.GetHashCode(); 
		}
#endif

#if !TARGET_JVM
		protected virtual void Dispose (bool explicitDisposing)
		{
			if (disposed)
				return;

			disposed = true;
			connected = false;
			if ((int) socket != -1) 
			{
				int error;
				closed = true;
				IntPtr x = socket;
				socket = (IntPtr) (-1);
				Close_internal (x, out error);
				if (blocking_thread != null) 
				{
					blocking_thread.Abort ();
					blocking_thread = null;
				}

				if (error != 0)
					throw new SocketException (error);
			}
		}
#else
        private void EnsureStillUsable()
        {
            if (disposed && closed)
                throw new ObjectDisposedException(this.GetType().ToString());
        }
        protected virtual void Dispose (bool explicitDisposing)
		{
			if (disposed)
				return;

			disposed = true;
			connected = false;
			if (socket != null) 
			{
				int error;
				closed = true;
				GHSocket x = socket;
				socket = null;
				Close_internal (x, out error);

				if (error != 0)
					throw new SocketException (error);
			}
		}
#endif

        #region .Net 2.0 properties and methods
#if NET_2_0

            #region Properties
        [MonoTODO]
        public int ReceiveBufferSize
        {
            get { throw new NotImplementedException(); }
            set { throw new NotImplementedException(); }
        }

        [MonoTODO]
        public int SendBufferSize
        {
            get { throw new NotImplementedException(); }
            set { throw new NotImplementedException(); }
        }

        [MonoTODO]
        public bool UseOnlyOverlappedIO
        {
            get { throw new NotImplementedException(); }
            set { throw new NotImplementedException(); }
        }
        
        [MonoTODO]
        public bool NoDelay
        {
            get { throw new NotImplementedException(); }
            set { throw new NotImplementedException(); }
        }

        [MonoTODO]
        public bool IsBound
        {
            get { throw new NotImplementedException(); }
        }

        [MonoTODO]
        public bool ExclusiveAddressUse
        {
            get { throw new NotImplementedException(); }
            set { throw new NotImplementedException(); }
        }

        [MonoTODO("udp sockets are not supported")]
        public bool DontFragment 
        {
            get { throw new NotImplementedException(); }
            set { throw new NotImplementedException(); }
        }

        [MonoTODO]
        public bool EnableBroadcast
        {
            get { throw new NotImplementedException(); }
            set { throw new NotImplementedException(); }
        }

        [MonoTODO]
        public bool MulticastLoopback
        {
            get { throw new NotImplementedException(); }
            set { throw new NotImplementedException(); }
        }

        [MonoTODO]
        public short Ttl
        {
            get { throw new NotImplementedException(); }
            set { throw new NotImplementedException(); }
        }

        [MonoTODO]
        public int ReceiveTimeout
        {
            get { throw new NotImplementedException(); }
            set { throw new NotImplementedException(); }
        }

        [MonoTODO]
        public int SendTimeout
        {
            get { throw new NotImplementedException(); }
            set { throw new NotImplementedException(); }
        }
            
            #endregion //Properties

            #region Methods

        [MonoTODO]
        public IAsyncResult BeginConnect(IPAddress address, int port,
                                        AsyncCallback requestCallback,
                                        object state)
        {
            throw new NotImplementedException();
        }

        [MonoTODO]
        public IAsyncResult BeginConnect(IPAddress[] addresses, int port,
                                        AsyncCallback requestCallback,
                                        object state)
        {
            throw new NotImplementedException();
        }

        [MonoTODO]
        public IAsyncResult BeginConnect(string host, int port,
                                        AsyncCallback requestCallback,
                                        object state)
        {
            throw new NotImplementedException();
        }

        [MonoTODO]
        public IAsyncResult BeginAccept(int receiveSize, AsyncCallback callback, object state)
        {
            throw new NotImplementedException();
        }

        [MonoTODO]
        public IAsyncResult BeginAccept( Socket acceptSocket,int receiveSize,
                                        AsyncCallback callback, object state)
        {
            throw new NotImplementedException();
        }

		[MonoNotSupported ("")]
		public Socket EndAccept (out byte [] buffer, IAsyncResult asyncResult)
		{
			throw new NotImplementedException ();
		}

		[MonoNotSupported ("")]
		public Socket EndAccept (out byte [] buffer, out int bytesTransferred, IAsyncResult asyncResult)
		{
			throw new NotImplementedException ();
		}

        [MonoTODO]
        public IAsyncResult BeginDisconnect(bool reuseSocket, AsyncCallback callback, object state)
        {
            throw new NotImplementedException();
        }

		[MonoNotSupported ("")]
		public IAsyncResult BeginSend (IList<ArraySegment<byte>> buffers, SocketFlags socketFlags, AsyncCallback callback, object state)
		{
			throw new NotImplementedException ();
		}

		[MonoNotSupported ("")]
		[CLSCompliantAttribute (false)]
		public IAsyncResult BeginSend (IList<ArraySegment<byte>> buffers, SocketFlags socketFlags, 
										out SocketError errorCode, AsyncCallback callback, 
										object state)
		{
			throw new NotImplementedException ();
		}

        [MonoTODO]
        public IAsyncResult BeginSend(byte[] buffer, int offset, int size,
                                        SocketFlags socketFlags, out SocketError errorCode,
                                        AsyncCallback callback, object state)
        {
            throw new NotImplementedException();
        }

		[MonoNotSupported ("")]
		public int EndSend (IAsyncResult asyncResult, out SocketError errorCode)
		{
			throw new NotImplementedException ();
		}

		[MonoNotSupported ("")]
		public IAsyncResult BeginReceive (byte [] buffer, int offset, int size, SocketFlags socketFlags, out SocketError errorCode, AsyncCallback callback, Object state)
		{
			throw new NotImplementedException ();
		}

		[CLSCompliantAttribute (false)]
		[MonoNotSupported ("")]
		public IAsyncResult BeginReceive (IList<ArraySegment<byte>> buffers, SocketFlags socketFlags, AsyncCallback callback, Object state)
		{
			throw new NotImplementedException ();
		}

		[CLSCompliantAttribute (false)]
		[MonoNotSupported ("")]
		public IAsyncResult BeginReceive (IList<ArraySegment<byte>> buffers, SocketFlags socketFlags, out SocketError errorCode, AsyncCallback callback, Object state)
		{
			throw new NotImplementedException ();
		}

		[MonoNotSupported ("")]
		public int EndReceive (IAsyncResult asyncResult, out SocketError errorCode)
		{
			throw new NotImplementedException ();
		}

		[MonoNotSupported ("")]
		public void SendFile (string fileName)
		{
			throw new NotImplementedException ();
		}

		[MonoNotSupported ("")]
		public void SendFile (string fileName, byte [] preBuffer, byte [] postBuffer, TransmitFileOptions flags)
		{
			throw new NotImplementedException ();
		}

		[MonoNotSupported ("")]
		public IAsyncResult BeginSendFile (string fileName, AsyncCallback callback, object state)
		{
			throw new NotImplementedException ();
		}

		[MonoNotSupported ("")]
		public IAsyncResult BeginSendFile (string fileName, byte [] preBuffer, byte [] postBuffer, TransmitFileOptions flags, AsyncCallback callback, object state)
		{
			throw new NotImplementedException ();
		}

		[MonoNotSupported ("")]
		public void EndSendFile (IAsyncResult asyncResult)
		{
			throw new NotImplementedException ();
		}

        [MonoTODO]
        public void Close(int timeout)
        {
            throw new NotImplementedException();
        }

        [MonoTODO]
        public void Connect(IPAddress address, int port)
        {
            throw new NotImplementedException();
        }

        [MonoTODO]
        public void Connect(IPAddress[] address, int port)
        {
            throw new NotImplementedException();
        }

        [MonoTODO]
        public void Connect(string host, int port)
        {
            throw new NotImplementedException();
        }

		[MonoNotSupported ("")]
		public void Disconnect (bool reuseSocket)
		{
			throw new NotImplementedException ();
		}

		[MonoNotSupported ("")]
		public SocketInformation DuplicateAndClose (int targetProcessId)
		{
			throw new NotImplementedException ();
		}
			#endregion //Methods

#endif
        #endregion

        void IDisposable.Dispose ()
		{
			Dispose (true);
			GC.SuppressFinalize (this);
		}
		
		~Socket () {
			Dispose(false);
		}

	}
}