minor refactoring

1 files changed, 18 insertions, 8 deletions

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");