diff options
author | Valery Piashchynski <[email protected]> | 2020-12-21 10:27:10 +0300 |
---|---|---|
committer | Valery Piashchynski <[email protected]> | 2020-12-21 10:27:10 +0300 |
commit | 2f71f79ac704ed95dad961677b6e602e38641b5d (patch) | |
tree | 7452bbedd1444079757a848ad07089bc6093561f /pkg/socket/socket_factory.go | |
parent | 3d4c75aadd9ffd0d46728f48f685de2e1bfc44bb (diff) |
Remove unused contex from interfaces. Update pool allocator.
Diffstat (limited to 'pkg/socket/socket_factory.go')
-rwxr-xr-x | pkg/socket/socket_factory.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/pkg/socket/socket_factory.go b/pkg/socket/socket_factory.go index b08d24e4..49456bd9 100755 --- a/pkg/socket/socket_factory.go +++ b/pkg/socket/socket_factory.go @@ -85,7 +85,7 @@ type socketSpawn struct { } // SpawnWorker creates Process and connects it to appropriate relay or returns error -func (f *Factory) SpawnWorkerWithContext(ctx context.Context, cmd *exec.Cmd) (worker.BaseProcess, error) { +func (f *Factory) SpawnWorkerWithTimeout(ctx context.Context, cmd *exec.Cmd) (worker.BaseProcess, error) { const op = errors.Op("spawn_worker_with_context") c := make(chan socketSpawn) go func() { @@ -174,7 +174,7 @@ func (f *Factory) SpawnWorker(cmd *exec.Cmd) (worker.BaseProcess, error) { } // Close socket factory and underlying socket connection. -func (f *Factory) Close(ctx context.Context) error { +func (f *Factory) Close() error { return f.ls.Close() } |