2 interfaces inheriting from INodePacket
Microsoft.Build (1)
src\msbuild\src\Shared\ITaskHostCallbackPacket.cs (1)
11
internal interface ITaskHostCallbackPacket :
INodePacket
MSBuild (1)
src\msbuild\src\Shared\ITaskHostCallbackPacket.cs (1)
11
internal interface ITaskHostCallbackPacket :
INodePacket
47 implementations of INodePacket
Microsoft.Build (29)
BackEnd\Components\BuildRequestEngine\BuildRequestConfigurationResponse.cs (1)
12
internal class BuildRequestConfigurationResponse :
INodePacket
BackEnd\Components\FileAccesses\FileAccessReport.cs (1)
9
internal sealed class FileAccessReport :
INodePacket
BackEnd\Components\FileAccesses\ProcessReport.cs (1)
9
internal sealed class ProcessReport :
INodePacket
BackEnd\Components\SdkResolution\SdkResolverRequest.cs (1)
15
internal sealed class SdkResolverRequest :
INodePacket
BackEnd\Components\SdkResolution\SdkResult.cs (1)
18
internal sealed class SdkResult : SdkResultBase,
INodePacket
BackEnd\Node\NodeConfiguration.cs (1)
18
internal class NodeConfiguration :
INodePacket
BackEnd\Node\ServerNodeBuildCancel.cs (1)
6
internal sealed class ServerNodeBuildCancel :
INodePacket
BackEnd\Node\ServerNodeBuildCommand.cs (1)
14
internal sealed class ServerNodeBuildCommand :
INodePacket
BackEnd\Node\ServerNodeBuildResult.cs (1)
6
internal sealed class ServerNodeBuildResult :
INodePacket
BackEnd\Node\ServerNodeConsoleWrite.cs (1)
6
internal sealed class ServerNodeConsoleWrite :
INodePacket
BackEnd\Shared\BuildRequest.cs (1)
21
internal class BuildRequest :
INodePacket
BackEnd\Shared\BuildRequestBlocker.cs (1)
39
internal class BuildRequestBlocker :
INodePacket
BackEnd\Shared\BuildRequestConfiguration.cs (1)
30
INodePacket
BackEnd\Shared\BuildRequestUnblocker.cs (1)
21
internal class BuildRequestUnblocker : ITranslatable,
INodePacket
BackEnd\Shared\BuildResult.cs (1)
38
public class BuildResult : BuildResultBase,
INodePacket
, IBuildResults
BackEnd\Shared\ResourceRequest.cs (1)
9
internal sealed class ResourceRequest :
INodePacket
BackEnd\Shared\ResourceResponse.cs (1)
9
internal sealed class ResourceResponse :
INodePacket
src\msbuild\src\Shared\LogMessagePacketBase.cs (1)
264
internal class LogMessagePacketBase :
INodePacket
src\msbuild\src\Shared\NodeBuildComplete.cs (1)
13
internal class NodeBuildComplete :
INodePacket
src\msbuild\src\Shared\NodeShutdown.cs (1)
36
internal class NodeShutdown :
INodePacket
src\msbuild\src\Shared\TaskHostBuildRequest.cs (1)
15
internal class TaskHostBuildRequest :
INodePacket
, ITaskHostCallbackPacket
src\msbuild\src\Shared\TaskHostBuildResponse.cs (1)
14
internal class TaskHostBuildResponse :
INodePacket
, ITaskHostCallbackPacket
src\msbuild\src\Shared\TaskHostConfiguration.cs (1)
18
internal class TaskHostConfiguration :
INodePacket
src\msbuild\src\Shared\TaskHostCoresRequest.cs (1)
11
internal class TaskHostCoresRequest :
INodePacket
, ITaskHostCallbackPacket
src\msbuild\src\Shared\TaskHostCoresResponse.cs (1)
11
internal class TaskHostCoresResponse :
INodePacket
, ITaskHostCallbackPacket
src\msbuild\src\Shared\TaskHostIsRunningMultipleNodesRequest.cs (1)
9
internal class TaskHostIsRunningMultipleNodesRequest :
INodePacket
, ITaskHostCallbackPacket
src\msbuild\src\Shared\TaskHostIsRunningMultipleNodesResponse.cs (1)
9
internal class TaskHostIsRunningMultipleNodesResponse :
INodePacket
, ITaskHostCallbackPacket
src\msbuild\src\Shared\TaskHostTaskCancelled.cs (1)
11
internal class TaskHostTaskCancelled :
INodePacket
src\msbuild\src\Shared\TaskHostTaskComplete.cs (1)
53
internal class TaskHostTaskComplete :
INodePacket
Microsoft.Build.Tasks.Core (6)
AssemblyDependency\Node\RarNodeBufferedLogEvents.cs (1)
13
internal class RarNodeBufferedLogEvents :
INodePacket
AssemblyDependency\Node\RarNodeExecuteRequest.cs (1)
15
internal sealed class RarNodeExecuteRequest :
INodePacket
AssemblyDependency\Node\RarNodeExecuteResponse.cs (1)
16
internal sealed class RarNodeExecuteResponse :
INodePacket
src\msbuild\src\Shared\LogMessagePacketBase.cs (1)
264
internal class LogMessagePacketBase :
INodePacket
src\msbuild\src\Shared\NodeBuildComplete.cs (1)
13
internal class NodeBuildComplete :
INodePacket
src\msbuild\src\Shared\NodeShutdown.cs (1)
36
internal class NodeShutdown :
INodePacket
MSBuild (12)
src\msbuild\src\Shared\LogMessagePacketBase.cs (1)
264
internal class LogMessagePacketBase :
INodePacket
src\msbuild\src\Shared\NodeBuildComplete.cs (1)
13
internal class NodeBuildComplete :
INodePacket
src\msbuild\src\Shared\NodeShutdown.cs (1)
36
internal class NodeShutdown :
INodePacket
src\msbuild\src\Shared\TaskHostBuildRequest.cs (1)
15
internal class TaskHostBuildRequest :
INodePacket
, ITaskHostCallbackPacket
src\msbuild\src\Shared\TaskHostBuildResponse.cs (1)
14
internal class TaskHostBuildResponse :
INodePacket
, ITaskHostCallbackPacket
src\msbuild\src\Shared\TaskHostConfiguration.cs (1)
18
internal class TaskHostConfiguration :
INodePacket
src\msbuild\src\Shared\TaskHostCoresRequest.cs (1)
11
internal class TaskHostCoresRequest :
INodePacket
, ITaskHostCallbackPacket
src\msbuild\src\Shared\TaskHostCoresResponse.cs (1)
11
internal class TaskHostCoresResponse :
INodePacket
, ITaskHostCallbackPacket
src\msbuild\src\Shared\TaskHostIsRunningMultipleNodesRequest.cs (1)
9
internal class TaskHostIsRunningMultipleNodesRequest :
INodePacket
, ITaskHostCallbackPacket
src\msbuild\src\Shared\TaskHostIsRunningMultipleNodesResponse.cs (1)
9
internal class TaskHostIsRunningMultipleNodesResponse :
INodePacket
, ITaskHostCallbackPacket
src\msbuild\src\Shared\TaskHostTaskCancelled.cs (1)
11
internal class TaskHostTaskCancelled :
INodePacket
src\msbuild\src\Shared\TaskHostTaskComplete.cs (1)
53
internal class TaskHostTaskComplete :
INodePacket
194 references to INodePacket
Microsoft.Build (130)
BackEnd\BuildManager\BuildManager.cs (4)
1521
void INodePacketHandler.PacketReceived(int node,
INodePacket
packet)
1931
private void ProcessPacket(int node,
INodePacket
packet)
3470
private static I ExpectPacketType<I>(
INodePacket
packet, NodePacketType expectedType)
3471
where I : class,
INodePacket
BackEnd\Client\MSBuildClient.cs (5)
477
private bool TrySendPacket(Func<
INodePacket
> packetResolver)
479
INodePacket
? packet = null;
677
while (packetPump.ReceivedPacketsQueue.TryDequeue(out
INodePacket
? packet) &&
690
private void HandlePacket(
INodePacket
packet)
850
private void WritePacket(Stream nodeStream,
INodePacket
packet)
BackEnd\Client\MSBuildClientPacketPump.cs (5)
23
public ConcurrentQueue<
INodePacket
> ReceivedPacketsQueue { get; }
85
ReceivedPacketsQueue = new ConcurrentQueue<
INodePacket
>();
132
public
INodePacket
DeserializePacket(NodePacketType packetType, ITranslator translator)
142
public void RoutePacket(int nodeId,
INodePacket
packet)
156
public void PacketReceived(int node,
INodePacket
packet)
BackEnd\Components\BuildRequestEngine\BuildRequestConfigurationResponse.cs (1)
85
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
BackEnd\Components\Communications\INodeManager.cs (1)
36
void SendData(int node,
INodePacket
packet);
BackEnd\Components\Communications\INodeProvider.cs (1)
78
void SendData(int node,
INodePacket
packet);
BackEnd\Components\Communications\LogMessagePacket.cs (1)
51
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
BackEnd\Components\Communications\NodeEndpointInProc.cs (5)
92
private ConcurrentQueue<
INodePacket
> _packetQueue;
217
public void SendData(
INodePacket
packet)
339
private void EnqueuePacket(
INodePacket
packet)
378
_packetQueue = new ConcurrentQueue<
INodePacket
>();
443
INodePacket
packet;
BackEnd\Components\Communications\NodeManager.cs (3)
121
public void SendData(int node,
INodePacket
packet)
257
public
INodePacket
DeserializePacket(NodePacketType packetType, ITranslator translator)
267
public void RoutePacket(int nodeId,
INodePacket
packet)
BackEnd\Components\Communications\NodeProviderInProc.cs (4)
155
public void SendData(int nodeId,
INodePacket
packet)
283
public
INodePacket
DeserializePacket(NodePacketType packetType, ITranslator translator)
284
=> Assumed.Unreachable<
INodePacket
>();
291
public void RoutePacket(int nodeId,
INodePacket
packet)
BackEnd\Components\Communications\NodeProviderOutOfProc.cs (1)
135
public void SendData(int nodeId,
INodePacket
packet)
BackEnd\Components\Communications\NodeProviderOutOfProcBase.cs (6)
97
protected void SendData(NodeContext context,
INodePacket
packet)
982
private readonly ConcurrentQueue<
INodePacket
> _packetWriteQueue;
1069
_packetWriteQueue = new ConcurrentQueue<
INodePacket
>();
1178
public void SendData(
INodePacket
packet)
1248
while (context._packetWriteQueue.TryDequeue(out
INodePacket
packet))
1341
private static bool IsExitPacket(
INodePacket
packet)
BackEnd\Components\Communications\NodeProviderOutOfProcTaskHost.cs (5)
197
public void SendData(int nodeId,
INodePacket
packet)
207
internal void SendData(TaskHostNodeKey nodeKey,
INodePacket
packet)
318
public
INodePacket
DeserializePacket(NodePacketType packetType, ITranslator translator)
328
public void RoutePacket(int nodeId,
INodePacket
packet)
343
public void PacketReceived(int node,
INodePacket
packet)
BackEnd\Components\Communications\TaskHostNodeManager.cs (3)
56
public void SendData(int node,
INodePacket
packet)
156
public
INodePacket
DeserializePacket(NodePacketType packetType, ITranslator translator)
166
public void RoutePacket(int nodeId,
INodePacket
packet)
BackEnd\Components\FileAccesses\FileAccessReport.cs (1)
25
internal static
INodePacket
FactoryForDeserialization(ITranslator translator) => new FileAccessReport(translator);
BackEnd\Components\FileAccesses\ProcessReport.cs (1)
22
internal static
INodePacket
FactoryForDeserialization(ITranslator translator) => new ProcessReport(translator);
BackEnd\Components\Logging\BuildEventArgTransportSink.cs (1)
15
internal delegate void SendDataDelegate(
INodePacket
packetToSend);
BackEnd\Components\Logging\LoggingService.cs (1)
1008
public void PacketReceived(int node,
INodePacket
packet)
BackEnd\Components\SdkResolution\HostedSdkResolverServiceBase.cs (2)
31
public Action<
INodePacket
> SendPacket { get; set; }
53
public abstract void PacketReceived(int node,
INodePacket
packet);
BackEnd\Components\SdkResolution\ISdkResolverService.cs (1)
21
Action<
INodePacket
> SendPacket { get; }
BackEnd\Components\SdkResolution\MainNodeSdkResolverService.cs (1)
59
public override void PacketReceived(int node,
INodePacket
packet)
BackEnd\Components\SdkResolution\OutOfProcNodeSdkResolverService.cs (3)
48
public OutOfProcNodeSdkResolverService(Action<
INodePacket
> sendPacket)
56
public override void PacketReceived(int node,
INodePacket
packet)
129
INodePacket
packet = SdkResolverRequest.Create(submissionId, sdk, loggingContext.BuildEventContext, sdkReferenceLocation, solutionPath, projectPath, interactive, isRunningInVisualStudio);
BackEnd\Components\SdkResolution\OutOfProcNodeSdkResolverServiceFactory.cs (2)
17
private readonly Action<
INodePacket
> _sendPacket;
19
public OutOfProcNodeSdkResolverServiceFactory(Action<
INodePacket
> sendPacket)
BackEnd\Components\SdkResolution\SdkResolverRequest.cs (2)
13
/// with an additional <see cref="
INodePacket
"/> implementation.
76
public static
INodePacket
FactoryForDeserialization(ITranslator translator)
BackEnd\Components\SdkResolution\SdkResolverService.cs (1)
78
public Action<
INodePacket
> SendPacket { get; }
BackEnd\Components\SdkResolution\SdkResult.cs (1)
102
public static
INodePacket
FactoryForDeserialization(ITranslator translator)
BackEnd\Node\InProcNode.cs (7)
54
private readonly ConcurrentQueue<
INodePacket
> _receivedPackets;
116
_receivedPackets = new ConcurrentQueue<
INodePacket
>();
167
while (_receivedPackets.TryDequeue(out
INodePacket
packet))
231
public
INodePacket
DeserializePacket(NodePacketType packetType, ITranslator translator)
233
=> InternalError.Throw<
INodePacket
>("Unexpected call to DeserializePacket on the in-proc node.");
240
public void RoutePacket(int nodeId,
INodePacket
packet)
378
private void HandlePacket(
INodePacket
packet)
BackEnd\Node\NodeConfiguration.cs (1)
186
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
BackEnd\Node\OutOfProcNode.cs (8)
107
private readonly ConcurrentQueue<
INodePacket
> _receivedPackets;
146
_receivedPackets = new ConcurrentQueue<
INodePacket
>();
272
while (_receivedPackets.TryDequeue(out
INodePacket
packet))
354
INodePacket
INodePacketFactory.DeserializePacket(NodePacketType packetType, ITranslator translator)
364
void INodePacketFactory.RoutePacket(int nodeId,
INodePacket
packet)
378
void INodePacketHandler.PacketReceived(int node,
INodePacket
packet)
600
private void SendPacket(
INodePacket
packet)
633
private void HandlePacket(
INodePacket
packet)
BackEnd\Node\OutOfProcServerNode.cs (8)
59
private readonly ConcurrentQueue<
INodePacket
> _receivedPackets;
91
_receivedPackets = new ConcurrentQueue<
INodePacket
>();
163
while (_receivedPackets.TryDequeue(out
INodePacket
? packet))
227
INodePacket
INodePacketFactory.DeserializePacket(NodePacketType packetType, ITranslator translator)
237
void INodePacketFactory.RoutePacket(int nodeId,
INodePacket
packet)
251
void INodePacketHandler.PacketReceived(int node,
INodePacket
packet)
302
private void SendPacket(
INodePacket
packet)
313
private void HandlePacket(
INodePacket
packet)
BackEnd\Node\ServerNodeBuildCancel.cs (1)
14
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
BackEnd\Node\ServerNodeBuildCommand.cs (1)
118
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
BackEnd\Node\ServerNodeBuildResult.cs (1)
41
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
BackEnd\Node\ServerNodeConsoleWrite.cs (1)
40
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
BackEnd\Shared\BuildRequest.cs (1)
447
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
BackEnd\Shared\BuildRequestBlocker.cs (1)
244
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
BackEnd\Shared\BuildRequestUnblocker.cs (1)
120
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
BackEnd\Shared\BuildResult.cs (1)
447
NodePacketType
INodePacket
.Type
BackEnd\Shared\ResourceRequest.cs (1)
106
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
BackEnd\Shared\ResourceResponse.cs (1)
69
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
Instance\TaskFactories\TaskHostTask.cs (7)
72
private ConcurrentQueue<
INodePacket
> _receivedPackets;
205
_receivedPackets = new ConcurrentQueue<
INodePacket
>();
402
INodePacket
packet = null;
505
public
INodePacket
DeserializePacket(NodePacketType packetType, ITranslator translator)
515
public void RoutePacket(int nodeId,
INodePacket
packet)
526
public void PacketReceived(int node,
INodePacket
packet)
544
private void HandlePacket(
INodePacket
packet, out bool taskFinished)
src\msbuild\src\Shared\INodeEndpoint.cs (2)
21
internal delegate void DataReceivedDelegate(INodeEndpoint endpoint,
INodePacket
packet);
104
void SendData(
INodePacket
packet);
src\msbuild\src\Shared\INodePacketFactory.cs (3)
13
internal delegate
INodePacket
NodePacketFactoryMethod(ITranslator translator);
50
INodePacket
DeserializePacket(NodePacketType packetType, ITranslator translator);
57
void RoutePacket(int nodeId,
INodePacket
packet);
src\msbuild\src\Shared\INodePacketHandler.cs (1)
19
void PacketReceived(int node,
INodePacket
packet);
src\msbuild\src\Shared\NodeEndpointOutOfProcBase.cs (7)
105
private ConcurrentQueue<
INodePacket
> _packetQueue;
207
public void SendData(
INodePacket
packet)
340
private void EnqueuePacket(
INodePacket
packet)
362
_packetQueue = new ConcurrentQueue<
INodePacket
>();
378
ConcurrentQueue<
INodePacket
> localPacketQueue = _packetQueue;
637
ConcurrentQueue<
INodePacket
> localPacketQueue,
777
INodePacket
packet;
src\msbuild\src\Shared\NodePacketFactory.cs (5)
53
INodePacket
packet = record.DeserializePacket(translator);
60
public
INodePacket
DeserializePacket(NodePacketType packetType, ITranslator translator)
70
public void RoutePacket(int nodeId,
INodePacket
packet)
106
public
INodePacket
DeserializePacket(ITranslator translator) => _factoryMethod(translator);
111
public void RoutePacket(int nodeId,
INodePacket
packet) => _handler.PacketReceived(nodeId, packet);
src\msbuild\src\Shared\TaskHostBuildRequest.cs (1)
208
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
src\msbuild\src\Shared\TaskHostBuildResponse.cs (1)
153
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
src\msbuild\src\Shared\TaskHostConfiguration.cs (1)
629
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
src\msbuild\src\Shared\TaskHostCoresRequest.cs (1)
52
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
src\msbuild\src\Shared\TaskHostCoresResponse.cs (1)
46
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
src\msbuild\src\Shared\TaskHostIsRunningMultipleNodesRequest.cs (1)
30
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
src\msbuild\src\Shared\TaskHostIsRunningMultipleNodesResponse.cs (1)
40
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
src\msbuild\src\Shared\TaskHostTaskCancelled.cs (1)
40
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
src\msbuild\src\Shared\TaskHostTaskComplete.cs (1)
294
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
Microsoft.Build.Tasks.Core (20)
AssemblyDependency\Node\OutOfProcRarClient.cs (1)
67
INodePacket
packet = _pipeClient.ReadPacket();
AssemblyDependency\Node\OutOfProcRarNodeEndpoint.cs (1)
84
INodePacket
packet = await _pipeServer.ReadPacketAsync(cancellationToken).ConfigureAwait(false);
src\msbuild\src\Shared\INodeEndpoint.cs (2)
21
internal delegate void DataReceivedDelegate(INodeEndpoint endpoint,
INodePacket
packet);
104
void SendData(
INodePacket
packet);
src\msbuild\src\Shared\INodePacketFactory.cs (3)
13
internal delegate
INodePacket
NodePacketFactoryMethod(ITranslator translator);
50
INodePacket
DeserializePacket(NodePacketType packetType, ITranslator translator);
57
void RoutePacket(int nodeId,
INodePacket
packet);
src\msbuild\src\Shared\INodePacketHandler.cs (1)
19
void PacketReceived(int node,
INodePacket
packet);
src\msbuild\src\Shared\NodePacketFactory.cs (5)
53
INodePacket
packet = record.DeserializePacket(translator);
60
public
INodePacket
DeserializePacket(NodePacketType packetType, ITranslator translator)
70
public void RoutePacket(int nodeId,
INodePacket
packet)
106
public
INodePacket
DeserializePacket(ITranslator translator) => _factoryMethod(translator);
111
public void RoutePacket(int nodeId,
INodePacket
packet) => _handler.PacketReceived(nodeId, packet);
src\msbuild\src\Shared\NodePipeBase.cs (7)
94
internal void WritePacket(
INodePacket
packet)
106
internal
INodePacket
ReadPacket()
140
internal async Task WritePacketAsync(
INodePacket
packet, CancellationToken cancellationToken = default)
156
internal async Task<
INodePacket
> ReadPacketAsync(CancellationToken cancellationToken = default)
190
private int WritePacketToBuffer(
INodePacket
packet)
250
private
INodePacket
DeserializePacket()
261
return InternalError.Throw<
INodePacket
>($"Exception while deserializing packet {packetType}: {e}");
MSBuild (44)
OutOfProcTaskHostNode.cs (16)
81
private Queue<
INodePacket
> _receivedPackets;
205
private readonly ConcurrentDictionary<int, TaskCompletionSource<
INodePacket
>> _pendingCallbackRequests = new();
261
_receivedPackets = new Queue<
INodePacket
>();
823
public
INodePacket
DeserializePacket(NodePacketType packetType, ITranslator translator)
833
public void RoutePacket(int nodeId,
INodePacket
packet)
848
public void PacketReceived(int node,
INodePacket
packet)
893
INodePacket
packet = null;
934
private void HandlePacket(
INodePacket
packet)
961
private void HandleCallbackResponse(
INodePacket
packet)
972
if (kvp.Value.PendingCallbackRequests.TryRemove(callbackPacket.RequestId, out TaskCompletionSource<
INodePacket
> tcsFromContext))
979
if (_pendingCallbackRequests.TryRemove(callbackPacket.RequestId, out TaskCompletionSource<
INodePacket
> tcs))
1017
where TResponse : class,
INodePacket
1028
var tcs = new TaskCompletionSource<
INodePacket
>(TaskCreationOptions.RunContinuationsAsynchronously);
1039
INodePacket
response = tcs.Task.GetAwaiter().GetResult();
1436
if (_pendingCallbackRequests.TryRemove(kvp.Key, out TaskCompletionSource<
INodePacket
> tcs))
1446
if (contextKvp.Value.PendingCallbackRequests.TryRemove(reqKvp.Key, out TaskCompletionSource<
INodePacket
> ctxTcs))
src\msbuild\src\Shared\INodeEndpoint.cs (2)
21
internal delegate void DataReceivedDelegate(INodeEndpoint endpoint,
INodePacket
packet);
104
void SendData(
INodePacket
packet);
src\msbuild\src\Shared\INodePacketFactory.cs (3)
13
internal delegate
INodePacket
NodePacketFactoryMethod(ITranslator translator);
50
INodePacket
DeserializePacket(NodePacketType packetType, ITranslator translator);
57
void RoutePacket(int nodeId,
INodePacket
packet);
src\msbuild\src\Shared\INodePacketHandler.cs (1)
19
void PacketReceived(int node,
INodePacket
packet);
src\msbuild\src\Shared\NodeEndpointOutOfProcBase.cs (7)
105
private ConcurrentQueue<
INodePacket
> _packetQueue;
207
public void SendData(
INodePacket
packet)
340
private void EnqueuePacket(
INodePacket
packet)
362
_packetQueue = new ConcurrentQueue<
INodePacket
>();
378
ConcurrentQueue<
INodePacket
> localPacketQueue = _packetQueue;
637
ConcurrentQueue<
INodePacket
> localPacketQueue,
777
INodePacket
packet;
src\msbuild\src\Shared\NodePacketFactory.cs (5)
53
INodePacket
packet = record.DeserializePacket(translator);
60
public
INodePacket
DeserializePacket(NodePacketType packetType, ITranslator translator)
70
public void RoutePacket(int nodeId,
INodePacket
packet)
106
public
INodePacket
DeserializePacket(ITranslator translator) => _factoryMethod(translator);
111
public void RoutePacket(int nodeId,
INodePacket
packet) => _handler.PacketReceived(nodeId, packet);
src\msbuild\src\Shared\TaskHostBuildRequest.cs (1)
208
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
src\msbuild\src\Shared\TaskHostBuildResponse.cs (1)
153
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
src\msbuild\src\Shared\TaskHostConfiguration.cs (1)
629
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
src\msbuild\src\Shared\TaskHostCoresRequest.cs (1)
52
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
src\msbuild\src\Shared\TaskHostCoresResponse.cs (1)
46
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
src\msbuild\src\Shared\TaskHostIsRunningMultipleNodesRequest.cs (1)
30
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
src\msbuild\src\Shared\TaskHostIsRunningMultipleNodesResponse.cs (1)
40
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
src\msbuild\src\Shared\TaskHostTaskCancelled.cs (1)
40
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
src\msbuild\src\Shared\TaskHostTaskComplete.cs (1)
294
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
TaskExecutionContext.cs (1)
94
public ConcurrentDictionary<int, TaskCompletionSource<
INodePacket
>> PendingCallbackRequests { get; } = new();