diff --git a/broker/src/asapo_broker/server/get_commands_test.go b/broker/src/asapo_broker/server/get_commands_test.go index dc0389fb1f585ca1b8d65012d67847347da1e2b6..17f3aea5a32a1308f3ec4e7e49f5d894cd6c2aea 100644 --- a/broker/src/asapo_broker/server/get_commands_test.go +++ b/broker/src/asapo_broker/server/get_commands_test.go @@ -43,18 +43,18 @@ var testsGetCommand = []struct { queryParams string externalParam string }{ -/* {"last", expectedSource,expectedStream, "", expectedStream + "/0/last","","0"}, + {"last", expectedSource,expectedStream, "", expectedStream + "/0/last","","0"}, {"id", expectedSource,expectedStream, "", expectedStream + "/0/1","","1"}, {"meta", expectedSource,"default", "", "default/0/meta/0","","0"}, - {"nacks",expectedSource, expectedStream, expectedGroupID, expectedStream + "/" + expectedGroupID + "/nacks","","0_0"},*/ + {"nacks",expectedSource, expectedStream, expectedGroupID, expectedStream + "/" + expectedGroupID + "/nacks","","0_0"}, {"groupedlast", expectedSource,expectedStream, expectedGroupID, expectedStream + "/" + expectedGroupID + "/groupedlast","",""}, -/* {"next", expectedSource,expectedStream, expectedGroupID, expectedStream + "/" + expectedGroupID + "/next","",""}, + {"next", expectedSource,expectedStream, expectedGroupID, expectedStream + "/" + expectedGroupID + "/next","",""}, {"next", expectedSource,expectedStream, expectedGroupID, expectedStream + "/" + expectedGroupID + "/next","&resend_nacks=true&delay_ms=10000&resend_attempts=3","10000_3"}, {"size", expectedSource,expectedStream, "", expectedStream + "/size","",""}, {"size",expectedSource, expectedStream, "", expectedStream + "/size","&incomplete=true","true"}, {"streams",expectedSource, "0", "", "0/streams","","0/"}, - {"lastack", expectedSource,expectedStream, expectedGroupID, expectedStream + "/" + expectedGroupID + "/lastack","",""},*/ + {"lastack", expectedSource,expectedStream, expectedGroupID, expectedStream + "/" + expectedGroupID + "/lastack","",""}, } diff --git a/tests/automatic/consumer/consumer_api/consumer_api.c b/tests/automatic/consumer/consumer_api/consumer_api.c index f89b792f66419dc9710abd88ecbd62521c8b5cc8..d9996dddedfb6461620e0c0a267275efbd311742 100644 --- a/tests/automatic/consumer/consumer_api/consumer_api.c +++ b/tests/automatic/consumer/consumer_api/consumer_api.c @@ -32,6 +32,7 @@ void test_datasets(AsapoConsumerHandle consumer, AsapoStringHandle group_id) { // get last in group dataset = asapo_consumer_get_last_dataset_ingroup(consumer,group_id, 0, "default", &err); EXIT_IF_ERROR("asapo_consumer_get_last_dataset_ingroup", err); + asapo_free_handle(&dataset); AsapoDataSetHandle ds_ig = asapo_consumer_get_last_dataset_ingroup(consumer,group_id, 0, "default", &err); ASSERT_TRUE(ds_ig == NULL,"returns null in case of error"); ASSERT_TRUE(asapo_error_get_type(err) == kEndOfStream,"asapo_consumer_get_last_dataset_ingroup second time end of stream error");