4 writes to _parser
System.Data (4)
fx\src\data\System\Data\SqlClient\SqlInternalConnectionTds.cs (4)
681TdsParser parser = Interlocked.Exchange(ref _parser, null); // guard against multiple concurrent dispose calls -- Delegated Transactions might cause this. 1541_parser = new TdsParser(ConnectionOptions.MARS, ConnectionOptions.Asynchronous); 1780_parser = new TdsParser(ConnectionOptions.MARS, ConnectionOptions.Asynchronous); 1829_parser = new TdsParser(ConnectionOptions.MARS, ConnectionOptions.Asynchronous);
61 references to _parser
System.Data (61)
fx\src\data\System\Data\SqlClient\SqlInternalConnectionTds.cs (61)
547return _parser.CurrentTransaction; 553return _parser._fResetConnection ? null : CurrentTransaction; 560return _parser.PendingTransaction; 596return _parser.IsYukonOrNewer; 602return _parser.IsKatmaiOrNewer; 614return _parser; 671Threading.Tasks.Task executeTask = _parser.TdsExecuteSQLBatch("use " + database, ConnectionOptions.ConnectTimeout, null, _parser._physicalStateObj, sync: true); 673_parser.Run(RunBehavior.UntilDone, null, null, null, _parser._physicalStateObj); 698TdsParser parser = _parser; 801isAlive = _parser._physicalStateObj.IsConnectionAlive(throwOnException); 853Debug.Assert(null != _parser || IsConnectionDoomed, "Deactivating a disposed connection?"); 854if (_parser != null) { 856_parser.Deactivate(IsConnectionDoomed); 873Debug.Assert(!_parser._physicalStateObj._pendingData, "Upon ResetConnection SqlInternalConnectionTds has pending data."); 881_parser.PrepareResetConnection(IsTransactionRoot && !IsNonPoolableTransactionRoot); 888Threading.Tasks.Task executeTask = _parser.TdsExecuteSQLBatch("sp_reset_connection", 30, null, _parser._physicalStateObj, sync: true); 890_parser.Run(RunBehavior.UntilDone, null, null, null, _parser._physicalStateObj); 954if (!_parser.IsYukonOrNewer) { 1032Threading.Tasks.Task executeTask = _parser.TdsExecuteSQLBatch(sqlBatch.ToString(), ConnectionOptions.ConnectTimeout, null, _parser._physicalStateObj, sync: true); 1034_parser.Run(RunBehavior.UntilDone, null, null, null, _parser._physicalStateObj); 1042_parser.CurrentTransaction = internalTransaction; 1081TdsParserStateObject stateObj = _parser._physicalStateObj; 1082TdsParser parser = _parser; 1151if (_parser.MARSOn) { 1152stateObj = _parser.GetSession(this); 1162_parser.TdsExecuteTransactionManagerRequest(null, requestType, transactionName, isoLevel, 1187byte[] dtcAddress = _parser.GetDTCAddress(ConnectionOptions.ConnectTimeout, _parser.GetSession(this)); 1193_parser.PropagateDistributedTransaction(cookie, ConnectionOptions.ConnectTimeout, _parser._physicalStateObj); 1201_parser.Run(RunBehavior.UntilDone, null, null, null, _parser._physicalStateObj); 1224bool isEncrypted = _parser.EncryptionOptions == EncryptionOptions.ON; 1237_parser._physicalStateObj.SniContext = SniContext.Snix_EnableMars; 1238_parser.EnableMars(); 1249_parser._physicalStateObj.SniContext = SniContext.Snix_AutoEnlist; 1253_parser._physicalStateObj.SniContext=SniContext.Snix_Login; 1355_parser.TdsLogin(login, requestedFeatures, _recoverySessionData, _fedAuthFeatureExtensionData); 1365if (_parser != null) { 1367_parser.Disconnect(); 1538if (_parser != null) 1539_parser.Disconnect(); 1602if (null == _parser 1603|| TdsParserState.Closed != _parser.State 1777if (_parser != null) 1778_parser.Disconnect(); 1826if (_parser != null) 1827_parser.Disconnect(); 1962_parser._physicalStateObj.SniContext = SniContext.Snix_Connect; 1964_parser.Connect(serverInfo, 1980_parser._physicalStateObj.SniContext = SniContext.Snix_Login; 2305_parser.SendFedAuthToken(fedAuthToken); 2599_parser.IsColumnEncryptionSupported = true; 2600_parser.TceVersionSupported = _tceVersionSupported; 2603_parser.EnclaveType = Encoding.Unicode.GetString(data, 2, (data.Length - 2));