Home
last modified time | relevance | path

Searched refs:num_readers (Results 1 – 8 of 8) sorted by relevance

/external/libcxx/src/
Dshared_mutex.cpp64 unsigned num_readers = (__state_ & __n_readers_) + 1; in lock_shared() local
66 __state_ |= num_readers; in lock_shared()
73 unsigned num_readers = __state_ & __n_readers_; in try_lock_shared() local
74 if (!(__state_ & __write_entered_) && num_readers != __n_readers_) in try_lock_shared()
76 ++num_readers; in try_lock_shared()
78 __state_ |= num_readers; in try_lock_shared()
88 unsigned num_readers = (__state_ & __n_readers_) - 1; in unlock_shared() local
90 __state_ |= num_readers; in unlock_shared()
93 if (num_readers == 0) in unlock_shared()
98 if (num_readers == __n_readers_ - 1) in unlock_shared()
/external/tensorflow/tensorflow/contrib/slim/python/slim/data/
Dparallel_reader.py41 num_readers=4, argument
94 self._readers = [reader_class(**reader_kwargs) for _ in range(num_readers)]
98 def num_readers(self): member in ParallelReader
196 num_readers=4, argument
262 num_readers=num_readers,
Ddataset_data_provider.py55 num_readers=1, argument
90 num_readers=num_readers,
Dparallel_reader_test.py46 num_readers = len(tfrecord_paths)
48 io_ops.TFRecordReader, shared_queue, num_readers=num_readers)
88 io_ops.TFRecordReader, shared_queue, num_readers=5)
169 self._tfrecord_paths, reader_class=io_ops.TFRecordReader, num_readers=3)
/external/libchrome/mojo/public/c/system/tests/
Dcore_perftest.cc157 unsigned num_readers, in DoMessagePipeThreadedTest() argument
162 assert(num_readers > 0); in DoMessagePipeThreadedTest()
173 for (unsigned i = 0; i < num_readers; i++) in DoMessagePipeThreadedTest()
180 for (unsigned i = 0; i < num_writers || i < num_readers; i++) { in DoMessagePipeThreadedTest()
183 if (i < num_readers) in DoMessagePipeThreadedTest()
198 for (unsigned i = 0; i < num_readers; i++) in DoMessagePipeThreadedTest()
212 for (unsigned i = 0; i < num_readers; i++) { in DoMessagePipeThreadedTest()
219 sprintf(sub_test_name, "%uw_%ur_%ubytes", num_writers, num_readers, in DoMessagePipeThreadedTest()
/external/bcc/src/cc/
Dperf_reader.c221 int perf_reader_poll(int num_readers, struct perf_reader **readers, int timeout) { in perf_reader_poll() argument
222 struct pollfd pfds[num_readers]; in perf_reader_poll()
225 for (i = 0; i <num_readers; ++i) { in perf_reader_poll()
230 if (poll(pfds, num_readers, timeout) > 0) { in perf_reader_poll()
231 for (i = 0; i < num_readers; ++i) { in perf_reader_poll()
Dperf_reader.h34 int perf_reader_poll(int num_readers, struct perf_reader **readers, int timeout);
/external/bcc/src/cc/includes/
Dperf_reader.h34 int perf_reader_poll(int num_readers, struct perf_reader **readers, int timeout);