openharmony/graphic_graphic_2d
1
0
Fork 0
mirror of https://gitee.com/openharmony/graphic_graphic_2d synced 2025-01-24 03:49:01 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

support local and remote

Browse Source 
Change-Id: I21cf7d28329fccbb0b7d38e00fff2e761c1c4566
Signed-off-by: luwh0708 <1632083718@qq.com>
This commit is contained in:
luwh0708 2021-08-12 21:25:36 +08:00
parent 4c6c69f910
commit 53b0e3ac78
1 changed files with 26 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
frameworks/surface/src/buffer_queue_producer.cpp
View File

@ -15,6 +15,8 @@
#include "buffer_queue_producer.h"
#include <set>
#include "buffer_extra_data_impl.h"
#include "buffer_log.h"
#include "buffer_manager.h"
@ -181,12 +183,36 @@ int BufferQueueProducer::CleanCacheInner(MessageParcel& arguments, MessageParcel
SurfaceError BufferQueueProducer::RequestBuffer(int32_t& sequence, sptr<SurfaceBuffer>& buffer,
int32_t& fence, BufferRequestConfig& config, std::vector<int32_t>& deletingBuffers)
{
static std::map<int32_t, wptr<SurfaceBufferImpl>> cache;
static std::map<pid_t, std::set<int32_t>> sendeds;
if (bufferQueue_ == nullptr) {
return SURFACE_ERROR_NULLPTR;
}
sptr<SurfaceBufferImpl> bufferImpl = SurfaceBufferImpl::FromBase(buffer);
BufferQueue::RequestBufferReturnValue retval = {.buffer = bufferImpl};
auto sret = bufferQueue_->RequestBuffer(config, retval);
/* The first remote call from a different process returns a non-null pointer,
* and all others return null Pointers.
* A local call always returns a non-null pointer. */
if (sret == SURFACE_ERROR_OK) { // success
if (retval.buffer != nullptr) { // add to cache
cache[retval.sequence] = retval.buffer;
} else { // not first
if (GetCallingPid() == getpid()) { // local calling
retval.buffer = cache[retval.sequence].promote();
} else { // remote calling, first isn't nullptr
auto& sended = sendeds[GetCallingPid()];
if (sended.find(retval.sequence) == sended.end()) {
retval.buffer = cache[retval.sequence].promote();
sended.insert(retval.sequence);
}
}
}
}
for (const auto &buffer : deletingBuffers) {
cache.erase(buffer);
sendeds[GetCallingPid()].erase(buffer);
}
sequence = retval.sequence;
buffer = retval.buffer;