107 SocketError <SocketError>k__BackingField =
saea.<
SocketError>k__BackingField;
108 int <BytesTransferred>k__BackingField =
saea.<BytesTransferred>k__BackingField;
120 throw new global::Cpp2IlInjected.AnalysisFailedException(
"CPP2IL failed to recover any usable IL for this method.");
307 string @
string =
SR.
GetString(
"This protocol version is not supported.");
547 throw new global::Cpp2IlInjected.AnalysisFailedException(
"CPP2IL failed to recover any usable IL for this method.");
577 throw new global::Cpp2IlInjected.AnalysisFailedException(
"CPP2IL failed to recover any usable IL for this method.");
629 throw new global::Cpp2IlInjected.AnalysisFailedException(
"CPP2IL failed to recover any usable IL for this method.");
730 throw new global::Cpp2IlInjected.AnalysisFailedException(
"CPP2IL failed to recover any usable IL for this method.");
759 throw new global::Cpp2IlInjected.AnalysisFailedException(
"CPP2IL failed to recover any usable IL for this method.");
832 Socket <AcceptSocket>k__BackingField = e.<AcceptSocket>k__BackingField;
834 if (<AcceptSocket>k__BackingField !=
null)
836 if (!<AcceptSocket>k__BackingField.
is_bound)
844 return "AcceptSocket: The socket must not be bound or connected." !=
null;
856 return "You must call the Bind method before performing this operation." !=
null;
893 throw new global::Cpp2IlInjected.AnalysisFailedException(
"CPP2IL failed to recover any usable IL for this method.");
905 throw new global::Cpp2IlInjected.AnalysisFailedException(
"CPP2IL failed to recover any usable IL for this method.");
956 while (backlog != 0);
988 if (remoteEP ==
null)
1084 throw new global::Cpp2IlInjected.AnalysisFailedException(
"CPP2IL failed to recover any usable IL for this method.");
1164 if (buffer ==
null || num != 0)
1232 throw new global::Cpp2IlInjected.AnalysisFailedException(
"CPP2IL failed to recover any usable IL for this method.");
1238 throw new global::Cpp2IlInjected.AnalysisFailedException(
"CPP2IL failed to recover any usable IL for this method.");
1288 throw new global::Cpp2IlInjected.AnalysisFailedException(
"CPP2IL failed to recover any usable IL for this method.");
1300 throw new global::Cpp2IlInjected.AnalysisFailedException(
"CPP2IL failed to recover any usable IL for this method.");
1369 if (!sockares.completed)
1373 sockares.CheckIfThrowDelayedException();
1388 throw new global::Cpp2IlInjected.AnalysisFailedException(
"CPP2IL failed to recover any usable IL for this method.");
1443 while (bufferList ==
null);
1449 if (bufferList !=
null)
1455 handle = socket_async_result.
Handle;
1535 throw new global::Cpp2IlInjected.AnalysisFailedException(
"CPP2IL failed to recover any usable IL for this method.");
1547 throw new global::Cpp2IlInjected.AnalysisFailedException(
"CPP2IL failed to recover any usable IL for this method.");
1561 if (buffer ==
null || num != 0)
1598 throw new global::Cpp2IlInjected.AnalysisFailedException(
"CPP2IL failed to recover any usable IL for this method.");
1612 if (handle ==
null || handle !=
null)
1615 while (handle ==
null)
1651 while (optionValue != 0);
1680 while (optionOutValue !=
null);
1698 throw new global::Cpp2IlInjected.AnalysisFailedException(
"CPP2IL failed to recover any usable IL for this method.");
1826 while (buffer ==
null)
1871 bool isCompleted =
sem.WaitAsync().IsCompleted;
1879 Socket <AcceptSocket>k__BackingField = e.<AcceptSocket>k__BackingField;
1880 if (<AcceptSocket>k__BackingField !=
null)
1894 throw new global::Cpp2IlInjected.AnalysisFailedException(
"CPP2IL failed to recover any usable IL for this method.");
1961 throw new global::Cpp2IlInjected.AnalysisFailedException(
"CPP2IL failed to recover any usable IL for this method.");
2160 base..ctor(num != 0
L);
2205 base..ctor(num != 0
L);
2254 short token = this.
_token;
2279 if (executionContext !=
null)
2295 short token = this.
_token;
2307 short token = this.
_token;
2429 throw new global::Cpp2IlInjected.AnalysisFailedException(
"CPP2IL failed to recover any usable IL for this method.");
2435 throw new global::Cpp2IlInjected.AnalysisFailedException(
"CPP2IL failed to recover any usable IL for this method.");
2547 internal void <.cctor>b__27_0(
object state)
2596 throw new global::Cpp2IlInjected.AnalysisFailedException(
"CPP2IL failed to recover any usable IL for this method.");
2602 throw new global::Cpp2IlInjected.AnalysisFailedException(
"CPP2IL failed to recover any usable IL for this method.");
2618 throw new global::Cpp2IlInjected.AnalysisFailedException(
"CPP2IL failed to recover any usable IL for this method.");
2624 throw new global::Cpp2IlInjected.AnalysisFailedException(
"CPP2IL failed to recover any usable IL for this method.");
2668 internal void <.cctor>
b__367_0(
object s, SocketAsyncEventArgs e)
2686 internal void <.cctor>
b__367_1(
object s, SocketAsyncEventArgs e)
2704 internal void <.cctor>
b__367_2(
object s, SocketAsyncEventArgs e)
2928 public static global::System.IOAsyncCallback <>9
__295_0;
2931 public static global::System.IOAsyncCallback <>9
__297_0;
2998 this.
job.MarkDisposed();
3005 public global::System.IOSelectorJob
job;
class f__AnonymousType0<< Count > j__TPar
static string GetString(string name, params object[] args)
static void SuppressFinalize(object obj)
IOAsyncCallback(object @object, IntPtr method)
void RegisterForBlockingSyscall()
void UnRegisterForBlockingSyscall()
SocketAsyncResult socket_async_result
void SetLastOperation(SocketAsyncOperation op)
IList< ArraySegment< byte > > _bufferList
void SetBytesTransferred(int value)
void Init(Socket socket, AsyncCallback callback, object state, SocketOperation operation)
int GetResult(short token)
ValueTask SendAsyncForNetworkStream(Socket socket)
ExecutionContext _executionContext
static AwaitableSocketAsyncEventArgs()
void ThrowIncorrectTokenException()
static readonly Action< object > s_availableSentinel
override void OnCompleted(SocketAsyncEventArgs _)
void ThrowMultipleContinuationsException()
bool WrapExceptionsInIOExceptions
static readonly Action< object > s_completedSentinel
bool< WrapExceptionsInIOExceptions > k__BackingField
void ThrowException(SocketError error)
void OnCompleted(Action< object > continuation, object state, short token, ValueTaskSourceOnCompletedFlags flags)
Exception CreateException(SocketError error)
static readonly Socket.AwaitableSocketAsyncEventArgs Reserved
ValueTaskSourceStatus GetStatus(short token)
ValueTask< int > ReceiveAsync(Socket socket)
Action< object > _continuation
void InvokeContinuation(Action< object > continuation, object state, bool forceAsync)
AwaitableSocketAsyncEventArgs()
Socket.AwaitableSocketAsyncEventArgs ValueTaskReceive
Socket.Int32TaskSocketAsyncEventArgs TaskReceive
Socket.AwaitableSocketAsyncEventArgs ValueTaskSend
Socket.Int32TaskSocketAsyncEventArgs TaskSend
Socket.TaskSocketAsyncEventArgs< Socket > TaskAccept
Int32TaskSocketAsyncEventArgs()
bool _wrapExceptionsInIOExceptions
AsyncTaskMethodBuilder< TResult > _builder
TaskSocketAsyncEventArgs()
AsyncTaskMethodBuilder< TResult > GetCompletionResponsibility([Out] bool responsibleForReturningToPool)
static void Disconnect_internal(SafeSocketHandle safeHandle, bool reuse, [Out] int error)
static bool s_LoggingEnabled
static unsafe int Send_icall(IntPtr sock, byte *buffer, int count, SocketFlags flags, [Out] int error, bool blocking)
void Connect(IPAddress address, int port)
void ThrowIfBufferNull(byte[] buffer)
static global::System.IOAsyncCallback BeginReceiveCallback
int Send(IList< ArraySegment< byte > > buffers, SocketFlags socketFlags)
static global::System.IOAsyncCallback BeginAcceptCallback
static bool OSSupportsIPv6
void ReturnSocketAsyncEventArgs(Socket.TaskSocketAsyncEventArgs< Socket > saea)
int EndSendTo(IAsyncResult asyncResult)
static unsafe int Send_array_icall(IntPtr sock, Socket.WSABUF *bufarray, int count, SocketFlags flags, [Out] int error, bool blocking)
static AsyncCallback ReceiveFromAsyncCallback
static void cancel_blocking_socket_operation(Thread thread)
int EndReceive(IAsyncResult asyncResult)
ProtocolType ProtocolType
static readonly Socket.Int32TaskSocketAsyncEventArgs s_rentedInt32Sentinel
int IOControl(int ioControlCode, byte[] optionInValue, byte[] optionOutValue)
static bool s_OSSupportsIPv6
static void GetSocketOption_obj_internal(SafeSocketHandle safeHandle, SocketOptionLevel level, SocketOptionName name, [Out] object obj_val, [Out] int error)
static SocketAddress RemoteEndPoint_internal(SafeSocketHandle safeHandle, int family, [Out] int error)
static void Disconnect_icall(IntPtr sock, bool reuse, [Out] int error)
static unsafe int Receive_internal(SafeSocketHandle safeHandle, Socket.WSABUF *bufarray, int count, SocketFlags flags, [Out] int error, bool blocking)
int Send(ReadOnlySpan< byte > buffer, SocketFlags socketFlags, [Out] SocketError errorCode)
ProtocolType protocolType
void SetSocketOption(SocketOptionLevel optionLevel, SocketOptionName optionName, int optionValue, bool silent)
void Disconnect(bool reuseSocket)
static readonly Socket.TaskSocketAsyncEventArgs< Socket > s_rentedSocketSentinel
static AsyncCallback AcceptAsyncCallback
static void Bind_icall(IntPtr sock, SocketAddress sa, [Out] int error)
static global::System.IOAsyncCallback BeginDisconnectCallback
Socket EndAccept([Out] byte[] buffer, [Out] int bytesTransferred, IAsyncResult asyncResult)
int ReceiveFrom(Memory< byte > buffer, int offset, int size, SocketFlags socketFlags, EndPoint remoteEP, [Out] SocketError errorCode)
static void SetSocketOption_icall(IntPtr socket, SocketOptionLevel level, SocketOptionName name, object obj_val, byte[] byte_val, int int_val, [Out] int error)
static AsyncCallback ConnectAsyncCallback
virtual void Dispose(bool disposing)
SocketAsyncResult ValidateEndIAsyncResult(IAsyncResult ares, string methodName, string argName)
static bool OSSupportsIPv4
IAsyncResult BeginReceiveFrom(byte[] buffer, int offset, int size, SocketFlags socketFlags, EndPoint remoteEP, AsyncCallback callback, object state)
IPEndPoint RemapIPEndPoint(IPEndPoint input)
static global::System.IOAsyncCallback BeginReceiveGenericCallback
static bool Poll_internal(SafeSocketHandle safeHandle, SelectMode mode, int timeout, [Out] int error)
void EndDisconnect(IAsyncResult asyncResult)
bool SendAsync(SocketAsyncEventArgs e)
static unsafe int SendTo_icall(IntPtr sock, byte *buffer, int count, SocketFlags flags, SocketAddress sa, [Out] int error, bool blocking)
static int IOControl_icall(IntPtr sock, int ioctl_code, byte[] input, byte[] output, [Out] int error)
static void BeginSendCallback(SocketAsyncResult sockares, int sent_so_far)
static unsafe int Send_internal(SafeSocketHandle safeHandle, byte *buffer, int count, SocketFlags flags, [Out] int error, bool blocking)
static AsyncCallback SendToAsyncCallback
int Receive(byte[] buffer, int offset, int size, SocketFlags socketFlags)
static global::System.IOAsyncCallback BeginConnectCallback
static readonly Task< int > s_zeroTask
int Receive(Memory< byte > buffer, int offset, int size, SocketFlags socketFlags, [Out] SocketError errorCode)
Socket(AddressFamily addressFamily, SocketType socketType, ProtocolType protocolType)
int EndSend(IAsyncResult asyncResult)
ValueTask< int > ReceiveAsync(Memory< byte > buffer, SocketFlags socketFlags, bool fromNetworkStream, CancellationToken cancellationToken)
SafeSocketHandle m_Handle
IAsyncResult BeginSend(byte[] buffer, int offset, int size, SocketFlags socketFlags, AsyncCallback callback, object state)
int EndReceiveFrom(IAsyncResult asyncResult, EndPoint endPoint)
static void Blocking_icall(IntPtr socket, bool block, [Out] int error)
static bool BeginMConnect(SocketAsyncResult sockares)
void QueueIOSelectorJob(SemaphoreSlim sem, IntPtr handle, global::System.IOSelectorJob job)
static void Shutdown_internal(SafeSocketHandle safeHandle, SocketShutdown how, [Out] int error)
int EndReceive(IAsyncResult asyncResult, [Out] SocketError errorCode)
void ThrowIfBufferOutOfRange(byte[] buffer, int offset, int size)
int SendTo(byte[] buffer, int offset, int size, SocketFlags socketFlags, EndPoint remoteEP)
int Send(IList< ArraySegment< byte > > buffers, SocketFlags socketFlags, [Out] SocketError errorCode)
static SocketAddress RemoteEndPoint_icall(IntPtr socket, int family, [Out] int error)
static object InternalSyncObject
static bool BeginSConnect(SocketAsyncResult sockares)
void Bind(EndPoint localEP)
static void Close_icall(IntPtr socket, [Out] int error)
static void Connect_icall(IntPtr sock, SocketAddress sa, [Out] int error, bool blocking)
static unsafe int Receive_array_icall(IntPtr sock, Socket.WSABUF *bufarray, int count, SocketFlags flags, [Out] int error, bool blocking)
int Receive(IList< ArraySegment< byte > > buffers, SocketFlags socketFlags, [Out] SocketError errorCode)
static SocketAddress LocalEndPoint_internal(SafeSocketHandle safeHandle, int family, [Out] int error)
static unsafe int SendTo_internal(SafeSocketHandle safeHandle, byte *buffer, int count, SocketFlags flags, SocketAddress sa, [Out] int error, bool blocking)
static IntPtr Socket_icall(AddressFamily family, SocketType type, ProtocolType proto, [Out] int error)
Socket EndAccept(IAsyncResult asyncResult)
static bool s_Initialized
static int IOControl_internal(SafeSocketHandle safeHandle, int ioctl_code, byte[] input, byte[] output, [Out] int error)
static global::System.IOAsyncCallback BeginReceiveFromCallback
int Receive(Span< byte > buffer, SocketFlags socketFlags, [Out] SocketError errorCode)
static unsafe int Send_internal(SafeSocketHandle safeHandle, Socket.WSABUF *bufarray, int count, SocketFlags flags, [Out] int error, bool blocking)
static unsafe int Receive_icall(IntPtr sock, byte *buffer, int count, SocketFlags flags, [Out] int error, bool blocking)
void Connect(EndPoint remoteEP)
void ReturnSocketAsyncEventArgs(Socket.Int32TaskSocketAsyncEventArgs saea, bool isReceive)
int Receive(IList< ArraySegment< byte > > buffers, SocketFlags socketFlags)
static bool s_SupportsIPv6
static readonly EventHandler< SocketAsyncEventArgs > AcceptCompletedHandler
static unsafe int ReceiveFrom_internal(SafeSocketHandle safeHandle, byte *buffer, int count, SocketFlags flags, SocketAddress sockaddr, [Out] int error, bool blocking)
static unsafe int ReceiveFrom_icall(IntPtr sock, byte *buffer, int count, SocketFlags flags, SocketAddress sockaddr, [Out] int error, bool blocking)
void SetIPProtectionLevel(IPProtectionLevel level)
int Send(byte[] buffer, int offset, int size, SocketFlags socketFlags)
static void Listen_internal(SafeSocketHandle safeHandle, int backlog, [Out] int error)
static bool IsProtocolSupported_internal(global::System.Net.NetworkInformation.NetworkInterfaceComponent networkInterface)
bool ReceiveAsync(SocketAsyncEventArgs e)
void Accept(Socket acceptSocket)
int Send(byte[] buffer, int offset, int size, SocketFlags socketFlags, [Out] SocketError errorCode)
SocketAsyncOperation SocketOperationToSocketAsyncOperation(SocketOperation op)
static bool Poll_icall(IntPtr socket, SelectMode mode, int timeout, [Out] int error)
static readonly EventHandler< SocketAsyncEventArgs > ReceiveCompletedHandler
static void Blocking_internal(SafeSocketHandle safeHandle, bool block, [Out] int error)
static int Available_internal(SafeSocketHandle safeHandle, [Out] int error)
IAsyncResult BeginReceive(byte[] buffer, int offset, int size, SocketFlags socketFlags, AsyncCallback callback, object state)
Task< int > ReceiveAsyncApm(Memory< byte > buffer, SocketFlags socketFlags)
static global::System.IOAsyncCallback BeginAcceptReceiveCallback
static void Listen_icall(IntPtr sock, int backlog, [Out] int error)
static void Connect_internal(SafeSocketHandle safeHandle, SocketAddress sa, [Out] int error, bool blocking)
bool Poll(int microSeconds, SelectMode mode)
IAsyncResult BeginSend(byte[] buffer, int offset, int size, SocketFlags socketFlags, [Out] SocketError errorCode, AsyncCallback callback, object state)
static bool IsProtocolSupported(global::System.Net.NetworkInformation.NetworkInterfaceComponent networkInterface)
static AsyncCallback DisconnectAsyncCallback
ValueTask SendAsyncForNetworkStream(ReadOnlyMemory< byte > buffer, SocketFlags socketFlags, CancellationToken cancellationToken)
static void CompleteSendReceive(Socket s, Socket.Int32TaskSocketAsyncEventArgs saea, bool isReceive)
static SafeSocketHandle Accept_internal(SafeSocketHandle safeHandle, [Out] int error, bool blocking)
static SocketAddress LocalEndPoint_icall(IntPtr socket, int family, [Out] int error)
int EndSend(IAsyncResult asyncResult, [Out] SocketError errorCode)
void InternalShutdown(SocketShutdown how)
void InitSocketAsyncEventArgs(SocketAsyncEventArgs e, AsyncCallback callback, object state, SocketOperation operation)
Task< int > SendAsyncApm(ReadOnlyMemory< byte > buffer, SocketFlags socketFlags)
static bool s_SupportsIPv4
static IntPtr Accept_icall(IntPtr sock, [Out] int error, bool blocking)
static AsyncCallback SendAsyncCallback
int EndReceiveFrom_internal(SocketAsyncResult sockares, SocketAsyncEventArgs ares)
Socket(AddressFamily family, SocketType type, ProtocolType proto, SafeSocketHandle safe_handle)
IAsyncResult BeginConnect(string host, int port, AsyncCallback callback, object state)
IAsyncResult BeginReceive(byte[] buffer, int offset, int size, SocketFlags socketFlags, [Out] SocketError errorCode, AsyncCallback callback, object state)
void Shutdown(SocketShutdown how)
static unsafe int Receive_internal(SafeSocketHandle safeHandle, byte *buffer, int count, SocketFlags flags, [Out] int error, bool blocking)
AddressFamily addressFamily
void ThrowIfDisposedAndClosed()
bool AcceptAsync(SocketAsyncEventArgs e)
static void Bind_internal(SafeSocketHandle safeHandle, SocketAddress sa, [Out] int error)
static void InitializeSockets()
static void GetSocketOption_obj_icall(IntPtr socket, SocketOptionLevel level, SocketOptionName name, [Out] object obj_val, [Out] int error)
IAsyncResult BeginAccept(AsyncCallback callback, object state)
static void SetSocketOption_internal(SafeSocketHandle safeHandle, SocketOptionLevel level, SocketOptionName name, object obj_val, byte[] byte_val, int int_val, [Out] int error)
static object s_InternalSyncObject
static void CompleteAccept(Socket s, Socket.TaskSocketAsyncEventArgs< Socket > saea)
static global::System.IOAsyncCallback BeginSendGenericCallback
IAsyncResult BeginConnect(EndPoint remoteEP, AsyncCallback callback, object state)
static void Shutdown_icall(IntPtr socket, SocketShutdown how, [Out] int error)
int Receive(byte[] buffer, int offset, int size, SocketFlags socketFlags, [Out] SocketError errorCode)
static int Available_icall(IntPtr socket, [Out] int error)
int IOControl(IOControlCode ioControlCode, byte[] optionInValue, byte[] optionOutValue)
static Exception GetException(SocketError error, bool wrapExceptionsInIOExceptions=false)
static readonly EventHandler< SocketAsyncEventArgs > SendCompletedHandler
bool CanTryAddressFamily(AddressFamily family)
void SetSocketOption(SocketOptionLevel optionLevel, SocketOptionName optionName, int optionValue)
static AsyncCallback ReceiveAsyncCallback
void EndConnect(IAsyncResult asyncResult)
object GetSocketOption(SocketOptionLevel optionLevel, SocketOptionName optionName)
Socket.CachedEventArgs _cachedTaskEventArgs
void Linger(IntPtr handle)
void DangerousAddRef(bool success)
static ExecutionContext Capture()
static int Exchange(int location1, int value)
static void Exit(object obj)
static void Enter(object obj)
static SynchronizationContext Current
static TaskScheduler Current
static Task FromCanceled(CancellationToken cancellationToken)
static void ThrowArgumentNullException(ExceptionArgument argument)
static void ThrowArgumentOutOfRangeException()
TResult GetResult(short token)
ValueTaskSourceOnCompletedFlags
static CancellationToken None