3 writes to _parser
System.Data (3)
fx\src\data\System\Data\SqlClient\SqlDataReader.cs (3)
415
_parser
= stateObj.Parser;
979
_parser
= null;
984
_parser
= null;
49 references to _parser
System.Data (49)
fx\src\data\System\Data\SqlClient\SqlDataReader.cs (49)
208
_sharedState._columnDataBytesRemaining = (long)
_parser
.PlpBytesLeft(_stateObj);
416
_defaultLCID =
_parser
.DefaultLCID;
880
TdsParser parser =
_parser
;
1083
var parser =
_parser
;
1119
while (
_parser
!= null && _stateObj != null && _stateObj._pendingData && !_metaDataConsumed) {
1120
if (
_parser
.State == TdsParserState.Broken ||
_parser
.State == TdsParserState.Closed) {
1125
if (
_parser
.Connection != null)
1126
_parser
.Connection.DoomThisConnection();
1130
if (!
_parser
.TryRun(RunBehavior.ReturnImmediately, _command, this, null, _stateObj, out ignored)) {
1580
if (!
_parser
.TryPlpBytesLeft(_stateObj, out left)) {
1593
remaining = (long)
_parser
.PlpBytesTotalLength(_stateObj);
1630
if (!
_parser
.TrySkipPlpValue((ulong) cb, _stateObj, out skipped)) {
1824
if (!
_parser
.TryPlpBytesLeft(_stateObj, out left)) {
2132
_sharedState._columnDataBytesRemaining = (long)
_parser
.PlpBytesLeft(_stateObj);
2143
cch = (long)
_parser
.PlpBytesTotalLength(_stateObj);
2157
cch = (long)
_parser
.SkipPlpValue((ulong)(cch), _stateObj);
2164
cch = (long)
_parser
.ReadPlpUnicodeChars(ref buffer, bufferIndex, length, _stateObj);
2168
cch = (long)
_parser
.ReadPlpAnsiChars(ref buffer, bufferIndex, length, _metaData[i], _stateObj);
2172
_sharedState._columnDataBytesRemaining = (long)
_parser
.PlpBytesLeft(_stateObj);
2747
if(null !=
_parser
) {
2807
if (
_parser
.State == TdsParserState.Broken ||
_parser
.State == TdsParserState.Closed) {
2812
if (!
_parser
.TryRun(RunBehavior.ReturnImmediately, _command, this, null, _stateObj, out ignored)) {
2823
if (null !=
_parser
) {
2882
if (
_parser
.State == TdsParserState.Broken ||
_parser
.State == TdsParserState.Closed) {
2887
if (!
_parser
.TryRun(RunBehavior.ReturnImmediately, _command, this, null, _stateObj, out ignored)) {
3001
if (null !=
_parser
) {
3013
if (null !=
_parser
) {
3026
if (!
_parser
.TryGetAltRowId(_stateObj, out altRowId)) {
3150
if (null !=
_parser
) {
3180
if (!
_parser
.TryRun(RunBehavior.ReturnImmediately, _command, this, null, _stateObj, out _sharedState._dataReady)) {
3223
if (!
_parser
.TryRun(RunBehavior.ReturnImmediately, _command, this, null, _stateObj, out _sharedState._dataReady)) {
3379
if (!
_parser
.TryReadSqlValue(_data[_sharedState._nextColumnDataToRead], columnMetaData, (int)_sharedState._columnDataBytesRemaining, _stateObj,
3496
if (!
_parser
.TrySkipValue(columnMetaData, _sharedState._nextColumnHeaderToRead, _stateObj)) {
3506
if (!
_parser
.TryProcessColumnHeader(columnMetaData, _stateObj, _sharedState._nextColumnHeaderToRead, out isNull, out dataLength)) {
3518
_parser
.Connection);
3529
if (!
_parser
.TryReadSqlValue(_data[_sharedState._nextColumnDataToRead], columnMetaData, (int)dataLength, _stateObj,
3706
if (_metaDataConsumed && null !=
_parser
) {
3713
if (!
_parser
.TryRun(RunBehavior.ReturnImmediately, _command, this, null, _stateObj, out ignored)) {
3724
if (!
_parser
.TryRun(RunBehavior.ReturnImmediately, _command, null, null, _stateObj, out ignored)) {
3770
if (
_parser
!= null) { // There is a valid case where parser is null
3787
if (!
_parser
.TryRun(RunBehavior.ReturnImmediately, null, null, null, _stateObj, out ignored)) {
3802
if (!
_parser
.TryRun(RunBehavior.ReturnImmediately, null, null, null, _stateObj, out ignored)) {
4590
if (
_parser
!= null) {
4591
_parser
.State = TdsParserState.Broken; // We failed to respond to attention, we have to quit!
4592
_parser
.Connection.BreakConnection();
4593
_parser
.ThrowExceptionAndWarning(_stateObj);