Commit e44a6719 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 34fb46aa
...@@ -279,7 +279,7 @@ func (db *DB) Open(ctx context.Context, opt *ConnOptions) (_ *Connection, err er ...@@ -279,7 +279,7 @@ func (db *DB) Open(ctx context.Context, opt *ConnOptions) (_ *Connection, err er
// must be called with db.mu locked. // must be called with db.mu locked.
// db.mu is unlocked on error. // db.mu is unlocked on error.
func (db *DB) openOrDBUnlock(ctx context.Context, at Tid, noPool bool) (*Connection, error) { func (db *DB) openOrDBUnlock(ctx context.Context, at Tid, noPool bool) (*Connection, error) {
// NoPool connection - create anew // NoPool connection - create one anew
if noPool { if noPool {
conn := newConnection(db, at) conn := newConnection(db, at)
conn.noPool = true conn.noPool = true
...@@ -313,7 +313,7 @@ retry: ...@@ -313,7 +313,7 @@ retry:
// we have some δtail coverage, but at is ahead of that. // we have some δtail coverage, but at is ahead of that.
if at > δhead { if at > δhead {
// wait till .δtail.head is up to date covering ≥ at // wait till δtail.head is up to date covering ≥ at,
// and retry the loop (δtail.tail might go over at while we are waiting) // and retry the loop (δtail.tail might go over at while we are waiting)
δready := make(chan struct{}) δready := make(chan struct{})
db.δwait[δwaiter{at, δready}] = struct{}{} db.δwait[δwaiter{at, δready}] = struct{}{}
......
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