Lines Matching refs:Reply

42   auto Reply = Preprocessor(RPCStatus, Context);  in remoteCall()  local
47 return Postprocessor(Reply); in remoteCall()
57 I32 Reply; in shutdown() local
59 auto Status = Stub->Shutdown(&Context, Request, &Reply); in shutdown()
61 return Reply.number(); in shutdown()
71 auto *Reply = protobuf::Arena::CreateMessage<I32>(Arena.get()); in registerLib() local
75 RPCStatus = Stub->RegisterLib(&Context, *Request, Reply); in registerLib()
76 return Reply; in registerLib()
79 [&](const auto &Reply) { in registerLib() argument
80 if (Reply->number() == 0) { in registerLib()
94 auto *Reply = protobuf::Arena::CreateMessage<I32>(Arena.get()); in unregisterLib() local
98 RPCStatus = Stub->UnregisterLib(&Context, *Request, Reply); in unregisterLib()
99 return Reply; in unregisterLib()
102 [&](const auto &Reply) { in unregisterLib() argument
103 if (Reply->number() == 0) { in unregisterLib()
119 auto *Reply = protobuf::Arena::CreateMessage<I32>(Arena.get()); in isValidBinary() local
127 RPCStatus = Stub->IsValidBinary(&Context, *Request, Reply); in isValidBinary()
128 return Reply; in isValidBinary()
131 [&](const auto &Reply) { in isValidBinary() argument
132 if (Reply->number()) { in isValidBinary()
137 return Reply->number(); in isValidBinary()
147 auto *Reply = protobuf::Arena::CreateMessage<I32>(Arena.get()); in getNumberOfDevices() local
149 RPCStatus = Stub->GetNumberOfDevices(&Context, *Request, Reply); in getNumberOfDevices()
151 return Reply; in getNumberOfDevices()
154 [&](const auto &Reply) { in getNumberOfDevices() argument
155 if (Reply->number()) { in getNumberOfDevices()
156 CLIENT_DBG("Found %d devices", Reply->number()) in getNumberOfDevices()
160 return Reply->number(); in getNumberOfDevices()
170 auto *Reply = protobuf::Arena::CreateMessage<I32>(Arena.get()); in initDevice() local
174 RPCStatus = Stub->InitDevice(&Context, *Request, Reply); in initDevice()
176 return Reply; in initDevice()
179 [&](const auto &Reply) { in initDevice() argument
180 if (!Reply->number()) { in initDevice()
185 return Reply->number(); in initDevice()
195 auto *Reply = protobuf::Arena::CreateMessage<I32>(Arena.get()); in initRequires() local
197 RPCStatus = Stub->InitRequires(&Context, *Request, Reply); in initRequires()
198 return Reply; in initRequires()
201 [&](const auto &Reply) { in initRequires() argument
202 if (Reply->number()) { in initRequires()
207 return Reply->number(); in initRequires()
219 auto *Reply = protobuf::Arena::CreateMessage<TargetTable>(Arena.get()); in loadBinary() local
223 RPCStatus = Stub->LoadBinary(&Context, *ImageMessage, Reply); in loadBinary()
224 return Reply; in loadBinary()
227 [&](auto &Reply) { in loadBinary() argument
228 if (Reply->entries_size() == 0) { in loadBinary()
233 unloadTargetTable(*Reply, DevicesToTables[DeviceId].get(), in loadBinary()
237 DeviceId, Reply->entries_size()) in loadBinary()
251 auto *Reply = protobuf::Arena::CreateMessage<I32>(Arena.get()); in isDataExchangeable() local
256 RPCStatus = Stub->IsDataExchangeable(&Context, *Request, Reply); in isDataExchangeable()
257 return Reply; in isDataExchangeable()
260 [&](auto &Reply) { in isDataExchangeable() argument
261 if (Reply->number()) { in isDataExchangeable()
267 return Reply->number(); in isDataExchangeable()
277 auto *Reply = protobuf::Arena::CreateMessage<Pointer>(Arena.get()); in dataAlloc() local
284 RPCStatus = Stub->DataAlloc(&Context, *Request, Reply); in dataAlloc()
285 return Reply; in dataAlloc()
288 [&](auto &Reply) { in dataAlloc() argument
289 if (Reply->number()) { in dataAlloc()
291 (void *)Reply->number()) in dataAlloc()
294 DeviceId, (void *)Reply->number()) in dataAlloc()
296 return (void *)Reply->number(); in dataAlloc()
307 auto *Reply = protobuf::Arena::CreateMessage<I32>(Arena.get()); in dataSubmit() local
309 Stub->DataSubmit(&Context, Reply)); in dataSubmit()
326 Reply->set_number(0); in dataSubmit()
327 return Reply; in dataSubmit()
348 Reply->set_number(0); in dataSubmit()
349 return Reply; in dataSubmit()
356 return Reply; in dataSubmit()
359 [&](auto &Reply) { in dataSubmit() argument
360 if (!Reply->number()) { in dataSubmit()
367 return Reply->number(); in dataSubmit()
386 auto *Reply = protobuf::Arena::CreateMessage<Data>(Arena.get()); in dataRetrieve() local
390 while (Reader->Read(Reply)) { in dataRetrieve()
391 if (Reply->ret()) { in dataRetrieve()
395 return Reply; in dataRetrieve()
398 if (Reply->start() == 0 && Reply->size() == Reply->data().size()) { in dataRetrieve()
399 memcpy(HstPtr, Reply->data().data(), Reply->data().size()); in dataRetrieve()
401 return Reply; in dataRetrieve()
404 memcpy((void *)((char *)HstPtr + Reply->start()), in dataRetrieve()
405 Reply->data().data(), Reply->data().size()); in dataRetrieve()
409 return Reply; in dataRetrieve()
412 [&](auto &Reply) { in dataRetrieve() argument
413 if (!Reply->ret()) { in dataRetrieve()
419 return Reply->ret(); in dataRetrieve()
431 auto *Reply = protobuf::Arena::CreateMessage<I32>(Arena.get()); in dataExchange() local
441 RPCStatus = Stub->DataExchange(&Context, *Request, Reply); in dataExchange()
442 return Reply; in dataExchange()
445 [&](auto &Reply) { in dataExchange() argument
446 if (Reply->number()) { in dataExchange()
455 return Reply->number(); in dataExchange()
464 auto *Reply = protobuf::Arena::CreateMessage<I32>(Arena.get()); in dataDelete() local
470 RPCStatus = Stub->DataDelete(&Context, *Request, Reply); in dataDelete()
471 return Reply; in dataDelete()
474 [&](auto &Reply) { in dataDelete() argument
475 if (!Reply->number()) { in dataDelete()
481 return Reply->number(); in dataDelete()
493 auto *Reply = protobuf::Arena::CreateMessage<I32>(Arena.get()); in runTargetRegion() local
512 RPCStatus = Stub->RunTargetRegion(&Context, *Request, Reply); in runTargetRegion()
513 return Reply; in runTargetRegion()
516 [&](auto &Reply) { in runTargetRegion() argument
517 if (!Reply->number()) { in runTargetRegion()
522 return Reply->number(); in runTargetRegion()
535 auto *Reply = protobuf::Arena::CreateMessage<I32>(Arena.get()); in runTargetTeamRegion() local
558 RPCStatus = Stub->RunTargetTeamRegion(&Context, *Request, Reply); in runTargetTeamRegion()
559 return Reply; in runTargetTeamRegion()
562 [&](auto &Reply) { in runTargetTeamRegion() argument
563 if (!Reply->number()) { in runTargetTeamRegion()
569 return Reply->number(); in runTargetTeamRegion()