Lines Matching refs:cl
35 static void test_ooo_rpc(struct ping_pong_thc_client_binding_t *cl,
38 cl->call.outoforder(cl, val, &result_val);
42 static void do_nx(struct ping_pong_thc_client_binding_t *cl,
46 if (cl->call_x.outoforder(cl, i, &response) != THC_CANCELED) {
59 struct ping_pong_thc_client_binding_t cl;
70 err = ping_pong_thc_init_client(&cl, b, b);
81 cl.send.str0(&cl, 42, s);
84 cl.recv.pong(&cl, &len);
87 cl.send.arr0(&cl, 42, "abc", 3);
89 cl.recv.pong(&cl, &total);
100 cl.send.slow_op(&cl, 100);
101 cl.recv.slow_reply(&cl, &v);
110 cl.send.ping(&cl, val);
111 cl.recv.pong(&cl, &val);
119 cl.send.testrpc(&cl, val);
120 cl.recv.testrpc(&cl, &result_val);
129 cl.call_seq.testrpc(&cl, val, &result_val);
142 cl.call_fifo.testrpc(&cl, my_v, &r);
154 ASYNC({test_ooo_rpc(&cl, 10);});
155 ASYNC({test_ooo_rpc(&cl, 50);});
156 ASYNC({test_ooo_rpc(&cl, 20);});
157 ASYNC({test_ooo_rpc(&cl, 40);});
158 ASYNC({test_ooo_rpc(&cl, 30);});
159 ASYNC({test_ooo_rpc(&cl, 50);});
160 ASYNC({test_ooo_rpc(&cl, 10);});
171 int r = cl.recv_x.pong(&cl, &val);
186 int r = cl.recv_any_x(&cl, &m,
204 while (cl.send_x.testrpc(&cl, 100+num_sent) == SYS_ERR_OK) {
214 cl.recv.testrpc(&cl, &response);
225 int r = cl.recv_x.testrpc(&cl, &response);
247 cl.send.testrpc(&cl, v);
252 cl.send.testrpc2(&cl, v);
262 if (cl.recv_x.testrpc(&cl, &response) != THC_CANCELED) {
270 if (cl.recv_x.testrpc2(&cl, &response) != THC_CANCELED) {
289 if (cl.call_seq_x.testrpc(&cl, i, &response) != THC_CANCELED) {
316 if (cl.call_fifo_x.testrpc(&cl, my_i, &response) != THC_CANCELED) {
345 if (cl.call_x.outoforder(&cl, my_i, &response) != THC_CANCELED) {
371 ASYNC({do_nx(&cl, my_i);});
380 cl.send.stop(&cl);