publish_request_queue_bs.h File Reference

#include "b2c.h"
#include "constants.h"
#include "message_out_bs.h"
#include "request_handle_bs.h"

Go to the source code of this file.

Functions
void	publish_request_queue_bs__INITIALISATION (void)
void	publish_request_queue_bs__allocate_new_publish_queue (t_bool *const publish_request_queue_bs__bres, constants__t_publishReqQueue_i *const publish_request_queue_bs__queue)
void	publish_request_queue_bs__append_publish_request_to_queue (const constants__t_publishReqQueue_i publish_request_queue_bs__p_queue, const constants__t_session_i publish_request_queue_bs__p_session, const constants__t_timeref_i publish_request_queue_bs__p_req_exp_time, const constants__t_server_request_handle_i publish_request_queue_bs__p_req_handle, const constants__t_request_context_i publish_request_queue_bs__p_req_ctx, const constants__t_msg_i publish_request_queue_bs__p_resp_msg, t_bool *const publish_request_queue_bs__bres)
void	publish_request_queue_bs__clear_and_deallocate_publish_queue (const constants__t_publishReqQueue_i publish_request_queue_bs__p_queue)
void	publish_request_queue_bs__clear_publish_queue (const constants__t_publishReqQueue_i publish_request_queue_bs__p_queue)
void	publish_request_queue_bs__continue_pop_head_iter_publish_request (const constants__t_publishReqQueue_i publish_request_queue_bs__p_queue, t_bool *const publish_request_queue_bs__p_continue, constants__t_session_i *const publish_request_queue_bs__p_session, constants__t_timeref_i *const publish_request_queue_bs__p_req_exp_time, constants__t_server_request_handle_i *const publish_request_queue_bs__p_req_handle, constants__t_request_context_i *const publish_request_queue_bs__p_req_ctx, constants__t_msg_i *const publish_request_queue_bs__p_resp_msg)
void	publish_request_queue_bs__discard_oldest_publish_request (const constants__t_publishReqQueue_i publish_request_queue_bs__p_queue, constants__t_session_i *const publish_request_queue_bs__old_session, constants__t_msg_i *const publish_request_queue_bs__old_resp_msg, constants__t_server_request_handle_i *const publish_request_queue_bs__old_req_handle, constants__t_request_context_i *const publish_request_queue_bs__old_req_ctx)
void	publish_request_queue_bs__get_nb_publish_requests (const constants__t_publishReqQueue_i publish_request_queue_bs__p_queue, t_entier4 *const publish_request_queue_bs__nb_pub_reqs)
void	publish_request_queue_bs__init_iter_publish_request (const constants__t_publishReqQueue_i publish_request_queue_bs__p_queue, t_bool *const publish_request_queue_bs__continue)
void	publish_request_queue_bs__is_request_expired (const constants__t_timeref_i publish_request_queue_bs__p_req_exp_time, t_bool *const publish_request_queue_bs__bres)
void	publish_request_queue_bs__pop_valid_publish_request_queue (const constants__t_publishReqQueue_i publish_request_queue_bs__p_queue, constants__t_session_i *const publish_request_queue_bs__p_session, constants__t_timeref_i *const publish_request_queue_bs__p_req_exp_time, constants__t_server_request_handle_i *const publish_request_queue_bs__p_req_handle, constants__t_request_context_i *const publish_request_queue_bs__p_req_ctx, constants__t_msg_i *const publish_request_queue_bs__p_resp_msg)
void	publish_request_queue_bs__prepend_publish_request_to_queue (const constants__t_publishReqQueue_i publish_request_queue_bs__p_queue, const constants__t_session_i publish_request_queue_bs__p_session, const constants__t_timeref_i publish_request_queue_bs__p_req_exp_time, const constants__t_server_request_handle_i publish_request_queue_bs__p_req_handle, const constants__t_request_context_i publish_request_queue_bs__p_req_ctx, const constants__t_msg_i publish_request_queue_bs__p_resp_msg, t_bool *const publish_request_queue_bs__bres)

Function Documentation

publish_request_queue_bs__INITIALISATION()

void publish_request_queue_bs__INITIALISATION ( void )

extern

publish_request_queue_bs__allocate_new_publish_queue()

void publish_request_queue_bs__allocate_new_publish_queue ( t_bool *const publish_request_queue_bs__bres, constants__t_publishReqQueue_i *const publish_request_queue_bs__queue )

extern

publish_request_queue_bs__append_publish_request_to_queue()

void publish_request_queue_bs__append_publish_request_to_queue ( const constants__t_publishReqQueue_i publish_request_queue_bs__p_queue, const constants__t_session_i publish_request_queue_bs__p_session, const constants__t_timeref_i publish_request_queue_bs__p_req_exp_time, const constants__t_server_request_handle_i publish_request_queue_bs__p_req_handle, const constants__t_request_context_i publish_request_queue_bs__p_req_ctx, const constants__t_msg_i publish_request_queue_bs__p_resp_msg, t_bool *const publish_request_queue_bs__bres )

extern

publish_request_queue_bs__clear_and_deallocate_publish_queue()

void publish_request_queue_bs__clear_and_deallocate_publish_queue ( const constants__t_publishReqQueue_i publish_request_queue_bs__p_queue )

extern

publish_request_queue_bs__clear_publish_queue()

void publish_request_queue_bs__clear_publish_queue ( const constants__t_publishReqQueue_i publish_request_queue_bs__p_queue )

extern

publish_request_queue_bs__continue_pop_head_iter_publish_request()

void publish_request_queue_bs__continue_pop_head_iter_publish_request ( const constants__t_publishReqQueue_i publish_request_queue_bs__p_queue, t_bool *const publish_request_queue_bs__p_continue, constants__t_session_i *const publish_request_queue_bs__p_session, constants__t_timeref_i *const publish_request_queue_bs__p_req_exp_time, constants__t_server_request_handle_i *const publish_request_queue_bs__p_req_handle, constants__t_request_context_i *const publish_request_queue_bs__p_req_ctx, constants__t_msg_i *const publish_request_queue_bs__p_resp_msg )

extern

publish_request_queue_bs__discard_oldest_publish_request()

void publish_request_queue_bs__discard_oldest_publish_request ( const constants__t_publishReqQueue_i publish_request_queue_bs__p_queue, constants__t_session_i *const publish_request_queue_bs__old_session, constants__t_msg_i *const publish_request_queue_bs__old_resp_msg, constants__t_server_request_handle_i *const publish_request_queue_bs__old_req_handle, constants__t_request_context_i *const publish_request_queue_bs__old_req_ctx )

extern

publish_request_queue_bs__get_nb_publish_requests()

void publish_request_queue_bs__get_nb_publish_requests ( const constants__t_publishReqQueue_i publish_request_queue_bs__p_queue, t_entier4 *const publish_request_queue_bs__nb_pub_reqs )

extern

publish_request_queue_bs__init_iter_publish_request()

void publish_request_queue_bs__init_iter_publish_request ( const constants__t_publishReqQueue_i publish_request_queue_bs__p_queue, t_bool *const publish_request_queue_bs__continue )

extern

publish_request_queue_bs__is_request_expired()

void publish_request_queue_bs__is_request_expired ( const constants__t_timeref_i publish_request_queue_bs__p_req_exp_time, t_bool *const publish_request_queue_bs__bres )

extern

publish_request_queue_bs__pop_valid_publish_request_queue()

void publish_request_queue_bs__pop_valid_publish_request_queue ( const constants__t_publishReqQueue_i publish_request_queue_bs__p_queue, constants__t_session_i *const publish_request_queue_bs__p_session, constants__t_timeref_i *const publish_request_queue_bs__p_req_exp_time, constants__t_server_request_handle_i *const publish_request_queue_bs__p_req_handle, constants__t_request_context_i *const publish_request_queue_bs__p_req_ctx, constants__t_msg_i *const publish_request_queue_bs__p_resp_msg )

extern

publish_request_queue_bs__prepend_publish_request_to_queue()

void publish_request_queue_bs__prepend_publish_request_to_queue ( const constants__t_publishReqQueue_i publish_request_queue_bs__p_queue, const constants__t_session_i publish_request_queue_bs__p_session, const constants__t_timeref_i publish_request_queue_bs__p_req_exp_time, const constants__t_server_request_handle_i publish_request_queue_bs__p_req_handle, const constants__t_request_context_i publish_request_queue_bs__p_req_ctx, const constants__t_msg_i publish_request_queue_bs__p_resp_msg, t_bool *const publish_request_queue_bs__bres )

extern