/
githubmirror
/
GoFrame
Обзор
Документация
Войти
/
githubmirror
/
GoFrame
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
master
os/gproc/gproc_comm_send.go
58 строк
1 KB
John Guo
enhance from issue #1589
16 фев 2022, 15:51
16 фев 2022, 15:51
948cb9f
Код
Авторство
О чём код?
// Copyright GoFrame Author(https://goframe.org). All Rights Reserved. // // This Source Code Form is subject to the terms of the MIT License. // If a copy of the MIT was not distributed with this file, // You can obtain one at https://github.com/gogf/gf. package gproc import ( "io" "github.com/gogf/gf/v2/errors/gerror" "github.com/gogf/gf/v2/internal/json" "github.com/gogf/gf/v2/net/gtcp" ) // Send sends data to specified process of given pid. func Send(pid int, data []byte, group ...string) error { msg := MsgRequest{ SenderPid: Pid(), ReceiverPid: pid, Group: defaultGroupNameForProcComm, Data: data, } if len(group) > 0 { msg.Group = group[0] } msgBytes, err := json.Marshal(msg) if err != nil { return err } var conn *gtcp.PoolConn conn, err = getConnByPid(pid) if err != nil { return err } defer conn.Close() // Do the sending. var result []byte result, err = conn.SendRecvPkg(msgBytes, gtcp.PkgOption{ Retry: gtcp.Retry{ Count: 3, }, }) if len(result) > 0 { response := new(MsgResponse) if err = json.UnmarshalUseNumber(result, response); err == nil { if response.Code != 1 { err = gerror.New(response.Message) } } } // EOF is not really an error. if err == io.EOF { err = nil } return err }