From c153935be4561f10a997bfea5f140dd8f160e080 Mon Sep 17 00:00:00 2001
From: Christian Pointner <equinox@helsinki.at>
Date: Sat, 16 Apr 2011 13:59:11 +0000
Subject: minor refactoring


diff --git a/src/writer.c b/src/writer.c
index fb99c96..361d43e 100644
--- a/src/writer.c
+++ b/src/writer.c
@@ -154,6 +154,18 @@ static int open_file(file_t* file)
   return 0;
 }
 
+static int check_boundaries(writer_t* writer)
+{
+  struct timespec now;
+  clock_gettime(CLOCK_REALTIME, &now);
+  
+  struct tm now_bd;
+  localtime_r(&(now.tv_sec), &now_bd);
+  log_printf(DEBUG, "it's now: %02d:%02d:%02d on %d.%d.%d", now_bd.tm_hour, now_bd.tm_min, now_bd.tm_sec, now_bd.tm_mday, now_bd.tm_mon+1, now_bd.tm_year+1900);
+
+  return 0;
+}
+  
 static gpointer writer_thread_func(gpointer data)
 {
   writer_t *writer = (writer_t*)data;
@@ -161,18 +173,16 @@ static gpointer writer_thread_func(gpointer data)
   
   GstBuffer* buf = NULL;
   for(;;) {
-    GstClockReturn ret =  gst_clock_id_wait(writer->clock_id_, NULL);
-    if(GST_CLOCK_UNSCHEDULED == ret)
+    GstClockReturn wret =  gst_clock_id_wait(writer->clock_id_, NULL);
+    if(GST_CLOCK_UNSCHEDULED == wret)
       break;
-    if(GST_CLOCK_EARLY == ret)
+    if(GST_CLOCK_EARLY == wret)
       continue;
 
-    struct timespec now;
-    clock_gettime(CLOCK_REALTIME, &now);
+    int ret = check_boundaries(writer);
+    if(ret) break;
 
-    struct tm now_bd;
-    localtime_r(&(now.tv_sec), &now_bd);
-    log_printf(DEBUG, "it's now: %02d:%02d:%02d on %d.%d.%d", now_bd.tm_hour, now_bd.tm_min, now_bd.tm_sec, now_bd.tm_mday, now_bd.tm_mon+1, now_bd.tm_year+1900);
+        // TODO: children handling (waitpid)
   }
  
   log_printf(NOTICE, "writer thread stopped");
-- 
cgit v0.10.2