Быстрая очередь сообщений с AIDL

Начиная с Android 12, Fast Message Queue может использоваться с интерфейсами AIDL с использованием бэкенда NDK. Это позволяет процессам взаимодействовать без накладных расходов и ограничений, связанных с транзакциями связующего компонента, после непродолжительной настройки. Использование Stable AIDL обеспечивает взаимодействие между системными и вендорными процессами.

Поддерживаемые типы полезной нагрузки

• @FixedSize AIDL parcelable типы
• Типы enum AIDL
• Интегральные типы AIDL

Сообщения, передаваемые между процессами в очереди сообщений общей памяти, должны иметь одинаковую структуру памяти в границах процессов и не могут содержать указатели. Попытка создать AidlMessageQueue с неподдерживаемым типом приведёт к ошибке компиляции.

Поддерживаемые типы очередей

В AIDL поддерживаются те же типы очередей , что и в HIDL, часто называемые разновидностями. Они используются в качестве аргументов шаблонов для очередей и дескрипторов.

Как использовать

Определите интерфейс AIDL, который передаст MQDescriptor другому процессу. MQDescriptor можно использовать везде, где допустимо использование parcelable.

Обязательными аргументами шаблона для MQDescriptor являются тип полезной нагрузки и тип очереди.

import android.hardware.common.fmq.MQDescriptor
import android.hardware.common.fmq.SynchronizedReadWrite

void getQueue(out MQDescriptor<int, SynchronizedReadWrite> mqDesc);

Процесс настройки каждой стороны очереди сообщений практически идентичен процессу с использованием HIDL , только с использованием типов AIDL.

#include <fmq/AidlMessageQueue.h>
...
using ::android::AidlMessageQueue;
using ::aidl::android::hardware::common::fmq::MQDescriptor;
using ::aidl::android::hardware::common::fmq::SynchronizedReadWrite;
...
ndk::ScopedAStatus MyInterface::getQueue(MQDescriptor<int32_t, SynchronizedReadWrite>* mqDesc) {
    *mqDesc = mFmqSynchronized->dupeDesc();
    return ndk::ScopedAStatus::ok();
}
...
// Create the first side of the queue before servicing getQueue() in this example
mFmqSynchronized =
  new AidlMessageQueue<int32_t, SynchronizedReadWrite>(kNumElementsInQueue);

Принимающий процесс создаст другую сторону очереди с дескриптором, полученным от интерфейса AIDL.

MQDescriptor<int32_t, SynchronizedReadWrite> desc;
auto ret = service->getQueue(true, &desc);
if (!ret.isOk()) {
   ...
}
// By default the constructor will reset the read and write pointers of the queue.
// Add a second `false` argument to avoid resetting the pointers.
mQueue = new (std::nothrow) AidlMessageQueue<int32_t, SynchronizedReadWrite>(desc);
if (!mQueue->isValid()) {
   ...
}

Использование AidlMessageQueue после настройки аналогично использованию HIDL MessageQueue . Все API, описанные в разделе «Использование MessageQueue», полностью поддерживаются AidlMessageQueue , за одним исключением:

const MQDescriptor<T, flavor>* getDesc() заменяется на MQDescriptor<T, U> dupeDesc() который возвращает AIDL MQDescriptor .