chronaxis.legacy.worker
在独立spawn进程按单条PULL许可调用共用BLF读取与串行解码政策。
有效INIT后导入依赖并加载一次DBC；惰性读取器在首次PULL才打开输入，READY不取帧。 每次许可按原序读取和解码一次，STATUS/ACK/STOP不授予读取许可。只使用限长JSON bytes协议，异常发送有限事实，实际子退出和父侧预算清理由协议控制器确认。
这是模块参考。日常调用先查公开API索引；下划线对象和嵌套函数供维护者查阅。签名来自固定源码，公开类构造签名经实际Python接口核对。
相关类型
LegacyCANRequest、LegacyDecodedFrame、LegacyRawFrame、Path
对象导航
| 对象 | 用途 |
|---|---|
_send |
通过bytes接口发送一个有界JSON包，不调用pickle通道。 |
_receive |
只接收一个不超过单包上限的bytes消息。 |
_exact |
限制每种控制包的精确字段，不让多余许可或版本字段静默生效。 |
_request |
解析唯一INIT，只接受单个实际BLF和原DBC路径，不读取其内容摘要。 |
_load_can_runtime |
在有效INIT后导入真实CAN依赖，模块导入本身只使用标准库。 |
_iter_blf |
按许可惰性创建共用BLF读取器，原消息顺序交付且可靠关闭本次文件。 |
_field_metadata |
只读同次db公开messages/signals核定位唯一，并返回原单位。 |
_frame |
保存当前消息的公开写出字段，不重建CAN消息或执行解码。 |
_argument_text |
只摘要原生异常参数，不执行任意对象str或先展开完整巨型消息。 |
_error_packet |
保存有限原错误事实，不把远端异常对象或任意类传给父进程。 |
_report_error |
尽力发送原错误事实，断管不替代child原错或阻止退出。 |
worker_main |
作为spawn目标按INIT/PULL协议调用共用BLF读取与串行兼容解码，等待许可时不预取。 |
导入与重导出来源（展开）
from importlib import metadata
from pathlib import Path
from ..dbc_loading import load_dbc_file
from .records import LegacyCANRequest, LegacyDecodedFrame, LegacyRawFrame, MAX_WIRE_BYTES, PROFILE_ID, decode_packet, decoded_to_dict, encode_packet, field_from_dict, field_to_dict_send
通过bytes接口发送一个有界JSON包，不调用pickle通道。
_send(connection, packet)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
connection |
multiprocessing.connection.Connection | 是 | 无 | 位置或关键字。父子进程之间已经建立的双向通信端点，用于发送请求和接收结果；不是文件路径或网络地址。 |
packet |
dict | 是 | 无 | 位置或关键字。packet为协议dict。 |
返回说明
返回None，不返回额外的计算值。
异常说明
原wire类型/限额或管道错误；不重试导致重复ITEM。
源码：src/chronaxis/legacy/worker.py:16（行号属于 8904c2f744951857659abd40aaa3535d57faf53c）。
_receive
只接收一个不超过单包上限的bytes消息。
_receive(connection)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
connection |
multiprocessing.connection.Connection | 是 | 无 | 位置或关键字。父子进程之间已经建立的双向通信端点，用于发送请求和接收结果；不是文件路径或网络地址。 |
返回说明
已校验dict。
异常说明
EOFError/OSError/协议错误传播，不把断管当正常来源EOF。
源码：src/chronaxis/legacy/worker.py:25（行号属于 8904c2f744951857659abd40aaa3535d57faf53c）。
_exact
限制每种控制包的精确字段，不让多余许可或版本字段静默生效。
_exact(packet, names)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
packet |
dict[str, object] | 是 | 无 | 位置或关键字。已经解码并检查字段的进程通信包，含op操作名及该操作的数据；本函数按当前协议步骤继续检查或发送它。 |
names |
set[str] | tuple[str, ...] | 是 | 无 | 位置或关键字。该协议操作需要的完整键名集合；缺键和额外键均报错。 |
返回说明
返回None，不返回额外的计算值。
异常说明
ValueError为字段缺失或多余。
本函数直接报告的具体错误：
ValueError：旧CAN控制包字段缺失或多余。
源码：src/chronaxis/legacy/worker.py:34（行号属于 8904c2f744951857659abd40aaa3535d57faf53c）。
_request
解析唯一INIT，只接受单个实际BLF和原DBC路径，不读取其内容摘要。
_request(packet)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
packet |
dict | 是 | 无 | 位置或关键字。packet为INIT dict。 |
返回说明
LegacyCANRequest。
异常说明
类型/形状/版本/路径错误；不调用旧reader或load_file。
本函数直接报告的具体错误：
ValueError：旧CAN需要init/version1。TypeError：旧CAN INIT需要文本路径与fields数组。ValueError：首版旧CAN仅支持单个现有BLF文件。
源码：src/chronaxis/legacy/worker.py:44（行号属于 8904c2f744951857659abd40aaa3535d57faf53c）。
_load_can_runtime
在有效INIT后导入真实CAN依赖，模块导入本身只使用标准库。
_load_can_runtime()参数：无显式参数。
参数说明
无。
返回说明
python-can与cantools模块。
异常说明
保留缺失依赖的可执行提示。 不读取来源、DBC或原项目文件，不安装同名vendor模块。
源码：src/chronaxis/legacy/worker.py:65（行号属于 8904c2f744951857659abd40aaa3535d57faf53c）。
_iter_blf
按许可惰性创建共用BLF读取器，原消息顺序交付且可靠关闭本次文件。
_iter_blf(path)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
path |
str | Path | 是 | 无 | 位置或关键字。要读取的BLF文件路径；按文件原顺序迭代原始报文。 |
返回说明
can.Message生成器。
异常说明
真实读取/关闭错误。 创建生成器不打开文件；第一次next才调用BLFRead，STOP或EOF关闭同一owner。
源码：src/chronaxis/legacy/worker.py:75（行号属于 8904c2f744951857659abd40aaa3535d57faf53c）。
_field_metadata
只读同次db公开messages/signals核定位唯一，并返回原单位。
_field_metadata(db, fields, *, cycle_fields=())参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
db |
cantools.database.can.Database | 是 | 无 | 位置或关键字。本次DBC加载所得数据库，读取消息和信号定义生成来源字段描述。 |
fields |
tuple[LegacyCANField, ...] | 是 | 无 | 位置或关键字。fields为原LegacyCANField tuple。 |
cycle_fields |
tuple[LegacyCANField, ...] | 否 | () | 仅关键字。需要读取DBC周期的字段定位集合；初始化时读取元数据，不逐帧读取DBC。 |
返回说明
按请求顺序的字段事实；周期请求的字段另含正cycle_ns。 仅DBC为FD而定位为经典CAN时增加固定兼容提示。 channel保声明，不冒称DBC已测通道；不把DBC声明写回原帧。
异常说明
ValueError为ID/消息/帧型/信号歧义或不符，TypeError为单位不受支持。
本函数直接报告的具体错误：
ValueError：原DBC消息名称或标准/FD帧型与定位不同。TypeError：原DBC公开unit需要文本或None。
源码：src/chronaxis/legacy/worker.py:102（行号属于 8904c2f744951857659abd40aaa3535d57faf53c）。
_frame
保存当前消息的公开写出字段，不重建CAN消息或执行解码。
_frame(msg)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
msg |
can.Message | 是 | 无 | 位置或关键字。本次旧读取器刚返回的原始报文，保持时间戳、ID、通道、标志和数据字节。 |
返回说明
LegacyRawFrame。
异常说明
新边界字段校验失败；data仅无损复制为bytes，不改timestamp/DLC/标志。
本函数直接报告的具体错误：
ValueError：原报文data超过64字节，不能先复制再拒绝。
源码：src/chronaxis/legacy/worker.py:154（行号属于 8904c2f744951857659abd40aaa3535d57faf53c）。
_argument_text
只摘要原生异常参数，不执行任意对象str或先展开完整巨型消息。
_argument_text(value, limit)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
value |
object | 是 | 无 | 位置或关键字。异常args中的一个原始值，转换为有长度上限的错误文字；不直接输出整个日志或大对象。 |
limit |
int | 是 | 无 | 位置或关键字。该错误文字的最大字符数，超过时截短以限制协议包大小。 |
返回说明
有限str，短原str保持内容。
异常说明
无主动异常；未知对象仅标明类型，不调用其自定义字符串方法。
源码：src/chronaxis/legacy/worker.py:169（行号属于 8904c2f744951857659abd40aaa3535d57faf53c）。
_error_packet
保存有限原错误事实，不把远端异常对象或任意类传给父进程。
_error_packet(exc, phase, request_id)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
exc |
BaseException | 是 | 无 | 位置或关键字。本次操作的原异常，供附加关闭失败信息并保留原因链。不要用错误字符串代替异常对象。 |
phase |
str | 是 | 无 | 位置或关键字。phase为有限阶段文本 |
request_id |
int | None | 是 | 无 | 位置或关键字。本次协议请求的编号，供父进程关联响应；尚未取得请求编号的初始化错误使用None。 |
返回说明
有限ERROR dict；message是至多4个args摘要，traceback仅至多8个栈地点， 均不是完整str(exc)或完整traceback，截断有明确note，短单str参数保持原文本。
异常说明
标准库字段访问/编码错误传播；调用方仍须确定退出，不伪报正常EOF。
源码：src/chronaxis/legacy/worker.py:184（行号属于 8904c2f744951857659abd40aaa3535d57faf53c）。
_report_error
尽力发送原错误事实，断管不替代child原错或阻止退出。
_report_error(connection, exc, phase, request_id)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
connection |
multiprocessing.connection.Connection | 是 | 无 | 位置或关键字。父子进程之间已经建立的双向通信端点，用于发送请求和接收结果；不是文件路径或网络地址。 |
exc |
BaseException | 是 | 无 | 位置或关键字。实际捕获的异常，提取有限错误信息后通过协议报告给父进程。 |
phase |
str | 是 | 无 | 位置或关键字。异常发生的处理步骤，例如初始化、读取或解码，用于定位失败阶段。 |
request_id |
int | None | 是 | 无 | 位置或关键字。本次协议请求的编号，供父进程关联响应；尚未取得请求编号的初始化错误使用None。 |
返回说明
返回None，不返回额外的计算值。
异常说明
不传播附加报告错误；原失败仍由worker最终非零退出表达。
源码：src/chronaxis/legacy/worker.py:227（行号属于 8904c2f744951857659abd40aaa3535d57faf53c）。
worker_main
作为spawn目标按INIT/PULL协议调用共用BLF读取与串行兼容解码，等待许可时不预取。
worker_main(connection)参数
| 名称 | 数据类型 | 必填 | 省略时的值 | 用途、取值和效果 |
|---|---|---|---|---|
connection |
multiprocessing.connection.Connection | 是 | 无 | 位置或关键字。父子进程之间已经建立的双向通信端点，用于发送请求和接收结果；不是文件路径或网络地址。 |
返回说明
正常STOP或真实EOF时None。
异常说明
原错误尽力发ERROR后以SystemExit(1)退出；连接/生成器附加关闭错误也非零。
本函数直接报告的具体错误：
ValueError：未知旧CAN控制操作。ValueError：PULL许可必须从0严格连续。ValueError：ACK仅接受确认最近返回ITEM。
副作用说明
本child内一次DBC加载、一次iter_frames、每许可一次next/parse；不额外扫描。
源码：src/chronaxis/legacy/worker.py:239（行号属于 8904c2f744951857659abd40aaa3535d57faf53c）。