| /dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.ServiceModel.Discovery/System/ServiceModel/Discovery/ |
| H A D | DiscoveryProxy.cs | 88 return new ByeOperationApril2005AsyncResult(this, message, callback, state); in IAnnouncementContractApril2005.BeginByeOperation()
103 return new HelloOperation11AsyncResult(this, message, callback, state); in IAnnouncementContract11.BeginHelloOperation()
118 return new ByeOperation11AsyncResult(this, message, callback, state); in IAnnouncementContract11.BeginByeOperation()
133 return new HelloOperationCD1AsyncResult(this, message, callback, state); in IAnnouncementContractCD1.BeginHelloOperation()
148 return new ByeOperationCD1AsyncResult(this, message, callback, state); in IAnnouncementContractCD1.BeginByeOperation()
193 return new ProbeDuplex11AsyncResult(request, this, this, callback, state); in IDiscoveryContractAdhoc11.BeginProbeOperation()
355 return this.OnBeginFind(findRequestContext, callback, state); in IDiscoveryServiceImplementation.BeginFind()
365 return this.OnBeginResolve(resolveCriteria, callback, state); in IDiscoveryServiceImplementation.BeginResolve()
375 return this.BeginShouldRedirectFind(findCriteria, callback, state); in IMulticastSuppressionImplementation.BeginShouldRedirectFind()
395 return new CompletedAsyncResult<bool>(false, callback, state); in BeginShouldRedirectFind()
[all …]
|
| H A D | DiscoveryService.cs | 77 return new ProbeDuplexApril2005AsyncResult(request, this, null, callback, state); in IDiscoveryContractApril2005.BeginProbeOperation()
107 return new ProbeDuplex11AsyncResult(request, this, null, callback, state); in IDiscoveryContractAdhoc11.BeginProbeOperation()
122 return new ResolveDuplex11AsyncResult(request, this, null, callback, state); in IDiscoveryContractAdhoc11.BeginResolveOperation()
138 return new ProbeRequestResponse11AsyncResult(request, this, callback, state); in IDiscoveryContractManaged11.BeginProbeOperation()
155 return new ResolveRequestResponse11AsyncResult(request, this, callback, state); in IDiscoveryContractManaged11.BeginResolveOperation()
170 return new ProbeDuplexCD1AsyncResult(request, this, null, callback, state); in IDiscoveryContractAdhocCD1.BeginProbeOperation()
185 return new ResolveDuplexCD1AsyncResult(request, this, null, callback, state); in IDiscoveryContractAdhocCD1.BeginResolveOperation()
201 return new ProbeRequestResponseCD1AsyncResult(request, this, callback, state); in IDiscoveryContractManagedCD1.BeginProbeOperation()
217 return new ResolveRequestResponseCD1AsyncResult(request, this, callback, state); in IDiscoveryContractManagedCD1.BeginResolveOperation()
237 return this.OnBeginFind(findRequestContext, callback, state); in IDiscoveryServiceImplementation.BeginFind()
[all …]
|
| H A D | AnnouncementService.cs | 54 return new HelloOperationApril2005AsyncResult(this, message, callback, state); in IAnnouncementContractApril2005.BeginHelloOperation()
69 return new ByeOperationApril2005AsyncResult(this, message, callback, state); in IAnnouncementContractApril2005.BeginByeOperation()
84 return new HelloOperation11AsyncResult(this, message, callback, state); in IAnnouncementContract11.BeginHelloOperation()
97 …nnouncementContract11.BeginByeOperation(ByeMessage11 message, AsyncCallback callback, object state) in IAnnouncementContract11.BeginByeOperation() argument
99 return new ByeOperation11AsyncResult(this, message, callback, state); in IAnnouncementContract11.BeginByeOperation()
114 return new HelloOperationCD1AsyncResult(this, message, callback, state); in IAnnouncementContractCD1.BeginHelloOperation()
129 return new ByeOperationCD1AsyncResult(this, message, callback, state); in IAnnouncementContractCD1.BeginByeOperation()
148 …return this.OnBeginOnlineAnnouncement(messageSequence, endpointDiscoveryMetadata, callback, state); in IAnnouncementServiceImplementation.OnBeginOnlineAnnouncement()
162 …eturn this.OnBeginOfflineAnnouncement(messageSequence, endpointDiscoveryMetadata, callback, state); in IAnnouncementServiceImplementation.OnBeginOfflineAnnouncement()
182 return new CompletedAsyncResult(callback, state); in OnBeginOnlineAnnouncement()
[all …]
|
| /dports/devel/py-pipenv/pipenv-2021.5.29/pipenv/cli/ |
| H A D | options.py | 100 state.index = value
104 callback=callback)(f)
224 state.three = value
225 state.two = not value
257 if state.quiet:
262 state.verbose = True
272 if state.verbose:
277 state.quiet = True
287 state.site_packages = value
297 state.clear = value
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/System.ServiceModel.Discovery/System.ServiceModel.Discovery/ |
| H A D | DiscoveryProxy.cs | 70 …turn OnBeginFind (new DefaultFindRequestContext (message.Body.ToFindCriteria ()), callback, state); in IDiscoveryProxyContract11.BeginFind()
81 return OnBeginResolve (message.Body.ToResolveCriteria (), callback, state); in IDiscoveryProxyContract11.BeginResolve()
93 …turn OnBeginFind (new DefaultFindRequestContext (message.Body.ToFindCriteria ()), callback, state); in IDiscoveryProxyContractApril2005.BeginFind()
104 return OnBeginResolve (message.Body.ToResolveCriteria (), callback, state); in IDiscoveryProxyContractApril2005.BeginResolve()
127 return OnBeginResolve (message.Body.ToResolveCriteria (), callback, state); in IDiscoveryProxyContractCD1.BeginResolve()
149 return OnBeginResolve (message.Body.ToResolveCriteria (), callback, state); in IDiscoveryTargetContract11.BeginResolve()
160 …return OnBeginOnlineAnnouncement (DiscoveryMessageSequenceGenerator.Next (), edm, callback, state); in IDiscoveryTargetContract11.BeginOnlineAnnouncement()
181 return OnBeginResolve (message.Body.ToResolveCriteria (), callback, state); in IDiscoveryTargetContractApril2005.BeginResolve()
192 …return OnBeginOnlineAnnouncement (DiscoveryMessageSequenceGenerator.Next (), edm, callback, state); in IDiscoveryTargetContractApril2005.BeginOnlineAnnouncement()
213 return OnBeginResolve (message.Body.ToResolveCriteria (), callback, state); in IDiscoveryTargetContractCD1.BeginResolve()
[all …]
|
| H A D | DiscoveryService.cs | 79 return OnBeginFind (find_context, callback, state); in IDiscoveryProxyContract11.BeginFind()
99 return OnBeginResolve (message.Body.ToResolveCriteria (), callback, state); in IDiscoveryProxyContract11.BeginResolve()
114 return OnBeginFind (find_context, callback, state); in IDiscoveryProxyContractApril2005.BeginFind()
134 return OnBeginResolve (message.Body.ToResolveCriteria (), callback, state); in IDiscoveryProxyContractApril2005.BeginResolve()
149 return OnBeginFind (find_context, callback, state); in IDiscoveryProxyContractCD1.BeginFind()
169 return OnBeginResolve (message.Body.ToResolveCriteria (), callback, state); in IDiscoveryProxyContractCD1.BeginResolve()
194 return OnBeginResolve (message.Body.ToResolveCriteria (), callback, state); in IDiscoveryTargetContract11.BeginResolve()
230 return OnBeginResolve (message.Body.ToResolveCriteria (), callback, state); in IDiscoveryTargetContractApril2005.BeginResolve()
266 return OnBeginResolve (message.Body.ToResolveCriteria (), callback, state); in IDiscoveryTargetContractCD1.BeginResolve()
302 return find_delegate.BeginInvoke (findRequestContext, callback, state); in OnBeginFind()
[all …]
|
| H A D | AnnouncementService.cs | 66 …ke (this, new AnnouncementEventArgs (endpointDiscoveryMetadata, messageSequence), callback, state); in OnBeginOfflineAnnouncement()
85 …ke (this, new AnnouncementEventArgs (endpointDiscoveryMetadata, messageSequence), callback, state); in OnBeginOnlineAnnouncement()
126 …nlineAnnouncement (MessageContracts11.OnlineAnnouncement msg, AsyncCallback callback, object state) in IAnnouncementContract11.BeginOnlineAnnouncement() argument
130 return OnBeginOnlineAnnouncement (msq, edm, callback, state); in IAnnouncementContract11.BeginOnlineAnnouncement()
137 return OnBeginOnlineAnnouncement (msq, edm, callback, state); in IAnnouncementContractApril2005.BeginOnlineAnnouncement()
140 …lineAnnouncement (MessageContractsCD1.OnlineAnnouncement msg, AsyncCallback callback, object state) in IAnnouncementContractCD1.BeginOnlineAnnouncement() argument
144 return OnBeginOnlineAnnouncement (msq, edm, callback, state); in IAnnouncementContractCD1.BeginOnlineAnnouncement()
166 …lineAnnouncement (MessageContracts11.OfflineAnnouncement msg, AsyncCallback callback, object state) in IAnnouncementContract11.BeginOfflineAnnouncement() argument
170 return OnBeginOfflineAnnouncement (msq, edm, callback, state); in IAnnouncementContract11.BeginOfflineAnnouncement()
177 return OnBeginOfflineAnnouncement (msq, edm, callback, state); in IAnnouncementContractApril2005.BeginOfflineAnnouncement()
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/System/System.Net.Sockets/ |
| H A D | SocketTaskExtensions.cs | 15 (callback, state) => ((Socket)state).BeginAccept(callback, state), in AcceptAsync()
24 …socketForAccept, receiveSize, callback, state) => ((Socket)state).BeginAccept(socketForAccept, rec… in AcceptAsync()
34 …(targetEndPoint, callback, state) => ((Socket)state).BeginConnect(targetEndPoint, callback, state), in ConnectAsync()
43 …(targetAddress, targetPort, callback, state) => ((Socket)state).BeginConnect(targetAddress, target… in ConnectAsync()
53 …(targetAddresses, targetPort, callback, state) => ((Socket)state).BeginConnect(targetAddresses, ta… in ConnectAsync()
63 …(targetHost, targetPort, callback, state) => ((Socket)state).BeginConnect(targetHost, targetPort, … in ConnectAsync()
92 …(targetBuffers, flags, callback, state) => ((Socket)state).BeginReceive(targetBuffers, flags, call… in ReceiveAsync()
108 (targetBuffer, flags, callback, state) => in ReceiveFromAsync()
154 (targetBuffer, callback, state) => in ReceiveMessageFromAsync()
202 (targetBuffer, flags, callback, state) => ((Socket)state).BeginSend( in SendAsync()
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Net.Sockets/src/System/Net/Sockets/ |
| H A D | SocketTaskExtensions.netfx.cs | 15 (callback, state) => ((Socket)state).BeginAccept(callback, state), in AcceptAsync()
24 …socketForAccept, receiveSize, callback, state) => ((Socket)state).BeginAccept(socketForAccept, rec… in AcceptAsync()
34 …(targetEndPoint, callback, state) => ((Socket)state).BeginConnect(targetEndPoint, callback, state), in ConnectAsync()
43 …(targetAddress, targetPort, callback, state) => ((Socket)state).BeginConnect(targetAddress, target… in ConnectAsync()
53 …(targetAddresses, targetPort, callback, state) => ((Socket)state).BeginConnect(targetAddresses, ta… in ConnectAsync()
63 …(targetHost, targetPort, callback, state) => ((Socket)state).BeginConnect(targetHost, targetPort, … in ConnectAsync()
92 …(targetBuffers, flags, callback, state) => ((Socket)state).BeginReceive(targetBuffers, flags, call… in ReceiveAsync()
108 (targetBuffer, flags, callback, state) => in ReceiveFromAsync()
154 (targetBuffer, callback, state) => in ReceiveMessageFromAsync()
202 (targetBuffer, flags, callback, state) => ((Socket)state).BeginSend( in SendAsync()
[all …]
|
| /dports/devel/pear-FSM/FSM-1.4.0/FSM/ |
| H A D | GraphViz.php | 85 * @param mixed $callback
129 $state = $input;
140 $nodes[$state] = $state;
180 * @param string $state start state
208 $nodes[$state] = $state;
219 * @param string $state
226 return $symbol.', '.$state;
243 return $callback.'()';
246 return get_class($callback[0]).'::'.$callback[1].'()';
248 return $callback[0].'::'.$callback[1].'()';
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.ServiceModel/System/ServiceModel/Security/ |
| H A D | WrapperSecurityCommunicationObject.cs | 200 public IAsyncResult BeginClose(AsyncCallback callback, object state) in BeginClose() argument
202 return this.communicationObject.BeginClose(callback, state); in BeginClose()
207 return this.communicationObject.BeginClose(timeout, callback, state); in BeginClose()
225 public IAsyncResult BeginOpen(AsyncCallback callback, object state) in BeginOpen() argument
227 return this.communicationObject.BeginOpen(callback, state); in BeginOpen()
232 return this.communicationObject.BeginOpen(timeout, callback, state); in BeginOpen()
377 public IAsyncResult BeginClose(AsyncCallback callback, object state) in BeginClose() argument
379 return this.communicationObject.BeginClose(callback, state); in BeginClose()
402 public IAsyncResult BeginOpen(AsyncCallback callback, object state) in BeginOpen() argument
404 return this.communicationObject.BeginOpen(callback, state); in BeginOpen()
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/System.Web.Mvc3/Mvc/Async/ |
| H A D | AsyncResultWrapper.cs | 38 return Begin<TResult>(callback, state, beginDelegate, endDelegate, null /* tag */); in Begin()
42 … return Begin<TResult>(callback, state, beginDelegate, endDelegate, tag, Timeout.Infinite); in Begin()
47 asyncResult.Begin(callback, state, timeout); in Begin()
52 return Begin(callback, state, beginDelegate, endDelegate, null /* tag */); in Begin()
56 return Begin(callback, state, beginDelegate, endDelegate, tag, Timeout.Infinite); in Begin()
66 return BeginSynchronous<TResult>(callback, state, func, null /* tag */); in BeginSynchronous()
85 asyncResult.Begin(callback, state, Timeout.Infinite); in BeginSynchronous()
89 … public static IAsyncResult BeginSynchronous(AsyncCallback callback, object state, Action action) { in BeginSynchronous() argument
90 return BeginSynchronous(callback, state, action, null /* tag */); in BeginSynchronous()
94 return BeginSynchronous<AsyncVoid>(callback, state, MakeVoidDelegate(action), tag); in BeginSynchronous()
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/external/aspnetwebstack/src/System.Web.Mvc/Async/ |
| H A D | AsyncResultWrapper.cs | 45 return Begin<TResult>(callback, state, beginDelegate, endDelegate, tag: null); in Begin()
50 … return Begin<TResult>(callback, state, beginDelegate, endDelegate, tag, Timeout.Infinite); in Begin()
56 asyncResult.Begin(callback, state, timeout); in Begin()
62 return Begin(callback, state, beginDelegate, endDelegate, tag: null); in Begin()
67 return Begin(callback, state, beginDelegate, endDelegate, tag, Timeout.Infinite); in Begin()
79 return BeginSynchronous<TResult>(callback, state, func, tag: null); in BeginSynchronous()
99 asyncResult.Begin(callback, state, Timeout.Infinite); in BeginSynchronous()
103 … public static IAsyncResult BeginSynchronous(AsyncCallback callback, object state, Action action) in BeginSynchronous() argument
105 return BeginSynchronous(callback, state, action, tag: null); in BeginSynchronous()
110 return BeginSynchronous<AsyncVoid>(callback, state, MakeVoidDelegate(action), tag); in BeginSynchronous()
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.ServiceModel.Internals/System/Runtime/ |
| H A D | IOThreadScheduler.cs | 108 public static void ScheduleCallbackNoFlow(Action<object> callback, object state) in ScheduleCallbackNoFlow() argument
128 public static void ScheduleCallbackLowPriNoFlow(Action<object> callback, object state) in ScheduleCallbackLowPriNoFlow() argument
149 bool ScheduleCallbackHelper(Action<object> callback, object state) in ScheduleCallbackHelper() argument
195 bool ScheduleCallbackLowPriHelper(Action<object> callback, object state) in ScheduleCallbackLowPriHelper() argument
232 callback, state, out wrapped); in ScheduleCallbackLowPriHelper()
252 void CompletionCallback(out Action<object> callback, out object state) in CompletionCallback() argument
325 bool TryCoalesce(out Action<object> callback, out object state) in TryCoalesce() argument
528 public void DequeueWorkItem(out Action<object> callback, out object state) in DequeueWorkItem()
620 iots.CompletionCallback(out callback, out state); in IOCallback()
630 callback(state); in IOCallback()
[all …]
|
| H A D | ActionItem.cs | 39 public static void Schedule(Action<object> callback, object state) in Schedule() argument
41 Schedule(callback, state, false); in Schedule()
46 public static void Schedule(Action<object> callback, object state, bool lowPriority) in Schedule() argument
54 new DefaultActionItem(callback, state, lowPriority).Schedule(); in Schedule()
58 ScheduleCallback(callback, state, lowPriority); in Schedule()
135 static void ScheduleCallback(Action<object> callback, object state, bool lowPriority) in ScheduleCallback() argument
140 IOThreadScheduler.ScheduleCallbackLowPriNoFlow(callback, state); in ScheduleCallback()
144 IOThreadScheduler.ScheduleCallbackNoFlow(callback, state); in ScheduleCallback()
291 this.callback(this.state); in Invoke()
307 this.callback(this.state); in TraceAndInvoke()
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.ServiceModel.Activities/System/ServiceModel/Activities/ |
| H A D | WorkflowControlClient.cs | 355 return BeginAbandon(instanceId, null, callback, state); in BeginAbandon()
477 return this.BeginCancel((Guid)inputs[0], callback, state); in OnBeginCancel()
499 return this.BeginRun((Guid)inputs[0], callback, state); in OnBeginRun()
576 AsyncCallback callback, object state) in CancelAsyncResult() argument
577 : base(callback, state) in CancelAsyncResult()
637 AsyncCallback callback, object state) in RunAsyncResult() argument
638 : base(callback, state) in RunAsyncResult()
699 : base(callback, state) in SuspendAsyncResult()
759 Guid instanceId, AsyncCallback callback, object state) in UnsuspendAsyncResult() argument
760 : base(callback, state) in UnsuspendAsyncResult()
[all …]
|
| H A D | WorkflowUpdateableControlClient.cs | 394 return BeginAbandon(instanceId, null, callback, state); in BeginAbandon()
550 return this.BeginRun((Guid)inputs[0], callback, state); in OnBeginRun()
648 AsyncCallback callback, object state) in CancelAsyncResult() argument
649 : base(callback, state) in CancelAsyncResult()
709 AsyncCallback callback, object state) in RunAsyncResult() argument
710 : base(callback, state) in RunAsyncResult()
771 : base(callback, state) in SuspendAsyncResult()
832 : base(callback, state) in UnsuspendAsyncResult()
893 : base(callback, state) in TerminateAsyncResult()
952 AsyncCallback callback, object state) in UpdateAsyncResult() argument
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.WorkflowServices/System/ServiceModel/Persistence/ |
| H A D | LockingPersistenceProvider.cs | 16 …e IAsyncResult BeginCreate(object instance, TimeSpan timeout, AsyncCallback callback, object state) in BeginCreate() argument
18 return this.BeginCreate(instance, timeout, false, callback, state); in BeginCreate()
23 … public override IAsyncResult BeginLoad(TimeSpan timeout, AsyncCallback callback, object state) in BeginLoad() argument
25 return this.BeginLoad(timeout, false, callback, state); in BeginLoad()
28 … IAsyncResult BeginLoad(TimeSpan timeout, bool lockInstance, AsyncCallback callback, object state); in BeginLoad() argument
30 …lt BeginLoadIfChanged(TimeSpan timeout, object instanceToken, AsyncCallback callback, object state) in BeginLoadIfChanged() argument
32 return this.BeginLoadIfChanged(timeout, instanceToken, false, callback, state); in BeginLoadIfChanged()
37 return this.BeginLoad(timeout, lockInstance, callback, state); in BeginLoadIfChanged()
40 … public abstract IAsyncResult BeginUnlock(TimeSpan timeout, AsyncCallback callback, object state); in BeginUnlock() argument
42 …e IAsyncResult BeginUpdate(object instance, TimeSpan timeout, AsyncCallback callback, object state) in BeginUpdate() argument
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.ServiceModel/System/ServiceModel/Dispatcher/ |
| H A D | ErrorHandlingAcceptor.cs | 113 return this.binder.BeginAccept(timeout, callback, state); in BeginTryAccept()
117 return new ErrorHandlingCompletedAsyncResult(true, callback, state); in BeginTryAccept()
121 return new ErrorHandlingCompletedAsyncResult(true, callback, state); in BeginTryAccept()
125 return new ErrorHandlingCompletedAsyncResult(false, callback, state); in BeginTryAccept()
130 return new ErrorHandlingCompletedAsyncResult(false, callback, state); in BeginTryAccept()
226 return new WaitCompletedAsyncResult(callback, state); in BeginWaitForChannel()
230 return new WaitCompletedAsyncResult(callback, state); in BeginWaitForChannel()
235 return new WaitCompletedAsyncResult(callback, state); in BeginWaitForChannel()
244 return new WaitCompletedAsyncResult(callback, state); in BeginWaitForChannel()
281 : base(data, callback, state) in ErrorHandlingCompletedAsyncResult()
[all …]
|
| H A D | ErrorhandlingReceiver.cs | 102 return this.binder.BeginTryReceive(timeout, callback, state); in BeginTryReceive()
106 return new ErrorHandlingCompletedAsyncResult(true, callback, state); in BeginTryReceive()
110 return new ErrorHandlingCompletedAsyncResult(true, callback, state); in BeginTryReceive()
115 return new ErrorHandlingCompletedAsyncResult(false, callback, state); in BeginTryReceive()
120 return new ErrorHandlingCompletedAsyncResult(false, callback, state); in BeginTryReceive()
212 return new WaitCompletedAsyncResult(callback, state); in BeginWaitForMessage()
216 return new WaitCompletedAsyncResult(callback, state); in BeginWaitForMessage()
221 return new WaitCompletedAsyncResult(callback, state); in BeginWaitForMessage()
230 return new WaitCompletedAsyncResult(callback, state); in BeginWaitForMessage()
267 : base(data, callback, state) in ErrorHandlingCompletedAsyncResult()
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/System.ServiceModel/Test/System.ServiceModel.Channels/ |
| H A D | InterceptorBindingElement.cs | 148 return inner.BeginOpen (timeout, callback, state); in OnBeginOpen()
163 return inner.BeginClose (timeout, callback, state); in OnBeginClose()
206 TimeSpan timeout, AsyncCallback callback, object state) in OnBeginAcceptChannel() argument
208 return inner.BeginAcceptChannel (timeout, callback, state); in OnBeginAcceptChannel()
249 return inner.BeginOpen (timeout, callback, state); in OnBeginOpen()
264 return inner.BeginClose (timeout, callback, state); in OnBeginClose()
303 return inner.BeginRequest (message, callback, state); in BeginRequest()
327 return inner.BeginOpen (timeout, callback, state); in OnBeginOpen()
342 return inner.BeginClose (timeout, callback, state); in OnBeginClose()
386 return inner.BeginReceiveRequest (callback, state); in BeginReceiveRequest()
[all …]
|
| /dports/devel/grpc130/grpc-1.30.2/test/cpp/microbenchmarks/ |
| H A D | bm_threadpool.cc | 80 callback->pool_, callback->counter_, callback->num_add_)); in Run()
85 delete callback; in Run()
108 state.SetItemsProcessed(state.iterations()); in ThreadPoolAddAnother()
143 delete callback; in Run()
158 const int num_iterations = state.range(0) / state.threads; in BM_ThreadPoolExternalAdd()
169 state.SetItemsProcessed(state.range(0)); in BM_ThreadPoolExternalAdd()
196 callback->pool_->Add(cb); in Run()
200 delete callback; in Run()
224 state.SetItemsProcessed(state.iterations()); in ThreadPoolAddSelf()
275 callback->pad[0] = 0; in Run()
[all …]
|
| /dports/devel/grpc134/grpc-1.34.1/test/cpp/microbenchmarks/ |
| H A D | bm_threadpool.cc | 81 callback->pool_, callback->counter_, callback->num_add_)); in Run()
86 delete callback; in Run()
109 state.SetItemsProcessed(state.iterations()); in ThreadPoolAddAnother()
144 delete callback; in Run()
159 const int num_iterations = state.range(0) / state.threads; in BM_ThreadPoolExternalAdd()
170 state.SetItemsProcessed(state.range(0)); in BM_ThreadPoolExternalAdd()
197 callback->pool_->Add(cb); in Run()
201 delete callback; in Run()
225 state.SetItemsProcessed(state.iterations()); in ThreadPoolAddSelf()
276 callback->pad[0] = 0; in Run()
[all …]
|
| /dports/devel/grpc/grpc-1.42.0/test/cpp/microbenchmarks/ |
| H A D | bm_threadpool.cc | 82 callback->pool_, callback->counter_, callback->num_add_)); in Run()
87 delete callback; in Run()
110 state.SetItemsProcessed(state.iterations()); in ThreadPoolAddAnother()
145 delete callback; in Run()
161 const int num_iterations = state.range(0) / state.threads(); in BM_ThreadPoolExternalAdd()
172 state.SetItemsProcessed(state.range(0)); in BM_ThreadPoolExternalAdd()
203 delete callback; in Run()
227 state.SetItemsProcessed(state.iterations()); in ThreadPoolAddSelf()
277 callback->pad[0] = 0; in Run()
279 callback->val_++; in Run()
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.ServiceModel/System/ServiceModel/Channels/ |
| H A D | LayeredChannelFactory.cs | 43 return this.innerChannelFactory.BeginOpen(timeout, callback, state); in OnBeginOpen()
118 public IAsyncResult BeginReceive(AsyncCallback callback, object state) in BeginReceive() argument
120 return InnerChannel.BeginReceive(callback, state); in BeginReceive()
123 public IAsyncResult BeginReceive(TimeSpan timeout, AsyncCallback callback, object state) in BeginReceive() argument
125 return InnerChannel.BeginReceive(timeout, callback, state); in BeginReceive()
135 public IAsyncResult BeginTryReceive(TimeSpan timeout, AsyncCallback callback, object state) in BeginTryReceive() argument
137 return InnerChannel.BeginTryReceive(timeout, callback, state); in BeginTryReceive()
161 return InnerChannel.BeginWaitForMessage(timeout, callback, state); in BeginWaitForMessage()
256 public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) in BeginSend() argument
258 return this.BeginSend(message, this.DefaultSendTimeout, callback, state); in BeginSend()
[all …]
|