2 files changed, 6 insertions, 6 deletions
diff --git a/src/lib.c b/src/lib.c
index a986f30..2fe0c94 100644
--- a/src/lib.c
+++ b/src/lib.c
@@ -28,14 +28,14 @@ static gboolean
 invoke_g_hash_table_remove (TranscodeServerCtx *ctx)
 {
   g_hash_table_remove (ctx->parent_ctx_table, ctx->path);
-  return FALSE;
+  return G_SOURCE_REMOVE;
 }
 
 static gboolean
 invoke_g_free_client_context (TranscodeClientCtx *ctx)
 {
   g_free (ctx);
-  return FALSE;
+  return G_SOURCE_REMOVE;
 }
 
 gboolean
diff --git a/src/main.c b/src/main.c
index 1921778..7cc2d25 100644
--- a/src/main.c
+++ b/src/main.c
@@ -127,7 +127,7 @@ invoke_write_client_chunk (TranscodeClientCtx *ctx)
    * after the client has disconnected and the SoupMessage is invalid.
    * When the client disconnects, timeout_handler_id is set to 0. */
   if (G_UNLIKELY (ctx->timeout_handler_id == 0))
-    return FALSE;
+    return G_SOURCE_REMOVE;
 
   g_signal_emit_by_name (ctx->appsink, "pull-sample", &sample);
   if (!sample) {
@@ -138,7 +138,7 @@ invoke_write_client_chunk (TranscodeClientCtx *ctx)
     else
       soup_message_set_status (ctx->msg, SOUP_STATUS_INTERNAL_SERVER_ERROR);
     soup_message_body_complete (ctx->msg->response_body);
-    return FALSE;
+    return G_SOURCE_REMOVE;
   }
 
   buffer = gst_sample_get_buffer (sample);
@@ -147,7 +147,7 @@ invoke_write_client_chunk (TranscodeClientCtx *ctx)
   if (!ctx->keyframe_found &&
       GST_BUFFER_FLAG_IS_SET (buffer, GST_BUFFER_FLAG_DELTA_UNIT)) {
     gst_sample_unref (sample);
-    return FALSE;
+    return G_SOURCE_REMOVE;
   }
   ctx->keyframe_found = TRUE;
 
@@ -161,7 +161,7 @@ invoke_write_client_chunk (TranscodeClientCtx *ctx)
 
   soup_server_unpause_message (server, ctx->msg);
   stp_print_status (".");
-  return FALSE;
+  return G_SOURCE_REMOVE;
 }
 
 static GstFlowReturn