vitalif
/
etcd
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

tools/funcational-tester/etcd-agent: log the error for dubgging

release-2.1
Xiang Li 2015-03-13 12:08:08 -07:00
parent a9ecf0caff
commit 83bb02e320
1 changed files with 19 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
tools/functional-tester/etcd-agent/rpc.go
View File

@ -37,6 +37,7 @@ func (a *Agent) RPCStart(args []string, pid *int) error {
log.Printf("rpc: start etcd with args %v", args)
err := a.start(args...)
if err != nil {
log.Println("rpc: error starting etcd", err)
return err
}
*pid = a.cmd.Process.Pid
@ -45,13 +46,19 @@ func (a *Agent) RPCStart(args []string, pid *int) error {
func (a *Agent) RPCStop(args struct{}, reply *struct{}) error {
log.Printf("rpc: stop etcd")
return a.stop()
err := a.stop()
if err != nil {
log.Println("rpc: error stopping etcd", err)
return err
}
return nil
}
func (a *Agent) RPCRestart(args struct{}, pid *int) error {
log.Printf("rpc: restart etcd")
err := a.restart()
if err != nil {
log.Println("rpc: error restarting etcd", err)
return err
}
*pid = a.cmd.Process.Pid
@ -60,12 +67,21 @@ func (a *Agent) RPCRestart(args struct{}, pid *int) error {
func (a *Agent) RPCCleanup(args struct{}, reply *struct{}) error {
log.Printf("rpc: cleanup etcd")
return a.cleanup()
err := a.cleanup()
if err != nil {
log.Println("rpc: error cleaning up etcd", err)
return err
}
return nil
}
func (a *Agent) RPCTerminate(args struct{}, reply *struct{}) error {
log.Printf("rpc: terminate etcd")
return a.terminate()
err := a.terminate()
if err != nil {
log.Println("rpc: error terminating etcd", err)
}
return nil
}
func (a *Agent) RPCIsolate(args struct{}, reply *struct{}) error {