'Program Lang./C++' 카테고리의 글 목록 (3 Page)

std::function 정리

Program Lang./C++ 2017. 1. 2. 11:15

1. std::function 개요

기존 함수포인터의 개념을 확장한 것이다. c++11이후부터는 callable target이 아래와 같이 다양해졌다.

따라서 기존 함수포인터만으로는 이를 cover할 수 없고, 보다 일반화된 개념이 필요해지면서

std::function이 새롭게 나온 것이다.

std::function이 처리할 수 있는 callable target은 아래와 같다.

function (일반함수)
lambda expression
bind expression
function object (함수 객체)
class 내의 맴버함수 및 맴버 변수

2. usage

선언하고 사용하는 방법에 대해서 아래와 같이 정리한다.

#include <functional>

std::function<리턴타입(입력 파라미터들)> 변수

void print(int a, int b);

ex) std::function<void(int, int)> fp = print;

3. 테스트 코드

각 callable target에 대한 사용법을 예제를 통해서 알아본다.

#include <iostream>
#include <functional>

using std::placeholders::_1;

void print_number(int i)
{
	std::cout << i << std::endl;
}

void print_sum(int a, int b)
{
	std::cout << a + b << std::endl;
}

struct PrintNum
{
	void operator()(int i) const
	{
		std::cout << i << std::endl;
	}
};

struct Foo 
{
    Foo(int num) : num_(num) {}
    void print_add(int i) const { std::cout << num_+i << '\n'; }
    int num_;
};

int main()
{
	// 1. function (일반함수)
	std::function<void(int)> f1 = print_number;
	f1(10); // 10을 출력
	
	// 2. lambda expression
	std::function<void(int)> f2 = [](int a){ print_number(a);};
	f2(10); // 10을 출력

// 3. bind expression
	std::function<void(int)> f3 = std::bind(print_sum, 10, _1);
	f3(20); // a = 10, b = 20, a + b = 30출력
	
	// 4. function object
	std::function<void(int)> f4 = PrintNum(); // 생성자호출로 함수객체 생성
	f4(10); // 10 출력, 생성된 함수객체의 operator()를 호출
	
	// 5. 객체의 맴버함수
	// 반드시 생성된 객체가 있어야 사용할 수 있다.
	const Foo foo(10); // const 맴버함수를 호출하려고 하니, const로 객체 생성
	// Foo foo(10); 의 경우로 만들때, 맴버함수의 const를 제거해야 한다.
	std::function<void(const Foo&, int)> f5 = &Foo::print_add;
	f5(foo, 10); // 20 출력
	
	// 6.1. bind + 맴버함수 경우, 생성된 객체를 참조로 넘기는 방법
	std::function<void(int)> f6 = std::bind(&Foo::print_add, &foo, _1);
	f6(10); // 20 출력
	
	// 6.2. bind + 맴버함수 경우, 생성된 객체를 복사로 넘긴다.
	std::function<void(int)> f7 = std::bind(&Foo::print_add, foo, _1);
	f7(10); // 20 출력
	
	// 6.3. 맴버변수
	std::function<int(Foo const&)> f8 = &Foo::num_;
	std::cout << f8(foo) << std::endl;
	
	return 0;
}

4. 결론

c++11 이후에서 class를 설계할 때, 기존에 함수포인터를 이용했다면 이제 std::function으로 모두

통일하는 것이 c++ 철학에 맞는 구현 방식이다.

'Program Lang. > C++' 카테고리의 다른 글

[json-c] simple generator json ojbect (0)	2017.01.09
[json-c] simple parsing example (0)	2017.01.09
unique_ptr, shared_ptr 읽히기 (0)	2016.12.30
c++ pair 읽히기 (0)	2016.12.30
full version (pat, pmt, sdt) (2)	2016.07.22

:

unique_ptr, shared_ptr 읽히기

Program Lang./C++ 2016. 12. 30. 14:45

1. 목적

c++ unique_ptr, shared_ptr 개인적인 정리

2. shared_ptr

C++98 표준안까지 사용되던 auto_ptr은 이제 더 이상 사용하지 않는 것이 권고 사항이다. C++11부터 지원하는 share_ptr을 간단히 말하면 객체의 자동 파괴를 수행하기 위해서 도입된 smart pointer 이다. 하지만 몇 가지 제약 사항은 여전히 존재한다. 제약 사항은 아래에서 하나씩 살펴보도록 하자.

일반적인 사용법은 테스트 코드에 주석으로 표기하였다. 자세한 사항은 standard 생성자 overriding을 참조하면 된다.

다만 주의해야 할 사항은 대입 연산은 explicit으로 처리되어 있기 때문에 암시적 대입연산은 동작하지 않는다.

또한 make_shared<> utility를 사용하는 것이 성능면에서 좋다.

2.1. shared_ptr 예제 (제약 사항 예제)

The C++ Standard Library 책의 예제는 너무 복잡하고 딱히 와 닿지도 않아서 어떤 블로그 소스 참조

하나의 객체에 대해서 서로 다른 shared_ptr로 참조하게 되면 소멸된 객체에 다시 소멸자를 호출하게 되어서 알 수 없는 동작을 수행하게 된다.

#include <iostream> #include <memory> #include <string> class Person { public: std::string name; //std::shared_ptr<Person> mfriend; std::weak_ptr<Person> mfriend; Person(const std::string& _name) : name(_name) { std::cout << __FUNCTION__ << ", " << __LINE__ << std::endl; } virtual ~Person() { std::cout << __FUNCTION__ << ", " << __LINE__ << std::endl; } }; int main() { // 임시객체 생성 Person *pPerson = new Person("heesoon.kim"); std::shared_ptr<Person> p1(pPerson , [](Person *p) { std::cout << "delete : " << p->name << std::endl; delete p; }); std::shared_ptr<Person> p2(pPerson, [](Person *p) { std::cout << "delete : " << p->name << std::endl; delete p; }); return 0; }

<실행결과>

Start

Person, 14
delete : heesoon.kim
~Person, 18
delete : heesoon.kim

Segmentation fault

Finish

순환 참조의 문제점을 보여주는 예제로 weak_ptr<Person> 주석을 막고 shared_ptr<Person>을 사용하면 소멸자가 호출되지 않는다. 결론적으로 객체가 정상적으로 파괴되지 않는 문제가 발생한다.

#include <iostream>
#include <memory>
#include <vector>
#include <string>

class Person
{
public:
    std::string name;
    //std::shared_ptr<Person> mfriend;
    std::weak_ptr<Person> mfriend;
    
    Person(const std::string& _name) : name(_name) {
        std::cout << __FUNCTION__ << ", " << __LINE__ << std::endl;
    }
    
    virtual ~Person() {
        std::cout << __FUNCTION__ << ", " << __LINE__ << std::endl;
    }
};

int main()
{
    // 1. default shared_ptr usage
    //std::shared_ptr<Person> kim(new Person("kim"));
    //std::shared_ptr<Person> lee(new Person("lee"));
    
    // 2. user define delete function
    std::shared_ptr<Person> kim(new Person("kim"), [](Person *p) {
        std::cout << "delete : " << p->name << std::endl;
        delete p;
    });
    
    std::shared_ptr<Person> lee(new Person("lee"), [](Person *p) {
        std::cout << "delete : " << p->name << std::endl;
        delete p;
    });
    
    // 3. using utility make_shared usage
    //std::shared_ptr<Person> kim = std::make_shared<Person>("kim");
    //std::shared_ptr<Person> lee = std::make_shared<Person>("lee");
    
    std::cout << "( " << kim.use_count() << ", " << lee.use_count() << ")" << std::endl;
    kim->mfriend = lee;
    std::cout << "( " << kim.use_count() << ", " << lee.use_count() << ")" << std::endl;
    lee->mfriend = kim;
    std::cout << "( " << kim.use_count() << ", " << lee.use_count() << ")" << std::endl;
    
    return 0;
}

2.3. shared_ptr 예제 (제약 사항 예제)

smart pointer라고는 하지만 여전히 주의를 기울여야 할 것이 남아 있다. weak_ptr은 shared_ptr의 reference_count를 늘리지 않지만 shared_ptr이 관리하는 객체를 공유한다. 객체의 자원 관리는 shared_ptr로 하되 객체에 접근하여 필요한 동작을 수행 시에는 weak_ptr로 하는 것이 바람직해 보인다.

'Program Lang. > C++' 카테고리의 다른 글

[json-c] simple parsing example (0)	2017.01.09
std::function 정리 (0)	2017.01.02
c++ pair 읽히기 (0)	2016.12.30
full version (pat, pmt, sdt) (2)	2016.07.22
sdt json version (0)	2016.07.22

:

c++ pair 읽히기

Program Lang./C++ 2016. 12. 30. 09:59

1. 목적

c++ map을 for_each 구문에서 쓰려고 하니까 pair 관련된 내용이 나와서 예제 짜보고 읽히기로 함.

2. 테스트 코드

std:pair을 사용하기 위해서는 두 개의 입력 요소를 하나의 요소로 만들어 주는 make_pair 구문과 같이

봐서 사용법을 읽히는 것이 좋을 것 같다.

아래 코드에서 for_each 문 안에 함수 포인터로 등록된 함수를 실행하기 위해서 item.second이 아닌

item.second()로 호출해야 하는 문법적인 근거를 모르겠다. 이래 저래 삽질하다가 함수 객채 호출 시에

사용하는 문법처럼 해 봤는데 동작은 하는데 모르겠네.

아시는 분은 댓글 부탁 드립니다.

3. 테스트 코드 실행

단순히 vector에 등록된 두 개의 debug 메뉴를 실행한다. 따라서 Hellow World와 내 이름을 차례되로 찍는다.

'Program Lang. > C++' 카테고리의 다른 글

std::function 정리 (0)	2017.01.02
unique_ptr, shared_ptr 읽히기 (0)	2016.12.30
full version (pat, pmt, sdt) (2)	2016.07.22
sdt json version (0)	2016.07.22
pmt json version (0)	2016.07.22

:

full version (pat, pmt, sdt)

Program Lang./C++ 2016. 7. 22. 12:43

처음 해보려고 한 목적은 개발 중에 필드에서 Stream 이상한 것이 많다.

이런 것들 항상 자기 컴에 복사해서 분석기로 돌려서 보고, 분석하지만 분석기가 동작이 제 각각이고 내가 보고 싶은 부분만

빨리 보고 싶은데 그러기도 힘들고 분석 후에 파일의 사후 관리도 안된다.

따라서 중앙 서버에 모든 파일을 두고 여기서 돌리고 브라우져로 결과를 보면 스트림 관리가 편하지 않을까 생각해서

해보려고 했다. 하지만 현실의 벽이 높다.

지금까지 작업을 수행했던 Section, PAT, PMT, SDT parser의 full version 정리

여기에 CAT, TDT, TOT, NIT, EIT 까지 붙이면 좋을텐데 시간이 되면 해야 할 것 같다.

올해 처음 생긴 5년마다의 안식년 휴가 3주 동안 이 모든 것을 하기에는 시간이 부족하다.

같이 공부하고 연구하는 사람이 있으면 좋을텐데, 회사의 개발자들은 별로 자기 개발에 의지가 없는듯.

혼자 하는 수 밖에. 난 오늘도 도서관 꼭대기 에어콘도 들어오지 않는 곳에서 열심히 열공 중이다. ㅠ.ㅠ

1. 소스 트리

지금까지 작업한 모든 소스 한 곳에 모았다. javascript folder는 실행결과를 web browser에서

확인하기 위해서 APM 설치 후에 기본 서비스 폴더에 복사해 넣으면 된다.

.

├── CMakeLists.txt

├── javascript

│ ├── css

│ │ ├── images

│ │ │ ├── ajax-loader.gif

│ │ │ ├── file.gif

│ │ │ ├── folder-closed.gif

│ │ │ ├── folder.gif

│ │ │ ├── minus.gif

│ │ │ ├── plus.gif

│ │ │ ├── treeview-black-line.gif

│ │ │ ├── treeview-black.gif

│ │ │ ├── treeview-default-line.gif

│ │ │ ├── treeview-default.gif

│ │ │ ├── treeview-famfamfam-line.gif

│ │ │ ├── treeview-famfamfam.gif

│ │ │ ├── treeview-gray-line.gif

│ │ │ ├── treeview-gray.gif

│ │ │ ├── treeview-red-line.gif

│ │ │ └── treeview-red.gif

│ │ ├── jquery.treeview.css

│ │ └── screen.css

│ ├── index.html

│ ├── lib

│ │ ├── jquery.cookie.js

│ │ ├── jquery.js

│ │ └── jquery.treeview.js

│ ├── pat_json.txt

│ ├── pmt_json.txt

│ └── sdt_json.txt

├── json_spirit

│ ├── CMakeFiles

│ │ ├── CMakeDirectoryInformation.cmake

│ │ ├── json_spirit.dir

│ │ │ ├── CXX.includecache

│ │ │ ├── DependInfo.cmake

│ │ │ ├── build.make

│ │ │ ├── cmake_clean.cmake

│ │ │ ├── cmake_clean_target.cmake

│ │ │ ├── depend.internal

│ │ │ ├── depend.make

│ │ │ ├── flags.make

│ │ │ ├── json_spirit_reader.cpp.o

│ │ │ ├── json_spirit_value.cpp.o

│ │ │ ├── json_spirit_writer.cpp.o

│ │ │ ├── link.txt

│ │ │ └── progress.make

│ │ └── progress.marks

│ ├── CMakeLists.txt

│ ├── Makefile

│ ├── cmake_install.cmake

│ ├── json_spirit.h

│ ├── json_spirit.vcproj

│ ├── json_spirit_error_position.h

│ ├── json_spirit_reader.cpp

│ ├── json_spirit_reader.h

│ ├── json_spirit_reader_template.h

│ ├── json_spirit_stream_reader.h

│ ├── json_spirit_utils.h

│ ├── json_spirit_value.cpp

│ ├── json_spirit_value.h

│ ├── json_spirit_writer.cpp

│ ├── json_spirit_writer.h

│ ├── json_spirit_writer_options.h

│ ├── json_spirit_writer_template.h

│ └── libjson_spirit.a

├── pat.cpp

├── pat.h

├── pmt.cpp

├── pmt.h

├── psi_glob.h

├── remove.sh

├── sdt.cpp

├── sdt.h

├── section.cpp

├── section.h

├── test.cpp

└── types.h

2. 헤더 파일

너무 많아서 github link 내의 소스 참조

3. 클래스 본체

너무 많아서 github link 내의 소스 참조.

4. 테스트 코드

실제 TS 파일을 사용자로부터 받아서 처리해야 하는데, 귀찮으니까 그냥 SGP.ts로 고정.

차후 IP Multicast Stream 받을 수 있도록 붙이면 고려해 볼 생각.

처음에는 Message Queue로 Section에서는 던지고 Parser쪽에서는 받아서 처리하려고 했는데

의미 없어 보여서 생략. Message Queue 동작은 github test folder에 정리했다.

#include <thread> #include "section.h" #include "pat.h" #include "pmt.h" #include "sdt.h" int main(int argc, char* argv[]) { SECTION_INFO_T sec; CSection* section = new CSection(); PAT* pat = new PAT(); PMT* pmt = new PMT(); SDT* sdt = new SDT(); // open media test, media is file section->openMedia("file://SGP.ts"); // create task to read continously std::thread tr = std::thread([&]() { while(1) { if(section->readMedia(&sec) == RESULT_NOTOK) break; // PAT parsing PAT PID is zero if(sec.pid == 0) { pat->parsingPATSection((UINT8*)sec.section); } else if(pat->isPmtPid(sec.pid) == true) { // current pid is pmt pid pmt->parsingPMTSection(sec.pid, (UINT8*)sec.section); } else if(sdt->isSDTSecton(sec.pid) == true) { sdt->parsingSDTSection((UINT8*)sec.section); } } }); tr.join(); // get PAT info pat->printPATList(); pat->savePatToJson(); // get PMT info pmt->printPMTList(); pmt->savePmtToJson(); // get SDT info sdt->printSDTList(); sdt->saveSdtToJson(); delete section; delete pat; delete pmt; delete sdt; return 0; }

5. 전체 소스 (github link)

https://github.com/heesoon/mpeg/tree/master/full_version

'Program Lang. > C++' 카테고리의 다른 글

unique_ptr, shared_ptr 읽히기 (0)	2016.12.30
c++ pair 읽히기 (0)	2016.12.30
sdt json version (0)	2016.07.22
pmt json version (0)	2016.07.22
pat 정보를 json 파일로 저장 후 webbrowser에서 확인 (0)	2016.07.21

:

sdt json version

Program Lang./C++ 2016. 7. 22. 11:52

SDT 정보를 브라우져에 출력하기 위한 예제

웹브라우져에서 확인 테스트는 자바스크립트 탭에 정리한다.

1. 소스 트리

자세한 내용은 PAT에 정리되어 있다. 여기서 핵심은 boost spirit을 이용한 json 라이블러리의 사용이다.

PAT쪽에 정리되어 있으므로 여기서 생략하기로 하자.

2. 헤더 파일

json 파일로 저장하는 함수 하나 추가해서 일단 생략하고 전체 소스 링크 참조

3. 클래스 본체

json 포멧은 PAT과 동일하다. 일단 저장은 PAT과 동일한 형태로 저장하고 브라우져에 출력 시에

좀 더 분석기와 유사한 UI와 맞추기 위해서 조정을 할 필요는 있다.

void SDT::saveSdtToJson(void) { sdt_info_list.sort([](SDT_INFO_T& prog1, SDT_INFO_T& prog2) -> bool { return prog1.program_number < prog2.program_number; }); std::ofstream os("/Users/hskim/Sites/mpeg/sdt_json.txt"); json_spirit::Array sdtArr; for(auto list : sdt_info_list) { json_spirit::Object sdtObj; sdtObj.push_back(json_spirit::Pair("version", list.version)); sdtObj.push_back(json_spirit::Pair("section_number", list.section_number)); sdtObj.push_back(json_spirit::Pair("service_id", list.program_number)); sdtObj.push_back(json_spirit::Pair("EIT_schedule_flag", list.EIT_schedule_flag)); sdtObj.push_back(json_spirit::Pair("EIT_present_following_flag", list.EIT_present_following_flag)); sdtObj.push_back(json_spirit::Pair("running_status", list.running_status)); sdtObj.push_back(json_spirit::Pair("free_CA_mode", list.free_CA_mode)); sdtObj.push_back(json_spirit::Pair("servicProvideeName", list.servicProvideeName.c_str())); sdtObj.push_back(json_spirit::Pair("serviceName", list.serviceName.c_str())); sdtArr.push_back(sdtObj); } json_spirit::write_formatted(sdtArr, os); os.close(); }

4. 테스트 코드

#include <thread> #include "section.h" #include "sdt.h" int main(int argc, char* argv[]) { SECTION_INFO_T sec; CSection* section = new CSection(); SDT* sdt = new SDT(); // open media test, media is file section->openMedia("file://SGP.ts"); // create task to read continously std::thread tr = std::thread([&]() { while(1) { if(section->readMedia(&sec) == RESULT_NOTOK) break; // check SDT section if(sdt->isSDTSecton(sec.pid) == true) { sdt->parsingSDTSection((UINT8*)sec.section); } } }); tr.join(); sdt->printSDTList(); sdt->saveSdtToJson(); delete section; delete sdt; return 0; }

5. 실행 결과

[ { "version" : 1, "section_number" : 0, "service_id" : 208, "EIT_schedule_flag" : false, "EIT_present_following_flag" : true, "running_status" : 4, "free_CA_mode" : false, "servicProvideeName" : "MediaCorp TV", "serviceName" : "TV1_SD" }, { "version" : 1, "section_number" : 0, "service_id" : 209, "EIT_schedule_flag" : false, "EIT_present_following_flag" : true, "running_status" : 4, "free_CA_mode" : false, "servicProvideeName" : "MediaCorp TV", "serviceName" : "TV2_SD" }, { "version" : 1, "section_number" : 0, "service_id" : 210, "EIT_schedule_flag" : false, "EIT_present_following_flag" : true, "running_status" : 4, "free_CA_mode" : false, "servicProvideeName" : "MediaCorp TV", "serviceName" : "TV3_HD" }, { "version" : 1, "section_number" : 0, "service_id" : 211, "EIT_schedule_flag" : false, "EIT_present_following_flag" : true, "running_status" : 4, "free_CA_mode" : false, "servicProvideeName" : "MediaCorp TV", "serviceName" : "TV4_HD" }, { "version" : 1, "section_number" : 0, "service_id" : 212, "EIT_schedule_flag" : false, "EIT_present_following_flag" : true, "running_status" : 4, "free_CA_mode" : false, "servicProvideeName" : "MediaCorp TV", "serviceName" : "TV5_Radio" }, { "version" : 1, "section_number" : 0, "service_id" : 213, "EIT_schedule_flag" : false, "EIT_present_following_flag" : true, "running_status" : 4, "free_CA_mode" : false, "servicProvideeName" : "MediaCorp TV", "serviceName" : "TV6_Rad" } ]

6. 전체 소스 (github link, javascript는 없음.)

자사스크립트는 자바스크립트 탭에 정리

https://github.com/heesoon/mpeg/tree/master/test/sdt_json

'Program Lang. > C++' 카테고리의 다른 글

c++ pair 읽히기 (0)	2016.12.30
full version (pat, pmt, sdt) (2)	2016.07.22
pmt json version (0)	2016.07.22
pat 정보를 json 파일로 저장 후 webbrowser에서 확인 (0)	2016.07.21
5. sdt (service description table) class (0)	2016.07.20

:

pmt json version

Program Lang./C++ 2016. 7. 22. 10:16

PAT 정보를 Json 파일 포멧으로 저장 후에 웹브라우져에서 확인하는 것의 연장선으로 PMT 정보도 출력했다.

결국 json 형식으로 출력 및 자바스크립트에서 막히는 문제로 삽질을 했다.

웹브라우져에서 확인 테스트는 자바스크립트 탭에 정리한다.

1. 소스 트리

자세한 내용은 PAT에 정리되어 있다. 여기서 핵심은 boost spirit을 이용한 json 라이블러리의 사용이다.

PAT쪽에 정리되어 있으므로 여기서 생략하기로 하자.

2. 헤더 파일

json 파일로 저장하는 함수 하나 추가해서 일단 생략하고 전체 소스 링크 참조

3. 클래스 본체

json 포멧이 PAT보다 복잡해졌다.

전체 PMT정보를 감싸는 pmtArr라는 Object Array가 선언되어 있고 이 배열 안에

다시 Object + Array 형태로 저장이 되어 있는 구조이다.

이 구조가 맞는 것인지는 모르겠다. 인터넷 상에 찾아보고 동작은 잘되서 맞는 것 같은데

시간이 되면 좀 더 자세히 봐봐야겠다

void PMT::savePmtToJson(void)
{
	// sort by porgram number
	pmtList.sort([](PMT_INFO_T& prog1, PMT_INFO_T& prog2) 
					-> bool { return prog1.program_number < prog2.program_number; });

std::ofstream os("/Users/hskim/Sites/mpeg/pmt_json.txt");

json_spirit::Array pmtArr;

for(auto list : pmtList)
	{
		json_spirit::Object pmtObj;

pmtObj.push_back(json_spirit::Pair("version", list.version));
		pmtObj.push_back(json_spirit::Pair("section_number", list.section_number));
		pmtObj.push_back(json_spirit::Pair("program_number", list.program_number));
		pmtObj.push_back(json_spirit::Pair("pcr_pid", list.pcr_pid));

json_spirit::Array esArr;
		for(auto es_list : list.es_info)
		{
			json_spirit::Object esObj;

esObj.push_back(json_spirit::Pair("stream_type", es_list.stream_type));
			esObj.push_back(json_spirit::Pair("es_pid", es_list.es_pid));

esArr.push_back(esObj);
		}

pmtObj.push_back(json_spirit::Pair("esInfo", esArr));

pmtArr.push_back(pmtObj);
	}

json_spirit::write_formatted(pmtArr, os);

os.close();
}

4. 테스트 코드

5. 실행 결과

[
    {
        "version" : 1,
        "section_number" : 0,
        "program_number" : 208,
        "pcr_pid" : 260,
        "esInfo" : [
            {
                "stream_type" : 17,
                "es_pid" : 515
            },
            {
                "stream_type" : 17,
                "es_pid" : 514
            },
            {
                "stream_type" : 17,
                "es_pid" : 513
            },
            {
                "stream_type" : 17,
                "es_pid" : 516
            },
            {
                "stream_type" : 27,
                "es_pid" : 260
            },
            {
                "stream_type" : 6,
                "es_pid" : 103
            },
            {
                "stream_type" : 6,
                "es_pid" : 102
            },
            {
                "stream_type" : 6,
                "es_pid" : 101
            },
            {
                "stream_type" : 6,
                "es_pid" : 100
            }
        ]
    },
    {
        "version" : 1,
        "section_number" : 0,
        "program_number" : 209,
        "pcr_pid" : 259,
        "esInfo" : [
            {
                "stream_type" : 17,
                "es_pid" : 517
            },
            {
                "stream_type" : 17,
                "es_pid" : 513
            },
            {
                "stream_type" : 17,
                "es_pid" : 516
            },
            {
                "stream_type" : 27,
                "es_pid" : 259
            }
        ]
    },
    {
        "version" : 1,
        "section_number" : 0,
        "program_number" : 210,
        "pcr_pid" : 257,
        "esInfo" : [
            {
                "stream_type" : 17,
                "es_pid" : 513
            },
            {
                "stream_type" : 6,
                "es_pid" : 100
            },
            {
                "stream_type" : 17,
                "es_pid" : 516
            },
            {
                "stream_type" : 27,
                "es_pid" : 257
            }
        ]
    },
    {
        "version" : 1,
        "section_number" : 0,
        "program_number" : 211,
        "pcr_pid" : 258,
        "esInfo" : [
            {
                "stream_type" : 17,
                "es_pid" : 514
            },
            {
                "stream_type" : 17,
                "es_pid" : 517
            },
            {
                "stream_type" : 6,
                "es_pid" : 102
            },
            {
                "stream_type" : 17,
                "es_pid" : 514
            },
            {
                "stream_type" : 27,
                "es_pid" : 258
            }
        ]
    },
    {
        "version" : 1,
        "section_number" : 0,
        "program_number" : 212,
        "pcr_pid" : 514,
        "esInfo" : [
            {
                "stream_type" : 17,
                "es_pid" : 516
            },
            {
                "stream_type" : 17,
                "es_pid" : 514
            }
        ]
    },
    {
        "version" : 1,
        "section_number" : 0,
        "program_number" : 213,
        "pcr_pid" : 516,
        "esInfo" : [
            {
                "stream_type" : 17,
                "es_pid" : 516
            }
        ]
    }
]

6. 전체 소스 (github link, javascript는 없음.)

자사스크립트는 자바스크립트 탭에 정리

https://github.com/heesoon/mpeg/tree/master/test/pmt_json

'Program Lang. > C++' 카테고리의 다른 글

full version (pat, pmt, sdt) (2)	2016.07.22
sdt json version (0)	2016.07.22
pat 정보를 json 파일로 저장 후 webbrowser에서 확인 (0)	2016.07.21
5. sdt (service description table) class (0)	2016.07.20
4. pmt class (0)	2016.07.19

:

pat 정보를 json 파일로 저장 후 webbrowser에서 확인

Program Lang./C++ 2016. 7. 21. 18:57

앞 장에서 pat(program associate table)을 MySQL로 저장해서 확인해 보았지만 최종적으로 webbrower에서

확인하기에는 Node.js 같은 것을 붙여야 하고 일이 커져서 일단 아래와 같이 구현해 본다.

MFC 나 C#등을 이용해서 UI를 짜면 되지만 실제 보여주는 UI는 webbrowser에서 보여지는 것을 보고 싶다.

그래서 일단 c++ native application에서 pat 정보를 parsing완료하면 json 포멧으로

저장한다. 저장 위치는 webserver root directory 이다.

저장된 값은 webbrowser를 실행하고 해당 URL을 입력해서 출력되는 것을 확인한다.

1. 선수 작업

먼저 c++ json parser and writer가 필요하다. 난 boost spirit을 이용한다.

아래 참고 사이트에서 소스를 받아서 빌드하면 잘 된다. 난 cmake만을 사용하므로 cmake로 돌리고

헤더 파일과 static library만을 내 project에 포함시키고 아래 소스 트리에서 json_spirit 폴더에 해당함.

내 project CMakeLists.txt파일에서 json_spirit 헤더와 라이블러리 패스만 잡아줌.

json_spirit 폴더 내의 CMakeLists.txt 파일은 내꺼 프로젝트와 상관없고 원래 있었던 것으로 연동안됨.

2. 소스 트리

.

├── CMakeLists.txt

├── json_spirit

│ ├── CMakeFiles

│ │ ├── CMakeDirectoryInformation.cmake

│ │ ├── json_spirit.dir

│ │ │ ├── CXX.includecache

│ │ │ ├── DependInfo.cmake

│ │ │ ├── build.make

│ │ │ ├── cmake_clean.cmake

│ │ │ ├── cmake_clean_target.cmake

│ │ │ ├── depend.internal

│ │ │ ├── depend.make

│ │ │ ├── flags.make

│ │ │ ├── json_spirit_reader.cpp.o

│ │ │ ├── json_spirit_value.cpp.o

│ │ │ ├── json_spirit_writer.cpp.o

│ │ │ ├── link.txt

│ │ │ └── progress.make

│ │ └── progress.marks

│ ├── CMakeLists.txt

│ ├── Makefile

│ ├── cmake_install.cmake

│ ├── json_spirit.h

│ ├── json_spirit.vcproj

│ ├── json_spirit_error_position.h

│ ├── json_spirit_reader.cpp

│ ├── json_spirit_reader.h

│ ├── json_spirit_reader_template.h

│ ├── json_spirit_stream_reader.h

│ ├── json_spirit_utils.h

│ ├── json_spirit_value.cpp

│ ├── json_spirit_value.h

│ ├── json_spirit_writer.cpp

│ ├── json_spirit_writer.h

│ ├── json_spirit_writer_options.h

│ ├── json_spirit_writer_template.h

│ └── libjson_spirit.a

├── pat.cpp

├── pat.h

├── pat_json.txt

├── psi_glob.h

├── remove.sh

├── section.cpp

├── section.h

├── test.cpp

└── types.h

3. 헤더 파일

보여지지 않는 파일은 기존 pat class와 동일하고 단지 변경 사항만 여기에 보여준다.

pat정보를 json으로 저장하기 위한 함수 선언이 추가되었다.

4. 본체

pat_json.txt 파일을 apache 서버 설정 루트 디렉토르로 만들어서 저장한다.

5. 테스트

webbrowser로 결과를 확인하는 내용은 아래 post에 정리해 두었다.

http://chipmaker.tistory.com/category/Program%20Lang./javascript/

6. pat_json.txt 파일 구조

6개의 프로그램 정보가 배열 형태의 json 포멧으로 저장되어 있다.

하나의 프로그램의 형식은 pat.h에 정의한 struct 구성과 동일하다.

7. 전체 소스 (github link)

https://github.com/heesoon/mpeg/tree/master/test/pat_json

8. 참고 자료

[boost spirit json parser and writer]

http://www.codeproject.com/Articles/20027/JSON-Spirit-A-C-JSON-Parser-Generator-Implemented

'Program Lang. > C++' 카테고리의 다른 글

sdt json version (0)	2016.07.22
pmt json version (0)	2016.07.22
5. sdt (service description table) class (0)	2016.07.20
4. pmt class (0)	2016.07.19
3. pat info. save to MySQL with cpp connector (0)	2016.07.19

:

5. sdt (service description table) class

Program Lang./C++ 2016. 7. 20. 19:17

이 장에서는 SDT (Service Description Table)에 대해서 알아보고, 구현 클래스를 살펴본다.

SDT는 MPEG-2 Part 2의 규격 사항은 아니다. MPEG System의 구성은 기본 골격은 MPEG에서 출발하고

세부적인 사항은 ATSC, DVB, ISDB의 형태로 나누어진다. SDT는 DVB에 해당하는 규격이고

요즘은 ATSC도 같이 보고 있지만 기존에 계속 DVB만해서 익숙한 것 위주로 구현해 본다.

SDT는 현재 방송되고 있는 방송사업자 정보나 방송 채널 이름 같은 정보를 얻어올 수 있다.

좀 세부적으로 들어가면 PAT에 있는 프로그램 갯수가 정말 정확할까? 이런 문제들이 속출하게된다.

테스트 코드에서 볼 수 있듯이 PMT를 parsing하기 위해서는 PAT가 먼저 parsing이 되어야 한다.

하지만 SDT의 경우에는 테스트 코드에서도 볼 수 있지만 PAT와 상관없이 바로 Section PID를 알고 있으므로

바로 PAT와 상관없이 Parsing할 수 있다.

여기서 복합적으로 성능을 올릴 수 있는 방법을 고민해 볼 수 있다. Chip의 특성을 잘 파악한다면

여러가지 복합적으로 생각해 볼 수 있다.

또한 SDT는 CI+와 직접적인 연관이 있다. 업체마다 구현은 다르겠지만 ...

상세하게 여기 기술하기에는 한계가 있다. 정보 유출로 걸릴까 무섭다.

1. 소스 트리

├── CMakeLists.txt

├── psi_glob.h

├── remove.sh

├── sdt.cpp

├── sdt.h

├── section.cpp

├── section.h

├── test.cpp

└── types.h

2. 헤더 파일

#ifndef __SDT_H__
#define __SDT_H__

#include <cstdio>
#include <iostream>
#include <string>
#include <memory>
#include <forward_list>
#include "types.h"
#include "psi_glob.h"

/* -------------------------------------------------------------------------------------------------------------------
	declare define
------------------------------------------------------------------------------------------------------------------- */
#define SDT_HEADER_SIZE		11

//#define PRINT_SDT_SECSION_HEADER
#ifdef PRINT_SDT_SECSION_HEADER
#define PRINT_SDT_INFO(x) std::printf("%30s = %10d [%#10x]\n", #x, x, x);
#else
#define PRINT_SDT_INFO(x)
#endif

#define SDT_ACTUAL_PID			0x11
#define SDT_ACTUAL_TABLE_ID		0x42 
/* -------------------------------------------------------------------------------------------------------------------
	declare class data
------------------------------------------------------------------------------------------------------------------- */
typedef struct
{
	UINT8 version;
	UINT8 section_number;
	UINT16 program_number;
	bool EIT_schedule_flag;
	bool EIT_present_following_flag;
	UINT8 running_status;
	bool free_CA_mode;
	std::string servicProvideeName;
	std::string serviceName;
} SDT_INFO_T;

class SDT
{

public :
	SDT();
	~SDT();
	RESULT_T parsingSDTSection(UINT8* pData);
	bool isSDTSecton(UINT16 pid);
	bool isExistSdt(UINT8 version_number, UINT8 section_number, UINT16 program_number);
	void printSDTList(void);
	RESULT_T parsingServiceDescriptor(SDT_INFO_T* sdtInfo, UINT8 *pData);

private :
	UINT32 NumOfService;
	std::forward_list<SDT_INFO_T> sdt_info_list;
};

#endif

3. 본체

/**
This is free and unencumbered software released into the public domain.

Anyone is free to copy, modify, publish, use, compile, sell, or
distribute this software, either in source code form or as a compiled
binary, for any purpose, commercial or non-commercial, and by any
means.

In jurisdictions that recognize copyright laws, the author or authors
of this software dedicate any and all copyright interest in the
software to the public domain. We make this dedication for the benefit
of the public at large and to the detriment of our heirs and
successors. We intend this dedication to be an overt act of
relinquishment in perpetuity of all present and future rights to this
software under copyright law.

THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.
IN NO EVENT SHALL THE AUTHORS BE LIABLE FOR ANY CLAIM, DAMAGES OR
OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE,
ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR
OTHER DEALINGS IN THE SOFTWARE.

For more information, please refer to <http://unlicense.org>
*/

/** --------------------------------------------------------------------
	file : sdt.cpp
	parsing service description table

version : 1.0
	data    : 2016.06.01
	author  : HeeSoon Kim(chipmaker0304@gmail.com)
-----------------------------------------------------------------------*/

/*
service_description_section(){
	table_id 						8 uimsbf
	section_syntax_indicator 		1 bslbf
	reserved_future_use 			1 bslbf
	reserved 						2 bslbf
	section_length 					12 uimsbf
	transport_stream_id 			16 uimsbf
	reserved 						2 bslbf
	version_number 					5 uimsbf
	current_next_indicator 			1 bslbf
	section_number 					8 uimsbf
	last_section_number 			8 uimsbf
	original_network_id 			16 uimsbf
	reserved_future_use 			8 bslbf
	
	for (i=0;i<N;i++){
		service_id 					16 uimsbf
		reserved_future_use 		6 bslbf
		EIT_schedule_flag 			1 bslbf
		EIT_present_following_flag 	1 bslbf
		running_status 				3 uimsbf
		free_CA_mode 				1 bslbf
		descriptors_loop_length 	12 uimsbf

for (j=0;j<N;j++){
			descriptor()
		}
	}
	CRC_32 32 rpchof
}
*/

#include "sdt.h"

SDT::SDT()
{
	NumOfService = 0;
	std::cout << __FUNCTION__ << std::endl;
}

SDT::~SDT()
{
	NumOfService = 0;
	sdt_info_list.clear();

std::cout << __FUNCTION__ << std::endl;
}

bool SDT::isSDTSecton(UINT16 pid)
{
	if(pid == SDT_ACTUAL_PID)
		return true;
	else
		return false;
}

bool SDT::isExistSdt(UINT8 version_number, UINT8 section_number, UINT16 program_number)
{
	for(auto list : sdt_info_list)
	{
		if(list.version == version_number && list.section_number == section_number && list.program_number == program_number)
		{
			return true;
		}
	}

return false;
}

void SDT::printSDTList(void)
{
	int i = 0;

sdt_info_list.sort([](SDT_INFO_T& prog1, SDT_INFO_T& prog2) 
					-> bool { return prog1.program_number < prog2.program_number; });

for(auto list : sdt_info_list)
	{
		std::printf("%3d] SDT version = %2d, Section = %2d, service_id = %3d \n" \
		, i, list.version, list.section_number, list.program_number);

std::printf("%3c %30s : %5d  \n", '-', "EIT_schedule_flag", list.EIT_schedule_flag);
		std::printf("%3c %30s : %5d  \n", '-', "EIT_present_following_flag", list.EIT_present_following_flag);
		std::printf("%3c %30s : %#5x \n", '-', "running_status", list.running_status);
		std::printf("%3c %30s : %5d  \n", '-', "free_CA_mode", list.free_CA_mode);
		std::printf("%3c %30s : %s   \n", '-', "service Provide Name", list.servicProvideeName.data());
		std::printf("%3c %30s : %s   \n", '-', "service Name", list.serviceName.data());

i++;
	}
}

#include <cstring>
RESULT_T SDT::parsingServiceDescriptor(SDT_INFO_T* sdtInfo, UINT8 *pData)
{
	UINT8 descriptor_tag;
	UINT8 descriptor_length;
	UINT8 service_type;
	UINT8 service_provider_name_length;
	UINT8 service_name_length;

descriptor_tag 					= pData[0];
	descriptor_length 				= pData[1];
	service_type 					= pData[2];
	service_provider_name_length 	= pData[3];

sdtInfo->servicProvideeName.assign((char*)pData+4, service_provider_name_length);

pData = pData + 3 + service_provider_name_length + 1;

service_name_length = pData[0];
	sdtInfo->serviceName.assign((char*)pData+1, service_name_length + 1);
}

RESULT_T SDT::parsingSDTSection(UINT8 *pData)
{
	bool EIT_schedule_flag;
	bool EIT_present_following_flag;
	bool free_CA_mode;

UINT8 *pSection;
	UINT8 point_field;
	UINT8 table_id;
	UINT8 version_number;
	UINT8 section_number;
	UINT8 last_section_number;
	UINT8 running_status;

UINT16 section_length;
	UINT16 transport_stream_id;
	UINT16 original_network_id;
	UINT16 service_id;
	UINT16 descriptors_loop_length;

point_field = pData[0];
	PRINT_SDT_INFO(point_field);

pSection = pData + point_field + 1;

table_id = pSection[0];
	PRINT_SDT_INFO(table_id);

if(table_id != SDT_ACTUAL_TABLE_ID)
	{
		return RESULT_NOTOK;
	}

section_length = ((pSection[1] & 0x0f) << 8) | pSection[2];
	PRINT_SDT_INFO(section_length);

transport_stream_id = (pSection[3] << 8) | pSection[4];
	PRINT_SDT_INFO(transport_stream_id);

version_number = (pSection[5] >> 1) & 0x1f;
	PRINT_SDT_INFO(version_number);

section_number = pSection[6];
	PRINT_SDT_INFO(section_number);

last_section_number = pSection[7];
	PRINT_SDT_INFO(last_section_number);

original_network_id = (pSection[8] << 8) | pSection[9];
	PRINT_SDT_INFO(original_network_id);

pSection = pData + point_field + SDT_HEADER_SIZE + 1;
	section_length -= SDT_HEADER_SIZE + 1;

while(section_length > 0)
	{
		SDT_INFO_T sdtInfo = {0, };

service_id = (pSection[0] << 8) | pSection[1];
		PRINT_SDT_INFO(service_id);

if(isExistSdt(version_number, section_number, service_id) == true)
			return RESULT_OK;

EIT_schedule_flag = (pSection[2] >> 1) & 0x01;
		PRINT_SDT_INFO(EIT_schedule_flag);

EIT_present_following_flag = pSection[2] & 0x01;		
		PRINT_SDT_INFO(EIT_present_following_flag);

running_status = (pSection[3] >> 5) & 0x07;
		PRINT_SDT_INFO(running_status);

free_CA_mode = (pSection[3] >> 4) & 0x01;
		PRINT_SDT_INFO(free_CA_mode);

descriptors_loop_length = ((pSection[3] & 0x0f) << 8) | pSection[4];
		PRINT_SDT_INFO(descriptors_loop_length);

sdtInfo.version 					= version_number;
		sdtInfo.section_number 				= section_number;
		sdtInfo.program_number 				= service_id;
		sdtInfo.EIT_schedule_flag 			= EIT_schedule_flag;
		sdtInfo.EIT_present_following_flag 	= EIT_present_following_flag;
		sdtInfo.running_status				= running_status;
		sdtInfo.free_CA_mode				= free_CA_mode;

parsingServiceDescriptor(&sdtInfo, pSection+5);
		//sdtInfo.serviceName.copy(0, pSection[])

sdt_info_list.push_front(sdtInfo);

pSection 		+= (5 + descriptors_loop_length);
		section_length 	-= (5 + descriptors_loop_length);
	}

return RESULT_OK;
}

4. 테스트 소스

5. 실행 결과

CSectionSDT

current media type : FILE

mediaInPath : SGP.ts

No Data !!

0] SDT version = 1, Section = 0, service_id = 208

- EIT_schedule_flag : 0

- EIT_present_following_flag : 1

- running_status : 0x4

- free_CA_mode : 0

- service Provide Name : MediaCorp TV

- service Name : TV1_SD

1] SDT version = 1, Section = 0, service_id = 209

- EIT_schedule_flag : 0

- EIT_present_following_flag : 1

- running_status : 0x4

- free_CA_mode : 0

- service Provide Name : MediaCorp TV

- service Name : TV2_SD

2] SDT version = 1, Section = 0, service_id = 210

- EIT_schedule_flag : 0

- EIT_present_following_flag : 1

- running_status : 0x4

- free_CA_mode : 0

- service Provide Name : MediaCorp TV

- service Name : TV3_HD

3] SDT version = 1, Section = 0, service_id = 211

- EIT_schedule_flag : 0

- EIT_present_following_flag : 1

- running_status : 0x4

- free_CA_mode : 0

- service Provide Name : MediaCorp TV

- service Name : TV4_HD

4] SDT version = 1, Section = 0, service_id = 212

- EIT_schedule_flag : 0

- EIT_present_following_flag : 1

- running_status : 0x4

- free_CA_mode : 0

- service Provide Name : MediaCorp TV

- service Name : TV5_Radio

5] SDT version = 1, Section = 0, service_id = 213

- EIT_schedule_flag : 0

- EIT_present_following_flag : 1

- running_status : 0x4

- free_CA_mode : 0

- service Provide Name : MediaCorp TV

- service Name : TV6_Rad

~CSection

~SDT

6. 전체 소스 (github link)

소스 코드는 여기 있는 부분과 다를 수 있다. 중간에 버그나 수정이 필요하면 다시 올리기 때문에 git에서 받는게 가장 최신임.

https://github.com/heesoon/mpeg/tree/master/test/sdt

'Program Lang. > C++' 카테고리의 다른 글

pmt json version (0)	2016.07.22
pat 정보를 json 파일로 저장 후 webbrowser에서 확인 (0)	2016.07.21
4. pmt class (0)	2016.07.19
3. pat info. save to MySQL with cpp connector (0)	2016.07.19
2. mpeg ts pat (program associate table) parser (0)	2016.07.14

:

4. pmt class

Program Lang./C++ 2016. 7. 19. 22:05

이 장에서는 PMT (Program Map Table)에 대해서 알아보고, 구현 클래스를 살펴본다.

PMT의 주요목적은 ES (Element Stream)에 대한 PID를 얻어오는 것이다.

또한 각 ES의 Type을 확인할 수 있다. Type의 의미는 현재 ES가 Audio인지 아니면 Video인지

Video이면 MPEG-2, MPEG-4 Part 4, MPEG-4 Part 10 지금은 UHD를 위한 타입도 추가되었다.

Set-Top Box나 TV에서는 A/V Decoder 블록이 존재하고 PMT에서 추출한 ES에 대한

PID를 A/V Decoder에 잘 넘겨주는 것이 System Decoder단 작업의 일이라고 보면된다.

PMT PID에 PCR PID가 있는데 Adaptation Field에 존재하는 PCR PID와 어떤 상관관계가

있는지 기억이 나지 않는다.

Adaptation Field를 이용하여 PCR Recovery, Rate 등 세가지인가 만족해야 하는 조건이 있다.

전에 한번 짜봐서 확인해 봤는데 분석기와 동일한 결과가 나왔다.

기회가 되면 소스 정리해서 올려놔야겠다.

Stream Analyzer처럼 Stream Type을 보기 좋게 하기 위해서는 추가적인 작업이 많이

필요해서 그냥 hexa값으로 표시하는 정도로 마무리한다.

1. 소스 트리

.

├── CMakeLists.txt

├── pat.cpp

├── pat.h

├── pmt.cpp

├── pmt.h

├── psi_glob.h

├── remove.sh

├── section.cpp

├── section.h

├── test.cpp

└── types.h

2. 헤더 파일

PMT를 Parsing하기 위한 전제 조건은 PAT가 Parsing 완료되어야 한다. 따라서 PAT는 필수적으로

따라 다닌다고 보면 된다.

#ifndef __PMT_H__
#define __PMT_H__

#include <cstdio>
#include <iostream>
#include <memory>
#include <forward_list>
#include "types.h"
#include "psi_glob.h"

/* -------------------------------------------------------------------------------------------------------------------
	declare define
------------------------------------------------------------------------------------------------------------------- */
#define _RESERVED			0x00
#define MPEG1_VIDEO			0x01
#define MPEG2_VIDEO			0x02
#define MPEG1_AUDIO			0x03
#define MPEG2_AUDIO			0x04
#define PRIVATE_SECTION		0x05
#define PES_PRIVATE_DATA	0x06
#define MHEG				0x07
#define DSMCC				0x08
#define MPEG4_VIDEO			0x10
#define MPEG4_H264_VIDEO	0x1B
#define HEVC_VIDEO			0x24

//#define PRINT_PMT_SECSION_HEADERå
#ifdef PRINT_PMT_SECSION_HEADER
#define PRINT_PMT_INFO(x) std::printf("%30s = %10d [%#10x]\n", #x, x, x);
#else
#define PRINT_PMT_INFO(x)
#endif

/* -------------------------------------------------------------------------------------------------------------------
	declare class data
------------------------------------------------------------------------------------------------------------------- */
typedef struct {
	UINT8 stream_type;
	UINT16 es_pid;
} ES_INFO_T;

typedef struct {
	UINT8 version;
	UINT8 section_number;
	UINT16 program_number;
	UINT16 pcr_pid;
	std::forward_list<ES_INFO_T> es_info;
} PMT_INFO_T;

class PMT
{
public :
	PMT();
	~PMT();
	RESULT_T parsingPMTSection(UINT16 pmtPid, UINT8* pData);
	bool isExistPmt(UINT8 vserion_number, UINT8 section_number, UINT16 program_number);
	void addNewPMTtoList(PMT_INFO_T newPmt);
	void addNewEStoPMT(PMT_INFO_T newPmt, ES_INFO_T newEs);
	void printPMTList(void);
	UINT32 getPMTProgNum(void);

private :
	UINT32 numProgs;
	std::forward_list<PMT_INFO_T> pmtList;
};
#endif

3. 클래스 본체

/**
This is free and unencumbered software released into the public domain.

Anyone is free to copy, modify, publish, use, compile, sell, or
distribute this software, either in source code form or as a compiled
binary, for any purpose, commercial or non-commercial, and by any
means.

In jurisdictions that recognize copyright laws, the author or authors
of this software dedicate any and all copyright interest in the
software to the public domain. We make this dedication for the benefit
of the public at large and to the detriment of our heirs and
successors. We intend this dedication to be an overt act of
relinquishment in perpetuity of all present and future rights to this
software under copyright law.

THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.
IN NO EVENT SHALL THE AUTHORS BE LIABLE FOR ANY CLAIM, DAMAGES OR
OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE,
ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR
OTHER DEALINGS IN THE SOFTWARE.

For more information, please refer to <http://unlicense.org>
*/

/** --------------------------------------------------------------------
	file : pmt.cpp
	parsing program map table informaiton

version : 1.0
	data    : 2016.06.01
	author  : HeeSoon Kim(chipmaker0304@gmail.com)
-----------------------------------------------------------------------*/
#include "pmt.h"

PMT::PMT()
{
	numProgs = 0;
	std::cout << __FUNCTION__ << std::endl;
}

PMT::~PMT()
{
	for(auto list : pmtList)
	{
		list.es_info.clear();
	}

pmtList.clear();

std::cout << __FUNCTION__ << std::endl;
}

bool PMT::isExistPmt(UINT8 version_number, UINT8 section_number, UINT16 program_number)
{
	for(auto list : pmtList)
	{
		if(list.version == version_number && list.section_number == section_number && list.program_number == program_number)
		{
			return true;
		}
	}

return false;
}

UINT32 PMT::getPMTProgNum(void)
{
	return numProgs;
}

void PMT::addNewPMTtoList(PMT_INFO_T newPmt)
{
	pmtList.push_front(newPmt);
}

void PMT::addNewEStoPMT(PMT_INFO_T newPmt, ES_INFO_T newEs)
{
	//pmtList.push_front(es_list);
	for(auto &pmt_list : pmtList)
	{
		if(pmt_list.program_number == newPmt.program_number)
		{
			pmt_list.es_info.push_front(newEs);
		}
	}
}

void PMT::printPMTList(void)
{
	int i = 1;
	int j = 1;

// sort by porgram number
	pmtList.sort([](PMT_INFO_T& prog1, PMT_INFO_T& prog2) 
					-> bool { return prog1.program_number < prog2.program_number; });

for(auto list : pmtList)
	{
		std::printf("%3d] PMT version = %2d Section = %2d program_number = %3d [PCR PID %5d (%#5x)]\n" \
		, i, list.version, list.section_number, list.program_number, list.pcr_pid, list.pcr_pid);

for(auto es_list : list.es_info)
		{
			std::printf("  -> [%3d] stream_type = %#5x [ES PID %5d (%#5x)]\n" \
			, j, es_list.stream_type, es_list.es_pid, es_list.es_pid);

j++;
		}

i++;
		j = 1;
	}
}

RESULT_T PMT::parsingPMTSection(UINT16 pmtPid, UINT8 *pData)
{
	UINT8 *pSection;
	UINT8 point_field;

UINT8 table_id;
	UINT16 section_length;
	UINT16 program_number;
	UINT8 version_number;
	bool current_next_indicator;
	UINT8 section_number;
	UINT8 last_section_number;
	UINT16 PCR_PID;
	UINT16 program_info_length;

UINT8 stream_type;
	UINT16 elementary_PID;
	UINT16 ES_info_length;
	UINT32 descriptor_length;

PMT_INFO_T pmt_info;
	ES_INFO_T es_info;

point_field = pData[0];
	//PRINT_PMT_INFO(point_field);

pSection = pData + point_field + 1;

table_id = pSection[0];
	//PRINT_PMT_INFO(table_id);

section_length = ((pSection[1] & 0x0f) << 8) | pSection[2];
	PRINT_PMT_INFO(section_length);

program_number = (pSection[3] << 8) | pSection[4];
	//PRINT_PMT_INFO(program_number);

version_number = (pSection[5] >> 0x01) & 0x1f;
	//PRINT_PMT_INFO(version_number);

current_next_indicator = pSection[5] & 0x01;
	//PRINT_PMT_INFO(current_next_indicator);

section_number = pSection[6];
	//PRINT_PMT_INFO(section_number);

last_section_number = pSection[7];
	//PRINT_PMT_INFO(last_section_number);

PCR_PID = ((pSection[8] & 0x1f) << 8) | pSection[9];
	PRINT_PMT_INFO(PCR_PID);

program_info_length = ((pSection[10] & 0x0f) << 8) | pSection[11];
	PRINT_PMT_INFO(program_info_length);

pSection = pData + point_field + PMT_HEADER_SIZE + program_info_length + 1;
	section_length -= PMT_HEADER_SIZE + 1 + program_info_length;

if(isExistPmt(version_number, section_number, program_number) == true)
	{
		return RESULT_NOTOK;
	}

// add new PMT to list
	pmt_info.version 			= version_number;
	pmt_info.section_number 	= section_number;
	pmt_info.program_number		= program_number;
	pmt_info.pcr_pid 			= PCR_PID;

numProgs++;

addNewPMTtoList(pmt_info);

while(section_length > 0)
	{
		stream_type = pSection[0];
		PRINT_PMT_INFO(stream_type);

elementary_PID = ((pSection[1] & 0x1f) << 8) | pSection[2];
		PRINT_PMT_INFO(elementary_PID);

ES_info_length = ((pSection[3] & 0x0f) << 8) | pSection[4];
		PRINT_PMT_INFO(ES_info_length);

es_info.stream_type = stream_type;
		es_info.es_pid		= elementary_PID;
		
		addNewEStoPMT(pmt_info, es_info);

if(ES_info_length+5 > section_length)
			break;

pSection 		+= 5;
		section_length 	-= (ES_info_length + 5);

while(ES_info_length > 0)
		{
			// Parsing Descriptor
			descriptor_length = pSection[1] + 2;
			if(descriptor_length > ES_info_length)
			{
				pSection += ES_info_length;
				ES_info_length = 0;
				break;
			}

ES_info_length 	-= descriptor_length;
			pSection		+= descriptor_length;
		}
	}

return RESULT_OK;
}

4. 테스트 코드

5. 실행 결과

hskim@MacBookPro/Volumes/Macintosh HD 2/share/c++/pmt $./test

CSection

pat generator called !!

PMT

current media type : FILE

mediaInPath : SGP.ts

No Data !!

1] PAT version = 1 Section = 0 program_number = 208 [PID 1031 (0x407)]

2] PAT version = 1 Section = 0 program_number = 209 [PID 1032 (0x408)]

3] PAT version = 1 Section = 0 program_number = 210 [PID 1033 (0x409)]

4] PAT version = 1 Section = 0 program_number = 211 [PID 1034 (0x40a)]

5] PAT version = 1 Section = 0 program_number = 212 [PID 1035 (0x40b)]

6] PAT version = 1 Section = 0 program_number = 213 [PID 1036 (0x40c)]

1] PMT version = 1 Section = 0 program_number = 208 [PCR PID 260 (0x104)]

-> [ 1] stream_type = 0x11 [ES PID 515 (0x203)]

-> [ 2] stream_type = 0x11 [ES PID 514 (0x202)]

-> [ 3] stream_type = 0x11 [ES PID 513 (0x201)]

-> [ 4] stream_type = 0x11 [ES PID 516 (0x204)]

-> [ 5] stream_type = 0x1b [ES PID 260 (0x104)]

-> [ 6] stream_type = 0x6 [ES PID 103 ( 0x67)]

-> [ 7] stream_type = 0x6 [ES PID 102 ( 0x66)]

-> [ 8] stream_type = 0x6 [ES PID 101 ( 0x65)]

-> [ 9] stream_type = 0x6 [ES PID 100 ( 0x64)]

2] PMT version = 1 Section = 0 program_number = 209 [PCR PID 259 (0x103)]

-> [ 1] stream_type = 0x11 [ES PID 517 (0x205)]

-> [ 2] stream_type = 0x11 [ES PID 513 (0x201)]

-> [ 3] stream_type = 0x11 [ES PID 516 (0x204)]

-> [ 4] stream_type = 0x1b [ES PID 259 (0x103)]

3] PMT version = 1 Section = 0 program_number = 210 [PCR PID 257 (0x101)]

-> [ 1] stream_type = 0x11 [ES PID 513 (0x201)]

-> [ 2] stream_type = 0x6 [ES PID 100 ( 0x64)]

-> [ 3] stream_type = 0x11 [ES PID 516 (0x204)]

-> [ 4] stream_type = 0x1b [ES PID 257 (0x101)]

4] PMT version = 1 Section = 0 program_number = 211 [PCR PID 258 (0x102)]

-> [ 1] stream_type = 0x11 [ES PID 514 (0x202)]

-> [ 2] stream_type = 0x11 [ES PID 517 (0x205)]

-> [ 3] stream_type = 0x6 [ES PID 102 ( 0x66)]

-> [ 4] stream_type = 0x11 [ES PID 514 (0x202)]

-> [ 5] stream_type = 0x1b [ES PID 258 (0x102)]

5] PMT version = 1 Section = 0 program_number = 212 [PCR PID 514 (0x202)]

-> [ 1] stream_type = 0x11 [ES PID 516 (0x204)]

-> [ 2] stream_type = 0x11 [ES PID 514 (0x202)]

6] PMT version = 1 Section = 0 program_number = 213 [PCR PID 516 (0x204)]

-> [ 1] stream_type = 0x11 [ES PID 516 (0x204)]

~CSection

pat destroy called !!

~PMT

6. 전체 소스 (github link)

https://github.com/heesoon/mpeg/tree/master/test/pmt

'Program Lang. > C++' 카테고리의 다른 글

pat 정보를 json 파일로 저장 후 webbrowser에서 확인 (0)	2016.07.21
5. sdt (service description table) class (0)	2016.07.20
3. pat info. save to MySQL with cpp connector (0)	2016.07.19
2. mpeg ts pat (program associate table) parser (0)	2016.07.14
1. mpeg sectoin parser (0)	2016.07.13

:

3. pat info. save to MySQL with cpp connector

Program Lang./C++ 2016. 7. 19. 21:11

http://chipmaker.tistory.com/entry/mysql-cpp-connector-study

에서 cpp connector wrapper 클래스를 만들고 이 클래스를 기반 클래스로 정의하였다.

여기서는 이 기반 클래스를 구체화하는 예제로 PAT 정보를 MySQL에 써 보도록 하자.

1. 소스 트리

.

├── CMakeLists.txt

├── mysqlAdaptor.cpp

├── mysqlAdaptor.h

├── mysqlAdaptorForPAT.cpp

├── mysqlAdaptorForPAT.h

├── pat.cpp

├── pat.h

├── psi_glob.h

├── remove.sh

├── section.cpp

├── section.h

├── test.cpp

└── types.h

2. 헤더 파일

#ifndef __MYSQL_ADAPTOR_PAT_H__
#define __MYSQL_ADAPTOR_PAT_H__

#include <iostream>
#include <string>
#include <sstream>
#include <iomanip>
#include <pat.h>

#include "mysql_connection.h"
#include <cppconn/driver.h>
#include <cppconn/exception.h>
#include <cppconn/resultset.h>
#include <cppconn/statement.h>

#include "mysqlAdaptor.h"
/* -------------------------------------------------------------------------------------------------------------------
	declare define
------------------------------------------------------------------------------------------------------------------- */

/* -------------------------------------------------------------------------------------------------------------------
	declare class data
------------------------------------------------------------------------------------------------------------------- */
class MySQLAdaptorForPAT : public BaseMySQLAdaptor
{
public :
	MySQLAdaptorForPAT();
	virtual ~MySQLAdaptorForPAT();
	void createTable(const std::string databaseName, const std::string tableName);
	void insertTable(const std::string tableName, void *object);
	void select(const std::string tableName);
};
#endif

PAT 정보를 MySQL에 쓰는 파일만 보고 전체 파일을 github link을 참조.

3. 클래스 본체

/**
This is free and unencumbered software released into the public domain.

Anyone is free to copy, modify, publish, use, compile, sell, or
distribute this software, either in source code form or as a compiled
binary, for any purpose, commercial or non-commercial, and by any
means.

In jurisdictions that recognize copyright laws, the author or authors
of this software dedicate any and all copyright interest in the
software to the public domain. We make this dedication for the benefit
of the public at large and to the detriment of our heirs and
successors. We intend this dedication to be an overt act of
relinquishment in perpetuity of all present and future rights to this
software under copyright law.

THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.
IN NO EVENT SHALL THE AUTHORS BE LIABLE FOR ANY CLAIM, DAMAGES OR
OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE,
ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR
OTHER DEALINGS IN THE SOFTWARE.

For more information, please refer to <http://unlicense.org>
*/

/** --------------------------------------------------------------------
	file : mysqlAdaptorForPAT.cpp
	mysql c++ connector wrapper class

version : 1.0
	data    : 2016.06.01
	author  : HeeSoon Kim(chipmaker0304@gmail.com)
-----------------------------------------------------------------------*/

#include "mysqlAdaptorForPAT.h"
#include "pat.h"

std::string PatTableString[] = {
	"version INT,",
	"section_number INT,",
	"program_number INT,",
	"pmtPid INT"
};

MySQLAdaptorForPAT::MySQLAdaptorForPAT()
{
	driver = get_driver_instance();
	std::cout << __FUNCTION__ << std::endl;
}

MySQLAdaptorForPAT::~MySQLAdaptorForPAT()
{
	std::cout << __FUNCTION__ << "," << __LINE__ << std::endl;
}

void MySQLAdaptorForPAT::createTable(const std::string databaseName, const std::string tableName)
{
	useDB(databaseName);

std::string columQuery;

for(auto str : PatTableString)
	{
		columQuery += str;
	}

std::string databaseQuery = "CREATE TABLE ";
	databaseQuery += tableName;
	databaseQuery += "(";
	databaseQuery += columQuery;
	databaseQuery += ")";

deleteTabe(tableName);
	stmt->execute(databaseQuery.c_str());
}

void MySQLAdaptorForPAT::insertTable(const std::string tableName, void *object)
{
	PAT *pat;
	std::string databaseQuery;

pat = static_cast<PAT*> (object);

for(auto list : pat->getPatList())
	{
		char buffer[256] = {0, };

std::sprintf(buffer, "(%d, %d, %d, %d)", list.version, list.section_number, list.program_number,\
			list.pmtPid);

databaseQuery = "INSERT INTO ";
		databaseQuery += tableName;
		databaseQuery += " VALUES";
		databaseQuery += buffer;

stmt->execute(databaseQuery.c_str());
	}
}

void MySQLAdaptorForPAT::select(const std::string tableName)
{
	std::string databaseQuery;
	int i = 1;

databaseQuery += "SELECT * from ";
	databaseQuery += tableName;

res = stmt->executeQuery(databaseQuery);

while (res->next()) 
	{
		std::cout << std::dec << i << "] " << "PAT ";
		std::cout << "version : " << res->getString(1) << ", ";
		std::cout << "section_number : " << res->getString(2) << ", ";
		std::cout << "program_number : " << res->getString(3) << ", ";
		std::cout << "PID : " << res->getString(4) << " ";
		std::cout << "[ " << std::hex << std::showbase << res->getInt(4) << " ]" << std::endl;
		i++;

}		
}

기반 클래스에서 순수 가상함수를 사용하였으나, 구지 순수 가상함수를 만들지 않고

가상함수로 만들고 함수 오버라이딩 기법을 사용해도 되지만 두서 없이 c++ 공부하다 보니 그 떄 생각나고

짜보고 싶은 것을 위주로 생각해서 진행해서 어떤 설계를 기반으로 하지 않은점은 고력해야 한다.

4. 테스트 예제

#include <thread>
#include <chrono>
#include <mutex>
#include "section.h"
#include "pat.h"
#include "mysqlAdaptorForPAT.h"

int main(int argc, char* argv[])
{	
	std::string address 	= "tcp://127.0.0.1:3306";
	std::string user 		= "root";
	std::string password 	= "";
	std::string dbName 		= "test";
	std::string tableName 	= "pat";

SECTION_INFO_T sec;
	CSection* section 				= new CSection();
	PAT* pat 						= new PAT();
	MySQLAdaptorForPAT *pMySqlPAT 	= new MySQLAdaptorForPAT();

// open media test, media is file
	section->openMedia("file://SGP.ts");

// create task to read continously
	std::thread tr = std::thread([&]() {

while(1)
		{
			if(section->readMedia(&sec) == RESULT_NOTOK)
				break;

// PAT parsing PAT PID is zero
			if(sec.pid == 0)
			{
				pat->parsingPATSection((UINT8*)sec.section);
			}
		}
	});

tr.join();

// print PAT info
	pat->printPATList();

pMySqlPAT->connect(address, user, password);
	pMySqlPAT->deleteDB(dbName);
	pMySqlPAT->createDB(dbName);
	pMySqlPAT->createTable(dbName, tableName);
	pMySqlPAT->insertTable(tableName, (void*)pat);
	pMySqlPAT->select(tableName);

//std::this_thread::sleep_for(std::chrono::milliseconds(1000));

delete section;
	delete pat;
	delete pMySqlPAT;

return 0;	
}

5. 실행 결과

6. github link (전체 소스)

https://github.com/heesoon/mpeg/tree/master/test/patSaveToMySQLDB

'Program Lang. > C++' 카테고리의 다른 글

5. sdt (service description table) class (0)	2016.07.20
4. pmt class (0)	2016.07.19
2. mpeg ts pat (program associate table) parser (0)	2016.07.14
1. mpeg sectoin parser (0)	2016.07.13
message queue with boost and serialization (0)	2016.07.12

:

CHIPMAKER

'Program Lang./C++'에 해당되는 글 36건

std::function 정리

'Program Lang. > C++' 카테고리의 다른 글

unique_ptr, shared_ptr 읽히기

'Program Lang. > C++' 카테고리의 다른 글

c++ pair 읽히기

'Program Lang. > C++' 카테고리의 다른 글

full version (pat, pmt, sdt)

'Program Lang. > C++' 카테고리의 다른 글

sdt json version

'Program Lang. > C++' 카테고리의 다른 글

pmt json version

'Program Lang. > C++' 카테고리의 다른 글

pat 정보를 json 파일로 저장 후 webbrowser에서 확인

'Program Lang. > C++' 카테고리의 다른 글

5. sdt (service description table) class

'Program Lang. > C++' 카테고리의 다른 글

4. pmt class

'Program Lang. > C++' 카테고리의 다른 글

3. pat info. save to MySQL with cpp connector

'Program Lang. > C++' 카테고리의 다른 글

티스토리툴바