로그 정리
This commit is contained in:
@ -282,8 +282,6 @@ func NewClient() (HoustonClient, error) {
|
|||||||
case shared.Deploy:
|
case shared.Deploy:
|
||||||
var dr shared.DeployRequest
|
var dr shared.DeployRequest
|
||||||
unmarshal(&dr, resp.Args)
|
unmarshal(&dr, resp.Args)
|
||||||
|
|
||||||
shared.Logger().Println(dr.Name, myname)
|
|
||||||
if dr.Name == myname {
|
if dr.Name == myname {
|
||||||
if srcdir, replacer, err := hc.prepareUpdateSelf(&dr); err == nil {
|
if srcdir, replacer, err := hc.prepareUpdateSelf(&dr); err == nil {
|
||||||
args := []string{
|
args := []string{
|
||||||
@ -292,7 +290,6 @@ func NewClient() (HoustonClient, error) {
|
|||||||
filepath.ToSlash(os.Args[0]),
|
filepath.ToSlash(os.Args[0]),
|
||||||
}
|
}
|
||||||
args = append(args, os.Args[1:]...)
|
args = append(args, os.Args[1:]...)
|
||||||
shared.Logger().Println(replacer, args)
|
|
||||||
cmd := exec.Command(replacer, args...)
|
cmd := exec.Command(replacer, args...)
|
||||||
if err := cmd.Start(); err != nil {
|
if err := cmd.Start(); err != nil {
|
||||||
shared.Logger().Println(err)
|
shared.Logger().Println(err)
|
||||||
@ -438,7 +435,6 @@ func (hc *houstonClient) checkOperation() error {
|
|||||||
cl.CloseSend()
|
cl.CloseSend()
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
shared.Logger().Println(update)
|
|
||||||
hc.operationChan <- update
|
hc.operationChan <- update
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@ -2,7 +2,6 @@ package server
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
"encoding/json"
|
|
||||||
"fmt"
|
"fmt"
|
||||||
"reflect"
|
"reflect"
|
||||||
"sync"
|
"sync"
|
||||||
@ -71,9 +70,6 @@ func (sp *hostPool) regist(desc *protos.OperationQueryRequest) (string, chan *op
|
|||||||
host = makeHostWithChan(desc).withOpChan(host.opChan)
|
host = makeHostWithChan(desc).withOpChan(host.opChan)
|
||||||
}
|
}
|
||||||
sp.hosts[desc.Hostname] = host
|
sp.hosts[desc.Hostname] = host
|
||||||
|
|
||||||
test, _ := json.Marshal(sp.hosts)
|
|
||||||
shared.Logger().Println(string(test))
|
|
||||||
return desc.Hostname, host.opChan
|
return desc.Hostname, host.opChan
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -86,9 +82,6 @@ func (sp *hostPool) refresh(desc *protos.OperationQueryRequest) {
|
|||||||
host = makeHostWithChan(desc).withOpChan(host.opChan)
|
host = makeHostWithChan(desc).withOpChan(host.opChan)
|
||||||
sp.hosts[desc.Hostname] = host
|
sp.hosts[desc.Hostname] = host
|
||||||
}
|
}
|
||||||
|
|
||||||
test, _ := json.Marshal(sp.hosts)
|
|
||||||
shared.Logger().Println(string(test))
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func (sp *hostPool) unregist(key string) {
|
func (sp *hostPool) unregist(key string) {
|
||||||
|
|||||||
Reference in New Issue
Block a user