fix: initial stuff, still not working

src/dpp/cluster.cpp

@@ -311,7 +311,11 @@ void cluster::shutdown() {
 	/* Signal termination */
 	terminating = true;
 	if (engine_thread) {
-		engine_thread->join();
+		if (engine_thread->joinable()) {
+			engine_thread->join();
+		} else {
+			log(ll_warning, "Cluster engine_thread is not joinable on dtor");
+		}
 	}
 	{
 		std::lock_guard<std::mutex> l(timer_guard);

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/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);
-				}
 			}
 		}
 	}