send_network_io_job.h

Go to the documentation of this file.

// BSD 3-Clause License
// Copyright (c) 2021-2025, 🍀☀🌕🌥 🌊
// See the LICENSE file in the project root for full license information.
 
#pragma once
 
#include <kcenon/pacs/network/pipeline/pipeline_coordinator.h>
#include <kcenon/pacs/network/pipeline/pipeline_job_types.h>
#include <kcenon/pacs/core/result.h>
 
#include <cstdint>
#include <functional>
#include <string>
#include <vector>
 
namespace kcenon::pacs::network::pipeline {
 
class send_network_io_job : public pipeline_job_base {
public:
    using completion_callback = std::function<void(uint64_t session_id,
                                                   bool success,
                                                   size_t bytes_sent)>;
 
    using error_callback = std::function<void(uint64_t session_id,
                                              const std::string& error)>;
 
    using send_function = std::function<VoidResult(uint64_t session_id,
                                                   const std::vector<uint8_t>& data)>;
 
    send_network_io_job(uint64_t session_id,
                        std::vector<uint8_t> data,
                        send_function send_fn,
                        completion_callback on_complete = nullptr,
                        error_callback on_error = nullptr);
 
    ~send_network_io_job() override = default;
 
    // Non-copyable, movable
    send_network_io_job(const send_network_io_job&) = delete;
    send_network_io_job& operator=(const send_network_io_job&) = delete;
    send_network_io_job(send_network_io_job&&) = default;
    send_network_io_job& operator=(send_network_io_job&&) = default;
 
    [[nodiscard]] auto execute(pipeline_coordinator& coordinator) -> VoidResult override;
 
    [[nodiscard]] auto get_context() const noexcept -> const job_context& override;
    [[nodiscard]] auto get_context() noexcept -> job_context& override;
 
    [[nodiscard]] auto get_name() const -> std::string override;
 
    [[nodiscard]] auto get_data() const noexcept -> const std::vector<uint8_t>&;
 
    [[nodiscard]] auto get_session_id() const noexcept -> uint64_t;
 
private:
    job_context context_;
    std::vector<uint8_t> data_;
    send_function send_fn_;
    completion_callback on_complete_;
    error_callback on_error_;
};
 
}  // namespace kcenon::pacs::network::pipeline