#include "nnstreamer-edge-aitt.h"
#include "nnstreamer-edge-mqtt.h"
-#ifndef PTHREAD_CREATE_JOINABLE
-#define PTHREAD_CREATE_JOINABLE 0
-#endif
-
#ifndef MSG_NOSIGNAL
#define MSG_NOSIGNAL 0
#endif
+/**
+ * @brief The maximum length of pending connections to accept socket.
+ */
#define N_BACKLOG 10
-#define DEFAULT_TIMEOUT_SEC 10
/**
* @brief Data structure for edge handle.
static bool
_fill_socket_addr (struct sockaddr_in *saddr, const char *host, const int port)
{
- /**
- * @todo handle protocol
- * 1. support edge connection type (TCP/UDP)
- * 2. ipv4 and ipv6
- */
+ /** @todo handle protocol (ipv4 and ipv6) */
saddr->sin_family = AF_INET;
saddr->sin_port = htons (port);
/**
* @brief Get message from mqtt broker with within timeout. (0 for inifinite timeout)
*/
-int
-nns_edge_mqtt_get_message (nns_edge_broker_h broker_h, void **msg, nns_size_t * msg_len, unsigned int timeout);
+int nns_edge_mqtt_get_message (nns_edge_broker_h broker_h, void **msg, nns_size_t *msg_len, unsigned int timeout);
/**
* @brief Internal util function to send edge-data via MQTT connection.
ret = nns_edge_data_destroy (dest_h);
EXPECT_EQ (ret, NNS_EDGE_ERROR_NONE);
- SAFE_FREE(serialized_data);
+ SAFE_FREE (serialized_data);
}
EXPECT_TRUE (nns_edge_queue_destroy (queue_h));
- SAFE_FREE(data);
+ SAFE_FREE (data);
}
/**