25 references to Token
Microsoft.ML.Core (1)
Utilities\ThreadUtils.cs (1)
170
/// <see cref="
Token
"/> as the cancellation token (this token is canceled iff <see cref="Set"/>
Microsoft.ML.Data (24)
DataLoadSave\Binary\BinaryLoader.cs (18)
1366
Contracts.Assert(ex.CancellationToken == _exMarshaller.
Token
);
1574
_toDecompressEnumerator = _toDecompress.GetConsumingEnumerable(ExMarshaller.
Token
).GetEnumerator();
1577
_toReadEnumerator = _toRead.GetConsumingEnumerable(ExMarshaller.
Token
).GetEnumerator();
1587
_toDecompress.Add(block, ExMarshaller.
Token
);
1593
_toDecompress.Add(sentBlock, ExMarshaller.
Token
);
1610
_waiter.Wait(block.BlockSequence, ExMarshaller.
Token
);
1618
_waiter.Wait(block.BlockSequence, ExMarshaller.
Token
);
1623
_waiter.Wait(block.BlockSequence, ExMarshaller.
Token
);
1624
_toRead.Add(block, ExMarshaller.
Token
);
1798
_toDecompressEnumerator = _toDecompress.GetConsumingEnumerable(ExMarshaller.
Token
).GetEnumerator();
1800
_toReadEnumerator = _toRead.GetConsumingEnumerable(ExMarshaller.
Token
).GetEnumerator();
1821
_toDecompress.Add(block, ExMarshaller.
Token
);
1827
_toDecompress.Add(sentBlock, ExMarshaller.
Token
);
1867
_waiter.Wait(block.BlockSequence, ExMarshaller.
Token
);
1882
_waiter.Wait(block.BlockSequence, ExMarshaller.
Token
);
1900
_waiter.Wait(block.BlockSequence, ExMarshaller.
Token
);
1902
_toRead.Add(new ReaderContainer(reader, decomp, block.Rows, block.BlockSequence), ExMarshaller.
Token
);
1989
Contracts.Assert(ex.CancellationToken == _exMarshaller.
Token
);
DataLoadSave\Binary\BinarySaver.cs (6)
222
foreach (Block block in toCompress.GetConsumingEnumerable(exMarshaller.
Token
))
237
waiter.Wait((long)columns * block.BlockIndex + block.ColumnIndex, exMarshaller.
Token
);
238
toWrite.Add(new Block(compressed, block.ColumnIndex, block.BlockIndex, uncompLength), exMarshaller.
Token
);
423
foreach (Block block in toWrite.GetConsumingEnumerable(exMarshaller.
Token
))
608
toCompress.Add(new Block(pipes[c].EndBlock(), c, blockIndex), exMarshaller.
Token
);
620
toCompress.Add(new Block(pipes[c].EndBlock(), c, blockIndex), exMarshaller.
Token
);