1 write to InvocationId
Microsoft.AspNetCore.SignalR.Common (1)
Protocol\HubInvocationMessage.cs (1)
29InvocationId = invocationId;
108 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)
1477Log.ArgumentBindingFailure(_logger, bindingFailure.InvocationId, bindingFailure.Target, bindingFailure.BindingFailure.SourceException); 1479if (!string.IsNullOrEmpty(bindingFailure.InvocationId)) 1481await SendWithLock(connectionState, CompletionMessage.WithError(bindingFailure.InvocationId, "Client failed to parse argument(s)."), cancellationToken: default).ConfigureAwait(false); 1489Log.ReceivedInvocation(_logger, invocation.InvocationId, invocation.Target, invocation.Arguments); 1493if (!connectionState.TryRemoveInvocation(completion.InvocationId!, out irq)) 1495Log.DroppedCompletionMessage(_logger, completion.InvocationId!); 1505if (!connectionState.TryGetInvocation(streamItem.InvocationId!, out irq)) 1507Log.DroppedStreamMessage(_logger, streamItem.InvocationId!); 1550var expectsResult = !string.IsNullOrEmpty(invocation.InvocationId); 1559await SendWithLock(connectionState, CompletionMessage.WithError(invocation.InvocationId!, "Client didn't provide a result."), cancellationToken: default).ConfigureAwait(false); 1563Log.ErrorSendingInvocationResult(_logger, invocation.InvocationId!, invocation.Target, ex); 1609await SendWithLock(connectionState, CompletionMessage.WithError(invocation.InvocationId!, resultException.Message), cancellationToken: default).ConfigureAwait(false); 1613await SendWithLock(connectionState, CompletionMessage.WithResult(invocation.InvocationId!, result), cancellationToken: default).ConfigureAwait(false); 1618await SendWithLock(connectionState, CompletionMessage.WithError(invocation.InvocationId!, "Client didn't provide a result."), cancellationToken: default).ConfigureAwait(false); 1623Log.ErrorSendingInvocationResult(_logger, invocation.InvocationId!, invocation.Target, ex); 1800if (string.IsNullOrEmpty(invocationMessage.InvocationId)) 2501Log.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 (35)
Internal\DefaultHubDispatcher.cs (27)
208Log.DroppingMessage(_logger, hubMessage.GetType().Name, (hubMessage as HubInvocationMessage)?.InvocationId ?? "(null)"); 231if (connection.ActiveRequestCancellationSources.TryGetValue(cancelInvocationMessage.InvocationId!, out var cts)) 233Log.CancelInvocation(_logger, cancelInvocationMessage.InvocationId!); 239Log.UnexpectedCancelWithId(_logger, cancelInvocationMessage.InvocationId!); 258else if (_hubLifetimeManager.TryGetReturnType(completionMessage.InvocationId!, out _)) 264Log.UnexpectedCompletion(_logger, completionMessage.InvocationId!); 296return SendInvocationError(bindingFailureMessage.InvocationId, connection, errorMessage); 334if (!string.IsNullOrEmpty(hubMethodInvocationMessage.InvocationId)) 338hubMethodInvocationMessage.InvocationId, $"Unknown hub method '{hubMethodInvocationMessage.Target}'")).AsTask(); 382await SendInvocationError(hubMethodInvocationMessage.InvocationId, connection, 400await SendInvocationError(hubMethodInvocationMessage.InvocationId, connection, 426_ = StreamAsync(hubMethodInvocationMessage.InvocationId!, connection, hubCallerContext, 460if (cts != null && !string.IsNullOrEmpty(hubMethodInvocationMessage.InvocationId)) 462if (!connection.ActiveRequestCancellationSources.TryAdd(hubMethodInvocationMessage.InvocationId!, cts)) 464Log.InvocationIdInUse(logger, hubMethodInvocationMessage.InvocationId); 465await SendInvocationError(hubMethodInvocationMessage.InvocationId, connection, 466$"Invocation ID '{hubMethodInvocationMessage.InvocationId}' is already in use."); 478Log.SendingResult(logger, hubMethodInvocationMessage.InvocationId, methodExecutor); 485await SendInvocationError(hubMethodInvocationMessage.InvocationId, connection, 502connection.ActiveRequestCancellationSources.TryRemove(hubMethodInvocationMessage.InvocationId!, out _); 517if (!string.IsNullOrEmpty(hubMethodInvocationMessage.InvocationId)) 520await connection.WriteAsync(CompletionMessage.WithResult(hubMethodInvocationMessage.InvocationId, result)); 542await SendInvocationError(hubMethodInvocationMessage.InvocationId, connection, 548await SendInvocationError(hubMethodInvocationMessage.InvocationId, connection, 797if (!string.IsNullOrEmpty(hubMethodInvocationMessage.InvocationId)) 800await connection.WriteAsync(CompletionMessage.WithError(hubMethodInvocationMessage.InvocationId, 810await 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 _))