}
};
+static std::atomic<int> g_receivedAnswers1;
+static void report1(DNSPacket* A)
+{
+ delete A;
+ g_receivedAnswers1++;
+}
BOOST_AUTO_TEST_CASE(test_distributor_queue) {
::arg().set("overload-queue-length","Maximum queuelength moving to packetcache only")="0";
for(n=0; n < 2000; ++n) {
auto q = new Question();
q->d_dt.set();
- d->question(q, report);
+ d->question(q, report1);
}
}, DistributorFatal, [](DistributorFatal) { return true; });
};
S.declare("timedout-packets", "timedout-packets");
auto d=Distributor<DNSPacket, Question, BackendDies>::Create(10);
- sleep(1);
- g_receivedAnswers=0;
try {
for(int n=0; n < 100; ++n) {
// tuple contains <type, user value, zone representation, line value, broken>
typedef boost::tuple<QType::typeenum, std::string, std::string, std::string, broken_marker> case_t;
typedef std::list<case_t> cases_t;
- reportAllTypes();
MRRecordContent::report();
IPSECKEYRecordContent::report();
KXRecordContent::report();
BOOST_AUTO_TEST_CASE(test_QueryCacheThreaded) {
try {
+ g_QCmissing = 0;
AuthQueryCache QC;
QC.setMaxEntries(1000000);
g_QC=&QC;
PC.setTTL(3600);
g_PC=&PC;
+ g_QCmissing = 0;
pthread_t tid[4];
for(int i=0; i < 4; ++i)
pthread_create(&tid[i], 0, threadPCMangler, (void*)(i*1000000UL));
#define BOOST_TEST_DYN_LINK
-#define BOOST_TEST_MAIN
-#define BOOST_TEST_MODULE unit
#ifdef HAVE_CONFIG_H
#include "config.h"
static ArgvMap theArg;
return theArg;
}
+
+
+bool init_unit_test() {
+ cerr << "Initing..." << endl;
+ reportAllTypes();
+ return true;
+}
+
+// entry point:
+int main(int argc, char* argv[])
+{
+ return boost::unit_test::unit_test_main( &init_unit_test, argc, argv );
+}