Lines Matching refs:Client
166 client, err := Dial("tcp", addr)
170 defer client.Close()
175 err = client.Call("Arith.Add", args, reply)
186 err = client.Call("Embed.Exported", args, reply)
197 err = client.Call("Arith.BadOperation", args, reply)
208 err = client.Call("Arith.Unknown", args, reply)
218 mulCall := client.Go("Arith.Mul", args, mulReply, nil)
220 addCall := client.Go("Arith.Add", args, addReply, nil)
241 err = client.Call("Arith.Div", args, reply)
251 err = client.Call("Arith.Add", reply, reply) // args, reply would be the correct thing to use
262 err = client.Call("Arith.Scan", &str, reply)
272 err = client.Call("Arith.String", args, &str)
283 err = client.Call("Arith.Mul", args, reply)
294 err = client.Call("net.rpc.Arith.Add", args, reply)
304 client, err := Dial("tcp", addr)
308 defer client.Close()
313 err = client.Call("newServer.Arith.Add", args, reply)
330 var client *Client
333 client, err = DialHTTP("tcp", httpServerAddr)
335 client, err = DialHTTPPath("tcp", httpServerAddr, path)
340 defer client.Close()
345 err = client.Call("Arith.Add", args, reply)
357 client, err := DialHTTP("tcp", httpServerAddr)
361 defer client.Close()
366 err = client.Call("BuiltinTypes.Map", args, &replyMap)
377 err = client.Call("BuiltinTypes.Slice", args, &replySlice)
388 err = client.Call("BuiltinTypes.Array", args, &replyArray)
397 // CodecEmulator provides a client-like api and a ServerCodec interface.
459 client := CodecEmulator{server: server}
460 defer client.Close()
464 err := client.Call("Arith.Add", args, reply)
472 err = client.Call("Arith.Add", nil, reply)
542 client := NewClientWithCodec(WriteFailCodec(0))
543 defer client.Close()
547 testSendDeadlock(client)
548 testSendDeadlock(client)
559 func testSendDeadlock(client *Client) {
565 client.Call("Arith.Add", args, reply)
568 func dialDirect() (*Client, error) {
572 func dialHTTP() (*Client, error) {
576 func countMallocs(dial func() (*Client, error), t *testing.T) float64 {
578 client, err := dial()
582 defer client.Close()
587 err := client.Call("Arith.Add", args, reply)
653 client, err := dialHTTP()
657 defer client.Close()
661 err = client.Call("Arith.Mul", args, &reply)
674 client, err := dialHTTP()
678 err = client.Close()
682 err = client.Call("Arith.Add", &Args{7, 9}, new(Reply))
728 client := NewClient(c)
729 err = client.Call("Arith.Add", args, reply)
740 call := client.Go("Arith.SleepMilli", args, reply, done)
748 func benchmarkEndToEnd(dial func() (*Client, error), b *testing.B) {
750 client, err := dial()
754 defer client.Close()
763 err := client.Call("Arith.Add", args, reply)
774 func benchmarkEndToEndAsync(dial func() (*Client, error), b *testing.B) {
780 client, err := dial()
784 defer client.Close()
802 client.Go("Arith.Add", args, reply, res)
