118_sharedState._dataReady = false; 207if (-1 == _sharedState._columnDataBytesRemaining) { 208_sharedState._columnDataBytesRemaining = (long)_parser.PlpBytesLeft(_stateObj); 211return _sharedState._columnDataBytesRemaining; 718if (0 == _sharedState._nextColumnHeaderToRead) { 732if (!_stateObj.Parser.TrySkipRow(_metaData, _sharedState._nextColumnHeaderToRead, _stateObj)) { 747_sharedState._dataReady = false; 768Debug.Assert(!_sharedState._dataReady, "_dataReady should be cleared"); 908_sharedState._dataReady = true; // set _sharedState._dataReady to not confuse CleanPartialRead 911if (_sharedState._dataReady) { 1566if (_sharedState._nextColumnHeaderToRead <= i) { 1578if ((-1 == _sharedState._columnDataBytesRemaining) && (_metaData[i].metaType.IsPlp)) { 1583_sharedState._columnDataBytesRemaining = (long)left; 1586if (0 == _sharedState._columnDataBytesRemaining) { 1596remaining = _sharedState._columnDataBytesRemaining; 1611if ((cb > _sharedState._columnDataBytesRemaining) && !_metaData[i].metaType.IsPlp) { 1640_sharedState._columnDataBytesRemaining -= cb; 1789Debug.Assert(_sharedState._nextColumnHeaderToRead == i + 1 && _sharedState._nextColumnDataToRead == i, "Non sequential access"); 1807if ((_sharedState._columnDataBytesRemaining == 0) || (length == 0)) { 1825_sharedState._columnDataBytesRemaining = -1; 1828_sharedState._columnDataBytesRemaining = (long)left; 1833int bytesToRead = (int)Math.Min((long)length, _sharedState._columnDataBytesRemaining); 1836_sharedState._columnDataBytesRemaining -= bytesRead; 2012if ((_sharedState._nextColumnDataToRead == (i+1)) && (_sharedState._nextColumnHeaderToRead == (i+1)) && (_columnDataChars != null) && (IsCommandBehavior(CommandBehavior.SequentialAccess)) && (dataIndex < _columnDataCharsRead)) { 2108if (_sharedState._nextColumnHeaderToRead <= i) { 2131if (-1 == _sharedState._columnDataBytesRemaining) { 2132_sharedState._columnDataBytesRemaining = (long)_parser.PlpBytesLeft(_stateObj); 2135if (0 == _sharedState._columnDataBytesRemaining) { 2172_sharedState._columnDataBytesRemaining = (long)_parser.PlpBytesLeft(_stateObj); 2824if (_sharedState._dataReady) { 2918if ((IsCommandBehavior(CommandBehavior.SequentialAccess)) && ((_sharedState._nextColumnHeaderToRead > i + 1) || (_lastColumnWithDataChunkRead > i))) { 3154if (_sharedState._dataReady) { 3164_sharedState._nextColumnHeaderToRead = 0; 3165_sharedState._nextColumnDataToRead = 0; 3166_sharedState._columnDataBytesRemaining = -1; // unknown 3180if (!_parser.TryRun(RunBehavior.ReturnImmediately, _command, this, null, _stateObj, out _sharedState._dataReady)) { 3184if (_sharedState._dataReady) { 3192_sharedState._dataReady = true; 3196if (_sharedState._dataReady) { 3222while (_stateObj._pendingData && !_sharedState._dataReady) { 3223if (!_parser.TryRun(RunBehavior.ReturnImmediately, _command, this, null, _stateObj, out _sharedState._dataReady)) { 3229if (_sharedState._dataReady) { 3239_sharedState._nextColumnHeaderToRead = 0; 3329Debug.Assert(_sharedState._nextColumnHeaderToRead <= _metaData.Length, "_sharedState._nextColumnHeaderToRead too large"); 3330Debug.Assert(_sharedState._nextColumnDataToRead <= _metaData.Length, "_sharedState._nextColumnDataToRead too large"); 3376if (!_data[_sharedState._nextColumnDataToRead].IsNull) { 3377_SqlMetaData columnMetaData = _metaData[_sharedState._nextColumnDataToRead]; 3379if (!_parser.TryReadSqlValue(_data[_sharedState._nextColumnDataToRead], columnMetaData, (int)_sharedState._columnDataBytesRemaining, _stateObj, 3384_sharedState._columnDataBytesRemaining = 0; 3386_sharedState._nextColumnDataToRead++; 3397if (!_sharedState._dataReady) { 3444if (i < _sharedState._nextColumnHeaderToRead) { 3446if ((i == _sharedState._nextColumnDataToRead) && (!readHeaderOnly)) { 3452Debug.Assert(i == _sharedState._nextColumnDataToRead || // Either we haven't read the column yet 3453((i + 1 < _sharedState._nextColumnDataToRead) && (IsCommandBehavior(CommandBehavior.SequentialAccess))) || // Or we're in sequential mode and we've read way past the column (i.e. it was not the last column we read) 3468if (0 < _sharedState._nextColumnDataToRead) { 3469_data[_sharedState._nextColumnDataToRead - 1].Clear(); 3477else if (_sharedState._nextColumnDataToRead < _sharedState._nextColumnHeaderToRead) { 3482Debug.Assert(_sharedState._nextColumnDataToRead == _sharedState._nextColumnHeaderToRead); 3491_SqlMetaData columnMetaData = _metaData[_sharedState._nextColumnHeaderToRead]; 3493if ((isSequentialAccess) && (_sharedState._nextColumnHeaderToRead < i)) { 3496if (!_parser.TrySkipValue(columnMetaData, _sharedState._nextColumnHeaderToRead, _stateObj)) { 3500_sharedState._nextColumnDataToRead = _sharedState._nextColumnHeaderToRead; 3501_sharedState._nextColumnHeaderToRead++; 3506if (!_parser.TryProcessColumnHeader(columnMetaData, _stateObj, _sharedState._nextColumnHeaderToRead, out isNull, out dataLength)) { 3510_sharedState._nextColumnDataToRead = _sharedState._nextColumnHeaderToRead; 3511_sharedState._nextColumnHeaderToRead++; // We read this one 3515TdsParser.GetNullSqlValue(_data[_sharedState._nextColumnDataToRead], 3521_sharedState._nextColumnDataToRead++; 3525if ((i > _sharedState._nextColumnDataToRead) || (!readHeaderOnly)) { 3529if (!_parser.TryReadSqlValue(_data[_sharedState._nextColumnDataToRead], columnMetaData, (int)dataLength, _stateObj, 3534_sharedState._nextColumnDataToRead++; 3537_sharedState._columnDataBytesRemaining = (long)dataLength; 3548} while (_sharedState._nextColumnHeaderToRead <= i); 3557if ((_lastColumnWithDataChunkRead == _sharedState._nextColumnDataToRead) && (_metaData[_lastColumnWithDataChunkRead].metaType.IsPlp)) { 3568if ((targetColumn >= _sharedState._nextColumnDataToRead) && (_sharedState._nextColumnDataToRead < _sharedState._nextColumnHeaderToRead)) { 3569if (_sharedState._columnDataBytesRemaining > bytesRemaining) { 3577bytesRemaining = checked(bytesRemaining - (int)_sharedState._columnDataBytesRemaining); 3582int currentColumn = _sharedState._nextColumnHeaderToRead; 3630Debug.Assert(_sharedState._nextColumnHeaderToRead <= _metaData.Length, "_sharedState._nextColumnHeaderToRead too large"); 3633if (_sharedState._nextColumnDataToRead < _sharedState._nextColumnHeaderToRead) { 3634if ((_sharedState._nextColumnHeaderToRead > 0) && (_metaData[_sharedState._nextColumnHeaderToRead - 1].metaType.IsPlp)) { 3647else if (0 < _sharedState._columnDataBytesRemaining) { 3648if (!_stateObj.TrySkipLongBytes(_sharedState._columnDataBytesRemaining)) { 3659_sharedState._columnDataBytesRemaining = 0; 3872Debug.Assert(!_sharedState._dataReady || _metaData != null, "Data is ready, but there is no metadata?"); 3873if ((!_sharedState._dataReady) || (_metaData == null)) { 3885Debug.Assert(!_sharedState._dataReady || _metaData != null, "Data is ready, but there is no metadata?"); 3886if ((!_sharedState._dataReady) || (_metaData == null)) { 3893((_sharedState._nextColumnHeaderToRead > columnIndex + 1) || (_lastColumnWithDataChunkRead > columnIndex))) { // Read past column 3894throw ADP.NonSequentialColumnAccess(columnIndex, Math.Max(_sharedState._nextColumnHeaderToRead - 1, _lastColumnWithDataChunkRead)); 3905Debug.Assert(!_sharedState._dataReady || _metaData != null, "Data is ready, but there is no metadata?"); 3906if ((!_sharedState._dataReady) || (_metaData == null)) { 3913((_sharedState._nextColumnDataToRead > columnIndex) || (_lastColumnWithDataChunkRead > columnIndex) || // Read past column 3916throw ADP.NonSequentialColumnAccess(columnIndex, Math.Max(_sharedState._nextColumnDataToRead, _lastColumnWithDataChunkRead + 1)); 3922Debug.Assert(!_sharedState._dataReady || _metaData != null, "Data is ready, but there is no metadata?"); 3925Debug.Assert(!requireData || _sharedState._dataReady, "No data is ready to be read"); 3928Debug.Assert((!enforceSequentialAccess) || (!IsCommandBehavior(CommandBehavior.SequentialAccess)) || ((_sharedState._nextColumnDataToRead <= columnIndex) && (_lastColumnWithDataChunkRead <= columnIndex)), "Already read past column"); 4018Debug.Assert(_sharedState._nextColumnDataToRead <= _lastColumnWithDataChunkRead, "Non sequential access"); 4019if ((_sharedState._nextColumnHeaderToRead <= _lastColumnWithDataChunkRead) || (_sharedState._nextColumnDataToRead < _lastColumnWithDataChunkRead)) { 4212if ((!_haltRead) && ((!_sharedState._dataReady) || (WillHaveEnoughData(_metaData.Length - 1)))) { 4218if (_sharedState._dataReady) { 4337if ((_sharedState._nextColumnHeaderToRead > i) && (!cancellationToken.IsCancellationRequested) && (_currentTask == null)) { 4432if ((!IsCommandBehavior(CommandBehavior.SequentialAccess)) && (_sharedState._nextColumnDataToRead > i) && (!cancellationToken.IsCancellationRequested) && (_currentTask == null)) { 4683_dataReady = _sharedState._dataReady, 4689_nextColumnDataToRead = _sharedState._nextColumnDataToRead, 4690_nextColumnHeaderToRead = _sharedState._nextColumnHeaderToRead, 4692_columnDataBytesRemaining = _sharedState._columnDataBytesRemaining, 4755_sharedState._dataReady = _snapshot._dataReady; 4761_sharedState._nextColumnDataToRead = _snapshot._nextColumnDataToRead; 4762_sharedState._nextColumnHeaderToRead = _snapshot._nextColumnHeaderToRead; 4764_sharedState._columnDataBytesRemaining = _snapshot._columnDataBytesRemaining;

370_readerState = reader._sharedState;