Method submit_request

lightx2v/disagg/workload.py:259–281

(self)

    @task
    def submit_request(self):
        stage = _current_stage(self.stages)
        request_index = int(time.time() * 1000) % 1_000_000
        payload = _build_request_payload(self.base_config, stage, request_index)
        send_started = time.perf_counter()
        try:
            host, port = _get_controller_target()
            self.req_mgr.send(host, port, payload)
            events.request.fire(
                request_type="zmq",
                name=f"{stage.name}:config_push",
                response_time=(time.perf_counter() - send_started) * 1000.0,
                response_length=len(str(payload)),
                exception=None,
            )
        except Exception as exc:
            events.request.fire(
                request_type="zmq",
                name=f"{stage.name}:config_push",
                response_time=(time.perf_counter() - send_started) * 1000.0,
                response_length=0,
                exception=exc,
            )


__all__ = [