iotcs_port_queue.h

Go to the documentation of this file.

/*
 * Copyright (c) 2015, 2016, Oracle and/or its affiliates. All rights reserved.
 *
 * This software is dual-licensed to you under the MIT License (MIT) and
 * the Universal Permissive License (UPL). See the LICENSE file in the root
 * directory for license terms. You may choose either license, or both.
 */

#ifndef IOTCS_PORT_QUEUE_H
#define IOTCS_PORT_QUEUE_H

#ifdef __cplusplus
extern "C" {
#endif

#include <stdint.h>
#include "iotcs.h"
#include "advanced/iotcs_message.h"

    typedef void* iotcs_port_message_queue;

#ifndef IOTCS_PORT_MESSAGE_QUEUE_SIZE
#define IOTCS_PORT_MESSAGE_QUEUE_SIZE 25
#endif

#ifndef IOTCS_PORT_REQUEST_QUEUE_SIZE
#define IOTCS_PORT_REQUEST_QUEUE_SIZE 8
#endif

#ifdef IOTCS_STORAGE_SUPPORT

typedef struct iotcs_storage_request_t {
    struct iotcs_uri_object_t* storage; 
} iotcs_storage_request;
#ifndef IOTCS_PORT_MEDIA_STORAGE_REQUEST_QUEUE_SIZE
#define IOTCS_PORT_MEDIA_STORAGE_REQUEST_QUEUE_SIZE 8
#endif
#endif

    iotcs_port_message_queue iotcs_port_message_queue_create();

    void iotcs_port_message_queue_destroy(iotcs_port_message_queue queue);

    iotcs_result iotcs_port_message_queue_put(iotcs_port_message_queue queue, iotcs_message *message, int32_t timeout_ms);

    iotcs_result iotcs_port_message_queue_get(iotcs_port_message_queue queue, iotcs_message *message /* OUT */, int32_t timeout_ms);

    int iotcs_port_message_queue_count(iotcs_port_message_queue queue);

    typedef void* iotcs_port_request_queue;

    typedef void* iotcs_port_request_handler_queue;

    iotcs_port_request_queue iotcs_port_request_queue_create();

    void iotcs_port_request_queue_destroy(iotcs_port_request_queue queue);

    iotcs_result iotcs_port_request_queue_put(iotcs_port_request_queue queue, iotcs_request_message *request, int32_t timeout_ms);

    iotcs_result iotcs_port_request_queue_get(iotcs_port_request_queue queue, iotcs_request_message **request /* OUT */, int32_t timeout_ms);


    int iotcs_port_request_queue_count(iotcs_port_request_queue queue);

#if defined IOTCS_STORAGE_SUPPORT || defined IOTCS_DOXYGEN   

    typedef void* iotcs_port_storage_request_queue;

    iotcs_port_request_queue iotcs_port_storage_request_queue_create();

    void iotcs_port_storage_request_queue_destroy(iotcs_port_storage_request_queue queue);

    iotcs_result iotcs_port_storage_request_queue_put(iotcs_port_storage_request_queue queue, iotcs_storage_request *request, int32_t timeout_ms);

    iotcs_result iotcs_port_storage_request_queue_get(iotcs_port_storage_request_queue queue, iotcs_storage_request *request /* OUT */, int32_t timeout_ms);
#endif
    
#if  defined(IOTCS_MESSAGE_DISPATCHER) && (IOTCS_REQUEST_HANDLER_THREAD_POOL_SIZE > 1)

    typedef void (*iotcs_request_handler) (iotcs_request_message* message, iotcs_message* response_message);

    typedef struct iotcs_request_handler_message_t {
        iotcs_request_handler handler;
        iotcs_request_message* request_message;
    } iotcs_request_handler_message;

    iotcs_port_request_handler_queue iotcs_port_request_handler_queue_create();

    void iotcs_port_request_handler_queue_destroy(iotcs_port_request_handler_queue queue);

    iotcs_result iotcs_port_request_handler_queue_put(iotcs_port_request_handler_queue queue, iotcs_request_handler_message *request, int32_t timeout_ms);

    iotcs_result iotcs_port_request_handler_queue_get(iotcs_port_request_handler_queue queue, iotcs_request_handler_message *request /* OUT */, int32_t timeout_ms);

    int iotcs_port_request_handler_queue_count(iotcs_port_request_handler_queue queue);

#endif

#ifdef __cplusplus
}
#endif

#endif /* IOTCS_PORT_QUEUE_H */