| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/bsddb/test/ |
| test_thread.py | 71 readers = 0 # derived class should set variable in class:ConcurrentDataStoreBase
85 readers_per_writer=self.readers//self.writers
87 self.assertEqual(self.readers,self.writers*readers_per_writer)
89 readers = []
91 for x in xrange(self.readers):
100 readers.append(rt)
106 b=readers[readers_per_writer*x:readers_per_writer*(x+1)]
122 for t in readers:
125 def writerThread(self, d, keys, readers):
134 count=len(keys)//len(readers)
180 readers = 10 variable in class:BTreeConcurrentDataStore
187 readers = 10 variable in class:HashConcurrentDataStore
196 readers = 10 variable in class:SimpleThreadedBase
320 readers = 0 variable in class:ThreadedTransactionsBase
471 readers = 10 variable in class:BTreeThreadedTransactions
477 readers = 10 variable in class:HashThreadedTransactions
483 readers = 10 variable in class:BTreeThreadedNoWaitTransactions
490 readers = 10 variable in class:HashThreadedNoWaitTransactions
[all...] |
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/bsddb/test/ |
| test_thread.py | 71 readers = 0 # derived class should set variable in class:ConcurrentDataStoreBase
85 readers_per_writer=self.readers//self.writers
87 self.assertEqual(self.readers,self.writers*readers_per_writer)
89 readers = []
91 for x in xrange(self.readers):
100 readers.append(rt)
106 b=readers[readers_per_writer*x:readers_per_writer*(x+1)]
122 for t in readers:
125 def writerThread(self, d, keys, readers):
134 count=len(keys)//len(readers)
180 readers = 10 variable in class:BTreeConcurrentDataStore
187 readers = 10 variable in class:HashConcurrentDataStore
196 readers = 10 variable in class:SimpleThreadedBase
320 readers = 0 variable in class:ThreadedTransactionsBase
471 readers = 10 variable in class:BTreeThreadedTransactions
477 readers = 10 variable in class:HashThreadedTransactions
483 readers = 10 variable in class:BTreeThreadedNoWaitTransactions
490 readers = 10 variable in class:HashThreadedNoWaitTransactions
[all...] |
| /external/fio/examples/ |
| netio_multicast.fio | 1 # netio UDP multicast example. Writers and readers can be run on separate hosts.
|
| /external/guava/guava/src/com/google/common/io/ |
| MultiReader.java | 26 * A {@link Reader} that concatenates multiple readers.
35 MultiReader(Iterator<? extends InputSupplier<? extends Reader>> readers)
37 this.it = readers;
|
| /external/chromium_org/third_party/mesa/src/src/gallium/drivers/r300/compiler/ |
| radeon_variable.c | 48 struct rc_list * readers; local
72 readers = rc_variable_readers_union(var);
74 for ( ; readers; readers = readers->Next) {
75 struct rc_reader * reader = readers->Item;
155 unsigned int chan_end = var->Readers[i].Inst->IP;
156 unsigned int mask = var->Readers[i].WriteMask;
167 if (var->Readers[i].Inst->IP < start) {
169 rc_match_endloop(var->Readers[i].Inst)
[all...] |
| /external/mesa3d/src/gallium/drivers/r300/compiler/ |
| radeon_variable.c | 48 struct rc_list * readers; local
72 readers = rc_variable_readers_union(var);
74 for ( ; readers; readers = readers->Next) {
75 struct rc_reader * reader = readers->Item;
155 unsigned int chan_end = var->Readers[i].Inst->IP;
156 unsigned int mask = var->Readers[i].WriteMask;
167 if (var->Readers[i].Inst->IP < start) {
169 rc_match_endloop(var->Readers[i].Inst)
[all...] |
| /external/wpa_supplicant_8/src/utils/ |
| eloop_win.c | 50 struct eloop_sock *readers; member in struct:eloop_data
133 tmp = os_realloc_array(eloop.readers, eloop.reader_count + 1,
147 eloop.readers = tmp;
160 if (eloop.readers == NULL || eloop.reader_count == 0)
164 if (eloop.readers[i].sock == sock)
170 WSAEventSelect(eloop.readers[i].sock, eloop.readers[i].event, 0);
171 WSACloseEvent(eloop.readers[i].event);
174 os_memmove(&eloop.readers[i], &eloop.readers[i + 1]
[all...] |
| eloop.c | 88 struct eloop_sock_table readers; member in struct:eloop_data
159 eloop.readers.type = EVENT_TYPE_READ;
340 static int eloop_sock_table_set_fds(struct eloop_sock_table *readers,
355 if (readers && readers->table) {
356 for (i = 0; i < readers->count; i++) {
357 fd = readers->table[i].sock;
449 static void eloop_sock_table_dispatch(struct eloop_sock_table *readers,
455 if (eloop_sock_table_dispatch_table(readers, pollfds_map,
569 return &eloop.readers;
[all...] |
| /frameworks/av/include/media/nbaio/ |
| Pipe.h | 24 // Pipe is multi-thread safe for readers (see PipeReader), but safe for only a single writer thread.
26 // time-base. Readers can be added and removed dynamically, and it's OK to have no readers.
|
| /external/chromium_org/content/common/ |
| one_writer_seqlock.h | 14 // This SeqLock handles only *one* writer and multiple readers. It may be
16 // readers. See:
|
| /external/chromium_org/mojo/public/c/system/tests/ |
| core_perftest.cc | 176 std::vector<MessagePipeReaderThread*> readers; local
178 readers.push_back(new MessagePipeReaderThread(h1_));
188 readers[i]->Start();
193 // Close both handles to make writers and readers stop immediately.
203 readers[i]->Join();
217 num_reads += readers[i]->num_reads();
218 delete readers[i];
220 readers.clear();
|
| /external/proguard/src/proguard/io/ |
| NameFilter.java | 48 * readers, depending on the given list of filters.
73 * readers, depending on the given list of filters.
|
| ClassFilter.java | 49 * readers.
|
| DirectoryFilter.java | 49 * readers.
|
| /external/llvm/include/llvm/Support/ |
| RWMutex.h | 58 /// lock is held by any readers, this method will wait until it can
89 unsigned readers, writers; member in class:llvm::sys::SmartRWMutex
91 explicit SmartRWMutex() : RWMutexImpl(), readers(0), writers(0) { }
99 ++readers;
109 assert(readers > 0 && "Reader lock not acquired before release!");
110 --readers;
|
| /frameworks/av/media/libnbaio/ |
| PipeReader.cpp | 39 int32_t readers = android_atomic_dec(&mPipe.mReaders); local
40 ALOG_ASSERT(readers > 0);
|
| README.txt | 11 supports 1 writer and N readers
|
| /system/extras/tests/sdcard/ |
| profile_sdcard.sh | 47 # Readers and writers should not starve each others.
49 # Check readers finished before writers.
|
| /external/chromium_org/content/public/browser/ |
| browser_accessibility_state.h | 16 // readers.
|
| /external/chromium_org/net/base/ |
| upload_data_stream.cc | 48 ScopedVector<UploadElementReader> readers; local
49 readers.push_back(reader.release());
50 return new UploadDataStream(readers.Pass(), identifier);
206 // Chunked transfers may only contain byte readers, so cannot have read
|
| /external/chromium_org/third_party/webrtc/base/ |
| sharedexclusivelock.h | 21 // multiple-readers/single-writer model.
|
| /external/chromium_org/v8/src/ |
| preparse-data-format.h | 11 // Generic and general data used by preparse data recorders and readers.
|
| /frameworks/compile/mclinker/include/mcld/LD/ |
| LDReader.h | 20 * \brief LDReader provides the basic interfaces for all readers. It also
|
| /frameworks/rs/ |
| rsFifo.h | 30 // readers or writers by design.
|
| /libcore/luni/src/main/java/java/util/concurrent/locks/ |
| ReadWriteLock.java | 60 * both readers and writers are waiting, at the time that a writer releases
63 * lengthy delays for a write if the readers are frequent and long-lived as
66 * <li>Determining whether readers that request the read lock while a
77 * in preference to other waiting readers or writers?
|
