1 interface inheriting from INodePacket
MSBuild (1)
ITaskHostCallbackPacket.cs (1)
11
internal interface ITaskHostCallbackPacket :
INodePacket
10 implementations of INodePacket
MSBuild (10)
LogMessagePacketBase.cs (1)
255
internal class LogMessagePacketBase :
INodePacket
NodeBuildComplete.cs (1)
13
internal class NodeBuildComplete :
INodePacket
NodeShutdown.cs (1)
36
internal class NodeShutdown :
INodePacket
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
39 references to INodePacket
MSBuild (39)
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;
614
ConcurrentQueue<
INodePacket
> localPacketQueue,
754
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 (14)
80
private Queue<
INodePacket
> _receivedPackets;
183
private readonly ConcurrentDictionary<int, TaskCompletionSource<
INodePacket
>> _pendingCallbackRequests = new();
213
_receivedPackets = new Queue<
INodePacket
>();
648
public
INodePacket
DeserializePacket(NodePacketType packetType, ITranslator translator)
658
public void RoutePacket(int nodeId,
INodePacket
packet)
673
public void PacketReceived(int node,
INodePacket
packet)
718
INodePacket
packet = null;
759
private void HandlePacket(
INodePacket
packet)
785
private void HandleCallbackResponse(
INodePacket
packet)
795
if (_pendingCallbackRequests.TryRemove(callbackPacket.RequestId, out TaskCompletionSource<
INodePacket
> tcs))
828
where TResponse : class,
INodePacket
833
var tcs = new TaskCompletionSource<
INodePacket
>(TaskCreationOptions.RunContinuationsAsynchronously);
844
INodePacket
response = tcs.Task.GetAwaiter().GetResult();
1023
if (_pendingCallbackRequests.TryRemove(kvp.Key, out TaskCompletionSource<
INodePacket
> tcs))
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)