rte_ipc_pubsub.c

Go to the documentation of this file.

 
#include "rte/oal/ipc/rte_ipc_pubsub.h"
#include "rte/utils/lifecycle/rte_lifecycle.h"
#include "rte/log.h"
 
/* Implementation stubs - actual implementation would use base IPC layer */





 

rte_status_t rte_ipc_pubsub_topic_create(rte_ipc_pubsub_topic_t *topic_out,
                                            const rte_ipc_pubsub_topic_config_t *config)
{
    rte_status_t lifecycle_status;
 
    if (topic_out == NULL || config == NULL) {
        return RTE_STATUS_INVALID_PARAM;
    }
 
    if (config->message_size == 0 || config->max_subscribers == 0) {
        return RTE_STATUS_INVALID_PARAM;
    }
 
    /* REQ-LIFECYCLE-001 (ADR-026): a pub-sub topic is a setup-only resource -
     * refuse once the application's setup phase has been locked. */
    lifecycle_status = rte_lifecycle_check_setup_allowed();
    if (lifecycle_status != RTE_STATUS_OK)
    {
        return lifecycle_status;
    }
 
    RTE_LOG_INFO("Creating pub-sub topic: %s (msg_sz=%zu, max_sub=%zu)",
                  config->topic_name, config->message_size, config->max_subscribers);
 
    /* TODO: Implement topic creation */
    return RTE_STATUS_OK;
}
 
rte_status_t rte_ipc_pubsub_publish(rte_ipc_pubsub_topic_t topic,
                                       const void *message,
                                       size_t message_size)
{
    if (topic == NULL || message == NULL) {
        return RTE_STATUS_INVALID_PARAM;
    }
 
    RTE_LOG_DEBUG("Publishing message to topic (%zu bytes)", message_size);
 
    /* TODO: Deliver message to all subscribers */
    return RTE_STATUS_OK;
}
 
rte_status_t rte_ipc_pubsub_topic_destroy(rte_ipc_pubsub_topic_t topic)
{
    if (topic == NULL) {
        return RTE_STATUS_INVALID_PARAM;
    }
 
    RTE_LOG_INFO("Destroying pub-sub topic");
    return RTE_STATUS_OK;
}
 
rte_status_t rte_ipc_pubsub_subscribe(rte_ipc_pubsub_subscriber_t *subscriber_out,
                                         const rte_ipc_pubsub_subscriber_config_t *config)
{
    if (subscriber_out == NULL || config == NULL) {
        return RTE_STATUS_INVALID_PARAM;
    }
 
    if (config->topic == NULL || config->queue_depth == 0) {
        return RTE_STATUS_INVALID_PARAM;
    }
 
    RTE_LOG_INFO("Subscribing: %s to topic (queue_depth=%zu)",
                  config->subscriber_name, config->queue_depth);
 
    /* TODO: Register subscriber and create queue */
    return RTE_STATUS_OK;
}
 
rte_status_t rte_ipc_pubsub_receive(rte_ipc_pubsub_subscriber_t subscriber,
                                       void *message_out,
                                       size_t message_size,
                                       rte_duration_ms_t timeout_ms)
{
    if (subscriber == NULL || message_out == NULL) {
        return RTE_STATUS_INVALID_PARAM;
    }
 
    /* TODO: Receive from subscriber queue with timeout */
    return RTE_STATUS_TIMEOUT;
}
 
rte_status_t rte_ipc_pubsub_unsubscribe(rte_ipc_pubsub_subscriber_t subscriber)
{
    if (subscriber == NULL) {
        return RTE_STATUS_INVALID_PARAM;
    }
 
    RTE_LOG_INFO("Unsubscribing from topic");
    return RTE_STATUS_OK;
}