X-Git-Url: http://git.osdn.net/view?p=rec10%2Frec10-git.git;a=blobdiff_plain;f=dist%2Ftrunk%2Ftstools%2Fepgdump%2Feit.c;fp=dist%2Ftrunk%2Ftstools%2Fepgdump%2Feit.c;h=4409434ae44f1539e2e7bdef9093be10734b7717;hp=0000000000000000000000000000000000000000;hb=13e65e890a6dd60705bacc22b893ce5c899b7001;hpb=9b4c01d4fac3cef067298b660c72fe3755616a7e

diff --git a/dist/trunk/tstools/epgdump/eit.c b/dist/trunk/tstools/epgdump/eit.c
new file mode 100755
index 0000000..4409434
--- /dev/null
+++ b/dist/trunk/tstools/epgdump/eit.c
@@ -0,0 +1,678 @@
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+
+#include "eit.h"
+
+char		*subtitle_cnv_str[] = {
+//	"¡¡Âè",
+//	"¡¼Âè",
+//	"-Âè",
+//	" Âè",
+//	"¡¡¡Ö",
+//	"¡¡¡ô",
+//	"¡Ê",
+//	"¡Ö",
+	NULL
+};
+static void timecmp(int *,int *,int *,
+					int, int, int);
+
+int parseEIThead(unsigned char *data, EIThead *h) {
+	int boff = 0;
+
+	memset(h, 0, sizeof(EIThead));
+
+	h->table_id = getBit(data, &boff, 8);
+	h->section_syntax_indicator = getBit(data, &boff, 1);
+	h->reserved_future_use = getBit(data, &boff, 1);
+	h->reserved1 = getBit(data, &boff, 2);
+	h->section_length =getBit(data, &boff,12);
+	h->service_id = getBit(data, &boff, 16);
+	h->reserved2 = getBit(data, &boff, 2);
+	h->version_number = getBit(data, &boff, 5);
+	h->current_next_indicator = getBit(data, &boff, 1);
+	h->section_number = getBit(data, &boff, 8);
+	h->last_section_number = getBit(data, &boff, 8);
+	h->transport_stream_id = getBit(data, &boff, 16);
+	h->original_network_id = getBit(data, &boff, 16);
+	h->segment_last_section_number = getBit(data, &boff, 8);
+	h->last_table_id = getBit(data, &boff, 8);
+  
+	return 14;
+}
+
+int parseEITbody(unsigned char *data, EITbody *b)
+{
+	int boff = 0;
+	int tnum;
+	char buf[4];
+
+	memset(b, 0, sizeof(EITbody));
+
+	b->event_id = getBit(data, &boff, 16);
+
+	memcpy(b->start_time, data + boff / 8, 5);
+	/* b->start_time = getBit(data, &boff, 40); */
+	boff += 40;
+	memcpy(b->duration, data + boff / 8, 3);
+	/* b->duration = getBit(data, &boff, 24); */
+	boff += 24;
+	b->running_status = getBit(data, &boff, 3);
+	b->free_CA_mode = getBit(data, &boff, 1);
+	b->descriptors_loop_length = getBit(data, &boff, 12);
+
+	/* ÆüÉÕÊÑ´¹ */
+	tnum = (b->start_time[0] & 0xFF) << 8 | (b->start_time[1] & 0xFF);
+  
+	b->yy = (tnum - 15078.2) / 365.25;
+	b->mm = ((tnum - 14956.1) - (int)(b->yy * 365.25)) / 30.6001;
+	b->dd = (tnum - 14956) - (int)(b->yy * 365.25) - (int)(b->mm * 30.6001);
+
+	if(b->dd == 0) {
+		printf("aa");
+	}
+
+	if(b->mm == 14 || b->mm == 15) {
+		b->yy += 1;
+		b->mm = b->mm - 1 - (1 * 12);
+	} else {
+		b->mm = b->mm - 1;
+	}
+
+	b->yy += 1900;
+  
+	memset(buf, '\0', sizeof(buf));
+	sprintf(buf, "%x", b->start_time[2]);
+	b->hh = atoi(buf);
+	memset(buf, '\0', sizeof(buf));
+	sprintf(buf, "%x", b->start_time[3]);
+	b->hm = atoi(buf);
+	memset(buf, '\0', sizeof(buf));
+	sprintf(buf, "%x", b->start_time[4]);
+	b->ss = atoi(buf);
+
+	if((b->duration[0] == 0xFF) && (b->duration[1] == 0xFF) && (b->duration[2] == 0xFF)){
+		b->dhh = b->dhm = b->dss = 0;
+	}else{
+		memset(buf, '\0', sizeof(buf));
+	sprintf(buf, "%x", b->duration[0]);
+	b->dhh = atoi(buf);
+		memset(buf, '\0', sizeof(buf));
+	sprintf(buf, "%x", b->duration[1]);
+	b->dhm = atoi(buf);
+		memset(buf, '\0', sizeof(buf));
+	sprintf(buf, "%x", b->duration[2]);
+	b->dss = atoi(buf);
+	}
+	return 12;
+}
+
+int parseSEVTdesc(unsigned char *data, SEVTdesc *desc) {
+	int boff = 0;
+  
+	memset(desc, 0, sizeof(SEVTdesc));
+
+	desc->descriptor_tag = getBit(data, &boff, 8);
+	if((desc->descriptor_tag & 0xFF) != 0x4D) {
+		return -1;
+	}
+	desc->descriptor_length = getBit(data, &boff, 8);
+	memcpy(desc->ISO_639_language_code, data + boff / 8, 3);
+	/* desc->ISO_639_language_code = getBit(data, &boff, 24); */
+	boff += 24;
+	desc->event_name_length = getBit(data, &boff, 8);
+	getStr(desc->event_name, data, &boff, desc->event_name_length);
+	desc->text_length = getBit(data, &boff, 8);
+	getStr(desc->text, data, &boff, desc->text_length);
+
+	return desc->descriptor_length + 2;
+}
+
+int parseContentDesc(unsigned char *data, ContentDesc *desc) {
+	int boff = 0;
+  
+	memset(desc, 0, sizeof(ContentDesc));
+
+	desc->descriptor_tag = getBit(data, &boff, 8);
+	if((desc->descriptor_tag & 0xFF) != 0x54) {
+		return -1;
+	}
+	desc->descriptor_length = getBit(data, &boff, 8);
+	memcpy(desc->content, data+(boff/8), desc->descriptor_length);
+	//getStr(desc->content, data, &boff, desc->descriptor_length);
+	return desc->descriptor_length + 2;
+}
+
+int parseSeriesDesc(unsigned char *data, SeriesDesc *desc) {
+	int boff = 0;
+  
+	memset(desc, 0, sizeof(SeriesDesc));
+
+	desc->descriptor_tag = getBit(data, &boff, 8);
+	if((desc->descriptor_tag & 0xFF) != 0xD5) {
+		return -1;
+	}
+	desc->descriptor_length = getBit(data, &boff, 8);
+	desc->series_id = getBit(data, &boff, 16);
+	desc->repeat_label = getBit(data, &boff, 4);
+	desc->program_pattern = getBit(data, &boff, 3);
+	desc->expire_date_valid_flag = getBit(data, &boff, 1);
+
+	desc->expire_date = getBit(data, &boff, 16);
+	//memcpy(desc->expire_date, data + boff / 8, 2);
+	//boff += 16;
+
+	desc->episode_number = getBit(data, &boff, 12);
+	desc->last_episode_number = getBit(data, &boff, 12);
+
+	getStr(desc->series_name_char, data, &boff, desc->descriptor_length - 8);
+	return desc->descriptor_length + 2;
+}
+
+int parseEEVTDhead(unsigned char *data, EEVTDhead *desc) {
+	int boff = 0;
+  
+	memset(desc, 0, sizeof(EEVTDhead));
+
+	desc->descriptor_tag = getBit(data, &boff, 8);
+	if((desc->descriptor_tag & 0xFF) != 0x4E) {
+		return -1;
+	}
+	desc->descriptor_length = getBit(data, &boff, 8);
+	desc->descriptor_number = getBit(data, &boff, 4);
+	desc->last_descriptor_number = getBit(data, &boff, 4);
+	memcpy(desc->ISO_639_language_code, data + boff / 8, 3);
+	/* desc->ISO_639_language_code = getBit(data, &boff, 24); */
+	boff += 24;
+
+	desc->length_of_items = getBit(data, &boff, 8);
+
+	return 7;
+}
+
+int parseEEVTDitem(unsigned char *data, EEVTDitem *desc) {
+	int boff = 0;
+  
+	memset(desc, 0, sizeof(EEVTDitem));
+
+	desc->item_description_length = getBit(data, &boff, 8);
+	getStr(desc->item_description, data, &boff, desc->item_description_length);
+
+	desc->item_length = getBit(data, &boff, 8);
+//	memcpy(desc->item, data + (boff / 8), desc->item_length);
+	getStr(desc->item, data, &boff, desc->item_length);
+
+	return desc->item_description_length + desc->item_length + 2;
+}
+
+int parseEEVTDtail(unsigned char *data, EEVTDtail *desc) {
+	int boff = 0;
+  
+	memset(desc, 0, sizeof(EEVTDtail));
+
+	desc->text_length = getBit(data, &boff, 8);
+	getStr(desc->text, data, &boff, desc->text_length);
+
+	return desc->text_length + 1;
+}
+
+int checkEEVTDitem(EEVTDitem *save, EEVTDitem *new, int descriptor_number) {
+
+	EEVTDitem swap;
+	int boff = 0;
+	if(new == NULL) {
+		if(save->item_length != 0) {
+			swap = *save;
+			getStr(save->item, (unsigned char*)swap.item, &boff, swap.item_length);
+
+
+                        //save->descriptor_number = descriptor_number;
+                        //*new = swap;
+			//*save = swap;
+                        if (swap.descriptor_number==1){
+//                            printf("descriptor_num %d   typeB\n",swap.descriptor_number);
+                        }
+
+			return 1;
+		} else {
+
+
+                        //printf("descriptor_num %d   typeC\n",swap.descriptor_number);
+
+
+
+			return 0;
+		}
+	}
+
+	if(new->item_description_length == 0) {
+		/* ³¤­ Êݸ */
+		memcpy(save->item + save->item_length, new->item, new->item_length);
+		save->item_length += new->item_length;
+
+
+                if (swap.descriptor_number==1){
+                            printf("descriptor_num %d   typeD\n",swap.descriptor_number);
+                        }
+
+
+		return 0;
+	} else {
+		/* ¥Ö¥ì¡¼¥¯¡£save¤ò°õºþÂоݤˤ¹¤ë¡£save¤ò¥¯¥ê¥¢? */
+		if(save->item_length != 0) {
+			/* ÂàÈòºÑ¤ß¤¬¤¢¤ê */
+			swap = *save;
+			getStr(save->item, (unsigned char*)swap.item, &boff, swap.item_length);
+			swap = *new;
+			*new = *save;
+			*save = swap;
+			save->descriptor_number = descriptor_number;
+                       
+
+
+
+                        if (swap.descriptor_number==1){
+                            printf("descriptor_num %d   typeE\n",swap.descriptor_number);
+                        }
+                        
+
+		} else {
+			*save = *new;
+			save->descriptor_number = descriptor_number;
+
+                        if (swap.descriptor_number==1){
+                            printf("descriptor_num %d   typeF\n",swap.descriptor_number);
+                        }
+
+
+			return 0;
+		}
+	}
+
+	return 1;
+}
+EIT_CONTROL	*searcheit(EIT_CONTROL *top, int servid, int eventid)
+{
+	EIT_CONTROL	*cur ;
+	cur = top ;
+
+	while(cur != NULL){
+		if((cur->event_id == eventid) && (cur->servid == servid)){
+			return cur ;
+		}
+
+		cur = cur->next ;
+	}
+	return NULL ;
+}
+void	conv_title_subtitle(EIT_CONTROL *eitptr)
+{
+	int		lp = 0 ;
+	size_t	addsize ;
+	char	*ptr ;
+	char	*newsubtitle ;
+
+	for(lp = 0 ; subtitle_cnv_str[lp] != NULL ; lp++){
+		ptr = strstr(eitptr->title, subtitle_cnv_str[lp]);
+		if(ptr == NULL){
+			continue ;
+		}
+		// ¥¿¥¤¥È¥ë¤¬¤Ê¤¯¤Ê¤é¤Ê¤¤¤è¤¦¤Ë
+		if(ptr == eitptr->title){
+			continue ;
+		}
+		newsubtitle = calloc(1, ((strlen(ptr) + 1) + (strlen(eitptr->subtitle) + 1)));
+		memcpy(newsubtitle, ptr, strlen(ptr));
+		newsubtitle[strlen(ptr)] = ' ';
+		*ptr = NULL ;
+		strcat(newsubtitle, eitptr->subtitle);
+		free(eitptr->subtitle);
+		eitptr->subtitle = newsubtitle ;
+		return ;
+	}
+}
+void	enqueue(EIT_CONTROL *top, EIT_CONTROL *eitptr)
+{
+	EIT_CONTROL	*cur ;
+	cur = top ;
+	int		rc ;
+
+	if(top->next == NULL){
+		top->next = eitptr ;
+		eitptr->prev = top ;
+		return ;
+	}
+	cur = top->next ;
+	while(cur != NULL){
+		rc = memcmp(&cur->yy, &eitptr->yy, (sizeof(int) * 3));
+		if(rc == 0){
+			rc = memcmp(&cur->hh, &eitptr->hh, (sizeof(int) * 3));
+			if(rc == 0){
+				free(eitptr->title);
+				free(eitptr->subtitle);
+				free(eitptr);
+				return ;
+			}
+			if(rc > 0){
+				if(cur->prev != 0){
+					cur->prev->next = eitptr ;
+					eitptr->prev = cur->prev ;
+				}
+				cur->prev = eitptr ;
+				eitptr->next = cur ;
+				conv_title_subtitle(eitptr);
+				return ;
+			}
+		}
+		if(rc > 0){
+			if(cur->prev != 0){
+				cur->prev->next = eitptr ;
+				eitptr->prev = cur->prev ;
+			}
+			cur->prev = eitptr ;
+			eitptr->next = cur ;
+			conv_title_subtitle(eitptr);
+			return ;
+		}
+		if(cur->next == NULL){
+			cur->next = eitptr ;
+			eitptr->prev = cur ;
+			conv_title_subtitle(eitptr);
+			return ;
+		}
+		cur = cur->next ;
+	}
+	return ;
+
+}
+
+void dumpEIT(unsigned char *ptr, int serv_id, int original_network_id, int transport_stream_id, EIT_CONTROL *eittop)
+{
+
+	EIThead  eith;
+	EITbody  eitb;
+	SEVTdesc sevtd;
+
+	EEVTDhead eevthead;
+	EEVTDitem eevtitem;
+	EEVTDtail eevttail;
+
+	EEVTDitem save_eevtitem;
+
+	EIT_CONTROL	*cur ;
+	EIT_CONTROL	*curtmp ;
+
+	int len = 0;
+	int loop_len = 0;
+	int loop_blen = 0;
+	int loop_elen = 0;
+	int str_alen = 0;
+
+	int ehh, emm, ess;
+
+	/* EIT */
+	len = parseEIThead(ptr, &eith); 
+
+	ptr += len;
+	loop_len = eith.section_length - (len - 3 + 4); // 3¤Ï¶¦Ḁ̈إåÀĹ 4¤ÏCRC
+	while(loop_len > 0) {
+		/* Ϣ³¤¹¤ë³ÈÄ¥¥¤¥Ù¥ó¥È¤Ï¡¢´Á»ú¥³¡¼¥É¤¬µã¤­Ê̤줷¤Æ
+		   ʬ³ä¤µ¤ì¤ë¤è¤¦¤À¡£Ï¢Â³¤«¤É¤¦¤«¤Ï¡¢item_description_length¤¬
+		   ÀßÄꤵ¤ì¤Æ¤¤¤ë¤«¤É¤¦¤«¤ÇȽÃǤǤ­¤ë¤è¤¦¤À¡£ */
+		memset(&save_eevtitem, 0, sizeof(EEVTDitem));
+
+		len = parseEITbody(ptr, &eitb);
+		ptr += len;
+		loop_len -= len;
+    
+		/* printf("evtid:%d\n", eitb.event_id); */
+    
+		loop_blen = eitb.descriptors_loop_length;
+		loop_len -= loop_blen;
+		while(loop_blen > 0) {
+
+/*yukikaze-test*/
+			//printf("desc_tag");
+			//int itt=getBit(*ptr,0,8);
+			//printf("%x",itt);
+
+			len = parseSEVTdesc(ptr, &sevtd);
+			if(len > 0) {
+
+				/*
+				  if(eith.service_id == 19304 && 
+				  eitb.event_id == 46564) {
+				  printf("aa");
+				  }
+				*/
+
+				ehh = eitb.hh;
+				emm = eitb.hm;
+				ess = eitb.ss;
+				if(eith.service_id != serv_id){
+					ptr += len;
+					loop_blen -= len;
+					continue ;
+				}
+
+				timecmp(&ehh, &emm, &ess,
+						eitb.dhh, eitb.dhm, eitb.dss);
+				cur = searcheit(eittop, eith.service_id, eitb.event_id);
+				if(cur == NULL){
+					curtmp = NULL;
+					cur = calloc(1, sizeof(EIT_CONTROL));
+				}
+				else {
+					curtmp = cur;
+				}
+				cur->event_id = eitb.event_id ;
+				cur->servid = eith.service_id ;
+				cur->title = calloc(1, (strlen(sevtd.event_name) + 1));
+
+				memcpy(cur->title, sevtd.event_name, strlen(sevtd.event_name));
+				cur->subtitle = calloc(1, (strlen(sevtd.text) + 1));
+				memcpy(cur->subtitle, sevtd.text, strlen(sevtd.text));
+				cur->yy = eitb.yy;
+				cur->mm = eitb.mm;
+				cur->dd = eitb.dd;
+				cur->hh = eitb.hh;
+				cur->hm = eitb.hm;
+				cur->ss = eitb.ss;
+				cur->ehh = eitb.dhh;
+				cur->emm = eitb.dhm;
+				cur->ess = eitb.dss ;
+				cur->table_id = eith.table_id ;
+				if ( !curtmp ) enqueue(eittop, cur);
+			} else {
+				len = parseEEVTDhead(ptr, &eevthead);
+
+				/*
+				  if(eith.service_id == 19304 && 
+				  eitb.event_id == 46564) {
+				  printf("aa");
+				  }
+				*/
+
+				if(len > 0) {
+					ptr += len;
+					loop_blen -= len;
+
+					loop_elen = eevthead.length_of_items;
+					loop_len -= loop_elen;
+					while(loop_elen > 0) {
+						len = parseEEVTDitem(ptr, &eevtitem);
+
+						ptr += len;
+						loop_elen -= len;
+						loop_blen -= len;
+                                                
+						if (1||checkEEVTDitem(&save_eevtitem, &eevtitem,
+										  eevthead.descriptor_number)) {
+#if 0
+							{
+                                                            if (eevtitem.descriptor_number>0){
+                                                                //printf("descriptor_num %d\n",eevtitem.descriptor_number);
+                                                            }
+
+                                                            /* long format */
+                                                            //printf("descriptor_num %d\n",eevtitem.descriptor_number);
+#if 1
+                                                            printf("EEVT,%d,%d,%d,%s,%s\n",
+										eith.service_id,
+                                                                			eitb.event_id,
+                                                                			eevtitem.descriptor_number, // ÂàÈò¹àÌÜ
+										eevtitem.item_description,
+										eevtitem.item);
+#endif
+
+							}
+#endif
+							cur = searcheit(eittop, eith.service_id, eitb.event_id);
+							if(cur == NULL){
+								curtmp = NULL;
+								cur = calloc(1, sizeof(EIT_CONTROL));
+							}
+							else {
+								curtmp = cur;
+							}
+
+#if 1
+							if ( cur->desc ) {
+								str_alen = strlen( cur->desc );
+							}
+							else {
+								str_alen = 0;
+							}
+							eevtitem.item_description_length = strlen(eevtitem.item_description);
+							eevtitem.item_length = strlen(eevtitem.item);
+							cur->desc = realloc(cur->desc, str_alen + eevtitem.item_description_length + eevtitem.item_length + 1000);
+							if ( !str_alen ) *cur->desc = '\0';
+
+							if ( eevtitem.item_description_length && !strstr(cur->desc, eevtitem.item_description) ) {
+								strcat(cur->desc, eevtitem.item_description);
+								strcat(cur->desc, "\t");
+							}
+
+							if ( eevtitem.item_length && !strstr(cur->desc, eevtitem.item)  ) {
+								strcat(cur->desc, eevtitem.item);
+								strcat(cur->desc, "\\n");
+							}
+#endif
+							if ( !curtmp ) enqueue(eittop, cur);
+						}
+					}
+
+					len = parseEEVTDtail(ptr, &eevttail);
+#if 0
+					{ /* long format */
+						printf("EEVTt,%d,%d,%d,%s\n", 
+								eith.service_id,
+								eitb.event_id,
+								eevthead.descriptor_number,
+								eevttail.text);
+					}
+#endif
+				} else {
+					ContentDesc contentDesc;
+					len = parseContentDesc(ptr, &contentDesc);
+					if (len > 0) {
+						int header_printed = 0;
+						for (int i = 0; i < contentDesc.descriptor_length - 1; i+=2) {
+							/*
+							if (0xff == (unsigned char)contentDesc.content[i])
+								continue;
+							*/
+#if 0
+							if (!header_printed) {
+								fprintf(out, "Content,%d,%d",
+									eith.service_id,
+									eitb.event_id);
+								header_printed = 1;
+							}
+#endif
+
+#if 0
+							fprintf(out, ",%02x%02x", (unsigned char)contentDesc.content[i], (unsigned char)contentDesc.content[i+1]);
+#endif
+						}
+						if((eith.original_network_id == original_network_id) && (eith.transport_stream_id == transport_stream_id)){
+							cur = searcheit(eittop, eith.service_id, eitb.event_id);
+							if(cur != NULL){
+								cur->content_type = (unsigned char)(contentDesc.content[0] >> 4);
+#if 0
+								fprintf(stdout, "%s:", cur->title);
+								fprintf(stdout, ",%02x%02x", (unsigned char)contentDesc.content[0], (unsigned char)contentDesc.content[1]);
+								fprintf(stdout, ",%02x%02x\n", (unsigned char)contentDesc.content[2], (unsigned char)contentDesc.content[3]);
+#endif
+
+							}
+#if 0
+							if (header_printed) {
+								fprintf(out, "\n");
+							}
+#endif
+						}
+					} else {
+						SeriesDesc seriesDesc;
+						len = parseSeriesDesc(ptr, &seriesDesc);
+						if (len > 0) {
+#if 0
+							printf("Series,%d,%d,series=%d,repeat=%01x,pattern=%d,expire_valid=%d,expire=%04x,epinum=%d,lastepinum=%d,%s\n",
+								eith.service_id,
+								eitb.event_id,
+								seriesDesc.series_id,
+								seriesDesc.repeat_label,
+								seriesDesc.program_pattern,
+								seriesDesc.expire_date_valid_flag,
+								seriesDesc.expire_date,
+								seriesDesc.episode_number,
+								seriesDesc.last_episode_number,
+								seriesDesc.series_name_char);
+#endif
+						} else {
+							len = parseOTHERdesc(ptr);
+						}
+					}
+				}
+			}
+			ptr += len;
+			loop_blen -= len;
+		}
+		/* ºÇ¸å¤Î¥Ö¥ì¡¼¥¯¥Á¥§¥Ã¥¯ */
+    
+		if(checkEEVTDitem(&save_eevtitem, NULL, 0)) {
+#if 0
+			if(mode == 1) { /* long format */
+				fprintf(out, "EEVT,%d,%d,%d,%s,%s\n", 
+						eith.service_id,
+						eitb.event_id,
+						save_eevtitem.descriptor_number,
+						save_eevtitem.item_description,
+						save_eevtitem.item);
+			}
+#endif
+		}
+	}
+
+	return;
+}
+
+void timecmp(int *thh, int *tmm, int *tss,
+			 int dhh, int dmm, int dss) {
+
+	int ama;
+
+	*tss += dss;
+	ama = *tss % 60;
+	*tmm += (*tss / 60);
+	*tss = ama;
+
+	*tmm += dmm;
+	ama   = *tmm % 60;
+	*thh += (*tmm / 60);
+	*tmm  = ama;
+
+	*thh += dhh;
+
+}