Android音视频——OMX 中 Nodeinstance 列表的管理与节点的操作

程思扬

发布于 2022-09-19 15:55:05

8560

发布于 2022-09-19 15:55:05

文章被收录于专栏：程思阳的专栏

在我们创建Componentinstance (OMX组件实例)后，需要对它里面的Nodelnstance列表进行管理。

OMX对解码器组件Component的使用，是通过OMXNodelnstance来实现的。 OMXNodelnstance 自身的动作包括 Nodeinstance 的生成(allocateNode )和删除 (freeNode)o其实就是对niDispatchers和mNode】DToInstance进行添加和删除。
mNodelDToInstance 就是一个 key 为 node id» value 为 Nodeinstance 的键/值对列表。而 niDispatchers 就是一个 key 为 node id, value 为 OMX::CallbackDispatcher 的键/值对列表。并且，每个 Nodeinstance 都拥有一个 0MX::CalIbackDispatchero
CallbackDispatcher的主要作用是在解码器组件Component发出回调动作后，将message 分发给对应的OMXCodec客户端。

在我们了解到OMXNodelnstance列表管理后，每个OMXNodelnstance中都有Node节点，若你需要给这些Node节点分配一些Buffer,下面看看对Node节点的操作过程。在/frameworks/av/media/libstagefright/include/OMXNodeInstance.h 中：

struct OMXNodeInstance {
    OMXNodeInstance(
            OMX *owner, const sp<IOMXObserver> &observer, const char *name);
             void setHandle(OMX::node_id node_id, OMX_HANDLETYPE handle);
 status_t prepareForAdaptivePlayback(
            OMX_U32 portIndex, OMX_BOOL enable,
           OMX_U32 maxFrameWidth, OMX_U32 maxFrameHeight);
    status_t useBuffer(
           OMX_U32 portIndex, const sp<IMemory> &params,
            OMX::buffer_id *buffer, OMX_U32 allottedSize);
//OMX: :Client通过此鹵数将已分配好的Buffer传给OMX服务器端组件，让其使用

 status_t allocateBuffer(
           OMX_U32 portIndex, size_t size, OMX::buffer_id *buffer,
            void **buffer_data);
            //Client通过调用此函数让Component分配Buffer
   status_t allocateBufferWithBackup(
           OMX_U32 portIndex, const sp<IMemory> &params,
           OMX::buffer_id *buffer, OMX_U32 allottedSize);
 status_t freeBuffer(OMX_U32 portIndex, OMX::buffer_id buffer);
 //Client通过调用此函数让Component释放allocateBuffer分配的Buffer
 status_t fillBuffer(OMX::buffer_id buffer, int fenceFd);
 //Client通过调用此函数传递空的Buffer给Component»让其将处理好的
//数据填入其中。此函数会调用OMX标准接口 OMX_FillThisBuffer 

 static OMX_ERRORTYPE OnEmptyBufferDone(
           OMX_IN OMX_HANDLETYPE hComponent,
            OMX_IN OMX_PTR pAppData,
         OMX_IN OMX_BUFFERHEADERTYPE *pBuffer);
//Buffer的读取后，调用此回调函数，向Client发送EmptyBufferDone消息 

 static OMX_ERRORTYPE OnFillBufferDone(
            OMX_IN OMX_HANDLETYPE hComponent,
           OMX_IN OMX_PTR pAppData,
          OMX_IN OMX_BUFFERHEADERTYPE *pBuffer);
//在Component莞成相应的处理操作并将输出数据填入输出Buffer后，调用此回调 //函数，向 Client 发送 FillBufferDone 消息

sp<GraphicBufferSource> getGraphicBufferSource();
   void setGraphicBufferSource(const sp<GraphicBufferSource>& bufferSource);

    // 处理| msg 124；，并可以对其进行修改。返回true iff完全处理并 
    // |msg| does not need to be sent to the event listener.
    bool handleMessage(omx_message &msg);
    OMXNodeInstance(const OMXNodeInstance &);
    OMXNodeInstance &operator=(const OMXNodeInstance &);

当执行这些函数时，都是先通过findinstance在mNodelDToInstance列表中找到对应的 Nodeinstance,然后调用Nodelnstance对应的方法。 OMXCodec对具体的component函数的操作，是通过OMXNodelnstance来实现的，如 filIBuffer> emptyBuffer> sendCommand等，它们都是通过OMX Core.h中的宏定义间接调用 OMX_Component.h 的 OMX_COMPONENTTYPE 中的相应函数指针来完成的。OMX_Core.h 和OMX_Compoiient.h都是OpenMAX标准头文件。

OMX_CALLBACKTYPE OMXNodeInstance::kCallbacks = { &OnEvent, &OnEmptyBufferDone, &OnFillBufferDone }; 它把3个OMXNodelnstance类的静态方法注册给了 kCallbacks。kCallbacks实际就是struct OMX COMPONENTTYPE和struct OMX_CALLBACKTYPE的具体实现，而这两者就是在 OMX Core.h 和 OMX_Component.h 中定义的。在哪里使用kCallbacks呢？下面看看OMX.cpp中的allocateNode函数：

status_t OMX::allocateNode(
        const char *name, const sp<IOMXObserver> &observer, node_id *node) {
   Mutex::Autolock autoLock(mLock);

   *node = 0;

    OMXNodeInstance *instance = new OMXNodeInstance(this, observer, name);

    OMX_COMPONENTTYPE *handle;
    OMX_ERRORTYPE err = mMaster->makeComponentInstance(
           name, &OMXNodeInstance::kCallbacks,
            instance, &handle);

    if (err != OMX_ErrorNone) {
        ALOGE("FAILED to allocate omx component '%s' err=%s(%#x)", name, asString(err), err);

       instance->onGetHandleFailed();

       return StatusFromOMXError(err);
    }

    *node = makeNodeID(instance);
    mDispatchers.add(*node, new CallbackDispatcher(instance));

    instance->setHandle(*node, handle);

    mLiveNodes.add(IInterface::asBinder(observer), instance);
    IInterface::asBinder(observer)->linkToDeath(this);

    return OK;
}

事件处理函数传给了组件Componentinstance,也就是传给了具体芯片平台相关的OMX IL 层。当组件有事件发生时，就会调用OMXNodelnstance中这几个注册过的事件处理函数：

OMX_ERRORTYPE OMXNodelnstance::OnEmptyBufferDone
OMX_ERRORTYPE OMXNodelnstance::OnFillBufferDone
OMX_ERRORTYPE OMXNodelnstance::OnEvent
而这几个函数又会调用OMX中对应的函数，也就是下面这3个函数：
OMX_ERRORTYPE OMX::OnEmptyBufferDone
OMX_ERRORTYPE OMX::OnFillBufferDone
OMX_ERRORTYPE OMX::OnEvent

总结一下，这儿个函数都采用相同的方式，即根据n odeid找到Cal I back Dispatcher,并把事件信息传递出去，也就是findDispatcher(node)->post(msg)o 进一步地，需要了解CallbackDispatcher的实现机制。它内部开启了一个线程，使用了信号量(signal)机制。 findDispatcher(node)->post(msg)是一个异步操作，只把消息传递过去，不会等待事件处理完毕就返回。问题来了，那么CallbackDispatcher是怎么处理接收到的消息的呢？查看以下代码：

bool OMX::CallbackDispatcher::loop() {
    for (;;) {
        std::list<omx_message> messages;
        {
            Mutex::Autolock autoLock(mLock);
           while (!mDone && mQueue.empty()) {
                mQueueChanged.wait(mLock);
            }
            if (mDone) {
                break;
            }
           messages.swap(mQueue);
        }
        dispatch(messages);
    }
    return false;
}

这样事件最终还是跨Binder传到OMXCodec里面，交给OMXCodecObserver 了« •旦有关于回调的过程，再从OMX服务器端发送到OMX客户端。我们又知道AwesomePlayer类中持有OMX客户端，所以这些从OMX组件通知上来的消息就可以到达AwesomePlayer中。这样就完成了 AwesomePlayer和OMX组件之间的通信。

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

原始发表：2022-07-31，如有侵权请联系 cloudcommunity@tencent.com 删除

面向对象编程