258 void VtsResourceManager::ProcessFmqCommand(const FmqRequestMessage& fmq_request,  in ProcessFmqCommand()  argument
260   const string& data_type = fmq_request.data_type();  in ProcessFmqCommand()
268     (this->*(iterator->second))(fmq_request, fmq_response);  in ProcessFmqCommand()
282   FmqRequestMessage fmq_request;  in RegisterFmq()  local
284   fmq_request.set_operation(FMQ_CREATE);  in RegisterFmq()
285   fmq_request.set_sync(queue_msg.type() == TYPE_FMQ_SYNC);  in RegisterFmq()
288   fmq_request.set_data_type(queue_msg.fmq_value(0).scalar_type());  in RegisterFmq()
289   fmq_request.set_queue_desc_addr(queue_desc_addr);  in RegisterFmq()
290   ProcessFmqCommand(fmq_request, &fmq_response);  in RegisterFmq()
296   FmqRequestMessage fmq_request;  in GetQueueDescAddress()  local
298   fmq_request.set_operation(FMQ_GET_DESC_ADDR);  in GetQueueDescAddress()
299   fmq_request.set_sync(queue_msg.type() == TYPE_FMQ_SYNC);  in GetQueueDescAddress()
302   fmq_request.set_data_type(queue_msg.fmq_value(0).scalar_type());  in GetQueueDescAddress()
303   fmq_request.set_queue_id(queue_msg.fmq_value(0).fmq_id());  in GetQueueDescAddress()
304   ProcessFmqCommand(fmq_request, &fmq_response);  in GetQueueDescAddress()
312     const FmqRequestMessage& fmq_request, FmqResponseMessage* fmq_response) {  in ProcessFmqCommandWithType()  argument
314   if (fmq_request.sync()) {  in ProcessFmqCommandWithType()
315     ProcessFmqCommandInternal<T, kSynchronizedReadWrite>(fmq_request,  in ProcessFmqCommandWithType()
318     ProcessFmqCommandInternal<T, kUnsynchronizedWrite>(fmq_request,  in ProcessFmqCommandWithType()
325     const FmqRequestMessage& fmq_request, FmqResponseMessage* fmq_response) {  in ProcessFmqCommandInternal()  argument
326   const string& data_type = fmq_request.data_type();  in ProcessFmqCommandInternal()
327   int queue_id = fmq_request.queue_id();  in ProcessFmqCommandInternal()
328   size_t queue_size = fmq_request.queue_size();  in ProcessFmqCommandInternal()
329   bool blocking = fmq_request.blocking();  in ProcessFmqCommandInternal()
330   bool reset_pointers = fmq_request.reset_pointers();  in ProcessFmqCommandInternal()
331   size_t write_data_size = fmq_request.write_data_size();  in ProcessFmqCommandInternal()
333   size_t read_data_size = fmq_request.read_data_size();  in ProcessFmqCommandInternal()
335   size_t queue_desc_addr = fmq_request.queue_desc_addr();  in ProcessFmqCommandInternal()
336   int64_t time_out_nanos = fmq_request.time_out_nanos();  in ProcessFmqCommandInternal()
346   switch (fmq_request.operation()) {  in ProcessFmqCommandInternal()
402       if (!FmqProto2Cpp<T>(fmq_request, write_data, write_data_size)) {  in ProcessFmqCommandInternal()
412       if (!FmqProto2Cpp<T>(fmq_request, write_data, write_data_size)) {  in ProcessFmqCommandInternal()
424       if (!FmqProto2Cpp<T>(fmq_request, write_data, write_data_size)) {  in ProcessFmqCommandInternal()
475 bool VtsResourceManager::FmqProto2Cpp(const FmqRequestMessage& fmq_request,  in FmqProto2Cpp()  argument
477   const string& data_type = fmq_request.data_type();  in FmqProto2Cpp()
482       convert_data[i] = (fmq_request.write_data(i).scalar_value().int8_t());  in FmqProto2Cpp()
487       convert_data[i] = fmq_request.write_data(i).scalar_value().uint8_t();  in FmqProto2Cpp()
492       convert_data[i] = fmq_request.write_data(i).scalar_value().int16_t();  in FmqProto2Cpp()
497       convert_data[i] = fmq_request.write_data(i).scalar_value().uint16_t();  in FmqProto2Cpp()
502       convert_data[i] = fmq_request.write_data(i).scalar_value().int32_t();  in FmqProto2Cpp()
507       convert_data[i] = fmq_request.write_data(i).scalar_value().uint32_t();  in FmqProto2Cpp()
512       convert_data[i] = fmq_request.write_data(i).scalar_value().int64_t();  in FmqProto2Cpp()
517       convert_data[i] = fmq_request.write_data(i).scalar_value().uint64_t();  in FmqProto2Cpp()
522       convert_data[i] = fmq_request.write_data(i).scalar_value().float_t();  in FmqProto2Cpp()
527       convert_data[i] = fmq_request.write_data(i).scalar_value().double_t();  in FmqProto2Cpp()
532       convert_data[i] = fmq_request.write_data(i).scalar_value().bool_t();  in FmqProto2Cpp()
549       (*parser)(fmq_request.write_data(i), &write_data[i], "");  in FmqProto2Cpp()