| /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;
|
| /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/wpa_supplicant_8/src/utils/ |
| eloop_none.c | 40 struct eloop_sock *readers; member in struct:eloop_data
69 tmp = os_realloc_array(eloop.readers, eloop.reader_count + 1,
79 eloop.readers = tmp;
92 if (eloop.readers == NULL || eloop.reader_count == 0)
96 if (eloop.readers[i].sock == sock)
102 os_memmove(&eloop.readers[i], &eloop.readers[i + 1],
366 if (0 /* TODO: eloop.readers[i].sock ready */) {
367 eloop.readers[i].handler(
368 eloop.readers[i].sock
[all...] |
| 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 | 66 struct eloop_sock_table readers; member in struct:eloop_data
237 static int eloop_sock_table_set_fds(struct eloop_sock_table *readers,
252 if (readers && readers->table) {
253 for (i = 0; i < readers->count; i++) {
254 fd = readers->table[i].sock;
346 static void eloop_sock_table_dispatch(struct eloop_sock_table *readers,
352 if (eloop_sock_table_dispatch_table(readers, pollfds_map,
445 return &eloop.readers;
728 (!dl_list_empty(&eloop.timeout) || eloop.readers.count > 0 |
[all...] |
| pcsc_funcs.c | 504 TCHAR *readers = NULL; local
506 char *readers = NULL; local
538 readers = os_malloc(len);
539 if (readers == NULL) {
544 ret = SCardListReaders(scard->ctx, NULL, readers, &len);
551 wpa_printf(MSG_WARNING, "SCARD: No smart card readers "
555 wpa_hexdump_ascii(MSG_DEBUG, "SCARD: Readers", (u8 *) readers, len);
557 * readers is a list of available readers. The last entry is terminate
[all...] |
| /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;
|
| /frameworks/av/media/libnbaio/ |
| PipeReader.cpp | 39 int32_t readers = android_atomic_dec(&mPipe.mReaders); local
40 ALOG_ASSERT(readers > 0);
|
| /external/chromium/net/http/ |
| http_cache.cc | 379 entry->readers.clear();
603 DCHECK(entry->writer || !entry->readers.empty());
634 DCHECK(entry->readers.empty());
662 DCHECK(entry->readers.empty());
796 // readers.
808 if (entry->readers.empty()) {
816 entry->readers.push_back(trans);
832 if (entry->will_process_pending_queue && entry->readers.empty())
853 DCHECK(entry->readers.empty());
883 std::find(entry->readers.begin(), entry->readers.end(), trans)
[all...] |
| http_cache.h | 223 TransactionList readers; member in struct:net::HttpCache::ActiveEntry
|
| /external/chromium_org/net/http/ |
| http_cache.cc | 308 entry->readers.clear();
570 DCHECK(entry->writer || !entry->readers.empty());
614 DCHECK(entry->readers.empty());
642 DCHECK(entry->readers.empty());
779 // readers.
791 if (entry->readers.empty()) {
799 entry->readers.push_back(trans);
815 if (entry->will_process_pending_queue && entry->readers.empty())
839 DCHECK(entry->readers.empty());
869 std::find(entry->readers.begin(), entry->readers.end(), trans)
[all...] |
| http_cache.h | 229 TransactionList readers; member in struct:net::HttpCache::ActiveEntry
|
| /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...] |
| radeon_pair_regalloc.c | 282 struct rc_list * readers = rc_variable_readers_union(variable); local
330 struct rc_reader r = var_ptr->Readers[j];
363 for ( ; readers; readers = readers->Next) {
364 struct rc_reader * r = readers->Item;
|
| /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...] |
| radeon_pair_regalloc.c | 282 struct rc_list * readers = rc_variable_readers_union(variable); local
330 struct rc_reader r = var_ptr->Readers[j];
363 for ( ; readers; readers = readers->Next) {
364 struct rc_reader * r = readers->Item;
|
| /external/chromium_org/chrome/browser/policy/cloud/ |
| test_request_interceptor.cc | 86 const ScopedVector<net::UploadElementReader>& readers = local
88 if (readers.size() != 1u)
90 const net::UploadBytesElementReader* reader = readers[0]->AsBytesReader();
|
| /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, identifier);
206 // Chunked transfers may only contain byte readers, so cannot have read
|
| /external/chromium_org/third_party/sqlite/src/ext/fts2/ |
| fts2.c | 1292 OrderedDLReader readers[MERGE_COUNT]; local
6055 DLReader readers[2]; local
6602 OptLeavesReader *readers; local
[all...] |
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/test/ |
| test_poll.py | 31 readers = []
41 readers.append(rd)
|
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/test/ |
| test_poll.py | 31 readers = []
41 readers.append(rd)
|
| /external/chromium_org/chrome/browser/sessions/ |
| better_session_restore_browsertest.cc | 84 const ScopedVector<net::UploadElementReader>& readers = local
86 for (size_t i = 0; i < readers.size(); ++i) {
88 readers[i]->AsBytesReader();
|
| /external/chromium_org/chrome/browser/extensions/api/web_request/ |
| web_request_api.cc | 250 const ScopedVector<net::UploadElementReader>& readers = local
255 for (reader = readers.begin(); reader != readers.end(); ++reader)
[all...] |
| /external/eclipse-basebuilder/basebuilder-3.6.2/org.eclipse.releng.basebuilder/plugins/ |
| org.apache.lucene_1.9.1.v20100518-1140.jar | |
