-
Notifications
You must be signed in to change notification settings - Fork 0
/
eit_txtout.cpp
1841 lines (1730 loc) · 56 KB
/
eit_txtout.cpp
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
757
758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
821
822
823
824
825
826
827
828
829
830
831
832
833
834
835
836
837
838
839
840
841
842
843
844
845
846
847
848
849
850
851
852
853
854
855
856
857
858
859
860
861
862
863
864
865
866
867
868
869
870
871
872
873
874
875
876
877
878
879
880
881
882
883
884
885
886
887
888
889
890
891
892
893
894
895
896
897
898
899
900
901
902
903
904
905
906
907
908
909
910
911
912
913
914
915
916
917
918
919
920
921
922
923
924
925
926
927
928
929
930
931
932
933
934
935
936
937
938
939
940
941
942
943
944
945
946
947
948
949
950
951
952
953
954
955
956
957
958
959
960
961
962
963
964
965
966
967
968
969
970
971
972
973
974
975
976
977
978
979
980
981
982
983
984
985
986
987
988
989
990
991
992
993
994
995
996
997
998
999
1000
// TsEITRead.cpp : コンソール アプリケーションのエントリ ポイントを定義します。
//
#include "stdafx.h"
#include "tsdata.h"
#include "ts_sidef.h"
#include "ts_packet.h"
#include "wingetopt.h"
//TODO: -C (range) 【特殊】(output)がテキストファイルではなく、入力TSファイルの指定した範囲を切り取ったものになります
// (range)は(start_packet_idx):(end_packet_idx)
using namespace std;
#define STR_STL_LOCALE "japanese" // STLのlocaleに渡す文字列
#define MAX_PID_NUM 8192
//#define _TEST_USE_FS_
// mainの返り値
enum
{
ERR_PARAM = 1,
ERR_INPUTFILE,
ERR_OUTPUTFILE,
ERR_NOTOT,
ERR_NOPAT,
ERR_NOSDT,
};
// PID毎のセクションバッファ
// mapを使ってもメモリ節約量は知れてるので配列で持つ
static CSectionBuf *ev_pSectionBuf[MAX_PID_NUM];
static UINT64 ev_BefSectionFilePos[MAX_PID_NUM]; // 以前のファイル位置(先頭:1)。packet単位(byte単位ではない)
static UINT64 ev_cur_filepos; // 現在のファイル位置(先頭:1)。packet単位(byte単位ではない)
// オプションパラメータ
enum E_READ_SIZE{RS_SIZE,RS_RATIO,RS_SEC,};
static bool ev_opt_is_out_patpmt = false; // PAT/PMTを出力する？
static bool ev_opt_is_all_out = false; // 全サービス/イベント情報を出力する？
static bool ev_opt_is_out_extevt = false; // 拡張形式イベント記述子を出力する？
static int ev_opt_offset_read = 0; // 読み込みオフセット
static bool ev_opt_offset_read_is_ratio = false;
static int ev_opt_max_read_size = 0; // 最大読み込みサイズ(*188*1000byte)
static E_READ_SIZE ev_opt_max_read_type = RS_SIZE;
static int ev_opt_offset_beg = 0; // 開始オフセット秒数
static int ev_opt_offset_end = 0; // 終了オフセット秒数
static bool ev_opt_read_eit_sch = false; // EIT(スケジュール)を読み込む？
static bool ev_opt_verbose = false; // 詳細出力モード
static bool ev_opt_no_progress = false; // 進捗表示を出さない
static bool ev_opt_outtime_offset = false; //
static int ev_opt_evt_output_type = 0;
static const TCHAR *ev_opt_input_fname = NULL; // 現在処理してるTSファイル名(デバッグログ用に)
static const TCHAR *ev_opt_output_fname = NULL; // 出力ファイル
static const TCHAR *ev_opt_dbgout_fname = NULL;
static const TCHAR *ev_opt_dbglog_fname = NULL;
//
static bool ev_dbglog_flg = false; // デバッグログフラグ。まだ1回も出力してない時FALSE
static tostream *ev_ps_dbglog = NULL; // デバッグログ出力用ストリーム
// TSファイル内の番組情報バッファリング用
static vector<CPAT> ev_pats;
static vector<CEIT*> ev_peits; // たくさん持つ可能性があり、insertとかの実行コストがバカにならないんで、ポインタで持つ
static vector<CSDT*> ev_psdts; // 同上
static vector<CPMT> ev_pmts;
static vector<CTOT> ev_tots; // 2個だけ保持する
// eit1 < eit2の時 trueを返す
static bool _compare_eit(const CEIT *eit1, const CEIT *eit2)
{
const CServiceInfo *p = eit2;
return eit1->CompareTo( p, true ) > 0;
}
// pmt1 < pmt2の時 trueを返す
static bool _compare_pmt(const CPMT &pmt1, const CPMT &pmt2)
{
const CServiceInfo *p = &pmt2;
return pmt1.CompareTo( p, true ) > 0;
}
// sdt1 < sdt2の時 trueを返す
static bool _compare_sdt(const CSDT *sdt1, const CSDT *sdt2)
{
const CServiceInfo *p = sdt2;
return sdt1->CompareTo( p, true ) > 0;
}
// 返り値：以下のいずれか。CRCエラーとかあった場合は後続パケットがあるはず
enum eSECTION_RET
{
SEC_NG_NEXT = 0, // NG。次パケット要求
SEC_OK_END, // OK。セクションデータ終了
SEC_OK_RETRY, // OK。
};
static eSECTION_RET _dump_section_data(const CPacket &packet, CSectionBuf *p_sec_buf, bool is_read_eit_sch)
{
eSECTION_RET ret = SEC_NG_NEXT;
size_t sec_len = 0;
int dbg_flg = 0; // デバッグ用フラグ
switch ( packet.header.pid )
{
case PID_PAT:
// 簡易的に末尾の
if ( ev_pats.size() == 0
|| ev_pats.back().version != CServiceInfo::GetVersion(p_sec_buf->GetData())
|| ev_pats.back().id != CServiceInfo::GetID(p_sec_buf->GetData())
)
{
CPAT pat;
if ( pat.SetData( p_sec_buf->GetData() ) )
{
ev_pats.push_back( pat );
sec_len = pat.GetBodySize();
ret = SEC_OK_END;
}
}
else
return SEC_OK_END; // 重複データなので処理済みにしとく
break;
case PID_EIT_0:
case PID_EIT_1:
case PID_EIT_2:
{
//CEIT eit;
CEIT *peit = new CEIT();
bool is_ignore;
if ( peit->SetData( p_sec_buf->GetData(), !is_read_eit_sch, &is_ignore ) )
{
//#ifdef _DEBUG
#if 0
if ( peit->transport_stream_id == 16625 && peit->id == 101 && peit->table_id == 0x58 )
{
DBG_LOG_WARN( _T("version:%2d section:%3d segment_last:%3d last_section:%3d length:%4d\n"),
peit->version, peit->section, peit->segment_last_section_number, peit->last_section, peit->length );
// _CrtDbgBreak();
}
#endif
sec_len = peit->GetBodySize();
if ( !is_ignore )
{
vector<CEIT*>::iterator pos = ev_peits.end();
if ( ev_peits.size() > 0 )
pos = lower_bound( ev_peits.begin(), ev_peits.end(), peit, _compare_eit );
int idx = pos - ev_peits.begin();
if ( pos == ev_peits.end() )
{
ev_peits.push_back( peit );
dbg_flg = 1;
}
else if ( (*pos)->CompareTo( peit, true ) == 0 )
{
(*pos)->AddData( *peit );
// イベントテーブルのないものに付いてはEITテーブルには入れない
if ( (*pos)->IsFullProcSection() && (*pos)->event_tbl.size() == 0 )
{
delete ev_peits[idx];
ev_peits.erase( pos );
}
dbg_flg = 2;
delete peit;
}
else
{
ev_peits.insert( pos, peit );
dbg_flg = 3;
}
}
else
delete peit;
ret = SEC_OK_END;
}
else
{
ret = SEC_NG_NEXT;
delete peit;
}
}
break;
case PID_TOT:
{
CTOT tot;
if ( tot.SetData( p_sec_buf->GetData() ) )
{
// 先頭時刻の挿入または追加
if ( ev_tots.size() == 0 )
ev_tots.push_back( tot );
else if ( ev_tots.size() > 1 && tot.jst_time < ev_tots[0].jst_time )
{
ev_tots.erase( ev_tots.begin() );
ev_tots.insert( ev_tots.begin(), tot );
_ASSERT( FALSE ); // 時系列に並んでるはずなんで、一応警告
}
// 末尾時刻の追加
if ( ev_tots.size() < 2 )
{
ev_tots.push_back( tot );
}
else if ( tot.jst_time > ev_tots[1].jst_time )
{
ev_tots.pop_back();
ev_tots.push_back( tot );
}
else
_ASSERT( FALSE );
sec_len = tot.GetBodySize();
_ASSERT( ev_tots.size() <= 2 );
ret = SEC_OK_END;
}
}
break;
case PID_SIT:
//
break;
case PID_SDT:
{
CSDT *psdt = new CSDT();
if ( psdt->SetData( p_sec_buf->GetData() ) )
{
vector<CSDT*>::iterator pos = ev_psdts.end();
sec_len = psdt->GetBodySize();
if ( ev_psdts.size() > 0 )
pos = lower_bound( ev_psdts.begin(), ev_psdts.end(), psdt, _compare_sdt );
if ( pos == ev_psdts.end() )
{
ev_psdts.push_back( psdt );
}
else if ( (*pos)->CompareTo( psdt, true ) == 0 )
{
(*pos)->AddData( *psdt );
delete psdt;
}
else
{
ev_psdts.insert( pos, psdt );
}
ret = SEC_OK_END;
}
else
{
ret = SEC_NG_NEXT;
delete psdt;
}
}
break;
default:
if ( ev_opt_is_out_patpmt )
{
CPMT pmt;
pmt.m_self_pid = packet.header.pid;
pmt.m_file_pos = ev_cur_filepos;
if ( pmt.SetData( p_sec_buf->GetData() ) )
{
vector<CPMT>::iterator pos = ev_pmts.end();
if ( ev_pmts.size() > 0 )
pos = lower_bound( ev_pmts.begin(), ev_pmts.end(), pmt, _compare_pmt );
if ( pos == ev_pmts.end() )
ev_pmts.push_back( pmt );
else if ( pos->CompareTo( &pmt, true ) == 0 )
{
pos->AddData( pmt );
}
else
ev_pmts.insert( pos, pmt );
sec_len = pmt.GetBodySize();
ret = SEC_OK_END;
}
else
ret = SEC_NG_NEXT;
}
break;
}
if ( sec_len && p_sec_buf->GetData().size() > sec_len + 4 )
{
int last_pt = sec_len + 4;
VECT_UINT8::const_iterator it = p_sec_buf->GetData().begin() + last_pt;
if ( *it != 0xFF )
{
// 続く場合。
VECT_UINT8 dmy_buf;
dmy_buf.push_back( 0 ); // ポインターフィールドを先頭に挿入
std::copy( it, p_sec_buf->GetData().end(), back_inserter(dmy_buf) );
p_sec_buf->ClearData();
p_sec_buf->AddData( packet.header.index, &dmy_buf[0], &dmy_buf[0] + dmy_buf.size() );
return SEC_OK_RETRY;
}
else
int iii = 0;
}
return ret;
}
// イベント大分類文字列取得
static const TCHAR* _get_genre_lvl1_str(int genre)
{
static const TCHAR *c_lvl1_str[] = {
_T("ニュース／報道"), // 0x0
_T("スポーツ"), // 0x1
_T("情報／ワイドショー"), // 0x2
_T("ドラマ"), // 0x3
_T("音楽"), // 0x4
_T("バラエティ"), // 0x5
_T("映画"), // 0x6
_T("アニメ／特撮"), // 0x7
_T("ドキュメンタリー／教養"), // 0x8
_T("劇場／公演"), // 0x9
_T("趣味／教育"), // 0xA
_T("福祉"), // 0xB
_T("予備"), // 0xC
_T("予備"), // 0xD
_T("拡張"), // 0xE
_T("その他 "), // 0xF
_T("ジャンル指定なし"),
};
_ASSERT( sizeof(c_lvl1_str) / sizeof(c_lvl1_str[0]) == 0x11 );
if ( genre < 0 )
return c_lvl1_str[0x10];
else
return c_lvl1_str[(genre>>4)&0xF];
}
// イベント中分類文字列取得
static const TCHAR* _get_genre_lvl2_str(int genre)
{
static const TCHAR *c_lvl2_str[] = {
_T("定時・総合"), // 0x0 0x0
_T("天気"), // 0x0 0x1
_T("特集・ドキュメント"), // 0x0 0x2
_T("政治・国会"), // 0x0 0x3
_T("経済・市況"), // 0x0 0x4
_T("海外・国際"), // 0x0 0x5
_T("解説"), // 0x0 0x6
_T("討論・会談"), // 0x0 0x7
_T("報道特番"), // 0x0 0x8
_T("ローカル・地域"), // 0x0 0x9
_T("交通"), // 0x0 0xA
_T(""), // 0x0 0xB
_T(""), // 0x0 0xC
_T(""), // 0x0 0xD
_T(""), // 0x0 0xE
_T("その他"), // 0x0 0xF
_T("スポーツニュース"), // 0x1 0x0
_T("野球"), // 0x1 0x1
_T("サッカー"), // 0x1 0x2
_T("ゴルフ"), // 0x1 0x3
_T("その他の球技"), // 0x1 0x4
_T("相撲・格闘技"), // 0x1 0x5
_T("オリンピック・国際大会"), // 0x1 0x6
_T("マラソン・陸上・水泳"), // 0x1 0x7
_T("モータースポーツ"), // 0x1 0x8
_T("マリン・ウィンタースポーツ"), // 0x1 0x9
_T("競馬・公営競技"), // 0x1 0xA
_T(""), // 0x1 0xB
_T(""), // 0x1 0xC
_T(""), // 0x1 0xD
_T(""), // 0x1 0xE
_T("その他"), // 0x1 0xF
_T("芸能・ワイドショー"), // 0x2 0x0
_T("ファッション"), // 0x2 0x1
_T("暮らし・住まい"), // 0x2 0x2
_T("健康・医療"), // 0x2 0x3
_T("ショッピング・通販"), // 0x2 0x4
_T("グルメ・料理"), // 0x2 0x5
_T("イベント"), // 0x2 0x6
_T("番組紹介・お知らせ"), // 0x2 0x7
_T(""), // 0x2 0x8
_T(""), // 0x2 0x9
_T(""), // 0x2 0xA
_T(""), // 0x2 0xB
_T(""), // 0x2 0xC
_T(""), // 0x2 0xD
_T(""), // 0x2 0xE
_T("その他"), // 0x2 0xF
_T("国内ドラマ"), // 0x3 0x0
_T("海外ドラマ"), // 0x3 0x1
_T("時代劇"), // 0x3 0x2
_T(""), // 0x3 0x3
_T(""), // 0x3 0x4
_T(""), // 0x3 0x5
_T(""), // 0x3 0x6
_T(""), // 0x3 0x7
_T(""), // 0x3 0x8
_T(""), // 0x3 0x9
_T(""), // 0x3 0xA
_T(""), // 0x3 0xB
_T(""), // 0x3 0xC
_T(""), // 0x3 0xD
_T(""), // 0x3 0xE
_T("その他"), // 0x3 0xF
_T("国内ロック・ポップス"), // 0x4 0x0
_T("海外ロック・ポップス"), // 0x4 0x1
_T("クラシック・オペラ"), // 0x4 0x2
_T("ジャズ・フュージョン"), // 0x4 0x3
_T("歌謡曲・演歌"), // 0x4 0x4
_T("ライブ・コンサート"), // 0x4 0x5
_T("ランキング・リクエスト"), // 0x4 0x6
_T("カラオケ・のど自慢"), // 0x4 0x7
_T("民謡・邦楽"), // 0x4 0x8
_T("童謡・キッズ"), // 0x4 0x9
_T("民族音楽・ワールドミュージック"), // 0x4 0xA
_T(""), // 0x4 0xB
_T(""), // 0x4 0xC
_T(""), // 0x4 0xD
_T(""), // 0x4 0xE
_T("その他"), // 0x4 0xF
_T("クイズ"), // 0x5 0x0
_T("ゲーム"), // 0x5 0x1
_T("トークバラエティ"), // 0x5 0x2
_T("お笑い・コメディ"), // 0x5 0x3
_T("音楽バラエティ"), // 0x5 0x4
_T("旅バラエティ"), // 0x5 0x5
_T("料理バラエティ"), // 0x5 0x6
_T(""), // 0x5 0x7
_T(""), // 0x5 0x8
_T(""), // 0x5 0x9
_T(""), // 0x5 0xA
_T(""), // 0x5 0xB
_T(""), // 0x5 0xC
_T(""), // 0x5 0xD
_T(""), // 0x5 0xE
_T("その他"), // 0x5 0xF
_T("洋画"), // 0x6 0x0
_T("邦画"), // 0x6 0x1
_T("アニメ"), // 0x6 0x2
_T(""), // 0x6 0x3
_T(""), // 0x6 0x4
_T(""), // 0x6 0x5
_T(""), // 0x6 0x6
_T(""), // 0x6 0x7
_T(""), // 0x6 0x8
_T(""), // 0x6 0x9
_T(""), // 0x6 0xA
_T(""), // 0x6 0xB
_T(""), // 0x6 0xC
_T(""), // 0x6 0xD
_T(""), // 0x6 0xE
_T("その他"), // 0x6 0xF
_T("国内アニメ"), // 0x7 0x0
_T("海外アニメ"), // 0x7 0x1
_T("特撮"), // 0x7 0x2
_T(""), // 0x7 0x3
_T(""), // 0x7 0x4
_T(""), // 0x7 0x5
_T(""), // 0x7 0x6
_T(""), // 0x7 0x7
_T(""), // 0x7 0x8
_T(""), // 0x7 0x9
_T(""), // 0x7 0xA
_T(""), // 0x7 0xB
_T(""), // 0x7 0xC
_T(""), // 0x7 0xD
_T(""), // 0x7 0xE
_T("その他"), // 0x7 0xF
_T("社会・時事"), // 0x8 0x0
_T("歴史・紀行"), // 0x8 0x1
_T("自然・動物・環境"), // 0x8 0x2
_T("宇宙・科学・医学"), // 0x8 0x3
_T("カルチャー・伝統文化"), // 0x8 0x4
_T("文学・文芸"), // 0x8 0x5
_T("スポーツ"), // 0x8 0x6
_T("ドキュメンタリー全般"), // 0x8 0x7
_T("インタビュー・討論"), // 0x8 0x8
_T(""), // 0x8 0x9
_T(""), // 0x8 0xA
_T(""), // 0x8 0xB
_T(""), // 0x8 0xC
_T(""), // 0x8 0xD
_T(""), // 0x8 0xE
_T("その他"), // 0x8 0xF
_T("現代劇・新劇"), // 0x9 0x0
_T("ミュージカル"), // 0x9 0x1
_T("ダンス・バレエ"), // 0x9 0x2
_T("落語・演芸"), // 0x9 0x3
_T("歌舞伎・古典"), // 0x9 0x4
_T(""), // 0x9 0x5
_T(""), // 0x9 0x6
_T(""), // 0x9 0x7
_T(""), // 0x9 0x8
_T(""), // 0x9 0x9
_T(""), // 0x9 0xA
_T(""), // 0x9 0xB
_T(""), // 0x9 0xC
_T(""), // 0x9 0xD
_T(""), // 0x9 0xE
_T("その他"), // 0x9 0xF
_T("旅・釣り・アウトドア"), // 0xA 0x0
_T("園芸・ペット・手芸"), // 0xA 0x1
_T("音楽・美術・工芸"), // 0xA 0x2
_T("囲碁・将棋"), // 0xA 0x3
_T("麻雀・パチンコ"), // 0xA 0x4
_T("車・オートバイ"), // 0xA 0x5
_T("コンピュータ・ＴＶゲーム"), // 0xA 0x6
_T("会話・語学"), // 0xA 0x7
_T("幼児・小学生"), // 0xA 0x8
_T("中学生・高校生"), // 0xA 0x9
_T("大学生・受験"), // 0xA 0xA
_T("生涯教育・資格"), // 0xA 0xB
_T("教育問題"), // 0xA 0xC
_T(""), // 0xA 0xD
_T(""), // 0xA 0xE
_T("その他"), // 0xA 0xF
_T("高齢者"), // 0xB 0x0
_T("障害者"), // 0xB 0x1
_T("社会福祉"), // 0xB 0x2
_T("ボランティア"), // 0xB 0x3
_T("手話"), // 0xB 0x4
_T("文字（字幕）"), // 0xB 0x5
_T("音声解説"), // 0xB 0x6
_T(""), // 0xB 0x7
_T(""), // 0xB 0x8
_T(""), // 0xB 0x9
_T(""), // 0xB 0xA
_T(""), // 0xB 0xB
_T(""), // 0xB 0xC
_T(""), // 0xB 0xD
_T(""), // 0xB 0xE
_T("その他"), // 0xB 0xF
_T(""), // 0xC 0x0
_T(""), // 0xC 0x1
_T(""), // 0xC 0x2
_T(""), // 0xC 0x3
_T(""), // 0xC 0x4
_T(""), // 0xC 0x5
_T(""), // 0xC 0x6
_T(""), // 0xC 0x7
_T(""), // 0xC 0x8
_T(""), // 0xC 0x9
_T(""), // 0xC 0xA
_T(""), // 0xC 0xB
_T(""), // 0xC 0xC
_T(""), // 0xC 0xD
_T(""), // 0xC 0xE
_T(""), // 0xC 0xF
_T(""), // 0xD 0x0
_T(""), // 0xD 0x1
_T(""), // 0xD 0x2
_T(""), // 0xD 0x3
_T(""), // 0xD 0x4
_T(""), // 0xD 0x5
_T(""), // 0xD 0x6
_T(""), // 0xD 0x7
_T(""), // 0xD 0x8
_T(""), // 0xD 0x9
_T(""), // 0xD 0xA
_T(""), // 0xD 0xB
_T(""), // 0xD 0xC
_T(""), // 0xD 0xD
_T(""), // 0xD 0xE
_T(""), // 0xD 0xF
_T("BS/地上デジタル放送用番組付属情報"), // 0xE 0x0
_T("広帯域 CSデジタル放送用拡張"), // 0xE 0x1
_T("衛星デジタル音声放送用拡張"), // 0xE 0x2
_T("サーバー型番組付属情報"), // 0xE 0x3
_T("IP放送用番組付属情報"), // 0xE 0x4
_T(""), // 0xE 0x5
_T(""), // 0xE 0x6
_T(""), // 0xE 0x7
_T(""), // 0xE 0x8
_T(""), // 0xE 0x9
_T(""), // 0xE 0xA
_T(""), // 0xE 0xB
_T(""), // 0xE 0xC
_T(""), // 0xE 0xD
_T(""), // 0xE 0xE
_T(""), // 0xE 0xF
_T(""), // 0xF 0x0
_T(""), // 0xF 0x1
_T(""), // 0xF 0x2
_T(""), // 0xF 0x3
_T(""), // 0xF 0x4
_T(""), // 0xF 0x5
_T(""), // 0xF 0x6
_T(""), // 0xF 0x7
_T(""), // 0xF 0x8
_T(""), // 0xF 0x9
_T(""), // 0xF 0xA
_T(""), // 0xF 0xB
_T(""), // 0xF 0xC
_T(""), // 0xF 0xD
_T(""), // 0xF 0xE
_T("その他"), // 0xF 0xF
};
static const TCHAR *c_undefined_str = _T("未定義");
static const TCHAR *c_unassign_str = _T("");
_ASSERT( sizeof(c_lvl2_str) / sizeof(c_lvl2_str[0]) == 0x100 );
if ( genre < 0 )
return c_unassign_str;
else
{
const TCHAR *pret = c_lvl2_str[genre&0xFF];
if ( !*pret || !pret ) // ""の場合、未定義
return c_undefined_str;
else
return pret;
}
}
static TCHAR *_get_datetime_str(time_t tt)
{
static TCHAR sz_tbuf[64];
_tcsftime( sz_tbuf, 64, _T("%Y/%m/%d %H:%M:%S"), localtime(&tt) );
return sz_tbuf;
}
static UINT64 _make_key( int network_id, int transport_id, int service_id)
{
UINT64 key = network_id;
key <<= 16;
key |= transport_id;
key <<= 16;
key |= service_id;
return key;
}
// SDT内サービスを探す。
// 見つからなかったとき
// SDTに該当項目がない →ev_psdtの最初の項目のservices.end()
// services配列内に項目がない →ev_psdtの最後の項目のservices.end()
// ev_psdtsの項目数0でないこと前提
static bool _find_sdt_svc(int network_id, int transport_id, int service_id, CSDT::VECT_SERV::iterator &it)
{
CSDT key;
key.id = transport_id;
key.original_network_id = network_id;
key.table_id = -1; // network_id,id(transport_id)が等しい最初の項目を返すようにするため。CSDT::CompareTo()の実装依存なんであまりよろしくない
vector<CSDT*>::iterator p = lower_bound( ev_psdts.begin(), ev_psdts.end(), &key, _compare_sdt );
if ( p == ev_psdts.end() || (*p)->id != transport_id || (*p)->original_network_id != network_id )
{
return false;
}
for ( ; p != ev_psdts.end(); ++p )
{
CSDT *psdt = *p;
if ( psdt->original_network_id != network_id || psdt->id != transport_id )
break;
for ( CSDT::VECT_SERV::iterator is = psdt->services.begin(); is != psdt->services.end(); ++is )
{
if ( is->service_id == service_id )
{
// 発見。複数あった場合、後のSDTを検索した方がいい？？
it = is;
return true;
}
}
}
return false;
}
static SServiceInfo* _make_program_info(MAP_SERV &services, const CEIT *peit, time_t tot_start, time_t tot_end)
{
SServiceInfo *psvc;
{
UINT64 map_key = _make_key( peit->original_network_id, peit->transport_stream_id, peit->id );
MAP_SERV::_Pairib pib = services.insert( MAP_SERV::value_type( map_key, SServiceInfo() ) );
psvc = &pib.first->second;
if ( pib.second )
{ // 新規登録時
// メンバ初期化
psvc->network_id = peit->original_network_id;
psvc->transport_id = peit->transport_stream_id;
psvc->service_id = peit->id;
// 該当サービスのSDTを検索し、名前などをセットする
CSDT::VECT_SERV::iterator is;
if ( !_find_sdt_svc( psvc->network_id, psvc->transport_id, psvc->service_id, is ) )
{
DBG_LOG_ASSERT( _T("\rnetwork_id:%d trans_id:%d svc_id:%dのSDT/Serviceがない\n"), psvc->network_id, psvc->transport_id, psvc->service_id );
}
else
{
for ( VECT_DESC::iterator iv = is->descriptors.begin(); iv != is->descriptors.end(); ++iv )
{
switch ( iv->tag )
{
case DSCTAG_SERVICE:
{
CServiceDesc desc(*iv);
psvc->prov_name = desc.service_provider_name;
psvc->name = desc.service_name;
psvc->service_type = desc.service_type;
goto end_serv_find_loop;
}
}
}
end_serv_find_loop:
;
}
}
}
for ( vector<CEIT::CEvent>::const_iterator ie = peit->event_tbl.begin(); ie != peit->event_tbl.end(); ie++ )
{
bool b_add_prg = false;
time_t t_start, t_end;
tm tm_b;
_convert_time_jst40( ie->start_time, tm_b );
t_start = mktime( &tm_b );
_convert_time_bcd( ie->duration, tm_b );
t_end = t_start + tm_b.tm_hour * 3600 + tm_b.tm_min * 60 + tm_b.tm_sec;
if ( ev_opt_is_all_out )
b_add_prg = true;
else
{
// tot_start～tot_endの期間にt_start、t_endがはいってるか
if ( t_start < tot_start )
b_add_prg = tot_start <= t_end;
else
b_add_prg = t_start <= tot_end;
}
if ( b_add_prg )
{
SProgramInfo *pprg;
{
MAP_PRG::_Pairib pib = psvc->programs.insert( MAP_PRG::value_type( ie->event_id, SProgramInfo() ) );
pprg = &pib.first->second;
if ( pib.second )
{ // 新規登録時、メンバを初期化
pprg->event_id = ie->event_id;
pprg->start_time = t_start;
pprg->end_time = t_end;
pprg->genre = -1;
pprg->flg = 0;
pprg->stream_content = -1;
pprg->component_type = -1;
pprg->ext_evt_flg = 0;
}
}
const int prg_all_flg = 4;
// スケジュール系と現在/次の番組系でevent_idが重複する可能性有り。
// 何回もセットすると遅いかもしれないんで、既に設定した情報はセットしないようにする
// 高々２回しかセットしない(筈)なので、気にしなくてもいいかもしんない(^_^;
if ( pprg->flg ^ ((1<<prg_all_flg)-1) )
{
for ( VECT_DESC::const_iterator id = ie->descriptors.begin(); id != ie->descriptors.end(); id++ )
{
try
{
switch ( id->tag )
{
case DSCTAG_SHORTEVT:
if ( !(pprg->flg & (1<<0)) )
{
CShortEventDesc dsc(*id);
pprg->name_str = dsc.name_str;
pprg->desc_str = dsc.desc_str;
if ( dsc.name_str.length() > 0 && dsc.desc_str.length() > 0 )
pprg->flg |= 1<<0;
}
break;
case DSCTAG_CONTENT:
if ( !(pprg->flg & (1<<1)) )
{
CContentDesc dsc(*id);
pprg->genre = (dsc.content_nibble_level_1<<4) | dsc.content_nibble_level_2;
pprg->flg |= 1<<1;
}
break;
case DSCTAG_COMPONENT:
if ( !(pprg->flg & (1<<2)) )
{
CComponentDesc dsc(*id);
pprg->stream_content = dsc.stream_content;
pprg->component_type = dsc.component_type;
pprg->flg |= 1<<2;
}
break;
case DSCTAG_EXTEVT:
if ( !(pprg->flg & (1<<3)) )
{
CExtEventDesc dsc(*id);
static VECT_UINT8 *st_p_prev_dat = NULL; // 項目名空白の拡張記述はその前の項目ありの記述からつながるみたい。
// staticにせんとforループの外で宣言しとけば良いような気もする。
for ( CExtEventDesc::VECT_ITEM::iterator ix = dsc.items.begin(); ix != dsc.items.end(); ++ix )
{
if ( (*ix).description.length() > 0 || !st_p_prev_dat )
{
CNTR_EXTEV::_Pairib pib = pprg->ext_evts.insert( CNTR_EXTEV::value_type((*ix).description, VECT_UINT8()) );
VECT_UINT8 &data = (*pib.first).second;
// 項目記述を末尾に追加
copy( (*ix).text.begin(), (*ix).text.end(), back_inserter(data) );
st_p_prev_dat = &data;
}
else
{
// 前の項目記述の末尾に追加
copy( (*ix).text.begin(), (*ix).text.end(), back_inserter(*st_p_prev_dat) );
}
}
if ( dsc.text.size() > 0 )
{
CNTR_EXTEV::_Pairib pib = pprg->ext_evts.insert( CNTR_EXTEV::value_type(_T(""), VECT_UINT8()) );
VECT_UINT8 &data = (*pib.first).second;
copy( dsc.text.begin(), dsc.text.end(), back_inserter(data) );
}
pprg->ext_evt_flg |= (1<<dsc.descriptor_number);
// 全部の拡張形式イベント記述子を処理したら項目セットビットを立てる。
// 同じイベントIDで別内容の拡張形式イベント記述子が来たら、それは無視される(いいのかな？)
if ( !(pprg->ext_evt_flg ^ ((1<<(dsc.last_descriptor_number+1))-1)) )
{
pprg->flg |= 1<<3;
st_p_prev_dat = NULL;
}
}
break;
// 他の記述子を追加する場合、prg_all_flgを増やして、pprg->flgで立てるビットを他と重複しないようにすること
}
}
catch (CDefExcept &d)
{
DBG_LOG_ASSERT( _T("\rservice:%d event:%d dscidx:%d %s\n"),
psvc->service_id, pprg->event_id, id - ie->descriptors.begin(), d.str_msg );
}
}
}
}
}
return psvc;
}
static bool _compare_prg(const MAP_PRG::const_iterator &it1, const MAP_PRG::const_iterator &it2)
{
return it1->second.start_time < it2->second.start_time;
}
// 情報の構成
// lpszFileName 出力ファイル名
// time_offset_out TOT出力時にオフセット影響を受ける？
// offset_beg 開始時間オフセット(秒)
// offset_end 終了時間オフセット(秒)
static int _output_program_info(tofstream &ofs)
{
MAP_SERV services;
// 通常TIME_JST40の比較だけでいけると思うが、0:00を跨ぐとおかしくなりそうなので、time_tで時間比較する
time_t tot_start, tot_end;
if ( ev_pats.size() == 0 )
return ERR_NOPAT;
else if ( ev_tots.size() < 2 )
return ERR_NOTOT;
else if ( ev_psdts.size() == 0 )
return ERR_NOSDT;
tot_start = ev_tots[0].m_time;
tot_end = ev_tots[1].m_time;
if ( tot_start + ev_opt_offset_beg > tot_end - ev_opt_offset_end )
{ // TS秒数が少なすぎる場合、start/endの中間値を取る
time_t t_dummy = (tot_start+tot_end)/2;
tot_start = tot_end = t_dummy;
}
else
{
tot_start += ev_opt_offset_beg;
tot_end -= ev_opt_offset_end;
}
clock_t clk_st = clock();
if ( ev_opt_is_all_out )
{
for ( vector<CEIT*>::iterator ie = ev_peits.begin(); ie != ev_peits.end(); ++ie )
_make_program_info( services, *ie, tot_start, tot_end );
}
else
{
for ( vector<CPAT>::iterator ip = ev_pats.begin(); ip != ev_pats.end(); ip++ )
{
for ( VECT_UINT16::iterator ipp = ip->prg_nos.begin(); ipp != ip->prg_nos.end(); ipp++ )
{
vector<CEIT*>::iterator pos;
SServiceInfo *psvc;
{
CEIT key;
key.transport_stream_id = ip->id;
key.id = *ipp;
key.original_network_id = 0; // transport_id,id(service_id)が等しい最初の項目を返すようにするため。CEIT::CompareTo()の実装依存なんであまりよろしくない
pos = lower_bound(ev_peits.begin(), ev_peits.end(), &key, _compare_eit );
if ( pos == ev_peits.end() || (*pos)->id != key.id )
{
// SDT内サービスを検索してEITがないのが正しいのかを一応確認。network_idは適当にセット
CSDT::VECT_SERV::iterator p;
bool flg = false;
if ( _find_sdt_svc( ev_peits.front()->original_network_id, key.transport_stream_id, key.id, p ) )
{
if ( !p->eit_present_following_flag && (!ev_opt_read_eit_sch || !p->eit_schedule_flag) )
flg = true;
}
if ( !flg )
DBG_LOG_ASSERT( _T("\rtrans_id:%d svc_id:%dのSDTがないので、EIT存在しないのが正しいかどうか判別できない\n"), ip->id, *ipp );
continue;
}
}
do
{
psvc = _make_program_info( services, *pos, tot_start, tot_end );
pos++;
}
while (pos != ev_peits.end()
&& (*pos)->id == psvc->service_id
&& (*pos)->transport_stream_id == psvc->transport_id
&& (*pos)->original_network_id == psvc->network_id );
}
}
// SProgramInfoがないSServiceInfoを削除する
{
MAP_SERV::iterator p = services.begin();
while ( p != services.end() )
{
if ( p->second.programs.size() == 0 )
p = services.erase( p );
else
p++;
}
}
}
//DBG_LOG_WARN( _T("make_prg:%.2f\n"), static_cast<double>(clock() - clk_st) / CLOCKS_PER_SEC );
//----------
clk_st = clock();
#ifdef _TEST_USE_FS_
tofstream& tss = ofs;
#else
tstrstream tss;
#endif
//----------
tss << _T("TOT");
if ( !ev_opt_outtime_offset )
{
tss << _T("\t") << _get_datetime_str(ev_tots[0].m_time);
tss << _T("\t") << _get_datetime_str(ev_tots[1].m_time);
}
else
{
tss << _T("\t") << _get_datetime_str(tot_start);
tss << _T("\t") << _get_datetime_str(tot_end);
}
tss << endl;
if ( ev_opt_is_out_patpmt )
{
for ( vector<CPAT>::iterator ip = ev_pats.begin(); ip != ev_pats.end(); ip++ )
{
_ASSERT( ip->prg_nos.size() == ip->prg_map_pids.size() );
for ( size_t i = 0; i < ip->prg_nos.size(); i++ )
{
tss << _T("PAT");
tss << _T("\t") << ip - ev_pats.begin();
tss << _T("\t") << ip->id;
tss << _T("\t") << i;
tss << _T("\t") << ip->prg_nos[i];
tss << _T("\t") << ip->prg_map_pids[i];
tss << endl;
}
}
int i = 0;
for ( vector<CPMT>::iterator im = ev_pmts.begin(); im != ev_pmts.end(); im++ )
{
for ( CPMT::VECT_STRM::iterator is = im->stream_tbl.begin(); is != im->stream_tbl.end(); is++ )
{
tss << _T("PMT1");
tss << _T("\t") << i;
tss << _T("\t") << im->m_self_pid;
tss << _T("\t") << im->id;
tss << _T("\t") << is - im->stream_tbl.begin();
tss << _T("\t") << is->stream_type;
tss << _T("\t") << is->elementary_pid;
tss << endl;