added select support (close #31)

std/hl/_std/sys/net/Socket.hx

@@ -116,7 +116,7 @@ class Socket {
 	public function new() : Void {
 		init();
 	}
-	
+
 	function init() : Void {
 		__s = socket_new(false);
 		input = new SocketInput(this);
@@ -203,8 +203,51 @@ class Socket {
 		if( !socket_set_fast_send(__s,b) ) throw new Sys.SysError("setFastSend() failure");
 	}
 
-	public static function select(read : Array<Socket>, write : Array<Socket>, others : Array<Socket>, ?timeout : Float) : {read: Array<Socket>,write: Array<Socket>,others: Array<Socket>} {
-		throw new Sys.SysError("Not implemented");
+	// TODO : use TLS when multithread added
+	static var tmp : hl.Bytes = null;
+	static var curTmpSize = 0;
+
+	static function makeArray( a : Array<Socket> ) : hl.NativeArray<SocketHandle> {
+		if( a == null ) return null;
+		var arr = new hl.NativeArray(a.length);
+		for( i in 0...a.length )
+			arr[i] = a[i].__s;
+		return arr;
+	}
+
+	static function outArray( a : hl.NativeArray<SocketHandle>, original : Array<Socket> ) : Array<Socket> {
+		var out = [];
+		if( a == null ) return out;
+		var i = 0, p = 0;
+		var max = original.length;
+		while( i < max ) {
+			var sh = a[i++];
+			if( sh == null ) break;
+			while( original[p].__s != sh ) p++;
+			out.push(original[p++]);
+		}
+		return out;
+	}
+
+	public static function select(read : Array<Socket>, write : Array<Socket>, others : Array<Socket>, ?timeout : Float) : {read: Array<Socket>, write: Array<Socket>, others: Array<Socket>} {
+		var sread = makeArray(read);
+		var swrite = makeArray(write);
+		var sothers = makeArray(others);
+		var tmpSize = 0;
+		if( sread != null ) tmpSize += socket_fd_size(sread.length);
+		if( swrite != null ) tmpSize += socket_fd_size(swrite.length);
+		if( sothers != null ) tmpSize += socket_fd_size(sothers.length);
+		if( tmpSize > curTmpSize ) {
+			tmp = new hl.Bytes(tmpSize);
+			curTmpSize = tmpSize;
+		}
+		if( !socket_select(sread, swrite, sothers, tmp, curTmpSize, timeout == null ? -1 : timeout) )
+			throw "Error while waiting on socket";
+		return {
+			read : outArray(sread,read),
+			write : outArray(swrite,write),
+			others : outArray(sothers,others),
+		};
 	}
 
 	@:hlNative("std", "socket_init") static function socket_init() : Void {}
@@ -221,4 +264,7 @@ class Socket {
 	@:hlNative("std", "socket_set_blocking") static function socket_set_blocking( s : SocketHandle, b : Bool ) : Bool { return true; }
 	@:hlNative("std", "socket_set_fast_send") static function socket_set_fast_send( s : SocketHandle, b : Bool ) : Bool { return true; }
 
+	@:hlNative("std", "socket_fd_size") static function socket_fd_size( count : Int) : Int { return 0; }
+	@:hlNative("std", "socket_select") static function socket_select( read : hl.NativeArray<SocketHandle>, write : hl.NativeArray<SocketHandle>, other : hl.NativeArray<SocketHandle>, tmpData : hl.Bytes, tmpSize : Int, timeout : Float ) : Bool { return false; }
+
 }