Adapter for integrating pipeline with DICOM server components. More...

#include <pipeline_adapter.h>

Collaboration diagram for kcenon::pacs::network::pipeline::pipeline_adapter:

Public Types
using	send_callback
	Type for network send callback.

using	association_callback
	Type for association event callback.

using	session_event_callback
	Type for session event callback.

using	service_handler = storage_query_exec_job::service_handler
	Service handler type.

Public Member Functions
	pipeline_adapter ()
	Construct adapter with default configuration.

	pipeline_adapter (const pipeline_config &config)
	Construct adapter with custom configuration.

	~pipeline_adapter ()
	Destructor - ensures graceful shutdown.

	pipeline_adapter (const pipeline_adapter &)=delete

pipeline_adapter &	operator= (const pipeline_adapter &)=delete

	pipeline_adapter (pipeline_adapter &&)=delete

pipeline_adapter &	operator= (pipeline_adapter &&)=delete

auto	start () -> VoidResult
	Start the pipeline adapter.

auto	stop () -> VoidResult
	Stop the pipeline adapter.

auto	is_running () const noexcept -> bool
	Check if the adapter is running.

void	register_session (uint64_t session_id, session_context context)
	Register a new session.

void	unregister_session (uint64_t session_id)
	Unregister a session.

auto	get_session (uint64_t session_id) -> std::optional< session_context >
	Get session context.

auto	get_active_session_count () const noexcept -> size_t
	Get number of active sessions.

auto	on_data_received (uint64_t session_id, std::vector< uint8_t > data) -> VoidResult
	Handle incoming data from network.

void	on_connection_closed (uint64_t session_id)
	Handle connection closed event.

void	register_c_store_handler (service_handler handler)
	Register C-STORE handler.

void	register_c_find_handler (service_handler handler)
	Register C-FIND handler.

void	register_c_get_handler (service_handler handler)
	Register C-GET handler.

void	register_c_move_handler (service_handler handler)
	Register C-MOVE handler.

void	register_c_echo_handler (service_handler handler)
	Register C-ECHO handler.

void	set_send_callback (send_callback callback)
	Set the network send callback.

void	set_association_callback (association_callback callback)
	Set the association event callback.

void	set_session_event_callback (session_event_callback callback)
	Set the session event callback.

auto	get_metrics () noexcept -> pipeline_metrics &
	Get the pipeline metrics.

auto	get_metrics () const noexcept -> const pipeline_metrics &
	Get the pipeline metrics (const)

auto	get_coordinator () noexcept -> pipeline_coordinator &
	Get the underlying coordinator.

auto	get_coordinator () const noexcept -> const pipeline_coordinator &
	Get the underlying coordinator (const)

Private Member Functions
auto	get_handler_for_command (dimse_command_type type) -> service_handler
	Get service handler for command type.

void	on_job_completed (const job_context &ctx, bool success)
	Handle job completion.

void	on_backpressure (pipeline_stage stage, size_t queue_depth)
	Handle backpressure.

Private Attributes
std::unique_ptr< pipeline_coordinator >	coordinator_
	Pipeline coordinator.

std::unordered_map< uint64_t, session_context >	sessions_
	Session registry.

std::mutex	sessions_mutex_

service_handler	c_store_handler_
	Service handlers.

service_handler	c_find_handler_

service_handler	c_get_handler_

service_handler	c_move_handler_

service_handler	c_echo_handler_

std::mutex	handlers_mutex_

send_callback	send_callback_
	Callbacks.

association_callback	association_callback_

session_event_callback	session_event_callback_

std::mutex	callbacks_mutex_

Detailed Description

Adapter for integrating pipeline with DICOM server components.

The adapter provides:

Session management for active associations
Service handler registration for DIMSE operations
Network send/receive callbacks
Graceful shutdown coordination

Definition at line 100 of file pipeline_adapter.h.

Member Typedef Documentation

◆ association_callback

using kcenon::pacs::network::pipeline::pipeline_adapter::association_callback

Initial value:

 std::function<void(uint64_t session_id,
                                                    kcenon::pacs::network::pdu_type type,
                                                    const std::vector<uint8_t>& data)>

Type for association event callback.

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/pipeline_adapter.h.

Definition at line 107 of file pipeline_adapter.h.

◆ send_callback

using kcenon::pacs::network::pipeline::pipeline_adapter::send_callback

Initial value:

std::function<VoidResult(uint64_t session_id,

const std::vector<uint8_t>& data)>

kcenon::pacs::network::VoidResult

kcenon::pacs::VoidResult VoidResult

VoidResult type alias for operations without return value.

Definition association.h:59

Type for network send callback.

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/pipeline_adapter.h.

Definition at line 103 of file pipeline_adapter.h.

◆ service_handler

using kcenon::pacs::network::pipeline::pipeline_adapter::service_handler = storage_query_exec_job::service_handler

Service handler type.

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/pipeline_adapter.h.

Definition at line 219 of file pipeline_adapter.h.

◆ session_event_callback

using kcenon::pacs::network::pipeline::pipeline_adapter::session_event_callback

Initial value:

std::function<void(uint64_t session_id,

const std::string& event)>

Type for session event callback.

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/pipeline_adapter.h.

Definition at line 112 of file pipeline_adapter.h.

Constructor & Destructor Documentation

◆ pipeline_adapter() [1/4]

kcenon::pacs::network::pipeline::pipeline_adapter::pipeline_adapter ( )

Construct adapter with default configuration.

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/pipeline_adapter.h.

Definition at line 24 of file pipeline_adapter.cpp.

25 : pipeline_adapter(pipeline_config{}) {

26}

kcenon::pacs::network::pipeline::pipeline_adapter::pipeline_adapter

pipeline_adapter()

Construct adapter with default configuration.

Definition pipeline_adapter.cpp:24

◆ pipeline_adapter() [2/4]

kcenon::pacs::network::pipeline::pipeline_adapter::pipeline_adapter ( const pipeline_config & config )

explicit

Construct adapter with custom configuration.

Parameters

config Pipeline configuration

Definition at line 28 of file pipeline_adapter.cpp.

    : coordinator_(std::make_unique<pipeline_coordinator>(config)) {
 
    // Set up internal callbacks
    coordinator_->set_job_completion_callback(
        [this](const job_context& ctx, bool success) {
            on_job_completed(ctx, success);
        }
    );
 
    coordinator_->set_backpressure_callback(
        [this](pipeline_stage stage, size_t depth) {
            on_backpressure(stage, depth);
        }
    );
}

References coordinator_, on_backpressure(), on_job_completed(), and kcenon::pacs::network::pipeline::success.

Here is the call graph for this function:

◆ ~pipeline_adapter()

kcenon::pacs::network::pipeline::pipeline_adapter::~pipeline_adapter ( )

Destructor - ensures graceful shutdown.

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/pipeline_adapter.h.

Definition at line 45 of file pipeline_adapter.cpp.

                                    {
    if (is_running()) {
        static_cast<void>(stop());
    }
}

References is_running(), and stop().

Here is the call graph for this function:

◆ pipeline_adapter() [3/4]

kcenon::pacs::network::pipeline::pipeline_adapter::pipeline_adapter ( const pipeline_adapter & )

delete

◆ pipeline_adapter() [4/4]

kcenon::pacs::network::pipeline::pipeline_adapter::pipeline_adapter ( pipeline_adapter && )

delete

Member Function Documentation

◆ get_active_session_count()

auto kcenon::pacs::network::pipeline::pipeline_adapter::get_active_session_count ( ) const -> size_t

nodiscardnoexcept

Get number of active sessions.

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/pipeline_adapter.h.

Definition at line 120 of file pipeline_adapter.cpp.

                                                                         {
    std::lock_guard<std::mutex> lock(sessions_mutex_);
    return sessions_.size();
}

References sessions_, and sessions_mutex_.

◆ get_coordinator() [1/2]

auto kcenon::pacs::network::pipeline::pipeline_adapter::get_coordinator ( ) const -> const pipeline_coordinator&

nodiscardnoexcept

Get the underlying coordinator (const)

Definition at line 242 of file pipeline_adapter.cpp.

                                   {
    return *coordinator_;
}

References coordinator_.

◆ get_coordinator() [2/2]

auto kcenon::pacs::network::pipeline::pipeline_adapter::get_coordinator ( ) -> pipeline_coordinator&

nodiscardnoexcept

Get the underlying coordinator.

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/pipeline_adapter.h.

Definition at line 238 of file pipeline_adapter.cpp.

                                                                         {
    return *coordinator_;
}

References coordinator_.

◆ get_handler_for_command()

auto kcenon::pacs::network::pipeline::pipeline_adapter::get_handler_for_command ( dimse_command_type type ) -> service_handler

nodiscardprivate

Get service handler for command type.

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/pipeline_adapter.h.

Definition at line 251 of file pipeline_adapter.cpp.

                       {
    std::lock_guard<std::mutex> lock(handlers_mutex_);
 
    switch (type) {
        case dimse_command_type::c_store_rq:
            return c_store_handler_;
 
        case dimse_command_type::c_find_rq:
            return c_find_handler_;
 
        case dimse_command_type::c_get_rq:
            return c_get_handler_;
 
        case dimse_command_type::c_move_rq:
            return c_move_handler_;
 
        case dimse_command_type::c_echo_rq:
            return c_echo_handler_;
 
        default:
            return nullptr;
    }
}

References kcenon::pacs::network::pipeline::c_echo_rq, kcenon::pacs::network::pipeline::c_find_rq, kcenon::pacs::network::pipeline::c_get_rq, kcenon::pacs::network::pipeline::c_move_rq, and kcenon::pacs::network::pipeline::c_store_rq.

◆ get_metrics() [1/2]

auto kcenon::pacs::network::pipeline::pipeline_adapter::get_metrics ( ) const -> const pipeline_metrics&

nodiscardnoexcept

Get the pipeline metrics (const)

Definition at line 234 of file pipeline_adapter.cpp.

                                                                             {
    return coordinator_->get_metrics();
}

References coordinator_.

◆ get_metrics() [2/2]

auto kcenon::pacs::network::pipeline::pipeline_adapter::get_metrics ( ) -> pipeline_metrics&

nodiscardnoexcept

Get the pipeline metrics.

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/pipeline_adapter.h.

Definition at line 230 of file pipeline_adapter.cpp.

                                                                 {
    return coordinator_->get_metrics();
}

References coordinator_.

◆ get_session()

auto kcenon::pacs::network::pipeline::pipeline_adapter::get_session ( uint64_t session_id ) -> std::optional<session_context>

nodiscard

Get session context.

Parameters

session_id Session identifier

Returns: Session context if found

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/pipeline_adapter.h.

Definition at line 110 of file pipeline_adapter.cpp.

                                    {
    std::lock_guard<std::mutex> lock(sessions_mutex_);
    auto it = sessions_.find(session_id);
    if (it != sessions_.end()) {
        return it->second;
    }
    return std::nullopt;
}

◆ is_running()

auto kcenon::pacs::network::pipeline::pipeline_adapter::is_running ( ) const -> bool

nodiscardnoexcept

Check if the adapter is running.

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/pipeline_adapter.h.

Definition at line 63 of file pipeline_adapter.cpp.

                                                         {
    return coordinator_->is_running();
}

References coordinator_.

Referenced by ~pipeline_adapter().

Here is the caller graph for this function:

◆ on_backpressure()

void kcenon::pacs::network::pipeline::pipeline_adapter::on_backpressure	(	pipeline_stage	stage,
		size_t	queue_depth )

private

Handle backpressure.

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/pipeline_adapter.h.

Definition at line 295 of file pipeline_adapter.cpp.

                                                                               {
    // Log backpressure event
    // In a full implementation, this could trigger adaptive throttling
    session_event_callback callback;
    {
        std::lock_guard<std::mutex> lock(callbacks_mutex_);
        callback = session_event_callback_;
    }
 
    if (callback) {
        std::string event = "backpressure_" + std::string(get_stage_name(stage)) +
                           "_depth_" + std::to_string(queue_depth);
        callback(0, event);  // session_id 0 for system events
    }
}

References callbacks_mutex_, kcenon::pacs::network::pipeline::get_stage_name(), and session_event_callback_.

Referenced by pipeline_adapter().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ on_connection_closed()

void kcenon::pacs::network::pipeline::pipeline_adapter::on_connection_closed ( uint64_t session_id )

Handle connection closed event.

Parameters

session_id Session that was closed

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/pipeline_adapter.h.

Definition at line 173 of file pipeline_adapter.cpp.

                                                               {
    unregister_session(session_id);
}

References unregister_session().

Here is the call graph for this function:

◆ on_data_received()

auto kcenon::pacs::network::pipeline::pipeline_adapter::on_data_received	(	uint64_t	session_id,
		std::vector< uint8_t >	data ) -> VoidResult

nodiscard

Handle incoming data from network.

Submits received PDU data to the pipeline for processing.

Parameters

session_id	Session that received the data
data	Raw PDU bytes

Returns: VoidResult indicating success or error

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/pipeline_adapter.h.

Definition at line 129 of file pipeline_adapter.cpp.

                                                                               {
    if (!is_running()) {
        return pacs_void_error(error_codes::not_initialized,
                               "Pipeline adapter is not running");
    }
 
    // Update session activity
    {
        std::lock_guard<std::mutex> lock(sessions_mutex_);
        auto it = sessions_.find(session_id);
        if (it != sessions_.end()) {
            it->second.last_activity = std::chrono::steady_clock::now();
        }
    }
 
    // Get send callback for use in jobs
    send_callback send_fn;
    {
        std::lock_guard<std::mutex> lock(callbacks_mutex_);
        send_fn = send_callback_;
    }
 
    // Get association callback
    association_callback assoc_cb;
    {
        std::lock_guard<std::mutex> lock(callbacks_mutex_);
        assoc_cb = association_callback_;
    }
 
    // Create receive job
    auto job = std::make_unique<receive_network_io_job>(
        session_id,
        std::move(data),
        nullptr,  // on_data callback not needed
        nullptr   // on_error callback not needed
    );
 
    return coordinator_->submit_to_stage(
        pipeline_stage::network_receive,
        std::move(job)
    );
}

References kcenon::pacs::network::pipeline::network_receive, and kcenon::pacs::pacs_void_error().

Here is the call graph for this function:

◆ on_job_completed()

void kcenon::pacs::network::pipeline::pipeline_adapter::on_job_completed	(	const job_context &	ctx,
		bool	success )

private

Handle job completion.

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/pipeline_adapter.h.

Definition at line 276 of file pipeline_adapter.cpp.

                                                                            {
    // Record end-to-end metrics if this is the final stage
    if (ctx.stage == pipeline_stage::network_send) {
        auto now = std::chrono::steady_clock::now();
        auto enqueue_time = std::chrono::steady_clock::time_point(
            std::chrono::nanoseconds(ctx.enqueue_time_ns)
        );
        auto latency_ns = std::chrono::duration_cast<std::chrono::nanoseconds>(
            now - enqueue_time
        ).count();
 
        coordinator_->get_metrics().record_operation_completion(
            ctx.category,
            static_cast<uint64_t>(latency_ns),
            success
        );
    }
}

References kcenon::pacs::network::pipeline::job_context::category, coordinator_, kcenon::pacs::network::pipeline::job_context::enqueue_time_ns, kcenon::pacs::network::pipeline::network_send, kcenon::pacs::network::pipeline::job_context::stage, and kcenon::pacs::network::pipeline::success.

Referenced by pipeline_adapter().

Here is the caller graph for this function:

◆ operator=() [1/2]

pipeline_adapter & kcenon::pacs::network::pipeline::pipeline_adapter::operator= ( const pipeline_adapter & )

delete

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/pipeline_adapter.h.

◆ operator=() [2/2]

pipeline_adapter & kcenon::pacs::network::pipeline::pipeline_adapter::operator= ( pipeline_adapter && )

delete

◆ register_c_echo_handler()

void kcenon::pacs::network::pipeline::pipeline_adapter::register_c_echo_handler ( service_handler handler )

Register C-ECHO handler.

Parameters

handler Handler function

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/pipeline_adapter.h.

Definition at line 201 of file pipeline_adapter.cpp.

                                                                      {
    std::lock_guard<std::mutex> lock(handlers_mutex_);
    c_echo_handler_ = std::move(handler);
}

References c_echo_handler_, and handlers_mutex_.

◆ register_c_find_handler()

void kcenon::pacs::network::pipeline::pipeline_adapter::register_c_find_handler ( service_handler handler )

Register C-FIND handler.

Parameters

handler Handler function

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/pipeline_adapter.h.

Definition at line 186 of file pipeline_adapter.cpp.

                                                                      {
    std::lock_guard<std::mutex> lock(handlers_mutex_);
    c_find_handler_ = std::move(handler);
}

References c_find_handler_, and handlers_mutex_.

◆ register_c_get_handler()

void kcenon::pacs::network::pipeline::pipeline_adapter::register_c_get_handler ( service_handler handler )

Register C-GET handler.

Parameters

handler Handler function

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/pipeline_adapter.h.

Definition at line 191 of file pipeline_adapter.cpp.

                                                                     {
    std::lock_guard<std::mutex> lock(handlers_mutex_);
    c_get_handler_ = std::move(handler);
}

References c_get_handler_, and handlers_mutex_.

◆ register_c_move_handler()

void kcenon::pacs::network::pipeline::pipeline_adapter::register_c_move_handler ( service_handler handler )

Register C-MOVE handler.

Parameters

handler Handler function

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/pipeline_adapter.h.

Definition at line 196 of file pipeline_adapter.cpp.

                                                                      {
    std::lock_guard<std::mutex> lock(handlers_mutex_);
    c_move_handler_ = std::move(handler);
}

References c_move_handler_, and handlers_mutex_.

◆ register_c_store_handler()

void kcenon::pacs::network::pipeline::pipeline_adapter::register_c_store_handler ( service_handler handler )

Register C-STORE handler.

Parameters

handler Handler function

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/pipeline_adapter.h.

Definition at line 181 of file pipeline_adapter.cpp.

                                                                       {
    std::lock_guard<std::mutex> lock(handlers_mutex_);
    c_store_handler_ = std::move(handler);
}

References c_store_handler_, and handlers_mutex_.

◆ register_session()

void kcenon::pacs::network::pipeline::pipeline_adapter::register_session	(	uint64_t	session_id,
		session_context	context )

Register a new session.

Parameters

session_id	Unique session identifier
context	Session context information

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/pipeline_adapter.h.

Definition at line 71 of file pipeline_adapter.cpp.

                                                                 {
    std::lock_guard<std::mutex> lock(sessions_mutex_);
    context.session_id = session_id;
    context.created_at = std::chrono::steady_clock::now();
    context.last_activity = context.created_at;
    sessions_[session_id] = std::move(context);
 
    // Update metrics
    coordinator_->get_metrics().increment_active_associations();
 
    // Notify session event
    session_event_callback callback;
    {
        std::lock_guard<std::mutex> cb_lock(callbacks_mutex_);
        callback = session_event_callback_;
    }
    if (callback) {
        callback(session_id, "session_registered");
    }
}

References callbacks_mutex_, coordinator_, kcenon::pacs::network::pipeline::session_context::created_at, kcenon::pacs::network::pipeline::session_context::last_activity, session_event_callback_, kcenon::pacs::network::pipeline::session_context::session_id, sessions_, and sessions_mutex_.

◆ set_association_callback()

void kcenon::pacs::network::pipeline::pipeline_adapter::set_association_callback ( association_callback callback )

Set the association event callback.

Parameters

callback Function to handle association PDUs

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/pipeline_adapter.h.

Definition at line 215 of file pipeline_adapter.cpp.

                                                                             {
    std::lock_guard<std::mutex> lock(callbacks_mutex_);
    association_callback_ = std::move(callback);
}

References association_callback_, and callbacks_mutex_.

◆ set_send_callback()

void kcenon::pacs::network::pipeline::pipeline_adapter::set_send_callback ( send_callback callback )

Set the network send callback.

Parameters

callback Function to send data over network

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/pipeline_adapter.h.

Definition at line 210 of file pipeline_adapter.cpp.

                                                               {
    std::lock_guard<std::mutex> lock(callbacks_mutex_);
    send_callback_ = std::move(callback);
}

References callbacks_mutex_, and send_callback_.

◆ set_session_event_callback()

void kcenon::pacs::network::pipeline::pipeline_adapter::set_session_event_callback ( session_event_callback callback )

Set the session event callback.

Parameters

callback Function to handle session events

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/pipeline_adapter.h.

Definition at line 220 of file pipeline_adapter.cpp.

                                     {
    std::lock_guard<std::mutex> lock(callbacks_mutex_);
    session_event_callback_ = std::move(callback);
}

References callbacks_mutex_, and session_event_callback_.

◆ start()

auto kcenon::pacs::network::pipeline::pipeline_adapter::start ( ) -> VoidResult

nodiscard

Start the pipeline adapter.

Returns: VoidResult indicating success or error

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/pipeline_adapter.h.

Definition at line 55 of file pipeline_adapter.cpp.

                                           {
    return coordinator_->start();
}

◆ stop()

auto kcenon::pacs::network::pipeline::pipeline_adapter::stop ( ) -> VoidResult

nodiscard

Stop the pipeline adapter.

Returns: VoidResult indicating success or error

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/pipeline_adapter.h.

Definition at line 59 of file pipeline_adapter.cpp.

                                          {
    return coordinator_->stop();
}

Referenced by ~pipeline_adapter().

Here is the caller graph for this function:

◆ unregister_session()

void kcenon::pacs::network::pipeline::pipeline_adapter::unregister_session ( uint64_t session_id )

Unregister a session.

Parameters

session_id Session to unregister

Examples: /home/runner/work/pacs_system/pacs_system/include/kcenon/pacs/network/pipeline/pipeline_adapter.h.

Definition at line 93 of file pipeline_adapter.cpp.

                                                             {
    std::lock_guard<std::mutex> lock(sessions_mutex_);
    if (sessions_.erase(session_id) > 0) {
        coordinator_->get_metrics().decrement_active_associations();
 
        // Notify session event
        session_event_callback callback;
        {
            std::lock_guard<std::mutex> cb_lock(callbacks_mutex_);
            callback = session_event_callback_;
        }
        if (callback) {
            callback(session_id, "session_unregistered");
        }
    }
}