Home
last modified time | relevance | path

Searched refs:dataSize (Results 1 – 25 of 68) sorted by relevance

123

/developtools/profiler/host/smartperf/ide/src/hdc/transmission/
DDataProcessing.ts46 let dataSize = usbHead!.dataSize;
47 if (dataSize > 0) {
48 let body = await this.readBody(dataSize);
76 public async readBody(dataSize: number): Promise<DataView> {
77 let data = await this.transmissionChannel.readData(dataSize);
86 dataSize: number
100 dataSize
104 let finalBufSize = dataView.byteLength + pbs.byteLength + dataSize;
120 private buildPacketHeader(sessionId: number, option: number, dataSize: number): Uint8Array {
125 dataSize
/developtools/smartperf_host/ide/src/hdc/transmission/
DDataProcessing.ts46 let dataSize = usbHead!.dataSize;
47 if (dataSize > 0) {
48 let body = await this.readBody(dataSize);
76 public async readBody(dataSize: number): Promise<DataView> {
77 let data = await this.transmissionChannel.readData(dataSize);
86 dataSize: number
100 dataSize
104 let finalBufSize = dataView.byteLength + pbs.byteLength + dataSize;
120 private buildPacketHeader(sessionId: number, option: number, dataSize: number): Uint8Array {
125 dataSize
/developtools/smartperf_host/ide/src/hdc/message/
DPayloadHead.ts25 …: Array<number>, reserve: Array<number>, protocolVer: number, headSize: number, dataSize: number) {
31 this._dataSize = dataSize;
56 let dataSize;
58 dataSize = 0;
60 dataSize = data.getUint32(7);
62 …n new PayloadHead([flagZero, flagOne], [reserveZero, reserveOne], protocolVer, headSize, dataSize);
81 get dataSize(): number { method in PayloadHead
85 set dataSize(value: number) { method in PayloadHead
DUSBHead.ts24 constructor(flag: number[], option: number, sessionId: number, dataSize: number) {
29 this._dataSize = dataSize;
70 let dataSize = data.getUint32(7);
71 return new USBHead([flagZero, flagOne], option, sessionId, dataSize);
98 get dataSize(): number { method in USBHead
102 set dataSize(value: number) { method in USBHead
DDataMessage.ts46 let dataSize = resultPayloadHead.dataSize; variable
55 if (dataSize > 0) {
56 this._resArrayBuffer = this.body!.buffer.slice(11 + headSize, 11 + headSize + dataSize);
/developtools/profiler/host/smartperf/ide/src/hdc/message/
DPayloadHead.ts25 …: Array<number>, reserve: Array<number>, protocolVer: number, headSize: number, dataSize: number) {
31 this._dataSize = dataSize;
56 let dataSize;
58 dataSize = 0;
60 dataSize = data.getUint32(7);
62 …n new PayloadHead([flagZero, flagOne], [reserveZero, reserveOne], protocolVer, headSize, dataSize);
81 get dataSize(): number { method in PayloadHead
85 set dataSize(value: number) { method in PayloadHead
DUSBHead.ts24 constructor(flag: number[], option: number, sessionId: number, dataSize: number) {
29 this._dataSize = dataSize;
70 let dataSize = data.getUint32(7);
71 return new USBHead([flagZero, flagOne], option, sessionId, dataSize);
98 get dataSize(): number { method in USBHead
102 set dataSize(value: number) { method in USBHead
DDataMessage.ts46 let dataSize = resultPayloadHead.dataSize; variable
55 if (dataSize > 0) {
56 this._resArrayBuffer = this.body!.buffer.slice(11 + headSize, 11 + headSize + dataSize);
/developtools/profiler/proto_encoder/src/
Dbase_message.cpp77 void BaseMessage::AddBytes(uint32_t fieldId, const void* data, uint32_t dataSize) in AddBytes() argument
89 if (!writeCtx_->getMemory(writeCtx_, VARINT_ENCODE_MAX_SIZE + SIZE_RESERVED_LEN + dataSize, in AddBytes()
96 fieldSize += EncodeVarint(fieldMemory + fieldSize, dataSize); in AddBytes()
97 if (dataSize != 0) { in AddBytes()
98 if (memcpy_s(fieldMemory + fieldSize, dataSize, data, dataSize) != EOK) { in AddBytes()
103 fieldSize += dataSize; in AddBytes()
193 int32_t dataSize = getData(writeCtx_); in AddBytesByCallBack() local
194 if (dataSize < 0) { in AddBytesByCallBack()
206 if (dataSize == 0) { in AddBytesByCallBack()
214 EncodeVarintPadding(fieldMemory, dataSize, SIZE_RESERVED_LEN); in AddBytesByCallBack()
[all …]
/developtools/hdc/src/common/
Dusb.cpp60 vector<uint8_t> HdcUSBBase::BuildPacketHeader(uint32_t sessionId, uint8_t option, uint32_t dataSize) in BuildPacketHeader() argument
69 head.dataSize = htonl(dataSize); in BuildPacketHeader()
110 uint32_t maybeSize = ntohl(usbPayloadHeader->dataSize); in IsUsbPacketHeader()
148 int HdcUSBBase::CheckPacketOption(HSession hSession, uint8_t *appendData, int dataSize) in CheckPacketOption() argument
154 header->dataSize = ntohl(header->dataSize); in CheckPacketOption()
168 hUSB->payloadSize = header->dataSize; in CheckPacketOption()
175 …USBBase::SendToHdcStream(HSession hSession, uv_stream_t *stream, uint8_t *appendData, int dataSize) in SendToHdcStream() argument
180 if (IsUsbPacketHeader(appendData, dataSize)) { in SendToHdcStream()
181 return CheckPacketOption(hSession, appendData, dataSize); in SendToHdcStream()
186 dataSize, hUSB->payloadSize, childRet); in SendToHdcStream()
[all …]
Dusb.h33 virtual int UsbToHdcProtocol(uv_stream_t *stream, uint8_t *appendData, int dataSize) in UsbToHdcProtocol() argument
37 int SendToHdcStream(HSession hSession, uv_stream_t *stream, uint8_t *appendData, int dataSize);
48 vector<uint8_t> BuildPacketHeader(uint32_t sessionId, uint8_t option, uint32_t dataSize);
49 int CheckPacketOption(HSession hSession, uint8_t *appendData, int dataSize);
Duart.h52 uint32_t dataSize; // data size not include head member
73 oss << " dataSize:" << dataSize; in ToDebugString()
75 if (dataSize != 0) { in ToDebugString()
88 dataSize(dataSizeIn),
95 dataSize == r.dataSize and packageIndex == r.packageIndex;
104 if (dataSize != 0) { in UpdateCheckSum()
106 dataCheckSum = std::accumulate(data, data + dataSize, 0u); in UpdateCheckSum()
127 if (dataSize == 0) { in ValidateData()
130 return (dataCheckSum == std::accumulate(data, data + dataSize, 0u)); in ValidateData()
201 virtual int UartToHdcProtocol(uv_stream_t *stream, uint8_t *appendData, int dataSize);
Dsession.cpp316 const int dataSize) in PushAsyncMessage() argument
325 if (dataSize > 0) { in PushAsyncMessage()
326 param->dataSize = dataSize; in PushAsyncMessage()
327 param->data = new uint8_t[param->dataSize](); in PushAsyncMessage()
332 if (memcpy_s((uint8_t *)param->data, param->dataSize, data, dataSize)) { in PushAsyncMessage()
799 const uint8_t *data, const int dataSize) in Send() argument
810 …protectBuf.checkSum = (ENABLE_IO_CHECKSUM && dataSize > 0) ? Base::CalcCheckSum(data, dataSize) : … in Send()
821 payloadHead.dataSize = htonl(dataSize); in Send()
822 int finalBufSize = sizeof(PayloadHead) + s.size() + dataSize; in Send()
831 WRITE_LOG(LOG_WARN, "send copyhead err for dataSize:%d", dataSize); in Send()
[all …]
/developtools/profiler/proto_encoder/include/
Dbase_message.h232 void AddBytes(uint32_t fieldId, const void* data, uint32_t dataSize);
317 uint32_t dataSize = 0; in AddPackedVarint() local
320 dataSize += EncodeVarint(pData + dataSize, *array); in AddPackedVarint()
324 EncodeVarintPadding(fieldMemory + tagSize, dataSize, lenSize); in AddPackedVarint()
325 size_ += tagSize + lenSize + dataSize; in AddPackedVarint()
327 writeCtx_->seek(writeCtx_, fieldOffset + tagSize + lenSize + dataSize); in AddPackedVarint()
347 uint32_t dataSize = arrayCount * sizeof(T); in AddPackedFixed() local
351 if (!writeCtx_->getMemory(writeCtx_, VARINT_ENCODE_MAX_SIZE + SIZE_RESERVED_LEN + dataSize, in AddPackedFixed()
358 tagSize += EncodeVarint(fieldMemory + tagSize, dataSize); in AddPackedFixed()
359 if (memcpy_s(fieldMemory + tagSize, dataSize, array, dataSize) != EOK) { in AddPackedFixed()
[all …]
/developtools/profiler/hiebpf/include/
Dbpf_controller.h78 static int HandleEvent(void *ctx, void *data, size_t dataSize);
79 static int DumpEvent(void *ctx, void *data, size_t dataSize);
136 static int DumpFSTraceEvent(BPFController *bpfctlr, void *data, size_t dataSize);
137 static int DumpPFTraceEvent(BPFController *bpfctlr, void *data, size_t dataSize);
138 static int DumpBIOTraceEvent(BPFController *bpfctlr, void *data, size_t dataSize);
139 static int DumpSTRTraceEvent(void *data, size_t dataSize);
Dbpf_event_receiver.h151 inline int Put(void *data, const size_t dataSize) in Put() argument
153 HHLOGF((data == nullptr or dataSize == 0), "invalid arguments: this should never happen"); in Put()
156 ret = buf_->Put((const char*)data, dataSize); in Put()
157 if (ret == static_cast<int>(dataSize)) { in Put()
160 …HHLOGF((0 <= ret and ret < static_cast<int>(dataSize)), "incomplete data received: this should nev… in Put()
/developtools/profiler/hiebpf/src/
Dbpf_controller.cpp495 int BPFController::HandleEvent(void *ctx, void *data, size_t dataSize) in HandleEvent() argument
508 int ret = receiver->Put(data, dataSize); in HandleEvent()
511 (0 <= ret and ret < static_cast<int>(dataSize)), in HandleEvent()
635 int BPFController::DumpFSTraceEvent(BPFController *bpfctlr, void *data, size_t dataSize) in DumpFSTraceEvent() argument
637 if (dataSize != sizeof(fstrace_cmplt_event_t)) { in DumpFSTraceEvent()
639 << " data size = " << dataSize in DumpFSTraceEvent()
645 if (memcpy_s(&cmpltEvent, sizeof(fstrace_cmplt_event_t), data, dataSize) != EOK) { in DumpFSTraceEvent()
650 << "\ndata size: " << dataSize; in DumpFSTraceEvent()
668 int BPFController::DumpPFTraceEvent(BPFController *bpfctlr, void *data, size_t dataSize) in DumpPFTraceEvent() argument
670 if (dataSize != sizeof(pftrace_cmplt_event_t)) { in DumpPFTraceEvent()
[all …]
Dringbuffer.cpp111 std::size_t dataSize = DataSize(); in Write() local
112 if (dataSize < len) { in Write()
113 len = dataSize; in Write()
151 auto dataSize = DataSize(); in Get() local
152 if (len > dataSize) { in Get()
292 auto dataSize = DataSize(); in Resize() local
293 if (head_ + dataSize > bufSize_) { in Resize()
302 dataSize - (bufSize_ - head_)) != EOK) { in Resize()
308 if (memcpy_s(newBuf, expandedSize, buffer_ + head_, dataSize) != EOK) { in Resize()
318 tail_ = dataSize; in Resize()
Dhhlog.cpp149 auto dataSize = buf_->GetDataSize(); in SaveLog() local
150 if (stop_.load() and (dataSize == 0)) { in SaveLog()
153 if (dataSize) { in SaveLog()
154 ssize_t ret = buf_->Write(fd_, dataSize); in SaveLog()
/developtools/smartperf_host/ide/test/hdc/message/
DUSBHead.test.ts53 expect(usbHead.dataSize).toBeFalsy();
57 usbHead.dataSize = true;
58 expect(usbHead.dataSize).toBeTruthy();
DPayloadHead.test.ts62 expect(payloadHead.dataSize).toBeUndefined();
66 payloadHead.dataSize = true;
67 expect(payloadHead.dataSize).toBeTruthy();
/developtools/profiler/host/smartperf/ide/src/hdc/hdcclient/
DHdcClient.ts76 let handBody = await this.readDataProcessing.readBody(handShake!.dataSize);
83 let dataSize = resultPayloadHead.dataSize;
91 PayloadHead.getPayloadHeadLength() + headSize + dataSize
/developtools/smartperf_host/ide/src/hdc/hdcclient/
DHdcClient.ts76 let handBody = await this.readDataProcessing.readBody(handShake!.dataSize);
83 let dataSize = resultPayloadHead.dataSize;
91 PayloadHead.getPayloadHeadLength() + headSize + dataSize
/developtools/hiperf/test/unittest/common/native/
Dperf_file_writer_test.cpp85 uint64_t dataSize = 0; variable
89 dataSize += recordmmap.GetSize();
100 ASSERT_EQ(fileWriter.GetDataSize(), dataSize);
121 uint64_t dataSize = 0; variable
125 dataSize += recordmmap.GetSize();
133 ASSERT_EQ(fileWriter.GetDataSize(), dataSize);
/developtools/hdc/test/unittest/common/
Duart_test.cpp157 head.dataSize = testString.size(); in MakeDemoData()
171 size_t dataSize = data.size() - sizeof(UartHead); in MakeData() local
172 if (memcpy_s(dataPtr, dataSize, testString.data(), testString.size()) != EOK) { in MakeData()
263 ASSERT_EQ(pUARTHead->dataSize, length - sizeof(UartHead)); in __anon1f4edf980402()
264 sendOffset += pUARTHead->dataSize; in __anon1f4edf980402()
271 for (uint32_t i = 0; i < pUARTHead->dataSize; i++) { in __anon1f4edf980402()
275 sourceDataPoint += pUARTHead->dataSize; in __anon1f4edf980402()
491 .WillRepeatedly([&](uv_stream_t *stream, uint8_t *data, int dataSize) { in __anon1f4edf980702() argument
492 return mockUARTBase.HdcUARTBase::UartToHdcProtocol(stream, data, dataSize); in __anon1f4edf980702()
533 testHead.dataSize = dataSizeTest;
[all …]

123