1 write to _pipes
Microsoft.ML.Data (1)
DataLoadSave\Binary\BinaryLoader.cs (1)
1264_pipes = new ReadPipe[parent.RowCount > 0 ? _actives.Length : 0];
17 references to _pipes
Microsoft.ML.Data (17)
DataLoadSave\Binary\BinaryLoader.cs (17)
1285if (_pipes.Length == 0) 1301int pipeBuffers = 2 * ((_parent._threads + _pipes.Length - 1) / _pipes.Length); 1303for (int c = 0; c < _pipes.Length; ++c) 1305_pipes[c] = ReadPipe.Create(this, c, pipeBuffers); 1306_pipeGetters[c] = _pipes[c].GetGetter(); 1354for (int c = 0; c < _pipes.Length; ++c) 1355anyTrue |= _pipes[c].MoveNextCleanup(); 1395int pipeIndex = (int)(seq % _pipes.Length); 1401if (!_pipes[pipeIndex].DecompressOne()) 1426for (int c = 0; c < _pipes.Length; ++c) 1427_pipes[c].PrepAndSendCompressedBlock(bi, b, rows); 1431for (int c = 0; c < _pipes.Length; ++c) 1432_pipes[c].SendSentinelBlock(b); 1977for (int c = 0; c < _pipes.Length; ++c) 1982pipeMoved = _pipes[c].MoveNext(); 2013if (!more && _pipes.Length > 0)