
# HG changeset patch
# User Naoya OYAMA <naoya.oyama@gmail.com>
# Date 1343831004 -32400
# Node ID bf96eac4dbb192d52276bde0729235fe8c40a54b
# Parent  e72dd5e8d53fd01e7721a43691e533bf94fb336d
Changed to a variable length buffer of splitbuf_t

diff -r e72dd5e8d53f -r bf96eac4dbb1 src/recpt1.c
--- a/src/recpt1.c	Sun Jul 29 23:16:30 2012 +0900
+++ b/src/recpt1.c	Wed Aug 01 23:23:24 2012 +0900
@@ -418,6 +418,8 @@
     buf.size = 0;
     buf.data = NULL;
     splitbuf.size = 0;
+    splitbuf.buffer_length = 0;
+    splitbuf.buffer = NULL;
 
     if(wfd == -1)
         fileless = TRUE;
@@ -454,6 +456,15 @@
 
         if(use_splitter) {
             splitbuf.size = 0;
+            if(splitbuf.buffer_length < buf.size && buf.size > 0) {
+                splitbuf.buffer = realloc(splitbuf.buffer, buf.size);
+                if(NULL == splitbuf.buffer) {
+                    fprintf(stderr, "splitbuf.buffer realloc failed\n");
+                    use_splitter = FALSE;
+                    goto fin;
+                }
+                splitbuf.buffer_length = buf.size;
+            }
 
             while(buf.size) {
                 /* $BJ,N%BP>](BPID$B$NCj=P(B */
@@ -608,6 +619,11 @@
                         pthread_kill(signal_thread, SIGPIPE);
                 }
             }
+            if(use_splitter) {
+                free(splitbuf.buffer);
+                splitbuf.buffer = NULL;
+                splitbuf.buffer_length = 0;
+            }
 
             break;
         }
diff -r e72dd5e8d53f -r bf96eac4dbb1 src/tssplitter_lite.h
--- a/src/tssplitter_lite.h	Sun Jul 29 23:16:30 2012 +0900
+++ b/src/tssplitter_lite.h	Wed Aug 01 23:23:24 2012 +0900
@@ -107,7 +107,7 @@
 
 /*
  * PCRからSTCを生成する処理方式(案)
- * 1. PCRを二つ取得するまでループ(1.�4.までは初期処理で実施すること)
+ * 1. PCRを二つ取得するまでループ(1.から4.までは初期処理で実施すること)
  * 2. ループ開始時刻(PCR)と、ループ抜けた時刻(PCR)の差分を取る
  * 3. ループ開始～終了の間に処理したパケット数を数える
  * 4. (2.のPCRの進んだ時間/3.のパケット数)　の計算によって、1パケットによって進むPCRを想定する
@@ -205,7 +205,8 @@
 typedef struct _splitbuf_t
 {
     int size;
-    u_char buffer[1024*1024];
+    int buffer_length;
+    u_char *buffer;
 } splitbuf_t;
 
 splitter* split_startup(char *sid, char *filename, char *cue_time);