Project Name File Name Usage Source Code Link
WCFQuickSamples Program.cs new ParameterizedThreadStart(ThreadProc) Link To Source File
WCFQuickSamples Program.cs new ParameterizedThreadStart(ThreadProc) Link To Source File
WCFQuickSamples Program.cs new ParameterizedThreadStart(CallService) Link To Source File
Orders MouseClickManager.cs new ParameterizedThreadStart(ResetThread) Link To Source File
SharpDevelop Profiler.cs new ParameterizedThreadStart(Logging) Link To Source File
OCTGN FormView.cs new ParameterizedThreadStart(SetRunState) Link To Source File
DistAppLog AppLogServer.cs new ParameterizedThreadStart(InicioWebserver) Link To Source File
SIinformer WEB.cs new ParameterizedThreadStart(_OpenUrl) Link To Source File
SuperSocket IAsyncRunner.cs new ParameterizedThreadStart(ExecuteAsyncStart) Link To Source File
Schumix2 ServerListener.cs new ParameterizedThreadStart(ClientHandler) Link To Source File
Schumix2 ClientSocket.cs new ParameterizedThreadStart(ClientHandler) Link To Source File
monodevelop WebDeployService.cs new ParameterizedThreadStart (DoDeploy) Link To Source File
memocloud ThreadUtil.cs new ParameterizedThreadStart((p) => a(p as T)) Link To Source File
QuickGraph TestCaseWorkerCollection.cs new ParameterizedThreadStart(pair.Worker.Start) Link To Source File
Picasso Parallel.cs new ParameterizedThreadStart( WorkerThread ) Link To Source File
sones UDPSocketMulticast.cs new ParameterizedThreadStart(((AUDPSocketConnection)TServerLogic).DataReceived) Link To Source File
vcap-dotnet WcfHttpTunnelParallelTest.cs new ParameterizedThreadStart( delegate(object indexObject) { int index = (int)indexObject; using (TcpClient actualClient = new TcpClient()) { actualClient.Connect(IPAddress.Parse("127.0.0.1"), clientPort); using (TcpClient acceptedClient = actualServer.AcceptTcpClient()) { for (int j = 0; j < writeCount; j++) { actualClient.GetStream().Write(sentBytes, 0, 5); } // Give the packets a chance to reach their destination. Thread.Sleep(2000); byte[] localReceivedBytes = new byte[1024]; int localReceivedBytesCount = acceptedClient.GetStream().Read(localReceivedBytes, 0, 1024); receivedBytes[index] = localReceivedBytes; receivedBytesCount[index] = localReceivedBytesCount; } } } ) Link To Source File
vcap-dotnet WcfHttpTunnelParallelTest.cs new ParameterizedThreadStart( delegate(object indexObject) { int index = (int)indexObject; using (TcpClient actualClient = new TcpClient()) { actualClient.Connect(IPAddress.Parse("127.0.0.1"), clientPort); // we may not accept the same client that we connected, but the data is the same using (TcpClient acceptedClient = actualServer.AcceptTcpClient()) { byte[] localReceivedBytes; int localReceivedBytesCount; for (int j = 0; j < writeCount; j++) { actualClient.GetStream().Write(sentBytes, 0, 5); } // Give the packets a chance to reach their destination. Thread.Sleep(1000); localReceivedBytes = new byte[1024]; localReceivedBytesCount = acceptedClient.GetStream().Read(localReceivedBytes, 0, 1024); receivedBytesFrom[index] = localReceivedBytes; receivedBytesCountFrom[index] = localReceivedBytesCount; for (int j = 0; j < writeCount; j++) { acceptedClient.GetStream().Write(sentBytes, 0, 5); } // Give the packets a chance to reach their destination. Thread.Sleep(1000); localReceivedBytes = new byte[1024]; localReceivedBytesCount = actualClient.GetStream().Read(localReceivedBytes, 0, 1024); receivedBytesTo[index] = localReceivedBytes; receivedBytesCountTo[index] = localReceivedBytesCount; } } } ) Link To Source File
vcap-dotnet HttpTunnelTest.cs new ParameterizedThreadStart( delegate(object indexObject) { int index = (int)indexObject; using (TcpClient actualClient = new TcpClient()) { actualClient.Connect(IPAddress.Parse("127.0.0.1"), clientEndPort); using (TcpClient acceptedClient = actualServer.AcceptTcpClient()) { for (int j = 0; j < writeCount; j++) { actualClient.GetStream().Write(sentBytes, 0, 5); } // Give the packets a chance to reach their destination. Thread.Sleep(2000); byte[] localReceivedBytes = new byte[1024]; int localReceivedBytesCount = acceptedClient.GetStream().Read(localReceivedBytes, 0, 1024); receivedBytes[index] = localReceivedBytes; receivedBytesCount[index] = localReceivedBytesCount; } } } ) Link To Source File
vcap-dotnet HttpTunnelTest.cs new ParameterizedThreadStart( delegate(object indexObject) { int index = (int)indexObject; using (TcpClient actualClient = new TcpClient()) { actualClient.Connect(IPAddress.Parse("127.0.0.1"), clientEndPort); // we may not accept the same client that we connected, but the data is the same using (TcpClient acceptedClient = actualServer.AcceptTcpClient()) { byte[] localReceivedBytes; int localReceivedBytesCount; for (int j = 0; j < writeCount; j++) { actualClient.GetStream().Write(sentBytes, 0, 5); } // Give the packets a chance to reach their destination. Thread.Sleep(1000); localReceivedBytes = new byte[1024]; localReceivedBytesCount = acceptedClient.GetStream().Read(localReceivedBytes, 0, 1024); receivedBytesFrom[index] = localReceivedBytes; receivedBytesCountFrom[index] = localReceivedBytesCount; for (int j = 0; j < writeCount; j++) { acceptedClient.GetStream().Write(sentBytes, 0, 5); } // Give the packets a chance to reach their destination. Thread.Sleep(1000); localReceivedBytes = new byte[1024]; localReceivedBytesCount = actualClient.GetStream().Read(localReceivedBytes, 0, 1024); receivedBytesTo[index] = localReceivedBytes; receivedBytesCountTo[index] = localReceivedBytesCount; } } } ) Link To Source File
vcap-dotnet IISPluginTest.cs new ParameterizedThreadStart(delegate(object data) { try { IISPlugin target = plugins[(int)data]; target.ConfigureApplication(appInfos[(int)data]); target.StartApplication(); } catch (Exception ex) { Logger.Fatal(ex.ToString()); } }) Link To Source File
vcap-dotnet IISPluginTest.cs new ParameterizedThreadStart(delegate(object data) { try { IISPlugin target = plugins[(int)data]; target.StopApplication(); } catch (Exception ex) { Logger.Fatal(ex.ToString()); } }) Link To Source File
vcap-dotnet NatsClientTest.cs new ParameterizedThreadStart(delegate(object data) { natsClient.Publish((string)data); }) Link To Source File
vcap-dotnet ClientEnd.cs new System.Threading.ParameterizedThreadStart(delegate(object objConnectionId) { Guid connectionId = (Guid)objConnectionId; TcpClient client = clients[connectionId]; while (!this.closing) { byte[] buffer = new byte[DataPackage.BufferSize]; int readCount = 0; try { readCount = client.GetStream().Read(buffer, 0, buffer.Length); } catch (IOException ex) { SocketException socketException = ex.InnerException as SocketException; // the 10054 means connection reset by peer if (socketException != null && socketException.ErrorCode == 10054) { client.Close(); try { wcfTunnelChannel.CloseConnection(connectionId); } catch (CommunicationException comEx) { this.state = TunnelClientEndState.ServerUnavailable; Logger.Warning(TunnelErrorMessages.CouldNotCloseConnection, comEx.ToString()); return; } break; } else { throw; } } if (readCount == 0) { client.Close(); try { wcfTunnelChannel.CloseConnection(connectionId); } catch (CommunicationException comEx) { this.state = TunnelClientEndState.ServerUnavailable; Logger.Warning(TunnelErrorMessages.CouldNotCloseConnection, comEx.ToString()); return; } break; } byte[] sendData = new byte[readCount]; Array.Copy(buffer, sendData, readCount); DataPackage sendDataPackage = new DataPackage(); sendDataPackage.Data = sendData; sendDataPackage.HasData = true; DataPackage receiveData = null; try { receiveData = wcfTunnelChannel.SendData(connectionId, sendDataPackage); } catch (CommunicationException comEx) { this.state = TunnelClientEndState.ServerUnavailable; Logger.Warning(TunnelErrorMessages.CouldNotSendData, comEx.ToString()); return; } if (receiveData.HasData) { client.GetStream().Write(receiveData.Data, 0, receiveData.Data.Length); } Thread.Sleep(DataPackage.PollInterval); } }) Link To Source File
vcap-dotnet ClientEnd.cs new System.Threading.ParameterizedThreadStart(delegate(object objConnectionId) { Guid connectionId = (Guid)objConnectionId; TcpClient client = clients[connectionId]; while (!this.closing && client.Connected) { DataPackage data = null; try { data = wcfTunnelChannel.ReceiveData(connectionId); } catch (CommunicationException comEx) { this.state = TunnelClientEndState.ServerUnavailable; Logger.Warning(TunnelErrorMessages.CouldNotReceiveData, comEx.ToString()); return; } if (data.HasData) { if (client != null) { client.GetStream().Write(data.Data, 0, data.Data.Length); } } Thread.Sleep(DataPackage.PollInterval); } }) Link To Source File
vcap-dotnet ClientEnd.cs new System.Threading.ParameterizedThreadStart(delegate(object objConnectionId) { Guid connectionId = (Guid)objConnectionId; while (!this.closing) { byte[] buffer; IPEndPoint remoteEndPoint = new IPEndPoint(IPAddress.Any, localPort); buffer = listener.Receive(ref remoteEndPoint); DataPackage sendDataPackage = new DataPackage(); sendDataPackage.Data = buffer; sendDataPackage.HasData = true; try { wcfTunnelChannel.SendData(connectionId, sendDataPackage); } catch (CommunicationException comEx) { this.state = TunnelClientEndState.ServerUnavailable; Logger.Warning(TunnelErrorMessages.CouldNotSendData, comEx.ToString()); return; } Thread.Sleep(DataPackage.PollInterval); } }) Link To Source File
vcap-dotnet ClientEnd.cs new System.Threading.ParameterizedThreadStart(delegate(object objConnectionId) { Guid connectionId = (Guid)objConnectionId; while (!this.closing) { DataPackage data = null; try { data = wcfTunnelChannel.ReceiveData(connectionId); } catch (CommunicationException comEx) { this.state = TunnelClientEndState.ServerUnavailable; Logger.Warning(TunnelErrorMessages.CouldNotReceiveData, comEx.ToString()); return; } if (data.HasData) { if (listener != null) { listener.Send(data.Data, data.Data.Length); } } Thread.Sleep(DataPackage.PollInterval); } }) Link To Source File