test: pipewire comp flag + test memory management

1 files changed, 12 insertions, 16 deletions

diff --git a/tests/pke-test-audio.cpp b/tests/pke-test-audio.cpp
index bc181b1..488a67c 100644
--- a/tests/pke-test-audio.cpp
+++ b/tests/pke-test-audio.cpp
@@ -17,11 +17,16 @@
 #include <thread>
 #include <threads.h>
 
-pk_membucket *bkt = nullptr;
+static pk_membucket *bkt = nullptr;
+
+#define PKE_TEST_AUDIO_SLEEP_DUR_NS 10
 
 void pke_test_audio_spinup() {
 	// pk_funcinstr_init();
 	pkeSettings.isSimulationPaused = true;
+	bkt = pk_mem_bucket_create("pke_test_audio", PK_MEM_DEFAULT_BUCKET_SIZE, PK_MEMBUCKET_FLAG_NONE);
+	pk_mem_bucket_set_client_mem_bucket(bkt);
+	pk_ev_init(bkt);
 	PkeThreads_Init();
 	AM_Init();
 	Physics_Init();
@@ -38,6 +43,9 @@ void pke_test_audio_teardown() {
 	Physics_Teardown();
 	AM_Teardown();
 	PkeThreads_Teardown();
+	pk_ev_teardown();
+	pk_mem_bucket_destroy(bkt);
+	pk_mem_bucket_set_client_mem_bucket(nullptr);
 	bkt = nullptr;
 	// pk_funcinstr_teardown();
 };
@@ -46,8 +54,6 @@ void pke_test_audio_teardown() {
 int pke_test_audio_001() {
 	uint32_t i;
 	try {
-		bkt = pk_mem_bucket_create("pke_test_serialization", PK_MEM_DEFAULT_BUCKET_SIZE, PK_MEMBUCKET_FLAG_NONE);
-
 		UBO.model = glm::translate(glm::mat4(1.f), glm::vec3(0, 0, 0));
 
 		float *zip_bop_bytes = pk_new_arr<float>(PKE_AUDIO_BITRATE, bkt);
@@ -66,24 +72,20 @@ int pke_test_audio_001() {
 
 		while (pke_audio_mstr.playing_objects.next > 0) {
 			pke_audio_tick(0.001f);
-			std::this_thread::sleep_for(std::chrono::nanoseconds(500000));
+			std::this_thread::sleep_for(std::chrono::nanoseconds(PKE_TEST_AUDIO_SLEEP_DUR_NS));
 		}
 
 		AM_Release(ah_sawtooth);
 
 	} catch (const std::exception &ex) {
-		pk_mem_bucket_destroy(bkt);
 		throw;
 	}
-	pk_mem_bucket_destroy(bkt);
 	return 0;
 }
 
 int pke_test_audio_002() {
 	uint32_t i, k;
 	try {
-		bkt = pk_mem_bucket_create("pke_test_serialization", PK_MEM_DEFAULT_BUCKET_SIZE, PK_MEMBUCKET_FLAG_NONE);
-
 		UBO.model = glm::translate(glm::mat4(1.f), glm::vec3(0, 0, 0));
 
 		AssetHandle ahs[3];
@@ -114,7 +116,7 @@ int pke_test_audio_002() {
 
 		while (pke_audio_mstr.playing_objects.next > 0) {
 			pke_audio_tick(0.001f);
-			std::this_thread::sleep_for(std::chrono::nanoseconds(500000));
+			std::this_thread::sleep_for(std::chrono::nanoseconds(PKE_TEST_AUDIO_SLEEP_DUR_NS));
 		}
 
 		for(k = 0; k < 3; ++k) {
@@ -122,18 +124,14 @@ int pke_test_audio_002() {
 		}
 
 	} catch (const std::exception &ex) {
-		pk_mem_bucket_destroy(bkt);
 		throw;
 	}
-	pk_mem_bucket_destroy(bkt);
 	return 0;
 }
 
 int pke_test_audio_003() {
 	uint64_t i, k;
 	try {
-		bkt = pk_mem_bucket_create("pke_test_serialization", PK_MEM_DEFAULT_BUCKET_SIZE, PK_MEMBUCKET_FLAG_NONE);
-
 		UBO.model = glm::translate(glm::mat4(1.f), glm::vec3(0, 0, 0));
 
 		InstPos inst_pos{};
@@ -185,7 +183,7 @@ int pke_test_audio_003() {
 			inst->bt.rigidBody->setWorldTransform(trfm);
 			// fprintf(stdout, "%f,%f,%f\n", rot_pos.x, rot_pos.y, rot_pos.z);
 
-			std::this_thread::sleep_for(std::chrono::nanoseconds(500000));
+			std::this_thread::sleep_for(std::chrono::nanoseconds(PKE_TEST_AUDIO_SLEEP_DUR_NS));
 		}
 
 		for(k = 0; k < 1; ++k) {
@@ -193,10 +191,8 @@ int pke_test_audio_003() {
 		}
 
 	} catch (const std::exception &ex) {
-		pk_mem_bucket_destroy(bkt);
 		throw;
 	}
-	pk_mem_bucket_destroy(bkt);
 	return 0;
 }