Skip to content

Commit

Permalink
Updating PR based on feedback.
Browse files Browse the repository at this point in the history
* Reoved SR.Format where not needed.
* Added back a comment that was useful.
* Use '_socket' instead of the in param 'socket' once '_socket = socket'
  • Loading branch information
StephenBonikowsky committed Oct 30, 2019
1 parent 05582c4 commit de6bf4f
Showing 1 changed file with 16 additions and 13 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -73,22 +73,22 @@ public SocketConnection(Socket socket, ConnectionBufferPool connectionBufferPool
_closeState = CloseState.Open;
_readBuffer = connectionBufferPool.Take();
_asyncReadBufferSize = _readBuffer.Length;
socket.SendBufferSize = socket.ReceiveBufferSize = _asyncReadBufferSize;
_socket.SendBufferSize = _socket.ReceiveBufferSize = _asyncReadBufferSize;
_asyncSendTimeout = _asyncReceiveTimeout = TimeSpan.MaxValue;
_socketSyncSendTimeout = _socketSyncReceiveTimeout = TimeSpan.MaxValue;

_remoteEndpoint = null;

if (autoBindToCompletionPort)
{
socket.UseOnlyOverlappedIO = false;
_socket.UseOnlyOverlappedIO = false;
}

// In SMSvcHost, sockets must be duplicated to the target process. Binding a handle to a completion port
// prevents any duplicated handle from ever binding to a completion port. The target process is where we
// want to use completion ports for performance. This means that in SMSvcHost, socket.UseOnlyOverlappedIO
// must be set to true to prevent completion port use.
if (socket.UseOnlyOverlappedIO)
if (_socket.UseOnlyOverlappedIO)
{
// Init BeginRead state
if (s_onReceiveCompleted == null)
Expand Down Expand Up @@ -135,7 +135,7 @@ public IPEndPoint RemoteIPEndPoint
catch (ObjectDisposedException objectDisposedException)
{
Exception exceptionToThrow = ConvertObjectDisposedException(objectDisposedException, TransferOperation.Undefined);
if (object.ReferenceEquals(exceptionToThrow, objectDisposedException))
if (ReferenceEquals(exceptionToThrow, objectDisposedException))
{
throw;
}
Expand Down Expand Up @@ -340,6 +340,9 @@ private void CloseAsyncAndLinger()

try
{
// A FIN (shutdown) packet has already been sent to the remote host and we're waiting for the remote
// host to send a FIN back. A pending read on a socket will complete returning zero bytes when a FIN
// packet is received.
if (BeginReadCore(0, 1, _readFinTimeout, s_onWaitForFinComplete, this) == AsyncCompletionResult.Queued)
{
return;
Expand Down Expand Up @@ -505,7 +508,7 @@ public void Shutdown(TimeSpan timeout)
catch (ObjectDisposedException objectDisposedException)
{
Exception exceptionToThrow = ConvertObjectDisposedException(objectDisposedException, TransferOperation.Undefined);
if (object.ReferenceEquals(exceptionToThrow, objectDisposedException))
if (ReferenceEquals(exceptionToThrow, objectDisposedException))
{
throw;
}
Expand All @@ -522,7 +525,7 @@ private void ThrowIfNotOpen()
{
throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(
ConvertObjectDisposedException(new ObjectDisposedException(
GetType().ToString(), SR.Format(SR.SocketConnectionDisposed)), TransferOperation.Undefined));
GetType().ToString(), SR.SocketConnectionDisposed), TransferOperation.Undefined));
}
}

Expand All @@ -532,7 +535,7 @@ private void ThrowIfClosed()
{
throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(
ConvertObjectDisposedException(new ObjectDisposedException(
GetType().ToString(), SR.Format(SR.SocketConnectionDisposed)), TransferOperation.Undefined));
GetType().ToString(), SR.SocketConnectionDisposed), TransferOperation.Undefined));
}
}

Expand Down Expand Up @@ -602,7 +605,7 @@ private Exception ConvertObjectDisposedException(ObjectDisposedException origina
}
else if (_aborted)
{
return new CommunicationObjectAbortedException(SR.Format(SR.SocketConnectionDisposed), originalException);
return new CommunicationObjectAbortedException(SR.SocketConnectionDisposed, originalException);
}
else
{
Expand Down Expand Up @@ -638,7 +641,7 @@ private static Exception ConvertTransferException(SocketException socketExceptio
{
if (aborted)
{
return new CommunicationObjectAbortedException(SR.Format(SR.TcpLocalConnectionAborted), originalException);
return new CommunicationObjectAbortedException(SR.TcpLocalConnectionAborted, originalException);
}
else
{
Expand Down Expand Up @@ -729,7 +732,7 @@ public AsyncCompletionResult BeginWrite(byte[] buffer, int offset, int size, boo
catch (ObjectDisposedException objectDisposedException)
{
Exception exceptionToThrow = ConvertObjectDisposedException(objectDisposedException, TransferOperation.Write);
if (object.ReferenceEquals(exceptionToThrow, objectDisposedException))
if (ReferenceEquals(exceptionToThrow, objectDisposedException))
{
throw;
}
Expand Down Expand Up @@ -882,7 +885,7 @@ public void Write(byte[] buffer, int offset, int size, bool immediate, TimeSpan
catch (ObjectDisposedException objectDisposedException)
{
Exception exceptionToThrow = ConvertObjectDisposedException(objectDisposedException, TransferOperation.Write);
if (object.ReferenceEquals(exceptionToThrow, objectDisposedException))
if (ReferenceEquals(exceptionToThrow, objectDisposedException))
{
throw;
}
Expand Down Expand Up @@ -941,7 +944,7 @@ private int ReadCore(byte[] buffer, int offset, int size, TimeSpan timeout, bool
catch (ObjectDisposedException objectDisposedException)
{
Exception exceptionToThrow = ConvertObjectDisposedException(objectDisposedException, TransferOperation.Read);
if (object.ReferenceEquals(exceptionToThrow, objectDisposedException))
if (ReferenceEquals(exceptionToThrow, objectDisposedException))
{
throw;
}
Expand Down Expand Up @@ -1038,7 +1041,7 @@ private AsyncCompletionResult BeginReadCore(int offset, int size, TimeSpan timeo
catch (ObjectDisposedException objectDisposedException)
{
Exception exceptionToThrow = ConvertObjectDisposedException(objectDisposedException, TransferOperation.Read);
if (object.ReferenceEquals(exceptionToThrow, objectDisposedException))
if (ReferenceEquals(exceptionToThrow, objectDisposedException))
{
throw;
}
Expand Down

0 comments on commit de6bf4f

Please sign in to comment.