Lines Matching refs:queue_id

291   return fmq_response.queue_id();  in RegisterFmq()
327 int queue_id = fmq_request.queue_id(); in ProcessFmqCommandInternal() local
349 if (queue_id == -1) { in ProcessFmqCommandInternal()
358 new_queue_id = fmq_driver_.CreateFmq<T, flavor>(data_type, queue_id, in ProcessFmqCommandInternal()
366 success = fmq_driver_.ReadFmq<T, flavor>(data_type, queue_id, read_data, in ProcessFmqCommandInternal()
378 data_type, queue_id, read_data, read_data_size, time_out_nanos); in ProcessFmqCommandInternal()
391 data_type, queue_id, read_data, read_data_size, read_notification, in ProcessFmqCommandInternal()
407 success = fmq_driver_.WriteFmq<T, flavor>(data_type, queue_id, write_data, in ProcessFmqCommandInternal()
418 data_type, queue_id, write_data, write_data_size, time_out_nanos); in ProcessFmqCommandInternal()
430 data_type, queue_id, write_data, write_data_size, read_notification, in ProcessFmqCommandInternal()
435 success = fmq_driver_.AvailableToWrite<T, flavor>(data_type, queue_id, in ProcessFmqCommandInternal()
441 success = fmq_driver_.AvailableToRead<T, flavor>(data_type, queue_id, in ProcessFmqCommandInternal()
447 success = fmq_driver_.GetQuantumSize<T, flavor>(data_type, queue_id, in ProcessFmqCommandInternal()
453 success = fmq_driver_.GetQuantumCount<T, flavor>(data_type, queue_id, in ProcessFmqCommandInternal()
459 success = fmq_driver_.IsValid<T, flavor>(data_type, queue_id); in ProcessFmqCommandInternal()
463 success = fmq_driver_.GetQueueDescAddress<T, flavor>(data_type, queue_id, in ProcessFmqCommandInternal()