Home
last modified time | relevance | path

Searched refs:readers_ (Results 1 – 25 of 55) sorted by relevance

123

/dports/cad/cascade-compiler/cascade-f4f7ae8bd1dd379790c0e58c286df90b8d1cdcde/src/cascade/runtime/
H A Ddata_plane.cc43 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 Dsession_file_operations_handler.cc24 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 Dnfc_proxy.cc47 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 Dnfc_proxy.cc49 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 DTimedMutex-inl.h183 (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 Drwlock.h54 , 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 Dmultiway_merge.hpp39 : 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 Dbuffered_multiway_merge.hpp35 : 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 DFileUtilTest.cpp153 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 DCompositeFastaReader.inl18 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 Dsync_policy_win32.h117 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 DQueryLookup.cpp40 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 Dzip_window.hpp481 : 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 Dzip.hpp360 : 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 DExclusiveData.h286 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 Dmix_block_queue.hpp211 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 Dmix_block_queue.cpp93 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 Dcausal.cpp58 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 Dcausal.cpp58 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 Dmultibuffer.cc182 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 Dmultibuffer.cc181 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 Dexpire_history_backend.cc378 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 Dexpire_history_backend.cc375 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 Dsanitizer_mutex.h234 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 Dsanitizer_mutex.h234 readers_.Post(wake_readers); in Unlock()
264 readers_.Wait(); in ReadLock()
313 Semaphore readers_; variable

123