Commit 7e92eedc authored by Robert Griesemer's avatar Robert Griesemer

gofmt'ed various stragglers

R=rsc
http://go/go-review/1022002
parent 183edddb
......@@ -36,7 +36,7 @@ type Client struct {
conn io.ReadWriteCloser;
enc *gob.Encoder;
dec *gob.Decoder;
pending map[uint64] *Call;
pending map[uint64]*Call;
}
func (client *Client) send(c *Call) {
......@@ -75,7 +75,7 @@ func (client *Client) input() {
if err == os.EOF {
err = io.ErrUnexpectedEOF;
}
break
break;
}
seq := response.Seq;
client.mutex.Lock();
......@@ -106,7 +106,7 @@ func NewClient(conn io.ReadWriteCloser) *Client {
client.conn = conn;
client.enc = gob.NewEncoder(conn);
client.dec = gob.NewDecoder(conn);
client.pending = make(map[uint64] *Call);
client.pending = make(map[uint64]*Call);
go client.input();
return client;
}
......@@ -115,7 +115,7 @@ func NewClient(conn io.ReadWriteCloser) *Client {
func DialHTTP(network, address string) (*Client, os.Error) {
conn, err := net.Dial(network, "", address);
if err != nil {
return nil, err
return nil, err;
}
io.WriteString(conn, "CONNECT " + rpcPath + " HTTP/1.0\n\n");
......@@ -136,7 +136,7 @@ func DialHTTP(network, address string) (*Client, os.Error) {
func Dial(network, address string) (*Client, os.Error) {
conn, err := net.Dial(network, "", address);
if err != nil {
return nil, err
return nil, err;
}
return NewClient(conn), nil;
}
......@@ -170,7 +170,7 @@ func (client *Client) Go(serviceMethod string, args interface{}, reply interface
// Call invokes the named function, waits for it to complete, and returns its error status.
func (client *Client) Call(serviceMethod string, args interface{}, reply interface{}) os.Error {
if client.shutdown != nil {
return client.shutdown
return client.shutdown;
}
call := <-client.Go(serviceMethod, args, reply, nil).Done;
return call.Error;
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment