openharmony/communication_ipc
1
0
Fork 0
mirror of https://gitee.com/openharmony/communication_ipc synced 2024-11-24 00:09:51 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

增加内核未消费完数据的后续处理2

Browse Source 
Signed-off-by: luodonghui <luodonghui@huawei.com>
Change-Id: I598d4bb1cffb7c4e7a517868bb86563d4c250f40
This commit is contained in:
luodonghui 2024-08-27 17:11:41 +08:00
parent 8f7fa1f27e
commit a75d087cf9
1 changed files with 13 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
ipc/native/src/mock/source/binder_invoker.cpp
View File

@ -1041,20 +1041,20 @@ void BinderInvoker::UpdateConsumedData(const binder_write_read &bwr, const size_
ZLOGE(LABEL, "binder write_consumed:%{public}llu exception, "
"outAvail:%{public}zu read_consumed:%{public}llu",
bwr.write_consumed, outAvail, bwr.read_consumed);
}
// Moves the data that is not consumed by the binder to the output_ buffer header.
if (bwr.write_consumed < output_.GetDataSize()) {
ZLOGI(LABEL, "moves the data that is not consumed by the binder, "
"write_consumed:%{public}llu outAvail:%{public}zu GetDataSize:%{public}zu",
bwr.write_consumed, outAvail, output_.GetDataSize());
Parcel temp;
temp.WriteBuffer(reinterpret_cast<void *>(output_.GetData() + bwr.write_consumed),
output_.GetDataSize() - bwr.write_consumed);
output_.FlushBuffer();
output_.WriteBuffer(reinterpret_cast<void *>(temp.GetData()), temp.GetDataSize());
} else {
// Moves the data that is not consumed by the binder to the output_ buffer header.
if (outAvail < output_.GetDataSize()) {
ZLOGI(LABEL, "moves the data that is not consumed by the binder, "
"write_consumed:%{public}llu outAvail:%{public}zu GetDataSize:%{public}zu",
bwr.write_consumed, outAvail, output_.GetDataSize());
Parcel temp;
temp.WriteBuffer(reinterpret_cast<void *>(output_.GetData() + bwr.write_consumed),
output_.GetDataSize() - bwr.write_consumed);
output_.FlushBuffer();
output_.WriteBuffer(reinterpret_cast<void *>(temp.GetData()), temp.GetDataSize());
} else {
output_.FlushBuffer();
}
output_.FlushBuffer();
}
}
if (bwr.read_consumed > 0) {