Mercurial > hg > orthanc
comparison UnitTestsSources/MultiThreadingTests.cpp @ 3857:67f988f42cef transcoding
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 { |