kemko/nomad
1
0
Fork 0
mirror of https://github.com/kemko/nomad.git synced 2026-01-04 09:25:46 +03:00
Code Issues Packages Projects Releases Wiki Activity

Removed using ProcessState when we just want an empty interface

Browse Source
This commit is contained in:
Diptanu Choudhury
2016-02-04 16:28:31 -08:00
parent ded50766c5
commit a3282cd0f7
1 changed files with 6 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
client/driver/executor_plugin.go
View File

@@ -63,15 +63,11 @@ func (e *ExecutorRPC) Wait() (*executor.ProcessState, error) {
}
func (e *ExecutorRPC) ShutDown() error {
var ps executor.ProcessState
err := e.client.Call("Plugin.ShutDown", new(interface{}), &ps)
return err
return e.client.Call("Plugin.ShutDown", new(interface{}), new(interface{}))
}
func (e *ExecutorRPC) Exit() error {
var ps executor.ProcessState
err := e.client.Call("Plugin.Exit", new(interface{}), &ps)
return err
return e.client.Call("Plugin.Exit", new(interface{}), new(interface{}))
}
type ExecutorRPCServer struct {
@@ -94,16 +90,12 @@ func (e *ExecutorRPCServer) Wait(args interface{}, ps *executor.ProcessState) er
return err
}
func (e *ExecutorRPCServer) ShutDown(args interface{}, ps *executor.ProcessState) error {
var err error
err = e.Impl.ShutDown()
return err
func (e *ExecutorRPCServer) ShutDown(args interface{}, resp *interface{}) error {
return e.Impl.ShutDown()
}
func (e *ExecutorRPCServer) Exit(args interface{}, ps *executor.ProcessState) error {
var err error
err = e.Impl.Exit()
return err
func (e *ExecutorRPCServer) Exit(args interface{}, resp *interface{}) error {
return e.Impl.Exit()
}
type ExecutorPlugin struct {