Fix/voice socketengine (#1337)

Author: Neko-Life

include/dpp/cluster.h

@@ -183,7 +183,7 @@ class DPP_EXPORT cluster {
 	 * @brief Used to spawn the socket engine into its own thread if
 	 * the cluster is started with dpp::st_return. It is unused otherwise.
 	 */
-	std::unique_ptr<std::thread> engine_thread{nullptr};
+	std::thread engine_thread;
 
 	/**
 	 * @brief Protection mutex for timers

src/dpp/cluster.cpp

@@ -298,7 +298,7 @@ void cluster::start(bool return_after) {
 	});
 
 	if (return_after) {
-		engine_thread = std::make_unique<std::thread>([event_loop]() {
+		engine_thread = std::thread([event_loop]() {
 			dpp::utility::set_thread_name("event_loop");
 			event_loop();
 		});
@@ -310,9 +310,12 @@ void cluster::start(bool return_after) {
 void cluster::shutdown() {
 	/* Signal termination */
 	terminating = true;
-	if (engine_thread) {
-		engine_thread->join();
+
+	if (engine_thread.joinable()) {
+		/* Join engine_thread if it ever started */
+		engine_thread.join();
 	}
+
 	{
 		std::lock_guard<std::mutex> l(timer_guard);
 		/* Free memory for active timers */
@@ -322,6 +325,7 @@ void cluster::shutdown() {
 		timer_list.clear();
 		next_timer.clear();
 	}
+
 	/* Terminate shards */
 	for (const auto& sh : shards) {
 		delete sh.second;

src/dpp/socketengines/epoll.cpp

@@ -111,6 +111,7 @@ struct DPP_EXPORT socket_engine_epoll : public socket_engine_base {
 				}
 
 				if ((ev.events & EPOLLOUT) != 0U) {
+					/* Should we have a flag to allow keeping WANT_WRITE? Maybe like WANT_WRITE_ONCE or GREEDY_WANT_WRITE, eh */
 					eh->flags = modify_event(epoll_handle, eh, eh->flags & ~WANT_WRITE);
 					if (eh->on_write) {
 						eh->on_write(fd, *eh);

src/dpp/sslclient.cpp

@@ -373,6 +373,10 @@ void ssl_client::on_read(socket fd, const struct socket_events& ev) {
 }
 
 void ssl_client::on_write(socket fd, const struct socket_events& e) {
+	/* We wanted write before so keep it */
+	socket_events se{e};
+	se.flags |= WANT_WRITE;
+	owner->socketengine->update_socket(se);
 
 	if (!tcp_connect_done) {
 		tcp_connect_done = true;

src/dpp/voice/enabled/read_write.cpp

@@ -39,10 +39,6 @@ void discord_voice_client::send(const char* packet, size_t len, uint64_t duratio
 	} else [[unlikely]] {
 		this->udp_send(packet, len);
 	}
-	if (!this->sent_stop_frames) {
-		udp_events.flags = WANT_READ | WANT_WRITE | WANT_ERROR;
-		owner->socketengine->update_socket(udp_events);
-	}
 }
 
 int discord_voice_client::udp_send(const char* data, size_t length) {

src/dpp/voice/enabled/write_ready.cpp

@@ -31,6 +31,13 @@
 namespace dpp {
 
 void discord_voice_client::write_ready() {
+	/* 
+	 * WANT_WRITE has been reset everytime this method is being called,
+	 * ALWAYS set it again no matter what we're gonna do.
+	 */
+	udp_events.flags = WANT_READ | WANT_WRITE | WANT_ERROR;
+	owner->socketengine->update_socket(udp_events);
+
 	uint64_t duration = 0;
 	bool track_marker_found = false;
 	uint64_t bufsize = 0;
@@ -54,15 +61,12 @@ void discord_voice_client::write_ready() {
 				}
 			}
 			if (!outbuf.empty()) {
-				if (this->udp_send(outbuf[0].packet.data(), outbuf[0].packet.length()) == (int)outbuf[0].packet.length()) {
+				int sent_siz = this->udp_send(outbuf[0].packet.data(), outbuf[0].packet.length());
+				if (sent_siz == (int)outbuf[0].packet.length()) {
 					duration = outbuf[0].duration * timescale;
 					bufsize = outbuf[0].packet.length();
 					outbuf.erase(outbuf.begin());
 				}
-				if (!outbuf.empty()) {
-					udp_events.flags = WANT_READ | WANT_WRITE | WANT_ERROR;
-					owner->socketengine->update_socket(udp_events);
-				}
 			}
 		}
 	}