GODRIVER-3173 Update APR

Author: prestonvasquez

bson/default_value_encoders.go

@@ -9,6 +9,7 @@ package bson
 import (
 	"encoding/json"
 	"errors"
+	"fmt"
 	"math"
 	"net/url"
 	"reflect"
@@ -165,6 +166,7 @@ func decimal128EncodeValue(_ EncodeContext, vw ValueWriter, val reflect.Value) e
 	if !val.IsValid() || val.Type() != tDecimal {
 		return ValueEncoderError{Name: "Decimal128EncodeValue", Types: []reflect.Type{tDecimal}, Received: val}
 	}
+	fmt.Println(val.Interface().(Decimal128))
 	return vw.WriteDecimal128(val.Interface().(Decimal128))
 }
 

internal/integration/csot_prose_test.go

@@ -176,6 +176,7 @@ func TestCSOTProse(t *testing.T) {
 				time.Millisecond,
 				"expected ping to fail within 150ms")
 		})
+
 	})
 
 	mt.RunOpts("11. multi-batch bulkWrites", mtest.NewOptions().MinServerVersion("8.0").
@@ -232,6 +233,9 @@ func TestCSOTProse(t *testing.T) {
 		assert.ErrorIs(mt, err, context.DeadlineExceeded, "expected a timeout error, got: %v", err)
 		assert.Equal(mt, 2, cnt, "expected bulkWrite calls: %d, got: %d", 2, cnt)
 	})
+
+	//mt.Run("pending read", func(mt *mtest.T) {
+	//})
 }
 
 func TestCSOTProse_GridFS(t *testing.T) {

internal/integration/unified/unified_spec_runner.go

@@ -122,6 +122,8 @@ func runTestFile(t *testing.T, filepath string, expectValidFail bool, opts ...*O
 			defer func() {
 				// catch panics from looking up elements and fail if it's unexpected
 				if r := recover(); r != nil {
+
+					panic(r)
 					if !expectValidFail {
 						mt.Fatal(r)
 					}

x/mongo/driver/topology/connection.go

@@ -51,6 +51,7 @@ type pendingReadState struct {
 	remainingBytes int32
 	requestID      int32
 	remainingTime  *time.Duration
+	start          time.Time
 }
 
 type connection struct {
@@ -490,12 +491,13 @@ func (c *connection) read(ctx context.Context) (bytesRead []byte, errMsg string,
 		if l := int32(n); l == 0 && isCSOTTimeout(err) && driverutil.HasMaxTimeMS(ctx) {
 			requestID, _ := driverutil.GetRequestID(ctx)
 
-			c.pendingReadMu.Lock()
+			//c.pendingReadMu.Lock()
 			c.pendingReadState = &pendingReadState{
 				remainingBytes: l,
 				requestID:      requestID,
+				start:          time.Now(),
 			}
-			c.pendingReadMu.Unlock()
+			//c.pendingReadMu.Unlock()
 		}
 		return nil, "incomplete read of message header", err
 	}
@@ -513,12 +515,13 @@ func (c *connection) read(ctx context.Context) (bytesRead []byte, errMsg string,
 		if remainingBytes > 0 && isCSOTTimeout(err) && driverutil.HasMaxTimeMS(ctx) {
 			requestID, _ := driverutil.GetRequestID(ctx)
 
-			c.pendingReadMu.Lock()
+			//c.pendingReadMu.Lock()
 			c.pendingReadState = &pendingReadState{
 				remainingBytes: remainingBytes,
 				requestID:      requestID,
+				start:          time.Now(),
 			}
-			c.pendingReadMu.Unlock()
+			//c.pendingReadMu.Unlock()
 		}
 		return dst, "incomplete read of full message", err
 	}