some cleaning

Author: SwooshyCueb

include/irods/private/amqp_sender.hpp

@@ -5,14 +5,11 @@
 
 #include <irods/irods_error.hpp>
 
-#include <chrono>
 #include <cstdint>
-#include <condition_variable>
 #include <fstream>
 #include <mutex>
 #include <optional>
 #include <semaphore>
-#include <shared_mutex>
 #include <string>
 #include <thread>
 #include <vector>
@@ -65,30 +62,29 @@ namespace irods::plugin::rule_engine::audit_amqp
 		                  std::ofstream& test_log_ofstream);
 
 		void on_container_start(proton::container& container) override;
-		void on_container_stop(proton::container& container) override;
-		void on_transport_close(proton::transport& transport) override;
 		void on_transport_error(proton::transport& transport) override;
-		void on_connection_open(proton::connection& connection) override;
-		void on_connection_close(proton::connection& connection) override;
 		void on_connection_error(proton::connection& connection) override;
-		void on_session_close(proton::session& session) override;
 		void on_session_error(proton::session& session) override;
-		void on_sender_open(proton::sender& sender) override;
-		void on_sender_close(proton::sender& sender) override;
 		void on_sender_error(proton::sender& sender) override;
-		void on_tracker_accept(proton::tracker& tracker) override;
 		void on_tracker_reject(proton::tracker& tracker) override;
-		void on_tracker_release(proton::tracker& tracker) override;
-		void on_tracker_settle(proton::tracker& tracker) override;
 		void on_error(const proton::error_condition& err_cond) override;
 
 		#ifdef IRODS_AUDIT_EXTRA_TRACE
+		void on_container_stop(proton::container& container) override;
 		void on_sendable(proton::sender& sender) override;
 		void on_transport_open(proton::transport& transport) override;
+		void on_transport_close(proton::transport& transport) override;
+		void on_connection_open(proton::connection& connection) override;
+		void on_connection_close(proton::connection& connection) override;
 		void on_session_open(proton::session& session) override;
+		void on_session_close(proton::session& session) override;
 		void on_sender_detach(proton::sender& sender) override;
+		void on_sender_open(proton::sender& sender) override;
+		void on_sender_close(proton::sender& sender) override;
+		void on_tracker_accept(proton::tracker& tracker) override;
+		void on_tracker_release(proton::tracker& tracker) override;
+		void on_tracker_settle(proton::tracker& tracker) override;
 		void on_sender_drain_start(proton::sender& sender) override;
-		void on_receiver_drain_finish(proton::receiver& receiver) override;
 		void on_connection_wake(proton::connection& connection) override;
 		#endif
 
@@ -110,16 +106,9 @@ namespace irods::plugin::rule_engine::audit_amqp
 		std::optional<bool> _durable_messages;
 
 		std::optional<std::thread> _proton_thread;
-
 		std::mutex _amqp_send_mutex;
-
-		std::shared_mutex _amqp_connection_cv_mutex;
-		std::condition_variable_any _amqp_connection_cv;
 		std::binary_semaphore _connection_semaphore;
 
-		std::shared_mutex _amqp_send_cv_mutex;
-		std::condition_variable_any _amqp_send_cv;
-
 		std::optional<proton::container> _container;
 		std::optional<proton::connection> _connection;
 		std::optional<proton::sender> _sender;