Lines Matching refs:Request

56   Null Request;  in shutdown()  local
59 auto Status = Stub->Shutdown(&Context, Request, &Reply); in shutdown()
69 auto *Request = protobuf::Arena::CreateMessage<TargetBinaryDescription>( in registerLib() local
72 loadTargetBinaryDescription(Desc, *Request); in registerLib()
73 Request->set_bin_ptr((uint64_t)Desc); in registerLib()
75 RPCStatus = Stub->RegisterLib(&Context, *Request, Reply); in registerLib()
93 auto *Request = protobuf::Arena::CreateMessage<Pointer>(Arena.get()); in unregisterLib() local
96 Request->set_number((uint64_t)Desc); in unregisterLib()
98 RPCStatus = Stub->UnregisterLib(&Context, *Request, Reply); in unregisterLib()
117 auto *Request = in isValidBinary() local
121 Request->set_image_ptr((uint64_t)Image->ImageStart); in isValidBinary()
125 Request->add_entry_ptrs((uint64_t)EntryItr++); in isValidBinary()
127 RPCStatus = Stub->IsValidBinary(&Context, *Request, Reply); in isValidBinary()
146 auto *Request = protobuf::Arena::CreateMessage<Null>(Arena.get()); in getNumberOfDevices() local
149 RPCStatus = Stub->GetNumberOfDevices(&Context, *Request, Reply); in getNumberOfDevices()
169 auto *Request = protobuf::Arena::CreateMessage<I32>(Arena.get()); in initDevice() local
172 Request->set_number(DeviceId); in initDevice()
174 RPCStatus = Stub->InitDevice(&Context, *Request, Reply); in initDevice()
194 auto *Request = protobuf::Arena::CreateMessage<I64>(Arena.get()); in initRequires() local
196 Request->set_number(RequiresFlags); in initRequires()
197 RPCStatus = Stub->InitRequires(&Context, *Request, Reply); in initRequires()
250 auto *Request = protobuf::Arena::CreateMessage<DevicePair>(Arena.get()); in isDataExchangeable() local
253 Request->set_src_dev_id(SrcDevId); in isDataExchangeable()
254 Request->set_dst_dev_id(DstDevId); in isDataExchangeable()
256 RPCStatus = Stub->IsDataExchangeable(&Context, *Request, Reply); in isDataExchangeable()
278 auto *Request = protobuf::Arena::CreateMessage<AllocData>(Arena.get()); in dataAlloc() local
280 Request->set_device_id(DeviceId); in dataAlloc()
281 Request->set_size(Size); in dataAlloc()
282 Request->set_hst_ptr((uint64_t)HstPtr); in dataAlloc()
284 RPCStatus = Stub->DataAlloc(&Context, *Request, Reply); in dataAlloc()
314 auto *Request = in dataSubmit() local
317 Request->set_device_id(DeviceId); in dataSubmit()
318 Request->set_data((char *)HstPtr + Start, End - Start); in dataSubmit()
319 Request->set_hst_ptr((uint64_t)HstPtr); in dataSubmit()
320 Request->set_tgt_ptr((uint64_t)TgtPtr); in dataSubmit()
321 Request->set_start(Start); in dataSubmit()
322 Request->set_size(Size); in dataSubmit()
324 if (!Writer->Write(*Request)) { in dataSubmit()
336 auto *Request = in dataSubmit() local
339 Request->set_device_id(DeviceId); in dataSubmit()
340 Request->set_data(HstPtr, Size); in dataSubmit()
341 Request->set_hst_ptr((uint64_t)HstPtr); in dataSubmit()
342 Request->set_tgt_ptr((uint64_t)TgtPtr); in dataSubmit()
343 Request->set_start(0); in dataSubmit()
344 Request->set_size(Size); in dataSubmit()
346 if (!Writer->Write(*Request)) { in dataSubmit()
378 auto *Request = in dataRetrieve() local
381 Request->set_device_id(DeviceId); in dataRetrieve()
382 Request->set_size(Size); in dataRetrieve()
383 Request->set_hst_ptr((int64_t)HstPtr); in dataRetrieve()
384 Request->set_tgt_ptr((int64_t)TgtPtr); in dataRetrieve()
388 Stub->DataRetrieve(&Context, *Request)); in dataRetrieve()
432 auto *Request = in dataExchange() local
435 Request->set_src_dev_id(SrcDevId); in dataExchange()
436 Request->set_src_ptr((uint64_t)SrcPtr); in dataExchange()
437 Request->set_dst_dev_id(DstDevId); in dataExchange()
438 Request->set_dst_ptr((uint64_t)DstPtr); in dataExchange()
439 Request->set_size(Size); in dataExchange()
441 RPCStatus = Stub->DataExchange(&Context, *Request, Reply); in dataExchange()
465 auto *Request = protobuf::Arena::CreateMessage<DeleteData>(Arena.get()); in dataDelete() local
467 Request->set_device_id(DeviceId); in dataDelete()
468 Request->set_tgt_ptr((uint64_t)TgtPtr); in dataDelete()
470 RPCStatus = Stub->DataDelete(&Context, *Request, Reply); in dataDelete()
494 auto *Request = in runTargetRegion() local
497 Request->set_device_id(DeviceId); in runTargetRegion()
499 Request->set_tgt_entry_ptr( in runTargetRegion()
504 Request->add_tgt_args((uint64_t)*ArgPtr); in runTargetRegion()
508 Request->add_tgt_offsets((uint64_t)*OffsetPtr); in runTargetRegion()
510 Request->set_arg_num(ArgNum); in runTargetRegion()
512 RPCStatus = Stub->RunTargetRegion(&Context, *Request, Reply); in runTargetRegion()
536 auto *Request = in runTargetTeamRegion() local
539 Request->set_device_id(DeviceId); in runTargetTeamRegion()
541 Request->set_tgt_entry_ptr( in runTargetTeamRegion()
546 Request->add_tgt_args((uint64_t)*ArgPtr); in runTargetTeamRegion()
551 Request->add_tgt_offsets((uint64_t)*OffsetPtr); in runTargetTeamRegion()
553 Request->set_arg_num(ArgNum); in runTargetTeamRegion()
554 Request->set_team_num(TeamNum); in runTargetTeamRegion()
555 Request->set_thread_limit(ThreadLimit); in runTargetTeamRegion()
556 Request->set_loop_tripcount(LoopTripcount); in runTargetTeamRegion()
558 RPCStatus = Stub->RunTargetTeamRegion(&Context, *Request, Reply); in runTargetTeamRegion()