1 write to RequestId
NuGet.Protocol (1)
Plugins\Messages\Message.cs (1)
93RequestId = requestId;
36 references to RequestId
NuGet.Protocol (36)
Plugins\AutomaticProgressReporter.cs (1)
176_request.RequestId,
Plugins\Connection.cs (3)
247_logger.Write(new CommunicationLogMessage(_logger.Now, message.RequestId, message.Method, message.Type, MessageState.Sending)); 254_logger.Write(new CommunicationLogMessage(_logger.Now, message.RequestId, message.Method, message.Type, MessageState.Sent)); 299_logger.Write(new CommunicationLogMessage(_logger.Now, e.Message.RequestId, e.Message.Method, e.Message.Type, MessageState.Received));
Plugins\InboundRequestContext.cs (8)
107_logger.Write(new TaskLogMessage(_logger.Now, request.RequestId, request.Method, request.Type, TaskState.Executing)); 118var response = MessageUtilities.Create(request.RequestId, MessageType.Cancel, request.Method); 130_logger.Write(new TaskLogMessage(_logger.Now, request.RequestId, request.Method, request.Type, TaskState.Completed)); 184request.RequestId, 191_logger.Write(new TaskLogMessage(_logger.Now, response.RequestId, response.Method, response.Type, TaskState.Queued)); 201_logger.Write(new TaskLogMessage(_logger.Now, response.RequestId, response.Method, response.Type, TaskState.Executing)); 213_logger.Write(new TaskLogMessage(_logger.Now, response.RequestId, response.Method, response.Type, TaskState.Completed)); 254_logger.Write(new TaskLogMessage(_logger.Now, request.RequestId, request.Method, request.Type, TaskState.Queued));
Plugins\MessageConverter.cs (5)
108if (!root.TryGetProperty(nameof(Message.RequestId), out var requestIdProp)) 110throw new JsonException(string.Format(CultureInfo.CurrentCulture, Strings.Error_RequiredJsonPropertyMissing, nameof(Message.RequestId))); 116throw new JsonException(string.Format(CultureInfo.CurrentCulture, Strings.ArgumentCannotBeNullOrEmpty, nameof(Message.RequestId))); 173writer.WriteString(nameof(Message.RequestId), value.RequestId);
Plugins\MessageDispatcher.cs (14)
386if (!_inboundRequestContexts.TryGetValue(request.RequestId, out _)) 391var message = MessageUtilities.Create(request.RequestId, type, request.Method, payload); 399RemoveInboundRequestContext(request.RequestId); 408var message = MessageUtilities.Create(request.RequestId, MessageType.Cancel, request.Method); 431message = new Message(request.RequestId, MessageType.Fault, request.Method, fault); 443var message = MessageUtilities.Create(request.RequestId, MessageType.Progress, request.Method, progress); 453var requestContext = GetOutboundRequestContext(response.RequestId); 476_outboundRequestContexts.TryAdd(message.RequestId, requestContext); 495_logger.Write(new CommunicationLogMessage(_logger.Now, message.RequestId, message.Method, message.Type, MessageState.Cancelled)); 513RemoveOutboundRequestContext(message.RequestId); 534if (_outboundRequestContexts.TryGetValue(e.Message.RequestId, out var requestContext)) 590if (_inboundRequestContexts.TryGetValue(message.RequestId, out var requestContext)) 632_inboundRequestContexts.TryAdd(message.RequestId, requestContext); 686message.RequestId,
Plugins\OutboundRequestContext`1.cs (5)
109RequestId = request.RequestId; 260Debug.WriteLine($"Request {_request.RequestId} timed out."); 273_logger.Write(new TaskLogMessage(_logger.Now, _request.RequestId, _request.Method, MessageType.Cancel, TaskState.Queued)); 283_logger.Write(new TaskLogMessage(_logger.Now, _request.RequestId, _request.Method, MessageType.Cancel, TaskState.Executing)); 295_logger.Write(new TaskLogMessage(_logger.Now, _request.RequestId, _request.Method, MessageType.Cancel, TaskState.Completed));