Discard packet_stream queue on demote

 - Cleanup some comments.

Signed-off-by: Andrew Opalach <andrew@akon.city>

1 files changed, 4 insertions, 4 deletions

diff --git a/src/libsink/sink.c b/src/libsink/sink.c
index 951b230..b5e2a65 100644
--- a/src/libsink/sink.c
+++ b/src/libsink/sink.c
@@ -504,7 +504,7 @@ static void maybe_remove_previous(struct camu_sink *sink)
 
 // Due to the looseness of the previous queue, we may have to explicitly remove an entry
 // if it becomes incorrect to attempt removing it's buffers.
-// An obvious example of this is at the point an entry gets freed. See LIANA_CLIENT_REMOVE_BUFFERS.
+// An obvious example of this is at the point an entry gets freed.
 static void maybe_remove_from_previous(struct camu_sink *sink, struct camu_sink_entry *entry)
 {
 #ifdef CAMU_SINK_TRACE
@@ -875,7 +875,7 @@ static void maybe_unset_current(struct camu_sink *sink)
         if (!sink->current->ended) {
             remove_entry_buffers(sink, sink->current);
         }
-        // TODO: A current-less state is not properly handled.
+        // @TODO: A current-less state is not properly handled.
         sink->current = NULL;
     }
 }
@@ -991,7 +991,7 @@ static void client_callback(void *userdata, u8 op, struct camu_codec_stream *str
         case CAMU_STREAM_SUBTITLE:
 #ifdef CAMU_HAVE_FFMPEG
             if (!camu_video_buffer_configure_subtitles(&entry->video.buf, stream->av.stream->codecpar)) {
-                // TODO:
+                // @TODO:
             }
 #endif
             break;
@@ -1174,6 +1174,7 @@ static void client_callback(void *userdata, u8 op, struct camu_codec_stream *str
         break;
     }
     case LIANA_CLIENT_CLOSED: {
+        // LIANA_CLIENT_REMOVE_BUFFERS has been called on this entry before we're here.
         nn_mutex_lock(&sink->mutex);
 
         if (entry == sink->target) {
@@ -1184,7 +1185,6 @@ static void client_callback(void *userdata, u8 op, struct camu_codec_stream *str
                 al_assert(sink->reconnecting == sink->current);
                 sink->reconnecting = NULL;
             }
-            // current's buffers will already be removed.
             sink->current = NULL;
             if (sink->target) {
                 switch_to(sink, sink->target);