/prebuilts/go/darwin-x86/src/io/ |
multi.go | 14 readers []Reader 18 for len(mr.readers) > 0 { 20 if len(mr.readers) == 1 { 21 if r, ok := mr.readers[0].(*multiReader); ok { 22 mr.readers = r.readers 26 n, err = mr.readers[0].Read(p) 30 mr.readers[0] = eofReader{} // permit earlier GC 31 mr.readers = mr.readers[1: [all...] |
/prebuilts/go/linux-x86/src/io/ |
multi.go | 14 readers []Reader 18 for len(mr.readers) > 0 { 20 if len(mr.readers) == 1 { 21 if r, ok := mr.readers[0].(*multiReader); ok { 22 mr.readers = r.readers 26 n, err = mr.readers[0].Read(p) 30 mr.readers[0] = eofReader{} // permit earlier GC 31 mr.readers = mr.readers[1: [all...] |
/external/llvm/include/llvm/Support/ |
RWMutex.h | 58 /// lock is held by any readers, this method will wait until it can 92 unsigned readers, writers; member in class:llvm::sys::SmartRWMutex 94 explicit SmartRWMutex() : impl(), readers(0), writers(0) { } 102 ++readers; 112 assert(readers > 0 && "Reader lock not acquired before release!"); 113 --readers;
|
/external/swiftshader/third_party/LLVM/include/llvm/Support/ |
RWMutex.h | 57 /// lock is held by any readers, this method will wait until it can 88 unsigned readers, writers; member in class:llvm::sys::SmartRWMutex 90 explicit SmartRWMutex() : RWMutexImpl(), readers(0), writers(0) { } 98 ++readers; 108 assert(readers > 0 && "Reader lock not acquired before release!"); 109 --readers;
|
/prebuilts/clang/host/darwin-x86/clang-3957855/prebuilt_include/llvm/include/llvm/Support/ |
RWMutex.h | 64 /// lock is held by any readers, this method will wait until it can 90 unsigned readers = 0; member in class:llvm::sys::SmartRWMutex 104 ++readers; 114 assert(readers > 0 && "Reader lock not acquired before release!"); 115 --readers;
|
/prebuilts/clang/host/darwin-x86/clang-3960126/prebuilt_include/llvm/include/llvm/Support/ |
RWMutex.h | 64 /// lock is held by any readers, this method will wait until it can 90 unsigned readers = 0; member in class:llvm::sys::SmartRWMutex 104 ++readers; 114 assert(readers > 0 && "Reader lock not acquired before release!"); 115 --readers;
|
/prebuilts/clang/host/darwin-x86/clang-3977809/prebuilt_include/llvm/include/llvm/Support/ |
RWMutex.h | 64 /// lock is held by any readers, this method will wait until it can 90 unsigned readers = 0; member in class:llvm::sys::SmartRWMutex 104 ++readers; 114 assert(readers > 0 && "Reader lock not acquired before release!"); 115 --readers;
|
/prebuilts/clang/host/darwin-x86/clang-4053586/prebuilt_include/llvm/include/llvm/Support/ |
RWMutex.h | 64 /// lock is held by any readers, this method will wait until it can 90 unsigned readers = 0; member in class:llvm::sys::SmartRWMutex 104 ++readers; 114 assert(readers > 0 && "Reader lock not acquired before release!"); 115 --readers;
|
/prebuilts/clang/host/linux-x86/clang-3957855/prebuilt_include/llvm/include/llvm/Support/ |
RWMutex.h | 64 /// lock is held by any readers, this method will wait until it can 90 unsigned readers = 0; member in class:llvm::sys::SmartRWMutex 104 ++readers; 114 assert(readers > 0 && "Reader lock not acquired before release!"); 115 --readers;
|
/prebuilts/clang/host/linux-x86/clang-3960126/prebuilt_include/llvm/include/llvm/Support/ |
RWMutex.h | 64 /// lock is held by any readers, this method will wait until it can 90 unsigned readers = 0; member in class:llvm::sys::SmartRWMutex 104 ++readers; 114 assert(readers > 0 && "Reader lock not acquired before release!"); 115 --readers;
|
/prebuilts/clang/host/linux-x86/clang-3977809/prebuilt_include/llvm/include/llvm/Support/ |
RWMutex.h | 64 /// lock is held by any readers, this method will wait until it can 90 unsigned readers = 0; member in class:llvm::sys::SmartRWMutex 104 ++readers; 114 assert(readers > 0 && "Reader lock not acquired before release!"); 115 --readers;
|
/prebuilts/clang/host/linux-x86/clang-4053586/prebuilt_include/llvm/include/llvm/Support/ |
RWMutex.h | 64 /// lock is held by any readers, this method will wait until it can 90 unsigned readers = 0; member in class:llvm::sys::SmartRWMutex 104 ++readers; 114 assert(readers > 0 && "Reader lock not acquired before release!"); 115 --readers;
|
/external/python/cpython2/Lib/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/gdb/darwin-x86/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/gdb/linux-x86/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/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...] |
/prebuilts/go/darwin-x86/src/sync/ |
rwmutex.go | 14 // The lock can be held by an arbitrary number of readers or a single writer. 24 // a blocked Lock call excludes new readers from acquiring the lock. 27 writerSem uint32 // semaphore for writers to wait for completing readers 28 readerSem uint32 // semaphore for readers to wait for completing writers 29 readerCount int32 // number of pending readers 30 readerWait int32 // number of departing readers 52 // it does not affect other simultaneous readers. 87 // Announce to readers there is a pending writer. 89 // Wait for active readers. 114 // Announce to readers there is no active writer [all...] |
/prebuilts/go/linux-x86/src/sync/ |
rwmutex.go | 14 // The lock can be held by an arbitrary number of readers or a single writer. 24 // a blocked Lock call excludes new readers from acquiring the lock. 27 writerSem uint32 // semaphore for writers to wait for completing readers 28 readerSem uint32 // semaphore for readers to wait for completing writers 29 readerCount int32 // number of pending readers 30 readerWait int32 // number of departing readers 52 // it does not affect other simultaneous readers. 87 // Announce to readers there is a pending writer. 89 // Wait for active readers. 114 // Announce to readers there is no active writer [all...] |
/external/guava/guava/src/com/google/common/io/ |
MultiReader.java | 28 * A {@link Reader} that concatenates multiple readers. 37 MultiReader(Iterator<? extends CharSource> readers) throws IOException { 38 this.it = readers;
|
/frameworks/av/media/libnbaio/ |
PipeReader.cpp | 39 int32_t readers = local 44 ALOG_ASSERT(readers > 0);
|
/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 | 101 struct eloop_sock_table readers; member in struct:eloop_data 182 eloop.readers.type = EVENT_TYPE_READ; 435 static int eloop_sock_table_set_fds(struct eloop_sock_table *readers, 450 if (readers && readers->table) { 451 for (i = 0; i < readers->count; i++) { 452 fd = readers->table[i].sock; 544 static void eloop_sock_table_dispatch(struct eloop_sock_table *readers, 550 if (eloop_sock_table_dispatch_table(readers, pollfds_map, 619 if (eloop.readers.changed | [all...] |
/prebuilts/tools/common/m2/repository/xml-resolver/xml-resolver/1.2/ |
xml-resolver-1.2.jar | |
/external/libmojo/mojo/public/c/system/tests/ |
core_perftest.cc | 173 std::vector<MessagePipeReaderThread*> readers; local 175 readers.push_back(new MessagePipeReaderThread(h1_)); 185 readers[i]->Start(); 190 // Close both handles to make writers and readers stop immediately. 200 readers[i]->Join(); 214 num_reads += readers[i]->num_reads(); 215 delete readers[i]; 217 readers.clear();
|