LookupTrackingManagerState

PreviousTime : DateTime

Previous time for diff calculation.

AddLookup(long, ISubscriptionMessage, TimeSpan)

Add a tracked lookup with timeout.

transactionId

Transaction ID.

subscription

Subscription message (cloned).

timeout

Timeout duration.

Clear()

Clears all adapter states and resets current state to Disconnected.

IncreaseTimeOut(long[])

Increase timeout for subscriptions that received data.

subscriptionIds

Subscription IDs that received data.

ProcessTimeouts(TimeSpan, long[]) : IEnumerable<ValueTuple<ISubscriptionMessage, Message>>

Process time elapsed and return timed-out lookups. Removes timed-out entries from tracking.

diff

Time elapsed since last check.

ignoreIds

Subscription IDs to skip (they just received data).

戻り値: Timed-out lookups.

RemoveLookup(long)

Remove a tracked lookup.

transactionId

Transaction ID.

TryDequeueFromAnyType(long) : Message

Try to dequeue from any type queue after removing the specified ID.

removingId

Transaction ID to remove.

戻り値: Next queued message, or null.

TryDequeueNext(MessageTypes, long) : Message

Try to dequeue the next subscription of the given type after removing the specified ID.

type

Message type.

removingId

Transaction ID to remove from queue.

戻り値: Next queued message, or null.

TryEnqueue(MessageTypes, long, ISubscriptionMessage) : bool

Try to enqueue a subscription into the per-type queue.

type

Message type.

transactionId

Transaction ID.

message

Subscription message (cloned).

戻り値: True if the subscription was queued (not the first in queue), false if it should proceed immediately.

TryGetAndRemoveLookup(long, ISubscriptionMessage) : bool

Try get and remove a tracked lookup.

transactionId

Transaction ID.

subscription

Found subscription, or null.

戻り値: True if found and removed.