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
>();
655
public
INodePacket
DeserializePacket(NodePacketType packetType, ITranslator translator)
665
public void RoutePacket(int nodeId,
INodePacket
packet)
680
public void PacketReceived(int node,
INodePacket
packet)
725
INodePacket
packet = null;
766
private void HandlePacket(
INodePacket
packet)
792
private void HandleCallbackResponse(
INodePacket
packet)
802
if (_pendingCallbackRequests.TryRemove(callbackPacket.RequestId, out TaskCompletionSource<
INodePacket
> tcs))
835
where TResponse : class,
INodePacket
840
var tcs = new TaskCompletionSource<
INodePacket
>(TaskCreationOptions.RunContinuationsAsynchronously);
851
INodePacket
response = tcs.Task.GetAwaiter().GetResult();
1030
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)