red-future/ppgo_job
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

追加提交

Browse Source
This commit is contained in:
linxiaozhi
2019-02-18 02:50:12 +08:00
parent 3bfcf57330
commit cf82d0bfbb
2 changed files with 4 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
controllers/server.go
View File

@@ -168,13 +168,12 @@ func RemoteCommandByTelnetPassword(servers *models.TaskServer) error {
addr := fmt.Sprintf("%s:%d", servers.ServerIp, servers.Port) addr := fmt.Sprintf("%s:%d", servers.ServerIp, servers.Port)
conn, err := gote.DialTimeout("tcp", addr, time.Second*10) conn, err := gote.DialTimeout("tcp", addr, time.Second*10)
defer conn.Close()
if err != nil { if err != nil {
return err return err
} }
defer conn.Close()
buf := make([]byte, 4096) buf := make([]byte, 4096)
_, err = conn.Read(buf) _, err = conn.Read(buf)
if err != nil { if err != nil {

5
jobs/job.go
View File

@@ -233,13 +233,12 @@ func RemoteCommandJobByTelnetPassword(id int, name string, command string, serve
addr := fmt.Sprintf("%s:%d", servers.ServerIp, servers.Port) addr := fmt.Sprintf("%s:%d", servers.ServerIp, servers.Port)
conn, err := gote.DialTimeout("tcp", addr, timeout) conn, err := gote.DialTimeout("tcp", addr, timeout)
defer conn.Close()
if err != nil { if err != nil {
return "", "", err, false return "", "", err, false
} }
defer conn.Close()
buf := make([]byte, 4096) buf := make([]byte, 4096)
_, err = conn.Read(buf) _, err = conn.Read(buf)
if err != nil { if err != nil {