diff options
| author | Valery Piashchynski <[email protected]> | 2021-01-19 16:47:15 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-01-19 16:47:15 +0300 |
| commit | 26f9d35e18ef79d79a5609c6c68f1b6ad38c7aed (patch) | |
| tree | dd6224660ffd0dcefe2332807203ee1eaf6697b4 /pkg/socket | |
| parent | 75ebbaac89ce8ebc3ab8de47b16e137844cfcd8a (diff) | |
Uniform all errors operations
Add new ExecTTL event
Update tests
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'pkg/socket')
| -rwxr-xr-x | pkg/socket/socket_factory.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/pkg/socket/socket_factory.go b/pkg/socket/socket_factory.go index ff882389..8f99ff73 100755 --- a/pkg/socket/socket_factory.go +++ b/pkg/socket/socket_factory.go @@ -86,7 +86,7 @@ type socketSpawn struct { // SpawnWorker creates Process and connects it to appropriate relay or returns error func (f *Factory) SpawnWorkerWithTimeout(ctx context.Context, cmd *exec.Cmd, listeners ...events.Listener) (worker.BaseProcess, error) { - const op = errors.Op("spawn_worker_with_context") + const op = errors.Op("factory_spawn_worker_with_timeout") c := make(chan socketSpawn) go func() { ctx, cancel := context.WithTimeout(ctx, f.tout) @@ -146,7 +146,7 @@ func (f *Factory) SpawnWorkerWithTimeout(ctx context.Context, cmd *exec.Cmd, lis } func (f *Factory) SpawnWorker(cmd *exec.Cmd, listeners ...events.Listener) (worker.BaseProcess, error) { - const op = errors.Op("spawn_worker") + const op = errors.Op("factory_spawn_worker") w, err := workerImpl.InitBaseWorker(cmd, workerImpl.AddListeners(listeners...)) if err != nil { return nil, err @@ -201,7 +201,7 @@ func (f *Factory) findRelayWithContext(ctx context.Context, w worker.BaseProcess } func (f *Factory) findRelay(w worker.BaseProcess) (*socket.Relay, error) { - const op = errors.Op("find_relay") + const op = errors.Op("factory_find_relay") // poll every 1ms for the relay pollDone := time.NewTimer(f.tout) for { |