Searched defs:WriterThread (Results 1 – 6 of 6) sorted by relevance
95 struct WriterThread { struct96 uint64_t packets_seen = 0;97 bool last_seen = false;98 uint32_t last_seq = 0;99 uint64_t seq_errors = 0;100 uint64_t counter_errors = 0;101 std::minstd_rand0 rnd_engine;
75 private static class WriterThread extends Thread { class in DemuxInputStreamTest80 …WriterThread(final String name, final String data, final OutputStream output, final DemuxOutputStr… in WriterThread() method in DemuxInputStreamTest.WriterThread
119 class WriterThread : public SimpleThread { class121 WriterThread(LockFreeAddressHashSet* set, std::atomic_bool* cancel) in WriterThread() function in base::__anon907be4130111::WriterThread
117 class WriterThread : public SimpleThread { class119 WriterThread(LockFreeAddressHashSet* set, subtle::Atomic32* cancel) in WriterThread() function in base::__anona93143fd0111::WriterThread
1069 Status AsyncWriter::WriterThread(Env* env, const std::string& shard_directory, in WriterThread() function in tensorflow::data::snapshot_util::AsyncWriter
2103 void WriterThread(Env* env) { in WriterThread() function in tensorflow::data::experimental::__anonbc65ddc20311::SnapshotDatasetOp::Dataset::Iterator::SnapshotWriterIterator