OpenHarmony-v5.1.0-Release/s

/*
 * Copyright (C) 2021-2024 Huawei Device Co., Ltd.
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

#ifndef OHOS_IPC_DBINDER_BASE_INVOKER_PROCESS_H
#define OHOS_IPC_DBINDER_BASE_INVOKER_PROCESS_H

#include "dbinder_base_invoker_define.h"
#include "hitrace_invoker.h"

namespace OHOS {

template <class T>
void DBinderBaseInvoker<T>::SendReplyWithSeqNum(uint64_t seqNum, MessageParcel &reply, uint32_t flags, int32_t result)
{
    if (!(flags & MessageOption::TF_ASYNC)) {
        SetSeqNum(seqNum);
        SendReply(reply, 0, result);
        SetSeqNum(0);
    }
}

template <class T> void DBinderBaseInvoker<T>::StartLoopFailSendReply(const char *buffer, uint32_t size, int32_t result)
{
    MessageParcel reply;
    const dbinder_transaction_data *tr = reinterpret_cast<const dbinder_transaction_data *>(buffer);
    SendReplyWithSeqNum(tr->seqNumber, reply, tr->flags, result);
}

template <class T>
int DBinderBaseInvoker<T>::TargetStubSendRequest(dbinder_transaction_data *tr, int32_t listenFd, uint64_t seqNum,
    MessageParcel &data, MessageParcel &reply)
{
    IPCProcessSkeleton *current = IPCProcessSkeleton::GetCurrent();
    if (current == nullptr) {
        ZLOGE(LOG_LABEL, "IPCProcessSkeleton is nullptr");
        DfxReportFailEvent(DbinderErrorCode::RPC_DRIVER, RADAR_IPC_PROCESS_SKELETON_NULL, __FUNCTION__);
        return RPC_BASE_INVOKER_CURRENT_NULL_ERR;
    }

    int error = ERR_NONE;
    std::lock_guard<std::mutex> lockGuard(objectMutex_);
    auto *stub = current->QueryStubByIndex(tr->cookie);
    if (stub == nullptr) {
        ZLOGE(LOG_LABEL, "stubIndex is invalid, listenFd:%{public}d seq:%{public}" PRIu64,
            listenFd, seqNum);
        DfxReportFailListenEvent(DbinderErrorCode::RPC_DRIVER, listenFd, RADAR_STUB_INVALID, __FUNCTION__);
        return RPC_BASE_INVOKER_STUBINDEX_ERR;
    }

    MessageOption option;
    option.SetFlags(tr->flags);
    auto *stubObject = reinterpret_cast<IPCObjectStub *>(stub);
    // cannot use stub any more after SendRequest because this cmd may be
    // dbinder dec ref and thus stub will be destroyed
    error = stubObject->SendRequest(tr->code, data, reply, option);
    if (error != ERR_NONE) {
        ZLOGW(LOG_LABEL, "stub sendrequest failed, cmd:%{public}u error:%{public}d "
            "listenFd:%{public}d seq:%{public}" PRIu64, tr->code, error, listenFd, seqNum);
        // can not return;
    }

    if (data.GetRawData() != nullptr) {
        ZLOGW(LOG_LABEL, "delete raw data in process skeleton, listenFd:%{public}d seq:%{public}" PRIu64,
            listenFd, seqNum);
        current->DetachRawData(listenFd);
    }
    return error;
}

template <class T> void DBinderBaseInvoker<T>::ProcessTransaction(dbinder_transaction_data *tr, int32_t listenFd)
{
    uint64_t senderSeqNumber = tr->seqNumber;
    MessageParcel data, reply;
    if (!IRemoteObjectTranslateWhenRcv(tr, data, listenFd)) {
        ZLOGE(LOG_LABEL, "translate object failed, listenFd:%{public}d seq:%{public}" PRIu64,
            listenFd, senderSeqNumber);
        DfxReportFailListenEvent(DbinderErrorCode::RPC_DRIVER, listenFd, RADAR_TRANSLATE_FAIL, __FUNCTION__);
        SendReplyWithSeqNum(senderSeqNumber, reply, tr->flags, RPC_BASE_INVOKER_TRANSLATE_ERR);
        return;
    }

    uint32_t oldStatus = GetStatus();
    DBinderCallerInfo oldCallerInfo;
    GetCallerInfo(oldCallerInfo);
    int ret = CheckAndSetCallerInfo(listenFd, tr->cookie);
    if (ret != ERR_NONE) {
        ZLOGE(LOG_LABEL, "check and set caller info failed, cmd:%{public}u listenFd:%{public}d", tr->code, listenFd);
        DfxReportFailListenEvent(DbinderErrorCode::RPC_DRIVER, listenFd, RADAR_CHECK_AND_SET_CALLER_FAIL, __FUNCTION__);
        SendReplyWithSeqNum(senderSeqNumber, reply, tr->flags, ret);
        return;
    }

    auto allocator = new (std::nothrow) DBinderSendAllocator();
    if (allocator == nullptr) {
        ZLOGE(LOG_LABEL, "DBinderSendAllocator failed, listenFd:%{public}d", listenFd);
        DfxReportFailListenEvent(DbinderErrorCode::RPC_DRIVER, listenFd, RADAR_SEND_ALLOCATOR_FAIL, __FUNCTION__);
        SendReplyWithSeqNum(senderSeqNumber, reply, tr->flags, ERR_ALLOC_MEMORY);
        SetCallerInfo(oldCallerInfo);
        return;
    }
    if (!data.SetAllocator(allocator)) {
        delete allocator;
        ZLOGE(LOG_LABEL, "SetAllocator failed, listenFd:%{public}d", listenFd);
        DfxReportFailListenEvent(DbinderErrorCode::RPC_DRIVER, listenFd, RADAR_SET_ALLOCATOR_FAIL, __FUNCTION__);
        SendReplyWithSeqNum(senderSeqNumber, reply, tr->flags, ERR_UNKNOWN_REASON);
        SetCallerInfo(oldCallerInfo);
        return;
    }
    data.ParseFrom(reinterpret_cast<uintptr_t>(tr->buffer), tr->buffer_size);
    if (!(tr->flags & MessageOption::TF_STATUS_CODE) && tr->offsets_size > 0) {
        data.InjectOffsets(reinterpret_cast<binder_uintptr_t>(reinterpret_cast<char *>(tr->buffer) + tr->offsets),
            tr->offsets_size / sizeof(binder_size_t));
    }

    uint32_t &newflags = const_cast<uint32_t &>(tr->flags);
    int isServerTraced = HitraceInvoker::TraceServerReceieve(tr->cookie, tr->code, data, newflags);
    SetStatus(IRemoteInvoker::ACTIVE_INVOKER);
    int error = TargetStubSendRequest(tr, listenFd, senderSeqNumber, data, reply);
    HitraceInvoker::TraceServerSend(tr->cookie, tr->code, isServerTraced, newflags);
    SendReplyWithSeqNum(senderSeqNumber, reply, tr->flags, error);
    SetStatus(oldStatus);
    SetCallerInfo(oldCallerInfo);
}

template <class T> void DBinderBaseInvoker<T>::ProcessReply(dbinder_transaction_data *tr, int32_t listenFd)
{
    IPCProcessSkeleton *current = IPCProcessSkeleton::GetCurrent();
    if (current == nullptr) {
        ZLOGE(LOG_LABEL, "IPCProcessSkeleton is nullptr, can not wakeup thread");
        DfxReportFailEvent(DbinderErrorCode::RPC_DRIVER, RADAR_IPC_PROCESS_SKELETON_NULL, __FUNCTION__);
        return;
    }

    std::shared_ptr<ThreadMessageInfo> messageInfo = current->QueryThreadBySeqNumber(tr->seqNumber);
    int32_t retryCount = 0;
    while (messageInfo == nullptr) {
        ZLOGW(LOG_LABEL, "query thread for reply failed, seqNum:%{public}llu, listenFd:%{public}d, retry:%{public}d",
            tr->seqNumber, listenFd, retryCount++);
        if (retryCount == REPLY_RETRY_COUNT) {
            ZLOGE(LOG_LABEL, "query thread for reply failed, no thread waiting reply message");
            DfxReportFailListenEvent(DbinderErrorCode::RPC_DRIVER, listenFd, RADAR_SEQ_MESSAGE_NULL, __FUNCTION__);
            return;  // messageInfo is null, no thread need to wakeup
        }
        std::this_thread::sleep_for(std::chrono::milliseconds(REPLY_RETRY_WAIT_MS));
        messageInfo = current->QueryThreadBySeqNumber(tr->seqNumber);
    }

    /* tr->sizeOfSelf > sizeof(dbinder_transaction_data) is checked in CheckTransactionData */
    messageInfo->buffer = new (std::nothrow) unsigned char[tr->sizeOfSelf - sizeof(dbinder_transaction_data)];
    if (messageInfo->buffer == nullptr) {
        ZLOGE(LOG_LABEL, "some thread is waiting for reply message, but no memory"
            ", seqNumber:%{public}llu listenFd:%{public}d", tr->seqNumber, listenFd);
        DfxReportFailListenEvent(DbinderErrorCode::RPC_DRIVER, listenFd, RADAR_SEQ_MESSAGE_BUFFER_NULL, __FUNCTION__);
        /* wake up sender thread */
        current->WakeUpThreadBySeqNumber(tr->seqNumber, listenFd);
        return;
    }
    /* copy receive message to sender thread */
    int memcpyResult = memcpy_s(messageInfo->buffer, tr->sizeOfSelf - sizeof(dbinder_transaction_data), tr->buffer,
        tr->sizeOfSelf - sizeof(dbinder_transaction_data));
    if (memcpyResult != 0) {
        ZLOGE(LOG_LABEL, "memcpy_s failed, error:%{public}d seqNumber:%{public}llu listenFd:%{public}d",
            memcpyResult, tr->seqNumber, listenFd);
        DfxReportFailListenEvent(DbinderErrorCode::RPC_DRIVER, listenFd, RADAR_ERR_MEMCPY_DATA, __FUNCTION__);
        delete[](unsigned char *) messageInfo->buffer;
        messageInfo->buffer = nullptr;
        /* wake up sender thread even no memssage */
        current->WakeUpThreadBySeqNumber(tr->seqNumber, listenFd);
        return;
    }

    messageInfo->flags = tr->flags;
    messageInfo->bufferSize = tr->buffer_size;
    messageInfo->offsetsSize = tr->offsets_size;
    messageInfo->offsets = tr->offsets;
    messageInfo->socketId = static_cast<uint32_t>(listenFd);

    /* wake up sender thread */
    current->WakeUpThreadBySeqNumber(tr->seqNumber, listenFd);
}

template <class T>
bool DBinderBaseInvoker<T>::ProcessRawData(std::shared_ptr<T> sessionObject, MessageParcel &data, uint64_t seqNum)
{
    if (data.GetRawData() == nullptr || data.GetRawDataSize() == 0) {
        return true; // do nothing, return true
    }

    std::shared_ptr<dbinder_transaction_data> transData = nullptr;
    size_t totalSize = sizeof(dbinder_transaction_data) + data.GetRawDataSize();
    transData.reset(reinterpret_cast<dbinder_transaction_data *>(::operator new(totalSize)));
    if (transData == nullptr) {
        ZLOGE(LOG_LABEL, "fail to create raw buffer with length:%{public}zu", totalSize);
        return false;
    }

    ConstructTransData(data, *transData, totalSize, seqNum, BC_SEND_RAWDATA, 0, 0);
    int result = memcpy_s(reinterpret_cast<char *>(transData.get()) + sizeof(dbinder_transaction_data),
        totalSize - sizeof(dbinder_transaction_data), data.GetRawData(), data.GetRawDataSize());
    if (result != 0) {
        ZLOGE(LOG_LABEL, "memcpy data fail, size:%{public}zu", data.GetRawDataSize());
        return false;
    }
    result = OnSendRawData(sessionObject, transData.get(), totalSize);
    if (result != 0) {
        ZLOGE(LOG_LABEL, "fail to send raw data");
        return false;
    }
    return true;
}

template <class T>
std::shared_ptr<dbinder_transaction_data> DBinderBaseInvoker<T>::ProcessNormalData(std::shared_ptr<T> sessionObject,
    MessageParcel &data, int32_t handle, int32_t socketId, uint64_t seqNum, int cmd, __u32 code, __u32 flags,
    int status)
{
    uint32_t sendSize = ((data.GetDataSize() > 0) ? data.GetDataSize() : sizeof(binder_size_t)) +
        sizeof(struct dbinder_transaction_data) + data.GetOffsetsSize() * T::GetFlatSessionLen() +
        data.GetOffsetsSize() * sizeof(binder_size_t);

    std::shared_ptr<dbinder_transaction_data> transData = nullptr;
    transData.reset(reinterpret_cast<dbinder_transaction_data *>(::operator new(sendSize)));
    if (transData == nullptr) {
        ZLOGE(LOG_LABEL, "new buffer failed of length:%{public}u", sendSize);
        return nullptr;
    }
    ConstructTransData(data, *transData, sendSize, seqNum, cmd, code, flags);
    transData->cookie = (handle == 0) ? 0 : sessionObject->GetStubIndex();
    if (MoveMessageParcel2TransData(data, sessionObject, transData, socketId, status) != true) {
        ZLOGE(LOG_LABEL, "move parcel to transData failed, handle:%{public}d socketId:%{public}d", handle, socketId);
        return nullptr;
    }
    return transData;
}

template <class T>
std::shared_ptr<ThreadProcessInfo> DBinderBaseInvoker<T>::MakeThreadProcessInfo(int32_t socketId, const char *inBuffer,
    uint32_t size)
{
    if (inBuffer == nullptr || size < sizeof(dbinder_transaction_data) || size > SOCKET_MAX_BUFF_SIZE) {
        ZLOGE(LOG_LABEL, "buffer is null or size:%{public}u invalid, socketId:%{public}d", size, socketId);
        return nullptr;
    }

    std::shared_ptr<ThreadProcessInfo> processInfo(new ThreadProcessInfo, [](ThreadProcessInfo *ptr) {
        if (ptr != nullptr) {
            delete ptr;
            ptr = nullptr;
        }
    });
    if (processInfo == nullptr) {
        ZLOGE(LOG_LABEL, "make ThreadProcessInfo fail, socketId:%{public}d", socketId);
        return nullptr;
    }
    std::shared_ptr<char> buffer(new (std::nothrow) char[size]);
    if (buffer == nullptr) {
        ZLOGE(LOG_LABEL, "new buffer failed of length:%{public}u socketId:%{public}d", size, socketId);
        return nullptr;
    }

    int memcpyResult = memcpy_s(buffer.get(), size, inBuffer, size);
    if (memcpyResult != 0) {
        ZLOGE(LOG_LABEL, "memcpy_s failed , size:%{public}u socketId:%{public}d", size, socketId);
        return nullptr;
    }

    processInfo->listenFd = socketId;
    processInfo->packageSize = size;
    processInfo->buffer = buffer;
    return processInfo;
}

template <class T>
bool DBinderBaseInvoker<T>::RemoveDBinderPtrData(std::shared_ptr<dbinder_transaction_data> tr, uint32_t &cutCount)
{
    size_t i = 0;
    size_t objCount = tr->offsets_size / sizeof(binder_size_t);
    while (i < objCount) {
        binder_size_t *offsets = reinterpret_cast<binder_size_t *>(tr->buffer + tr->buffer_size);
        auto obj = reinterpret_cast<binder_object_header *>(tr->buffer + offsets[i]);
        if (obj->type == BINDER_TYPE_PTR) {
            ZLOGI(LOG_LABEL, "ptr object offset:%{public}llu", offsets[i]);
            // record deleted offset
            binder_size_t delOffset = offsets[i];
            // update these offsets that following the deleted offset
            for (size_t j = i; (j + 1) < objCount; j++) {
                offsets[j] = offsets[j + 1] - sizeof(binder_buffer_object);
            }
            // update total offsets size
            tr->offsets_size -= sizeof(binder_size_t);

            // remove ptr space in the buffer
            size_t removeSize = tr->buffer_size + tr->offsets_size - delOffset - sizeof(binder_buffer_object);
            errno_t ret = memmove_s(tr->buffer + delOffset, removeSize,
                tr->buffer + delOffset + sizeof(binder_buffer_object), removeSize);
            if (ret != EOK) {
                ZLOGE(LOG_LABEL, "memmove fail, %{public}d", ret);
                return false;
            }
            // update buffer size
            tr->buffer_size -= sizeof(binder_buffer_object);
            // update offsets
            tr->offsets = tr->buffer_size;

            // clear the disused buffer space
            size_t delSize = sizeof(binder_size_t) + sizeof(binder_buffer_object) + T::GetFlatSessionLen();
            memset_s(tr->buffer + tr->buffer_size + tr->offsets_size, delSize, 0, delSize);
            // update sizeofSelf
            tr->sizeOfSelf -= delSize;
            ++cutCount;
        }
        ++i;
    }
    return true;
}

template <class T>
void DBinderBaseInvoker<T>::OverrideMessageParcelData(std::shared_ptr<dbinder_transaction_data> tr, MessageParcel &data)
{
    // override data(MessageParcel)
    data.FlushBuffer();
    data.WriteBuffer(reinterpret_cast<const void *>(tr->buffer), tr->buffer_size);
    // set offsets
    size_t objCount = tr->offsets_size / sizeof(binder_size_t);
    if (objCount > 0) {
        data.InjectOffsets(reinterpret_cast<binder_uintptr_t>(tr->buffer + tr->offsets), objCount);
    }
}

template <class T>
void DBinderBaseInvoker<T>::PrintDBinderTransaction(const char *funcName, const char *titleName,
    const dbinder_transaction_data *tr)
{
    if (funcName == nullptr || titleName == nullptr || tr == nullptr) {
        ZLOGE(LOG_LABEL, "invalid param");
        return;
    }
    ZLOGI(LOG_LABEL, "[%{public}s %{public}s]: sizeOfSelf:%{public}u, magic:%{public}u, version:%{public}u, "
        "cmd:%{public}d, code:%{public}u, flags:%{public}u, cookie:%{public}llu, seqNumber:%{public}llu, "
        "buffer_size:%{public}llu, offsets_size:%{public}llu, offsets:%{public}llu, "
        "sizeof(dbinder_transaction_data):%{public}zu",
        funcName, titleName, tr->sizeOfSelf, tr->magic, tr->version, tr->cmd, tr->code, tr->flags, tr->cookie,
        tr->seqNumber, tr->buffer_size, tr->offsets_size, tr->offsets, sizeof(dbinder_transaction_data));
}

template <class T>
void DBinderBaseInvoker<T>::PrintBuffer(const char *funcName, const char *titleName, const uint8_t *data,
    size_t length)
{
    std::string format;
    size_t idx = 0;
    while (idx < length) {
        format += std::to_string(data[idx]) + ',';
        ++idx;
    }
    ZLOGI(LOG_LABEL, "[%{public}s %{public}s]: length:%{public}zu, content:%{public}s",
        funcName, titleName, length, format.c_str());
}

template <class T>
bool DBinderBaseInvoker<T>::MoveMessageParcel2TransData(MessageParcel &data, std::shared_ptr<T> sessionObject,
    std::shared_ptr<dbinder_transaction_data> transData, int32_t socketId, int status)
{
    if (data.GetDataSize() > 0) {
        /* Send this parcel's data through the socket. */
        transData->buffer_size = data.GetDataSize();
        uint32_t useSize = transData->sizeOfSelf - sizeof(dbinder_transaction_data);
        int memcpyResult =
            memcpy_s(transData->buffer, useSize, reinterpret_cast<void *>(data.GetData()), transData->buffer_size);
        if (data.GetOffsetsSize() > 0) {
            memcpyResult += memcpy_s(transData->buffer + transData->buffer_size, useSize - transData->buffer_size,
                reinterpret_cast<void *>(data.GetObjectOffsets()), data.GetOffsetsSize() * sizeof(binder_size_t));
        }
        if (memcpyResult != 0) {
            ZLOGE(LOG_LABEL, "parcel data memcpy_s failed, socketId:%{public}d", socketId);
            return false;
        }
        transData->offsets_size = data.GetOffsetsSize() * sizeof(binder_size_t);
        transData->offsets = transData->buffer_size;

        // remove dbinder PTR data
        uint32_t cutCount = 0;
        if (!RemoveDBinderPtrData(transData, cutCount)) {
            ZLOGE(LOG_LABEL, "RemoveDBinderPtrData fail");
            return false;
        }
        if (cutCount > 0) {
            OverrideMessageParcelData(transData, data);
        }

        if (!CheckTransactionData(transData.get())) {
            ZLOGE(LOG_LABEL, "check trans data fail, socketId:%{public}d", socketId);
            return false;
        }
        if (!IRemoteObjectTranslateWhenSend(transData, socketId, sessionObject)) {
            ZLOGE(LOG_LABEL, "translate object failed, socketId:%{public}d", socketId);
            return false;
        }
    } else {
        transData->flags |= TF_STATUS_CODE;
        transData->buffer_size = sizeof(binder_size_t);
        transData->offsets_size = static_cast<binder_size_t>(status);
        transData->offsets = transData->buffer_size;
    }
    return true;
}
} // namespace OHOS
#endif // OHOS_IPC_DBINDER_BASE_INVOKER_PROCESS_H