Searched refs:lock (Results 1 – 16 of 16) sorted by relevance
149 std::lock_guard<std::mutex> lock( observers_mutex_ ); in addFile()172 if ( auto heart_beat = weakHeartBeat.lock() ) { in addFile()201 if ( auto heart_beat = weakHeartBeat.lock() ) in addFile()241 std::lock_guard<std::mutex> lock( watch_tower->observers_mutex_ ); in removeNotification()259 std::unique_lock<std::mutex> lock( observers_mutex_ ); in run()264 &observed_file_list_, &lock, &files_needing_readding, polling_interval_ms_ ); in run()
308 std::unique_lock<std::mutex>* lock, in waitAndProcessEvents() argument321 lock->unlock(); in waitAndProcessEvents()328 lock->lock(); in waitAndProcessEvents()337 if ( std::shared_ptr<WinWatchedDirRecord> dir_record = dir_record_ptr.lock() ) in waitAndProcessEvents()
256 if ( auto dir = d.second.lock() ) { in searchByDirWdAndName()283 if ( auto dir = d.second.lock() ) { in searchByDirWd()291 if ( auto d = dir->second.lock() ) { in searchByDirWd()347 dir = observed_dirs_[ dir_name ].lock(); in watchedDirectory()362 if ( auto list = weakHeartBeat.lock() ) { in addWatchedDirectory()
192 list_lock->lock(); in waitAndProcessEvents()
128 list_lock->lock(); in waitAndProcessEvents()
181 std::unique_lock<std::mutex>* lock,
392 fileMutex_.lock(); in doGetLineString()412 fileMutex_.lock(); in doGetExpandedLineString()452 fileMutex_.lock(); in doGetLines()491 fileMutex_.lock(); in doGetExpandedLines()
106 if ( auto keep = weakHeartbeat.lock() ) { in registerFile()107 unique_lock<mutex> lock(mutex_); in registerFile() local127 unique_lock<mutex> lock(mutex_); in waitNotificationReceived() local128 bool result = ( cv_.wait_for( lock, std::chrono::milliseconds(timeout_ms), in waitNotificationReceived()