diff options
| -rw-r--r-- | p2pvr/dvb/Jamfile.jam | 2 | ||||
| -rw-r--r-- | p2pvr/dvb/unittests/.ycm_extra_conf.py | 119 | ||||
| -rw-r--r-- | p2pvr/dvb/unittests/Jamfile.jam | 23 | ||||
| -rw-r--r-- | p2pvr/dvb/unittests/createSamples.cpp | 126 |
4 files changed, 269 insertions, 1 deletions
diff --git a/p2pvr/dvb/Jamfile.jam b/p2pvr/dvb/Jamfile.jam index c8f2fe0..2dbbbda 100644 --- a/p2pvr/dvb/Jamfile.jam +++ b/p2pvr/dvb/Jamfile.jam @@ -4,7 +4,7 @@ cpp-pch pch : pch.hpp : lib p2pvrdvb : pch - [ glob-tree *.cpp ] + [ glob-tree *.cpp : unittests ] : <library>../ice//p2pvrice <implicit-dependency>../ice//p2pvrice diff --git a/p2pvr/dvb/unittests/.ycm_extra_conf.py b/p2pvr/dvb/unittests/.ycm_extra_conf.py new file mode 100644 index 0000000..06d416d --- /dev/null +++ b/p2pvr/dvb/unittests/.ycm_extra_conf.py @@ -0,0 +1,119 @@ +import os +import ycm_core + +flags = [ +'-Wall', +'-Wextra', +'-Werror', +'-Wc++98-compat', +'-Wno-long-long', +'-Wno-variadic-macros', +'-fexceptions', +'-DNDEBUG', +'-std=c++11', +'-x', +'c++', +'-I', +'.', +'-isystem', +'../../ice', +'-isystem', +'../../ice/bin/gcc-4.8.3/debug/slicer-yes', +'-isystem', +'../siParsers', +'-isystem', +'/usr/include', +'-isystem', +'/usr/include/glibmm-2.4', +] + +# Set this to the absolute path to the folder (NOT the file!) containing the +# compile_commands.json file to use that instead of 'flags'. See here for +# more details: http://clang.llvm.org/docs/JSONCompilationDatabase.html +# +# Most projects will NOT need to set this to anything; you can just change the +# 'flags' list of compilation flags. Notice that YCM itself uses that approach. +compilation_database_folder = '' + +if os.path.exists( compilation_database_folder ): + database = ycm_core.CompilationDatabase( compilation_database_folder ) +else: + database = None + +SOURCE_EXTENSIONS = [ '.cpp', '.cxx', '.cc', '.c', '.m', '.mm' ] + +def DirectoryOfThisScript(): + return os.path.dirname( os.path.abspath( __file__ ) ) + + +def MakeRelativePathsInFlagsAbsolute( flags, working_directory ): + if not working_directory: + return list( flags ) + new_flags = [] + make_next_absolute = False + path_flags = [ '-isystem', '-I', '-iquote', '--sysroot=' ] + for flag in flags: + new_flag = flag + + if make_next_absolute: + make_next_absolute = False + if not flag.startswith( '/' ): + new_flag = os.path.join( working_directory, flag ) + + for path_flag in path_flags: + if flag == path_flag: + make_next_absolute = True + break + + if flag.startswith( path_flag ): + path = flag[ len( path_flag ): ] + new_flag = path_flag + os.path.join( working_directory, path ) + break + + if new_flag: + new_flags.append( new_flag ) + return new_flags + + +def IsHeaderFile( filename ): + extension = os.path.splitext( filename )[ 1 ] + return extension in [ '.h', '.hxx', '.hpp', '.hh' ] + + +def GetCompilationInfoForFile( filename ): + # The compilation_commands.json file generated by CMake does not have entries + # for header files. So we do our best by asking the db for flags for a + # corresponding source file, if any. If one exists, the flags for that file + # should be good enough. + if IsHeaderFile( filename ): + basename = os.path.splitext( filename )[ 0 ] + for extension in SOURCE_EXTENSIONS: + replacement_file = basename + extension + if os.path.exists( replacement_file ): + compilation_info = database.GetCompilationInfoForFile( + replacement_file ) + if compilation_info.compiler_flags_: + return compilation_info + return None + return database.GetCompilationInfoForFile( filename ) + + +def FlagsForFile( filename, **kwargs ): + if database: + # Bear in mind that compilation_info.compiler_flags_ does NOT return a + # python list, but a "list-like" StringVec object + compilation_info = GetCompilationInfoForFile( filename ) + if not compilation_info: + return None + + final_flags = MakeRelativePathsInFlagsAbsolute( + compilation_info.compiler_flags_, + compilation_info.compiler_working_dir_ ) + else: + relative_to = DirectoryOfThisScript() + final_flags = MakeRelativePathsInFlagsAbsolute( flags, relative_to ) + + return { + 'flags': final_flags, + 'do_cache': True + } diff --git a/p2pvr/dvb/unittests/Jamfile.jam b/p2pvr/dvb/unittests/Jamfile.jam new file mode 100644 index 0000000..6e8cfbf --- /dev/null +++ b/p2pvr/dvb/unittests/Jamfile.jam @@ -0,0 +1,23 @@ +import testing ; + +lib boost_system ; +lib boost_filesystem ; +lib IceUtil ; +lib Ice ; + +path-constant me : . ; + +exe createSamples : + createSamples.cpp + : + <define>BOOST_TEST_DYN_LINK + <library>..//p2pvrdvb + <library>../../ice//p2pvrice + <library>IceUtil + <library>Ice + <library>boost_system + <library>boost_filesystem + <library>../..//boost_utf + <define>ROOT=\"$(me)\" + ; + diff --git a/p2pvr/dvb/unittests/createSamples.cpp b/p2pvr/dvb/unittests/createSamples.cpp new file mode 100644 index 0000000..affa123 --- /dev/null +++ b/p2pvr/dvb/unittests/createSamples.cpp @@ -0,0 +1,126 @@ +#define BOOST_TEST_MODULE CreateSamples +#include <boost/test/unit_test.hpp> +#include <boost/filesystem/operations.hpp> +#include <boost/function.hpp> +#include <boost/bind.hpp> +#include <boost/tuple/tuple.hpp> +#include <Ice/ObjectAdapter.h> +#include <Ice/Service.h> +#include <scopeObject.h> +#include <linux/dvb/frontend.h> +#include <siParsers/network.h> +#include <siParsers/service.h> +#include <siParsers/event.h> + +#define XSTR(s) STR(s) +#define STR(s) #s +const boost::filesystem::path root(XSTR(ROOT)); + +template <class Parser> +static +boost::tuple<Ice::CommunicatorPtr, Ice::ObjectAdapterPtr, Parser *> +standardConfig() +{ + Ice::StringSeq params { + "--Ice.ThreadPool.Client.Size=5", + "--Ice.ThreadPool.Client.SizeMax=10", + "--Ice.ThreadPool.Server.Size=5", + "--Ice.ThreadPool.Server.SizeMax=10" + }; + Ice::CommunicatorPtr ic = Ice::initialize(params); + auto adapter = ic->createObjectAdapterWithEndpoints("Adp", "tcp -p 12000"); + auto parser = new Parser(); + adapter->add(parser, ic->stringToIdentity("parser")); + adapter->activate(); + return { ic, adapter, parser }; +} + +template <class Base, class Object> +class SiSampleCollector : public Base { + public: + SiSampleCollector() : + packets(0) + { + } + + bool HandleTable(Object) override + { + return false; + } + + bool NewData(const P2PVR::Data & bytes, const Ice::Current & ice) override + { + packets.push_back(bytes); + return SiTableParserBase::NewData(bytes, ice); + } + + std::list<P2PVR::Data> packets; +}; + +template <class Base, class Object> +static +void +CaptureAndSave(const boost::filesystem::path & fileName, const boost::function<void(P2PVR::TunerPrx, P2PVR::RawDataClientPrx)> & method) +{ + auto icp = standardConfig<SiSampleCollector<Base, Object>>(); + auto ic = boost::get<0>(icp); + auto adap = boost::get<1>(icp); + auto p = boost::get<2>(icp); + ScopeObject _([&ic]{ ic->destroy(); }); + + auto devs = P2PVR::DevicesPrx::checkedCast(ic->stringToProxy("Devices:tcp -h defiant -p 10000")); + auto parser = P2PVR::RawDataClientPrx::checkedCast(adap->createProxy(ic->stringToIdentity("parser"))); + BOOST_REQUIRE(devs); + devs->ice_ping(); + BOOST_REQUIRE(parser); + parser->ice_ping(); + + DVBSI::TerrestrialDeliveryPtr transport = new DVBSI::TerrestrialDelivery { + 4170, 682000000, 0, true, true, true, 3, 0, 2, 1, 0, 1, true + }; + BOOST_REQUIRE_EQUAL(transport->Frequency, 682000000); + BOOST_REQUIRE_EQUAL(transport->TransmissionMode, 1); + + BOOST_CHECKPOINT("Acquire device"); + P2PVR::TunerPrx tuner = devs->GetTunerAny(FE_OFDM, transport); + BOOST_REQUIRE(tuner); + tuner->ice_ping(); + + BOOST_CHECKPOINT("Get data"); + method(tuner, parser); + + BOOST_CHECKPOINT("Release device"); + devs->ReleaseTuner(tuner); + + BOOST_MESSAGE("Total packets: " << p->packets.size()); + BOOST_REQUIRE(p->packets.size() > 0); + + auto out = Ice::createOutputStream(ic); + out->write(p->packets); + Ice::ByteSeq buf; + out->finished(buf); + BOOST_MESSAGE(root); + auto outFile = fopen((root / fileName).string().c_str(), "w"); + BOOST_REQUIRE(outFile); + BOOST_REQUIRE_EQUAL(1, fwrite(&buf.front(), buf.size(), 1, outFile)); + BOOST_REQUIRE_EQUAL(0, fclose(outFile)); +} + +BOOST_AUTO_TEST_CASE( network_sample ) +{ + CaptureAndSave<SiNetworkInformationParser, DVBSI::NetworkPtr>("network.dat", + [](P2PVR::TunerPrx t, P2PVR::RawDataClientPrx rdc) { t->SendNetworkInformation(rdc); }); +} + +BOOST_AUTO_TEST_CASE( services_sample ) +{ + CaptureAndSave<SiServicesParser, DVBSI::TransportStreamPtr>("services.dat", + [](P2PVR::TunerPrx t, P2PVR::RawDataClientPrx rdc) { t->SendServiceDescriptions(rdc); }); +} + +BOOST_AUTO_TEST_CASE( events_sample ) +{ + CaptureAndSave<SiEpgParser, DVBSI::EventPtr>("events.dat", + [](P2PVR::TunerPrx t, P2PVR::RawDataClientPrx rdc) { t->SendEventInformation(rdc); }); +} + |