Home
last modified time | relevance | path

Searched refs:OfferMessage (Results 1 – 25 of 58) sorted by relevance

123

/dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/Test/System.Threading.Tasks.Dataflow/
H A DBoundedCapacityTest.cs53 target.OfferMessage (new DataflowMessageHeader (1), 42, null, false)); in OfferMessageTest()
55 target.OfferMessage (new DataflowMessageHeader (2), 43, null, false)); in OfferMessageTest()
60 target.OfferMessage (new DataflowMessageHeader (3), 44, null, false)); in OfferMessageTest()
74 target.OfferMessage (new DataflowMessageHeader (1), 42, source, false)); in OfferMessageWithSourceTest()
78 target.OfferMessage (header, 43, source, false)); in OfferMessageWithSourceTest()
89 target.OfferMessage (new DataflowMessageHeader (3), 44, source, false)); in OfferMessageWithSourceTest()
204 target.OfferMessage (header1, 41, source, false)); in MultipleOffersTest()
209 target.OfferMessage (header2, 42, source, false)); in MultipleOffersTest()
214 target.OfferMessage (header3, 43, source, false)); in MultipleOffersTest()
236 target.OfferMessage (header, 12, source, false)); in DontConsumePostponedAfterCompleteTest()
H A DJoinBlock`3Test.cs131 block.Target1.OfferMessage (header1, 11, source1, false)); in NonGreedyMaxNumberOfGroupsTest()
133 block.Target2.OfferMessage (header1, 21, source2, false)); in NonGreedyMaxNumberOfGroupsTest()
135 block.Target3.OfferMessage (header1, 31, source3, false)); in NonGreedyMaxNumberOfGroupsTest()
145 block.Target1.OfferMessage (header2, 21, source1, false)); in NonGreedyMaxNumberOfGroupsTest()
H A DJoinBlockTest.cs161 block.Target1.OfferMessage (header1, 11, source1, false)); in NonGreedyMaxNumberOfGroupsTest()
163 block.Target2.OfferMessage (header1, 21, source2, false)); in NonGreedyMaxNumberOfGroupsTest()
172 block.Target1.OfferMessage (header2, 21, source1, false)); in NonGreedyMaxNumberOfGroupsTest()
H A DBatchBlockTest.cs432 target.OfferMessage (header1, 11, source1, false)); in NonGreedyMaxNumberOfGroupsTest()
434 target.OfferMessage (header1, 21, source2, false)); in NonGreedyMaxNumberOfGroupsTest()
443 target.OfferMessage (header2, 21, source1, false)); in NonGreedyMaxNumberOfGroupsTest()
H A DBufferBlockTest.cs117 target.OfferMessage (header, 1, source, true)); in ConsumeToAcceptTest()
H A DEncapsulateTest.cs79 public DataflowMessageStatus OfferMessage ( in OfferMessage() method in MonoTests.System.Threading.Tasks.Dataflow.CompletionCheckerBlock
/dports/net-im/signald/signald-65cf5e8a1cf2b81fd1f5c3936e0164d53c5a9b29/src/main/java/io/finn/signald/clientprotocol/v1/
H A DOfferMessage.java22 public class OfferMessage { class
28 public OfferMessage(org.whispersystems.signalservice.api.messages.calls.OfferMessage message) { in OfferMessage() method in OfferMessage
H A DCallMessage.java26 @JsonProperty("offer_message") public OfferMessage offerMessage;
36 offerMessage = new OfferMessage(callMessage.getOfferMessage().get()); in CallMessage()
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/tests/Dataflow/
H A DConcurrentTests.cs65 …t => t.OfferMessage(new DataflowMessageHeader(1), default(int), null, false), // Message ID doesn'… in RunConcurrentTests()
72 …t => t.OfferMessage(new DataflowMessageHeader(1), default(int), null, false), // Message ID doesn'… in RunConcurrentTests()
79 …t => t.OfferMessage(new DataflowMessageHeader(1), default(int), null, false), // Message ID doesn'… in RunConcurrentTests()
85 …t => t.OfferMessage(new DataflowMessageHeader(1), default(int), null, false), // Message ID doesn'… in RunConcurrentTests()
92 …t => t.OfferMessage(new DataflowMessageHeader(1), default(int), null, false), // Message ID doesn'… in RunConcurrentTests()
99 …t => t.OfferMessage(new DataflowMessageHeader(1), default(int), null, false), // Message ID doesn'… in RunConcurrentTests()
H A DDataflowTestHelper.cs79 …AssertExtensions.Throws<ArgumentException>("messageHeader", () => target.OfferMessage(default(Data… in TestOfferMessage_ArgumentValidation()
80 …AssertExtensions.Throws<ArgumentException>("messageHeader", () => target.OfferMessage(default(Data… in TestOfferMessage_ArgumentValidation()
81 …AssertExtensions.Throws<ArgumentException>("consumeToAccept", () => target.OfferMessage(new Datafl… in TestOfferMessage_ArgumentValidation()
90 … actual: target.OfferMessage(new DataflowMessageHeader(i), default(T), null, false)); in TestOfferMessage_AcceptsDataDirectly()
101 actual: target.OfferMessage(new DataflowMessageHeader(4), default(T), null, false)); in TestOfferMessage_CompleteAndOffer()
118 …actual: target.OfferMessage(new DataflowMessageHeader(1), default(T), stingySource, consumeToAccep… in TestOfferMessage_AcceptsViaLinking()
H A DJoinBlockTests.cs68 …ntException>("messageHeader", () => new JoinBlock<int, int>().Target1.OfferMessage(default(Dataflo… in TestArgumentExceptions()
69 …Exception>("consumeToAccept", () => new JoinBlock<int, int>().Target1.OfferMessage(new DataflowMes… in TestArgumentExceptions()
363 …join.Target1.OfferMessage(new DataflowMessageHeader(1), 0, sources[0], consumeToAccept: true); // … in TestNonGreedyFailToConsumeReservedMessage()
364 …join.Target2.OfferMessage(new DataflowMessageHeader(1), 0, sources[1], consumeToAccept: true); // … in TestNonGreedyFailToConsumeReservedMessage()
390 … joinBlock.Target1.OfferMessage(new DataflowMessageHeader(1), 1, source, consumeToAccept: true); in TestNonGreedyReleasingFailsAtCompletion()
408 … joinBlock.Target1.OfferMessage(new DataflowMessageHeader(1), 1, source1, consumeToAccept: true); in TestNonGreedyConsumingFailsWhileJoining()
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/src/Blocks/
H A DActionBlock.cs278 …_defaultTarget.OfferMessage(Common.SingleMessageHeader, item, null, false) == DataflowMessageStatu… in Post()
283 …DataflowMessageStatus ITargetBlock<TInput>.OfferMessage(DataflowMessageHeader messageHeader, TInpu… in OfferMessage() method in System.Threading.Tasks.Dataflow.ActionBlock
286 _defaultTarget.OfferMessage(messageHeader, messageValue, source, consumeToAccept) : in OfferMessage()
287 _spscTarget.OfferMessage(messageHeader, messageValue, source, consumeToAccept); in OfferMessage()
H A DWriteOnceBlock.cs337 target.OfferMessage(_header, _value, this, consumeToAccept: useCloning); in LinkTo()
351 …DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageV… in OfferMessage() method in System.Threading.Tasks.Dataflow.WriteOnceBlock
447 target.OfferMessage(_header, _value, this, consumeToAccept: useCloning); in ReleaseReservation()
484 target.OfferMessage(_header, _value, this, consumeToAccept: useCloning); in OfferToTargets()
/dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/CoreFxSources/Blocks/
H A DActionBlock.cs277 …_defaultTarget.OfferMessage(Common.SingleMessageHeader, item, null, false) == DataflowMessageStatu… in Post()
282 …DataflowMessageStatus ITargetBlock<TInput>.OfferMessage(DataflowMessageHeader messageHeader, TInpu… in OfferMessage() method in System.Threading.Tasks.Dataflow.ActionBlock
285 _defaultTarget.OfferMessage(messageHeader, messageValue, source, consumeToAccept) : in OfferMessage()
286 _spscTarget.OfferMessage(messageHeader, messageValue, source, consumeToAccept); in OfferMessage()
H A DWriteOnceBlock.cs336 target.OfferMessage(_header, _value, this, consumeToAccept: useCloning); in LinkTo()
350 …DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageV… in OfferMessage() method in System.Threading.Tasks.Dataflow.WriteOnceBlock
446 target.OfferMessage(_header, _value, this, consumeToAccept: useCloning); in ReleaseReservation()
483 target.OfferMessage(_header, _value, this, consumeToAccept: useCloning); in OfferToTargets()
H A DTransformBlock.cs334 …DataflowMessageStatus ITargetBlock<TInput>.OfferMessage(DataflowMessageHeader messageHeader, TInpu… in OfferMessage() method in System.Threading.Tasks.Dataflow.TransformBlock
336 return _target.OfferMessage(messageHeader, messageValue, source, consumeToAccept); in OfferMessage()
/dports/net-im/signal-cli/signal-cli-0.9.0/src/main/java/org/asamk/signal/json/
H A DJsonCallMessage.java10 import org.whispersystems.signalservice.api.messages.calls.OfferMessage;
19 final OfferMessage offerMessage;
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/src/Base/
H A DITargetBlock.cs23 …DataflowMessageStatus OfferMessage(DataflowMessageHeader messageHeader, TInput messageValue, ISour… in OfferMessage() method
H A DDataflowBlock.cs139 …DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageV… in OfferMessage() method in System.Threading.Tasks.Dataflow.DataflowBlock.FilteredLinkPropagator
153 return _target.OfferMessage(messageHeader, messageValue, this, consumeToAccept); in OfferMessage()
253 …return target.OfferMessage(Common.SingleMessageHeader, item, source: null, consumeToAccept: false)… in Post()
315 …switch (target.OfferMessage(Common.SingleMessageHeader, item, source: null, consumeToAccept: false… in SendAsync()
582 switch (_target.OfferMessage( in OfferToTarget()
1172 …DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageV… in OfferMessage() method in System.Threading.Tasks.Dataflow.DataflowBlock.ReceiveTarget
1562 …DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageV… in OfferMessage() method in System.Threading.Tasks.Dataflow.DataflowBlock.OutputAvailableAsyncTarget
1660 …public DataflowMessageStatus OfferMessage(DataflowMessageHeader messageHeader, TInput messageValue… in OfferMessage() method in System.Threading.Tasks.Dataflow.DataflowBlock.EncapsulatingPropagator
1662 return _target.OfferMessage(messageHeader, messageValue, source, consumeToAccept); in OfferMessage()
2225 …public DataflowMessageStatus OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISo… in OfferMessage() method in System.Threading.Tasks.Dataflow.DataflowBlock.ChooseTarget
[all …]
/dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/CoreFxSources/Base/
H A DITargetBlock.cs22 …DataflowMessageStatus OfferMessage(DataflowMessageHeader messageHeader, TInput messageValue, ISour… in OfferMessage() method
H A DDataflowBlock.cs166 …DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageV… in OfferMessage() method in System.Threading.Tasks.Dataflow.DataflowBlock.FilteredLinkPropagator
180 return _target.OfferMessage(messageHeader, messageValue, this, consumeToAccept); in OfferMessage()
280 …return target.OfferMessage(Common.SingleMessageHeader, item, source: null, consumeToAccept: false)… in Post()
342 …switch (target.OfferMessage(Common.SingleMessageHeader, item, source: null, consumeToAccept: false… in SendAsync()
609 switch (_target.OfferMessage( in OfferToTarget()
1199 …DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageV… in OfferMessage() method in System.Threading.Tasks.Dataflow.DataflowBlock.ReceiveTarget
1590 …DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageV… in OfferMessage() method in System.Threading.Tasks.Dataflow.DataflowBlock.OutputAvailableAsyncTarget
1688 …public DataflowMessageStatus OfferMessage(DataflowMessageHeader messageHeader, TInput messageValue… in OfferMessage() method in System.Threading.Tasks.Dataflow.DataflowBlock.EncapsulatingPropagator
1690 return _target.OfferMessage(messageHeader, messageValue, source, consumeToAccept); in OfferMessage()
2253 …public DataflowMessageStatus OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISo… in OfferMessage() method in System.Threading.Tasks.Dataflow.DataflowBlock.ChooseTarget
[all …]
/dports/net-im/signald/signald-65cf5e8a1cf2b81fd1f5c3936e0164d53c5a9b29/src/main/java/io/finn/signald/
H A DJsonCallMessage.java26 public OfferMessage offerMessage;
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/src/Internal/
H A DTargetRegistry.cs328 …DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageV… in OfferMessage() method in System.Threading.Tasks.Dataflow.Internal.TargetRegistry.NopLinkPropagator
331 return _target.OfferMessage(messageHeader, messageValue, this, consumeToAccept); in OfferMessage()
/dports/lang/mono/mono-5.10.1.57/mcs/class/System.Threading.Tasks.Dataflow/CoreFxSources/Internal/
H A DTargetRegistry.cs328 …DataflowMessageStatus ITargetBlock<T>.OfferMessage(DataflowMessageHeader messageHeader, T messageV… in OfferMessage() method in System.Threading.Tasks.Dataflow.Internal.TargetRegistry.NopLinkPropagator
331 return _target.OfferMessage(messageHeader, messageValue, this, consumeToAccept); in OfferMessage()
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/ref/
H A DSystem.Threading.Tasks.Dataflow.cs21 …lowMessageStatus System.Threading.Tasks.Dataflow.ITargetBlock<TInput>.OfferMessage(System.Threadin… in OfferMessage() method in System.Threading.Tasks.Dataflow.ActionBlock
37 …DataflowMessageStatus System.Threading.Tasks.Dataflow.ITargetBlock<T>.OfferMessage(System.Threadin… in OfferMessage() method in System.Threading.Tasks.Dataflow.BatchBlock
94 …DataflowMessageStatus System.Threading.Tasks.Dataflow.ITargetBlock<T>.OfferMessage(System.Threadin… in OfferMessage() method in System.Threading.Tasks.Dataflow.BroadcastBlock
110 …DataflowMessageStatus System.Threading.Tasks.Dataflow.ITargetBlock<T>.OfferMessage(System.Threadin… in OfferMessage() method in System.Threading.Tasks.Dataflow.BufferBlock
216 …System.Threading.Tasks.Dataflow.DataflowMessageStatus OfferMessage(System.Threading.Tasks.Dataflow… in OfferMessage() method
270 …lowMessageStatus System.Threading.Tasks.Dataflow.ITargetBlock<TInput>.OfferMessage(System.Threadin… in OfferMessage() method in System.Threading.Tasks.Dataflow.TransformBlock
290 …lowMessageStatus System.Threading.Tasks.Dataflow.ITargetBlock<TInput>.OfferMessage(System.Threadin… in OfferMessage() method in System.Threading.Tasks.Dataflow.TransformManyBlock
307 …DataflowMessageStatus System.Threading.Tasks.Dataflow.ITargetBlock<T>.OfferMessage(System.Threadin… in OfferMessage() method in System.Threading.Tasks.Dataflow.WriteOnceBlock

123