1 write to InvocationId
Microsoft.AspNetCore.SignalR.Common (1)
Protocol\HubInvocationMessage.cs (1)
29
InvocationId
= invocationId;
44 references to InvocationId
Microsoft.AspNetCore.Components.Server (6)
src\aspnetcore\src\SignalR\common\Protocols.MessagePack\src\Protocol\MessagePackHubProtocolWorker.cs (6)
431
if (string.IsNullOrEmpty(message.
InvocationId
))
437
writer.Write(message.
InvocationId
);
463
writer.Write(message.
InvocationId
);
487
writer.Write(message.
InvocationId
);
535
writer.Write(message.
InvocationId
);
553
writer.Write(message.
InvocationId
);
Microsoft.AspNetCore.SignalR.Common (8)
Protocol\CompletionMessage.cs (2)
54
return $"Completion {{ {nameof(
InvocationId
)}: \"{
InvocationId
}\", {nameof(Error)}: {errorStr}{resultField} }}";
Protocol\HubMethodInvocationMessage.cs (4)
120
return $"InvocationMessage {{ {nameof(
InvocationId
)}: \"{
InvocationId
}\", {nameof(Target)}: \"{Target}\", {nameof(Arguments)}: [ {args} ], {nameof(StreamIds)}: [ {streamIds} ] }}";
175
return $"StreamInvocation {{ {nameof(
InvocationId
)}: \"{
InvocationId
}\", {nameof(Target)}: \"{Target}\", {nameof(Arguments)}: [ {args} ], {nameof(StreamIds)}: [ {streamIds} ] }}";
Protocol\StreamItemMessage.cs (2)
29
return $"StreamItem {{ {nameof(
InvocationId
)}: \"{
InvocationId
}\", {nameof(Item)}: {Item ?? "<<null>>"} }}";
Microsoft.AspNetCore.SignalR.Core (28)
Internal\DefaultHubDispatcher.cs (20)
163
Log.DroppingMessage(_logger, hubMessage.GetType().Name, (hubMessage as HubInvocationMessage)?.
InvocationId
?? "(null)");
186
if (connection.ActiveRequestCancellationSources.TryGetValue(cancelInvocationMessage.
InvocationId
!, out var cts))
188
Log.CancelStream(_logger, cancelInvocationMessage.
InvocationId
!);
213
else if (_hubLifetimeManager.TryGetReturnType(completionMessage.
InvocationId
!, out _))
219
Log.UnexpectedCompletion(_logger, completionMessage.
InvocationId
!);
251
return SendInvocationError(bindingFailureMessage.
InvocationId
, connection, errorMessage);
289
if (!string.IsNullOrEmpty(hubMethodInvocationMessage.
InvocationId
))
293
hubMethodInvocationMessage.
InvocationId
, $"Unknown hub method '{hubMethodInvocationMessage.Target}'")).AsTask();
336
await SendInvocationError(hubMethodInvocationMessage.
InvocationId
, connection,
354
await SendInvocationError(hubMethodInvocationMessage.
InvocationId
, connection,
380
_ = StreamAsync(hubMethodInvocationMessage.
InvocationId
!, connection, arguments, scope, hubActivator, hub, cts, hubMethodInvocationMessage, descriptor);
413
Log.SendingResult(logger, hubMethodInvocationMessage.
InvocationId
, methodExecutor);
420
await SendInvocationError(hubMethodInvocationMessage.
InvocationId
, connection,
442
if (!string.IsNullOrEmpty(hubMethodInvocationMessage.
InvocationId
))
445
await connection.WriteAsync(CompletionMessage.WithResult(hubMethodInvocationMessage.
InvocationId
, result));
467
await SendInvocationError(hubMethodInvocationMessage.
InvocationId
, connection,
473
await SendInvocationError(hubMethodInvocationMessage.
InvocationId
, connection,
696
if (!string.IsNullOrEmpty(hubMethodInvocationMessage.
InvocationId
))
699
await connection.WriteAsync(CompletionMessage.WithError(hubMethodInvocationMessage.
InvocationId
,
709
await 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)
54
if (_pendingInvocations.TryGetValue(message.
InvocationId
!, out var item))
58
throw new InvalidOperationException($"Connection ID '{connectionId}' is not valid for invocation ID '{message.
InvocationId
}'.");
64
if (_pendingInvocations.Remove(message.
InvocationId
!, out _))
StreamTracker.cs (2)
54
if (TryGetConverter(message.
InvocationId
!, out var converter))
76
_lookup.TryRemove(message.
InvocationId
!, out var converter);
Microsoft.AspNetCore.SignalR.Protocols.Json (2)
Protocol\JsonHubProtocol.cs (2)
717
if (!string.IsNullOrEmpty(message.
InvocationId
))
719
writer.WriteString(InvocationIdPropertyNameBytes, message.
InvocationId
);