api: more informative request canceling

Log the probable reason for unexpected requestId.
Add requestId info to context done error message.

Author: nurzhan-saktaganov

CHANGELOG.md

@@ -17,6 +17,8 @@ Versioning](http://semver.org/spec/v2.0.0.html) except to the first release.
 - Implemented stringer methods for pool.Role (#405).
 
 ### Changed
+- More informative request canceling: log the probable reason for unexpected requestId
+  and add requestId info to context done error message.
 
 ### Fixed
 

connection.go

@@ -100,7 +100,7 @@ func (d defaultLogger) Report(event ConnLogKind, conn *Connection, v ...interfac
 			conn.Addr(), err)
 	case LogUnexpectedResultId:
 		header := v[0].(Header)
-		log.Printf("tarantool: connection %s got unexpected resultId (%d) in response",
+		log.Printf("tarantool: connection %s got unexpected resultId (%d) in response (probably canceled request)",
 			conn.Addr(), header.RequestId)
 	case LogWatchEventReadFailed:
 		err := v[0].(error)
@@ -940,7 +940,7 @@ func (conn *Connection) newFuture(req Request) (fut *Future) {
 	if ctx != nil {
 		select {
 		case <-ctx.Done():
-			fut.SetError(fmt.Errorf("context is done"))
+			fut.SetError(fmt.Errorf("context is done (requestId %d)", fut.requestId))
 			shard.rmut.Unlock()
 			return
 		default:
@@ -982,7 +982,7 @@ func (conn *Connection) contextWatchdog(fut *Future, ctx context.Context) {
 	case <-fut.done:
 		return
 	default:
-		conn.cancelFuture(fut, fmt.Errorf("context is done"))
+		conn.cancelFuture(fut, fmt.Errorf("context is done (requestId %d)", fut.requestId))
 	}
 }
 
@@ -1008,7 +1008,7 @@ func (conn *Connection) send(req Request, streamId uint64) *Future {
 	if req.Ctx() != nil {
 		select {
 		case <-req.Ctx().Done():
-			conn.cancelFuture(fut, fmt.Errorf("context is done"))
+			conn.cancelFuture(fut, fmt.Errorf("context is done (requestId %d)", fut.requestId))
 			return fut
 		default:
 		}

example_test.go

@@ -166,7 +166,7 @@ func ExamplePingRequest_Context() {
 	fmt.Println("Ping Error", err)
 	// Output:
 	// Ping Resp data []
-	// Ping Error context is done
+	// Ping Error context is done (requestId 3)
 }
 
 func ExampleSelectRequest() {

tarantool_test.go

@@ -2731,7 +2731,7 @@ func TestClientRequestObjectsWithPassedCanceledContext(t *testing.T) {
 	req := NewPingRequest().Context(ctx)
 	cancel()
 	resp, err := conn.Do(req).Get()
-	if err.Error() != "context is done" {
+	if !strings.HasPrefix(err.Error(), "context is done") {
 		t.Fatalf("Failed to catch an error from done context")
 	}
 	if resp != nil {
@@ -2802,7 +2802,7 @@ func TestClientRequestObjectsWithContext(t *testing.T) {
 	if err == nil {
 		t.Fatalf("caught nil error")
 	}
-	if err.Error() != "context is done" {
+	if !strings.HasPrefix(err.Error(), "context is done") {
 		t.Fatalf("wrong error caught: %v", err)
 	}
 }
@@ -3295,7 +3295,7 @@ func TestClientIdRequestObjectWithPassedCanceledContext(t *testing.T) {
 	resp, err := conn.Do(req).Get()
 	require.Nilf(t, resp, "Response is empty")
 	require.NotNilf(t, err, "Error is not empty")
-	require.Equal(t, err.Error(), "context is done")
+	require.ErrorContains(t, err, "context is done")
 }
 
 func TestConnectionProtocolInfoUnsupported(t *testing.T) {