|
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
|
/*----------------------------------------------------------------------
Test of a non cmsRun executable
Note that the commented out lines are what is necessary to
setup the MessageLogger in this test. Note that tests like
this will hang after 1000 messages are sent to the MessageLogger
if the MessageLogger is not runnning.
----------------------------------------------------------------------*/
#include "FWCore/PluginManager/interface/ProblemTracker.h"
#include "FWCore/ParameterSet/interface/ParameterSet.h"
#include "FWCore/Framework/interface/EventProcessor.h"
#include "FWCore/ParameterSetReader/interface/ParameterSetReader.h"
#include "FWCore/Utilities/interface/propagate_const.h"
#include "FWCore/Concurrency/interface/ThreadsController.h"
// #include "FWCore/Utilities/interface/Presence.h"
// #include "FWCore/PluginManager/interface/PresenceFactory.h"
#include <cppunit/extensions/HelperMacros.h>
#include <memory>
#include <string>
class testStandalone : public CppUnit::TestFixture {
CPPUNIT_TEST_SUITE(testStandalone);
CPPUNIT_TEST(writeAndReadFile);
CPPUNIT_TEST_SUITE_END();
public:
void setUp() {
m_handler = std::make_unique<edm::AssertHandler>();
m_scheduler = std::make_unique<edm::ThreadsController>(1);
}
void tearDown() {
m_handler = nullptr; // propagate_const<T> has no reset() function
}
void writeAndReadFile();
private:
edm::propagate_const<std::unique_ptr<edm::AssertHandler>> m_handler;
edm::propagate_const<std::unique_ptr<edm::ThreadsController>> m_scheduler;
};
///registration of the test so that the runner can find it
CPPUNIT_TEST_SUITE_REGISTRATION(testStandalone);
void testStandalone::writeAndReadFile() {
{
std::string configuration(
"import FWCore.ParameterSet.Config as cms\n"
"process = cms.Process('TEST')\n"
"process.maxEvents = cms.untracked.PSet(\n"
" input = cms.untracked.int32(5)\n"
")\n"
"process.source = cms.Source('EmptySource')\n"
"process.JobReportService = cms.Service('JobReportService')\n"
"process.InitRootHandlers = cms.Service('InitRootHandlers')\n"
"process.m1 = cms.EDProducer('IntProducer',\n"
" ivalue = cms.int32(11)\n"
")\n"
"process.out = cms.OutputModule('PoolOutputModule',\n"
" fileName = cms.untracked.string('testStandalone.root')\n"
")\n"
"process.p = cms.Path(process.m1)\n"
"process.e = cms.EndPath(process.out)\n");
edm::EventProcessor proc(edm::getPSetFromConfig(configuration));
proc.beginJob();
proc.run();
proc.endJob();
}
{
std::string configuration(
"import FWCore.ParameterSet.Config as cms\n"
"process = cms.Process('TEST1')\n"
"process.source = cms.Source('PoolSource',\n"
" fileNames = cms.untracked.vstring('file:testStandalone.root')\n"
")\n"
"process.InitRootHandlers = cms.Service('InitRootHandlers')\n"
"process.JobReportService = cms.Service('JobReportService')\n"
"process.add_(cms.Service('SiteLocalConfigService'))\n");
edm::EventProcessor proc(edm::getPSetFromConfig(configuration));
proc.beginJob();
proc.run();
proc.endJob();
}
}
|