next stage fix（clean） · Pull Request !2134 · OpenHarmony/commonlibrary_ets_utils

修改后差异点说明：
一、runOnce的回调从异步改同步——Callback多次使用时，会第一时间记录错误信息，同步抛错或异步触发error事件（取决于开发者是否已监听error事件）——1.0异步处理，Callback多次使用时因为emitErrorOnce异步叠异步，约等于直接跳过多执行的Callback
二、补充数个属性或缓冲区辅助操作
1、新增doWrite-Callback计数writableCb（进Callback前即doWrite前增加，Callback内减少）用于判断写入任务是否完成
2、新增writableSync属性用于感知doWrite-Callback是被同步调用的还是异步调用的（进Callback前即doWrite前设置为true，doWrite后设置为false，Callback内writableSync为true说明是同步调用的，为false说明是异步调用的），Callback内部逻辑对于不同调用场景有不同执行逻辑
3、新增writableBufferLength用于记录实际存入buffer的数据长度，用于批量写出时能正确更新writableLengthInner属性（对开发者而言所有数据都是会过一次的buffer的，但实现上进行了优化，不开cork时，buffer为空时的写入的数据不过buffer直接写出，对内writableLengthInner不能反映buffer实际使用情况）
4、新增write-Callback缓冲区writeCallbackBuffer，用于补全各种场景中write-Callback的执行，write不携带Callback时若chunk写入buffer，则writeCallbackBuffer也会添加空函数doNothing()占位保持Callback和buffer中的chunk一一对应
三、write
1、Encoding机制更改——仅能影响本次写入数据的Encoding——1.0直接修改defaultEncoding
2、write after end机制更改——去除writing豁免，增加错误信息保护（有其他报错时优先保留其他报错），错误信息记录改为同步，添加配套的清场操作，异步改用promise触发，增加error事件尾随的close事件，避免两层异步，将throwError内部逻辑拆出使用——1.0存在writing下end之后可write的漏洞，其他正常情况差异不关键，忽略
3、已存在报错信息时——补充清场和Callback处理——1.0直接return
四、writeUint8Array
1、新增默认Encoding还原步骤——write中会暂时将全局Encoding更改，和原设的默认值不同时用默认值再刷一次进行还原
2、新增doWrite-Callback计数相关处理
3、新增writableSync相关处理
4、新增writableBufferLength相关处理
5、新增writeCallbackBuffer存放处理
6、新增writableCb相关处理
7、回调函数逻辑更迭——当次chunk对应的Callback处理，辅助参数维护，error场景处理（Callback带入或已触发），writableLengthInner属性更新，后续数据请求（异步批量请求，同步则不主动请求），drain事件检查——1.0为Callback带入error的处理，当次chunk对应的Callback处理，请求后续一个数据
8、runOnce回调升级——补齐error场景处理——1.0仅触发error事件，不会抛错，使得不监听error事件时，仅跳过多余Callback，无错误信息
9、返回值补充对错误信息的检查，有错误时返回false
五、writeString
1、新增默认Encoding还原步骤——write中会暂时将全局Encoding更改，和原设的默认值不同时用默认值再刷一次进行还原
2、新增doWrite-Callback计数相关处理
3、新增writableSync相关处理
4、新增writableBufferLength相关处理
5、新增writeCallbackBuffer存放处理
6、新增writableCb相关处理
7、回调函数逻辑更迭——当次chunk对应的Callback处理，辅助参数维护，error场景处理（Callback带入或已触发），writableLengthInner属性更新，后续数据请求（异步批量请求，同步则不主动请求），drain事件检查——1.0为Callback带入error时将其刷新到全局错误信息记录，当次chunk对应的Callback处理，请求后续一个数据，针对Callback带入的error进行错误场景处理
8、runOnce回调升级——补齐error场景处理——1.0执行emitErrorOnce，本质上也是仅触发error事件，不会抛错，使得不监听error事件时，仅跳过多余Callback，无错误信息
六、errorFresh：新增缓冲区清场处理函数，用于出错时缓冲区累积的write-Callback回调执行，缓冲区及相关属性清理
七、freshCache
1、新增cork计数未归零时直接返回
2、读取下一份缓冲区数据——取消const限制（不止取一次）并同步从writeCallbackBuffer读取下一个write-Callback（但不执行）——1.0取出后存于const
3、更换缓冲区数据输出机制——while循环不断读取缓冲区数据通过doWrite输出，同步回调场景下维持循环直到缓冲区清空，异步回调场景下则在doWrite后直接中断循环，通过Callback请求后续数据——缓冲区未空时输出，通过Callback再次进入freshCache尝试获取后续数据，同步回调场景下形成递归形式获取数据（writableLengthInner数值维护还放在回溯的那半部分，逆序减少），异步回调场景下依序处理；缓冲区为空取不到数据时writing状态解除，writableLengthInner 直接置0，处理drain事件
4、新增流的finish收尾处理
八、freshCacheV
1、新增cork计数未归零时直接返回
2、补齐缓冲区为空时的流finish处理
3、缓冲区非空且有doWritev的情况下，新增writableBufferLength和writableLengthInner相关处理——备份批量输出开始时的buffer使用长度，在回调中从writableLengthInner中减去——1.0没维护writableLengthInner
4、缓冲区非空且有doWritev的情况下，辅助参数（writing、writableCb、writableSync等）使用
5、缓冲区非空且有doWritev的情况下，Callback带入error，error场景处理——补齐error场景处理——1.0仅触发error事件
6、缓冲区非空且有doWritev的情况下，新增write-Callbacks批量处理——writeCallbacks备份批量输出开始时的writeCallbackBuffer，writeCallbackBuffer在同步流程中清空，writeCallbacks在批量执行完后清空——1.0不处理write-Callback
7、缓冲区非空且有doWritev的情况下，buffer清空时机更改——外移到doWritev后的同步流程中——1.0在Callback中，导致部分场景吞数据
8、缓冲区非空且有doWritev的情况下，Callback中增加后续数据请求——异步回调场景再次调用freshCacheV请求数据，同步回调场景下数据已清空，不再请求后续数据——1.0不请求后续数据
9、缓冲区非空且有doWritev的情况下，补齐流finish处理
10、runOnce回调升级——补齐error场景处理——1.0仅触发error事件，不会抛错，使得不监听error事件时，仅跳过多余Callback，无错误信息
九、afterWrite：drain事件检查——重复代码较多，提取为独立函数，并且补充需要达到水位线的要求，调用前进行同步异步判断，确保异步触发——1.0只要缓冲区被清空就报
十、finishWrite：finish事件及紧随的close事件——重复代码较多，提取为独立函数，finish事件单层异步执行（同步回调场景补一层异步，异步回调时不需要）并执行end-Callback，close事件紧跟一层异步执行——1.0多种场景遗漏，会丢finish事件，且close事件仅和end接口使用绑定，同步触发
十一、endInner
1、write功能转移——上移到end，且改为有写入就转给write处理，除了end-callback——1.0writing直接切到write处理（丢失后续的finish事件），非writing则自行通过doWrite写出
2、多余write-after-end处理删除——end中的检查能满足拦截需要，且endInner这部分非异步，所以直接删除——1.0无写入时会通过writableEndedInner再判断一次（end里已经通过writableEndedInner判断过一次了，而且没异步，不需要复查）
3、end-Callback——改为异步处理——1.0同步处理
4、事件处理——异步执行finish和close——1.0仅有finish（close在end里）
5、异步改用promise触发
十二、end
1、异常处理——顺序调整（其他错误->writableFinishedInner相关的Steam already finished->writableEndedInner相关的write after end）——1.0为（writableFinishedInner相关的Steam already finished->writableEndedInner相关的write after end->其他错误）
2、异步改用promise触发
3、write——从endInner前置到此——1.0在endInner
4、uncork——简化逻辑，改完cork计数就甩给uncork——1.0在cork计数不为0时，会跳过endInner
5、close事件——下移到endInner——1.0直接同步执行
十三、setDefaultEncoding和setEncoding：
1、功能拆分优化——原setDefaultEncoding改为setEncoding，新增setDefaultEncoding用于更新默认值 记录——1.0仅setDefaultEncoding
2、报错处理——throwError后补个errorFresh——NA
3、ascii——TextEncoder不支持ascii，设置ascii时用utf-8替代——1.0在设置ascii时，TextEncoder环节啥样没干跳过了，导致ascii后设置时会掩盖掉原Encoding（Encoding没有属性或接口可查，只有doWrite(v)的入参可看）但是TextEncoder其实没改掉
十四、uncork
1、转入freshCacheV环节添加非writing限制
2、转入freshCacheV环节也纳入cork计数非零限制
十五、off：throwError后补个errorFresh
十六、noWriteOpes：throwError后补个errorFresh
十七、throwError
1、writableInner——出错导致writableInner置false下放到本函数内减少重复代码和避免遗漏——1.0在出错的地方各自置false
2、异步改用promise触发
3、error事件后补充close事件
十八、移除多余的isOnError、emitErrorExecutedInner、emitErrorIdInner、emitErrorOnce（报错体系目前基本统一到throwError、errorFresh下——除了write的'write after end'单独适配）

---
## 一：关联的Issue

## 二：修改原因
（目的、解决的问题等，例如：修复xx场景崩溃问题）

## 三：修改描述
（做了什么，变更了什么，例如：xx函数入口增加判空）

## 四：兼容性领域分析
（若涉及非兼容性变更，需简要说明**变更点**，否则请简要说明不涉及的**理由**）

## 五：CheckList（**必填项**）
### 1. 接口功能自检
- rk3568 推UT文件执行（影响功能的必须执行）
  - [ ] 已通过
  - [ ] 不涉及，无需验证
- xts测试套执行（影响功能的必须执行）
  - [ ] 已通过
  - [ ] 不涉及，无需验证

### 2. 解决问题分类自检 (基于问题维度自检)
- [ ] 解决接口发生crash等问题。
- [ ] 解决接口定义与实际表现不一致问题。
- [ ] 解决接口历史方案存在的问题。
- [ ] 解决接口性能问题。
- [ ] 新需求上库。
- [ ] 解决告警问题。
- [ ] 不涉及

### 3. 接口功能用例看护自检（基于修改的功能点自检）
- [ ] 接口功能有看护用例，测试已通过。
- [ ] 接口功能没有用例看护，已经补充用例。
- [ ] 接口功能的看护用例存在问题，同步修改用例。
- [ ] 涉及接口变更行为，看护用例需同步修改。
- [ ] 不涉及

### 4. 稳定性专项自检（非Test代码必须执行）
- 用例验证，门禁构建镜像启动一遍所有应用，无相关的异常出现
  - [ ] 已通过
  - [ ] 不涉及，无需验证

### 5. 压测专项自检
- 压测填表验证，无相关的异常出现
  - [ ] 已通过
  - [ ] 不涉及，无需验证

### 6. 并发专项自检（taskpool/worker改动必须执行）
- 图库详情页功能测试
   - [ ] 已通过
- 畅连功能测试：登陆账号，发送30+图片，持续30+轮次
  - [ ] 已通过
- 游戏功能测试（消消乐/倩女幽魂/三国志/多乐斗地主/象棋等）
  - [ ] 已通过
- 48小时压测
  - [ ] 已通过
- wukong压测2小时验证（非Test代码需要）
  - [ ] 无相关crash产生
  - [ ] 不涉及，无需验证
### 7. 需求上库自检
- 是否同步合入interface仓的相关d.ts（需求合入用同一个issue）
  - [ ] 已同步
  - [ ] 不涉及
## 六：将上述测试的截图贴到下面

Type	Assign personnel	Status
Reviewer	yingguofeng weng-changcheng gonggong xliu	In progress (0/1 )
Tester	openharmony_ci	In progress (0/1 )

OpenHarmony/commonlibrary_ets_utilsClosed .gitee-modal { width: 500px !important; }

Search

OpenHarmony/commonlibrary_ets_utils
Closed