Mercurial > pt1

changeset 4:43d177fa65c9

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
fixed indentation
author Yoshiki Yazawa <yaz@honeyplanet.jp>
date Tue, 17 Feb 2009 01:46:54 +0900
parents 6801fe7e04ff
children 97fd2315114e
files recpt1/decoder.c recpt1/decoder.h recpt1/recpt1.c recpt1/recpt1.h
diffstat 4 files changed, 269 insertions(+), 270 deletions(-) [+]
line wrap: on
line diff
--- a/recpt1/decoder.c	Tue Feb 17 01:40:56 2009 +0900
+++ b/recpt1/decoder.c	Tue Feb 17 01:46:54 2009 +0900
@@ -5,52 +5,52 @@
 decoder *
 b25_startup(void)
 {
-  decoder *dec = calloc(1, sizeof(decoder));
-  int code;
+    decoder *dec = calloc(1, sizeof(decoder));
+    int code;
 
-  dec->b25 = create_arib_std_b25();
-  dec->b25->set_multi2_round(dec->b25, 4); //xxx round should be configurable
-  dec->b25->set_strip(dec->b25, 0); //ditto
-  dec->b25->set_emm_proc(dec->b25, 0); //ditto
-  dec->bcas = create_b_cas_card();
-  code = dec->bcas->init(dec->bcas);
-  code = dec->b25->set_b_cas_card(dec->b25, dec->bcas);
+    dec->b25 = create_arib_std_b25();
+    dec->b25->set_multi2_round(dec->b25, 4); //xxx round should be configurable
+    dec->b25->set_strip(dec->b25, 0); //ditto
+    dec->b25->set_emm_proc(dec->b25, 0); //ditto
+    dec->bcas = create_b_cas_card();
+    code = dec->bcas->init(dec->bcas);
+    code = dec->b25->set_b_cas_card(dec->b25, dec->bcas);
 
-  return dec;
+    return dec;
 }
 
 int
 b25_shutdown(decoder *dec)
 {
-  dec->b25->release(dec->b25);
-  dec->bcas->release(dec->bcas);
-  free(dec);
+    dec->b25->release(dec->b25);
+    dec->bcas->release(dec->bcas);
+    free(dec);
 
-  return 0;
+    return 0;
 }
 
 int
 b25_decode(decoder *dec, ARIB_STD_B25_BUFFER *sbuf, ARIB_STD_B25_BUFFER *dbuf)
 {
-  int code;
+    int code;
 
-  code = dec->b25->put(dec->b25, sbuf);
-  if(code < 0)
+    code = dec->b25->put(dec->b25, sbuf);
+    if(code < 0)
+        return code;
+
+    code = dec->b25->get(dec->b25, dbuf);
     return code;
-
-  code = dec->b25->get(dec->b25, dbuf);
-  return code;
 }
 
 int
 b25_finish(decoder *dec, ARIB_STD_B25_BUFFER *sbuf, ARIB_STD_B25_BUFFER *dbuf)
 {
-  int code;
+    int code;
 
-  code = dec->b25->flush(dec->b25);
-  if(code < 0)
+    code = dec->b25->flush(dec->b25);
+    if(code < 0)
+        return code;
+
+    code = dec->b25->get(dec->b25, dbuf);
     return code;
-
-  code = dec->b25->get(dec->b25, dbuf);
-  return code;
 }
--- a/recpt1/decoder.h	Tue Feb 17 01:40:56 2009 +0900
+++ b/recpt1/decoder.h	Tue Feb 17 01:46:54 2009 +0900
@@ -6,18 +6,18 @@
 
 typedef struct decoder
 {
-  ARIB_STD_B25 *b25;
-  B_CAS_CARD *bcas;
+    ARIB_STD_B25 *b25;
+    B_CAS_CARD *bcas;
 } decoder;
 
 /* prototypes */
 decoder *b25_startup(void);
 int b25_shutdown(decoder *dec);
 int b25_decode(decoder *dec,
-	       ARIB_STD_B25_BUFFER *sbuf,
-	       ARIB_STD_B25_BUFFER *dbuf);
+               ARIB_STD_B25_BUFFER *sbuf,
+               ARIB_STD_B25_BUFFER *dbuf);
 int b25_finish(decoder *dec,
-	       ARIB_STD_B25_BUFFER *sbuf,
-	       ARIB_STD_B25_BUFFER *dbuf);
+               ARIB_STD_B25_BUFFER *sbuf,
+               ARIB_STD_B25_BUFFER *dbuf);
 
 #endif
--- a/recpt1/recpt1.c	Tue Feb 17 01:40:56 2009 +0900
+++ b/recpt1/recpt1.c	Tue Feb 17 01:46:54 2009 +0900
@@ -15,293 +15,293 @@
 #include "decoder.h"
 
 /* globals */
-int	wfd;		/* for output file */
-int	f_exit = FALSE ;
+int wfd;                /* for output file */
+int f_exit = FALSE ;
 
 typedef struct thread_data {
-  QUEUE_T *queue;
-  decoder *decoder;
+    QUEUE_T *queue;
+    decoder *decoder;
 } thread_data;
 
 // 周波数テーブル変換
 ISDB_T_FREQ_CONV_TABLE *
 searchrecoff(char *channel)
 {
-  int		lp ;
+    int lp ;
 
-  for(lp = 0 ; lp < 113 ; lp++){
-    // 文字列＆長さ一致したら周波数テーブル番号を返却する
-    if((memcmp(isdb_t_conv_table[lp].parm_freq, channel,
-	       strlen(channel)) == 0) &&
-       (strlen(channel) == strlen(isdb_t_conv_table[lp].parm_freq))){
-      return &isdb_t_conv_table[lp] ;
+    for(lp = 0 ; lp < 113 ; lp++){
+        // 文字列＆長さ一致したら周波数テーブル番号を返却する
+        if((memcmp(isdb_t_conv_table[lp].parm_freq, channel,
+                   strlen(channel)) == 0) &&
+           (strlen(channel) == strlen(isdb_t_conv_table[lp].parm_freq))){
+            return &isdb_t_conv_table[lp] ;
+        }
     }
-  }
-  return NULL ;
+    return NULL ;
 }
 
 QUEUE_T *
 create_queue(size_t size)
 {
-  QUEUE_T*	p_queue;
-  int		memsize = sizeof(QUEUE_T) + size * sizeof(BUFSZ);
+    QUEUE_T *p_queue;
+    int     memsize = sizeof(QUEUE_T) + size * sizeof(BUFSZ);
 
-  p_queue = (QUEUE_T*)calloc(memsize, sizeof(char));
+    p_queue = (QUEUE_T*)calloc(memsize, sizeof(char));
 
-  if(p_queue != NULL){
-    p_queue->size = size;
-    p_queue->no_full = size;
-    p_queue->no_empty = 0;
-    pthread_mutex_init(&p_queue->mutex, NULL);
-    pthread_cond_init(&p_queue->cond_full, NULL);
-    pthread_cond_init(&p_queue->cond_empty, NULL);
-  }
+    if(p_queue != NULL){
+        p_queue->size = size;
+        p_queue->no_full = size;
+        p_queue->no_empty = 0;
+        pthread_mutex_init(&p_queue->mutex, NULL);
+        pthread_cond_init(&p_queue->cond_full, NULL);
+        pthread_cond_init(&p_queue->cond_empty, NULL);
+    }
 
-  return p_queue;
+    return p_queue;
 }
 
 void
 destroy_queue(QUEUE_T *p_queue)
 {
-  if(p_queue != NULL){
-    pthread_mutex_destroy(&p_queue->mutex);
-    pthread_cond_destroy(&p_queue->cond_full);
-    pthread_cond_destroy(&p_queue->cond_empty);
-    free(p_queue);
-  }
+    if(p_queue != NULL) {
+        pthread_mutex_destroy(&p_queue->mutex);
+        pthread_cond_destroy(&p_queue->cond_full);
+        pthread_cond_destroy(&p_queue->cond_empty);
+        free(p_queue);
+    }
 }
 
 /* enqueue data. this function will block if queue is full. */
 void
 enqueue(QUEUE_T *p_queue, BUFSZ *data)
 {
-  pthread_mutex_lock(&p_queue->mutex);
-  /* entered critical section */
+    pthread_mutex_lock(&p_queue->mutex);
+    /* entered critical section */
 
-  /* wait until queue is not full */
-  while(!p_queue->no_full) {
-    pthread_cond_wait(&p_queue->cond_full, &p_queue->mutex);
-    printf("Full\n");
-  }
+    /* wait until queue is not full */
+    while(!p_queue->no_full) {
+        pthread_cond_wait(&p_queue->cond_full, &p_queue->mutex);
+        printf("Full\n");
+    }
 
-  p_queue->buffer[p_queue->in] = data;
+    p_queue->buffer[p_queue->in] = data;
 
-  p_queue->in++;
-  p_queue->in %= p_queue->size;
+    p_queue->in++;
+    p_queue->in %= p_queue->size;
 
-  p_queue->no_full--;
-  p_queue->no_empty++;
+    p_queue->no_full--;
+    p_queue->no_empty++;
 
-  /* leaving critical section */
-  pthread_mutex_unlock(&p_queue->mutex);
-  pthread_cond_signal(&p_queue->cond_empty);
+    /* leaving critical section */
+    pthread_mutex_unlock(&p_queue->mutex);
+    pthread_cond_signal(&p_queue->cond_empty);
 }
 
 /* dequeue data. this function will block if queue is empty. */
 BUFSZ *
 dequeue(QUEUE_T *p_queue)
 {
-  BUFSZ	*buffer;
+    BUFSZ	*buffer;
 
-  pthread_mutex_lock(&p_queue->mutex);
-  /* entered the critical section*/
+    pthread_mutex_lock(&p_queue->mutex);
+    /* entered the critical section*/
 
-  /* wait until queue is filled */
-  while (!p_queue->no_empty) {
-    pthread_cond_wait(&p_queue->cond_empty, &p_queue->mutex);
-  }
+    /* wait until queue is filled */
+    while (!p_queue->no_empty) {
+        pthread_cond_wait(&p_queue->cond_empty, &p_queue->mutex);
+    }
 
-  /* take buffer address */
-  buffer = p_queue->buffer[p_queue->out];
+    /* take buffer address */
+    buffer = p_queue->buffer[p_queue->out];
 
-  // 次にデータを取り出す場所をインクリメント
-  p_queue->out++;
-  p_queue->out %= p_queue->size;
+    // 次にデータを取り出す場所をインクリメント
+    p_queue->out++;
+    p_queue->out %= p_queue->size;
 
-  /* update flags */
-  p_queue->no_full++;
-  p_queue->no_empty--;
+    /* update flags */
+    p_queue->no_full++;
+    p_queue->no_empty--;
 
-  /* leaving the critical section */
-  pthread_mutex_unlock(&p_queue->mutex);
-  pthread_cond_signal(&p_queue->cond_full);
+    /* leaving the critical section */
+    pthread_mutex_unlock(&p_queue->mutex);
+    pthread_cond_signal(&p_queue->cond_full);
 
-  return buffer;
+    return buffer;
 }
 
 /* this function will be a writing thread */
 void *
 write_func(void *p)
 {
-  thread_data *data = (thread_data *)p;
-  QUEUE_T *p_queue = data->queue;
-  decoder *dec = data->decoder;
-  BUFSZ	*buf ;
-  ARIB_STD_B25_BUFFER sbuf, dbuf;
+    thread_data *data = (thread_data *)p;
+    QUEUE_T *p_queue = data->queue;
+    decoder *dec = data->decoder;
+    BUFSZ	*buf ;
+    ARIB_STD_B25_BUFFER sbuf, dbuf;
+
+    while(1) {
+        buf = dequeue(p_queue);
+        /* no entry in the queue */
+        if(buf == NULL){
+            close(wfd);
+            break ;
+        }
 
-  while(1){
-    buf = dequeue(p_queue);
-    /* no entry in the queue */
-    if(buf == NULL){
-      close(wfd);
-      break ;
+        sbuf.data = buf->buffer;
+        sbuf.size = buf->size;
+
+        /* write data to output file*/
+        b25_decode(dec, &sbuf, &dbuf);
+        write(wfd, dbuf.data, dbuf.size);
+        free(buf);
+
+        /* normal exit */
+        if((f_exit) && (!p_queue->no_empty)){
+            b25_finish(dec, &sbuf, &dbuf);
+            write(wfd, dbuf.data, dbuf.size);
+            close(wfd);
+            break ;
+        }
     }
 
-    sbuf.data = buf->buffer;
-    sbuf.size = buf->size;
-
-    /* write data to output file*/
-    b25_decode(dec, &sbuf, &dbuf);
-    write(wfd, dbuf.data, dbuf.size);
-    free(buf);
-
-    /* normal exit */
-    if((f_exit) && (!p_queue->no_empty)){
-      b25_finish(dec, &sbuf, &dbuf);
-      write(wfd, dbuf.data, dbuf.size);
-      close(wfd);
-      break ;
-    }
-  }
-
-  return NULL;
+    return NULL;
 }
 
 int
 main(int argc, char **argv)
 {
-  int		fd ;
-  int		lp ;
-  int		recsec ;
-  time_t	start_time ;
-  time_t	cur_time ;
-  FREQUENCY	freq;
-  ISDB_T_FREQ_CONV_TABLE	*ptr ;
-  pthread_t dequeue_threads;
-  QUEUE_T *p_queue = create_queue(MAX_QUEUE);
-  BUFSZ	*bufptr ;
-  decoder *dec;
-  thread_data tdata;
+    int fd ;
+    int lp ;
+    int recsec ;
+    time_t start_time ;
+    time_t cur_time ;
+    FREQUENCY freq;
+    ISDB_T_FREQ_CONV_TABLE *ptr ;
+    pthread_t dequeue_threads;
+    QUEUE_T *p_queue = create_queue(MAX_QUEUE);
+    BUFSZ   *bufptr ;
+    decoder *dec;
+    thread_data tdata;
 
-  if(argc < 4) {
-    printf("Usage %s: channel recsec destfile\n", argv[0]);
-    printf("channel =\n");
-    printf("151ch：BS朝日\n");
-    printf("161ch：BS-i\n");
-    printf("171ch：BSジャパン\n");
-    printf("211ch：BS11デジタル\n");
-    printf("222ch：TwellV\n");
-    printf("141ch：BS日テレ\n");
-    printf("181ch：BSフジ\n");
-    printf("101ch：NHK衛星第1放送(BS1)\n");
-    printf("102ch：NHK衛星第2放送(BS2)\n");
-    printf("103ch：NHKハイビジョン(BShi)\n");
-    return 1;
-  }
-  ptr = searchrecoff(argv[1]);
-  if(ptr == NULL) {
-    printf("Channel Select Error(%s)\n", argv[1]);
-    return 1 ;
-  }
+    if(argc < 4) {
+        printf("Usage %s: channel recsec destfile\n", argv[0]);
+        printf("channel =\n");
+        printf("151ch：BS朝日\n");
+        printf("161ch：BS-i\n");
+        printf("171ch：BSジャパン\n");
+        printf("211ch：BS11デジタル\n");
+        printf("222ch：TwellV\n");
+        printf("141ch：BS日テレ\n");
+        printf("181ch：BSフジ\n");
+        printf("101ch：NHK衛星第1放送(BS1)\n");
+        printf("102ch：NHK衛星第2放送(BS2)\n");
+        printf("103ch：NHKハイビジョン(BShi)\n");
+        return 1;
+    }
+    ptr = searchrecoff(argv[1]);
+    if(ptr == NULL) {
+        printf("Channel Select Error(%s)\n", argv[1]);
+        return 1 ;
+    }
 
-  freq.frequencyno = ptr->set_freq ;
-  freq.slot = ptr->add_freq ;
+    freq.frequencyno = ptr->set_freq ;
+    freq.slot = ptr->add_freq ;
 
-  if(ptr->type == CHTYPE_SATELLITE) {
-    for(lp = 0 ; lp < 2 ; lp++) {
-      fd = open(bsdev[lp], O_RDONLY);
-      if(fd >= 0) {
-	break ;
-      }
-    }
-    if(fd < 0) {
-      printf("Device Open Error\n");
-      return 1;
+    if(ptr->type == CHTYPE_SATELLITE) {
+        for(lp = 0 ; lp < 2 ; lp++) {
+            fd = open(bsdev[lp], O_RDONLY);
+            if(fd >= 0) {
+                break ;
+            }
+        }
+        if(fd < 0) {
+            printf("Device Open Error\n");
+            return 1;
+        }
+    } else {
+        for(lp = 0 ; lp < 2 ; lp++) {
+            fd = open(isdb_t_dev[lp], O_RDONLY);
+            if(fd >= 0) {
+                break ;
+            }
+        }
+        if(fd < 0) {
+            printf("Device Open Error\n");
+            return 1;
+        }
     }
-  } else {
-    for(lp = 0 ; lp < 2 ; lp++) {
-      fd = open(isdb_t_dev[lp], O_RDONLY);
-      if(fd >= 0) {
-	break ;
-      }
-    }
-    if(fd < 0) {
-      printf("Device Open Error\n");
-      return 1;
-    }
-  }
-  recsec = atoi(argv[2]);
+    recsec = atoi(argv[2]);
 
-  /* initialize decoder */
-  dec = b25_startup();
+    /* initialize decoder */
+    dec = b25_startup();
 
-  /* open output file */
-  wfd = open(argv[3], (O_RDWR | O_CREAT | O_TRUNC), 0666);
-  if(wfd < 0) {
-    printf("Output File Open Error(%s)\n", argv[3]);
-    return 0;
-  }
+    /* open output file */
+    wfd = open(argv[3], (O_RDWR | O_CREAT | O_TRUNC), 0666);
+    if(wfd < 0) {
+        printf("Output File Open Error(%s)\n", argv[3]);
+        return 0;
+    }
 
-  if(ioctl(fd, SET_CHANNEL, &freq) < 0) {
-    printf("Tuner Select Error\n");
-    return 0 ;
-  }
+    if(ioctl(fd, SET_CHANNEL, &freq) < 0) {
+        printf("Tuner Select Error\n");
+        return 0 ;
+    }
 
-  /* make reading thread */
-  tdata.queue = p_queue;
-  tdata.decoder = dec;
-  pthread_create(&dequeue_threads, NULL, write_func, &tdata);
+    /* make reading thread */
+    tdata.queue = p_queue;
+    tdata.decoder = dec;
+    pthread_create(&dequeue_threads, NULL, write_func, &tdata);
 
-  /* start recording*/
-  if(ioctl(fd, START_REC, 0) < 0) {
-    printf("Tuner Start Error\n");
-    return 0 ;
-  }
+    /* start recording*/
+    if(ioctl(fd, START_REC, 0) < 0) {
+        printf("Tuner Start Error\n");
+        return 0 ;
+    }
 
-  time(&start_time);
+    time(&start_time);
 
-  /* read from tuner */
-  while(1) {
-    time(&cur_time);
-    bufptr = malloc(sizeof(BUFSZ));
-    bufptr->size = read(fd, bufptr->buffer, MAX_READ_SIZE);
-    if(bufptr->size <= 0) {
-      if((cur_time - start_time) >= recsec) {
-	f_exit = TRUE ;
-	enqueue(p_queue, NULL);
-	break ;
-      } else {
-	continue ;
-      }
-    }
-    enqueue(p_queue, bufptr);
+    /* read from tuner */
+    while(1) {
+        time(&cur_time);
+        bufptr = malloc(sizeof(BUFSZ));
+        bufptr->size = read(fd, bufptr->buffer, MAX_READ_SIZE);
+        if(bufptr->size <= 0) {
+            if((cur_time - start_time) >= recsec) {
+                f_exit = TRUE ;
+                enqueue(p_queue, NULL);
+                break ;
+            } else {
+                continue ;
+            }
+        }
+        enqueue(p_queue, bufptr);
 
-    /* stop recording */
-    if((cur_time - start_time) >= recsec) {
-      ioctl(fd, STOP_REC, 0);
-      /* read remaining data */
-      while(1) {
-	bufptr = malloc(sizeof(BUFSZ));
-	bufptr->size = read(fd, bufptr->buffer, MAX_READ_SIZE);
-	if(bufptr->size <= 0) {
-	  f_exit = TRUE ;
-	  enqueue(p_queue, NULL);
-	  break ;
-	}
-	enqueue(p_queue, bufptr);
-      }
-      break ;
+        /* stop recording */
+        if((cur_time - start_time) >= recsec) {
+            ioctl(fd, STOP_REC, 0);
+            /* read remaining data */
+            while(1) {
+                bufptr = malloc(sizeof(BUFSZ));
+                bufptr->size = read(fd, bufptr->buffer, MAX_READ_SIZE);
+                if(bufptr->size <= 0) {
+                    f_exit = TRUE ;
+                    enqueue(p_queue, NULL);
+                    break ;
+                }
+                enqueue(p_queue, bufptr);
+            }
+            break ;
+        }
     }
-  }
-  /* close tuner */
-  close(fd);
+    /* close tuner */
+    close(fd);
 
-  /* wait reading thread */
-  pthread_join(dequeue_threads, NULL);
-  destroy_queue(p_queue);
+    /* wait reading thread */
+    pthread_join(dequeue_threads, NULL);
+    destroy_queue(p_queue);
 
-  /* release decoder */
-  b25_shutdown(dec);
+    /* release decoder */
+    b25_shutdown(dec);
 
-  return 0 ;
+    return 0 ;
 }
--- a/recpt1/recpt1.h	Tue Feb 17 01:40:56 2009 +0900
+++ b/recpt1/recpt1.h	Tue Feb 17 01:46:54 2009 +0900
@@ -10,37 +10,36 @@
 	"/dev/pt1video3"
 };
 
-#define		CHTYPE_SATELLITE	0		// 衛星デジタル放送
-#define		CHTYPE_GROUND		1		// 地上デジタル放送
-#define		MAX_QUEUE		8192
+#define CHTYPE_SATELLITE	0		// 衛星デジタル放送
+#define CHTYPE_GROUND		1		// 地上デジタル放送
+#define MAX_QUEUE		8192
+#define MAX_READ_SIZE	(1024 * 16)
+#define WRITE_SIZE	(1024 * 1024 * 2)
+#define TRUE	1
+#define FALSE	0
 
-#define		MAX_READ_SIZE	(1024 * 16)
-#define		WRITE_SIZE	(1024 * 1024 * 2)
-#define		TRUE	1
-#define		FALSE	0
-
-typedef	struct	_BUFSZ {
-  int	 size ;
-  u_char buffer[MAX_READ_SIZE];
+typedef struct _BUFSZ {
+    int	 size ;
+    u_char buffer[MAX_READ_SIZE];
 } BUFSZ;
 
-typedef	struct	_QUEUE_T {
-  unsigned int		in;		// 次に入れるインデックス
-  unsigned int		out;		// 次に出すインデックス
-  unsigned int		size;		// キューのサイズ
-  unsigned int		no_full;	// 満タンになると 0 になる
-  unsigned int		no_empty;	// 空っぽになると 0 になる
-  pthread_mutex_t	mutex;
-  pthread_cond_t	cond_full;	// データが満タンのときに待つための cond
-  pthread_cond_t	cond_empty;	// データが空のときに待つための cond
-  BUFSZ			*buffer[1];	// バッファポインタ
+typedef struct _QUEUE_T {
+    unsigned int		in;		// 次に入れるインデックス
+    unsigned int		out;		// 次に出すインデックス
+    unsigned int		size;		// キューのサイズ
+    unsigned int		no_full;	// 満タンになると 0 になる
+    unsigned int		no_empty;	// 空っぽになると 0 になる
+    pthread_mutex_t	mutex;
+    pthread_cond_t	cond_full;	// データが満タンのときに待つための cond
+    pthread_cond_t	cond_empty;	// データが空のときに待つための cond
+    BUFSZ			*buffer[1];	// バッファポインタ
 } QUEUE_T;
 
-typedef	struct	_ISDB_T_FREQ_CONV_TABLE {
-  int	set_freq ;	// 実際にioctl()を行う値
-  int	type ;		// チャンネルタイプ
-  int	add_freq ;	// 追加する周波数(BS/CSの場合はスロット番号)
-  char	*parm_freq ;	// パラメータで受ける値
+typedef struct _ISDB_T_FREQ_CONV_TABLE {
+    int	set_freq ;	// 実際にioctl()を行う値
+    int	type ;		// チャンネルタイプ
+    int	add_freq ;	// 追加する周波数(BS/CSの場合はスロット番号)
+    char	*parm_freq ;	// パラメータで受ける値
 } ISDB_T_FREQ_CONV_TABLE;
 
 // 変換テーブル(ISDB-T用)