调用超时问题

[sxzxs]

当被调用的进程退出了，但是接口还是会等到超时后才返回

期望： 当被调用的进程退出时，接口立即返回错误

[sxzxs]

    /*
    * Synchronously calls a function on the target channel with a timeout.
    * @param target_channel The channel to call the function on.
    * @param timeout_ms The timeout in milliseconds.
    * @param func_name The name of the function to call.
    * @param args The arguments to pass to the function.
    * @return A veigar::CallResult containing the result of the function call.
    * If the service is not running, it returns an error.
    * If the call times out, it returns an error.
    * If the call is successful, it returns the result of the function call.
    */
    template <typename... Args>
    veigar::CallResult sync_call(const std::string& target_channel, uint32_t timeout_ms, const std::string& func_name, Args... args)
    {
        LOGGER_TRACE_IN();
        std::string service_pid_start = get_service_pid();
        if(service_pid_start.empty()) 
        {
            veigar::CallResult cr;
            cr.errCode = veigar::ErrorCode::FAILED;
            cr.errorMessage = "service is not running, cannot call function.";
            LOGGER_ERROR("service is not running, cannot call function.");
            LOGGER_TRACE_OUT();
            return cr;
        }

        std::shared_ptr<veigar::AsyncCallResult> acr = doAsyncCall(target_channel, 30000, func_name, std::forward<Args>(args)...);
        if (!acr || !acr->second.valid()) 
        {
            if (acr) 
            {
                _p_vg->releaseCall(acr->first);
            }

            veigar::CallResult cr;
            cr.errCode = veigar::ErrorCode::FAILED;
            cr.errorMessage = "Async call failed, invalid future.";
            LOGGER_ERROR(cr.errorMessage);
            LOGGER_TRACE_OUT();
            return cr;
        }

        int remaining_timeout = timeout_ms;
        while (remaining_timeout > 0) 
        {
            int current_wait = std::min(remaining_timeout, 5000); // Wait max 5 seconds at a time
            auto wait_result = acr->second.wait_for(std::chrono::milliseconds(current_wait));
            
            if (wait_result != std::future_status::timeout) 
            {
                // Got a result, break the loop
                break;
            }

            std::string current_pid = get_service_pid();
            if(service_pid_start != current_pid)
            {

                veigar::CallResult cr;
                cr.errCode = veigar::ErrorCode::FAILED;
                cr.errorMessage = "service is not running, cannot load testprogram.";
                _p_vg->releaseCall(acr->first);
                LOGGER_ERROR("{}. before: {}, now: {}", cr.errorMessage, service_pid_start, current_pid);
                LOGGER_TRACE_OUT();
                return cr;
            }
            
            remaining_timeout -= current_wait;
        }

        if (remaining_timeout <= 0) 
        {
            // Timeout occurred
            veigar::CallResult cr;
            cr.errCode = veigar::ErrorCode::FAILED;
            cr.errorMessage = "Call timed out.";
            _p_vg->releaseCall(acr->first);
            LOGGER_ERROR(cr.errorMessage);
            LOGGER_TRACE_OUT();
            return cr;
        }

        veigar::CallResult ret = std::move(acr->second.get());
        releaseCall(acr->first);
        return ret;
    }

我目前的方案