diff options
author | Chris <ccbrown112@gmail.com> | 2017-08-16 17:23:38 -0500 |
---|---|---|
committer | GitHub <noreply@github.com> | 2017-08-16 17:23:38 -0500 |
commit | f80d50adbddf55a043dfcab5b47d7c1e22749b7d (patch) | |
tree | 5deb606debb6322716c9cdcc6c58be4f68b74223 /plugin/rpcplugin/process_unix.go | |
parent | 4f85ed985d478ddf6692fa4f7d8d98d2a412d18c (diff) | |
download | chat-f80d50adbddf55a043dfcab5b47d7c1e22749b7d.tar.gz chat-f80d50adbddf55a043dfcab5b47d7c1e22749b7d.tar.bz2 chat-f80d50adbddf55a043dfcab5b47d7c1e22749b7d.zip |
PLT-7407: Back-end plugin mechanism (#7177)
* begin backend plugin wip
* flesh out rpcplugin. everything done except for minor supervisor stubs
* done with basic plugin infrastructure
* simplify tests
* remove unused test lines
Diffstat (limited to 'plugin/rpcplugin/process_unix.go')
-rw-r--r-- | plugin/rpcplugin/process_unix.go | 45 |
1 files changed, 45 insertions, 0 deletions
diff --git a/plugin/rpcplugin/process_unix.go b/plugin/rpcplugin/process_unix.go new file mode 100644 index 000000000..f196e34f8 --- /dev/null +++ b/plugin/rpcplugin/process_unix.go @@ -0,0 +1,45 @@ +// +build !windows + +package rpcplugin + +import ( + "context" + "io" + "os" + "os/exec" +) + +type process struct { + command *exec.Cmd +} + +func newProcess(ctx context.Context, path string) (Process, io.ReadWriteCloser, error) { + ipc, childFiles, err := NewIPC() + if err != nil { + return nil, nil, err + } + defer childFiles[0].Close() + defer childFiles[1].Close() + + cmd := exec.CommandContext(ctx, path) + cmd.Stdout = os.Stdout + cmd.Stderr = os.Stderr + cmd.ExtraFiles = childFiles + err = cmd.Start() + if err != nil { + ipc.Close() + return nil, nil, err + } + + return &process{ + command: cmd, + }, ipc, nil +} + +func (p *process) Wait() error { + return p.command.Wait() +} + +func inheritedProcessIPC() (io.ReadWriteCloser, error) { + return InheritedIPC(3, 4) +} |