Home
last modified time | relevance | path

Searched refs:sendOperation (Results 1 – 8 of 8) sorted by relevance

/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.ServiceModel.Routing/System/ServiceModel/Routing/
H A DProcessRequestAsyncResult.cs58 SendOperation sendOperation = this.messageRpc.Operations[0]; in StartProcessing()
59 …this.currentClient = this.service.GetOrCreateClient<TContract>(sendOperation.CurrentEndpoint, this… in StartProcessing()
68 if (messageRpc.Transaction != null && sendOperation.HasAlternate) in StartProcessing()
75 if (sendOperation.AlternateEndpointCount > 0) in StartProcessing()
84 sendOperation.PrepareMessage(message); in StartProcessing()
208 SendOperation sendOperation = this.messageRpc.Operations[0]; in HandleClientOperationFailure()
236 sessionChannels.AbortChannel(sendOperation.CurrentEndpoint); in HandleClientOperationFailure()
245 if (!this.abortedRetry && (sendOperation.AlternateEndpointCount > 0)) in HandleClientOperationFailure()
262 sessionChannels.AbortChannel(sendOperation.CurrentEndpoint); in HandleClientOperationFailure()
268 if (sendOperation.TryMoveToAlternate(exception)) in HandleClientOperationFailure()
[all …]
H A DProcessMessagesAsyncResult.cs155 SendOperation sendOperation = messageRpc.Operations[this.destinationIndex]; in SendToCurrentClient()
156 if (sendOperation.Sent) in SendToCurrentClient()
163 sendOperation.HasAlternate) in SendToCurrentClient()
169 RoutingEndpointTrait endpointTrait = sendOperation.CurrentEndpoint; in SendToCurrentClient()
184 sendOperation.PrepareMessage(message); in SendToCurrentClient()
531 sessionChannels.AbortChannel(sendOperation.CurrentEndpoint); in HandleClientOperationFailure()
540 if (!this.abortedRetry && (sendOperation.AlternateEndpointCount > 0)) in HandleClientOperationFailure()
548 if (sendOperation.TryMoveToAlternate(e)) in HandleClientOperationFailure()
564 sendOperation.TransmitSucceeded(null); in HandleClientOperationFailure()
609 if (client.Key.Equals(sendOperation.CurrentEndpoint)) in HandleCloseFailure()
[all …]
/dports/science/dakota/dakota-6.13.0-release-public.src-UI/packages/external/acro/packages/pebbl/src/comm/pebbl/
H A DcoTree.cpp56 void coTree::sendOperation(void* buffer,int size,MessageID& tag,int dst) in sendOperation() function in pebbl::coTree
136 sendOperation(upSendBuf(), in run()
174 sendOperation(downSendBuf(i), in run()
H A DcoTree.h98 virtual void sendOperation(void* buffer,
/dports/net-im/telepathy-qt/telepathy-qt-0.9.8/examples/file-transfer/
H A Dfile-sender.cpp235 PendingFileSend *sendOperation = new PendingFileSend(transferChannel, SharedPtr<RefCounted>()); in onTransferRequestFinished() local
236 connect(sendOperation, in onTransferRequestFinished()
243 PendingFileSend *sendOperation = qobject_cast<PendingFileSend*>(op); in onSendFinished() local
245 sendOperation->channel()->requestClose(); in onSendFinished()
/dports/lang/zig/zig-0.9.0/lib/libc/include/any-windows-any/
H A Dwsman.h398 …*streamData, WINBOOL endOfStream, WSMAN_SHELL_ASYNC *async, WSMAN_OPERATION_HANDLE *sendOperation);
/dports/lang/zig-devel/zig-0.9.0/lib/libc/include/any-windows-any/
H A Dwsman.h398 …*streamData, WINBOOL endOfStream, WSMAN_SHELL_ASYNC *async, WSMAN_OPERATION_HANDLE *sendOperation);
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/shaka-player/dist/
H A Dshaka-player.ui.map7 …"backoffOperation","time","bytes","numBytesRemaining","bytesToLoad_","sendOperation","shaka.util.E…