Mercurial > hg > orthanc

comparison UnitTestsSources/MultiThreadingTests.cpp @ 2730:cb1b26a7db98

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
fix mingw compilation
author s.jodogne@gmail.com
date Fri, 13 Jul 2018 12:34:53 +0200
parents 46061a91c88a
children fe4fe52f0c94
comparison
equal deleted inserted replaced
2728:cdf13d06cf40 2730:cb1b26a7db98
705 { 705 {
706 SequenceOfOperationsJob::Lock lock(*job); 706 SequenceOfOperationsJob::Lock lock(*job);
707 size_t i = lock.AddOperation(new LogJobOperation); 707 size_t i = lock.AddOperation(new LogJobOperation);
708 size_t j = lock.AddOperation(new LogJobOperation); 708 size_t j = lock.AddOperation(new LogJobOperation);
709 size_t k = lock.AddOperation(new LogJobOperation); 709 size_t k = lock.AddOperation(new LogJobOperation);
710 lock.AddInput(i, StringOperationValue("Hello")); 710
711 lock.AddInput(i, StringOperationValue("World")); 711 StringOperationValue a("Hello");
712 StringOperationValue b("World");
713 lock.AddInput(i, a);
714 lock.AddInput(i, b);
715
712 lock.Connect(i, j); 716 lock.Connect(i, j);
713 lock.Connect(j, k); 717 lock.Connect(j, k);
714 } 718 }
715 719
716 boost::this_thread::sleep(boost::posix_time::milliseconds(2000)); 720 boost::this_thread::sleep(boost::posix_time::milliseconds(2000));
1000 { 1004 {
1001 SequenceOfOperationsJob::Lock lock(job); 1005 SequenceOfOperationsJob::Lock lock(job);
1002 size_t a = lock.AddOperation(new LogJobOperation); 1006 size_t a = lock.AddOperation(new LogJobOperation);
1003 size_t b = lock.AddOperation(new LogJobOperation); 1007 size_t b = lock.AddOperation(new LogJobOperation);
1004 lock.Connect(a, b); 1008 lock.Connect(a, b);
1005 lock.AddInput(a, StringOperationValue("hello")); 1009
1006 lock.AddInput(a, StringOperationValue("world")); 1010 StringOperationValue s1("hello");
1011 StringOperationValue s2("world");
1012 lock.AddInput(a, s1);
1013 lock.AddInput(a, s2);
1007 lock.SetDicomAssociationTimeout(200); 1014 lock.SetDicomAssociationTimeout(200);
1008 lock.SetTrailingOperationTimeout(300); 1015 lock.SetTrailingOperationTimeout(300);
1009 } 1016 }
1010 1017
1011 ASSERT_EQ(JobStepCode_Continue, job.ExecuteStep().GetCode()); 1018 ASSERT_EQ(JobStepCode_Continue, job.ExecuteStep().GetCode());