etcd-io
/
dbtester
mirror of https://github.com/etcd-io/dbtester.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

agent: run Consul with agent

This commit is contained in:
Gyu-Ho Lee 2016-03-23 04:54:42 -07:00
parent c123d5bd2a
commit b38ea519a3
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
agent/agent.go
View File

@ -266,7 +266,7 @@ func (t *transporterServer) Transfer(ctx context.Context, r *Request) (*Response
processPID = t.pid processPID = t.pid
go func() { go func() {
if err := cmd.Wait(); err != nil { if err := cmd.Wait(); err != nil {
log.Printf("Start(%s) cmd.Wait returned %v", cmd.Path, err) log.Printf("%s cmd.Wait returned %v", cmd.Path, err)
return return
} }
log.Printf("Exiting %s", cmd.Path) log.Printf("Exiting %s", cmd.Path)
@ -327,7 +327,7 @@ func (t *transporterServer) Transfer(ctx context.Context, r *Request) (*Response
processPID = t.pid processPID = t.pid
go func() { go func() {
if err := cmd.Wait(); err != nil { if err := cmd.Wait(); err != nil {
log.Printf("Start(%s) cmd.Wait returned %v", cmd.Path, err) log.Printf("%s cmd.Wait returned %v", cmd.Path, err)
return return
} }
log.Printf("Exiting %s", cmd.Path) log.Printf("Exiting %s", cmd.Path)
@ -401,7 +401,7 @@ func (t *transporterServer) Transfer(ctx context.Context, r *Request) (*Response
processPID = t.pid processPID = t.pid
go func() { go func() {
if err := cmd.Wait(); err != nil { if err := cmd.Wait(); err != nil {
log.Printf("Start(%s) cmd.Wait returned %v", cmd.Path, err) log.Printf("%s cmd.Wait returned %v", cmd.Path, err)
return return
} }
log.Printf("Exiting %s", cmd.Path) log.Printf("Exiting %s", cmd.Path)
@ -431,6 +431,7 @@ func (t *transporterServer) Transfer(ctx context.Context, r *Request) (*Response
} }
} }
flags := []string{ flags := []string{
"agent",
"-server", "-server",
"-node", names[t.req.ServerIndex], "-node", names[t.req.ServerIndex],
"-data-dir", consulDataDir, "-data-dir", consulDataDir,
@ -454,7 +455,7 @@ func (t *transporterServer) Transfer(ctx context.Context, r *Request) (*Response
processPID = t.pid processPID = t.pid
go func() { go func() {
if err := cmd.Wait(); err != nil { if err := cmd.Wait(); err != nil {
log.Printf("Start(%s) cmd.Wait returned %v", cmd.Path, err) log.Printf("%s cmd.Wait returned %v", cmd.Path, err)
return return
} }
log.Printf("Exiting %s", cmd.Path) log.Printf("Exiting %s", cmd.Path)
@ -495,7 +496,7 @@ func (t *transporterServer) Transfer(ctx context.Context, r *Request) (*Response
processPID = t.pid processPID = t.pid
go func() { go func() {
if err := cmd.Wait(); err != nil { if err := cmd.Wait(); err != nil {
log.Printf("Restart(%s) cmd.Wait returned %v", cmd.Path, err) log.Printf("%s cmd.Wait returned %v", cmd.Path, err)
return return
} }
log.Printf("Exiting %s", cmd.Path) log.Printf("Exiting %s", cmd.Path)