Mercurial > hg > orthanc

comparison UnitTestsSources/MultiThreadingTests.cpp @ 1000:13e230bbd882 lua-scripting

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
rename filter to command
author Sebastien Jodogne <s.jodogne@gmail.com>
date Fri, 04 Jul 2014 14:14:14 +0200
parents 8c67382f44a7
children 84b6d7bca6db
comparison
equal deleted inserted replaced
999:db18c071fbd7 1000:13e230bbd882
275 printf("DONE\n"); fflush(stdout); 275 printf("DONE\n"); fflush(stdout);
276 } 276 }
277 277
278 278
279 279
280 class Tutu : public IServerFilter 280 class Tutu : public IServerCommand
281 { 281 {
282 private: 282 private:
283 int factor_; 283 int factor_;
284 284
285 public: 285 public:
315 }; 315 };
316 316
317 317
318 static void Tata(ServerScheduler* s, ServerJob* j, bool* done) 318 static void Tata(ServerScheduler* s, ServerJob* j, bool* done)
319 { 319 {
320 typedef IServerFilter::ListOfStrings ListOfStrings; 320 typedef IServerCommand::ListOfStrings ListOfStrings;
321 321
322 #if 1 322 #if 1
323 while (!(*done)) 323 while (!(*done))
324 { 324 {
325 ListOfStrings l; 325 ListOfStrings l;
346 TEST(Toto, Toto) 346 TEST(Toto, Toto)
347 { 347 {
348 ServerScheduler scheduler(10); 348 ServerScheduler scheduler(10);
349 349
350 ServerJob job; 350 ServerJob job;
351 ServerFilterInstance& f2 = job.AddFilter(new Tutu(2)); 351 ServerCommandInstance& f2 = job.AddCommand(new Tutu(2));
352 ServerFilterInstance& f3 = job.AddFilter(new Tutu(3)); 352 ServerCommandInstance& f3 = job.AddCommand(new Tutu(3));
353 ServerFilterInstance& f4 = job.AddFilter(new Tutu(4)); 353 ServerCommandInstance& f4 = job.AddCommand(new Tutu(4));
354 ServerFilterInstance& f5 = job.AddFilter(new Tutu(5)); 354 ServerCommandInstance& f5 = job.AddCommand(new Tutu(5));
355 f2.AddInput(boost::lexical_cast<std::string>(42)); 355 f2.AddInput(boost::lexical_cast<std::string>(42));
356 //f3.AddInput(boost::lexical_cast<std::string>(42)); 356 //f3.AddInput(boost::lexical_cast<std::string>(42));
357 //f4.AddInput(boost::lexical_cast<std::string>(42)); 357 //f4.AddInput(boost::lexical_cast<std::string>(42));
358 f2.ConnectNext(f3); 358 f2.ConnectNext(f3);
359 f3.ConnectNext(f4); 359 f3.ConnectNext(f4);
365 boost::thread t(Tata, &scheduler, &job, &done); 365 boost::thread t(Tata, &scheduler, &job, &done);
366 366
367 367
368 //scheduler.Submit(job); 368 //scheduler.Submit(job);
369 369
370 IServerFilter::ListOfStrings l; 370 IServerCommand::ListOfStrings l;
371 scheduler.SubmitAndWait(l, job); 371 scheduler.SubmitAndWait(l, job);
372 372
373 for (IServerFilter::ListOfStrings::iterator i = l.begin(); i != l.end(); i++) 373 for (IServerCommand::ListOfStrings::iterator i = l.begin(); i != l.end(); i++)
374 { 374 {
375 printf("** %s\n", i->c_str()); 375 printf("** %s\n", i->c_str());
376 } 376 }
377 377
378 //Toolbox::ServerBarrier(); 378 //Toolbox::ServerBarrier();