d0kuhn/mosquitto
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
b6a54a21d8
mosquitto/test/unit/persist_read_test.c

821 lines
25 KiB
C
Raw Normal View History

Start of tests for persistence reading.
2019-03-14 20:57:25 +00:00
/* Tests for persistence.
*
* FIXME - these need to be aggressive about finding failures, at the moment
* they are just confirming that good behaviour works. */
#include <CUnit/CUnit.h>
#include <CUnit/Basic.h>
#define WITH_BROKER
#define WITH_PERSISTENCE
#include "mosquitto_broker_internal.h"
#include "persist.h"
Tests for persisting message store properties.
2019-03-24 21:38:00 +00:00
#include "property_mosq.h"
Start of tests for persistence reading.
2019-03-14 20:57:25 +00:00
uint64_t last_retained;
char *last_sub = NULL;
int last_qos;
Add subscription-identifier and options to persistence.
2019-03-21 11:53:46 +00:00
uint32_t last_identifier;
Start of tests for persistence reading.
2019-03-14 20:57:25 +00:00
static void TEST_persistence_disabled(void)
{
struct mosquitto_db db;
struct mosquitto__config config;
int rc;
memset(&db, 0, sizeof(struct mosquitto_db));
memset(&config, 0, sizeof(struct mosquitto__config));
db.config = &config;
rc = persist__restore(&db);
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
}
static void TEST_empty_file(void)
{
struct mosquitto_db db;
struct mosquitto__config config;
int rc;
memset(&db, 0, sizeof(struct mosquitto_db));
memset(&config, 0, sizeof(struct mosquitto__config));
db.config = &config;
config.persistence = true;
config.persistence_filepath = "files/persist_read/empty.test-db";
rc = persist__restore(&db);
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
}
static void TEST_corrupt_header(void)
{
struct mosquitto_db db;
struct mosquitto__config config;
int rc;
memset(&db, 0, sizeof(struct mosquitto_db));
memset(&config, 0, sizeof(struct mosquitto__config));
db.config = &config;
config.persistence = true;
config.persistence_filepath = "files/persist_read/corrupt-header-short.test-db";
rc = persist__restore(&db);
CU_ASSERT_EQUAL(rc, 1);
config.persistence_filepath = "files/persist_read/corrupt-header-long.test-db";
rc = persist__restore(&db);
CU_ASSERT_EQUAL(rc, 1);
}
static void TEST_unsupported_version(void)
{
struct mosquitto_db db;
struct mosquitto__config config;
int rc;
memset(&db, 0, sizeof(struct mosquitto_db));
memset(&config, 0, sizeof(struct mosquitto__config));
db.config = &config;
config.persistence = true;
config.persistence_filepath = "files/persist_read/unsupported-version.test-db";
rc = persist__restore(&db);
CU_ASSERT_EQUAL(rc, 1);
}
static void TEST_v3_config_ok(void)
{
struct mosquitto_db db;
struct mosquitto__config config;
int rc;
memset(&db, 0, sizeof(struct mosquitto_db));
memset(&config, 0, sizeof(struct mosquitto__config));
db.config = &config;
config.persistence = true;
config.persistence_filepath = "files/persist_read/v3-cfg.test-db";
rc = persist__restore(&db);
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
CU_ASSERT_EQUAL(db.last_db_id, 0x7856341200000000);
}
Start of persistence writing tests.
2019-03-19 14:25:40 +00:00
static void TEST_v4_config_ok(void)
{
struct mosquitto_db db;
struct mosquitto__config config;
int rc;
memset(&db, 0, sizeof(struct mosquitto_db));
memset(&config, 0, sizeof(struct mosquitto__config));
db.config = &config;
config.persistence = true;
config.persistence_filepath = "files/persist_read/v4-cfg.test-db";
rc = persist__restore(&db);
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
CU_ASSERT_EQUAL(db.last_db_id, 0x7856341200000000);
}
Start of tests for persistence reading.
2019-03-14 20:57:25 +00:00
static void TEST_v3_config_truncated(void)
{
struct mosquitto_db db;
struct mosquitto__config config;
int rc;
memset(&db, 0, sizeof(struct mosquitto_db));
memset(&config, 0, sizeof(struct mosquitto__config));
db.config = &config;
config.persistence = true;
config.persistence_filepath = "files/persist_read/v3-cfg-truncated.test-db";
rc = persist__restore(&db);
CU_ASSERT_EQUAL(rc, 1);
CU_ASSERT_EQUAL(db.last_db_id, 0);
}
static void TEST_v3_config_bad_dbid(void)
{
struct mosquitto_db db;
struct mosquitto__config config;
int rc;
memset(&db, 0, sizeof(struct mosquitto_db));
memset(&config, 0, sizeof(struct mosquitto__config));
db.config = &config;
config.persistence = true;
config.persistence_filepath = "files/persist_read/v3-cfg-bad-dbid.test-db";
rc = persist__restore(&db);
CU_ASSERT_EQUAL(rc, 1);
CU_ASSERT_EQUAL(db.last_db_id, 0);
}
static void TEST_v3_bad_chunk(void)
{
struct mosquitto_db db;
struct mosquitto__config config;
int rc;
memset(&db, 0, sizeof(struct mosquitto_db));
memset(&config, 0, sizeof(struct mosquitto__config));
db.config = &config;
config.persistence = true;
config.persistence_filepath = "files/persist_read/v3-bad-chunk.test-db";
rc = persist__restore(&db);
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
CU_ASSERT_EQUAL(db.last_db_id, 0x17);
}
static void TEST_v3_message_store(void)
{
struct mosquitto_db db;
struct mosquitto__config config;
int rc;
memset(&db, 0, sizeof(struct mosquitto_db));
memset(&config, 0, sizeof(struct mosquitto__config));
db.config = &config;
config.persistence = true;
config.persistence_filepath = "files/persist_read/v3-message-store.test-db";
rc = persist__restore(&db);
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
CU_ASSERT_EQUAL(db.msg_store_count, 1);
CU_ASSERT_EQUAL(db.msg_store_bytes, 7);
CU_ASSERT_PTR_NOT_NULL(db.msg_store);
if(db.msg_store){
CU_ASSERT_EQUAL(db.msg_store->db_id, 1);
CU_ASSERT_STRING_EQUAL(db.msg_store->source_id, "source_id");
CU_ASSERT_EQUAL(db.msg_store->source_mid, 2);
CU_ASSERT_EQUAL(db.msg_store->mid, 0);
CU_ASSERT_EQUAL(db.msg_store->qos, 2);
CU_ASSERT_EQUAL(db.msg_store->retain, 1);
Fix Coverity Scan defect 140436. Null dereference.
2019-03-26 12:05:23 +00:00
CU_ASSERT_PTR_NOT_NULL(db.msg_store->topic);
if(db.msg_store->topic){
CU_ASSERT_STRING_EQUAL(db.msg_store->topic, "topic");
}
Start of tests for persistence reading.
2019-03-14 20:57:25 +00:00
CU_ASSERT_EQUAL(db.msg_store->payloadlen, 7);
if(db.msg_store->payloadlen == 7){
CU_ASSERT_NSTRING_EQUAL(UHPA_ACCESS_PAYLOAD(db.msg_store), "payload", 7);
}
}
}
static void TEST_v3_client(void)
{
struct mosquitto_db db;
struct mosquitto__config config;
struct mosquitto *context;
int rc;
memset(&db, 0, sizeof(struct mosquitto_db));
memset(&config, 0, sizeof(struct mosquitto__config));
db.config = &config;
config.persistence = true;
config.persistence_filepath = "files/persist_read/v3-client.test-db";
rc = persist__restore(&db);
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
CU_ASSERT_PTR_NOT_NULL(db.contexts_by_id);
HASH_FIND(hh_id, db.contexts_by_id, "client-id", strlen("client-id"), context);
CU_ASSERT_PTR_NOT_NULL(context);
if(context){
Separate broker message queues into in/out. This allows and includes better flow control handling for QoS>0.
2019-04-13 21:59:29 +00:00
CU_ASSERT_PTR_NULL(context->msgs_in.inflight);
CU_ASSERT_PTR_NULL(context->msgs_out.inflight);
Start of tests for persistence reading.
2019-03-14 20:57:25 +00:00
CU_ASSERT_EQUAL(context->last_mid, 0x5287);
}
}
static void TEST_v3_client_message(void)
{
struct mosquitto_db db;
struct mosquitto__config config;
struct mosquitto *context;
int rc;
memset(&db, 0, sizeof(struct mosquitto_db));
memset(&config, 0, sizeof(struct mosquitto__config));
db.config = &config;
config.persistence = true;
config.persistence_filepath = "files/persist_read/v3-client-message.test-db";
Separate broker message queues into in/out. This allows and includes better flow control handling for QoS>0.
2019-04-13 21:59:29 +00:00
config.max_inflight_messages = 20;
Start of tests for persistence reading.
2019-03-14 20:57:25 +00:00
rc = persist__restore(&db);
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
CU_ASSERT_PTR_NOT_NULL(db.contexts_by_id);
HASH_FIND(hh_id, db.contexts_by_id, "client-id", strlen("client-id"), context);
CU_ASSERT_PTR_NOT_NULL(context);
if(context){
Separate broker message queues into in/out. This allows and includes better flow control handling for QoS>0.
2019-04-13 21:59:29 +00:00
CU_ASSERT_PTR_NOT_NULL(context->msgs_out.inflight);
if(context->msgs_out.inflight){
CU_ASSERT_PTR_NULL(context->msgs_out.inflight->next);
CU_ASSERT_PTR_NOT_NULL(context->msgs_out.inflight->store);
if(context->msgs_out.inflight->store){
CU_ASSERT_EQUAL(context->msgs_out.inflight->store->ref_count, 1);
CU_ASSERT_STRING_EQUAL(context->msgs_out.inflight->store->source_id, "source_id");
CU_ASSERT_EQUAL(context->msgs_out.inflight->store->source_mid, 2);
CU_ASSERT_EQUAL(context->msgs_out.inflight->store->mid, 0);
CU_ASSERT_EQUAL(context->msgs_out.inflight->store->qos, 2);
CU_ASSERT_EQUAL(context->msgs_out.inflight->store->retain, 1);
CU_ASSERT_PTR_NOT_NULL(context->msgs_out.inflight->store->topic);
if(context->msgs_out.inflight->store->topic){
CU_ASSERT_STRING_EQUAL(context->msgs_out.inflight->store->topic, "topic");
Fix Coverity Scan defect 140436. Null dereference.
2019-03-26 12:05:23 +00:00
}
Separate broker message queues into in/out. This allows and includes better flow control handling for QoS>0.
2019-04-13 21:59:29 +00:00
CU_ASSERT_EQUAL(context->msgs_out.inflight->store->payloadlen, 7);
if(context->msgs_out.inflight->store->payloadlen == 7){
CU_ASSERT_NSTRING_EQUAL(UHPA_ACCESS_PAYLOAD(context->msgs_out.inflight->store), "payload", 7);
Start of tests for persistence reading.
2019-03-14 20:57:25 +00:00
}
}
Separate broker message queues into in/out. This allows and includes better flow control handling for QoS>0.
2019-04-13 21:59:29 +00:00
CU_ASSERT_EQUAL(context->msgs_out.inflight->mid, 0x73);
CU_ASSERT_EQUAL(context->msgs_out.inflight->qos, 1);
CU_ASSERT_EQUAL(context->msgs_out.inflight->retain, 0);
CU_ASSERT_EQUAL(context->msgs_out.inflight->direction, mosq_md_out);
CU_ASSERT_EQUAL(context->msgs_out.inflight->state, mosq_ms_wait_for_puback);
CU_ASSERT_EQUAL(context->msgs_out.inflight->dup, 0);
CU_ASSERT_PTR_NULL(context->msgs_out.inflight->properties);
Start of tests for persistence reading.
2019-03-14 20:57:25 +00:00
}
}
}
static void TEST_v3_retain(void)
{
struct mosquitto_db db;
struct mosquitto__config config;
int rc;
last_retained = 0;
memset(&db, 0, sizeof(struct mosquitto_db));
memset(&config, 0, sizeof(struct mosquitto__config));
db.config = &config;
config.persistence = true;
config.persistence_filepath = "files/persist_read/v3-retain.test-db";
rc = persist__restore(&db);
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
CU_ASSERT_EQUAL(db.msg_store_count, 1);
CU_ASSERT_EQUAL(db.msg_store_bytes, 7);
CU_ASSERT_PTR_NOT_NULL(db.msg_store);
if(db.msg_store){
CU_ASSERT_EQUAL(db.msg_store->db_id, 0x54);
CU_ASSERT_STRING_EQUAL(db.msg_store->source_id, "source_id");
CU_ASSERT_EQUAL(db.msg_store->source_mid, 2);
CU_ASSERT_EQUAL(db.msg_store->mid, 0);
CU_ASSERT_EQUAL(db.msg_store->qos, 2);
CU_ASSERT_EQUAL(db.msg_store->retain, 1);
Fix Coverity Scan defect 140436. Null dereference.
2019-03-26 12:05:23 +00:00
CU_ASSERT_PTR_NOT_NULL(db.msg_store->topic);
if(db.msg_store->topic){
CU_ASSERT_STRING_EQUAL(db.msg_store->topic, "topic");
}
Start of tests for persistence reading.
2019-03-14 20:57:25 +00:00
CU_ASSERT_EQUAL(db.msg_store->payloadlen, 7);
if(db.msg_store->payloadlen == 7){
CU_ASSERT_NSTRING_EQUAL(UHPA_ACCESS_PAYLOAD(db.msg_store), "payload", 7);
}
}
CU_ASSERT_EQUAL(last_retained, 0x54);
}
static void TEST_v3_sub(void)
{
struct mosquitto_db db;
struct mosquitto__config config;
struct mosquitto *context;
int rc;
last_sub = NULL;
last_qos = -1;
memset(&db, 0, sizeof(struct mosquitto_db));
memset(&config, 0, sizeof(struct mosquitto__config));
db.config = &config;
config.persistence = true;
config.persistence_filepath = "files/persist_read/v3-sub.test-db";
rc = persist__restore(&db);
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
CU_ASSERT_PTR_NOT_NULL(db.contexts_by_id);
HASH_FIND(hh_id, db.contexts_by_id, "client-id", strlen("client-id"), context);
CU_ASSERT_PTR_NOT_NULL(context);
if(context){
CU_ASSERT_PTR_NOT_NULL(last_sub);
if(last_sub){
CU_ASSERT_STRING_EQUAL(last_sub, "subscription")
free(last_sub);
}
CU_ASSERT_EQUAL(last_qos, 1);
}
}
static void TEST_v4_message_store(void)
{
struct mosquitto_db db;
struct mosquitto__config config;
int rc;
memset(&db, 0, sizeof(struct mosquitto_db));
memset(&config, 0, sizeof(struct mosquitto__config));
db.config = &config;
config.persistence = true;
config.persistence_filepath = "files/persist_read/v4-message-store.test-db";
rc = persist__restore(&db);
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
CU_ASSERT_EQUAL(db.msg_store_count, 1);
CU_ASSERT_EQUAL(db.msg_store_bytes, 7);
CU_ASSERT_PTR_NOT_NULL(db.msg_store);
if(db.msg_store){
CU_ASSERT_EQUAL(db.msg_store->db_id, 0xFEDCBA9876543210);
CU_ASSERT_STRING_EQUAL(db.msg_store->source_id, "source_id");
CU_ASSERT_EQUAL(db.msg_store->source_mid, 0x88);
CU_ASSERT_EQUAL(db.msg_store->mid, 0);
CU_ASSERT_EQUAL(db.msg_store->qos, 1);
CU_ASSERT_EQUAL(db.msg_store->retain, 0);
Fix Coverity Scan defect 140436. Null dereference.
2019-03-26 12:05:23 +00:00
CU_ASSERT_PTR_NOT_NULL(db.msg_store->topic);
if(db.msg_store->topic){
CU_ASSERT_STRING_EQUAL(db.msg_store->topic, "topic");
}
Start of tests for persistence reading.
2019-03-14 20:57:25 +00:00
CU_ASSERT_EQUAL(db.msg_store->payloadlen, 7);
if(db.msg_store->payloadlen == 7){
CU_ASSERT_NSTRING_EQUAL(UHPA_ACCESS_PAYLOAD(db.msg_store), "payload", 7);
}
}
}
v5 persistence file format This includes changes to improve read/write performance. It is not complete, and will have further changes to add properties and anything else required for MQTT v5.
2019-03-20 00:02:38 +00:00
static void TEST_v5_config_ok(void)
{
struct mosquitto_db db;
struct mosquitto__config config;
int rc;
memset(&db, 0, sizeof(struct mosquitto_db));
memset(&config, 0, sizeof(struct mosquitto__config));
db.config = &config;
config.persistence = true;
config.persistence_filepath = "files/persist_read/v5-cfg.test-db";
rc = persist__restore(&db);
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
CU_ASSERT_EQUAL(db.last_db_id, 0x7856341200000000);
}
static void TEST_v5_config_truncated(void)
{
struct mosquitto_db db;
struct mosquitto__config config;
int rc;
memset(&db, 0, sizeof(struct mosquitto_db));
memset(&config, 0, sizeof(struct mosquitto__config));
db.config = &config;
config.persistence = true;
config.persistence_filepath = "files/persist_read/v5-cfg-truncated.test-db";
rc = persist__restore(&db);
CU_ASSERT_EQUAL(rc, 1);
CU_ASSERT_EQUAL(db.last_db_id, 0);
}
static void TEST_v5_bad_chunk(void)
{
struct mosquitto_db db;
struct mosquitto__config config;
int rc;
memset(&db, 0, sizeof(struct mosquitto_db));
memset(&config, 0, sizeof(struct mosquitto__config));
db.config = &config;
config.persistence = true;
config.persistence_filepath = "files/persist_read/v5-bad-chunk.test-db";
rc = persist__restore(&db);
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
CU_ASSERT_EQUAL(db.last_db_id, 0x17);
}
static void TEST_v5_message_store(void)
{
struct mosquitto_db db;
struct mosquitto__config config;
int rc;
memset(&db, 0, sizeof(struct mosquitto_db));
memset(&config, 0, sizeof(struct mosquitto__config));
db.config = &config;
config.persistence = true;
config.persistence_filepath = "files/persist_read/v5-message-store.test-db";
rc = persist__restore(&db);
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
CU_ASSERT_EQUAL(db.msg_store_count, 1);
CU_ASSERT_EQUAL(db.msg_store_bytes, 7);
CU_ASSERT_PTR_NOT_NULL(db.msg_store);
if(db.msg_store){
CU_ASSERT_EQUAL(db.msg_store->db_id, 1);
CU_ASSERT_STRING_EQUAL(db.msg_store->source_id, "source_id");
CU_ASSERT_EQUAL(db.msg_store->source_mid, 2);
CU_ASSERT_EQUAL(db.msg_store->mid, 0);
CU_ASSERT_EQUAL(db.msg_store->qos, 2);
CU_ASSERT_EQUAL(db.msg_store->retain, 1);
CU_ASSERT_STRING_EQUAL(db.msg_store->topic, "topic");
CU_ASSERT_EQUAL(db.msg_store->payloadlen, 7);
if(db.msg_store->payloadlen == 7){
CU_ASSERT_NSTRING_EQUAL(UHPA_ACCESS_PAYLOAD(db.msg_store), "payload", 7);
}
Tests for persisting message store properties.
2019-03-24 21:38:00 +00:00
CU_ASSERT_PTR_NULL(db.msg_store->properties);
}
}
static void TEST_v5_message_store_props(void)
{
struct mosquitto_db db;
struct mosquitto__config config;
struct mosquitto__listener listener;
int rc;
memset(&db, 0, sizeof(struct mosquitto_db));
memset(&config, 0, sizeof(struct mosquitto__config));
memset(&listener, 0, sizeof(struct mosquitto__listener));
db.config = &config;
listener.port = 1883;
config.listeners = &listener;
config.listener_count = 1;
config.persistence = true;
config.persistence_filepath = "files/persist_read/v5-message-store-props.test-db";
rc = persist__restore(&db);
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
CU_ASSERT_EQUAL(db.msg_store_count, 1);
CU_ASSERT_EQUAL(db.msg_store_bytes, 7);
CU_ASSERT_PTR_NOT_NULL(db.msg_store);
if(db.msg_store){
CU_ASSERT_EQUAL(db.msg_store->db_id, 1);
CU_ASSERT_STRING_EQUAL(db.msg_store->source_id, "source_id");
CU_ASSERT_EQUAL(db.msg_store->source_mid, 2);
CU_ASSERT_EQUAL(db.msg_store->mid, 0);
CU_ASSERT_EQUAL(db.msg_store->qos, 2);
CU_ASSERT_EQUAL(db.msg_store->retain, 1);
CU_ASSERT_STRING_EQUAL(db.msg_store->topic, "topic");
CU_ASSERT_EQUAL(db.msg_store->payloadlen, 7);
if(db.msg_store->payloadlen == 7){
CU_ASSERT_NSTRING_EQUAL(UHPA_ACCESS_PAYLOAD(db.msg_store), "payload", 7);
}
CU_ASSERT_PTR_NOT_NULL(db.msg_store->properties);
if(db.msg_store->properties){
CU_ASSERT_EQUAL(db.msg_store->properties->identifier, 1);
CU_ASSERT_EQUAL(db.msg_store->properties->value.i8, 1);
}
CU_ASSERT_PTR_NOT_NULL(db.msg_store->source_listener);
v5 persistence file format This includes changes to improve read/write performance. It is not complete, and will have further changes to add properties and anything else required for MQTT v5.
2019-03-20 00:02:38 +00:00
}
}
static void TEST_v5_client(void)
{
struct mosquitto_db db;
struct mosquitto__config config;
struct mosquitto *context;
int rc;
memset(&db, 0, sizeof(struct mosquitto_db));
memset(&config, 0, sizeof(struct mosquitto__config));
db.config = &config;
config.persistence = true;
config.persistence_filepath = "files/persist_read/v5-client.test-db";
rc = persist__restore(&db);
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
CU_ASSERT_PTR_NOT_NULL(db.contexts_by_id);
HASH_FIND(hh_id, db.contexts_by_id, "client-id", strlen("client-id"), context);
CU_ASSERT_PTR_NOT_NULL(context);
if(context){
Separate broker message queues into in/out. This allows and includes better flow control handling for QoS>0.
2019-04-13 21:59:29 +00:00
CU_ASSERT_PTR_NULL(context->msgs_in.inflight);
CU_ASSERT_PTR_NULL(context->msgs_out.inflight);
v5 persistence file format This includes changes to improve read/write performance. It is not complete, and will have further changes to add properties and anything else required for MQTT v5.
2019-03-20 00:02:38 +00:00
CU_ASSERT_EQUAL(context->last_mid, 0x5287);
}
}
static void TEST_v5_client_message(void)
{
struct mosquitto_db db;
struct mosquitto__config config;
struct mosquitto *context;
int rc;
memset(&db, 0, sizeof(struct mosquitto_db));
memset(&config, 0, sizeof(struct mosquitto__config));
db.config = &config;
config.persistence = true;
config.persistence_filepath = "files/persist_read/v5-client-message.test-db";
rc = persist__restore(&db);
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
CU_ASSERT_PTR_NOT_NULL(db.contexts_by_id);
HASH_FIND(hh_id, db.contexts_by_id, "client-id", strlen("client-id"), context);
CU_ASSERT_PTR_NOT_NULL(context);
if(context){
Separate broker message queues into in/out. This allows and includes better flow control handling for QoS>0.
2019-04-13 21:59:29 +00:00
CU_ASSERT_PTR_NOT_NULL(context->msgs_out.inflight);
if(context->msgs_out.inflight){
CU_ASSERT_PTR_NULL(context->msgs_out.inflight->next);
CU_ASSERT_PTR_NOT_NULL(context->msgs_out.inflight->store);
if(context->msgs_out.inflight->store){
CU_ASSERT_EQUAL(context->msgs_out.inflight->store->ref_count, 1);
CU_ASSERT_STRING_EQUAL(context->msgs_out.inflight->store->source_id, "source_id");
CU_ASSERT_EQUAL(context->msgs_out.inflight->store->source_mid, 2);
CU_ASSERT_EQUAL(context->msgs_out.inflight->store->mid, 0);
CU_ASSERT_EQUAL(context->msgs_out.inflight->store->qos, 2);
CU_ASSERT_EQUAL(context->msgs_out.inflight->store->retain, 1);
CU_ASSERT_STRING_EQUAL(context->msgs_out.inflight->store->topic, "topic");
CU_ASSERT_EQUAL(context->msgs_out.inflight->store->payloadlen, 7);
if(context->msgs_out.inflight->store->payloadlen == 7){
CU_ASSERT_NSTRING_EQUAL(UHPA_ACCESS_PAYLOAD(context->msgs_out.inflight->store), "payload", 7);
v5 persistence file format This includes changes to improve read/write performance. It is not complete, and will have further changes to add properties and anything else required for MQTT v5.
2019-03-20 00:02:38 +00:00
}
}
Separate broker message queues into in/out. This allows and includes better flow control handling for QoS>0.
2019-04-13 21:59:29 +00:00
CU_ASSERT_EQUAL(context->msgs_out.inflight->mid, 0x73);
CU_ASSERT_EQUAL(context->msgs_out.inflight->qos, 1);
CU_ASSERT_EQUAL(context->msgs_out.inflight->retain, 0);
CU_ASSERT_EQUAL(context->msgs_out.inflight->direction, mosq_md_out);
CU_ASSERT_EQUAL(context->msgs_out.inflight->state, mosq_ms_wait_for_puback);
CU_ASSERT_EQUAL(context->msgs_out.inflight->dup, 0);
CU_ASSERT_PTR_NULL(context->msgs_out.inflight->properties);
Code and tests for persisting client msg properties.
2019-03-23 22:52:08 +00:00
}
}
}
static void TEST_v5_client_message_props(void)
{
struct mosquitto_db db;
struct mosquitto__config config;
struct mosquitto *context;
int rc;
memset(&db, 0, sizeof(struct mosquitto_db));
memset(&config, 0, sizeof(struct mosquitto__config));
db.config = &config;
config.persistence = true;
config.persistence_filepath = "files/persist_read/v5-client-message-props.test-db";
rc = persist__restore(&db);
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
CU_ASSERT_PTR_NOT_NULL(db.contexts_by_id);
HASH_FIND(hh_id, db.contexts_by_id, "client-id", strlen("client-id"), context);
CU_ASSERT_PTR_NOT_NULL(context);
if(context){
Separate broker message queues into in/out. This allows and includes better flow control handling for QoS>0.
2019-04-13 21:59:29 +00:00
CU_ASSERT_PTR_NOT_NULL(context->msgs_out.inflight);
if(context->msgs_out.inflight){
CU_ASSERT_PTR_NULL(context->msgs_out.inflight->next);
CU_ASSERT_PTR_NOT_NULL(context->msgs_out.inflight->store);
if(context->msgs_out.inflight->store){
CU_ASSERT_EQUAL(context->msgs_out.inflight->store->ref_count, 1);
CU_ASSERT_STRING_EQUAL(context->msgs_out.inflight->store->source_id, "source_id");
CU_ASSERT_EQUAL(context->msgs_out.inflight->store->source_mid, 2);
CU_ASSERT_EQUAL(context->msgs_out.inflight->store->mid, 0);
CU_ASSERT_EQUAL(context->msgs_out.inflight->store->qos, 2);
CU_ASSERT_EQUAL(context->msgs_out.inflight->store->retain, 1);
CU_ASSERT_STRING_EQUAL(context->msgs_out.inflight->store->topic, "topic");
CU_ASSERT_EQUAL(context->msgs_out.inflight->store->payloadlen, 7);
if(context->msgs_out.inflight->store->payloadlen == 7){
CU_ASSERT_NSTRING_EQUAL(UHPA_ACCESS_PAYLOAD(context->msgs_out.inflight->store), "payload", 7);
Code and tests for persisting client msg properties.
2019-03-23 22:52:08 +00:00
}
}
Separate broker message queues into in/out. This allows and includes better flow control handling for QoS>0.
2019-04-13 21:59:29 +00:00
CU_ASSERT_EQUAL(context->msgs_out.inflight->mid, 0x73);
CU_ASSERT_EQUAL(context->msgs_out.inflight->qos, 1);
CU_ASSERT_EQUAL(context->msgs_out.inflight->retain, 0);
CU_ASSERT_EQUAL(context->msgs_out.inflight->direction, mosq_md_out);
CU_ASSERT_EQUAL(context->msgs_out.inflight->state, mosq_ms_wait_for_puback);
CU_ASSERT_EQUAL(context->msgs_out.inflight->dup, 0);
CU_ASSERT_PTR_NOT_NULL(context->msgs_out.inflight->properties);
if(context->msgs_out.inflight->properties){
CU_ASSERT_EQUAL(context->msgs_out.inflight->properties->identifier, 1);
CU_ASSERT_EQUAL(context->msgs_out.inflight->properties->value.i8, 1);
Code and tests for persisting client msg properties.
2019-03-23 22:52:08 +00:00
}
v5 persistence file format This includes changes to improve read/write performance. It is not complete, and will have further changes to add properties and anything else required for MQTT v5.
2019-03-20 00:02:38 +00:00
}
}
}
static void TEST_v5_retain(void)
{
struct mosquitto_db db;
struct mosquitto__config config;
int rc;
last_retained = 0;
memset(&db, 0, sizeof(struct mosquitto_db));
memset(&config, 0, sizeof(struct mosquitto__config));
db.config = &config;
config.persistence = true;
config.persistence_filepath = "files/persist_read/v5-retain.test-db";
rc = persist__restore(&db);
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
CU_ASSERT_EQUAL(db.msg_store_count, 1);
CU_ASSERT_EQUAL(db.msg_store_bytes, 7);
CU_ASSERT_PTR_NOT_NULL(db.msg_store);
if(db.msg_store){
CU_ASSERT_EQUAL(db.msg_store->db_id, 0x54);
CU_ASSERT_STRING_EQUAL(db.msg_store->source_id, "source_id");
CU_ASSERT_EQUAL(db.msg_store->source_mid, 2);
CU_ASSERT_EQUAL(db.msg_store->mid, 0);
CU_ASSERT_EQUAL(db.msg_store->qos, 2);
CU_ASSERT_EQUAL(db.msg_store->retain, 1);
CU_ASSERT_STRING_EQUAL(db.msg_store->topic, "topic");
CU_ASSERT_EQUAL(db.msg_store->payloadlen, 7);
if(db.msg_store->payloadlen == 7){
CU_ASSERT_NSTRING_EQUAL(UHPA_ACCESS_PAYLOAD(db.msg_store), "payload", 7);
}
}
CU_ASSERT_EQUAL(last_retained, 0x54);
}
static void TEST_v5_sub(void)
{
struct mosquitto_db db;
struct mosquitto__config config;
struct mosquitto *context;
int rc;
last_sub = NULL;
last_qos = -1;
memset(&db, 0, sizeof(struct mosquitto_db));
memset(&config, 0, sizeof(struct mosquitto__config));
db.config = &config;
config.persistence = true;
config.persistence_filepath = "files/persist_read/v5-sub.test-db";
rc = persist__restore(&db);
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
CU_ASSERT_PTR_NOT_NULL(db.contexts_by_id);
HASH_FIND(hh_id, db.contexts_by_id, "client-id", strlen("client-id"), context);
CU_ASSERT_PTR_NOT_NULL(context);
if(context){
CU_ASSERT_PTR_NOT_NULL(last_sub);
if(last_sub){
CU_ASSERT_STRING_EQUAL(last_sub, "subscription")
free(last_sub);
}
CU_ASSERT_EQUAL(last_qos, 1);
Add subscription-identifier and options to persistence.
2019-03-21 11:53:46 +00:00
CU_ASSERT_EQUAL(last_identifier, 0x7623);
v5 persistence file format This includes changes to improve read/write performance. It is not complete, and will have further changes to add properties and anything else required for MQTT v5.
2019-03-20 00:02:38 +00:00
}
}
Start of tests for persistence reading.
2019-03-14 20:57:25 +00:00
/* ========================================================================
* TEST SUITE SETUP
* ======================================================================== */
int init_persist_read_tests(void)
{
CU_pSuite test_suite = NULL;
test_suite = CU_add_suite("Persist read", NULL, NULL);
if(!test_suite){
printf("Error adding CUnit persist read test suite.\n");
return 1;
}
if(0
|| !CU_add_test(test_suite, "Persistence disabled", TEST_persistence_disabled)
|| !CU_add_test(test_suite, "Empty file", TEST_empty_file)
|| !CU_add_test(test_suite, "Corrupt header", TEST_corrupt_header)
|| !CU_add_test(test_suite, "Unsupported version", TEST_unsupported_version)
|| !CU_add_test(test_suite, "v3 config ok", TEST_v3_config_ok)
|| !CU_add_test(test_suite, "v3 config bad truncated", TEST_v3_config_truncated)
|| !CU_add_test(test_suite, "v3 config bad dbid", TEST_v3_config_bad_dbid)
|| !CU_add_test(test_suite, "v3 bad chunk", TEST_v3_bad_chunk)
|| !CU_add_test(test_suite, "v3 message store", TEST_v3_message_store)
|| !CU_add_test(test_suite, "v3 client", TEST_v3_client)
|| !CU_add_test(test_suite, "v3 client message", TEST_v3_client_message)
|| !CU_add_test(test_suite, "v3 retain", TEST_v3_retain)
|| !CU_add_test(test_suite, "v3 sub", TEST_v3_sub)
Start of persistence writing tests.
2019-03-19 14:25:40 +00:00
|| !CU_add_test(test_suite, "v4 config ok", TEST_v4_config_ok)
Start of tests for persistence reading.
2019-03-14 20:57:25 +00:00
|| !CU_add_test(test_suite, "v4 message store", TEST_v4_message_store)
v5 persistence file format This includes changes to improve read/write performance. It is not complete, and will have further changes to add properties and anything else required for MQTT v5.
2019-03-20 00:02:38 +00:00
|| !CU_add_test(test_suite, "v5 config ok", TEST_v5_config_ok)
|| !CU_add_test(test_suite, "v5 config bad truncated", TEST_v5_config_truncated)
|| !CU_add_test(test_suite, "v5 bad chunk", TEST_v5_bad_chunk)
|| !CU_add_test(test_suite, "v5 message store", TEST_v5_message_store)
Tests for persisting message store properties.
2019-03-24 21:38:00 +00:00
|| !CU_add_test(test_suite, "v5 message store+props", TEST_v5_message_store_props)
v5 persistence file format This includes changes to improve read/write performance. It is not complete, and will have further changes to add properties and anything else required for MQTT v5.
2019-03-20 00:02:38 +00:00
|| !CU_add_test(test_suite, "v5 client", TEST_v5_client)
|| !CU_add_test(test_suite, "v5 client message", TEST_v5_client_message)
Code and tests for persisting client msg properties.
2019-03-23 22:52:08 +00:00
|| !CU_add_test(test_suite, "v5 client message+props", TEST_v5_client_message_props)
v5 persistence file format This includes changes to improve read/write performance. It is not complete, and will have further changes to add properties and anything else required for MQTT v5.
2019-03-20 00:02:38 +00:00
|| !CU_add_test(test_suite, "v5 retain", TEST_v5_retain)
|| !CU_add_test(test_suite, "v5 sub", TEST_v5_sub)
Start of tests for persistence reading.
2019-03-14 20:57:25 +00:00
){
printf("Error adding persist CUnit tests.\n");
return 1;
}
return 0;
}
int main(int argc, char *argv[])
{
Start of persistence writing tests.
2019-03-19 14:25:40 +00:00
int fails;
Start of tests for persistence reading.
2019-03-14 20:57:25 +00:00
if(CU_initialize_registry() != CUE_SUCCESS){
printf("Error initializing CUnit registry.\n");
return 1;
}
if(0
|| init_persist_read_tests()
){
CU_cleanup_registry();
return 1;
}
CU_basic_set_mode(CU_BRM_VERBOSE);
CU_basic_run_tests();
Start of persistence writing tests.
2019-03-19 14:25:40 +00:00
fails = CU_get_number_of_failures();
Start of tests for persistence reading.
2019-03-14 20:57:25 +00:00
CU_cleanup_registry();
Start of persistence writing tests.
2019-03-19 14:25:40 +00:00
return (int)fails;
Start of tests for persistence reading.
2019-03-14 20:57:25 +00:00
}
Reference in New Issue Copy Permalink