Home
last modified time | relevance | path

Searched refs:request_id (Results 1 – 25 of 47) sorted by relevance

12

/third_party/mindspore/mindspore/ccsrc/ps/core/
Dnode.cc47 uint64_t request_id = AddMessageTrack(1); in SendMessageSync() local
48 const_cast<CommMessage &>(message).mutable_pb_meta()->set_request_id(request_id); in SendMessageSync()
53 … << ", the node id is:" << node_info_.node_id_ << " send the request id is:" << request_id; in SendMessageSync()
54 return Wait(request_id, timeout); in SendMessageSync()
62 uint64_t request_id = AddMessageTrack(1); in SendMessageAsync() local
63 meta->set_request_id(request_id); in SendMessageAsync()
68 … << ", the node id is:" << node_info_.node_id_ << " send the request id is:" << request_id; in SendMessageAsync()
69 return request_id; in SendMessageAsync()
77 uint64_t request_id = AddMessageTrack(1); in SendMessageSync() local
78 meta->set_request_id(request_id); in SendMessageSync()
[all …]
Dinstance_manager.cc23 … const std::string &body, const uint64_t &request_id, const NodeInfo &node_info) { in NewInstanceAsync() argument
29 message_meta->set_request_id(request_id); in NewInstanceAsync()
42 const uint64_t &request_id, const NodeInfo &node_info) { in QueryInstanceAsync() argument
48 message_meta->set_request_id(request_id); in QueryInstanceAsync()
62 const uint64_t &request_id, const NodeInfo &node_info) { in EnableFLSAsync() argument
68 message_meta->set_request_id(request_id); in EnableFLSAsync()
82 const uint64_t &request_id, const NodeInfo &node_info) { in DisableFLSAsync() argument
88 message_meta->set_request_id(request_id); in DisableFLSAsync()
Dabstract_node.cc72 uint64_t request_id = AddMessageTrack(nodes_address_.size()); in Broadcast() local
78 message_meta->set_request_id(request_id); in Broadcast()
89 … << ", the node id is:" << node_info_.node_id_ << " send the request id is:" << request_id; in Broadcast()
90 return Wait(request_id, timeout); in Broadcast()
208 uint64_t request_id = AddMessageTrack(data.size()); in Send() local
222 message_meta->set_request_id(request_id); in Send()
236 … << ", the node id is:" << node_info_.node_id_ << " send the request id is:" << request_id; in Send()
237 return Wait(request_id, timeout); in Send()
253 uint64_t request_id = AddMessageTrack(1); in Send() local
254 set_message_callback(request_id, [&]() { in Send()
[all …]
Dinstance_manager.h45 const uint64_t &request_id, const NodeInfo &node_info);
48 const uint64_t &request_id, const NodeInfo &node_info);
50 …c(const std::shared_ptr<TcpClient> &client, const NodeManager &manager, const uint64_t &request_id,
53 …c(const std::shared_ptr<TcpClient> &client, const NodeManager &manager, const uint64_t &request_id,
Dscheduler_node.cc480 RunMessageCallback(meta->request_id()); in GetOrCreateClient()
764 uint64_t request_id = AddMessageTrack(node_manager_.server_num()); in ProcessNewInstance() local
768 set_message_callback(request_id, [&]() { in ProcessNewInstance()
770 outputs = receive_messages_[request_id]; in ProcessNewInstance()
771 receive_messages_.erase(request_id); in ProcessNewInstance()
781 instance_manager_->NewInstanceAsync(client, node_manager_, body, request_id, node_info_); in ProcessNewInstance()
784 bool res = Wait(request_id); in ProcessNewInstance()
818 uint64_t request_id = AddMessageTrack(node_manager_.server_num()); in ProcessQueryInstance() local
822 set_message_callback(request_id, [&]() { in ProcessQueryInstance()
824 outputs = receive_messages_[request_id]; in ProcessQueryInstance()
[all …]
Dnode.h71 bool Wait(uint64_t request_id, const uint32_t &timeout = kCommTimeoutInSeconds);
87 bool CheckMessageTrack(const uint64_t &request_id);
89 void set_message_callback(const uint64_t &request_id, const MessageCallback &callback);
92 void RunMessageCallback(const uint64_t &request_id);
/third_party/cef/libcef/browser/net_service/
Dresource_request_handler_wrapper.cc119 PendingRequest(int32_t request_id, in PendingRequest()
124 : id_(request_id), in PendingRequest()
463 void OnBeforeRequest(int32_t request_id, in OnBeforeRequest() argument
479 request_id, request, request_was_redirected, std::move(callback), in OnBeforeRequest()
494 request_id, request, request_was_redirected, in OnBeforeRequest()
503 RequestState* state = GetOrCreateState(request_id); in OnBeforeRequest()
530 GetHandler(request_id, request, &intercept_only, requestPtr); in OnBeforeRequest()
535 requestPtr = MakeRequest(request, request_id, true); in OnBeforeRequest()
562 MaybeLoadCookies(request_id, state, request, std::move(exec_callback)); in OnBeforeRequest()
565 void MaybeLoadCookies(int32_t request_id, in MaybeLoadCookies() argument
[all …]
Dbrowser_urlrequest_impl.cc51 static int32_t request_id = kInitialRequestID; in MakeRequestID() local
52 return --request_id; in MakeRequestID()
55 bool IsValidRequestID(int32_t request_id) { in IsValidRequestID() argument
56 return request_id < kInitialRequestID; in IsValidRequestID()
69 void Add(int32_t request_id, in Add() argument
72 DCHECK_LE(request_id, kInitialRequestID); in Add()
75 DCHECK(map_.find(request_id) == map_.end()); in Add()
76 map_.insert(std::make_pair(request_id, std::make_pair(request, client))); in Add()
79 void Remove(int32_t request_id) { in Remove() argument
80 if (request_id > kInitialRequestID) in Remove()
[all …]
Dproxy_url_loader_factory.h53 virtual void OnBeforeRequest(int32_t request_id,
64 int32_t request_id,
75 int32_t request_id, in ProcessRequestHeaders() argument
86 virtual void ProcessResponseHeaders(int32_t request_id, in ProcessResponseHeaders() argument
108 int32_t request_id,
116 int32_t request_id,
122 int32_t request_id, in OnRequestComplete() argument
127 virtual void OnRequestError(int32_t request_id, in OnRequestError() argument
163 int32_t request_id,
174 int32_t request_id,
Dresource_handler_wrapper.cc385 ResourceResponseWrapper(const int32_t request_id, in ResourceResponseWrapper() argument
387 : request_id_(request_id), in ResourceResponseWrapper()
399 bool OpenInputStream(int32_t request_id, in OpenInputStream() argument
402 DCHECK_EQ(request_id, request_id_); in OpenInputStream()
412 request_->Set(&request, request_id); in OpenInputStream()
442 void GetResponseHeaders(int32_t request_id, in GetResponseHeaders() argument
449 DCHECK_EQ(request_id, request_id_); in GetResponseHeaders()
512 int32_t request_id, in CreateResourceResponse() argument
514 return std::make_unique<ResourceResponseWrapper>(request_id, handler); in CreateResourceResponse()
Dlogin_delegate.cc117 const content::GlobalRequestID& request_id, in LoginDelegate() argument
132 auth_info, request_id, origin_url)); in LoginDelegate()
153 const content::GlobalRequestID& request_id, in Start() argument
157 auto url_request_info = CefBrowserURLRequest::FromRequestID(request_id); in Start()
Dstream_reader_url_loader.h82 virtual bool OpenInputStream(int32_t request_id,
88 virtual void GetResponseHeaders(int32_t request_id,
110 virtual void OnInputStreamOpenFailed(int32_t request_id,
115 int32_t request_id,
Dlogin_delegate.h31 const content::GlobalRequestID& request_id,
41 const content::GlobalRequestID& request_id,
Dbrowser_urlrequest_impl.h30 static absl::optional<RequestInfo> FromRequestID(int32_t request_id);
32 const content::GlobalRequestID& request_id);
Dproxy_url_loader_factory.cc369 bool OpenInputStream(int32_t request_id, in OpenInputStream() argument
372 return response_->OpenInputStream(request_id, request, std::move(callback)); in OpenInputStream()
375 void OnInputStreamOpenFailed(int32_t request_id, bool* restarted) override { in OnInputStreamOpenFailed() argument
380 void GetResponseHeaders(int32_t request_id, in GetResponseHeaders() argument
387 response_->GetResponseHeaders(request_id, status_code, reason_phrase, in GetResponseHeaders()
1172 int32_t request_id, in OnBeforeRequest() argument
1181 int32_t request_id, in ShouldInterceptRequest() argument
1188 int32_t request_id, in OnRequestResponse() argument
1200 int32_t request_id, in OnFilterResponseBody() argument
1318 int32_t request_id, in CreateLoaderAndStart() argument
[all …]
Dstream_reader_url_loader.cc44 int32_t request_id, in Open() argument
50 wrapper->Start(request_id, request); in Open()
69 void Start(int32_t request_id, const network::ResourceRequest& request) { in Start() argument
73 base::WrapRefCounted(this), request_id, request)); in Start()
101 void OpenOnWorkThread(int32_t request_id, in OpenOnWorkThread() argument
110 request_id, request, in OpenOnWorkThread()
465 int32_t request_id, in StreamReaderURLLoader() argument
471 : request_id_(request_id), in StreamReaderURLLoader()
Dresource_handler_wrapper.h19 int32_t request_id,
/third_party/cef/libcef/browser/printing/
Dprint_view_manager.h55 int32_t request_id,
60 int32_t request_id) override {} in SetOptionsFromDocument() argument
62 int32_t request_id) override {} in DidPrepareDocumentForPreview() argument
64 int32_t request_id) override {} in DidPreviewPage() argument
66 int32_t request_id) override;
67 void PrintPreviewFailed(int32_t document_cookie, int32_t request_id) override;
69 int32_t request_id) override;
71 int32_t request_id) override {} in PrinterSettingsInvalid() argument
75 int32_t request_id) override {} in DidGetDefaultPageLayout() argument
77 int32_t request_id) override {} in DidStartPreview() argument
Dprint_view_manager.cc58 int request_id, in FillInDictionaryFromPdfPrintSettings() argument
131 print_settings.SetInteger(kPreviewRequestID, request_id); in FillInDictionaryFromPdfPrintSettings()
132 print_settings.SetBoolean(kIsFirstRequest, request_id != 0); in FillInDictionaryFromPdfPrintSettings()
262 int32_t request_id, in CheckForCancel() argument
265 return PrintViewManager::CheckForCancel(preview_ui_id, request_id, in CheckForCancel()
274 int32_t request_id) { in MetafileReadyForPrinting() argument
304 int32_t request_id) { in PrintPreviewFailed() argument
309 int32_t request_id) { in PrintPreviewCancelled() argument
/third_party/cef/libcef_dll/wrapper/
Dcef_message_router.cc258 const int request_id = args->GetInt(1); in OnProcessMessageReceived() local
264 CancelUnhandledQuery(browser, frame, context_id, request_id); in OnProcessMessageReceived()
300 info->request_id = request_id; in OnProcessMessageReceived()
310 CancelUnhandledQuery(browser, frame, context_id, request_id); in OnProcessMessageReceived()
320 const int request_id = args->GetInt(1); in OnProcessMessageReceived() local
322 CancelPendingRequest(browser_id, context_id, request_id); in OnProcessMessageReceived()
340 int request_id; member
423 info->request_id, response); in SendQuerySuccess()
429 int request_id, in SendQuerySuccess() argument
435 args->SetInt(1, request_id); in SendQuerySuccess()
[all …]
/third_party/cef/libcef/browser/devtools/
Ddevtools_frontend.cc180 int request_id) in NetworkResourceLoader() argument
184 request_id_(request_id) { in NetworkResourceLoader()
378 int request_id = message.FindIntKey("id").value_or(0); in HandleMessageFromDevToolsFrontend() local
418 SendMessageAck(request_id, std::move(response)); in HandleMessageFromDevToolsFrontend()
544 if (request_id) in HandleMessageFromDevToolsFrontend()
545 SendMessageAck(request_id, base::Value()); in HandleMessageFromDevToolsFrontend()
611 void CefDevToolsFrontend::SendMessageAck(int request_id, base::Value arg) { in SendMessageAck() argument
613 base::Value(request_id), std::move(arg)); in SendMessageAck()
/third_party/ltp/testcases/network/rpc/basic_tests/rpc01/lib/
Dlibrpc01.c30 rc = rc && xdr_long(xdrs, &bp->request_id); in xdr_receive_data()
44 rc = rc && xdr_long(xdrs, &buffer->request_id); in xdr_send_data()
Dlibrpc01.h26 long request_id; member
/third_party/grpc/src/python/grpcio_tests/tests_py3_only/interop/
Dxds_interop_client.py84 def on_rpc_complete(self, request_id: int, peer: str, method: str) -> None:
86 if self._start <= request_id < self._end:
180 request_id: int, stub: test_pb2_grpc.TestServiceStub,
194 futures[request_id] = (future, method)
289 request_id = None
291 request_id = _global_rpc_id
297 _start_rpc(config.method, config.metadata, request_id, stub,
/third_party/libevdev/include/linux/linux/
Duinput.h49 __u32 request_id; member
56 __u32 request_id; member

12