Function TestConn_UsedAtUpdatedOnRead

internal/pool/conn_used_at_test.go:13–53

TestConn_UsedAtUpdatedOnRead verifies that usedAt is updated when reading from connection

(t *testing.T)

// TestConn_UsedAtUpdatedOnRead verifies that usedAt is updated when reading from connection
func TestConn_UsedAtUpdatedOnRead(t *testing.T) {
	// Create a mock connection
	server, client := net.Pipe()
	defer server.Close()
	defer client.Close()

	cn := NewConn(client)
	defer cn.Close()

	// Get initial usedAt time
	initialUsedAt := cn.UsedAt()

	// Wait 100ms to ensure time difference (usedAt has ~50ms precision from cached time)
	time.Sleep(100 * time.Millisecond)

	// Simulate a read operation by calling WithReader
	ctx := context.Background()
	err := cn.WithReader(ctx, time.Second, func(rd *proto.Reader) error {
		// Don't actually read anything, just trigger the deadline update
		return nil
	})

	if err != nil {
		t.Fatalf("WithReader failed: %v", err)
	}

	// Get updated usedAt time
	updatedUsedAt := cn.UsedAt()

	// Verify that usedAt was updated
	if !updatedUsedAt.After(initialUsedAt) {
		t.Errorf("Expected usedAt to be updated after read. Initial: %v, Updated: %v",
			initialUsedAt, updatedUsedAt)
	}

	// Verify the difference is reasonable (should be around 100ms, accounting for ~50ms cache precision and ~5ms sleep precision)
	diff := updatedUsedAt.Sub(initialUsedAt)
	if diff < 45*time.Millisecond || diff > 155*time.Millisecond {
		t.Errorf("Expected usedAt difference to be around 100ms (±50ms for cache, ±5ms for sleep), got %v", diff)
	}
}

// TestConn_UsedAtUpdatedOnWrite verifies that usedAt is updated when writing to connection
func TestConn_UsedAtUpdatedOnWrite(t *testing.T) {