openharmony/communication_dsoftbus
1
0
Fork 0
mirror of https://gitee.com/openharmony/communication_dsoftbus synced 2024-12-18 15:28:15 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix: Modify to asyn IPC operation

Browse Source 
Signed-off-by: liangjunhao <liangjunhao10@huawei.com>
This commit is contained in:
liangjunhao 2023-12-22 16:09:20 +08:00
parent 961d30086b
commit 8b267c56c0
1 changed files with 12 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
core/transmission/ipc/standard/src/trans_client_proxy_standard.cpp
View File

@ -174,17 +174,23 @@ int32_t TransClientProxy::OnChannelOpened(const char *sessionName, const Channel
MessageParcel reply;
MessageOption option;
if (channel->channelType != CHANNEL_TYPE_UDP) {
option = { MessageOption::TF_ASYNC };
}
int32_t ret = remote->SendRequest(CLIENT_ON_CHANNEL_OPENED, data, reply, option);
if (ret != SOFTBUS_OK) {
TRANS_LOGE(TRANS_CTRL, "OnChannelOpened send request failed, ret=%{public}d", ret);
return SOFTBUS_ERR;
}
int32_t serverRet;
if (!reply.ReadInt32(serverRet)) {
TRANS_LOGE(TRANS_CTRL, "OnChannelOpened read serverRet failed");
return SOFTBUS_ERR;
if (channel->channelType == CHANNEL_TYPE_UDP) {
int32_t serverRet = 0;
if (!reply.ReadInt32(serverRet)) {
TRANS_LOGE(TRANS_CTRL, "Udp type OnChannelOpened read serverRet failed");
return SOFTBUS_ERR;
}
return serverRet;
}
return serverRet;
return SOFTBUS_OK;
}
int32_t TransClientProxy::OnChannelOpenFailed(int32_t channelId, int32_t channelType, int32_t errCode)
@ -280,7 +286,7 @@ int32_t TransClientProxy::OnChannelClosed(int32_t channelId, int32_t channelType
return SOFTBUS_ERR;
}
MessageParcel reply;
MessageOption option;
MessageOption option = { MessageOption::TF_ASYNC };
int32_t ret = remote->SendRequest(CLIENT_ON_CHANNEL_CLOSED, data, reply, option);
if (ret != SOFTBUS_OK) {
TRANS_LOGE(TRANS_CTRL, "OnChannelClosed send request failed, ret=%{public}d", ret);