Commit 5f353dfb authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 68e5de9a
...@@ -620,6 +620,12 @@ func openClientByURL(ctx context.Context, u *url.URL, opt *zodb.DriverOptions) ( ...@@ -620,6 +620,12 @@ func openClientByURL(ctx context.Context, u *url.URL, opt *zodb.DriverOptions) (
errq := make(chan error, 1) errq := make(chan error, 1)
go func() { go func() {
err := c.Run(context.Background()) // NOTE not ctx err := c.Run(context.Background()) // NOTE not ctx
// Client.Close cancels talkMaster which makes Run to return
// `client: talk master(M): context canceled`
// do not propagate this error ZODB-level user.
if errors.Is(err, context.Canceled) {
err = nil
}
// close .watchq after serve is over // close .watchq after serve is over
c.at0Mu.Lock() c.at0Mu.Lock()
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment