1 write to RequestId
NuGet.Protocol (1)
Plugins\Messages\Message.cs (1)
93RequestId = requestId;
31 references to RequestId
NuGet.Protocol (31)
Plugins\AutomaticProgressReporter.cs (1)
178_request.RequestId,
Plugins\Connection.cs (3)
249_logger.Write(new CommunicationLogMessage(_logger.Now, message.RequestId, message.Method, message.Type, MessageState.Sending)); 256_logger.Write(new CommunicationLogMessage(_logger.Now, message.RequestId, message.Method, message.Type, MessageState.Sent)); 301_logger.Write(new CommunicationLogMessage(_logger.Now, e.Message.RequestId, e.Message.Method, e.Message.Type, MessageState.Received));
Plugins\InboundRequestContext.cs (8)
109_logger.Write(new TaskLogMessage(_logger.Now, request.RequestId, request.Method, request.Type, TaskState.Executing)); 120var response = MessageUtilities.Create(request.RequestId, MessageType.Cancel, request.Method); 132_logger.Write(new TaskLogMessage(_logger.Now, request.RequestId, request.Method, request.Type, TaskState.Completed)); 186request.RequestId, 193_logger.Write(new TaskLogMessage(_logger.Now, response.RequestId, response.Method, response.Type, TaskState.Queued)); 203_logger.Write(new TaskLogMessage(_logger.Now, response.RequestId, response.Method, response.Type, TaskState.Executing)); 215_logger.Write(new TaskLogMessage(_logger.Now, response.RequestId, response.Method, response.Type, TaskState.Completed)); 256_logger.Write(new TaskLogMessage(_logger.Now, request.RequestId, request.Method, request.Type, TaskState.Queued));
Plugins\MessageDispatcher.cs (14)
387if (!_inboundRequestContexts.TryGetValue(request.RequestId, out requestContext)) 392var message = MessageUtilities.Create(request.RequestId, type, request.Method, payload); 400RemoveInboundRequestContext(request.RequestId); 409var message = MessageUtilities.Create(request.RequestId, MessageType.Cancel, request.Method); 432message = new Message(request.RequestId, MessageType.Fault, request.Method, fault); 444var message = MessageUtilities.Create(request.RequestId, MessageType.Progress, request.Method, progress); 454var requestContext = GetOutboundRequestContext(response.RequestId); 477_outboundRequestContexts.TryAdd(message.RequestId, requestContext); 496_logger.Write(new CommunicationLogMessage(_logger.Now, message.RequestId, message.Method, message.Type, MessageState.Cancelled)); 514RemoveOutboundRequestContext(message.RequestId); 537if (_outboundRequestContexts.TryGetValue(e.Message.RequestId, out requestContext)) 595if (_inboundRequestContexts.TryGetValue(message.RequestId, out requestContext)) 633_inboundRequestContexts.TryAdd(message.RequestId, requestContext); 695message.RequestId,
Plugins\OutboundRequestContext`1.cs (5)
108RequestId = request.RequestId; 246Debug.WriteLine($"Request {_request.RequestId} timed out."); 259_logger.Write(new TaskLogMessage(_logger.Now, _request.RequestId, _request.Method, MessageType.Cancel, TaskState.Queued)); 269_logger.Write(new TaskLogMessage(_logger.Now, _request.RequestId, _request.Method, MessageType.Cancel, TaskState.Executing)); 281_logger.Write(new TaskLogMessage(_logger.Now, _request.RequestId, _request.Method, MessageType.Cancel, TaskState.Completed));