1 write to _eventSink
System.Data (1)
fx\src\data\Microsoft\SqlServer\Server\sqlpipe.cs (1)
36_eventSink = new SmiEventSink_Default();
43 references to _eventSink
System.Data (43)
fx\src\data\Microsoft\SqlServer\Server\sqlpipe.cs (43)
102_smiContext.SendMessageToPipe( message, _eventSink ); 105_eventSink.ProcessMessagesAndThrow(); 108_eventSink.CleanMessages(); 113Debug.Assert(_eventSink.HasMessages == false, "There should be no messages left in _eventsink at the end of the Send message!"); 128using ( SmiRecordBuffer recordBuffer = _smiContext.CreateRecordBuffer(columnMetaData, _eventSink) ) { 129_eventSink.ProcessMessagesAndThrow(); // Handle any errors that are reported. 132_smiContext.SendResultsStartToPipe( recordBuffer, _eventSink ); 133_eventSink.ProcessMessagesAndThrow(); // Handle any errors that are reported. 138ValueUtilsSmi.FillCompatibleSettersFromReader(_eventSink, recordBuffer, new List<SmiExtendedMetaData>(columnMetaData), reader); 141ValueUtilsSmi.FillCompatibleITypedSettersFromReader(_eventSink, recordBuffer, columnMetaData, reader); 144_smiContext.SendResultsRowToPipe( recordBuffer, _eventSink ); 145_eventSink.ProcessMessagesAndThrow(); // Handle any errors that are reported. 149_smiContext.SendResultsEndToPipe( recordBuffer, _eventSink ); 150_eventSink.ProcessMessagesAndThrow(); // Handle any errors that are reported. 158_eventSink.CleanMessages(); 163Debug.Assert(_eventSink.HasMessages == false, "There should be no messages left in _eventsink at the end of the Send reader!"); 181recordBuffer = _smiContext.CreateRecordBuffer(columnMetaData, _eventSink); 183ValueUtilsSmi.FillCompatibleSettersFromRecord(_eventSink, recordBuffer, columnMetaData, record, null /* no default values */); 186ValueUtilsSmi.FillCompatibleITypedSettersFromRecord(_eventSink, recordBuffer, columnMetaData, record); 190_smiContext.SendResultsStartToPipe( recordBuffer, _eventSink ); 191_eventSink.ProcessMessagesAndThrow(); // Handle any errors that are reported. 195_smiContext.SendResultsRowToPipe( recordBuffer, _eventSink ); 196_eventSink.ProcessMessagesAndThrow(); // Handle any errors that are reported. 199_smiContext.SendResultsEndToPipe( recordBuffer, _eventSink ); 200_eventSink.ProcessMessagesAndThrow(); // Handle any errors that are reported. 208_eventSink.CleanMessages(); 213Debug.Assert(_eventSink.HasMessages == false, "There should be no messages left in _eventsink at the end of the Send record!"); 228recordBuffer = _smiContext.CreateRecordBuffer(record.InternalGetSmiMetaData(), _eventSink); // Only MetaData needed for sending start 230_smiContext.SendResultsStartToPipe( recordBuffer, _eventSink ); 233_eventSink.ProcessMessagesAndThrow(); 240_eventSink.CleanMessages(); 245Debug.Assert(_eventSink.HasMessages == false, "There should be no messages left in _eventsink at the end of the SendResultsStart!"); 268recordBuffer = _smiContext.CreateRecordBuffer(columnMetaData, _eventSink); 270ValueUtilsSmi.FillCompatibleSettersFromRecord(_eventSink, recordBuffer, columnMetaData, record, null /* no default values */); 273ValueUtilsSmi.FillCompatibleITypedSettersFromRecord(_eventSink, recordBuffer, columnMetaData, record); 276_smiContext.SendResultsRowToPipe( recordBuffer, _eventSink ); 279_eventSink.ProcessMessagesAndThrow(); 285_eventSink.CleanMessages(); 290Debug.Assert(_eventSink.HasMessages == false, "There should be no messages left in _eventsink at the end of the SendResultsRow!"); 299_smiContext.SendResultsEndToPipe( _recordBufferSent, _eventSink ); 307_eventSink.ProcessMessagesAndThrow(); 310_eventSink.CleanMessages(); 315Debug.Assert(_eventSink.HasMessages == false, "There should be no messages left in _eventsink at the end of the SendResultsEnd!");