# HG changeset patch # User Yoshiki Yazawa # Date 1235325977 -32400 # Node ID 6da603afd36361cd813d91a25e1a8aa5edd5935a # Parent 407af34cfbd900d82c6ee461c462b7d01d7548dc added udp capability diff -r 407af34cfbd9 -r 6da603afd363 recpt1/recpt1.c --- a/recpt1/recpt1.c Tue Feb 17 11:52:26 2009 +0900 +++ b/recpt1/recpt1.c Mon Feb 23 03:06:17 2009 +0900 @@ -9,6 +9,10 @@ #include #include +#include +#include +#include + #include #include "pt1_ioctl.h" @@ -18,10 +22,16 @@ /* globals */ int f_exit = FALSE; +typedef struct sock_data { + int sfd; /* socket fd */ + struct sockaddr_in addr; +} sock_data; + typedef struct thread_data { QUEUE_T *queue; decoder *decoder; - int fd; + int wfd; /* output file fd */ + sock_data *sock_data; } thread_data; /* lookup frequency conversion table*/ @@ -46,7 +56,7 @@ create_queue(size_t size) { QUEUE_T *p_queue; - int memsize = sizeof(QUEUE_T) + size * sizeof(BUFSZ); + int memsize = sizeof(QUEUE_T) + size * sizeof(BUFSZ); p_queue = (QUEUE_T*)calloc(memsize, sizeof(char)); @@ -104,7 +114,7 @@ BUFSZ * dequeue(QUEUE_T *p_queue) { - BUFSZ *buffer; + BUFSZ *buffer; pthread_mutex_lock(&p_queue->mutex); /* entered the critical section*/ @@ -139,12 +149,20 @@ thread_data *data = (thread_data *)p; QUEUE_T *p_queue = data->queue; decoder *dec = data->decoder; - int wfd = data->fd; + int wfd = data->wfd; int use_b25 = dec ? 1 : 0; - BUFSZ *buf; + int use_udp = data->sock_data ? 1 : 0; + int sfd = 0; + struct sockaddr *addr = NULL; + BUFSZ *buf; ARIB_STD_B25_BUFFER sbuf, dbuf; int code; + if(use_udp) { + sfd = data->sock_data->sfd; + addr = (struct sockaddr *)&data->sock_data->addr; + } + while(1) { buf = dequeue(p_queue); /* no entry in the queue */ @@ -165,9 +183,19 @@ break; } write(wfd, dbuf.data, dbuf.size); + + if(use_udp && sfd) { + sendto(sfd, dbuf.data, dbuf.size, 0, + addr, sizeof(struct sockaddr_in)); + } free(buf); } else { write(wfd, sbuf.data, sbuf.size); + + if(use_udp && sfd) { + sendto(sfd, sbuf.data, sbuf.size, 0, + addr, sizeof(struct sockaddr_in)); + } free(buf); } @@ -178,11 +206,18 @@ if(code < 0) { fprintf(stderr, "b25_finish failed\n"); close(wfd); + close(sfd); break; } write(wfd, dbuf.data, dbuf.size); + + if(use_udp && sfd) { + sendto(sfd, dbuf.data, dbuf.size, 0, + addr, sizeof(struct sockaddr_in)); + } } close(wfd); + close(sfd); break; } } @@ -190,10 +225,16 @@ return NULL; } +void +show_usage(char *cmd) +{ + fprintf(stderr, "Usage: %s [--b25 [--round N] [--strip] [--EMM]] [--udp hostname [--port port]] channel recsec destfile\n", cmd); +} + int main(int argc, char **argv) { - int fd, wfd; + int tfd, wfd; int lp; int recsec; time_t start_time, cur_time; @@ -204,9 +245,12 @@ BUFSZ *bufptr; decoder *dec = NULL; thread_data tdata; - decoder_options dopt; + decoder_options dopt = { + 4, /* round */ + 0, /* strip */ + 0 /* emm */ + }; - int use_b25 = 0; int result; int option_index; struct option long_options[] = { @@ -215,42 +259,55 @@ { "round", 1, NULL, 'r'}, { "strip", 0, NULL, 's'}, { "emm", 0, NULL, 'm'}, - { "EMM", 0, NULL, 'm'} + { "EMM", 0, NULL, 'm'}, + { "udp", 1, NULL, 'u'}, + { "port", 1, NULL, 'p'} }; - dopt.round = 4; - dopt.strip = 0; - dopt.emm = 0; + int use_b25 = 0; + int use_udp = 0; + char *host_to = NULL; + int port_to = 1234; + sock_data *sdata = NULL; - while((result = getopt_long(argc, argv, "br:sm", long_options, &option_index)) != -1) { + while((result = getopt_long(argc, argv, "br:sm" "u:p:", long_options, &option_index)) != -1) { switch(result) { case 'b': - use_b25 = 1; + use_b25 = 1; fprintf(stderr, "using B25...\n"); - break; + break; case 's': - dopt.strip = 1; + dopt.strip = 1; fprintf(stderr, "enable B25 strip\n"); - break; + break; case 'm': - dopt.emm = 1; + dopt.emm = 1; fprintf(stderr, "enable B25 emm processing\n"); - break; + break; case 'r': - dopt.round = atoi(optarg); + dopt.round = atoi(optarg); fprintf(stderr, "set round %d\n", dopt.round); break; case ':': fprintf(stderr, "%c needs value\n", result); break; case '?': - fprintf(stderr, "Usage: [--b25 [--round N] [--strip] [--EMM]] channel recsec destfile\n"); + show_usage(argv[0]); + break; + case 'u': + use_udp = 1; + host_to = optarg; + fprintf(stderr, "UDP destination address: %s\n", host_to); + break; + case 'p': + port_to = atoi(optarg); + fprintf(stderr, "UDP port: %d\n", port_to); break; } } - if(argc - optind < 3) { - printf("Usage %s: [--b25 [--round N] [--strip] [--EMM]] channel recsec destfile\n", argv[0]); + if(argc - optind < 3) { + show_usage(argv[0]); printf("channel =\n"); printf("151ch：BS朝日\n"); printf("161ch：BS-i\n"); @@ -267,39 +324,39 @@ printf("CS2-CS24：CSチャンネル\n"); return 1; } - ptr = searchrecoff(argv[optind]); - if(ptr == NULL){ - printf("Channel Select Error(%s)\n", argv[optind]); - return 1; - } + ptr = searchrecoff(argv[optind]); + if(ptr == NULL){ + printf("Channel Select Error(%s)\n", argv[optind]); + return 1; + } 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) { + tfd = open(bsdev[lp], O_RDONLY); + if(tfd >= 0) { break; } } - if(fd < 0) { + if(tfd < 0) { fprintf(stderr, "Device Open Error\n"); return 1; } } else { for(lp = 0; lp < 2; lp++) { - fd = open(isdb_t_dev[lp], O_RDONLY); - if(fd >= 0) { + tfd = open(isdb_t_dev[lp], O_RDONLY); + if(tfd >= 0) { break; } } - if(fd < 0) { + if(tfd < 0) { fprintf(stderr, "Device Open Error\n"); return 1; } } - recsec = atoi(argv[optind + 1]); + recsec = atoi(argv[optind + 1]); /* initialize decoder */ if(use_b25) { @@ -311,6 +368,28 @@ } } + /* initialize udp connection */ + if(use_udp) { + sdata = calloc(1, sizeof(sock_data)); + struct in_addr ia; + ia.s_addr = inet_addr(host_to); + if(ia.s_addr == INADDR_NONE) { + struct hostent *hoste = gethostbyname(host_to); + if(!hoste) { + perror("failed to get host by name"); + return 1; + } + ia.s_addr = *(in_addr_t*) (hoste->h_addr_list[0]); + } + sdata->addr.sin_family = AF_INET; + sdata->addr.sin_port = htons (port_to); + sdata->addr.sin_addr.s_addr = ia.s_addr; + if((sdata->sfd = socket(PF_INET, SOCK_DGRAM, 0)) < 0) { + perror("socket"); + return 1; + } + } + /* open output file */ wfd = open(argv[optind + 2], (O_RDWR | O_CREAT | O_TRUNC), 0666); if(wfd < 0) { @@ -318,7 +397,7 @@ return 1; } - if(ioctl(fd, SET_CHANNEL, &freq) < 0) { + if(ioctl(tfd, SET_CHANNEL, &freq) < 0) { fprintf(stderr, "Tuner Select Error\n"); return 1; } @@ -326,11 +405,12 @@ /* make reader thread */ tdata.queue = p_queue; tdata.decoder = dec; - tdata.fd = wfd; + tdata.wfd = wfd; + tdata.sock_data = sdata; pthread_create(&dequeue_threads, NULL, write_func, &tdata); /* start recording */ - if(ioctl(fd, START_REC, 0) < 0) { + if(ioctl(tfd, START_REC, 0) < 0) { fprintf(stderr, "Tuner Start Error\n"); return 1; } @@ -341,7 +421,7 @@ while(1) { time(&cur_time); bufptr = malloc(sizeof(BUFSZ)); - bufptr->size = read(fd, bufptr->buffer, MAX_READ_SIZE); + bufptr->size = read(tfd, bufptr->buffer, MAX_READ_SIZE); if(bufptr->size <= 0) { if((cur_time - start_time) >= recsec) { f_exit = TRUE; @@ -355,11 +435,11 @@ /* stop recording */ if((cur_time - start_time) >= recsec) { - ioctl(fd, STOP_REC, 0); + ioctl(tfd, STOP_REC, 0); /* read remaining data */ while(1) { bufptr = malloc(sizeof(BUFSZ)); - bufptr->size = read(fd, bufptr->buffer, MAX_READ_SIZE); + bufptr->size = read(tfd, bufptr->buffer, MAX_READ_SIZE); if(bufptr->size <= 0) { f_exit = TRUE; enqueue(p_queue, NULL); @@ -371,12 +451,18 @@ } } /* close tuner */ - close(fd); + close(tfd); /* wait reader thread */ pthread_join(dequeue_threads, NULL); destroy_queue(p_queue); + /* close socket */ + if(use_udp) { + close(sdata->sfd); + free(sdata); + } + /* release decoder */ if(use_b25) { b25_shutdown(dec);