| /device/google/contexthub/util/nanotool/ |
| D | nanomessage.cpp | 32 bool HardwareVersionInfo::Populate(const std::vector<uint8_t>& buffer) { in Populate() argument
33 if (buffer.size() != sizeof(VersionInfo)) { in Populate()
37 const uint8_t *data = buffer.data(); in Populate()
51 char buffer[1024]; in ToString() local
52 snprintf(buffer, sizeof(buffer), format_string, in ToString()
58 return std::string(buffer); in ToString()
66 char buffer[128]; in ToString() local
67 snprintf(buffer, sizeof(buffer), format_string, in ToString()
69 return std::string(buffer); in ToString()
72 bool WriteEventResponse::Populate(const std::vector<uint8_t>& buffer) { in Populate() argument
[all …]
|
| D | sensorevent.cpp | 34 const std::vector<uint8_t>& buffer) { in FromBytes() argument
38 ReadEventResponse::EventTypeFromBuffer(buffer) - in FromBytes()
96 (!sensor_event->Populate(buffer) || !sensor_event->SizeIsValid())) { in FromBytes()
154 char buffer[32]; in GetSampleTimeStr() local
155 snprintf(buffer, sizeof(buffer), "%" PRIu64 ".%06" PRIu64 " ms", in GetSampleTimeStr()
158 return std::string(buffer); in GetSampleTimeStr()
176 char buffer[64]; in ToString() local
177 snprintf(buffer, sizeof(buffer), in ToString()
183 return std::string(buffer) + StringForAllSamples(); in ToString()
212 char buffer[64]; in StringForSample() local
[all …]
|
| /device/google/contexthub/util/stm32_flash/ |
| D | spi.c | 24 uint8_t spi_write_data(handle_t *handle, uint8_t *buffer, int length) in spi_write_data() argument
30 .tx_buf = (unsigned long)buffer, in spi_write_data()
31 .rx_buf = (unsigned long)buffer, in spi_write_data()
35 buffer[length] = checksum(handle, buffer, length); in spi_write_data()
38 return buffer[length]; in spi_write_data()
46 uint8_t buffer[] = in spi_write_cmd() local
54 .len = sizeof(buffer), in spi_write_cmd()
55 .tx_buf = (unsigned long)buffer, in spi_write_cmd()
56 .rx_buf = (unsigned long)buffer, in spi_write_cmd()
69 uint8_t buffer[] = in spi_read_data() local
[all …]
|
| D | stm32_bl.c | 45 uint8_t buffer[sizeof(uint8_t)+1]; in write_len() local
47 buffer[0] = len-1; in write_len()
49 return handle->write_data(handle, buffer, sizeof(uint8_t)); in write_len()
54 uint8_t buffer[sizeof(uint16_t)+1]; in write_cnt() local
56 buffer[0] = (cnt >> 8) & 0xFF; in write_cnt()
57 buffer[1] = (cnt ) & 0xFF; in write_cnt()
59 return handle->write_data(handle, buffer, sizeof(uint16_t)); in write_cnt()
64 uint8_t buffer[sizeof(uint32_t)+1]; in write_addr() local
66 buffer[0] = (addr >> 24) & 0xFF; in write_addr()
67 buffer[1] = (addr >> 16) & 0xFF; in write_addr()
[all …]
|
| D | flash.c | 71 uint8_t *buffer; in main() local
226 buffer = calloc(tot_len(buf.st_size), 1); in main()
230 if (fread(&buffer[sizeof(uint32_t)], 1, length, file) < (size_t)length) { in main()
232 free(buffer); in main()
242 buffer[0] = type; in main()
243 buffer[1] = (length >> 16) & 0xFF; in main()
244 buffer[2] = (length >> 8) & 0xFF; in main()
245 buffer[3] = (length ) & 0xFF; in main()
246 crc = ~stm32f4_crc32(buffer, sizeof(uint32_t) + length); in main()
248 memcpy(&buffer[sizeof(uint32_t) + pad(length)], in main()
[all …]
|
| D | i2c.c | 26 uint8_t i2c_write_data(handle_t *handle, uint8_t *buffer, int length) in i2c_write_data() argument
30 buffer[length] = checksum(handle, buffer, length); in i2c_write_data()
32 if (write(i2c_handle->fd, buffer, length+1) == (length+1)) in i2c_write_data()
40 uint8_t buffer[sizeof(uint8_t)+1] = in i2c_write_cmd() local
45 return handle->write_data(handle, buffer, sizeof(uint8_t)); in i2c_write_cmd()
60 uint8_t buffer; in i2c_read_ack() local
62 if (handle->read_data(handle, &buffer, sizeof(uint8_t)) == CMD_ACK) in i2c_read_ack()
63 return buffer; in i2c_read_ack()
|
| /device/linaro/hikey/gralloc960/ |
| D | mali_gralloc_bufferdescriptor.cpp | 117 int mali_gralloc_get_backing_store_internal(buffer_handle_t buffer, gralloc1_backing_store_t *outSt… in mali_gralloc_get_backing_store_internal() argument
119 if (private_handle_t::validate(buffer) < 0) in mali_gralloc_get_backing_store_internal()
121 AERR("Invalid buffer %p, returning error", buffer); in mali_gralloc_get_backing_store_internal()
125 private_handle_t *hnd = (private_handle_t *)buffer; in mali_gralloc_get_backing_store_internal()
131 int mali_gralloc_get_consumer_usage_internal(buffer_handle_t buffer, uint64_t *outUsage) in mali_gralloc_get_consumer_usage_internal() argument
133 if (private_handle_t::validate(buffer) < 0) in mali_gralloc_get_consumer_usage_internal()
135 AERR("Invalid buffer %p, returning error", buffer); in mali_gralloc_get_consumer_usage_internal()
139 private_handle_t *hnd = (private_handle_t *)buffer; in mali_gralloc_get_consumer_usage_internal()
144 int mali_gralloc_get_dimensions_internal(buffer_handle_t buffer, uint32_t *outWidth, uint32_t *outH… in mali_gralloc_get_dimensions_internal() argument
146 if (private_handle_t::validate(buffer) < 0) in mali_gralloc_get_dimensions_internal()
[all …]
|
| D | mali_gralloc_public_interface.cpp | 104 static int32_t mali_gralloc_get_backing_store(gralloc1_device_t *device, buffer_handle_t buffer, in mali_gralloc_get_backing_store() argument
108 ret = mali_gralloc_get_backing_store_internal(buffer, outStore); in mali_gralloc_get_backing_store()
113 static int32_t mali_gralloc_get_consumer_usage(gralloc1_device_t *device, buffer_handle_t buffer, in mali_gralloc_get_consumer_usage() argument
117 ret = mali_gralloc_get_consumer_usage_internal(buffer, outUsage); in mali_gralloc_get_consumer_usage()
122 static int32_t mali_gralloc_get_dimensions(gralloc1_device_t *device, buffer_handle_t buffer, uint3… in mali_gralloc_get_dimensions() argument
126 ret = mali_gralloc_get_dimensions_internal(buffer, outWidth, outHeight); in mali_gralloc_get_dimensions()
131 static int32_t mali_gralloc_get_format(gralloc1_device_t *device, buffer_handle_t buffer, int32_t *… in mali_gralloc_get_format() argument
134 ret = mali_gralloc_get_format_internal(buffer, outFormat); in mali_gralloc_get_format()
139 static int32_t mali_gralloc_get_producer_usage(gralloc1_device_t *device, buffer_handle_t buffer, in mali_gralloc_get_producer_usage() argument
143 ret = mali_gralloc_get_producer_usage_internal(buffer, outUsage); in mali_gralloc_get_producer_usage()
[all …]
|
| D | mali_gralloc_bufferaccess.h | 25 int mali_gralloc_lock(const mali_gralloc_module *m, buffer_handle_t buffer, uint64_t usage, int l, …
27 int mali_gralloc_lock_ycbcr(const mali_gralloc_module *m, buffer_handle_t buffer, uint64_t usage, i…
29 int mali_gralloc_unlock(const mali_gralloc_module *m, buffer_handle_t buffer);
31 int mali_gralloc_get_num_flex_planes(const mali_gralloc_module *m, buffer_handle_t buffer, uint32_t…
32 int mali_gralloc_lock_async(const mali_gralloc_module *m, buffer_handle_t buffer, uint64_t usage, i…
34 int mali_gralloc_lock_ycbcr_async(const mali_gralloc_module *m, buffer_handle_t buffer, uint64_t us…
36 int mali_gralloc_lock_flex_async(const mali_gralloc_module *m, buffer_handle_t buffer, uint64_t usa…
38 int mali_gralloc_unlock_async(const mali_gralloc_module *m, buffer_handle_t buffer, int32_t *fence_…
|
| /device/amlogic/yukawa/hal/gralloc/ |
| D | mali_gralloc_bufferdescriptor.cpp | 128 int mali_gralloc_get_backing_store_internal(buffer_handle_t buffer, gralloc1_backing_store_t *outSt… in mali_gralloc_get_backing_store_internal() argument
130 if (private_handle_t::validate(buffer) < 0) in mali_gralloc_get_backing_store_internal()
132 AERR("Invalid buffer %p, returning error", buffer); in mali_gralloc_get_backing_store_internal()
136 private_handle_t *hnd = (private_handle_t *)buffer; in mali_gralloc_get_backing_store_internal()
142 int mali_gralloc_get_consumer_usage_internal(buffer_handle_t buffer, uint64_t *outUsage) in mali_gralloc_get_consumer_usage_internal() argument
144 if (private_handle_t::validate(buffer) < 0) in mali_gralloc_get_consumer_usage_internal()
146 AERR("Invalid buffer %p, returning error", buffer); in mali_gralloc_get_consumer_usage_internal()
150 private_handle_t *hnd = (private_handle_t *)buffer; in mali_gralloc_get_consumer_usage_internal()
155 int mali_gralloc_get_dimensions_internal(buffer_handle_t buffer, uint32_t *outWidth, uint32_t *outH… in mali_gralloc_get_dimensions_internal() argument
157 if (private_handle_t::validate(buffer) < 0) in mali_gralloc_get_dimensions_internal()
[all …]
|
| D | mali_gralloc_public_interface.cpp | 104 static int32_t mali_gralloc_get_backing_store(gralloc1_device_t *device, buffer_handle_t buffer, in mali_gralloc_get_backing_store() argument
108 ret = mali_gralloc_get_backing_store_internal(buffer, outStore); in mali_gralloc_get_backing_store()
113 static int32_t mali_gralloc_get_consumer_usage(gralloc1_device_t *device, buffer_handle_t buffer, in mali_gralloc_get_consumer_usage() argument
117 ret = mali_gralloc_get_consumer_usage_internal(buffer, outUsage); in mali_gralloc_get_consumer_usage()
122 static int32_t mali_gralloc_get_dimensions(gralloc1_device_t *device, buffer_handle_t buffer, uint3… in mali_gralloc_get_dimensions() argument
126 ret = mali_gralloc_get_dimensions_internal(buffer, outWidth, outHeight); in mali_gralloc_get_dimensions()
131 static int32_t mali_gralloc_get_format(gralloc1_device_t *device, buffer_handle_t buffer, int32_t *… in mali_gralloc_get_format() argument
134 ret = mali_gralloc_get_format_internal(buffer, outFormat); in mali_gralloc_get_format()
139 static int32_t mali_gralloc_get_producer_usage(gralloc1_device_t *device, buffer_handle_t buffer, in mali_gralloc_get_producer_usage() argument
143 ret = mali_gralloc_get_producer_usage_internal(buffer, outUsage); in mali_gralloc_get_producer_usage()
[all …]
|
| D | mali_gralloc_bufferaccess.h | 25 int mali_gralloc_lock(const mali_gralloc_module *m, buffer_handle_t buffer, uint64_t usage, int l, …
27 int mali_gralloc_lock_ycbcr(const mali_gralloc_module *m, buffer_handle_t buffer, uint64_t usage, i…
29 int mali_gralloc_unlock(const mali_gralloc_module *m, buffer_handle_t buffer);
31 int mali_gralloc_get_num_flex_planes(const mali_gralloc_module *m, buffer_handle_t buffer, uint32_t…
32 int mali_gralloc_lock_async(const mali_gralloc_module *m, buffer_handle_t buffer, uint64_t usage, i…
34 int mali_gralloc_lock_ycbcr_async(const mali_gralloc_module *m, buffer_handle_t buffer, uint64_t us…
36 int mali_gralloc_lock_flex_async(const mali_gralloc_module *m, buffer_handle_t buffer, uint64_t usa…
38 int mali_gralloc_unlock_async(const mali_gralloc_module *m, buffer_handle_t buffer, int32_t *fence_…
|
| /device/generic/goldfish-opengl/android-emu/android/base/files/ |
| D | StreamSerializing.h | 35 void saveBufferRaw(Stream* stream, char* buffer, uint32_t len);
36 bool loadBufferRaw(Stream* stream, char* buffer);
39 void saveBuffer(Stream* stream, const std::vector<T>& buffer) { in saveBuffer() argument
40 stream->putBe32(buffer.size()); in saveBuffer()
41 stream->write(buffer.data(), sizeof(T) * buffer.size()); in saveBuffer()
45 bool loadBuffer(Stream* stream, std::vector<T>* buffer) { in loadBuffer() argument
47 buffer->resize(len); in loadBuffer()
48 int ret = (int)stream->read(buffer->data(), len * sizeof(T)); in loadBuffer()
53 void saveBuffer(Stream* stream, const SmallVector<T>& buffer) { in saveBuffer() argument
54 stream->putBe32(buffer.size()); in saveBuffer()
[all …]
|
| /device/google/bonito/health/ |
| D | LearnedCapacityBackupRestore.cpp | 44 std::string buffer; in ReadPersistData() local
46 if (!android::base::ReadFileToString(std::string(kSysCFPersistFile), &buffer)) { in ReadPersistData()
51 if (sscanf(buffer.c_str(), "%d", &sw_cap_) < 1) in ReadPersistData()
52 LOG(ERROR) << "data format is wrong in the storage file: " << buffer; in ReadPersistData()
54 LOG(INFO) << "Storage data: " << buffer; in ReadPersistData()
69 std::string buffer; in ReadNominalCapacity() local
71 if (!android::base::ReadFileToString(std::string(kChgFullDesignFile), &buffer)) { in ReadNominalCapacity()
76 buffer = android::base::Trim(buffer); in ReadNominalCapacity()
78 if (sscanf(buffer.c_str(), "%d", &nom_cap_) < 1) in ReadNominalCapacity()
79 LOG(ERROR) << "Failed to parse nominal capacity: " << buffer; in ReadNominalCapacity()
[all …]
|
| /device/google/contexthub/firmware/os/core/ |
| D | hostIntf.c | 87 struct HostIntfDataBuffer buffer; member
419 void hostIntfTxAck(void *buffer, uint8_t len) in hostIntfTxAck() argument
423 memcpy(txPayload, buffer, len); in hostIntfTxAck()
538 sensor->buffer.length = 0; in resetBuffer()
539 memset(&sensor->buffer.firstSample, 0x00, sizeof(struct SensorFirstSample)); in resetBuffer()
560 struct HostIntfDataBuffer *buffer = data; in hostIntfPacketDequeue() local
565 ret = simpleQueueDequeue(mOutputQ, buffer); in hostIntfPacketDequeue()
567 sensor = getActiveSensorByType(buffer->sensType); in hostIntfPacketDequeue()
570 …if (sensor->sensorHandle == 0 && !buffer->firstSample.biasPresent && !buffer->firstSample.numFlush… in hostIntfPacketDequeue()
575 sensor->curSamples -= buffer->firstSample.numSamples; in hostIntfPacketDequeue()
[all …]
|
| /device/generic/goldfish/wifi/execns/ |
| D | execns.cpp | 103 char buffer[32]; in readNamespacePid() local
104 size_t bytesRead = ::fread(buffer, 1, sizeof(buffer), file.get()); in readNamespacePid()
105 if (bytesRead < sizeof(buffer) && feof(file.get())) { in readNamespacePid()
107 buffer[bytesRead] = '\0'; in readNamespacePid()
108 if (isNumericString(buffer)) { in readNamespacePid()
110 return buffer; in readNamespacePid()
112 LOGE("File %s does not contain a valid pid '%s'", nsPath, buffer); in readNamespacePid()
186 static int sncatf(char* buffer, size_t size, const char* fmt, ...) { in sncatf() argument
187 size_t len = strnlen(buffer, size); in sncatf()
197 int printed = vsnprintf(buffer + len, size - len, fmt, args); in sncatf()
[all …]
|
| /device/google/cuttlefish/host/commands/secure_env/ |
| D | tpm_hmac.cpp | 35 TPM2B_MAX_BUFFER buffer; in OneshotHmac() local
36 static_assert(sizeof(buffer.buffer) >= TPM2_MAX_DIGEST_BUFFER); in OneshotHmac()
37 buffer.size = data_size; in OneshotHmac()
38 memcpy(buffer.buffer, data, data_size); in OneshotHmac()
46 &buffer, in OneshotHmac()
70 *reinterpret_cast<decltype(rand())*>(sequence_auth.buffer) = rand(); in SegmentedHmac()
100 TPM2B_MAX_BUFFER buffer; in SegmentedHmac() local
102 buffer.size = TPM2_MAX_DIGEST_BUFFER; in SegmentedHmac()
103 memcpy(buffer.buffer, &data[hashed], TPM2_MAX_DIGEST_BUFFER); in SegmentedHmac()
111 &buffer); in SegmentedHmac()
[all …]
|
| D | tpm_random_source.cpp | 32 while (requested_length > sizeof(generated->buffer)) { in GenerateRandom()
34 ESYS_TR_NONE, sizeof(generated->buffer), in GenerateRandom()
42 memcpy(random, generated->buffer, sizeof(generated->buffer)); in GenerateRandom()
43 random = (uint8_t*) random + sizeof(generated->buffer); in GenerateRandom()
44 requested_length -= sizeof(generated->buffer); in GenerateRandom()
55 memcpy(random, generated->buffer, requested_length); in GenerateRandom()
64 const uint8_t* buffer, size_t size) const { in AddRngEntropy() argument
67 memcpy(in_data.buffer, buffer, MAX_STIR_RANDOM_BUFFER_SIZE); in AddRngEntropy()
69 buffer += MAX_STIR_RANDOM_BUFFER_SIZE; in AddRngEntropy()
86 memcpy(in_data.buffer, buffer, size); in AddRngEntropy()
|
| /device/google/cuttlefish/host/frontend/webrtc/ |
| D | display_handler.cpp | 35 std::shared_ptr<CvdVideoFrameBuffer> buffer( in Loop() local
39 buffer->DataY(), buffer->StrideY(), in Loop()
40 buffer->DataU(), buffer->StrideU(), in Loop()
41 buffer->DataV(), buffer->StrideV(), in Loop()
47 std::static_pointer_cast<webrtc_streaming::VideoFrameBuffer>(buffer); in Loop()
57 std::shared_ptr<webrtc_streaming::VideoFrameBuffer> buffer; in SendLastFrame() local
60 buffer = last_buffer_; in SendLastFrame()
62 if (!buffer) { in SendLastFrame()
75 display_sink_->OnFrame(buffer, time_stamp); in SendLastFrame()
|
| D | connection_observer.cpp | 99 auto buffer = GetEventBuffer(); in OnTouchEvent() local
100 if (!buffer) { in OnTouchEvent()
104 buffer->AddEvent(EV_ABS, ABS_X, x); in OnTouchEvent()
105 buffer->AddEvent(EV_ABS, ABS_Y, y); in OnTouchEvent()
106 buffer->AddEvent(EV_KEY, BTN_TOUCH, down); in OnTouchEvent()
107 buffer->AddEvent(EV_SYN, 0, 0); in OnTouchEvent()
109 reinterpret_cast<const char *>(buffer->data()), in OnTouchEvent()
110 buffer->size()); in OnTouchEvent()
118 auto buffer = GetEventBuffer(); in OnKeyboardEvent() local
119 if (!buffer) { in OnKeyboardEvent()
[all …]
|
| /device/google/cuttlefish/guest/hals/hwcomposer/common/ |
| D | gralloc_utils.cpp | 59 std::optional<uint32_t> Gralloc::GetWidth(buffer_handle_t buffer) { in GetWidth() argument
61 cros_gralloc_handle_t gralloc3_buffer = cros_gralloc_convert_handle(buffer); in GetWidth()
69 reinterpret_cast<const cuttlefish_gralloc0_buffer_handle_t*>(buffer); in GetWidth()
76 std::optional<uint32_t> Gralloc::GetHeight(buffer_handle_t buffer) { in GetHeight() argument
78 cros_gralloc_handle_t gralloc3_buffer = cros_gralloc_convert_handle(buffer); in GetHeight()
86 reinterpret_cast<const cuttlefish_gralloc0_buffer_handle_t*>(buffer); in GetHeight()
93 std::optional<uint32_t> Gralloc::GetDrmFormat(buffer_handle_t buffer) { in GetDrmFormat() argument
95 cros_gralloc_handle_t gralloc3_buffer = cros_gralloc_convert_handle(buffer); in GetDrmFormat()
103 reinterpret_cast<const cuttlefish_gralloc0_buffer_handle_t*>(buffer); in GetDrmFormat()
111 buffer_handle_t buffer) { in GetMonoPlanarStrideBytes() argument
[all …]
|
| /device/google/wahoo/health/ |
| D | LearnedCapacityBackupRestore.cpp | 53 std::string buffer; in ReadFromStorage() local
55 if (!android::base::ReadFileToString(std::string(kSysCFPersistFile), &buffer)) { in ReadFromStorage()
60 if (sscanf(buffer.c_str(), "%d", &sw_cap_) < 1) in ReadFromStorage()
61 LOG(ERROR) << "data format is wrong in the storage file: " << buffer; in ReadFromStorage()
63 LOG(INFO) << "Storage data: " << buffer; in ReadFromStorage()
78 std::string buffer; in ReadFromSRAM() local
80 if (!android::base::ReadFileToString(std::string(kChgFullFile), &buffer)) { in ReadFromSRAM()
85 buffer = android::base::Trim(buffer); in ReadFromSRAM()
87 if (sscanf(buffer.c_str(), "%d", &hw_cap_) < 1) in ReadFromSRAM()
88 LOG(ERROR) << "Failed to parse SRAM bins: " << buffer; in ReadFromSRAM()
[all …]
|
| D | CycleCountBackupRestore.cpp | 45 std::string buffer; in ReadFromStorage() local
47 if (!android::base::ReadFileToString(std::string(kSysPersistFile), &buffer)) { in ReadFromStorage()
52 if (sscanf(buffer.c_str(), "%d %d %d %d %d %d %d %d", in ReadFromStorage()
56 LOG(ERROR) << "data format is wrong in the storage file: " << buffer; in ReadFromStorage()
58 LOG(INFO) << "Storage data: " << buffer; in ReadFromStorage()
77 std::string buffer; in ReadFromSRAM() local
79 if (!android::base::ReadFileToString(std::string(kCycCntFile), &buffer)) { in ReadFromSRAM()
84 buffer = android::base::Trim(buffer); in ReadFromSRAM()
86 if (sscanf(buffer.c_str(), "%d %d %d %d %d %d %d %d", in ReadFromSRAM()
90 LOG(ERROR) << "Failed to parse SRAM bins: " << buffer; in ReadFromSRAM()
[all …]
|
| /device/linaro/hikey/hifi/xaf/hifi-dpf/audio/ |
| D | xa-class-base.c | 168 xf_set_param_msg_t *cmd = m->buffer; in xa_base_set_param()
212 xf_get_param_msg_t *cmd = m->buffer; in xa_base_get_param()
246 xf_ext_param_msg_t *cmd = m->buffer; in xa_base_set_param_ext()
255 ((u8 *)m->buffer)[i + 0], ((u8 *)m->buffer)[i + 1], in xa_base_set_param_ext()
256 ((u8 *)m->buffer)[i + 2], ((u8 *)m->buffer)[i + 3], in xa_base_set_param_ext()
257 ((u8 *)m->buffer)[i + 4], ((u8 *)m->buffer)[i + 5], in xa_base_set_param_ext()
258 ((u8 *)m->buffer)[i + 6], ((u8 *)m->buffer)[i + 7], in xa_base_set_param_ext()
259 ((u8 *)m->buffer)[i + 8], ((u8 *)m->buffer)[i + 9], in xa_base_set_param_ext()
260 ((u8 *)m->buffer)[i + 10], ((u8 *)m->buffer)[i + 11], in xa_base_set_param_ext()
261 ((u8 *)m->buffer)[i + 12], ((u8 *)m->buffer)[i + 13], in xa_base_set_param_ext()
[all …]
|
| /device/generic/goldfish/radio/librilutils/ |
| D | record_stream.c | 37 unsigned char *buffer; member
55 ret->buffer = (unsigned char *)malloc (maxRecordLen + HEADER_SIZE); in record_stream_new()
57 ret->unconsumed = ret->buffer; in record_stream_new()
58 ret->read_end = ret->buffer; in record_stream_new()
59 ret->buffer_end = ret->buffer + maxRecordLen + HEADER_SIZE; in record_stream_new()
67 free(rs->buffer); in record_stream_free()
143 if (p_rs->unconsumed == p_rs->buffer in record_stream_get_next()
153 if (p_rs->unconsumed != p_rs->buffer) { in record_stream_get_next()
159 memmove(p_rs->buffer, p_rs->unconsumed, toMove); in record_stream_get_next()
162 p_rs->read_end = p_rs->buffer + toMove; in record_stream_get_next()
[all …]
|