Lines Matching refs:e
228 self.onmessage = async (e: MessageEvent) => {
229 currentAction = e.data.action;
230 currentActionId = e.data.id;
232 if (e.data.action === 'reset') {
234 } else if (e.data.action === 'open') {
239 id: e.data.id,
240 action: e.data.action,
244 let uint8Array = new Uint8Array(e.data.buffer);
275 let parseConfig = e.data.parseConfig;
282 let wasmConfigStr = e.data.wasmConfig;
372 let rowTraceStr = Array.from(new Uint16Array(e.data.buffer.slice(0, 2)));
387 let dataTypeData = e.data.buffer.slice(offset, offset + tlvTypeLength);
390 let currentLData = e.data.buffer.slice(offset, offset + tlvTypeLength);
444 id: e.data.id,
445 action: e.data.action,
454 self.postMessage({ id: e.data.id, ready: true, index: index + 1 });
458 id: e.data.id,
459 action: e.data.action,
463 buffer: e.data.buffer,
467 [e.data.buffer]
469 } else if (e.data.action === 'exec') {
470 query(e.data.name, e.data.sql, e.data.params);
474 id: e.data.id,
475 action: e.data.action,
478 } else if (e.data.action === 'exec-proto') {
479 execProtoForWorker(e.data, (sql: string) => {
481 if (e.data.params.trafic !== TraficEnum.ProtoBuffer) {
488 allArray[0] = e.data.name;
493 if (protoDataMap.has(e.data.name)) {
494 finalArrayBuffer = protoDataMap.get(e.data.name);
495 protoDataMap.delete(e.data.name);
500 } else if (e.data.action == 'exec-buf') {
501 query(e.data.name, e.data.sql, e.data.params);
503 { id: e.data.id, action: e.data.action, results: arr!.buffer },
507 } else if (e.data.action.startsWith('exec-sdk')) {
508 querySdk(e.data.name, e.data.sql, e.data.params, e.data.action);
512 id: e.data.id,
513 action: e.data.action,
516 } else if (e.data.action.startsWith('exec-metric')) {
517 queryMetric(e.data.sql);
521 id: e.data.id,
522 action: e.data.action,
525 } else if (e.data.action == 'init-port') {
526 let port = e.ports[0];
536 } else if (e.data.action == 'download-db') {
557 id: e.data.id,
558 action: e.data.action,
565 } else if (e.data.action === 'upload-so') {
566 uploadSoActionId = e.data.id;
567 let fileList = e.data.params as Array<File>;
576 } else if (e.data.action === 'cut-file') {
577 cutFileByRange(e);
578 } else if (e.data.action === 'long_trace') {
581 let headArray = e.data.params.headArray;
582 let timStamp = e.data.params.timeStamp;
583 let allIndexDataList = e.data.params.splitDataList;
584 let splitFileInfos = e.data.params.splitFileInfo as Array<{
819 id: e.data.id,
820 action: e.data.action,
1070 function cutFileByRange(e: MessageEvent) {
1071 let cutLeftTs = e.data.leftTs;
1072 let cutRightTs = e.data.rightTs;
1073 let uint8Array = new Uint8Array(e.data.buffer);
1075 let cutFileCallBack = cutFileCallBackFunc(resultBuffer, uint8Array, e);
1097 id: e.data.id,
1098 action: e.data.action,
1101 buffer: e.data.buffer,
1104 [e.data.buffer]
1109 function cutFileCallBackFunc(resultBuffer: Array<any>, uint8Array: Uint8Array, e: MessageEvent): Fu…
1129 id: e.data.id,
1130 action: e.data.action,
1133 buffer: e.data.buffer,
1137 [e.data.buffer, cutBuffer.buffer]