root/trunk/epgdumpr2/sdt.c

リビジョン 136, 4.5 kB (コミッタ: sorshi, コミット時期: 15 年 前)

foltiaで利用しているepgdumpを追加

Line 
1 #include <stdio.h>
2 #include <stdlib.h>
3 #include <string.h>
4
5 #include "sdt.h"
6 #include "ts_ctl.h"
7
8 int parseSDThead(unsigned char *data, SDThead *h) {
9         int boff = 0;
10
11         memset(h, 0, sizeof(SDThead));
12
13         boff = 0;
14         h->table_id = getBit(data, &boff, 8);
15         h->section_syntax_indicator = getBit(data, &boff, 1);
16         h->reserved_future_use1 = getBit(data, &boff, 1);
17         h->reserved1 = getBit(data, &boff, 2);
18         h->section_length = getBit(data, &boff, 12);
19         h->transport_stream_id = getBit(data, &boff, 16);
20         h->reserved2 = getBit(data, &boff, 2);
21         h->version_number = getBit(data, &boff, 5);
22         h->current_next_indicator = getBit(data, &boff, 1);
23         h->section_number = getBit(data, &boff, 8);
24         h->last_section_number = getBit(data, &boff, 8);
25         h->original_network_id = getBit(data, &boff, 16);
26         h->reserved_future_use2 = getBit(data, &boff, 8);
27
28         return 11;
29 }
30
31 int parseSDTbody(unsigned char *data, SDTbody *b) {
32         int boff = 0;
33
34         memset(b, 0, sizeof(SDTbody));
35
36         b->service_id = getBit(data, &boff, 16);
37         b->reserved_future_use1 = getBit(data, &boff, 3);
38         b->EIT_user_defined_flags = getBit(data, &boff, 3);
39         b->EIT_schedule_flag = getBit(data, &boff, 1);
40         b->EIT_present_following_flag = getBit(data, &boff, 1);
41         b->running_status = getBit(data, &boff, 3);
42         b->free_CA_mode = getBit(data, &boff, 1);
43         b->descriptors_loop_length = getBit(data, &boff, 12);
44
45         return 5;
46 }
47
48 int parseSVCdesc(unsigned char *data, SVCdesc *desc) {
49         int boff = 0;
50  
51         memset(desc, 0, sizeof(SVCdesc));
52
53         desc->descriptor_tag = getBit(data, &boff, 8);
54         desc->descriptor_length = getBit(data, &boff, 8);
55         desc->service_type = getBit(data, &boff, 8);
56         desc->service_provider_name_length = getBit(data, &boff, 8);
57         getStr(desc->service_provider_name, data, &boff, desc->service_provider_name_length);
58         desc->service_name_length = getBit(data, &boff, 8);
59         getStr(desc->service_name, data, &boff, desc->service_name_length);
60
61         return desc->descriptor_length + 2;
62 }
63 int             serachid(SVT_CONTROL *top, int service_id)
64 {
65         SVT_CONTROL     *cur = top ;
66         while(cur != NULL){
67                 if(cur->event_id == service_id){
68                         return 1 ;
69                 }
70                 cur = cur->next ;
71         }
72         return 0 ;
73 }
74
75 void    enqueue_sdt(SVT_CONTROL *top, SVT_CONTROL *sdtptr)
76 {
77         SVT_CONTROL     *cur ;
78
79         if(top->next == NULL){
80                 top->next = sdtptr ;
81                 top->prev = top ;
82                 return ;
83         }
84         cur = top->next ;
85         while(cur != NULL){
86                 if(sdtptr->event_id < cur->event_id){
87                         if(cur->prev != NULL){
88                                 cur->prev->next = sdtptr ;
89                                 sdtptr->prev = cur->prev ;
90                         }
91                         cur->prev = sdtptr ;
92                         sdtptr->next = cur ;
93                         return ;
94                 }
95                 if(cur->next == NULL){
96                         cur->next = sdtptr ;
97                         sdtptr->prev = cur ;
98                         return ;
99                 }
100                 cur = cur->next ;
101         }
102         return ;
103
104 }
105
106 void dumpSDT(unsigned char *ptr, SVT_CONTROL *top)
107 {
108
109         SDThead  sdth;
110         SDTbody  sdtb;
111         SVCdesc  desc;
112         SVT_CONTROL     *svtptr ;
113         int             rc ;
114
115         int len = 0;
116         int loop_len = 0;
117
118         /* SDT */
119         len = parseSDThead(ptr, &sdth);
120         ptr += len;
121         loop_len = sdth.section_length - (len - 3 + 4); // 3�����������4��RC
122         while(loop_len > 0) {
123                 len = parseSDTbody(ptr, &sdtb);
124                 ptr += len;
125                 loop_len -= len;
126                 parseSVCdesc(ptr, &desc);
127
128                 rc = serachid(top, sdtb.service_id);
129                 if(rc == 0){
130                         svtptr = calloc(1, sizeof(SVT_CONTROL));
131                         svtptr->event_id = sdtb.service_id;
132                         svtptr->original_network_id = sdth.original_network_id;
133                         svtptr->transport_stream_id = sdth.transport_stream_id;
134                         svtptr->event_id = sdtb.service_id;
135                         memcpy(svtptr->servicename, desc.service_name, strlen(desc.service_name));
136                         enqueue_sdt(top, svtptr);
137 #if 0
138                         printf("SDT=%s,%d,%x,%x,%x,%x,%x,%x,%x\n",
139                                 desc.service_name, sdtb.service_id, sdtb.reserved_future_use1,
140                                 sdtb.EIT_user_defined_flags, sdtb.EIT_schedule_flag, sdtb.EIT_present_following_flag,
141                                 sdtb.running_status, sdtb.free_CA_mode, sdtb.descriptors_loop_length);
142 /*
143 #else
144 0x01:����帥�TV�泣����
145 0xA5:����≪��激��恰���泣����
146 0x0C:����帥��若��� */
147                         printf("SDT=(%x:%x)%s,%d,%d,%d,%d,%d(%d,%x,%x,%x,%x,%x,%x,%x,%x,%x,%x,%x,%x,%x)\n",
148                                         sdth.table_id, desc.service_type,
149                                         desc.service_name, sdtb.service_id,
150                                         desc.descriptor_tag, desc.descriptor_length, desc.service_type,
151                                         desc.service_provider_name_length, desc.service_name_length,
152                                         sdth.table_id, sdth.section_syntax_indicator, sdth.reserved_future_use1,
153                                         sdth.reserved1, sdth.section_length, sdth.transport_stream_id,
154                                         sdth.reserved2, sdth.version_number, sdth.current_next_indicator,
155                                         sdth.section_number, sdth.last_section_number, sdth.original_network_id,
156                                         sdth.reserved_future_use2);
157 #endif
158                 }
159
160                 ptr += sdtb.descriptors_loop_length;
161                 loop_len -= sdtb.descriptors_loop_length;
162         }
163  
164         return;
165 }
Note: リポジトリブラウザについてのヘルプは TracBrowser を参照してください。
track feed