Searched defs:WriterThread (Results 1 – 7 of 7) 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 final 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::__anon73b5672e0111::WriterThread
119 class WriterThread : public SimpleThread { class121 WriterThread(LockFreeAddressHashSet* set, std::atomic_bool* cancel) in WriterThread() function in base::__anonba02c6ca0111::WriterThread
117 class WriterThread : public SimpleThread { class119 WriterThread(LockFreeAddressHashSet* set, subtle::Atomic32* cancel) in WriterThread() function in base::__anond32c17ce0111::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::__anon037cfb730311::SnapshotDatasetOp::Dataset::Iterator::SnapshotWriterIterator