diff options
| author | Valery Piashchynski <[email protected]> | 2021-08-17 19:55:15 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-08-17 19:55:15 +0300 |
| commit | ab690ab9c6ae2b00aef1b501e8b17ff02b5da753 (patch) | |
| tree | 0a58b043605ef1d9b09e75b207c236aacb1ed55a /plugins/websockets/plugin.go | |
| parent | bd0da830ae345e1ed4a67782bf413673beeba037 (diff) | |
Update to go 1.17
Add Stat with tests
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'plugins/websockets/plugin.go')
| -rw-r--r-- | plugins/websockets/plugin.go | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/plugins/websockets/plugin.go b/plugins/websockets/plugin.go index ad371bf8..a7db0f83 100644 --- a/plugins/websockets/plugin.go +++ b/plugins/websockets/plugin.go @@ -118,7 +118,8 @@ func (p *Plugin) Serve() chan error { Supervisor: p.cfg.Pool.Supervisor, }, map[string]string{RrMode: "http", RrBroadcastPath: p.cfg.Path}) if err != nil { - errCh <- err + errCh <- errors.E(op, err) + return } p.accessValidator = p.defaultAccessValidator(p.phpPool) @@ -135,7 +136,7 @@ func (p *Plugin) Serve() chan error { default: data, err := ps.Next() if err != nil { - errCh <- err + errCh <- errors.E(op, err) return } p.workersPool.Queue(data) |