271_parser = parser; 286_parser = parser;

289Debug.Assert(null != _parser._physicalStateObj, "no physical session?"); 290Debug.Assert(null != _parser._physicalStateObj._inBuff, "no in buffer?"); 291Debug.Assert(null != _parser._physicalStateObj._outBuff, "no out buffer?"); 292Debug.Assert(_parser._physicalStateObj._outBuff.Length == 293_parser._physicalStateObj._inBuff.Length, "Unexpected unequal buffers."); 296SetPacketSize(_parser._physicalStateObj._outBuff.Length); 384return _parser; 455Debug.Assert(_parser.IsKatmaiOrNewer, "NBCROW is sent by pre-Katmai server"); 564Debug.Assert(_parser.MARSOn, "Can not activate a non-MARS connection"); 576while ((!hasLock) && (_parser.State != TdsParserState.Closed) && (_parser.State != TdsParserState.Broken)) { 591while ((!hasParserLock) && (_parser.State != TdsParserState.Closed) && (_parser.State != TdsParserState.Broken)) { 593_parser.Connection._parserLock.Wait(canReleaseFromAnyThread: false, timeout: _waitForCancellationLockPollTimeout, lockTaken: ref hasParserLock); 595_parser.Connection.ThreadHasParserLockForClose = true; 601if (_parser.Connection.ThreadHasParserLockForClose) { 602_parser.Connection.ThreadHasParserLockForClose = false; 604_parser.Connection._parserLock.Release(); 656Debug.Assert(_parser.MARSOn, "Should not be calling CheckSetResetConnectionState on non MARS connection"); 664_parser._fResetConnection = false; 666_fResetEventOwned = !_parser._resetConnectionEvent.Set(); 682_fResetEventOwned = !_parser._resetConnectionEvent.Set(); 797if (_parser.MARSOn) { 809_parser.DecrementNonTransactedOpenResultCount(); 905return _parser.IncrementNonTransactedOpenResultCount(); 946_parser.ThrowExceptionAndWarning(this, callerHasConnectionLock, asyncClose); 1005if (_parser.State == TdsParserState.Broken || _parser.State == TdsParserState.Closed) { 1116this == _parser._physicalStateObj, 1120(_parser.IsYukonOrNewer && 1611if (!_parser.TrySkipPlpValue((ulong)length, this, out ignored)) { 1623_parser.ThrowUnsupportedCollationEncountered(this); 1937if (_parser.State == TdsParserState.Broken || _parser.State == TdsParserState.Closed) { 1962if (_parser.MARSOn) { // Only take reset lock on MARS and Async. 2035AddError(new SqlError(TdsEnums.TIMEOUT_EXPIRED, (byte)0x00, TdsEnums.MIN_ERROR_CLASS, _parser.Server, _parser.Connection.TimeoutErrorInternal.GetErrorMessage(), "", 0, TdsEnums.SNI_WAIT_TIMEOUT)); 2040if (_parser.Connection.IsInPool) { 2043Debug.Assert(_parser.Connection.IsConnectionDoomed, "Timeout occurred while the connection is in the pool"); 2044_parser.State = TdsParserState.Broken; 2045_parser.Connection.BreakConnection(); 2050else if (_parser.State == TdsParserState.OpenLoggedIn) { 2094_parser.State = TdsParserState.Broken; 2095_parser.Connection.BreakConnection(); 2123if (_parser.State == TdsParserState.Broken || _parser.State == TdsParserState.Closed) { 2222Debug.Assert(_parser.Connection == null || _parser.Connection.Pool != null, "Shouldn't be calling IsConnectionAlive on non-pooled connections"); 2226if ((_parser == null) || ((_parser.State == TdsParserState.Broken) || (_parser.State == TdsParserState.Closed))) { 2232else if ((_pendingCallbacks > 1) || ((_parser.Connection != null) && (!_parser.Connection.IsInPool))) { 2255AddError(_parser.ProcessSNIError(this)); 2283if ((_parser == null) || ((_parser.State == TdsParserState.Broken) || (_parser.State == TdsParserState.Closed))) { 2319Debug.Assert(_parser.Connection != null, "SqlConnectionInternalTds handler can not be null at this point."); 2320AddError(new SqlError(TdsEnums.TIMEOUT_EXPIRED, (byte)0x00, TdsEnums.MIN_ERROR_CLASS, _parser.Server, _parser.Connection.TimeoutErrorInternal.GetErrorMessage(), "", 0, TdsEnums.SNI_WAIT_TIMEOUT)); 2365if (_parser._loginWithFailover) 2368_parser.Disconnect(); 2370else if ((_parser.State == TdsParserState.OpenNotLoggedIn) && (_parser.Connection.ConnectionOptions.MultiSubnetFailover || _parser.Connection.ConnectionOptions.TransparentNetworkIPResolution)) 2373_parser.Disconnect(); 2382_parser.State = TdsParserState.Broken; // We failed subsequent read, we have to quit! 2383_parser.Connection.BreakConnection(); 2388AddError(_parser.ProcessSNIError(stateObj)); 2398if ((_parser.State == TdsParserState.Closed) || (_parser.State == TdsParserState.Broken)) { 2404AddError(_parser.ProcessSNIError(this)); 2477if (source == null && _parser._pMarsPhysicalConObj == this) { 2485if (_parser.MARSOn) { // Only take reset lock on MARS and Async. 2530else if ((_parser.State == TdsParserState.Closed) || (_parser.State == TdsParserState.Broken)) { 2545Debug.Assert(_parser.State == TdsParserState.Broken || _parser.State == TdsParserState.Closed || _parser.Connection.IsConnectionDoomed, "Failed to capture exception while the connection was still healthy"); 2550_parser.State = TdsParserState.Broken; 2551_parser.Connection.BreakConnection(); 2565AddError(_parser.ProcessSNIError(this)); 2687if ((_parser.State == TdsParserState.Closed) || (_parser.State == TdsParserState.Broken)) { 2729bool async = _parser._asyncWrite; // NOTE: We are capturing this now for the assert after the Task is returned, since WritePacket will turn off async if there is an exception 2806connectionToDoom: _parser.Connection); 2811if ((_parser.State == TdsParserState.Closed) || (_parser.State == TdsParserState.Broken)) { 2815if (_parser.IsYukonOrNewer && !_bulkCopyOpperationInProgress // ignore the condition checking for bulk copy (SQL BU 414551) 2827bool willCancel = (_cancelled) && (_parser._asyncWrite); 2855_parser.CheckResetConnection(this); // HAS SIDE EFFECTS - re-org at a later time if possible 2862task = AsyncHelper.CreateContinuationTask(task, CancelWritePacket, _parser.Connection); 2871_parser.Connection.ThreadHasParserLockForClose = true; // In case of error, let the connection know that we are holding the lock 2881_parser.Connection.ThreadHasParserLockForClose = false; 2897bool sync = !_parser._asyncWrite; 2974if (_parser.MARSOn) { // Only take reset lock on MARS. 2989AddError(_parser.ProcessSNIError(this)); 3005if (_parser.State == TdsParserState.Closed || _parser.State == TdsParserState.Broken) { 3027if ((mustTakeWriteLock) && (!_parser.Connection.ThreadHasParserLockForClose)) { 3029_parser.Connection._parserLock.Wait(canReleaseFromAnyThread: false); 3030_parser.Connection.ThreadHasParserLockForClose = true; 3034if (_parser.State == TdsParserState.Closed || _parser.State == TdsParserState.Broken) { 3039_parser._asyncWrite = false; // stop async write 3045_parser.Connection.ThreadHasParserLockForClose = false; 3046_parser.Connection._parserLock.Release(); 3081_parser.Connection.ThreadHasParserLockForClose = true; 3083Debug.Assert(_parser.Connection != null, "SqlConnectionInternalTds handler can not be null at this point."); 3084AddError(new SqlError(TdsEnums.TIMEOUT_EXPIRED, (byte)0x00, TdsEnums.MIN_ERROR_CLASS, _parser.Server, _parser.Connection.TimeoutErrorInternal.GetErrorMessage(), "", 0, TdsEnums.SNI_WAIT_TIMEOUT)); 3087_parser.ProcessPendingAck(this); 3091_parser.Connection.ThreadHasParserLockForClose = false; 3097if (_parser.State == TdsParserState.OpenNotLoggedIn && 3098_parser.EncryptionOptions == EncryptionOptions.LOGIN) { 3107_parser.RemoveEncryption(); // Remove the SSL Provider. 3108_parser.EncryptionOptions = EncryptionOptions.OFF; // Turn encryption off. 3191SqlStatistics statistics = _parser.Statistics; 3450var parser = _parser;