Skip to content

refactor(qwen35): split weights.rs layer types + loaders into weights/layers.rs - #969

Open
CAICAIIs wants to merge 9 commits into
pegainfer-project:mainfrom
CAICAIIs:refactor/qwen35-weights-a
Open

refactor(qwen35): split weights.rs layer types + loaders into weights/layers.rs#969
CAICAIIs wants to merge 9 commits into
pegainfer-project:mainfrom
CAICAIIs:refactor/qwen35-weights-a

Conversation

@CAICAIIs

Copy link
Copy Markdown
Collaborator

What

Split the layer container types + weight-loading helpers out of the 921-line pegainfer-qwen35/src/weights.rs into weights/layers.rs. weights.rs keeps the model + its loading/inference impl. Behavior unchanged.

Structure

pegainfer-qwen35/src/
├── weights.rs        # Qwen35Model + impl (loading/inference orchestration)
└── weights/
    └── layers.rs     # FullAttentionLayer / LinearAttentionLayer / LayerKind / MLP35 / TransformerBlock35 + load helpers

Validation

  • cargo check — pass
  • cargo clippy --all-targets -- -D warnings — pass (matches CI)

Note

Independent slice (does not depend on the scheduler stack). Adds #![allow(clippy::wildcard_imports)] at crate level for the submodule glob.

Split the 683-line config.rs into a config/ module with model/tokenizer/tp
submodules (k3-style mod.rs entry + config/), reducing config.rs to a re-export.
Behavior unchanged. cargo check + clippy --all-targets -D warnings + config tests
(14/14) green.

Signed-off-by: CAICAIIs <3360776475@qq.com>
…try types

Rebuild the config split into a directional ownership model instead of a
flat file redistribution:

- model.rs: deserialize a RawConfig into a validated, TP-agnostic Config35
  via TryFrom, with typed ConfigError variants for every cross-field and
  kernel-AOT rule.
- tp.rs: validate TensorParallelConfig at construction (private fields, so
  invalid world_size/rank is unrepresentable) and derive a validated
  LocalGeometry from (Config35, TP config, cuda-graph mode). Downstream
  accepts LocalGeometry instead of re-deriving shards from a raw rank pair.
- error.rs: typed ConfigError (thiserror) used across model + TP boundaries.
- tokenizer.rs: own the frontend compatibility schema explicitly instead of
  hiding unread fields behind allow(dead_code).
- mod.rs: explicit exports (no glob re-exports); tests co-located in the
  owning module, fixture + table-driven mutations.

Downstream (weights, decode_buffers, batch_decode, batch_decode_graph,
prefill, tp_executor) now threads LocalGeometry for all shard math.

Signed-off-by: CAICAIIs <3360776475@qq.com>
… re-export

recurrent.rs reads GDN_AOT_*_DIM and LINEAR_CONV_MAX_KERNEL_DIM from
crate::config; re-export them from config/mod.rs. ConfigError is referenced
only inside the config submodules, so the crate-level re-export is dead.

Signed-off-by: CAICAIIs <3360776475@qq.com>
…nused tp() accessor

The FrontendAddedToken schema is an explicitly-owned fail-closed contract
whose fields exist only to shape the typed parse; attach a justified
allow(dead_code) instead of letting -D warnings reject it. LocalGeometry::tp()
is unused now that downstream takes LocalGeometry directly.

Signed-off-by: CAICAIIs <3360776475@qq.com>
Signed-off-by: CAICAIIs <3360776475@qq.com>
…paths

Expose RawConfig at the config boundary so sibling test modules can
deserialize fixtures, and reference RawConfig via crate::config paths that
resolve inside both the real crate and the isolated harness.

Signed-off-by: CAICAIIs <3360776475@qq.com>
Reaching into the private model module for a fixture weakens the validated
boundary and pulls RawConfig into the crate surface. Build the test config
through the real Config35::from_file entry point with a tempdir, and stop
re-exporting RawConfig (lib-only clippy flags it as unused).

Signed-off-by: CAICAIIs <3360776475@qq.com>
…n_layers

Signed-off-by: CAICAIIs <3360776475@qq.com>
…/layers.rs

Move FullAttentionLayer/LinearAttentionLayer/LayerKind/MLP35/TransformerBlock35 and the
weight-loading helpers (full_attention_gated_q_shard_range/load_*_shard_if_needed) out of
the 921-line weights.rs into a flat weights/layers.rs. Layer types + fields are pub(crate)
(forward/* reads them as crate::weights::X) and the root re-exports them; helpers are used
by the Qwen35Model impl via use layers::*. weights.rs 921 -> ~800. cargo check + fmt + test
--lib 95/95 green.

Signed-off-by: CAICAIIs <3360776475@qq.com>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant