diff --git a/crates/engine_zmq_client/examples/live_probe.rs b/crates/engine_zmq_client/examples/live_probe.rs index 9dcbca45f..e1a1b9d2e 100644 --- a/crates/engine_zmq_client/examples/live_probe.rs +++ b/crates/engine_zmq_client/examples/live_probe.rs @@ -1,5 +1,3 @@ -// SPDX-License-Identifier: Apache-2.0 -// // Live wire-validation probe: play the SMG frontend against a real headless // vLLM EngineCore over ZMQ. Binds the handshake/input/output sockets, drives the // handshake, submits one tokenized generate request, and prints the streamed diff --git a/crates/engine_zmq_client/src/codec/dtype.rs b/crates/engine_zmq_client/src/codec/dtype.rs index b950427d1..d10ee9360 100644 --- a/crates/engine_zmq_client/src/codec/dtype.rs +++ b/crates/engine_zmq_client/src/codec/dtype.rs @@ -1,5 +1,3 @@ -// SPDX-License-Identifier: Apache-2.0 -// // Adapted from the Apache-2.0 reference `vllm-engine-core-client` // (vllm-project/vllm): protocol/dtype.rs and protocol/logprobs/array.rs. diff --git a/crates/engine_zmq_client/src/codec/mod.rs b/crates/engine_zmq_client/src/codec/mod.rs index bbd4f5f2a..1871ba84a 100644 --- a/crates/engine_zmq_client/src/codec/mod.rs +++ b/crates/engine_zmq_client/src/codec/mod.rs @@ -1,5 +1,3 @@ -// SPDX-License-Identifier: Apache-2.0 -// // Adapted from the Apache-2.0 reference `vllm-engine-core-client` // (vllm-project/vllm): protocol/mod.rs. diff --git a/crates/engine_zmq_client/src/codec/tensor.rs b/crates/engine_zmq_client/src/codec/tensor.rs index 4f3e959ea..638078ef6 100644 --- a/crates/engine_zmq_client/src/codec/tensor.rs +++ b/crates/engine_zmq_client/src/codec/tensor.rs @@ -1,5 +1,3 @@ -// SPDX-License-Identifier: Apache-2.0 -// // Adapted from the Apache-2.0 reference `vllm-engine-core-client` // (vllm-project/vllm): protocol/tensor.rs and protocol/logprobs/array.rs. // diff --git a/crates/engine_zmq_client/src/connector.rs b/crates/engine_zmq_client/src/connector.rs index 876ffc6cf..13ce8ef7e 100644 --- a/crates/engine_zmq_client/src/connector.rs +++ b/crates/engine_zmq_client/src/connector.rs @@ -1,5 +1,3 @@ -// SPDX-License-Identifier: Apache-2.0 -// // The connector: the frontend-side request/response layer over a // [`ConnectedTransport`]. Adapted from the Apache-2.0 reference // `vllm-engine-core-client` (vllm-project/vllm) client, scoped to SMG's needs: diff --git a/crates/engine_zmq_client/src/error.rs b/crates/engine_zmq_client/src/error.rs index ce8691983..09fca8c01 100644 --- a/crates/engine_zmq_client/src/error.rs +++ b/crates/engine_zmq_client/src/error.rs @@ -1,5 +1,3 @@ -// SPDX-License-Identifier: Apache-2.0 -// // Error variants for the vLLM EngineCore protocol are adapted from the // Apache-2.0 reference `vllm-engine-core-client` (vllm-project/vllm, // rust/src/engine-core-client/src/error.rs). See crate root for provenance. diff --git a/crates/engine_zmq_client/src/lib.rs b/crates/engine_zmq_client/src/lib.rs index c8b9ec3fb..8d2280cce 100644 --- a/crates/engine_zmq_client/src/lib.rs +++ b/crates/engine_zmq_client/src/lib.rs @@ -1,5 +1,3 @@ -// SPDX-License-Identifier: Apache-2.0 - //! Engine-agnostic ZMQ transport + per-engine protocol modules for same-host //! SMG backend connections. //! diff --git a/crates/engine_zmq_client/src/mock_engine.rs b/crates/engine_zmq_client/src/mock_engine.rs index 1ea597a3d..17de2b1e3 100644 --- a/crates/engine_zmq_client/src/mock_engine.rs +++ b/crates/engine_zmq_client/src/mock_engine.rs @@ -1,5 +1,3 @@ -// SPDX-License-Identifier: Apache-2.0 -// // Test-only mock engine, adapted from the Apache-2.0 reference // `vllm-engine-core-client` (vllm-project/vllm): mock_engine.rs + test_utils.rs. // diff --git a/crates/engine_zmq_client/src/protocol/handshake.rs b/crates/engine_zmq_client/src/protocol/handshake.rs index 3c3c82c67..408bf7417 100644 --- a/crates/engine_zmq_client/src/protocol/handshake.rs +++ b/crates/engine_zmq_client/src/protocol/handshake.rs @@ -1,5 +1,3 @@ -// SPDX-License-Identifier: Apache-2.0 -// // Ported from the Apache-2.0 reference `vllm-engine-core-client` // (vllm-project/vllm): protocol/handshake.rs. diff --git a/crates/engine_zmq_client/src/protocol/mod.rs b/crates/engine_zmq_client/src/protocol/mod.rs index ecf3f6640..23ca47533 100644 --- a/crates/engine_zmq_client/src/protocol/mod.rs +++ b/crates/engine_zmq_client/src/protocol/mod.rs @@ -1,5 +1,3 @@ -// SPDX-License-Identifier: Apache-2.0 - //! Per-engine wire protocol modules plus the engine-neutral seam the transport //! and connector are generic over. //! diff --git a/crates/engine_zmq_client/src/protocol/tokenspeed/mod.rs b/crates/engine_zmq_client/src/protocol/tokenspeed/mod.rs index 0ef2eed60..ed5968247 100644 --- a/crates/engine_zmq_client/src/protocol/tokenspeed/mod.rs +++ b/crates/engine_zmq_client/src/protocol/tokenspeed/mod.rs @@ -1,5 +1,3 @@ -// SPDX-License-Identifier: Apache-2.0 - //! TokenSpeed wire protocol. //! //! Clean-room port of TokenSpeed's native engine-IPC messages diff --git a/crates/engine_zmq_client/src/protocol/tokenspeed/output.rs b/crates/engine_zmq_client/src/protocol/tokenspeed/output.rs index e1e52d2d5..baaabe97c 100644 --- a/crates/engine_zmq_client/src/protocol/tokenspeed/output.rs +++ b/crates/engine_zmq_client/src/protocol/tokenspeed/output.rs @@ -1,5 +1,3 @@ -// SPDX-License-Identifier: Apache-2.0 -// // TokenSpeed per-step batched output — the native `BatchTokenIDOutSlim` from // `io_struct.py`, a tagged `msgspec.Struct(array_like=True)`: on the wire it is // a positional msgpack array with the class-name tag string as element 0. diff --git a/crates/engine_zmq_client/src/protocol/tokenspeed/request.rs b/crates/engine_zmq_client/src/protocol/tokenspeed/request.rs index 38ec0edea..713623d47 100644 --- a/crates/engine_zmq_client/src/protocol/tokenspeed/request.rs +++ b/crates/engine_zmq_client/src/protocol/tokenspeed/request.rs @@ -1,5 +1,3 @@ -// SPDX-License-Identifier: Apache-2.0 -// // TokenSpeed tokenized generate request — the native `TokenizedGenerateReqInput` // from `io_struct.py`, a tagged `msgspec.Struct(array_like=True)`: on the wire // it is a positional msgpack array with the class-name tag string as element 0. diff --git a/crates/engine_zmq_client/src/protocol/tokenspeed/sampling.rs b/crates/engine_zmq_client/src/protocol/tokenspeed/sampling.rs index 81ac5e8ea..82cc0daea 100644 --- a/crates/engine_zmq_client/src/protocol/tokenspeed/sampling.rs +++ b/crates/engine_zmq_client/src/protocol/tokenspeed/sampling.rs @@ -1,5 +1,3 @@ -// SPDX-License-Identifier: Apache-2.0 -// // TokenSpeed `SamplingParams` — a Python `msgspec.Struct(kw_only=True, // array_like=True)` (runtime/sampling/sampling_params.py), so it rides the // wire as an untagged positional msgpack array nested inside the tokenized diff --git a/crates/engine_zmq_client/src/protocol/vllm/logprobs.rs b/crates/engine_zmq_client/src/protocol/vllm/logprobs.rs index 0dff223bd..ec75785b0 100644 --- a/crates/engine_zmq_client/src/protocol/vllm/logprobs.rs +++ b/crates/engine_zmq_client/src/protocol/vllm/logprobs.rs @@ -1,5 +1,3 @@ -// SPDX-License-Identifier: Apache-2.0 -// // Ported from the Apache-2.0 reference `vllm-engine-core-client` // (vllm-project/vllm): protocol/logprobs.rs + protocol/logprobs/wire.rs. // The numpy-array decoders live in `crate::codec::tensor`. diff --git a/crates/engine_zmq_client/src/protocol/vllm/lora.rs b/crates/engine_zmq_client/src/protocol/vllm/lora.rs index b57ba2863..174d73670 100644 --- a/crates/engine_zmq_client/src/protocol/vllm/lora.rs +++ b/crates/engine_zmq_client/src/protocol/vllm/lora.rs @@ -1,5 +1,3 @@ -// SPDX-License-Identifier: Apache-2.0 -// // Ported from the Apache-2.0 reference `vllm-engine-core-client` // (vllm-project/vllm): protocol/lora.rs. diff --git a/crates/engine_zmq_client/src/protocol/vllm/mod.rs b/crates/engine_zmq_client/src/protocol/vllm/mod.rs index 44d96abdd..aae1220a6 100644 --- a/crates/engine_zmq_client/src/protocol/vllm/mod.rs +++ b/crates/engine_zmq_client/src/protocol/vllm/mod.rs @@ -1,5 +1,3 @@ -// SPDX-License-Identifier: Apache-2.0 - //! vLLM EngineCore wire protocol. //! //! Clean-room port of vLLM's Apache-2.0 `vllm-engine-core-client` diff --git a/crates/engine_zmq_client/src/protocol/vllm/output.rs b/crates/engine_zmq_client/src/protocol/vllm/output.rs index c8d2a05e9..1374f18f4 100644 --- a/crates/engine_zmq_client/src/protocol/vllm/output.rs +++ b/crates/engine_zmq_client/src/protocol/vllm/output.rs @@ -1,5 +1,3 @@ -// SPDX-License-Identifier: Apache-2.0 -// // Ported from the Apache-2.0 reference `vllm-engine-core-client` // (vllm-project/vllm): protocol/output.rs. // diff --git a/crates/engine_zmq_client/src/protocol/vllm/request.rs b/crates/engine_zmq_client/src/protocol/vllm/request.rs index de7546f5e..3e2e70959 100644 --- a/crates/engine_zmq_client/src/protocol/vllm/request.rs +++ b/crates/engine_zmq_client/src/protocol/vllm/request.rs @@ -1,5 +1,3 @@ -// SPDX-License-Identifier: Apache-2.0 -// // Ported from the Apache-2.0 reference `vllm-engine-core-client` // (vllm-project/vllm): protocol/request.rs. // diff --git a/crates/engine_zmq_client/src/protocol/vllm/sampling.rs b/crates/engine_zmq_client/src/protocol/vllm/sampling.rs index 13ed51a9a..6e7e70fe5 100644 --- a/crates/engine_zmq_client/src/protocol/vllm/sampling.rs +++ b/crates/engine_zmq_client/src/protocol/vllm/sampling.rs @@ -1,5 +1,3 @@ -// SPDX-License-Identifier: Apache-2.0 -// // Ported from the Apache-2.0 reference `vllm-engine-core-client` // (vllm-project/vllm): protocol/sampling.rs. // diff --git a/crates/engine_zmq_client/src/protocol/vllm/stats.rs b/crates/engine_zmq_client/src/protocol/vllm/stats.rs index 365b6eb94..3e7b53552 100644 --- a/crates/engine_zmq_client/src/protocol/vllm/stats.rs +++ b/crates/engine_zmq_client/src/protocol/vllm/stats.rs @@ -1,5 +1,3 @@ -// SPDX-License-Identifier: Apache-2.0 -// // Ported from the Apache-2.0 reference `vllm-engine-core-client` // (vllm-project/vllm): protocol/stats.rs. diff --git a/crates/engine_zmq_client/src/transport.rs b/crates/engine_zmq_client/src/transport.rs index 8b2599969..167c20011 100644 --- a/crates/engine_zmq_client/src/transport.rs +++ b/crates/engine_zmq_client/src/transport.rs @@ -1,5 +1,3 @@ -// SPDX-License-Identifier: Apache-2.0 -// // Ported from the Apache-2.0 reference `vllm-engine-core-client` // (vllm-project/vllm): transport.rs. // diff --git a/model_gateway/src/routers/grpc/zmq_client.rs b/model_gateway/src/routers/grpc/zmq_client.rs index e3fc0b692..dd442d42f 100644 --- a/model_gateway/src/routers/grpc/zmq_client.rs +++ b/model_gateway/src/routers/grpc/zmq_client.rs @@ -1,5 +1,3 @@ -// SPDX-License-Identifier: Apache-2.0 -// // ZMQ backend adapter (gateway glue): presents the vLLM engine surface (the same // proto request/response types as `VllmEngineClient`) but speaks ZMQ directly to // a same-host engine (vLLM EngineCore or TokenSpeed) via `engine-zmq-client`,