65 lines
1.2 KiB
Go
65 lines
1.2 KiB
Go
package golang
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"net"
|
|
"os"
|
|
)
|
|
|
|
type ChildIPC struct {
|
|
*ipcCommon
|
|
}
|
|
|
|
func NewChild(opts *Options, localApis ...any) (*ChildIPC, error) {
|
|
if opts == nil {
|
|
opts = &Options{}
|
|
}
|
|
c := ChildIPC{
|
|
ipcCommon: &ipcCommon{
|
|
localApis: mapTypeNames(localApis),
|
|
pendingCalls: make(map[int64]*pendingCall),
|
|
errCh: make(chan error, 1),
|
|
ctx: context.Background(),
|
|
debugMessages: opts.DebugMessages,
|
|
},
|
|
}
|
|
|
|
socketPath := socketPathFromArgs()
|
|
if socketPath == "" {
|
|
return nil, fmt.Errorf("ipc socket path is missing")
|
|
}
|
|
c.socketPath = socketPath
|
|
|
|
return &c, nil
|
|
}
|
|
|
|
func (c *ChildIPC) Start() error {
|
|
conn, err := net.Dial("unix", c.socketPath)
|
|
if err != nil {
|
|
return fmt.Errorf("connect to parent socket: %w", err)
|
|
}
|
|
c.conn = conn
|
|
go c.readConn()
|
|
return nil
|
|
}
|
|
|
|
func (c *ChildIPC) Wait() error {
|
|
err := <-c.errCh
|
|
if err != nil {
|
|
return fmt.Errorf("ipc error: %w", err)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// socketPathFromArgs parses --ipc-socket from os.Args without calling flag.Parse(),
|
|
// which would interfere with the host application's flag handling.
|
|
func socketPathFromArgs() string {
|
|
for i, arg := range os.Args {
|
|
if arg == ipcSocketArg && i+1 < len(os.Args) {
|
|
return os.Args[i+1]
|
|
}
|
|
}
|
|
return ""
|
|
}
|