/foundation/ace/ace_engine_lite/frameworks/src/core/base/ |
D | string_util.cpp | 24 char *StringUtil::Copy(const char *sequence) in Copy() argument 26 if (sequence == nullptr) { in Copy() 29 size_t size = strlen(sequence); in Copy() 37 if (strncpy_s(buffer, size + 1, sequence, size) == 0) { in Copy() 52 char *StringUtil::Slice(const char *sequence, const int32_t start) in Slice() argument 54 return StringUtil::Slice(sequence, start, strlen(sequence)); in Slice() 56 char *StringUtil::Slice(const char *sequence, const int32_t start, const int32_t end) in Slice() argument 58 if (sequence == nullptr) { in Slice() 61 uint32_t size = strlen(sequence); in Slice() 80 if (strncpy_s(buffer, diffSize + 1, sequence + startIdx, diffSize) == 0) { in Slice() [all …]
|
D | string_util.h | 26 static char *Copy(const char *sequence); 28 static char *Slice(const char *sequence, const int32_t start); 29 static char *Slice(const char *sequence, const int32_t start, const int32_t end); 30 static bool StartsWith(const char *sequence, const char *subsequence); 31 static char *Trim(char *sequence);
|
/foundation/graphic/standard/frameworks/surface/src/ |
D | buffer_queue.cpp | 223 retval.sequence = bufferImpl->GetSeqNum(); in RequestBuffer() 228 …BLOGD("Success alloc Buffer id: %{public}d Queue id: %{public}" PRIu64 "", retval.sequence, unique… in RequestBuffer() 241 retval.sequence = bufferImpl->GetSeqNum(); in ReuseBuffer() 242 bool needRealloc = (config != bufferQueueCache_[retval.sequence].config); in ReuseBuffer() 248 DeleteBufferInCache(retval.sequence); in ReuseBuffer() 257 retval.sequence = bufferImpl->GetSeqNum(); in ReuseBuffer() 258 bufferQueueCache_[retval.sequence].config = config; in ReuseBuffer() 261 bufferQueueCache_[retval.sequence].state = BUFFER_STATE_REQUESTED; in ReuseBuffer() 262 retval.fence = bufferQueueCache_[retval.sequence].fence; in ReuseBuffer() 265 bufferQueueCache_[retval.sequence].fence = -1; in ReuseBuffer() [all …]
|
D | buffer_client_producer.cpp | 39 #define SEND_REQUEST_WITH_SEQ(COMMAND, arguments, reply, option, sequence) \ argument 43 BLOGN_FAILURE_ID(sequence, "SendRequest return %{public}d", ret); \ 48 #define CHECK_RETVAL_WITH_SEQ(reply, sequence) \ argument 52 BLOGN_FAILURE_ID(sequence, "Remote return %{public}d", ret); \ 77 CHECK_RETVAL_WITH_SEQ(reply, retval.sequence); in RequestBuffer() 79 ReadSurfaceBufferImpl(reply, retval.sequence, retval.buffer); in RequestBuffer() 86 GSError BufferClientProducer::CancelBuffer(int32_t sequence, BufferExtraData &bedata) in CancelBuffer() argument 90 arguments.WriteInt32(sequence); in CancelBuffer() 93 SEND_REQUEST_WITH_SEQ(BUFFER_PRODUCER_CANCEL_BUFFER, arguments, reply, option, sequence); in CancelBuffer() 94 CHECK_RETVAL_WITH_SEQ(reply, sequence); in CancelBuffer() [all …]
|
D | buffer_queue_producer.cpp | 91 WriteSurfaceBufferImpl(reply, retval.sequence, retval.buffer); in RequestBufferRemote() 101 int32_t sequence; in CancelBufferRemote() local 104 sequence = arguments.ReadInt32(); in CancelBufferRemote() 107 GSError sret = CancelBuffer(sequence, bedataimpl); in CancelBufferRemote() 115 int32_t sequence; in FlushBufferRemote() local 119 sequence = arguments.ReadInt32(); in FlushBufferRemote() 124 GSError sret = FlushBuffer(sequence, bedataimpl, fence, config); in FlushBufferRemote() 221 cache[retval.sequence] = retval.buffer; in RequestBuffer() 222 sended.insert(retval.sequence); in RequestBuffer() 226 retval.buffer = cache[retval.sequence].promote(); in RequestBuffer() [all …]
|
D | buffer_utils.cpp | 91 int32_t &sequence, sptr<SurfaceBuffer>& buffer) in ReadSurfaceBufferImpl() argument 93 sequence = parcel.ReadInt32(); in ReadSurfaceBufferImpl() 95 sptr<SurfaceBufferImpl> bufferImpl = new SurfaceBufferImpl(sequence); in ReadSurfaceBufferImpl() 114 int32_t sequence, const sptr<SurfaceBuffer> &buffer) in WriteSurfaceBufferImpl() argument 116 parcel.WriteInt32(sequence); in WriteSurfaceBufferImpl()
|
D | producer_surface.cpp | 71 BLOGN_FAILURE_ID(retval.sequence, "Map failed"); in RequestBuffer() 74 BLOGN_SUCCESS_ID(retval.sequence, "Map"); in RequestBuffer() 79 bufferProducerCache_[retval.sequence] = SurfaceBufferImpl::FromBase(retval.buffer); in RequestBuffer() 80 } else if (bufferProducerCache_.find(retval.sequence) == bufferProducerCache_.end()) { in RequestBuffer() 83 retval.buffer = bufferProducerCache_[retval.sequence]; in RequestBuffer() 92 BLOGNW("Warning [%{public}d], InvalidateCache failed", retval.sequence); in RequestBuffer()
|
D | producer_egl_surface.cpp | 80 BLOGN_FAILURE_ID(retval.sequence, "Map failed"); in RequestBuffer() 82 BLOGN_SUCCESS_ID(retval.sequence, "Map"); in RequestBuffer() 87 bufferProducerCache_[retval.sequence] = SurfaceBufferImpl::FromBase(retval.buffer); in RequestBuffer() 89 retval.buffer = bufferProducerCache_[retval.sequence]; in RequestBuffer() 96 BLOGNW("Warning [%{public}d], InvalidateCache failed", retval.sequence); in RequestBuffer()
|
/foundation/graphic/standard/frameworks/wmtest/frameworks/ |
D | native_test_ipc_stub.cpp | 35 int32_t sequence = 0; in OnRemoteRequest() local 41 sequence = arguments.ReadInt32(); in OnRemoteRequest() 47 reply.WriteInt32(SendMessage(sequence, message, remoteObject)); in OnRemoteRequest() 50 sequence = arguments.ReadInt32(); in OnRemoteRequest() 59 reply.WriteInt32(Register(sequence, ipc)); in OnRemoteRequest() 62 sequence = arguments.ReadInt32(); in OnRemoteRequest() 68 reply.WriteInt32(OnMessage(sequence, message, remoteObject)); in OnRemoteRequest()
|
D | inative_test.cpp | 222 GSError INativeTest::IPCClientSendMessage(int32_t sequence, const std::string &message, const sptr<… in IPCClientSendMessage() argument 224 …GSLOG7SO(INFO) << "send message from " << GetProcessSequence() << " to " << sequence << ": " << me… in IPCClientSendMessage() 225 return remoteIpc->SendMessage(sequence, message, robj); in IPCClientSendMessage() 228 void INativeTest::IPCClientOnMessage(int32_t sequence, const std::string &message, const sptr<IRemo… in IPCClientOnMessage() argument 230 GSLOG7SO(INFO) << "Received from " << sequence << ", message: " << message; in IPCClientOnMessage() 249 GSError INativeTest::SendMessage(int32_t sequence, const std::string &message, const sptr<IRemoteOb… in SendMessage() argument 251 GSLOG7SO(DEBUG) << "Received from " << pidToSeq[GetCallingPid()] << " to " << sequence in SendMessage() 253 if (sequence != -1) { in SendMessage() 254 auto it = ipcs.find(sequence); in SendMessage() 256 GSLOG7SO(WARN) << "Cannot found send target! (-> " << sequence << ")"; in SendMessage() [all …]
|
D | native_test_ipc_proxy.cpp | 30 GSError NativeTestIpcProxy::SendMessage(int32_t sequence, const std::string &message, const sptr<IR… in SendMessage() argument 40 arg.WriteInt32(sequence); in SendMessage() 56 GSError NativeTestIpcProxy::Register(int32_t sequence, sptr<INativeTestIpc> &ipc) in Register() argument 66 arg.WriteInt32(sequence); in Register() 77 GSError NativeTestIpcProxy::OnMessage(int32_t sequence, const std::string &message, const sptr<IRem… in OnMessage() argument 87 arg.WriteInt32(sequence); in OnMessage()
|
D | inative_test_ipc.h | 25 …virtual GSError SendMessage(int32_t sequence, const std::string &message, const sptr<IRemoteObject… 26 virtual GSError Register(int32_t sequence, sptr<INativeTestIpc> &ipc) = 0; 27 …virtual GSError OnMessage(int32_t sequence, const std::string &message, const sptr<IRemoteObject> …
|
D | native_test_ipc_proxy.h | 29 …virtual GSError SendMessage(int32_t sequence, const std::string &message, const sptr<IRemoteObject… 30 virtual GSError Register(int32_t sequence, sptr<INativeTestIpc> &ipc) override; 31 …virtual GSError OnMessage(int32_t sequence, const std::string &message, const sptr<IRemoteObject> …
|
D | inative_test.h | 82 GSError IPCClientSendMessage(int32_t sequence, 84 …virtual void IPCClientOnMessage(int32_t sequence, const std::string &message, const sptr<IRemoteOb… 92 …virtual GSError SendMessage(int32_t sequence, const std::string &message, const sptr<IRemoteObject… 93 virtual GSError Register(int32_t sequence, sptr<INativeTestIpc> &ipc) override; 94 …virtual GSError OnMessage(int32_t sequence, const std::string &message, const sptr<IRemoteObject> …
|
/foundation/graphic/standard/frameworks/surface/test/unittest/ |
D | buffer_queue_test.cpp | 139 ASSERT_GE(retval.sequence, 0); 142 cache[retval.sequence] = retval.buffer; 149 ret = bq->FlushBuffer(retval.sequence, bedata, -1, flushConfig); 183 ASSERT_GE(retval.sequence, 0); 186 ret = bq->CancelBuffer(retval.sequence, bedata); 206 ASSERT_GE(retval.sequence, 0); 209 ret = bq->CancelBuffer(retval.sequence, bedata); 212 ret = bq->CancelBuffer(retval.sequence, bedata); 232 ASSERT_GE(retval.sequence, 0); 235 ret = bq->FlushBuffer(retval.sequence, bedata, -1, flushConfig); [all …]
|
D | buffer_queue_producer_test.cpp | 108 ret = bqp->CancelBuffer(retval.sequence, bedata); 127 ret = bqp->CancelBuffer(retval.sequence, bedata); 130 ret = bqp->CancelBuffer(retval.sequence, bedata); 160 ret = bqp->CancelBuffer(retval1.sequence, bedata); 163 ret = bqp->CancelBuffer(retval2.sequence, bedata); 166 ret = bqp->CancelBuffer(retval3.sequence, bedata); 185 ret = bqp->FlushBuffer(retval.sequence, bedata, -1, flushConfig); 212 ret = bqp->FlushBuffer(retval.sequence, bedata, -1, flushConfig); 215 ret = bqp->FlushBuffer(retval.sequence, bedata, -1, flushConfig);
|
D | buffer_client_producer_remote_test.cpp | 167 ret = bp->CancelBuffer(retval.sequence, bedata); 186 ret = bp->CancelBuffer(retval.sequence, bedata); 189 ret = bp->CancelBuffer(retval.sequence, bedata); 219 ret = bp->CancelBuffer(retval1.sequence, bedata); 222 ret = bp->CancelBuffer(retval2.sequence, bedata); 225 ret = bp->CancelBuffer(retval3.sequence, bedata); 248 ret = bp->CancelBuffer(retval.sequence, bedata); 269 ret = bp->FlushBuffer(retval.sequence, bedata, -1, flushConfig); 287 ret = bp->FlushBuffer(retval.sequence, bedata, -1, flushConfig); 290 ret = bp->FlushBuffer(retval.sequence, bedata, -1, flushConfig);
|
D | buffer_queue_producer_remote_test.cpp | 131 ret = bp->CancelBuffer(retval.sequence, bedata); 155 ret = bp->CancelBuffer(retval.sequence, bedata); 158 ret = bp->CancelBuffer(retval.sequence, bedata); 193 ret = bp->CancelBuffer(retval1.sequence, bedata); 196 ret = bp->CancelBuffer(retval2.sequence, bedata); 199 ret = bp->CancelBuffer(retval3.sequence, bedata); 223 ret = bp->FlushBuffer(retval.sequence, bedata, -1, flushConfig); 254 ret = bp->FlushBuffer(retval.sequence, bedata, -1, flushConfig); 257 ret = bp->FlushBuffer(retval.sequence, bedata, -1, flushConfig);
|
D | buffer_queue_consumer_test.cpp | 80 ASSERT_GE(retval.sequence, 0); 86 ret = bq->FlushBuffer(retval.sequence, bedata, -1, flushConfig); 112 ASSERT_GE(retval.sequence, 0); 115 ret = bq->FlushBuffer(retval.sequence, bedata, -1, flushConfig);
|
/foundation/graphic/standard/frameworks/surface/include/ |
D | buffer_queue.h | 63 GSError CancelBuffer(int32_t sequence, const BufferExtraData &bedata); 65 GSError FlushBuffer(int32_t sequence, const BufferExtraData &bedata, 68 GSError DoFlushBuffer(int32_t sequence, const BufferExtraData &bedata, 104 void DeleteBufferInCache(int sequence); 105 void DumpToFile(int32_t sequence);
|
D | buffer_utils.h | 35 void ReadSurfaceBufferImpl(MessageParcel &parcel, int32_t &sequence, sptr<SurfaceBuffer> &buffer); 36 void WriteSurfaceBufferImpl(MessageParcel &parcel, int32_t sequence, const sptr<SurfaceBuffer> &buf…
|
D | buffer_client_producer.h | 38 GSError CancelBuffer(int32_t sequence, BufferExtraData &bedata) override; 40 GSError FlushBuffer(int32_t sequence, BufferExtraData &bedata,
|
/foundation/graphic/standard/interfaces/innerkits/surface/ |
D | ibuffer_producer.h | 32 int32_t sequence; member 40 virtual GSError CancelBuffer(int32_t sequence, BufferExtraData &bedata) = 0; 42 virtual GSError FlushBuffer(int32_t sequence, BufferExtraData &bedata,
|
/foundation/graphic/standard/rosen/modules/render_service_base/src/platform/ohos/ |
D | rs_vsync_client_ohos.cpp | 31 static int sequence = 0; in RSVsyncClientOhos() local 33 name += "_" + std::to_string(::getpid()) + "_" + std::to_string(sequence); in RSVsyncClientOhos()
|
/foundation/communication/ipc/ipc/native/src/core/source/ |
D | ipc_thread_pool.cpp | 82 int sequence = threadSequence_.fetch_add(1, std::memory_order_relaxed); in MakeThreadName() local 85 return std::to_string(sequence) + threadName; in MakeThreadName() 88 return std::to_string(sequence) + threadName; in MakeThreadName()
|