Lines Matching refs:t
24 my $t = Memcached::ProxyTest->new(servers => [12011, 12012, 12013, 12014]);
30 $t->set_c($ps);
31 $t->accept_backends();
60 $t->c_send("ms badchunk 2\r\nfail");
61 $t->c_recv("CLIENT_ERROR bad data chunk\r\n", "got bad data chunk response");
63 $t->clear();
70 $t->c_send("$cmd$cmd");
71 $t->c_recv("NF\r\n");
72 $t->c_recv("SERVER_ERROR lua start failure\r\n");
73 $t->clear();
77 $t->c_send("mg badreturn/a\r\n");
78 $t->c_recv("SERVER_ERROR bad response\r\n");
79 $t->clear();
98 $t->c_send("$cmd");
100 $t->be_recv([0, 1, 2], "mg all/$k O$k\r\n", "backend received pipelined $k");
101 $t->be_send([0, 1, 2], "HD O$k\r\n");
105 $t->c_recv("HD O$k\r\n", "client got res $k");
107 $t->clear();
127 $t->c_send("$cmd$cmd$cmd");
129 $t->be_recv([0], $cmd, "backend 0 received locaity req");
130 $t->be_send([0], "EN\r\n"); # not sending to client.
133 $t->c_recv("HD t$x\r\n", "client got return sequence $x");
145 $t->c_send("mg split/a t\r\n");
146 $t->be_recv_c([0, 3], 'each factory be gets the request');
147 $t->be_send(3, "EN\r\n");
148 $t->be_send(0, "HD t70\r\n");
149 $t->c_recv_be('client received hit');
150 $t->clear();
156 $t->c_send("mg splitfailover/f t\r\n");
157 $t->be_recv_c(0, 'first backend receives client req');
158 $t->be_recv_c(3, 'split factory gets client req');
159 $t->be_send(3, "HD t133\r\n");
162 $t->be_send(0, "EN Ofirst\r\n");
163 $t->be_recv_c([1, 2], 'rest of be receives retry');
164 $t->be_send([1, 2], "EN Ofailover\r\n");
165 $t->c_recv("EN Ofirst\r\n", 'client receives first res');
166 $t->clear();
179 $t->c_send("mg errors/reterror t\r\n");
180 $t->c_recv("SERVER_ERROR lua failure\r\n", "lua threw an error");
182 $t->c_send("mg errors/retnil t\r\n");
183 $t->c_recv("SERVER_ERROR bad response\r\n", "lua returned nil");
185 $t->c_send("mg errors/retint t\r\n");
186 $t->c_recv("SERVER_ERROR bad response\r\n", "lua returned an integer");
188 $t->c_send("mg errors/retnone t\r\n");
189 $t->c_recv("SERVER_ERROR bad response\r\n", "lua returned nothing");
190 $t->clear();
196 $t->c_send("mg suberrors/error t\r\n");
197 $t->c_recv("SERVER_ERROR backend failure\r\n", "lua threw an error");
199 $t->c_send("mg suberrors/nil t\r\n");
200 $t->c_recv("SERVER_ERROR backend failure\r\n", "lua returned nil");
202 $t->c_send("mg suberrors/int t\r\n");
203 $t->c_recv("SERVER_ERROR backend failure\r\n", "lua returned an integer");
205 $t->c_send("mg suberrors/none t\r\n");
206 $t->c_recv("SERVER_ERROR backend failure\r\n", "lua returned nothing");
207 $t->clear();
216 $t->c_send("mg fastgoodint/a\r\n");
217 $t->be_recv_c([0, 1, 2]);
218 $t->be_send(0, "HD t1\r\n");
219 $t->c_recv_be('first good response');
220 $t->be_send([1, 2], "EN Ohmm\r\n");
221 $t->clear();
225 $t->c_send("mg fastgoodint/a\r\n");
226 $t->be_recv_c([0, 1, 2]);
227 $t->be_send([1, 2], "EN Ommh\r\n");
228 $t->c_recv_be('received miss');
229 $t->be_send([0], "HD t40\r\n");
230 $t->clear();
234 $t->c_send("mg fastgoodint/a\r\n");
235 $t->be_recv_c([0, 1, 2]);
236 $t->be_send(0, "EN Omhh\r\n");
237 $t->be_send(1, "HD t43\r\n");
238 $t->be_send(2, "HD t44\r\n");
239 $t->c_recv("HD t43\r\n", 'received first');
240 $t->clear();
244 $t->c_send("mg waitfor/a\r\n");
245 $t->c_recv("HD t1\r\n", 'client response before backends receive cmd');
246 $t->be_recv_c([0, 1, 2]);
247 $t->be_send([0, 1, 2], "HD t9\r\n");
248 $t->clear();
252 $t->c_send("mg waitfor/b t\r\n");
253 $t->be_recv_c([0, 1, 2]);
254 $t->be_send([0, 1, 2], "HD t13\r\n");
255 $t->c_recv_be();
256 $t->clear();
260 $t->c_send("mg waitfor/c t\r\n");
261 $t->be_recv_c([0, 1, 2]);
262 $t->be_send([0, 1, 2], "HD t11\r\n");
263 $t->c_recv_be();
264 $t->clear();
268 $t->c_send("mg waitfor/d t\r\n");
269 $t->be_recv_c([0, 1]);
271 $t->be_send(1, "HD t23\r\n");
272 ok(!$t->wait_c(0.2), 'client doesnt become readable');
273 $t->be_send(0, "HD t17\r\n");
274 $t->c_recv("HD t23\r\n");
275 $t->clear();
282 $t->c_send("mg failover/a t\r\n");
283 $t->be_recv_c(0);
284 $t->be_send(0, "HD t31\r\n");
285 $t->c_recv_be();
286 $t->clear();
290 $t->c_send("mg failover/b t\r\n");
291 $t->be_recv_c(0, 'first backend receives client req');
292 $t->be_send(0, "EN\r\n");
294 $t->be_recv_c([1, 2], 'rest of be then receive the retry');
295 $t->be_send(1, "EN\r\n");
296 $t->be_send(2, "HD t41\r\n");
297 $t->c_recv_be('client received last response');
301 $t->c_send("mg failover/c t\r\n");
302 $t->be_recv_c(0, 'first backend receives client req');
303 $t->be_send(0, "EN Ofirst\r\n");
304 $t->be_recv_c([1, 2], 'rest of be receives retry');
305 $t->be_send([1, 2], "EN Ofailover\r\n");
306 $t->c_recv("EN Ofirst\r\n", 'client receives first res');
321 $t->c_send("mg single/a\r\n");
322 $t->be_recv_c(0);
323 $t->be_send(0, "HD\r\n");
324 $t->c_recv_be();
325 $t->clear();
329 $t->c_send("mg first/a t\r\n");
330 $t->be_recv_c([0, 1, 2]);
332 $t->be_send([1, 2], "HD t5\r\n");
333 $t->be_send(0, "HD t1\r\n");
335 $t->c_recv_be();
336 $t->clear();
340 $t->c_send("mg partial/a t\r\n");
341 $t->be_recv_c([0, 1, 2]);
342 $t->be_send(0, "HD t4\r\n");
343 ok(!$t->wait_c(0.2), 'client doesnt become readable');
344 $t->be_send(1, "HD t4\r\n");
345 $t->c_recv_be('response received after 2/3 returned');
346 $t->be_send(2, "HD t5\r\n");
347 $t->clear();
351 $t->c_send("mg all/a t\r\n");
352 $t->be_recv_c([0, 1, 2]);
353 $t->be_send([0, 1], "HD t1\r\n");
354 ok(!$t->wait_c(0.2), 'client doesnt become readable');
355 $t->be_send(2, "HD t1\r\n");
356 $t->c_recv_be('response received after 3/3 returned');
357 $t->clear();
361 $t->c_send("mg fastgood/a t\r\n");
362 $t->be_recv_c([0, 1, 2]);
364 $t->be_send(0, "EN\r\n");
365 ok(!$t->wait_c(0.2), 'client doesnt become readable');
366 $t->be_send(1, "HD t5\r\n");
367 $t->c_recv_be('response received after first good');
368 $t->be_send(2, "EN\r\n");
369 $t->clear();
375 $t->c_send("mg blocker/a t Ltest\r\n");
376 $t->be_recv_c([0, 1, 2, 3], 'received blocker requests');
377 $t->be_send([0, 1, 2], "HD t10\r\n");
378 ok(!$t->wait_c(0.2), 'client doesnt become readable');
379 $t->be_send(3, "HD t15\r\n");
381 $t->c_recv("HD t10\r\n");
382 $t->clear();
385 $t->c_send("mg blocker/b t Ltest\r\n");
386 $t->be_recv_c([0, 1, 2, 3]);
387 $t->be_send([0, 1, 2], "HD t10\r\n");
388 ok(!$t->wait_c(0.2), 'client doesnt become readable');
389 $t->be_send(3, "EN\r\n");
391 $t->c_recv("SERVER_ERROR blocked\r\n");
392 $t->clear();
400 $t->c_send("mg logall/a t\r\n");
401 $t->be_recv_c([0, 1, 2]);
402 $t->be_send([0, 1, 2], "HD t3\r\n");
403 $t->c_recv_be();
411 $t->clear();
419 $t->c_send("mg summary/a t\r\n");
420 $t->be_recv_c([0, 1, 2]);
421 $t->be_send([0, 1, 2], "HD t8\r\n");
422 $t->c_recv_be();
424 $t->clear();