1 write to InvocationId
Microsoft.AspNetCore.SignalR.Common (1)
Protocol\HubInvocationMessage.cs (1)
29InvocationId = invocationId;
101 references to InvocationId
Microsoft.AspNetCore.Components.Server (6)
src\aspnetcore\src\SignalR\common\Protocols.MessagePack\src\Protocol\MessagePackHubProtocolWorker.cs (6)
431if (string.IsNullOrEmpty(message.InvocationId)) 437writer.Write(message.InvocationId); 463writer.Write(message.InvocationId); 487writer.Write(message.InvocationId); 535writer.Write(message.InvocationId); 553writer.Write(message.InvocationId);
Microsoft.AspNetCore.SignalR.Client.Core (19)
HubConnection.cs (17)
1303Log.ArgumentBindingFailure(_logger, bindingFailure.InvocationId, bindingFailure.Target, bindingFailure.BindingFailure.SourceException); 1305if (!string.IsNullOrEmpty(bindingFailure.InvocationId)) 1307await SendWithLock(connectionState, CompletionMessage.WithError(bindingFailure.InvocationId, "Client failed to parse argument(s)."), cancellationToken: default).ConfigureAwait(false); 1315Log.ReceivedInvocation(_logger, invocation.InvocationId, invocation.Target, invocation.Arguments); 1319if (!connectionState.TryRemoveInvocation(completion.InvocationId!, out irq)) 1321Log.DroppedCompletionMessage(_logger, completion.InvocationId!); 1331if (!connectionState.TryGetInvocation(streamItem.InvocationId!, out irq)) 1333Log.DroppedStreamMessage(_logger, streamItem.InvocationId!); 1376var expectsResult = !string.IsNullOrEmpty(invocation.InvocationId); 1385await SendWithLock(connectionState, CompletionMessage.WithError(invocation.InvocationId!, "Client didn't provide a result."), cancellationToken: default).ConfigureAwait(false); 1389Log.ErrorSendingInvocationResult(_logger, invocation.InvocationId!, invocation.Target, ex); 1435await SendWithLock(connectionState, CompletionMessage.WithError(invocation.InvocationId!, resultException.Message), cancellationToken: default).ConfigureAwait(false); 1439await SendWithLock(connectionState, CompletionMessage.WithResult(invocation.InvocationId!, result), cancellationToken: default).ConfigureAwait(false); 1444await SendWithLock(connectionState, CompletionMessage.WithError(invocation.InvocationId!, "Client didn't provide a result."), cancellationToken: default).ConfigureAwait(false); 1449Log.ErrorSendingInvocationResult(_logger, invocation.InvocationId!, invocation.Target, ex); 1626if (string.IsNullOrEmpty(invocationMessage.InvocationId)) 2327Log.DroppingMessage(_logger, ((HubInvocationMessage)message).GetType().Name, ((HubInvocationMessage)message).InvocationId);
HubConnection.Log.cs (2)
42SendingMessage(logger, message.GetType().Name, invocationMessage.InvocationId); 63MessageSent(logger, message.GetType().Name, invocationMessage.InvocationId);
Microsoft.AspNetCore.SignalR.Common (8)
Protocol\CompletionMessage.cs (2)
54return $"Completion {{ {nameof(InvocationId)}: \"{InvocationId}\", {nameof(Error)}: {errorStr}{resultField} }}";
Protocol\HubMethodInvocationMessage.cs (4)
120return $"InvocationMessage {{ {nameof(InvocationId)}: \"{InvocationId}\", {nameof(Target)}: \"{Target}\", {nameof(Arguments)}: [ {args} ], {nameof(StreamIds)}: [ {streamIds} ] }}"; 175return $"StreamInvocation {{ {nameof(InvocationId)}: \"{InvocationId}\", {nameof(Target)}: \"{Target}\", {nameof(Arguments)}: [ {args} ], {nameof(StreamIds)}: [ {streamIds} ] }}";
Protocol\StreamItemMessage.cs (2)
29return $"StreamItem {{ {nameof(InvocationId)}: \"{InvocationId}\", {nameof(Item)}: {Item ?? "<<null>>"} }}";
Microsoft.AspNetCore.SignalR.Core (28)
Internal\DefaultHubDispatcher.cs (20)
163Log.DroppingMessage(_logger, hubMessage.GetType().Name, (hubMessage as HubInvocationMessage)?.InvocationId ?? "(null)"); 186if (connection.ActiveRequestCancellationSources.TryGetValue(cancelInvocationMessage.InvocationId!, out var cts)) 188Log.CancelStream(_logger, cancelInvocationMessage.InvocationId!); 213else if (_hubLifetimeManager.TryGetReturnType(completionMessage.InvocationId!, out _)) 219Log.UnexpectedCompletion(_logger, completionMessage.InvocationId!); 251return SendInvocationError(bindingFailureMessage.InvocationId, connection, errorMessage); 289if (!string.IsNullOrEmpty(hubMethodInvocationMessage.InvocationId)) 293hubMethodInvocationMessage.InvocationId, $"Unknown hub method '{hubMethodInvocationMessage.Target}'")).AsTask(); 336await SendInvocationError(hubMethodInvocationMessage.InvocationId, connection, 354await SendInvocationError(hubMethodInvocationMessage.InvocationId, connection, 380_ = StreamAsync(hubMethodInvocationMessage.InvocationId!, connection, arguments, scope, hubActivator, hub, cts, hubMethodInvocationMessage, descriptor); 413Log.SendingResult(logger, hubMethodInvocationMessage.InvocationId, methodExecutor); 420await SendInvocationError(hubMethodInvocationMessage.InvocationId, connection, 442if (!string.IsNullOrEmpty(hubMethodInvocationMessage.InvocationId)) 445await connection.WriteAsync(CompletionMessage.WithResult(hubMethodInvocationMessage.InvocationId, result)); 467await SendInvocationError(hubMethodInvocationMessage.InvocationId, connection, 473await SendInvocationError(hubMethodInvocationMessage.InvocationId, connection, 696if (!string.IsNullOrEmpty(hubMethodInvocationMessage.InvocationId)) 699await connection.WriteAsync(CompletionMessage.WithError(hubMethodInvocationMessage.InvocationId, 709await connection.WriteAsync(CompletionMessage.WithError(hubMethodInvocationMessage.InvocationId!,
Internal\DefaultHubDispatcherLog.cs (3)
75=> ReceivedStreamItem(logger, message.InvocationId); 84=> CompletingStream(logger, message.InvocationId); 90=> ClosingStreamWithBindingError(logger, message.InvocationId, message.Error);
src\aspnetcore\src\SignalR\common\Shared\ClientResultsManager.cs (3)
54if (_pendingInvocations.TryGetValue(message.InvocationId!, out var item)) 58throw new InvalidOperationException($"Connection ID '{connectionId}' is not valid for invocation ID '{message.InvocationId}'."); 64if (_pendingInvocations.Remove(message.InvocationId!, out _))
StreamTracker.cs (2)
54if (TryGetConverter(message.InvocationId!, out var converter)) 76_lookup.TryRemove(message.InvocationId!, out var converter);
Microsoft.AspNetCore.SignalR.Protocols.Json (2)
Protocol\JsonHubProtocol.cs (2)
717if (!string.IsNullOrEmpty(message.InvocationId)) 719writer.WriteString(InvocationIdPropertyNameBytes, message.InvocationId);
Microsoft.AspNetCore.SignalR.Protocols.MessagePack (6)
Protocol\MessagePackHubProtocolWorker.cs (6)
431if (string.IsNullOrEmpty(message.InvocationId)) 437writer.Write(message.InvocationId); 463writer.Write(message.InvocationId); 487writer.Write(message.InvocationId); 535writer.Write(message.InvocationId); 553writer.Write(message.InvocationId);
Microsoft.AspNetCore.SignalR.Protocols.NewtonsoftJson (2)
Protocol\NewtonsoftJsonHubProtocol.cs (2)
696if (!string.IsNullOrEmpty(message.InvocationId)) 699writer.WriteValue(message.InvocationId);
Microsoft.AspNetCore.SignalR.Specification.Tests (24)
HubLifetimeManagerTestBase.cs (11)
191Assert.NotNull(invocation.InvocationId); 194await manager.SetConnectionResultAsync(connection1.ConnectionId, CompletionMessage.WithResult(invocation.InvocationId, 10)).DefaultTimeout(); 218Assert.NotNull(invocation.InvocationId); 221await manager.SetConnectionResultAsync(connection1.ConnectionId, CompletionMessage.WithError(invocation.InvocationId, "Error from client")).DefaultTimeout(); 248Assert.NotNull(invocation.InvocationId); 252manager.SetConnectionResultAsync(connection2.ConnectionId, CompletionMessage.WithError(invocation.InvocationId, "Error from client"))).DefaultTimeout(); 254Assert.Equal($"Connection ID '{connection2.ConnectionId}' is not valid for invocation ID '{invocation.InvocationId}'.", ex.Message); 257await manager.SetConnectionResultAsync(connection1.ConnectionId, CompletionMessage.WithResult(invocation.InvocationId, 10)).DefaultTimeout(); 307await manager1.SetConnectionResultAsync(connection2.ConnectionId, CompletionMessage.WithError(invocation2.InvocationId, "error")); 312await manager1.SetConnectionResultAsync(connection1.ConnectionId, CompletionMessage.WithResult(invocation1.InvocationId, 3)); 365await manager1.SetConnectionResultAsync(connection1.ConnectionId, CompletionMessage.WithResult(invocation1.InvocationId, 1));
ScaleoutHubLifetimeManagerTests.cs (10)
487Assert.NotNull(invocation.InvocationId); 491await manager1.SetConnectionResultAsync(connection1.ConnectionId, CompletionMessage.WithResult(invocation.InvocationId, 10)).DefaultTimeout(); 518Assert.NotNull(invocation.InvocationId); 522await manager1.SetConnectionResultAsync(connection1.ConnectionId, CompletionMessage.WithError(invocation.InvocationId, "Error from client")).DefaultTimeout(); 603Assert.NotEqual(invocation1.InvocationId, invocation2.InvocationId); 605await manager1.SetConnectionResultAsync(connection.ConnectionId, CompletionMessage.WithResult(invocation2.InvocationId, 2)).DefaultTimeout(); 606await manager2.SetConnectionResultAsync(connection.ConnectionId, CompletionMessage.WithResult(invocation1.InvocationId, 5)).DefaultTimeout(); 650Assert.NotNull(invocation.InvocationId); 654await manager1.SetConnectionResultAsync(connection1.ConnectionId, CompletionMessage.WithResult(invocation.InvocationId, "wrong type")).DefaultTimeout();
src\aspnetcore\src\SignalR\common\testassets\Tests.Utils\TestClient.cs (3)
129if (message is HubInvocationMessage hubInvocationMessage && !string.Equals(hubInvocationMessage.InvocationId, invocationId)) 162if (message is HubInvocationMessage hubInvocationMessage && !string.Equals(hubInvocationMessage.InvocationId, invocationId)) 237return message is HubInvocationMessage hubMessage ? hubMessage.InvocationId : null;
Microsoft.AspNetCore.SignalR.StackExchangeRedis (6)
RedisHubLifetimeManager.cs (3)
565RedisLog.ErrorForwardingResult(_logger, completionMessage.InvocationId!, ex); 701var invocationInfo = _clientResultsManager.RemoveInvocation(((CompletionMessage)hubMessage!).InvocationId!); 705hubMessage = CompletionMessage.WithError(((CompletionMessage)hubMessage!).InvocationId!, $"Client result wasn't deserializable to {invocationInfo?.Type.Name}.");
src\aspnetcore\src\SignalR\common\Shared\ClientResultsManager.cs (3)
54if (_pendingInvocations.TryGetValue(message.InvocationId!, out var item)) 58throw new InvalidOperationException($"Connection ID '{connectionId}' is not valid for invocation ID '{message.InvocationId}'."); 64if (_pendingInvocations.Remove(message.InvocationId!, out _))