Mercurial > hg > orthanc

comparison UnitTestsSources/MultiThreadingTests.cpp @ 3857:67f988f42cef transcoding

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
integration mainline->transcoding
author Sebastien Jodogne <s.jodogne@gmail.com>
date Tue, 21 Apr 2020 16:33:59 +0200
parents 023b2a9f3aa1 6498739a3c3c
children ea1d32861cfc
comparison
equal deleted inserted replaced
3848:44bfcfdf42e8 3857:67f988f42cef
1096 1096
1097 StringOperationValue s1("hello"); 1097 StringOperationValue s1("hello");
1098 StringOperationValue s2("world"); 1098 StringOperationValue s2("world");
1099 lock.AddInput(a, s1); 1099 lock.AddInput(a, s1);
1100 lock.AddInput(a, s2); 1100 lock.AddInput(a, s2);
1101 lock.SetDicomAssociationTimeout(200);
1102 lock.SetTrailingOperationTimeout(300); 1101 lock.SetTrailingOperationTimeout(300);
1103 } 1102 }
1104 1103
1105 ASSERT_EQ(JobStepCode_Continue, job.Step("jobId").GetCode()); 1104 ASSERT_EQ(JobStepCode_Continue, job.Step("jobId").GetCode());
1106 1105
1282 { 1281 {
1283 private: 1282 private:
1284 MemoryStorageArea storage_; 1283 MemoryStorageArea storage_;
1285 SQLiteDatabaseWrapper db_; // The SQLite DB is in memory 1284 SQLiteDatabaseWrapper db_; // The SQLite DB is in memory
1286 std::unique_ptr<ServerContext> context_; 1285 std::unique_ptr<ServerContext> context_;
1287 TimeoutDicomConnectionManager manager_;
1288 1286
1289 public: 1287 public:
1290 OrthancJobsSerialization() 1288 OrthancJobsSerialization()
1291 { 1289 {
1292 db_.Open(); 1290 db_.Open();
1405 } 1403 }
1406 1404
1407 // StoreScuOperation 1405 // StoreScuOperation
1408 1406
1409 { 1407 {
1410 RemoteModalityParameters modality; 1408 TimeoutDicomConnectionManager luaManager;
1411 modality.SetApplicationEntityTitle("REMOTE"); 1409
1412 modality.SetHost("192.168.1.1"); 1410 {
1413 modality.SetPortNumber(1000); 1411 RemoteModalityParameters modality;
1414 modality.SetManufacturer(ModalityManufacturer_StoreScp); 1412 modality.SetApplicationEntityTitle("REMOTE");
1415 1413 modality.SetHost("192.168.1.1");
1416 StoreScuOperation operation("TEST", modality); 1414 modality.SetPortNumber(1000);
1417 1415 modality.SetManufacturer(ModalityManufacturer_StoreScp);
1418 ASSERT_TRUE(CheckIdempotentSerialization(unserializer, operation)); 1416
1419 operation.Serialize(s); 1417 StoreScuOperation operation(luaManager, "TEST", modality);
1420 } 1418
1421 1419 ASSERT_TRUE(CheckIdempotentSerialization(unserializer, operation));
1422 { 1420 operation.Serialize(s);
1423 operation.reset(unserializer.UnserializeOperation(s)); 1421 }
1424 1422
1425 const StoreScuOperation& tmp = dynamic_cast<StoreScuOperation&>(*operation); 1423 {
1426 ASSERT_EQ("REMOTE", tmp.GetRemoteModality().GetApplicationEntityTitle()); 1424 operation.reset(unserializer.UnserializeOperation(s));
1427 ASSERT_EQ("192.168.1.1", tmp.GetRemoteModality().GetHost()); 1425
1428 ASSERT_EQ(1000, tmp.GetRemoteModality().GetPortNumber()); 1426 const StoreScuOperation& tmp = dynamic_cast<StoreScuOperation&>(*operation);
1429 ASSERT_EQ(ModalityManufacturer_StoreScp, tmp.GetRemoteModality().GetManufacturer()); 1427 ASSERT_EQ("REMOTE", tmp.GetRemoteModality().GetApplicationEntityTitle());
1430 ASSERT_EQ("TEST", tmp.GetLocalAet()); 1428 ASSERT_EQ("192.168.1.1", tmp.GetRemoteModality().GetHost());
1429 ASSERT_EQ(1000, tmp.GetRemoteModality().GetPortNumber());
1430 ASSERT_EQ(ModalityManufacturer_StoreScp, tmp.GetRemoteModality().GetManufacturer());
1431 ASSERT_EQ("TEST", tmp.GetLocalAet());
1432 }
1431 } 1433 }
1432 1434
1433 // SystemCallOperation 1435 // SystemCallOperation
1434 1436
1435 { 1437 {