2 interfaces inheriting from INodePacket
Microsoft.Build (1)
ITaskHostCallbackPacket.cs (1)
11
internal interface ITaskHostCallbackPacket :
INodePacket
MSBuild (1)
ITaskHostCallbackPacket.cs (1)
11
internal interface ITaskHostCallbackPacket :
INodePacket
49 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)
15
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)
20
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)
39
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
LogMessagePacketBase.cs (1)
255
internal class LogMessagePacketBase :
INodePacket
NodeBuildComplete.cs (1)
13
internal class NodeBuildComplete :
INodePacket
NodeShutdown.cs (1)
36
internal class NodeShutdown :
INodePacket
TaskHostBuildRequest.cs (1)
15
internal class TaskHostBuildRequest :
INodePacket
, ITaskHostCallbackPacket
TaskHostBuildResponse.cs (1)
14
internal class TaskHostBuildResponse :
INodePacket
, ITaskHostCallbackPacket
TaskHostConfiguration.cs (1)
19
internal class TaskHostConfiguration :
INodePacket
TaskHostCoresRequest.cs (1)
11
internal class TaskHostCoresRequest :
INodePacket
, ITaskHostCallbackPacket
TaskHostCoresResponse.cs (1)
11
internal class TaskHostCoresResponse :
INodePacket
, ITaskHostCallbackPacket
TaskHostIsRunningMultipleNodesRequest.cs (1)
9
internal class TaskHostIsRunningMultipleNodesRequest :
INodePacket
, ITaskHostCallbackPacket
TaskHostIsRunningMultipleNodesResponse.cs (1)
9
internal class TaskHostIsRunningMultipleNodesResponse :
INodePacket
, ITaskHostCallbackPacket
TaskHostTaskCancelled.cs (1)
11
internal class TaskHostTaskCancelled :
INodePacket
TaskHostTaskComplete.cs (1)
53
internal class TaskHostTaskComplete :
INodePacket
Microsoft.Build.Engine.UnitTests (2)
BackEnd\LoggingService_Tests.cs (1)
1618
internal sealed class NonLoggingPacket :
INodePacket
BackEnd\NodeEndpointInProc_Tests.cs (1)
131
private sealed class TestPacket :
INodePacket
Microsoft.Build.Tasks.Core (6)
AssemblyDependency\Node\RarNodeBufferedLogEvents.cs (1)
13
internal class RarNodeBufferedLogEvents :
INodePacket
AssemblyDependency\Node\RarNodeExecuteRequest.cs (1)
16
internal sealed class RarNodeExecuteRequest :
INodePacket
AssemblyDependency\Node\RarNodeExecuteResponse.cs (1)
16
internal sealed class RarNodeExecuteResponse :
INodePacket
LogMessagePacketBase.cs (1)
255
internal class LogMessagePacketBase :
INodePacket
NodeBuildComplete.cs (1)
13
internal class NodeBuildComplete :
INodePacket
NodeShutdown.cs (1)
36
internal class NodeShutdown :
INodePacket
MSBuild (12)
LogMessagePacketBase.cs (1)
255
internal class LogMessagePacketBase :
INodePacket
NodeBuildComplete.cs (1)
13
internal class NodeBuildComplete :
INodePacket
NodeShutdown.cs (1)
36
internal class NodeShutdown :
INodePacket
TaskHostBuildRequest.cs (1)
15
internal class TaskHostBuildRequest :
INodePacket
, ITaskHostCallbackPacket
TaskHostBuildResponse.cs (1)
14
internal class TaskHostBuildResponse :
INodePacket
, ITaskHostCallbackPacket
TaskHostConfiguration.cs (1)
19
internal class TaskHostConfiguration :
INodePacket
TaskHostCoresRequest.cs (1)
11
internal class TaskHostCoresRequest :
INodePacket
, ITaskHostCallbackPacket
TaskHostCoresResponse.cs (1)
11
internal class TaskHostCoresResponse :
INodePacket
, ITaskHostCallbackPacket
TaskHostIsRunningMultipleNodesRequest.cs (1)
9
internal class TaskHostIsRunningMultipleNodesRequest :
INodePacket
, ITaskHostCallbackPacket
TaskHostIsRunningMultipleNodesResponse.cs (1)
9
internal class TaskHostIsRunningMultipleNodesResponse :
INodePacket
, ITaskHostCallbackPacket
TaskHostTaskCancelled.cs (1)
11
internal class TaskHostTaskCancelled :
INodePacket
TaskHostTaskComplete.cs (1)
53
internal class TaskHostTaskComplete :
INodePacket
229 references to INodePacket
Microsoft.Build (128)
BackEnd\BuildManager\BuildManager.cs (4)
1447
void INodePacketHandler.PacketReceived(int node,
INodePacket
packet)
1853
private void ProcessPacket(int node,
INodePacket
packet)
3384
private static I ExpectPacketType<I>(
INodePacket
packet, NodePacketType expectedType) where I : class,
INodePacket
BackEnd\Client\MSBuildClient.cs (5)
339
while (packetPump.ReceivedPacketsQueue.TryDequeue(out
INodePacket
? packet) &&
405
private bool TrySendPacket(Func<
INodePacket
> packetResolver)
407
INodePacket
? packet = null;
554
private void HandlePacket(
INodePacket
packet)
636
private void WritePacket(Stream nodeStream,
INodePacket
packet)
BackEnd\Client\MSBuildClientPacketPump.cs (5)
24
public ConcurrentQueue<
INodePacket
> ReceivedPacketsQueue { get; }
86
ReceivedPacketsQueue = new ConcurrentQueue<
INodePacket
>();
133
public
INodePacket
DeserializePacket(NodePacketType packetType, ITranslator translator)
143
public void RoutePacket(int nodeId,
INodePacket
packet)
157
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)
52
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
BackEnd\Components\Communications\NodeEndpointInProc.cs (5)
93
private ConcurrentQueue<
INodePacket
> _packetQueue;
218
public void SendData(
INodePacket
packet)
340
private void EnqueuePacket(
INodePacket
packet)
379
_packetQueue = new ConcurrentQueue<
INodePacket
>();
444
INodePacket
packet;
BackEnd\Components\Communications\NodeManager.cs (3)
122
public void SendData(int node,
INodePacket
packet)
263
public
INodePacket
DeserializePacket(NodePacketType packetType, ITranslator translator)
273
public void RoutePacket(int nodeId,
INodePacket
packet)
BackEnd\Components\Communications\NodeProviderInProc.cs (3)
156
public void SendData(int nodeId,
INodePacket
packet)
293
public
INodePacket
DeserializePacket(NodePacketType packetType, ITranslator translator)
305
public void RoutePacket(int nodeId,
INodePacket
packet)
BackEnd\Components\Communications\NodeProviderOutOfProc.cs (1)
136
public void SendData(int nodeId,
INodePacket
packet)
BackEnd\Components\Communications\NodeProviderOutOfProcBase.cs (6)
97
protected void SendData(NodeContext context,
INodePacket
packet)
917
private readonly ConcurrentQueue<
INodePacket
> _packetWriteQueue;
985
_packetWriteQueue = new ConcurrentQueue<
INodePacket
>();
1094
public void SendData(
INodePacket
packet)
1118
while (context._packetWriteQueue.TryDequeue(out
INodePacket
packet))
1190
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)
57
public void SendData(int node,
INodePacket
packet)
157
public
INodePacket
DeserializePacket(NodePacketType packetType, ITranslator translator)
167
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)
16
internal delegate void SendDataDelegate(
INodePacket
packetToSend);
BackEnd\Components\Logging\LoggingService.cs (1)
1000
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)
79
public Action<
INodePacket
> SendPacket { get; }
BackEnd\Components\SdkResolution\SdkResult.cs (1)
102
public static
INodePacket
FactoryForDeserialization(ITranslator translator)
BackEnd\Node\InProcNode.cs (6)
55
private readonly ConcurrentQueue<
INodePacket
> _receivedPackets;
117
_receivedPackets = new ConcurrentQueue<
INodePacket
>();
168
while (_receivedPackets.TryDequeue(out
INodePacket
packet))
234
public
INodePacket
DeserializePacket(NodePacketType packetType, ITranslator translator)
246
public void RoutePacket(int nodeId,
INodePacket
packet)
384
private void HandlePacket(
INodePacket
packet)
BackEnd\Node\NodeConfiguration.cs (1)
186
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
BackEnd\Node\OutOfProcNode.cs (8)
106
private readonly ConcurrentQueue<
INodePacket
> _receivedPackets;
145
_receivedPackets = new ConcurrentQueue<
INodePacket
>();
271
while (_receivedPackets.TryDequeue(out
INodePacket
packet))
353
INodePacket
INodePacketFactory.DeserializePacket(NodePacketType packetType, ITranslator translator)
363
void INodePacketFactory.RoutePacket(int nodeId,
INodePacket
packet)
377
void INodePacketHandler.PacketReceived(int node,
INodePacket
packet)
599
private void SendPacket(
INodePacket
packet)
630
private void HandlePacket(
INodePacket
packet)
BackEnd\Node\OutOfProcServerNode.cs (8)
45
private readonly ConcurrentQueue<
INodePacket
> _receivedPackets;
77
_receivedPackets = new ConcurrentQueue<
INodePacket
>();
149
while (_receivedPackets.TryDequeue(out
INodePacket
? packet))
213
INodePacket
INodePacketFactory.DeserializePacket(NodePacketType packetType, ITranslator translator)
223
void INodePacketFactory.RoutePacket(int nodeId,
INodePacket
packet)
237
void INodePacketHandler.PacketReceived(int node,
INodePacket
packet)
288
private void SendPacket(
INodePacket
packet)
299
private void HandlePacket(
INodePacket
packet)
BackEnd\Node\ServerNodeBuildCancel.cs (1)
14
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
BackEnd\Node\ServerNodeBuildCommand.cs (1)
110
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)
446
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)
448
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)
INodeEndpoint.cs (2)
21
internal delegate void DataReceivedDelegate(INodeEndpoint endpoint,
INodePacket
packet);
104
void SendData(
INodePacket
packet);
INodePacketFactory.cs (3)
13
internal delegate
INodePacket
NodePacketFactoryMethod(ITranslator translator);
50
INodePacket
DeserializePacket(NodePacketType packetType, ITranslator translator);
57
void RoutePacket(int nodeId,
INodePacket
packet);
INodePacketHandler.cs (1)
19
void PacketReceived(int node,
INodePacket
packet);
Instance\TaskFactories\TaskHostTask.cs (7)
74
private ConcurrentQueue<
INodePacket
> _receivedPackets;
207
_receivedPackets = new ConcurrentQueue<
INodePacket
>();
381
INodePacket
packet = null;
484
public
INodePacket
DeserializePacket(NodePacketType packetType, ITranslator translator)
494
public void RoutePacket(int nodeId,
INodePacket
packet)
505
public void PacketReceived(int node,
INodePacket
packet)
523
private void HandlePacket(
INodePacket
packet, out bool taskFinished)
NodeEndpointOutOfProcBase.cs (7)
104
private ConcurrentQueue<
INodePacket
> _packetQueue;
200
public void SendData(
INodePacket
packet)
330
private void EnqueuePacket(
INodePacket
packet)
352
_packetQueue = new ConcurrentQueue<
INodePacket
>();
368
ConcurrentQueue<
INodePacket
> localPacketQueue = _packetQueue;
608
ConcurrentQueue<
INodePacket
> localPacketQueue,
748
INodePacket
packet;
NodePacketFactory.cs (5)
58
INodePacket
packet = record.DeserializePacket(translator);
65
public
INodePacket
DeserializePacket(NodePacketType packetType, ITranslator translator)
79
public void RoutePacket(int nodeId,
INodePacket
packet)
119
public
INodePacket
DeserializePacket(ITranslator translator) => _factoryMethod(translator);
124
public void RoutePacket(int nodeId,
INodePacket
packet) => _handler.PacketReceived(nodeId, packet);
TaskHostBuildRequest.cs (1)
208
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
TaskHostBuildResponse.cs (1)
153
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
TaskHostConfiguration.cs (1)
532
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
TaskHostCoresRequest.cs (1)
52
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
TaskHostCoresResponse.cs (1)
46
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
TaskHostIsRunningMultipleNodesRequest.cs (1)
30
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
TaskHostIsRunningMultipleNodesResponse.cs (1)
40
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
TaskHostTaskCancelled.cs (1)
40
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
TaskHostTaskComplete.cs (1)
258
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
Microsoft.Build.Engine.UnitTests (38)
BackEnd\BuildEventArgTransportSink_Tests.cs (4)
66
void TransportDelegate(
INodePacket
packet)
89
void TransportDelegate(
INodePacket
packet)
110
void TransportDelegate(
INodePacket
packet)
153
private static void PacketProcessor(
INodePacket
packet)
BackEnd\BuildRequest_Tests.cs (2)
124
INodePacket
packet = BuildRequest.FactoryForDeserialization(TranslationHelpers.GetReadTranslator());
245
INodePacket
packet = BuildRequest.FactoryForDeserialization(TranslationHelpers.GetReadTranslator());
BackEnd\BuildRequestConfiguration_Tests.cs (3)
252
INodePacket
packet = BuildRequestConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator());
293
INodePacket
packet = BuildRequestConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator());
610
INodePacket
packet = BuildRequestConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator());
BackEnd\BuildRequestConfigurationResponse_Tests.cs (1)
84
INodePacket
deserializedPacket = BuildRequestConfigurationResponse.FactoryForDeserialization(TranslationHelpers.GetReadTranslator());
BackEnd\BuildResult_Tests.cs (4)
119
Assert.Equal(NodePacketType.BuildResult, ((
INodePacket
)result).Type);
326
Assert.Equal(NodePacketType.BuildResult, (result as
INodePacket
).Type);
328
INodePacket
packet = BuildResult.FactoryForDeserialization(TranslationHelpers.GetReadTranslator());
357
INodePacket
packet = BuildResult.FactoryForDeserialization(TranslationHelpers.GetReadTranslator());
BackEnd\MockHost.cs (1)
231
public
INodePacket
DeserializePacket(NodePacketType type, byte[] serializedPacket)
BackEnd\MockSdkResolverService.cs (1)
17
public Action<
INodePacket
> SendPacket { get; }
BackEnd\NodeEndpointInProc_Tests.cs (8)
108
public
INodePacket
DeserializePacket(NodePacketType packetType, ITranslator translator)
113
public void RoutePacket(int nodeId,
INodePacket
packet)
163
public readonly
INodePacket
packet;
165
public DataReceivedContext(Thread thread,
INodePacket
packet)
301
INodePacket
managerPacket = new TestPacket();
302
INodePacket
nodePacket = new TestPacket();
330
INodePacket
managerPacket = new TestPacket();
331
INodePacket
nodePacket = new TestPacket();
BackEnd\NodePackets_Tests.cs (1)
330
INodePacket
tempPacket = LogMessagePacket.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()) as LogMessagePacket;
BackEnd\TaskHostConfiguration_Tests.cs (7)
355
INodePacket
packet = TaskHostConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator());
460
INodePacket
packet = TaskHostConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator());
510
INodePacket
packet = TaskHostConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator());
558
INodePacket
packet = TaskHostConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator());
605
INodePacket
packet = TaskHostConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator());
659
INodePacket
packet = TaskHostConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator());
708
INodePacket
packet = TaskHostConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator());
BackEnd\TaskHostTaskCancelled_Tests.cs (1)
35
INodePacket
packet = TaskHostTaskCancelled.FactoryForDeserialization(TranslationHelpers.GetReadTranslator());
BackEnd\TaskHostTaskComplete_Tests.cs (5)
120
INodePacket
packet = TaskHostTaskComplete.FactoryForDeserialization(TranslationHelpers.GetReadTranslator());
143
INodePacket
packet = TaskHostTaskComplete.FactoryForDeserialization(TranslationHelpers.GetReadTranslator());
169
INodePacket
packet = TaskHostTaskComplete.FactoryForDeserialization(TranslationHelpers.GetReadTranslator());
196
INodePacket
packet = TaskHostTaskComplete.FactoryForDeserialization(TranslationHelpers.GetReadTranslator());
222
INodePacket
packet = TaskHostTaskComplete.FactoryForDeserialization(TranslationHelpers.GetReadTranslator());
Microsoft.Build.Tasks.Core (19)
AssemblyDependency\Node\OutOfProcRarClient.cs (1)
67
INodePacket
packet = _pipeClient.ReadPacket();
AssemblyDependency\Node\OutOfProcRarNodeEndpoint.cs (1)
84
INodePacket
packet = await _pipeServer.ReadPacketAsync(cancellationToken).ConfigureAwait(false);
INodeEndpoint.cs (2)
21
internal delegate void DataReceivedDelegate(INodeEndpoint endpoint,
INodePacket
packet);
104
void SendData(
INodePacket
packet);
INodePacketFactory.cs (3)
13
internal delegate
INodePacket
NodePacketFactoryMethod(ITranslator translator);
50
INodePacket
DeserializePacket(NodePacketType packetType, ITranslator translator);
57
void RoutePacket(int nodeId,
INodePacket
packet);
INodePacketHandler.cs (1)
19
void PacketReceived(int node,
INodePacket
packet);
NodePacketFactory.cs (5)
58
INodePacket
packet = record.DeserializePacket(translator);
65
public
INodePacket
DeserializePacket(NodePacketType packetType, ITranslator translator)
79
public void RoutePacket(int nodeId,
INodePacket
packet)
119
public
INodePacket
DeserializePacket(ITranslator translator) => _factoryMethod(translator);
124
public void RoutePacket(int nodeId,
INodePacket
packet) => _handler.PacketReceived(nodeId, packet);
NodePipeBase.cs (6)
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()
MSBuild (44)
INodeEndpoint.cs (2)
21
internal delegate void DataReceivedDelegate(INodeEndpoint endpoint,
INodePacket
packet);
104
void SendData(
INodePacket
packet);
INodePacketFactory.cs (3)
13
internal delegate
INodePacket
NodePacketFactoryMethod(ITranslator translator);
50
INodePacket
DeserializePacket(NodePacketType packetType, ITranslator translator);
57
void RoutePacket(int nodeId,
INodePacket
packet);
INodePacketHandler.cs (1)
19
void PacketReceived(int node,
INodePacket
packet);
NodeEndpointOutOfProcBase.cs (7)
104
private ConcurrentQueue<
INodePacket
> _packetQueue;
200
public void SendData(
INodePacket
packet)
330
private void EnqueuePacket(
INodePacket
packet)
352
_packetQueue = new ConcurrentQueue<
INodePacket
>();
368
ConcurrentQueue<
INodePacket
> localPacketQueue = _packetQueue;
608
ConcurrentQueue<
INodePacket
> localPacketQueue,
748
INodePacket
packet;
NodePacketFactory.cs (5)
58
INodePacket
packet = record.DeserializePacket(translator);
65
public
INodePacket
DeserializePacket(NodePacketType packetType, ITranslator translator)
79
public void RoutePacket(int nodeId,
INodePacket
packet)
119
public
INodePacket
DeserializePacket(ITranslator translator) => _factoryMethod(translator);
124
public void RoutePacket(int nodeId,
INodePacket
packet) => _handler.PacketReceived(nodeId, packet);
OutOfProcTaskHostNode.cs (16)
81
private Queue<
INodePacket
> _receivedPackets;
182
private readonly ConcurrentDictionary<int, TaskCompletionSource<
INodePacket
>> _pendingCallbackRequests = new();
238
_receivedPackets = new Queue<
INodePacket
>();
804
public
INodePacket
DeserializePacket(NodePacketType packetType, ITranslator translator)
814
public void RoutePacket(int nodeId,
INodePacket
packet)
829
public void PacketReceived(int node,
INodePacket
packet)
874
INodePacket
packet = null;
915
private void HandlePacket(
INodePacket
packet)
942
private void HandleCallbackResponse(
INodePacket
packet)
953
if (kvp.Value.PendingCallbackRequests.TryRemove(callbackPacket.RequestId, out TaskCompletionSource<
INodePacket
> tcsFromContext))
960
if (_pendingCallbackRequests.TryRemove(callbackPacket.RequestId, out TaskCompletionSource<
INodePacket
> tcs))
999
where TResponse : class,
INodePacket
1010
var tcs = new TaskCompletionSource<
INodePacket
>(TaskCreationOptions.RunContinuationsAsynchronously);
1021
INodePacket
response = tcs.Task.GetAwaiter().GetResult();
1372
if (_pendingCallbackRequests.TryRemove(kvp.Key, out TaskCompletionSource<
INodePacket
> tcs))
1382
if (contextKvp.Value.PendingCallbackRequests.TryRemove(reqKvp.Key, out TaskCompletionSource<
INodePacket
> ctxTcs))
TaskExecutionContext.cs (1)
94
public ConcurrentDictionary<int, TaskCompletionSource<
INodePacket
>> PendingCallbackRequests { get; } = new();
TaskHostBuildRequest.cs (1)
208
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
TaskHostBuildResponse.cs (1)
153
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
TaskHostConfiguration.cs (1)
532
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
TaskHostCoresRequest.cs (1)
52
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
TaskHostCoresResponse.cs (1)
46
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
TaskHostIsRunningMultipleNodesRequest.cs (1)
30
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
TaskHostIsRunningMultipleNodesResponse.cs (1)
40
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
TaskHostTaskCancelled.cs (1)
40
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)
TaskHostTaskComplete.cs (1)
258
internal static
INodePacket
FactoryForDeserialization(ITranslator translator)