/dports/cad/cascade-compiler/cascade-f4f7ae8bd1dd379790c0e58c286df90b8d1cdcde/src/cascade/runtime/ |
H A D | data_plane.cc | 43 if (id >= readers_.size()) { in register_id() 44 readers_.resize(id+1); in register_id() 55 assert(id < readers_.size()); in register_reader() 57 readers_[id].push_back(e); in register_reader() 62 assert(id < readers_.size()); in unregister_reader() 69 assert(id < readers_.size()); in reader_find() 70 return find(readers_[id].begin(), readers_[id].end(), e); in reader_find() 74 assert(id < readers_.size()); in reader_begin() 75 return readers_[id].begin(); in reader_begin() 79 assert(id < readers_.size()); in reader_end() [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/remoting/host/file_transfer/ |
H A D | session_file_operations_handler.cc | 24 readers_.erase(location.first); in ReadFile() 40 auto reader_iter = readers_.find(file_id); in ReadChunk() 41 if (reader_iter == readers_.end()) { in ReadChunk() 91 auto reader_iter = readers_.find(file_id); in Close() 92 if (reader_iter != readers_.end()) { in Close() 93 readers_.erase(reader_iter); in Close() 120 if (reader_iter != readers_.end()) { in Cancel() 121 readers_.erase(reader_iter); in Cancel() 134 readers_.erase(file_id); in OnReaderOpenResult() 141 DCHECK(reader_iter != readers_.end()); in OnReaderOpenResult() [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/blink/renderer/modules/nfc/ |
H A D | nfc_proxy.cc | 47 visitor->Trace(readers_); in Trace() 54 DCHECK(!readers_.Contains(reader)); in StartReading() 61 readers_.insert(reader, next_watch_id_); in StartReading() 67 auto iter = readers_.find(reader); in StopReading() 68 if (iter != readers_.end()) { in StopReading() 74 readers_.erase(iter); in StopReading() 109 ReaderMap copy = readers_; in OnWatch() 120 ReaderMap copy = readers_; in OnError() 133 if (!readers_.Contains(reader)) in OnReaderRegistered() 139 if (readers_.at(reader) != watch_id) in OnReaderRegistered() [all …]
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/blink/renderer/modules/nfc/ |
H A D | nfc_proxy.cc | 49 visitor->Trace(readers_); in Trace() 57 DCHECK(!readers_.Contains(reader)); in StartReading() 64 readers_.insert(reader, next_watch_id_); in StartReading() 70 auto iter = readers_.find(reader); in StopReading() 71 if (iter != readers_.end()) { in StopReading() 77 readers_.erase(iter); in StopReading() 112 ReaderMap copy = readers_; in OnWatch() 123 ReaderMap copy = readers_; in OnError() 136 if (!readers_.Contains(reader)) in OnReaderRegistered() 142 if (readers_.at(reader) != watch_id) in OnReaderRegistered() [all …]
|
/dports/devel/folly/folly-2021.12.27.00/folly/fibers/ |
H A D | TimedMutex-inl.h | 183 (state_ == State::UNLOCKED && readers_ == 0) || in lock_shared() 184 (state_ == State::READ_LOCKED && readers_ > 0)); in lock_shared() 187 readers_ += 1; in lock_shared() 222 (state_ == State::UNLOCKED && readers_ == 0) || in try_lock_shared_until() 226 readers_ += 1; in try_lock_shared_until() 239 readers_ += 1; in try_lock_shared() 333 readers_ -= 1; in unlock_() 341 readers_ = read_waiters_.size(); in unlock_() 348 } else if (readers_ == 0) { in unlock_() 371 readers_ += 1; in unlock_and_lock_shared() [all …]
|
/dports/databases/tiledb/TileDB-2.5.2/tiledb/common/ |
H A D | rwlock.h | 54 , readers_(0) { in RWLock() 72 ++readers_; in read_lock() 81 if (--readers_ == 0) in read_unlock() 89 while (writer_ || readers_ > 0) in write_lock() 108 ++readers_; in write_downgrade() 131 uint64_t readers_; variable
|
/dports/misc/thrill/thrill-12c5b59bca66df93b66628b3829027bd0f110dd9/thrill/core/ |
H A D | multiway_merge.hpp | 39 : readers_(readers_begin), in MultiwayMergeTree() 47 if (TLX_LIKELY(readers_[t].HasNext())) { in MultiwayMergeTree() 49 current_[t].second = readers_[t].template Next<ValueType>(); in MultiwayMergeTree() 72 if (TLX_LIKELY(readers_[top].HasNext())) { in NextWithSource() 74 current_[top].second = readers_[top].template Next<ValueType>(); in NextWithSource() 93 if (TLX_LIKELY(readers_[top].HasNext())) { in Next() 95 current_[top].second = readers_[top].template Next<ValueType>(); in Next() 109 ReaderIterator readers_; member in thrill::core::MultiwayMergeTree
|
H A D | buffered_multiway_merge.hpp | 35 : readers_(readers_begin), in BufferedMultiwayMergeTree() 43 if (TLX_LIKELY(readers_[t].HasNext())) { in BufferedMultiwayMergeTree() 45 current_[t].second = readers_[t].template Next<ValueType>(); in BufferedMultiwayMergeTree() 70 if (TLX_LIKELY(readers_[top].HasNext())) { in Update() 72 current_[top].second = readers_[top].template Next<ValueType>(); in Update() 86 ReaderIterator readers_; member in thrill::core::BufferedMultiwayMergeTree
|
/dports/devel/folly/folly-2021.12.27.00/folly/test/ |
H A D | FileUtilTest.cpp | 153 std::vector<std::pair<size_t, Reader>> readers_; member in folly::test::FileUtilTest 160 readers_.emplace_back(0, reader({0})); in FileUtilTest() 161 readers_.emplace_back(62, reader({62})); in FileUtilTest() 163 readers_.emplace_back(61, reader({61, 0})); in FileUtilTest() 165 readers_.emplace_back(62, reader({31, 31})); in FileUtilTest() 166 readers_.emplace_back(62, reader({1, 10, 20, 10, 1, 20})); in FileUtilTest() 168 readers_.emplace_back(41, reader({1, 10, 20, 10, 0})); in FileUtilTest() 177 for (auto& p : readers_) { in TEST_F() 187 for (auto& p : readers_) { in TEST_F() 245 for (auto& p : readers_) { in TEST_F() [all …]
|
/dports/biology/pbbam/pbbam-0.18.0/include/pbbam/internal/ |
H A D | CompositeFastaReader.inl | 18 readers_.emplace_back(std::make_unique<FastaReader>(fn)); 29 while (!readers_.empty()) { 30 auto& reader = readers_.front(); 34 readers_.pop_front();
|
/dports/sysutils/gsmartcontrol/gsmartcontrol-1.1.3/src/hz/ |
H A D | sync_policy_win32.h | 117 RWMutexWin32() : readers_(0), writers_(0) in RWMutexWin32() 155 ++readers_; 169 ++readers_; 189 ++readers_; 206 ++readers_; 225 if (--readers_ == 0) 263 unsigned int readers_; variable
|
/dports/biology/pbbam/pbbam-0.18.0/tools/pbbamify/src/ |
H A D | QueryLookup.cpp | 40 readers_.clear(); in Load() 43 readers_.push_back(new_reader); in Load() 107 readers_.at(it->second.fileNumber)->VirtualSeek(it->second.fileOffset); in Find() 109 if (!readers_.at(it->second.fileNumber)->GetNext(record)) { in Find()
|
/dports/misc/thrill/thrill-12c5b59bca66df93b66628b3829027bd0f110dd9/thrill/api/ |
H A D | zip_window.hpp | 481 : zip_node_(zip_node), readers_(readers) { } in ZipWindowReader() 487 if (readers_[i].HasNext()) return true; in HasNext() 493 if (!readers_[i].HasNext()) return false; in HasNext() 509 if (Pad && !readers_[Index::index].HasNext()) { in operator ()() 516 readers_[Index::index].template Next<ZipArg>()); in operator ()() 527 std::array<Reader, kNumInputs>& readers_; member in thrill::api::ZipWindowReader 555 : zip_node_(zip_node), readers_(readers) { } in ZipWindowReader() 561 if (readers_[i].HasNext()) return true; in HasNext() 567 if (!readers_[i].HasNext()) return false; in HasNext() 583 if (Pad && !readers_[Index::index].HasNext()) { in operator ()() [all …]
|
H A D | zip.hpp | 360 : zip_node_(zip_node), readers_(readers) { } in ReaderNext() 366 if (readers_[i].HasNext()) return true; in HasNext() 372 if (!readers_[i].HasNext()) return false; in HasNext() 384 if (Pad && !readers_[Index::index].HasNext()) { in operator ()() 388 return readers_[Index::index].template Next<ZipArg>(); in operator ()() 395 std::array<Reader, kNumInputs>& readers_; member in thrill::api::ZipNode::ReaderNext
|
/dports/www/firefox/firefox-99.0/js/src/threading/ |
H A D | ExclusiveData.h | 286 mutable int readers_; variable 297 readers_++; in acquireReaderLock() 303 MOZ_ASSERT(readers_ > 0); in releaseReaderLock() 304 if (--readers_ == 0) { in releaseReaderLock() 312 while (readers_ > 0) { in acquireWriterLock() 331 : lock_(id), value_(std::forward<Args>(args)...), readers_(0) {} in RWExclusiveData()
|
/dports/misc/thrill/thrill-12c5b59bca66df93b66628b3829027bd0f110dd9/thrill/data/ |
H A D | mix_block_queue.hpp | 211 assert(selected_ < readers_.size()); in Next() 214 return readers_[selected_].template Next<T>(); in Next() 230 std::vector<BlockQueue::Reader> readers_; member in thrill::data::MixBlockQueueReader
|
H A D | mix_block_queue.cpp | 93 readers_.reserve(mix_queue_.num_workers_); in MixBlockQueueReader() 97 readers_.emplace_back( in MixBlockQueueReader() 129 assert(src_blk.src < readers_.size()); in PullBlock()
|
/dports/databases/galera/galera-release_25.3.35/tests/test_causal/ |
H A D | causal.cpp | 58 readers_ (1), in Config() 85 ("readers", po::value<size_t>(&readers_), in Config() 123 << "readers : " << readers_ << "\n" in Config() 144 size_t readers() const { return readers_; } in readers() 156 size_t readers_; member in causal::Config
|
/dports/databases/galera26/galera-release_26.4.10/tests/test_causal/ |
H A D | causal.cpp | 58 readers_ (1), in Config() 85 ("readers", po::value<size_t>(&readers_), in Config() 123 << "readers : " << readers_ << "\n" in Config() 144 size_t readers() const { return readers_; } in readers() 156 size_t readers_; member in causal::Config
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/media/blink/ |
H A D | multibuffer.cc | 182 std::set<Reader*>* set_of_readers = &readers_[pos]; in AddReader() 224 auto i = readers_.find(pos); in RemoveReader() 225 if (i == readers_.end()) in RemoveReader() 229 readers_.erase(i); in RemoveReader() 261 for (auto i = readers_.lower_bound(observer_range.begin); in NotifyAvailableRange() 262 i != readers_.end() && i->first < observer_range.end; ++i) { in NotifyAvailableRange() 342 MultiBufferBlockId next_reader_pos = ClosestNextEntry(readers_, pos); in SuggestProviderState() 354 ClosestPreviousEntry(readers_, pos - 1); in SuggestProviderState()
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/media/blink/ |
H A D | multibuffer.cc | 181 std::set<Reader*>* set_of_readers = &readers_[pos]; in AddReader() 223 auto i = readers_.find(pos); in RemoveReader() 224 if (i == readers_.end()) in RemoveReader() 228 readers_.erase(i); in RemoveReader() 260 for (auto i = readers_.lower_bound(observer_range.begin); in NotifyAvailableRange() 261 i != readers_.end() && i->first < observer_range.end; ++i) { in NotifyAvailableRange() 341 MultiBufferBlockId next_reader_pos = ClosestNextEntry(readers_, pos); in SuggestProviderState() 353 ClosestPreviousEntry(readers_, pos - 1); in SuggestProviderState()
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/components/history/core/browser/ |
H A D | expire_history_backend.cc | 378 for (size_t i = 0; i < readers_.size(); i++) in InitWorkQueue() 379 work_queue_.push(readers_[i]); in InitWorkQueue() 400 readers_.clear(); in StartExpiringOldStuff() 405 readers_.push_back(GetAllVisitsReader()); in StartExpiringOldStuff() 406 readers_.push_back(GetAutoSubframeVisitsReader()); in StartExpiringOldStuff()
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/components/history/core/browser/ |
H A D | expire_history_backend.cc | 375 for (size_t i = 0; i < readers_.size(); i++) in InitWorkQueue() 376 work_queue_.push(readers_[i]); in InitWorkQueue() 397 readers_.clear(); in StartExpiringOldStuff() 402 readers_.push_back(GetAllVisitsReader()); in StartExpiringOldStuff() 403 readers_.push_back(GetAutoSubframeVisitsReader()); in StartExpiringOldStuff()
|
/dports/lang/gcc12-devel/gcc-12-20211205/libsanitizer/sanitizer_common/ |
H A D | sanitizer_mutex.h | 234 readers_.Post(wake_readers); in Unlock() 264 readers_.Wait(); in ReadLock() 313 Semaphore readers_; variable
|
/dports/devel/llvm-devel/llvm-project-f05c95f10fc1d8171071735af8ad3a9e87633120/compiler-rt/lib/sanitizer_common/ |
H A D | sanitizer_mutex.h | 234 readers_.Post(wake_readers); in Unlock() 264 readers_.Wait(); in ReadLock() 313 Semaphore readers_; variable
|