Skip to content
This repository was archived by the owner on Jul 22, 2023. It is now read-only.
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 3 additions & 0 deletions src/libiotc/control_topic/iotc_control_topic_layer.c
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,9 @@
#ifdef __cplusplus
extern "C" {
#endif

iotc_state_t iotc_control_topic_connection_state_changed(void* context,
iotc_state_t state);

iotc_state_t iotc_control_topic_connection_state_changed(void* context,
iotc_state_t state) {
Expand Down
2 changes: 1 addition & 1 deletion src/libiotc/datastructures/iotc_vector.c
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,7 @@ static int8_t iotc_vector_realloc(iotc_vector_t* vector,
return 0;
}

iotc_vector_t* iotc_vector_create() {
iotc_vector_t* iotc_vector_create(void) {
iotc_state_t state = IOTC_STATE_OK;

IOTC_ALLOC(iotc_vector_t, ret, state);
Expand Down
2 changes: 1 addition & 1 deletion src/libiotc/datastructures/iotc_vector.h
Original file line number Diff line number Diff line change
Expand Up @@ -72,7 +72,7 @@ typedef int8_t(iotc_vector_cmp_t)(const union iotc_vector_selector_u* e0,

typedef int8_t(iotc_vector_pred_t)(union iotc_vector_selector_u* e0);

extern iotc_vector_t* iotc_vector_create();
extern iotc_vector_t* iotc_vector_create(void);

/**
* @brief iotc_vector_create_from
Expand Down
4 changes: 4 additions & 0 deletions src/libiotc/event_dispatcher/iotc_event_dispatcher.c
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,10 @@
#include "iotc_helpers.h"
#include "iotc_list.h"

iotc_state_t iotc_evtd_update_event_on_fd(iotc_evtd_instance_t* instance,
iotc_vector_t* container,
iotc_fd_t fd);

static inline int8_t iotc_evtd_cmp_fd(
const union iotc_vector_selector_u* e0,
const union iotc_vector_selector_u* value) {
Expand Down
10 changes: 10 additions & 0 deletions src/libiotc/event_loop/iotc_event_loop.c
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,16 @@
#include "iotc_bsp_time.h"
#include "iotc_event_dispatcher_api.h"

iotc_state_t iotc_bsp_event_loop_transform_to_bsp_select(
iotc_evtd_instance_t** in_event_dispatchers, uint8_t in_num_evtds,
iotc_bsp_socket_events_t* in_socket_events_array,
size_t in_socket_events_array_length, iotc_time_t* out_timeout);

iotc_state_t iotc_bsp_event_loop_update_event_dispatcher(
iotc_evtd_instance_t** in_event_dispatchers, uint8_t in_num_evtds,
iotc_bsp_socket_events_t* in_socket_events_array,
size_t in_socket_events_array_length);

/**
* @brief iotc_bsp_event_loop_count_all_sockets
* @param event_dispatchers
Expand Down
3 changes: 3 additions & 0 deletions src/libiotc/mqtt/logic/iotc_mqtt_logic_layer.c
Original file line number Diff line number Diff line change
Expand Up @@ -40,6 +40,9 @@ extern "C" {
static void iotc_mqtt_logic_task_queue_shutdown(
iotc_mqtt_logic_task_t** task_queue);

uint8_t iotc_mqtt_logic_layer_task_should_be_stored_predicate(
void* context, iotc_mqtt_logic_task_t* task, int i);

static void iotc_mqtt_logic_task_queue_shutdown_wrap(void** task_queue) {
assert(NULL != task_queue);
assert(NULL != *task_queue);
Expand Down