Skip to content

Commit 7577bed

Browse files
author
Divjot Arora
committed
rebase fix
1 parent bdf2e7d commit 7577bed

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

x/mongo/driver/topology/connection_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -116,7 +116,7 @@ func TestConnection(t *testing.T) {
116116
assert.Equal(t, want, got, "expected error %v, got %v", want, got)
117117
})
118118
t.Run("cancelConnectContext is nil after connect", func(t *testing.T) {
119-
conn, err := newConnection(context.Background(), address.Address(""))
119+
conn, err := newConnection(address.Address(""))
120120
assert.Nil(t, err, "newConnection shouldn't error. got %v; want nil", err)
121121
var wg sync.WaitGroup
122122
wg.Add(1)

x/mongo/driver/topology/rtt_monitor.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,7 @@ func (r *rttMonitor) setupRttConnection() error {
119119
}
120120

121121
func (r *rttMonitor) pingServer() {
122-
if r.conn == nil || r.conn.expired() {
122+
if r.conn == nil || r.conn.closed() {
123123
if err := r.setupRttConnection(); err != nil {
124124
return
125125
}

0 commit comments

Comments
 (0)