/foundation/CastEngine/castengine_wifi_display/services/utils/ |
H A D | data_buffer.cpp | 28 capacity_ = size; in DataBuffer() 35 capacity_ = other.size_; 36 data_ = new uint8_t[capacity_ + 1]; 37 memcpy_s(data_, capacity_ + 1, other.data_, other.size_); 46 capacity_ = other.size_; 48 data_ = new uint8_t[capacity_ + 1]; 49 memcpy_s(data_, capacity_ + 1, other.data_, other.size_); 61 capacity_ = other.capacity_; 64 other.capacity_ [all...] |
H A D | circular_buffer.h | 38 capacity_ = capacity; in circular_buffer() 44 capacity_ = copy.capacity(); in circular_buffer() 60 size_t capacity_ = 0; member in OHOS::Sharing::circular_buffer 68 set_capacity(capacity_); in clear() 101 capacity_ = new_capacity; in set_capacity() 106 return size() == capacity_; in full() 126 return capacity_; in capacity() 166 capacity_ = copy.capacity(); in operator =()
|
/foundation/graphic/graphic_utils_lite/interfaces/kits/gfx_utils/ |
H A D | vector.h | 39 Vector(uint16_t capacity = 1) : capacity_(capacity) in Vector() 46 capacity_ = value.Capacity(); in Vector() 47 array_ = new T[capacity_]; in Vector() 73 if (size_ == capacity_) { in PushBack() 74 capacity_ <<= 1; in PushBack() 75 T* array = new T[capacity_]; in PushBack() 120 return capacity_; in Capacity() 125 if (size <= capacity_) { in ReSize() 148 uint16_t capacity = capacity_; in Swap() 149 capacity_ in Swap() 179 uint16_t capacity_ = 0; global() member in OHOS::Graphic::Vector [all...] |
/foundation/ability/idl_tool/util/ |
H A D | string_builder.cpp | 36 if (position_ + 1 >= capacity_) { in Append() 54 if (position_ + len >= capacity_) { in Append() 60 if (memcpy_s(buffer_ + position_, capacity_ - position_, string, len) != EOK) { in Append() 74 if (position_ + len >= capacity_) { in Append() 80 if (memcpy_s(buffer_ + position_, capacity_ - position_, string.string(), len) != EOK) { in Append() 103 if (positionTmp >= capacity_) { in AppendFormat() 125 if (capacity_ > String::MAX_SIZE) { in Grow() 130 size_t newSize = (capacity_ == 0 ? 256 : capacity_ * 2); in Grow() 131 if (newSize < capacity_ in Grow() [all...] |
/foundation/ability/idl_tool/idl_tool_2/util/ |
H A D | string_builder.cpp | 37 if (position_ + 1 >= capacity_) { in Append() 55 if (position_ + len >= capacity_) { in Append() 61 int ret = memcpy_s(buffer_ + position_, capacity_ - position_, string, len); in Append() 77 if (position_ + len >= capacity_) { in Append() 83 int ret = memcpy_s(buffer_ + position_, capacity_ - position_, string.c_str(), len); in Append() 109 if (position_ + writeSize >= capacity_) { in AppendFormat() 132 if (capacity_ > StringHelper::maxSize) { in Grow() 137 size_t newSize = (capacity_ == 0) ? 256 : (capacity_ * 2); in Grow() 138 if (newSize < capacity_ in Grow() [all...] |
/foundation/distributedhardware/distributed_screen/services/common/databuffer/src/ |
H A D | data_buffer.cpp | 30 capacity_ = capacity; in DataBuffer() 45 capacity_ = 0; in ~DataBuffer() 50 return capacity_; in Capacity() 60 capacity_ = size; in SetSize() 86 if (capacity < capacity_) { in ResetCapcity() 92 capacity_ = 0; in ResetCapcity() 94 capacity_ = capacity; in ResetCapcity() 103 int32_t ret = memcpy_s(data_ + capacity_, dataSize, inputData, dataSize); in AddData() 108 capacity_ += dataSize; in AddData() 123 if (static_cast<unsigned long>(offset + datasize) > capacity_ || outpu in GetData() [all...] |
/foundation/multimedia/media_foundation/tests/unittest/avbuffer/ |
H A D | avbuffer_func_unit_test.cpp | 308 DmabufHeapBuffer dmaBuffer = {.size = capacity_, .heapFlags = 0}; in HWTEST_F() 313 allocator_ = AVAllocatorFactory::CreateHardwareAllocator(0, capacity_, memFlag_); in HWTEST_F() 345 capacity_ = MEMSIZE; in HWTEST_F() 355 EXPECT_EQ(buffer_->memory_->capacity_, capacity_); in HWTEST_F() 368 capacity_ = MEMSIZE; in HWTEST_F() 372 remoteBuffer_ = buffer_ = AVBuffer::CreateAVBuffer(allocator_, capacity_, align_); in HWTEST_F() 374 EXPECT_EQ(buffer_->memory_->GetCapacity(), capacity_); in HWTEST_F() 385 capacity_ = MEMSIZE; in HWTEST_F() 395 EXPECT_EQ(buffer_->memory_->capacity_, capacity in HWTEST_F() 1850 EXPECT_EQ(memcmp(static_cast<void *>(addr), inputBuffer_.data(), capacity_), 0); HWTEST_F() local 1856 EXPECT_EQ(memcmp(static_cast<void *>(addr), inputBuffer_.data(), capacity_), 0); HWTEST_F() local 1857 EXPECT_EQ(memcmp(static_cast<void *>(addr), outputBuffer_.data(), capacity_), 0); HWTEST_F() local [all...] |
H A D | avbuffer_unit_test.cpp | 78 DmabufHeapBuffer dmaBuffer = {.size = capacity_, .heapFlags = 0}; in CreateLocalHardwareMem() 83 allocator_ = AVAllocatorFactory::CreateHardwareAllocator(dmaBuffer.fd, capacity_, memFlag_); in CreateLocalHardwareMem() 85 remoteBuffer_ = buffer_ = AVBuffer::CreateAVBuffer(allocator_, capacity_, align_); in CreateLocalHardwareMem() 93 DmabufHeapBuffer dmaBuffer = {.size = capacity_, .heapFlags = 0}; in CreateLocalHardwareMemSecure() 98 allocator_ = AVAllocatorFactory::CreateHardwareAllocator(dmaBuffer.fd, capacity_, memFlag_, true); in CreateLocalHardwareMemSecure() 100 remoteBuffer_ = buffer_ = AVBuffer::CreateAVBuffer(allocator_, capacity_, align_); in CreateLocalHardwareMemSecure() 108 DmabufHeapBuffer dmaBuffer = {.size = capacity_, .heapFlags = 0}; in CreateLocalHardwareMemByConfig() 114 config_.size = capacity_; in CreateLocalHardwareMemByConfig() 137 remoteBuffer_ = buffer_ = AVBuffer::CreateAVBuffer(allocator_, capacity_, align_); in CreateLocalSharedMem() 146 config_.size = capacity_; in CreateLocalSharedMemByConfig() 395 EXPECT_EQ(memcmp(static_cast<void *>(addr), inputBuffer_.data(), capacity_), 0); CheckMemTrans() local 396 EXPECT_EQ(memcmp(static_cast<void *>(addr), outputBuffer_.data(), capacity_), 0); CheckMemTrans() local 406 EXPECT_EQ(memcmp(static_cast<void *>(addr), inputBuffer_.data(), capacity_), 0); CheckMemTrans() local 407 EXPECT_EQ(memcmp(static_cast<void *>(addr), outputBuffer_.data(), capacity_), 0); CheckMemTrans() local [all...] |
/foundation/multimedia/camera_framework/services/deferred_processing_service/src/base/buffer_manager/ |
H A D | shared_buffer.cpp | 27 : capacity_(capacity) in SharedBuffer() 29 DP_DEBUG_LOG("entered, capacity = %{public}ld", static_cast<long>(capacity_)); in SharedBuffer() 53 DP_CHECK_ERROR_RETURN_RET_LOG(bytes > capacity_, DP_INVALID_PARAM, in CopyFrom() 55 static_cast<long>(bytes), static_cast<long>(capacity_)); in CopyFrom() 58 static_cast<long>(capacity_), static_cast<long>(bytes)); in CopyFrom() 74 ashmem_ = Ashmem::CreateAshmem(name.data(), capacity_); in AllocateAshmemUnlocked() 76 "buffer create ashmem failed. capacity: %{public}ld", static_cast<long>(capacity_)); in AllocateAshmemUnlocked() 78 DP_DEBUG_LOG("size: %{public}ld, fd: %{public}d", static_cast<long>(capacity_), fd); in AllocateAshmemUnlocked() 90 DP_DEBUG_LOG("dealloc ashmem capacity(%{public}ld) success.", static_cast<long>(capacity_)); in DeallocAshmem()
|
/foundation/multimedia/media_foundation/src/buffer/avsharedmemory/ |
H A D | avsharedmemorybase.cpp | 64 : base_(nullptr), capacity_(size), flags_(flags), name_(name), fd_(-1), size_(0) in AVSharedMemoryBase() 71 : base_(nullptr), capacity_(size), flags_(flags), name_(name), fd_(dup(fd)), size_(0) in AVSharedMemoryBase() 89 name_.c_str(), capacity_, flags_, fd_); in Init() 93 FALSE_RETURN_V_MSG_E(capacity_ > 0, static_cast<int32_t>(Status::ERROR_INVALID_PARAMETER), in Init() 94 "size is invalid, size = %{public}d", capacity_); in Init() 99 FALSE_RETURN_V_MSG_E(size == capacity_, static_cast<int32_t>(Status::ERROR_INVALID_PARAMETER), in Init() 100 "size not equal capacity_, size = %{public}d, capacity_ = %{public}d", size, capacity_); in Init() 103 fd_ = AshmemCreate(name_.c_str(), static_cast<size_t>(capacity_)); in Init() [all...] |
/foundation/multimedia/media_foundation/interface/inner_api/osal/task/ |
H A D | blocking_queue.h | 34 : name_(std::move(name)), capacity_(capacity), isActive(true) in BlockingQueue() 46 return capacity_; in Capacity() 60 if (que_.size() >= capacity_) { in Push() 62 cvFull_.Wait(lock, [this] { return !isActive || que_.size() < capacity_; }); in Push() 66 "d", name_.c_str(), isActive.load(), que_.size() < capacity_); in Push() 81 if (que_.size() >= capacity_) { in Push() 83 cvFull_.WaitFor(lock, timeoutMs, [this] { return !isActive || que_.size() < capacity_; }); in Push() 85 if (!isActive || (que_.size() == capacity_)) { in Push() 87 isActive.load(), que_.size() < capacity_); in Push() 155 capacity_ in ResetCapacity() 181 size_t capacity_; global() member in OHOS::Media::BlockingQueue [all...] |
/foundation/multimedia/media_foundation/engine/include/foundation/utils/ |
H A D | blocking_queue.h | 35 : name_(std::move(name)), capacity_(capacity), isActive(true) in BlockingQueue() 46 return capacity_; in Capacity() 60 if (que_.size() >= capacity_) { in Push() 62 cvFull_.Wait(lock, [this] { return !isActive || que_.size() < capacity_; }); in Push() 66 "d", name_.c_str(), isActive.load(), que_.size() < capacity_); in Push() 81 if (que_.size() >= capacity_) { in Push() 83 cvFull_.WaitFor(lock, timeoutMs, [this] { return !isActive || que_.size() < capacity_; }); in Push() 85 if (!isActive || (que_.size() == capacity_)) { in Push() 87 isActive.load(), que_.size() < capacity_); in Push() 157 bool needNotify = que_.size() == capacity_; in ClearUnprotected() 170 const size_t capacity_; global() member in OHOS::Media::BlockingQueue [all...] |
/foundation/graphic/graphic_2d/rosen/modules/2d_graphics/src/drawing/recording/ |
H A D | mem_allocator.cpp | 29 MemAllocator::MemAllocator() : isReadOnly_(false), capacity_(0), size_(0), startPtr_(nullptr) {} in MemAllocator() 45 capacity_ = size; in BuildFromData() 71 capacity_ = 0; in Clear() 81 capacity_ = 0; in ClearData() 107 capacity_ = size; in Resize() 121 if (capacity_ == 0 || capacity_ < size_ + size) { in Add() 123 if (Resize((capacity_ + size) * MEMORY_EXPANSION_FACTOR) == false) { in Add() 127 if (!memcpy_s(startPtr_ + size_, capacity_ - size_, data, size)) { in Add()
|
/foundation/resourceschedule/ffrt/src/util/ |
H A D | spmc_queue.cpp | 41 capacity_ = capacity; in Init() 52 return capacity_; in GetCapacity() 68 void* res = buf_[head % capacity_]; in PopHead() 83 if ((tail - head) < capacity_) { in PushTail() 84 buf_[tail % capacity_] = object; in PushTail() 100 void* element = buf_[head % capacity_]; in FindElement()
|
/foundation/distributedhardware/distributed_audio/services/common/audiodata/src/ |
H A D | audio_data.cpp | 26 capacity_ = capacity; in AudioData() 34 return capacity_; in Capacity() 49 if (!(offset <= capacity_) || !(offset + size <= capacity_)) { in SetRange() 103 capacity_ = 0; in ~AudioData()
|
/foundation/ability/dmsfwk/services/dtbschedmgr/src/softbus_adapter/transport/ |
H A D | dsched_data_buffer.cpp | 27 capacity_ = capacity; in DSchedDataBuffer() 53 return capacity_; in Capacity() 66 if (!(offset <= capacity_) || !(offset + size <= capacity_)) { in SetRange()
|
/foundation/multimedia/media_foundation/src/buffer/avbuffer/ |
H A D | av_hardware_memory.cpp | 43 allocator->capacity_ = capacity; in CreateHardwareAllocator() 51 capacity_(-1), in AVHardwareAllocator() 85 (void)::munmap(allocBase_, static_cast<size_t>(capacity_)); in Free() 92 capacity_ = -1; in Free() 124 capacity_, memFlag_, fd_); in MapMemoryAddr() 126 (void)::munmap(allocBase_, static_cast<size_t>(capacity_)); in MapMemoryAddr() 131 FALSE_RETURN_V_MSG_E(capacity_ > 0, Status::ERROR_INVALID_DATA, "capacity is invalid, capacity:%{public}d", in MapMemoryAddr() 132 capacity_); in MapMemoryAddr() 140 void *addr = ::mmap(nullptr, static_cast<size_t>(capacity_), static_cast<int>(prot), MAP_SHARED, fd_, 0); in MapMemoryAddr() 155 (void)::munmap(base_, static_cast<size_t>(capacity_)); in ~AVHardwareMemory() [all...] |
H A D | av_shared_memory_ext.cpp | 95 int32_t allocSize = align_ ? (capacity_ + align_ - 1) : capacity_; in Init() 172 (void)::munmap(base_, static_cast<size_t>(capacity_)); 186 uid_, capacity_, memFlag_, fd_); in MapMemoryAddr() 190 FALSE_RETURN_V_MSG_E(capacity_ > 0, Status::ERROR_INVALID_DATA, "size is invalid, size:%{public}d", capacity_); in MapMemoryAddr() 201 void *addr = ::mmap(nullptr, static_cast<size_t>(capacity_), static_cast<int>(prot), MAP_SHARED, fd_, 0); in MapMemoryAddr()
|
H A D | avmemory.cpp | 89 mem->capacity_ = capacity; in CreateAVMemory() 101 mem->capacity_ = capacity; in CreateAVMemory() 224 capacity_ = capacity; in ReadCommonFromMessageParcel() 246 FALSE_RETURN_V_MSG_E(ret && (capacity_ >= offset) && (offset >= 0), false, "offset is invalid"); in SkipCommonFromMessageParcel() 249 FALSE_RETURN_V_MSG_E(ret && (capacity_ >= size) && (size >= 0), false, "size is invalid"); in SkipCommonFromMessageParcel() 264 ret = bufferParcel.WriteInt32(capacity_) && bufferParcel.WriteInt32(align_) && bufferParcel.WriteInt32(offset_) && in WriteCommonToMessageParcel() 285 return capacity_; in GetCapacity() 295 FALSE_RETURN_V_MSG_E((capacity_ >= size) && (size >= 0), Status::ERROR_INVALID_PARAMETER, in SetSize() 298 size_, capacity_); in SetSize() 310 FALSE_RETURN_V_MSG_E((capacity_ > in SetOffset() [all...] |
/foundation/multimedia/image_framework/frameworks/innerkitsimpl/accessor/src/ |
H A D | buffer_metadata_stream.cpp | 42 capacity_ = 0; in BufferMetadataStream() 54 capacity_ = static_cast<long>(size); in BufferMetadataStream() 70 if (currentOffset_ + static_cast<long>(size) > capacity_) { in Write() 74 currentOffset_, static_cast<long>(size), capacity_); in Write() 116 capacity_ = newCapacity; in Write() 125 if (EOK != memcpy_s(buffer_ + currentOffset_, capacity_ - currentOffset_, data, size)) { in Write() 249 if (src.GetSize() > static_cast<ssize_t>(capacity_)) { in CopyFrom() 253 src.GetSize(), capacity_); in CopyFrom() 271 capacity_ = estimatedSize; in CopyFrom() 316 capacity_ in HandleWriteFailure() [all...] |
/foundation/ai/intelligent_voice_framework/utils/ |
H A D | queue_util.h | 44 capacity_ = capacity; in Init() 52 while (queue_.size() >= capacity_) { in Push() 54 notFullCv_.wait(lock, [&]() { return ((queue_.size() < capacity_) || (!IsAvailable())); }); in Push() 67 while (queue_.size() >= capacity_) { in Push() 69 notFullCv_.wait(lock, [&]() { return ((queue_.size() < capacity_) || (!IsAvailable())); }); in Push() 115 capacity_ = 0; in Uninit() 140 uint32_t capacity_ = 0; member in OHOS::IntellVoiceUtils::QueueUtil
|
/foundation/multimedia/camera_framework/services/deferred_processing_service/include/base/ |
H A D | blocking_queue.h | 33 : name_(name), capacity_(capacity > 0 ? capacity : std::numeric_limits<size_t>::max()), isActive_(true) in BlockingQueue() 45 return que_.size() == capacity_; in Full() 49 return capacity_; in Capacity() 183 bool needNotify = que_.size() == capacity_; in ClearUnlocked() 194 if (que_.size() >= capacity_) { in CanPush() 195 cvFull_.wait(lock, [this] { return !isActive_ || que_.size() < capacity_; }); in CanPush() 207 if (que_.size() >= capacity_) { in CanPush() 208 cvFull_.wait(lock, timeoutMs, [this] { return !isActive_ || que_.size() < capacity_; }); in CanPush() 210 if (!isActive_ || (que_.size() == capacity_)) { in CanPush() 221 const size_t capacity_; member in OHOS::CameraStandard::DeferredProcessing::BlockingQueue [all...] |
/foundation/multimedia/av_codec/services/utils/include/ |
H A D | block_queue.h | 34 : name_(std::move(name)), capacity_(capacity), isActive_(true) in BlockQueue() 48 return capacity_; in Capacity() 65 if (que_.size() >= capacity_) { in Push() 67 condFull_.wait(lock, [this] { return !isActive_ || que_.size() < capacity_; }); in Push() 71 name_.c_str(), isActive_.load(), que_.size() < capacity_); in Push() 150 bool needNotify = que_.size() == capacity_; in ClearUnprotected() 162 const size_t capacity_; member in OHOS::MediaAVCodec::BlockQueue
|
/foundation/distributeddatamgr/kv_store/frameworks/common/ |
H A D | lru_bucket.h | 28 : size_(0), capacity_(capacity) {} in LRUBucket() 50 return capacity_; in Capacity() 56 capacity_ = capacity; in ResetCapacity() 57 while (capacity_ < size_) { in ResetCapacity() 60 return capacity_ == capacity; in ResetCapacity() 89 if (capacity_ == 0) { in Set() 101 while (capacity_ <= size_) { in Set() 223 size_t capacity_; member in OHOS::LRUBucket
|
/foundation/distributeddatamgr/relational_store/rdbmock/frameworks/native/rdb/ |
H A D | lru_bucket.h | 28 : size_(0), capacity_(capacity) {} in LRUBucket() 50 return capacity_; in Capacity() 56 capacity_ = capacity; in ResetCapacity() 57 while (capacity_ < size_) { in ResetCapacity() 60 return capacity_ == capacity; in ResetCapacity() 89 if (capacity_ == 0) { in Set() 101 while (capacity_ <= size_) { in Set() 223 size_t capacity_; member in OHOS::LRUBucket
|