943Debug.Assert(null != _stateObj.Parser, "TdsParser class should not be null in Command.Execute!"); 944Debug.Assert(_stateObj.Parser == _activeConnection.Parser, "stateobject parser not same as connection parser"); 1367_stateObj.Parser.State = TdsParserState.Broken; // We failed to respond to attention, we have to quit! 1368_stateObj.Parser.Connection.BreakConnection(); 1369_stateObj.Parser.ThrowExceptionAndWarning(_stateObj); 1549bool result = _stateObj.Parser.TryRun(RunBehavior.UntilDone, this, null, null, _stateObj, out dataReady); 3110Task executeTask = _stateObj.Parser.TdsExecuteSQLBatch(this.CommandText, timeout, this.Notification, _stateObj, sync: true); 3120bool result = _stateObj.Parser.TryRun(RunBehavior.UntilDone, this, null, null, _stateObj, out dataReady); 4423writeTask = _stateObj.Parser.TdsExecuteRPC(this, _sqlRPCParameterEncryptionReqArray, timeout, inSchema, this.Notification, _stateObj, CommandType.StoredProcedure == CommandType, sync: !asyncWrite); 4434writeTask = _stateObj.Parser.TdsExecuteRPC(this, _SqlRPCBatchArray, timeout, inSchema, this.Notification, _stateObj, CommandType.StoredProcedure == CommandType, sync: !asyncWrite ); 4451writeTask = _stateObj.Parser.TdsExecuteSQLBatch(text, timeout, this.Notification, _stateObj, 4455writeTask = _stateObj.Parser.TdsExecuteSQLBatch(text, timeout, this.Notification, _stateObj, sync: !asyncWrite); 4500writeTask = _stateObj.Parser.TdsExecuteRPC(this, _rpcArrayOf1, timeout, inSchema, this.Notification, _stateObj, CommandType.StoredProcedure == CommandType, sync:!asyncWrite); 4520Task executeTask = _stateObj.Parser.TdsExecuteSQLBatch(optionSettings, timeout, this.Notification, _stateObj, sync: true); 4524bool result = _stateObj.Parser.TryRun(RunBehavior.UntilDone, this, null, null, _stateObj, out dataReady); 4535writeTask=_stateObj.Parser.TdsExecuteRPC(this, _rpcArrayOf1, timeout, inSchema, this.Notification, _stateObj, CommandType.StoredProcedure == CommandType, sync:!asyncWrite); 4699bool result = _stateObj.Parser.TryRun(RunBehavior.UntilDone, this, ds, null, _stateObj, out dataReady); 5491string paramList = BuildParamList(_stateObj.Parser, _parameters); 5645string paramList = BuildParamList(_stateObj.Parser, BatchRPCMode ? parameters : _parameters); 5967string paramList = BuildParamList(_stateObj.Parser, _parameters);

415_parser = stateObj.Parser; 719if (!_stateObj.Parser.TrySkipRow(_metaData, _stateObj)) { 732if (!_stateObj.Parser.TrySkipRow(_metaData, _sharedState._nextColumnHeaderToRead, _stateObj)) { 3637if (!_stateObj.Parser.TrySkipPlpValue(UInt64.MaxValue, _stateObj, out ignored)) {

3791if (!stateObj.Parser.TrySkipRow(stateObj._cleanupMetaData, stateObj)) { 3818if (!stateObj.Parser.TrySkipRow(metadata, sharedState._nextColumnHeaderToRead, stateObj)) { 7701Debug.Assert(this == stateObj.Parser, "different parsers"); 7849Debug.Assert(this == stateObj.Parser, "different parser");

641Parser.ProcessPendingAck(this); 693Parser.PutSession(this); 718Parser.ProcessPendingAck(this); 772TdsParserState state = Parser.State; 775Parser.DrainData(this); // This may throw - taking us to catch block. 2010Parser.State = TdsParserState.Broken; 2011Parser.Connection.BreakConnection(); 2323if (stateObj.Parser.State == TdsParserState.OpenLoggedIn) { 3076Debug.Assert(Parser.Connection._parserLock.ThreadMayHaveLock(), "Thread is writing without taking the connection lock"); 3178SqlStatistics statistics = Parser.Statistics;

63_stateObj.Parser.WriteUnsignedLong(TdsEnums.SQL_PLP_NULL, _stateObj); 96_stateObj.Parser.WriteShort(TdsEnums.VARNULL, _stateObj); 103_stateObj.Parser.WriteInt(TdsEnums.FIXEDNULL, _stateObj); 120_stateObj.Parser.WriteSqlVariantHeader(3, TdsEnums.SQLBIT, 0, _stateObj); 138_stateObj.Parser.WriteSqlVariantHeader(3, TdsEnums.SQLINT1, 0, _stateObj); 165_stateObj.Parser.WriteUnsignedLong(TdsEnums.SQL_PLP_UNKNOWNLEN, _stateObj); 170_stateObj.Parser.WriteInt(length, _stateObj); 183_stateObj.Parser.WriteSqlVariantHeader(4 + length, TdsEnums.SQLBIGVARBINARY, 2, _stateObj); 185_stateObj.Parser.WriteShort(length, _stateObj); 199_stateObj.Parser.WriteLong(0, _stateObj); 207_stateObj.Parser.WriteSqlVariantHeader(4, TdsEnums.SQLBIGVARBINARY, 2, _stateObj); 209_stateObj.Parser.WriteShort(0, _stateObj); 213_stateObj.Parser.WriteInt(TdsEnums.SQL_PLP_CHUNK_TERMINATOR, _stateObj); 234_encoder = _stateObj.Parser._defaultEncoding.GetEncoder(); 248_stateObj.Parser.WriteUnsignedLong(TdsEnums.SQL_PLP_UNKNOWNLEN, _stateObj); 253_stateObj.Parser.WriteInt(length*ADP.CharSize, _stateObj); 254_stateObj.Parser.WriteCharArray(buffer, length, bufferOffset, _stateObj); 263_stateObj.Parser.WriteSqlVariantValue(new String(buffer, bufferOffset, length), length, 0, _stateObj); 268_stateObj.Parser.WriteShort(length*ADP.CharSize, _stateObj); 269_stateObj.Parser.WriteCharArray(buffer, length, bufferOffset, _stateObj); 288_stateObj.Parser.WriteLong(0, _stateObj); 295_stateObj.Parser.WriteShort(0, _stateObj); 299_stateObj.Parser.WriteInt(TdsEnums.SQL_PLP_CHUNK_TERMINATOR, _stateObj); 320bytes = _stateObj.Parser._defaultEncoding.GetBytes(value); 324bytes = _stateObj.Parser._defaultEncoding.GetBytes(chars); 340bytes = _stateObj.Parser._defaultEncoding.GetBytes(value); 343bytes = _stateObj.Parser._defaultEncoding.GetBytes(value.ToCharArray(offset, length)); 345_stateObj.Parser.WriteSqlVariantHeader(9 + bytes.Length, TdsEnums.SQLBIGVARCHAR, 7, _stateObj); 346_stateObj.Parser.WriteUnsignedInt(collation.info, _stateObj); // propbytes: collation.Info 348_stateObj.Parser.WriteShort(bytes.Length, _stateObj); // propbyte: varlen 352_stateObj.Parser.WriteSqlVariantHeader(9 + length * ADP.CharSize, TdsEnums.SQLNVARCHAR, 7, _stateObj); 353_stateObj.Parser.WriteUnsignedInt(collation.info, _stateObj); // propbytes: collation.Info 355_stateObj.Parser.WriteShort(length * ADP.CharSize, _stateObj); // propbyte: varlen 356_stateObj.Parser.WriteString(value, length, offset, _stateObj); 362_stateObj.Parser.WriteLong(length*ADP.CharSize, _stateObj); // PLP total length 363_stateObj.Parser.WriteInt(length*ADP.CharSize, _stateObj); // Chunk length 364_stateObj.Parser.WriteString(value, length, offset, _stateObj); // Data 366_stateObj.Parser.WriteInt(TdsEnums.SQL_PLP_CHUNK_TERMINATOR, _stateObj); // Terminator 370_stateObj.Parser.WriteShort(length*ADP.CharSize, _stateObj); 371_stateObj.Parser.WriteString(value, length, offset, _stateObj); 381_stateObj.Parser.WriteSqlVariantHeader(4, TdsEnums.SQLINT2, 0, _stateObj); 386_stateObj.Parser.WriteShort(value, _stateObj); 394_stateObj.Parser.WriteSqlVariantHeader(6, TdsEnums.SQLINT4, 0, _stateObj); 399_stateObj.Parser.WriteInt(value, _stateObj); 408_stateObj.Parser.WriteSqlVariantHeader(10, TdsEnums.SQLINT8, 0, _stateObj); 409_stateObj.Parser.WriteLong(value, _stateObj); 414_stateObj.Parser.WriteSqlVariantHeader(10, TdsEnums.SQLMONEY, 0, _stateObj); 415_stateObj.Parser.WriteInt((int)(value >> 0x20), _stateObj); 416_stateObj.Parser.WriteInt((int)value, _stateObj); 423_stateObj.Parser.WriteInt((int)value, _stateObj); 426_stateObj.Parser.WriteInt((int)(value >> 0x20), _stateObj); 427_stateObj.Parser.WriteInt((int)value, _stateObj); 430_stateObj.Parser.WriteLong(value, _stateObj); 440_stateObj.Parser.WriteSqlVariantHeader(6, TdsEnums.SQLFLT4, 0, _stateObj); 445_stateObj.Parser.WriteFloat(value, _stateObj); 453_stateObj.Parser.WriteSqlVariantHeader(10, TdsEnums.SQLFLT8, 0, _stateObj); 458_stateObj.Parser.WriteDouble(value, _stateObj); 466_stateObj.Parser.WriteSqlVariantHeader(21, TdsEnums.SQLNUMERICN, 2, _stateObj); 469_stateObj.Parser.WriteSqlDecimal(value, _stateObj); 473_stateObj.Parser.WriteSqlDecimal(SqlDecimal.ConvertToPrecScale(value, _metaData.Precision, _metaData.Scale), _stateObj); 484_stateObj.Parser.WriteSqlVariantDateTime2(value, _stateObj); 488_stateObj.Parser.WriteSqlVariantDate(value, _stateObj); 493_stateObj.Parser.WriteSqlVariantHeader(10, TdsEnums.SQLDATETIME, 0, _stateObj); 494_stateObj.Parser.WriteInt(dt.days, _stateObj); 495_stateObj.Parser.WriteInt(dt.time, _stateObj); 509_stateObj.Parser.WriteShort(dt.days, _stateObj); 510_stateObj.Parser.WriteShort(dt.time, _stateObj); 513_stateObj.Parser.WriteInt(dt.days, _stateObj); 514_stateObj.Parser.WriteInt(dt.time, _stateObj); 535_stateObj.Parser.WriteSqlVariantHeader(18, TdsEnums.SQLUNIQUEID, 0, _stateObj); 554_stateObj.Parser.WriteSqlVariantHeader(8, TdsEnums.SQLTIME, 1, _stateObj); 577_stateObj.Parser.WriteSqlVariantHeader(13, TdsEnums.SQLDATETIMEOFFSET, 1, _stateObj);