Home
last modified time | relevance | path

Searched refs:Watcher (Results 1 – 25 of 2489) sorted by relevance

12345678910>>...100

/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/main/java/org/apache/zookeeper/
H A DZKWatchManager.java59 Watcher getDefaultWatcher() { in getDefaultWatcher()
113 private void addTo(Set<Watcher> from, Set<Watcher> to) { in addTo()
119 public Map<Watcher.Event.EventType, Set<Watcher>> removeWatcher( in removeWatcher()
121 Watcher watcher, in removeWatcher()
122 Watcher.WatcherType watcherType, in removeWatcher()
130 Map<Watcher.Event.EventType, Set<Watcher>> removedWatchers = new HashMap<>(); in removeWatcher()
191 …private boolean contains(String path, Watcher watcherObj, Map<String, Set<Watcher>> pathVsWatchers… in contains()
220 void containsWatcher(String path, Watcher watcher, Watcher.WatcherType watcherType) throws in containsWatcher()
301 Watcher watcher, in removeWatches()
345 public Set<Watcher> materialize( in materialize()
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/content/browser/scheduler/responsiveness/
H A Dwatcher.cc21 Watcher::Metadata::Metadata(const void* identifier, in Metadata()
188 void Watcher::OnSuspend() { in OnSuspend()
193 void Watcher::OnResume() { in OnResume()
198 Watcher::Watcher() = default;
199 Watcher::~Watcher() = default;
201 void Watcher::SetUp() { in SetUp()
215 void Watcher::Destroy() { in Destroy()
227 void Watcher::SetUpOnIOThread() { in SetUpOnIOThread()
233 void Watcher::TearDownOnUIThread() {} in TearDownOnUIThread()
235 void Watcher::FinishDestroyMetricSource() { in FinishDestroyMetricSource()
[all …]
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/content/browser/scheduler/responsiveness/
H A Dwatcher.cc20 Watcher::Metadata::Metadata(const void* identifier, in Metadata()
27 std::unique_ptr<Calculator> Watcher::CreateCalculator() { in CreateCalculator()
89 void Watcher::DidRunTask(const base::PendingTask* task, in DidRunTask()
197 Watcher::Watcher() = default;
198 Watcher::~Watcher() = default;
200 void Watcher::SetUp() { in SetUp()
210 void Watcher::Destroy() { in Destroy()
218 void Watcher::SetUpOnIOThread() { in SetUpOnIOThread()
224 void Watcher::TearDownOnUIThread() {} in TearDownOnUIThread()
226 void Watcher::FinishDestroyMetricSource() { in FinishDestroyMetricSource()
[all …]
/dports/x11/waybar/Waybar-0.9.12/include/modules/sni/
H A Dwatcher.hpp9 class Watcher { class
11 Watcher();
14 ~Watcher();
16 using singleton = std::shared_ptr<Watcher>;
18 static std::weak_ptr<Watcher> weak; in getInstance()
20 std::shared_ptr<Watcher> strong = weak.lock(); in getInstance()
22 strong = std::shared_ptr<Watcher>(new Watcher()); in getInstance()
33 Watcher * watcher;
41 static gboolean handleRegisterHost(Watcher *, GDBusMethodInvocation *, const gchar *);
42 static gboolean handleRegisterItem(Watcher *, GDBusMethodInvocation *, const gchar *);
[all …]
/dports/mail/nextcloud-mail/mail/vendor/amphp/amp/lib/Loop/
H A DDriver.php27 /** @var Watcher[] */
30 /** @var Watcher[] */
33 /** @var Watcher[] */
36 /** @var Watcher[] */
144 * @param Watcher[] $watchers
190 $watcher = new Watcher;
225 $watcher = new Watcher;
262 $watcher = new Watcher;
298 $watcher = new Watcher;
333 $watcher = new Watcher;
[all …]
/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/test/java/org/apache/zookeeper/test/
H A DPersistentRecursiveWatcherTest.java34 import org.apache.zookeeper.Watcher;
45 private Watcher persistentWatcher;
91 assertEvent(events, Watcher.Event.EventType.NodeCreated, "/a/b"); in internalTestBasic()
92 assertEvent(events, Watcher.Event.EventType.NodeCreated, "/a/b/c"); in internalTestBasic()
93 assertEvent(events, Watcher.Event.EventType.NodeCreated, "/a/b/c/d"); in internalTestBasic()
108 assertEvent(events, Watcher.Event.EventType.NodeCreated, "/a/b"); in testRemoval()
122 assertEvent(events, Watcher.Event.EventType.None, null); in testDisconnect()
124 assertEvent(events, Watcher.Event.EventType.None, null); in testDisconnect()
162 assertEvent(events, Watcher.Event.EventType.NodeCreated, "/a"); in testRootWatcher()
163 assertEvent(events, Watcher.Event.EventType.NodeCreated, "/a/b"); in testRootWatcher()
[all …]
H A DPersistentWatcherTest.java35 import org.apache.zookeeper.Watcher;
46 private Watcher persistentWatcher;
146 assertEvent(events, Watcher.Event.EventType.NodeCreated, "/a/b"); in internalTestBasic()
147 assertEvent(events, Watcher.Event.EventType.NodeChildrenChanged, "/a/b"); in internalTestBasic()
148 assertEvent(events, Watcher.Event.EventType.NodeDataChanged, "/a/b"); in internalTestBasic()
149 assertEvent(events, Watcher.Event.EventType.NodeChildrenChanged, "/a/b"); in internalTestBasic()
150 assertEvent(events, Watcher.Event.EventType.NodeDeleted, "/a/b"); in internalTestBasic()
151 assertEvent(events, Watcher.Event.EventType.NodeCreated, "/a/b"); in internalTestBasic()
162 assertEvent(events, Watcher.Event.EventType.NodeCreated, "/a/b"); in testRemoval()
177 assertEvent(events, Watcher.Event.EventType.None, null); in testDisconnect()
[all …]
/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/main/java/org/apache/zookeeper/server/watch/
H A DWatchManager.java29 import org.apache.zookeeper.Watcher;
30 import org.apache.zookeeper.Watcher.Event.EventType;
31 import org.apache.zookeeper.Watcher.Event.KeeperState;
61 private boolean isDeadWatcher(Watcher watcher) { in isDeadWatcher()
77 Set<Watcher> list = watchTable.get(path); in addWatch()
106 Set<Watcher> list = watchTable.get(p); in removeWatcher()
125 Set<Watcher> watchers = new HashSet<>(); in triggerWatch()
164 for (Watcher w : watchers) { in triggerWatch()
215 for (Watcher w : e.getValue()) { in dumpWatches()
258 Set<Watcher> list = watchTable.get(path); in removeWatcher()
[all …]
/dports/x11-toolkits/ctk/CTK-2018-10-29/Libs/CommandLineModules/Testing/Cpp/
H A DctkCmdLineModuleSignalTester.cpp29 connect(&Watcher, SIGNAL(started()), SLOT(moduleStarted())); in ctkCmdLineModuleSignalTester()
30 connect(&Watcher, SIGNAL(canceled()), SLOT(moduleCanceled())); in ctkCmdLineModuleSignalTester()
31 connect(&Watcher, SIGNAL(finished()), SLOT(moduleFinished())); in ctkCmdLineModuleSignalTester()
33 connect(&Watcher, SIGNAL(paused()), SLOT(modulePaused())); in ctkCmdLineModuleSignalTester()
34 connect(&Watcher, SIGNAL(resumed()), SLOT(moduleResumed())); in ctkCmdLineModuleSignalTester()
36 connect(&Watcher, SIGNAL(resultReadyAt(int)), SLOT(resultReadyAt(int))); in ctkCmdLineModuleSignalTester()
43 connect(&Watcher, SIGNAL(outputDataReady()), SLOT(outputDataReady())); in ctkCmdLineModuleSignalTester()
44 connect(&Watcher, SIGNAL(errorDataReady()), SLOT(errorDataReady())); in ctkCmdLineModuleSignalTester()
50 this->Watcher.setFuture(future); in setFuture()
56 return &this->Watcher; in watcher()
[all …]
/dports/x11/waybar/Waybar-0.9.12/src/modules/sni/
H A Dwatcher.cpp6 Watcher::Watcher() in Watcher() function in Watcher
9 sigc::mem_fun(*this, &Watcher::busAcquired), in Watcher()
15 Watcher::~Watcher() { in ~Watcher()
48 gboolean Watcher::handleRegisterHost(Watcher* obj, GDBusMethodInvocation* invocation, in handleRegisterHost()
86 gboolean Watcher::handleRegisterItem(Watcher* obj, GDBusMethodInvocation* invocation, in handleRegisterItem()
121 Watcher::GfWatch* Watcher::gfWatchFind(GSList* list, const gchar* bus_name, in gfWatchFind()
133 void Watcher::gfWatchFree(gpointer data) { in gfWatchFree()
147 Watcher::GfWatch* Watcher::gfWatchNew(GfWatchType type, const gchar* service, const gchar* bus_name, in gfWatchNew()
148 const gchar* object_path, Watcher* watcher) { in gfWatchNew()
159 &Watcher::nameVanished, in gfWatchNew()
[all …]
/dports/games/pcgen/pcgen/data/modern/rpg_objects/modern_dispatch/090_the_watchers/
H A Dmoderndispatch090_feats.lst8 Aspect of the Watcher CATEGORY:FEAT TYPE:Watcher.Nephilim.Celestial PRECLASS:…
9 Aura CATEGORY:FEAT TYPE:Watcher.Nephilim.Celestial PRECLASS:1,The Watcher=…
10 …elestial Toughness I CATEGORY:FEAT TYPE:Watcher.Nephilim.Celestial PRECLASS:…
11 … CATEGORY:FEAT TYPE:Watcher.Nephilim.Celestial PREABILITY:1,CATEGORY=FEAT,Celestial Toughness …
12 … CATEGORY:FEAT TYPE:Watcher.Nephilim.Celestial PREABILITY:1,CATEGORY=FEAT,Celestial Toughness …
13 …ce CATEGORY:FEAT TYPE:Watcher.Nephilim.Celestial !PREABILITY:1,CATEGORY=FEAT,Divine …
14 Divine Healing CATEGORY:FEAT TYPE:Watcher.Nephilim.Celestial PRECLASS:1,The …
17 Languages of Babylon CATEGORY:FEAT TYPE:Watcher.Nephilim.Celestial PRECLASS:1…
18 …CATEGORY:FEAT TYPE:Watcher.Nephilim.Celestial !PREABILITY:1,CATEGORY=FEAT,Resistance …
19 Sustaining Spirit CATEGORY:FEAT TYPE:Watcher.Nephilim.Celestial PREABILITY:1,CATEGORY=FEAT,Occ…
[all …]
H A Dmoderndispatch090_feats_hidden.lst6 ###Block: Watcher abilities
9 Watcher Acid Resistance CATEGORY:FEAT TYPE:WatcherResistance VISIBLE:NO SAB:Acid Resistance %|Wa…
10 Watcher Cold Resistance CATEGORY:FEAT TYPE:WatcherResistance VISIBLE:NO SAB:Cold Resistance %|Wa…
11 Watcher Electricity Resistance CATEGORY:FEAT TYPE:WatcherResistance VISIBLE:NO SAB:Electricity Res…
12 Watcher Fire Resistance CATEGORY:FEAT TYPE:WatcherResistance VISIBLE:NO SAB:Fire Resistance %|Wa…
/dports/sysutils/nomad/nomad-1.1.0/nomad/deploymentwatcher/
H A Ddeployments_watcher.go60 type Watcher struct { struct
105 ) *Watcher {
107 return &Watcher{
120 func (w *Watcher) SetEnabled(enabled bool, state *state.StateStore) { argument
141 func (w *Watcher) flush(enabled bool) { argument
164 func (w *Watcher) watchDeployments(ctx context.Context) { argument
232 func (w *Watcher) add(d *structs.Deployment) error { argument
279 func (w *Watcher) remove(d *structs.Deployment) { argument
297 func (w *Watcher) forceAdd(dID string) (*deploymentWatcher, error) { argument
423 func (w *Watcher) upsertJob(job *structs.Job) (uint64, error) { argument
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/nomad/deploymentwatcher/
H A Ddeployments_watcher.go60 type Watcher struct { struct
96 updateBatchDuration time.Duration) *Watcher {
98 return &Watcher{
109 func (w *Watcher) SetEnabled(enabled bool, state *state.StateStore) { argument
130 func (w *Watcher) flush() { argument
148 func (w *Watcher) watchDeployments(ctx context.Context) { argument
216 func (w *Watcher) add(d *structs.Deployment) error { argument
262 func (w *Watcher) remove(d *structs.Deployment) { argument
280 func (w *Watcher) forceAdd(dID string) (*deploymentWatcher, error) { argument
368 func (w *Watcher) upsertJob(job *structs.Job) (uint64, error) { argument
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/base/files/
H A Dfile_descriptor_watcher_posix.cc35 class FileDescriptorWatcher::Controller::Watcher class in base::FileDescriptorWatcher::Controller
39 Watcher(WeakPtr<Controller> controller, MessagePumpForIO::Mode mode, int fd);
40 ~Watcher() override;
82 DISALLOW_COPY_AND_ASSIGN(Watcher);
85 FileDescriptorWatcher::Controller::Watcher::Watcher( in Watcher() function in base::FileDescriptorWatcher::Controller::Watcher
97 FileDescriptorWatcher::Controller::Watcher::~Watcher() { in ~Watcher()
102 void FileDescriptorWatcher::Controller::Watcher::StartWatching() { in StartWatching()
116 void FileDescriptorWatcher::Controller::Watcher::OnFileCanReadWithoutBlocking( in OnFileCanReadWithoutBlocking()
138 void FileDescriptorWatcher::Controller::Watcher::
199 [](Watcher* watcher, ScopedClosureRunner closure) { in ~Controller()
[all …]
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/base/files/
H A Dfile_descriptor_watcher_posix.cc35 class FileDescriptorWatcher::Controller::Watcher class in base::FileDescriptorWatcher::Controller
39 Watcher(WeakPtr<Controller> controller, MessagePumpForIO::Mode mode, int fd);
40 ~Watcher() override;
82 DISALLOW_COPY_AND_ASSIGN(Watcher);
85 FileDescriptorWatcher::Controller::Watcher::Watcher( in Watcher() function in base::FileDescriptorWatcher::Controller::Watcher
97 FileDescriptorWatcher::Controller::Watcher::~Watcher() { in ~Watcher()
102 void FileDescriptorWatcher::Controller::Watcher::StartWatching() { in StartWatching()
117 void FileDescriptorWatcher::Controller::Watcher::OnFileCanReadWithoutBlocking( in OnFileCanReadWithoutBlocking()
139 void FileDescriptorWatcher::Controller::Watcher::
200 [](Watcher* watcher, ScopedClosureRunner closure) { in ~Controller()
[all …]
/dports/net/goreplay/goreplay-1.2.0/vendor/github.com/smartystreets/goconvey/web/server/watch/
H A Dintegration.go13 type Watcher struct { struct
33 return &Watcher{
46 func (this *Watcher) Listen() { argument
66 func (this *Watcher) respond(command messaging.WatcherCommand) { argument
110 func (this *Watcher) execute() { argument
115 func (this *Watcher) scan() { argument
151 func (this *Watcher) set(state int64) { argument
159 func (this *Watcher) ignore(paths string) { argument
167 func (this *Watcher) reinstate(paths string) { argument
174 func (this *Watcher) protectedWrite(protected func()) { argument
[all …]
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/github.com/smartystreets/goconvey/web/server/watch/
H A Dintegration.go13 type Watcher struct { struct
33 return &Watcher{
46 func (this *Watcher) Listen() { argument
66 func (this *Watcher) respond(command messaging.WatcherCommand) { argument
110 func (this *Watcher) execute() { argument
115 func (this *Watcher) scan() { argument
151 func (this *Watcher) set(state int64) { argument
159 func (this *Watcher) ignore(paths string) { argument
167 func (this *Watcher) reinstate(paths string) { argument
174 func (this *Watcher) protectedWrite(protected func()) { argument
[all …]
/dports/net-im/tut/tut-0.0.17/vendor/github.com/smartystreets/goconvey/web/server/watch/
H A Dintegration.go13 type Watcher struct { struct
33 return &Watcher{
46 func (this *Watcher) Listen() { argument
66 func (this *Watcher) respond(command messaging.WatcherCommand) { argument
110 func (this *Watcher) execute() { argument
115 func (this *Watcher) scan() { argument
151 func (this *Watcher) set(state int64) { argument
159 func (this *Watcher) ignore(paths string) { argument
167 func (this *Watcher) reinstate(paths string) { argument
174 func (this *Watcher) protectedWrite(protected func()) { argument
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/vendor/github.com/smartystreets/goconvey/web/server/watch/
H A Dintegration.go13 type Watcher struct { struct
33 return &Watcher{
46 func (this *Watcher) Listen() { argument
66 func (this *Watcher) respond(command messaging.WatcherCommand) { argument
110 func (this *Watcher) execute() { argument
115 func (this *Watcher) scan() { argument
151 func (this *Watcher) set(state int64) { argument
159 func (this *Watcher) ignore(paths string) { argument
167 func (this *Watcher) reinstate(paths string) { argument
174 func (this *Watcher) protectedWrite(protected func()) { argument
[all …]
/dports/security/snowflake-tor/snowflake-ead5a960d7fa19dc890ccbfc0765c5ab6629eaa9/vendor/github.com/smartystreets/goconvey/web/server/watch/
H A Dintegration.go13 type Watcher struct { struct
33 return &Watcher{
46 func (this *Watcher) Listen() { argument
66 func (this *Watcher) respond(command messaging.WatcherCommand) { argument
110 func (this *Watcher) execute() { argument
115 func (this *Watcher) scan() { argument
151 func (this *Watcher) set(state int64) { argument
159 func (this *Watcher) ignore(paths string) { argument
167 func (this *Watcher) reinstate(paths string) { argument
174 func (this *Watcher) protectedWrite(protected func()) { argument
[all …]
/dports/www/writefreely/writefreely-0.13.1/vendor/github.com/smartystreets/goconvey/web/server/watch/
H A Dintegration.go13 type Watcher struct { struct
33 return &Watcher{
46 func (this *Watcher) Listen() { argument
66 func (this *Watcher) respond(command messaging.WatcherCommand) { argument
110 func (this *Watcher) execute() { argument
115 func (this *Watcher) scan() { argument
151 func (this *Watcher) set(state int64) { argument
159 func (this *Watcher) ignore(paths string) { argument
167 func (this *Watcher) reinstate(paths string) { argument
174 func (this *Watcher) protectedWrite(protected func()) { argument
[all …]
/dports/sysutils/terraform/terraform-1.0.11/vendor/github.com/smartystreets/goconvey/web/server/watch/
H A Dintegration.go13 type Watcher struct { struct
33 return &Watcher{
46 func (this *Watcher) Listen() { argument
66 func (this *Watcher) respond(command messaging.WatcherCommand) { argument
110 func (this *Watcher) execute() { argument
115 func (this *Watcher) scan() { argument
151 func (this *Watcher) set(state int64) { argument
159 func (this *Watcher) ignore(paths string) { argument
167 func (this *Watcher) reinstate(paths string) { argument
174 func (this *Watcher) protectedWrite(protected func()) { argument
[all …]
/dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/github.com/smartystreets/goconvey/web/server/watch/
H A Dintegration.go13 type Watcher struct { struct
33 return &Watcher{
46 func (this *Watcher) Listen() { argument
66 func (this *Watcher) respond(command messaging.WatcherCommand) { argument
110 func (this *Watcher) execute() { argument
115 func (this *Watcher) scan() { argument
151 func (this *Watcher) set(state int64) { argument
159 func (this *Watcher) ignore(paths string) { argument
167 func (this *Watcher) reinstate(paths string) { argument
174 func (this *Watcher) protectedWrite(protected func()) { argument
[all …]
/dports/databases/mongodb42-tools/mongo-tools-r4.2.17/vendor/github.com/smartystreets/goconvey/web/server/watch/
H A Dintegration.go13 type Watcher struct { struct
33 return &Watcher{
46 func (this *Watcher) Listen() { argument
66 func (this *Watcher) respond(command messaging.WatcherCommand) { argument
110 func (this *Watcher) execute() { argument
115 func (this *Watcher) scan() { argument
151 func (this *Watcher) set(state int64) { argument
159 func (this *Watcher) ignore(paths string) { argument
167 func (this *Watcher) reinstate(paths string) { argument
174 func (this *Watcher) protectedWrite(protected func()) { argument
[all …]

12345678910>>...100