1 interface inheriting from INodePacket
MSBuild (1)
ITaskHostCallbackPacket.cs (1)
11
internal interface ITaskHostCallbackPacket :
INodePacket
12 implementations of 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
44 references to INodePacket
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;
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 (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)