re
/
redis
forked from mirror/redis
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Change hooks to be LIFO

This commit is contained in:
Vladimir Mihailenco 2020-09-10 09:22:51 +03:00
parent f82e4988ec
commit 5aaa6c6207
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
redis.go
View File

@ -77,9 +77,9 @@ func (hs hooks) beforeProcess(ctx context.Context, cmd Cmder) (context.Context,
func (hs hooks) afterProcess(ctx context.Context, cmd Cmder) error { func (hs hooks) afterProcess(ctx context.Context, cmd Cmder) error {
var firstErr error var firstErr error
for _, h := range hs.hooks { for i := len(hs.hooks) - 1; i >= 0; i-- {
err := h.AfterProcess(ctx, cmd) h := hs.hooks[i]
if err != nil && firstErr == nil { if err := h.AfterProcess(ctx, cmd); err != nil && firstErr == nil {
firstErr = err firstErr = err
} }
} }
@ -118,9 +118,9 @@ func (hs hooks) beforeProcessPipeline(ctx context.Context, cmds []Cmder) (contex
func (hs hooks) afterProcessPipeline(ctx context.Context, cmds []Cmder) error { func (hs hooks) afterProcessPipeline(ctx context.Context, cmds []Cmder) error {
var firstErr error var firstErr error
for _, h := range hs.hooks { for i := len(hs.hooks) - 1; i >= 0; i-- {
err := h.AfterProcessPipeline(ctx, cmds) h := hs.hooks[i]
if err != nil && firstErr == nil { if err := h.AfterProcessPipeline(ctx, cmds); err != nil && firstErr == nil {
firstErr = err firstErr = err
} }
} }