Mercurial > hg > orthanc
comparison UnitTestsSources/MultiThreadingTests.cpp @ 1000:13e230bbd882 lua-scripting
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(); |