Searched refs:watcher (Results 1 – 11 of 11) sorted by relevance
| /memcached-1.6.32/t/ |
| D | watcher.t | 17 my $watcher = $server->new_sock;
20 print $watcher "watch\n";
21 my $res = <$watcher>;
41 while (my $log = <$watcher>) {
55 $res = <$watcher>;
154 $watcher = $server->new_sock;
155 print $watcher "watch mutations\n";
156 $res = <$watcher>;
168 while (my $log = <$watcher>) {
177 my $watcher = $server->new_sock;
[all …]
|
| D | proxyantiflap.t | 68 my $watcher = $p_srv->new_sock;
69 print $watcher "watch proxyevents\n";
70 is(<$watcher>, "OK\r\n", "watcher enabled");
82 like(<$watcher>, qr/error=(disconnected|reading)/, "disconn error log");
98 like(<$watcher>, qr/error=(disconnected|reading)/, "disconn error log");
101 wait_reload($watcher);
117 like(<$watcher>, qr/error=(disconnected|reading)/, "disconn error log");
124 like(<$watcher>, qr/error=markedbadflap/, "got caught flapping");
129 like(<$watcher>, qr/error=markedbadflap/, "still considered flapping");
146 like(<$watcher>, qr/error=(disconnected|reading)/, "normal disconn error");
[all …]
|
| D | proxyustats.t | 69 my ($p_srv, $ps, $watcher);
79 $watcher = $p_srv->new_sock;
80 print $watcher "watch proxyevents\n";
81 is(<$watcher>, "OK\r\n", "watcher enabled");
99 wait_reload($watcher);
142 wait_reload($watcher);
161 wait_reload($watcher);
180 wait_reload($watcher);
216 wait_reload($watcher);
230 wait_reload($watcher);
[all …]
|
| D | proxyconfig.t | 105 my $watcher = $p_srv->new_sock;
120 wait_reload($watcher);
169 wait_reload($watcher);
172 $watch_s->add($watcher);
195 wait_reload($watcher);
204 wait_reload($watcher);
275 wait_reload($watcher);
286 $watcher = $p_srv->new_sock;
326 $watcher = $p_srv->new_sock;
343 wait_reload($watcher);
[all …]
|
| D | watcher_connid.t | 32 my $watcher = $server->new_sock;
33 print $watcher "watch fetchers mutations\n";
34 my $res = <$watcher>;
41 $res = <$watcher>;
45 $res = <$watcher>;
64 $res = <$watcher>;
|
| D | proxylimits.t | 72 my $watcher;
110 $watcher = $p_srv->new_sock;
111 print $watcher "watch proxyevents\n";
112 is(<$watcher>, "OK\r\n", "watcher enabled");
114 wait_reload($watcher);
137 wait_reload($watcher);
173 like(<$watcher>, qr/error=outofmemory/, "OOM log line");
179 wait_reload($watcher);
198 wait_reload($watcher);
|
| D | proxyinternal.t | 175 my $watcher = $p_srv->new_sock;
176 print $watcher "watch deletions\n";
177 is(<$watcher>, "OK\r\n", "deletions watcher enabled");
186 like(<$watcher>, qr/ts=\d+\.\d+\ gid=\d+ type=deleted key=vfoo cmd=delete .+ size=4/,
196 like(<$watcher>, qr/ts=\d+\.\d+\ gid=\d+ type=deleted key=vfoo cmd=md .+ size=4/,
|
| D | proxyslotcache.t | 145 my $watcher = $p_srv->new_sock;
146 print $watcher "watch proxyevents\n";
147 is(<$watcher>, "OK\r\n", "watcher enabled");
168 wait_reload($watcher);
|
| D | proxyunits.t | 1114 my $watcher = $p_srv->new_sock;
1115 print $watcher "watch proxyuser proxyreqs\n";
1116 is(<$watcher>, "OK\r\n", "watcher enabled");
1120 like(<$watcher>, qr/ts=(\S+) gid=\d+ type=proxy_user msg=testing manual log messages/,
1130 …like(<$watcher>, qr/ts=(\S+) gid=\d+ type=proxy_req elapsed=\d+ type=105 code=17 status=0 cfd=\d+ …
1148 …like(<$watcher>, qr/ts=(\S+) gid=\d+ type=proxy_req elapsed=\d+ type=105 code=17 status=0 cfd=\d+ …
|
| /memcached-1.6.32/ |
| D | logger.c | 50 static int logger_thread_poll_watchers(int force_poll, int watcher);
779 static int logger_thread_poll_watchers(int force_poll, int watcher) { in logger_thread_poll_watchers() argument
788 if (w == NULL || (watcher != WATCHER_ALL && x != watcher)) in logger_thread_poll_watchers()
821 if (w == NULL || (watcher != WATCHER_ALL && x != watcher)) in logger_thread_poll_watchers()
|
| /memcached-1.6.32/doc/ |
| D | protocol.txt | 1207 - Turn connection into a watcher. Options can be stacked and are
1208 space-separated. Logs will be sent to the watcher until it disconnects.
1212 - "OK" to indicate the watcher is ready to send logs.
1515 | | | per active watcher connected. |
|