Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Version 1.2.8 (fixes, ehnacements, improved datum management) #234

Merged
merged 108 commits into from
Feb 24, 2025
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
108 commits
Select commit Hold shift + click to select a range
b38e2a7
Remove unnecessary stdlib include
rogerfraser May 26, 2023
9a5253f
Merge branch 'master' of https://github.com/rogerfraser/DynAdjust
rogerfraser May 26, 2023
0ddf9cc
Normalise and improve handling of epsg codes
rogerfraser May 7, 2024
c097621
Add ability to identify first file
rogerfraser May 7, 2024
2618e43
Improve handling of project datum on data import
rogerfraser May 7, 2024
f47b6fc
Add new MSVC versions
rogerfraser May 7, 2024
8f27b6b
Improve monitoring of program execution
rogerfraser May 7, 2024
2b4e329
Change behaviour of reference frame option and improve reporting
rogerfraser May 8, 2024
f3bc1d9
Add a new pointer type definition
rogerfraser May 8, 2024
fbf191f
Simplify logic implementation
rogerfraser May 8, 2024
5d197bc
Revert to file datum first, then project datum
rogerfraser May 8, 2024
c8b175a
Simplify logic implementation
rogerfraser May 8, 2024
eb4900f
Update GUI reporting
rogerfraser Aug 21, 2024
c12c691
Enable datum override using first file
rogerfraser Aug 21, 2024
493b0a6
Fix N-stat sorting for X msrs
rogerfraser Aug 22, 2024
7e9ab90
Reset X Nstat value
rogerfraser Aug 23, 2024
8036ecd
Fix adj output sorting on msr correction
rogerfraser Aug 26, 2024
1da9a25
Fix adj output sorting on msr correction
rogerfraser Aug 26, 2024
f3c9e9e
Update commit
rogerfraser Aug 26, 2024
480498c
Fix adj output sorting on msr adj sd
rogerfraser Aug 26, 2024
d34f4be
Fix adj output sorting on msr value
rogerfraser Aug 26, 2024
cbbb9fd
Remove unnecessary option to sort adj msr by outlier (use n-stat inst…
rogerfraser Aug 27, 2024
7c7dfae
Make reference-frame argument optional
rogerfraser Aug 27, 2024
c565a78
Prevent create-stage-files option in report results mode
rogerfraser Aug 30, 2024
32c8e23
Improve locating MKL for cmake builds
rogerfraser Sep 2, 2024
5916e90
Replace deprecated function
rogerfraser Sep 3, 2024
8c7fbc9
Remove unused variable
rogerfraser Sep 3, 2024
b535bbd
Fix DBID output on printing alternate GNSS units
rogerfraser Sep 3, 2024
d657f8c
Improve help-module search
rogerfraser Sep 10, 2024
99fdea1
Improve initialisation of default datum
rogerfraser Sep 10, 2024
49c0141
Minor enhancement
rogerfraser Sep 10, 2024
81864b7
Improve handling of ignored directions and direction sets
rogerfraser Sep 10, 2024
81e4399
Improve commentary on interation threshold
rogerfraser Sep 11, 2024
19ab481
Add i/o indicators for reftran and geoid
rogerfraser Oct 7, 2024
08055b2
Add file type test method
rogerfraser Oct 7, 2024
24b7457
Improve reference frame reporting
rogerfraser Oct 7, 2024
a06debc
Remove unnecessary guard on writing file metadata
rogerfraser Oct 7, 2024
88eabe6
Capture if reference frame source is the file
rogerfraser Oct 22, 2024
fd65bc4
Manage epoch reporting with static frames
rogerfraser Oct 22, 2024
01fd681
Restrict parsing of cluster id to field width
rogerfraser Oct 23, 2024
310a3aa
Minor UI enhancements
rogerfraser Oct 23, 2024
67e93ba
Harmonise all references to zenith distance
rogerfraser Oct 25, 2024
77981f9
New method to get reference epoch from epsg string
rogerfraser Jan 23, 2025
57fdeb3
Add epoch as optional argument and handle datum init
rogerfraser Jan 23, 2025
77e057d
Update comments and XML datum parsing
rogerfraser Jan 23, 2025
c6da4da
Park undefined method
rogerfraser Jan 24, 2025
025d73d
Park undefined methods
rogerfraser Jan 24, 2025
1e5f79b
Remove unnecessary include
rogerfraser Jan 24, 2025
740bbdd
Make vcxproj files consistent. Fix std byte C++17
rogerfraser Jan 24, 2025
3beeb20
Further changes to improve frame and epoch handling
rogerfraser Jan 24, 2025
c6ff4cf
Handle file epoch with cmd line supplied frame
rogerfraser Jan 24, 2025
98fbddf
Cater for blank file epoch
rogerfraser Jan 24, 2025
f8b042b
Set epoch from cmd line
rogerfraser Jan 24, 2025
491767f
Set override datum for msr files
rogerfraser Jan 24, 2025
2b874b7
Improve comments
rogerfraser Jan 29, 2025
a118590
Handle user supplied epoch in XML files
rogerfraser Jan 29, 2025
dc4ab1d
Handle empty frame and epoch tags in xml msrs
rogerfraser Jan 31, 2025
261b2ed
Improve handling of specified frame for xml files
rogerfraser Jan 31, 2025
d79cd2a
Remove unused variables
rogerfraser Jan 31, 2025
6db3a5d
Replace deprecated basename with stem
rogerfraser Jan 31, 2025
184ba22
Fix overrides
rogerfraser Jan 31, 2025
ae2b105
Handle import epoch in project files
rogerfraser Feb 4, 2025
6f528a8
Improve handling multiple file datums on import
rogerfraser Feb 4, 2025
f8cbd92
Add help relating to code changes (frame, epoch)
rogerfraser Feb 5, 2025
83e0c06
Remove using namespace std and boost
rogerfraser Feb 10, 2025
2fc5544
Update to Boost 1.87
rogerfraser Feb 10, 2025
ac9ebfc
Further namespace clean up
rogerfraser Feb 10, 2025
a455bb4
Reduce windows includes to essentials
rogerfraser Feb 10, 2025
57cf9a1
Improve test procedure
rogerfraser Feb 10, 2025
d8399fc
Fix test for reporting proj ref frame
rogerfraser Feb 10, 2025
8af5827
Revert to original preprocessor definition
rogerfraser Feb 10, 2025
2dccbaf
Address incorrect cast
rogerfraser Feb 10, 2025
40d4f7b
Test for unique macro definitions
rogerfraser Feb 10, 2025
b25b6d3
Handle a change to the apu header
rogerfraser Feb 10, 2025
6e6539d
Another fix to test for reporting proj ref frame
rogerfraser Feb 11, 2025
b5f4e14
Test no longer valid
rogerfraser Feb 11, 2025
d920447
Update cmake_release.yml
rogerfraser Feb 11, 2025
1e0b892
Update test_coverage.yml
rogerfraser Feb 11, 2025
0842721
Remove test for no frame
rogerfraser Feb 11, 2025
880ce22
Merge branch 'master' of https://github.com/rogerfraser/dynadjust
rogerfraser Feb 11, 2025
39c30fb
Fix handling of user-supplied epoch
rogerfraser Feb 11, 2025
7d591fc
Add latest MSVC compiler versions
rogerfraser Feb 11, 2025
a9d3d47
Catch unrecognised frame label
rogerfraser Feb 11, 2025
9e1253e
Update tests
rogerfraser Feb 11, 2025
c3a2b5d
Update tests
rogerfraser Feb 12, 2025
5f720ec
Update BUILDING.md
rogerfraser Feb 12, 2025
a1d63e0
Update proj epsg code when if changed from first file datum
rogerfraser Feb 13, 2025
9ca733b
Merge branch 'master' of https://github.com/rogerfraser/dynadjust
rogerfraser Feb 13, 2025
7339512
Update copyright year
rogerfraser Feb 17, 2025
8f210d9
Initialise epoch for static datums
rogerfraser Feb 18, 2025
e790454
Fix handling of static datum epoch
rogerfraser Feb 18, 2025
55a242a
UI enhancements
rogerfraser Feb 19, 2025
a31707a
Initialise default epoch
rogerfraser Feb 19, 2025
2fd038f
Frame and epoch warning and error enhancements
rogerfraser Feb 20, 2025
0a6cfff
Handle incomplete date string
rogerfraser Feb 20, 2025
195c42e
Add incomplte date to tests
rogerfraser Feb 20, 2025
7f7e8ba
Improve handling of user supplied epoch
rogerfraser Feb 20, 2025
6b634df
Create symlinks to assist testing
rogerfraser Feb 20, 2025
4e64ebb
Handle process exceptions
rogerfraser Feb 20, 2025
03ed1ab
Add new tests
rogerfraser Feb 21, 2025
378825d
Increase reftran test coverage
rogerfraser Feb 21, 2025
e70768a
Increase transformation parameter code coverage
rogerfraser Feb 21, 2025
0f16684
Update docker.yml
rogerfraser Feb 21, 2025
181b521
Improve UI messaging re frame and epoch
rogerfraser Feb 24, 2025
46cef52
Merge branch 'master' of https://github.com/rogerfraser/dynadjust
rogerfraser Feb 24, 2025
3fd6e3a
Minor enhancements
rogerfraser Feb 24, 2025
5076143
Remove unused variable
rogerfraser Feb 24, 2025
d1479bd
Merge pull request #233 from rogerfraser/master
rogerfraser Feb 24, 2025
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions .github/workflows/cmake_release.yml
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@ on:
branches: [ master ]
pull_request:
branches: [ master ]
workflow_dispatch:

env:
# Customize the CMake build type here (Release, Debug, RelWithDebInfo, etc.)
Expand Down
6 changes: 4 additions & 2 deletions .github/workflows/docker.yml
Original file line number Diff line number Diff line change
Expand Up @@ -3,8 +3,10 @@ name: Build docker image

on:
push:
branches:
- 'master'
branches: [ master ]
pull_request:
branches: [ master ]
workflow_dispatch:

jobs:
docker:
Expand Down
1 change: 1 addition & 0 deletions .github/workflows/test_coverage.yml
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@ on:
branches: [ master ]
pull_request:
branches: [ master ]
workflow_dispatch:

env:
# Customize the CMake build type here (Release, Debug, RelWithDebInfo, etc.)
Expand Down
561 changes: 524 additions & 37 deletions dynadjust/CMakeLists.txt

Large diffs are not rendered by default.

4 changes: 2 additions & 2 deletions dynadjust/dynadjust.props
Original file line number Diff line number Diff line change
Expand Up @@ -2,8 +2,8 @@
<Project ToolsVersion="4.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
<ImportGroup Label="PropertySheets" />
<PropertyGroup Label="UserMacros">
<BoostIncludeDir>C:\Data\boost\boost_1_78_0\include</BoostIncludeDir>
<BoostLibDir>C:\Data\boost\boost_1_78_0\lib\$(Platform)</BoostLibDir>
<BoostIncludeDir>C:\Data\boost\boost_1_87_0\include</BoostIncludeDir>
<BoostLibDir>C:\Data\boost\boost_1_87_0\lib\$(Platform)</BoostLibDir>
<XsdIncludeDir>C:\Program Files (x86)\CodeSynthesis XSD 4.0\include</XsdIncludeDir>
<XsdLibDir_x64>C:\Program Files (x86)\CodeSynthesis XSD 4.0\lib64\vc-12.0</XsdLibDir_x64>
<XsdLibDir_Win32>C:\Program Files (x86)\CodeSynthesis XSD 4.0\lib\vc-12.0</XsdLibDir_Win32>
Expand Down
2 changes: 1 addition & 1 deletion dynadjust/dynadjust.rc
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@ BEGIN
VALUE "FileDescription", "DynAdjust is a rigorous, high performance least squares adjustment application."
VALUE "FileVersion", "1.2.8.0"
VALUE "InternalName", "DynAdjust"
VALUE "LegalCopyright", "Copyright 2022 Geoscience Australia"
VALUE "LegalCopyright", "Copyright 2025 Geoscience Australia"
VALUE "OriginalFilename", "DynAdjust"
VALUE "ProductName", "DynAdjust"
VALUE "ProductVersion", "1.2.8.0"
Expand Down
106 changes: 53 additions & 53 deletions dynadjust/dynadjust/dnaadjust/dnaadjust-multi.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@ extern boost::exception_ptr rev_error;
extern boost::exception_ptr cmb_error;
extern boost::exception_ptr prep_error;

bool combineAdjustmentExceptionThrown(const vector<boost::exception_ptr>& cmb_errors_)
bool combineAdjustmentExceptionThrown(const std::vector<boost::exception_ptr>& cmb_errors_)
{
// got a forward or reverse exception, or
// have any of the other combination adjustments failed?
Expand All @@ -58,7 +58,7 @@ bool combineAdjustmentExceptionThrown(const vector<boost::exception_ptr>& cmb_er
return false;
}

bool prepareAdjustmentExceptionThrown(const vector<boost::exception_ptr>& prep_errors_)
bool prepareAdjustmentExceptionThrown(const std::vector<boost::exception_ptr>& prep_errors_)
{
// have any of the other combination adjustments failed?
UINT32 err_size(static_cast<UINT32>(prep_errors_.size()));
Expand Down Expand Up @@ -94,19 +94,19 @@ void dna_adjust::AdjustPhasedMultiThread()
{
initialiseIteration();

string corr_msg;
ostringstream ss;
std::string corr_msg;
std::ostringstream ss;
UINT32 i;
bool iterate(true);

milliseconds iteration_time(milliseconds(0));
cpu_timer it_time, tot_time;
boost::posix_time::milliseconds iteration_time(boost::posix_time::milliseconds(0));
boost::timer::cpu_timer it_time, tot_time;

#if defined(__ICC) || defined(__INTEL_COMPILER) // Intel compiler
boost::shared_ptr<thread> f, r, c;
vector< boost::shared_ptr<thread> > mt_adjust_threads_sp;
std::vector< boost::shared_ptr<thread> > mt_adjust_threads_sp;
#else
vector<boost::thread> mt_adjust_threads;
std::vector<boost::thread> mt_adjust_threads;
#endif

concurrentAdjustments.resize_runs(blockCount_);
Expand Down Expand Up @@ -170,7 +170,7 @@ void dna_adjust::AdjustPhasedMultiThread()
for_each(mt_adjust_threads.begin(), mt_adjust_threads.end(), boost::mem_fn(&boost::thread::join));
#endif
// This point is reached when the threads have finished
iteration_time = milliseconds(it_time.elapsed().wall/MILLI_TO_NANO);
iteration_time = boost::posix_time::milliseconds(it_time.elapsed().wall/MILLI_TO_NANO);

//delete mt_adjust_threads;
#if defined(__ICC) || defined(__INTEL_COMPILER) // Intel compiler
Expand All @@ -197,15 +197,15 @@ void dna_adjust::AdjustPhasedMultiThread()
break;

ss.str("");
if (iteration_time > seconds(1))
ss << seconds(static_cast<long>(iteration_time.total_seconds()));
if (iteration_time > boost::posix_time::seconds(1))
ss << boost::posix_time::seconds(static_cast<long>(iteration_time.total_seconds()));
else
ss << iteration_time;

///////////////////////////////////
// protected write to adj file (not needed here since write to
// adj file at this stage is via single thread
adj_file << setw(PRINT_VAR_PAD) << left << "Elapsed time" << ss.str() << endl;
adj_file << std::setw(PRINT_VAR_PAD) << std::left << "Elapsed time" << ss.str() << std::endl;
OutputLargestCorrection(corr_msg);
///////////////////////////////////

Expand Down Expand Up @@ -277,7 +277,7 @@ void dna_adjust::SolveMTTry(bool COMPUTE_INVERSE, const UINT32& block)
try {
SolveMT(COMPUTE_INVERSE, block);
}
catch (const runtime_error& e) {
catch (const std::runtime_error& e) {

// could not invert matrix. throw error

Expand All @@ -286,12 +286,12 @@ void dna_adjust::SolveMTTry(bool COMPUTE_INVERSE, const UINT32& block)
#endif
if (projectSettings_.g.verbose)
{
debug_file << "Block " << block + 1 << " (reverse, multi-thread)" << endl;
debug_file << "Pre-adjustment Estimates" << fixed << setprecision(16) << v_estimatedStationsR_.at(block);
debug_file << "Design" << fixed << setprecision(16) << v_designR_.at(block);
debug_file << "Measurements" << fixed << setprecision(16) << v_measMinusCompR_.at(block);
debug_file << "At * V-inv" << fixed << setprecision(16) << v_AtVinvR_.at(block);
debug_file << "Normals " << fixed << setprecision(16) << v_normalsR_.at(block) << endl;
debug_file << "Block " << block + 1 << " (reverse, multi-thread)" << std::endl;
debug_file << "Pre-adjustment Estimates" << std::fixed << std::setprecision(16) << v_estimatedStationsR_.at(block);
debug_file << "Design" << std::fixed << std::setprecision(16) << v_designR_.at(block);
debug_file << "Measurements" << std::fixed << std::setprecision(16) << v_measMinusCompR_.at(block);
debug_file << "At * V-inv" << std::fixed << std::setprecision(16) << v_AtVinvR_.at(block);
debug_file << "Normals " << std::fixed << std::setprecision(16) << v_normalsR_.at(block) << std::endl;
debug_file.flush();
}
#ifdef _MS_COMPILER_
Expand Down Expand Up @@ -344,29 +344,29 @@ void dna_adjust::SolveMT(bool COMPUTE_INVERSE, const UINT32& block)
break;
}

debug_file << endl;
debug_file << std::endl;

debug_file << "Block " << block + 1 << " (Reverse)";
debug_file << endl;
debug_file << "Pre-adjustment Estimates" << fixed << setprecision(16) << v_estimatedStationsR_.at(block);
debug_file << std::endl;
debug_file << "Pre-adjustment Estimates" << std::fixed << std::setprecision(16) << v_estimatedStationsR_.at(block);
debug_file << "Block " << block + 1 << " (Reverse)";
debug_file << endl;
debug_file << "Design" << fixed << setprecision(16) << v_designR_.at(block);
debug_file << std::endl;
debug_file << "Design" << std::fixed << std::setprecision(16) << v_designR_.at(block);
debug_file << "Block " << block + 1 << " (Reverse)";
debug_file << endl;
debug_file << "Measurements" << fixed << setprecision(16) << v_measMinusCompR_.at(block);
debug_file << std::endl;
debug_file << "Measurements" << std::fixed << std::setprecision(16) << v_measMinusCompR_.at(block);
debug_file << "Block " << block + 1 << " (Reverse)";
debug_file << endl;
debug_file << "At * V-inv" << fixed << setprecision(16) << v_AtVinvR_.at(block) << endl;
debug_file << std::endl;
debug_file << "At * V-inv" << std::fixed << std::setprecision(16) << v_AtVinvR_.at(block) << std::endl;
debug_file << "Block " << block + 1 << " (Reverse)";
debug_file << endl;
debug_file << "Normals " << fixed << setprecision(16) << v_normalsR_.at(block) << endl;
debug_file << std::endl;
debug_file << "Normals " << std::fixed << std::setprecision(16) << v_normalsR_.at(block) << std::endl;
debug_file << "Block " << block + 1 << " (Reverse)";
debug_file << endl;
debug_file << "Precisions" << fixed << setprecision(16) << v_normalsR_.at(block) << endl;
debug_file << std::endl;
debug_file << "Precisions" << std::fixed << std::setprecision(16) << v_normalsR_.at(block) << std::endl;
debug_file << "Block " << block + 1 << " (Reverse)";
debug_file << endl;
debug_file << "Corrections" << fixed << setprecision(16) << v_correctionsR_.at(block) << endl;
debug_file << std::endl;
debug_file << "Corrections" << std::fixed << std::setprecision(16) << v_correctionsR_.at(block) << std::endl;
debug_file.flush();

dbg_file_mutex.unlock();
Expand All @@ -381,7 +381,7 @@ void dna_adjust::SolveMT(bool COMPUTE_INVERSE, const UINT32& block)

void adjust_forward_thread::operator()()
{
stringstream ss;
std::stringstream ss;
UINT32 currentBlock;

concurrentAdjustments.forward_run_started();
Expand All @@ -396,7 +396,7 @@ void adjust_forward_thread::operator()()
return;

//ss.str("");
//ss << "1> Adjusted block " << currentBlock + 1 << " (forward, in isolation)... " << endl;
//ss << "1> Adjusted block " << currentBlock + 1 << " (forward, in isolation)... " << std::endl;
//main_adj_->ThreadSafeWritetoAdjFile(ss.str());

// Check if an exception was thrown in the reverse or combine threads
Expand All @@ -422,7 +422,7 @@ void adjust_forward_thread::operator()()
/////////////////////////////////////
//// protected write to adj file
//ss.str("");
//ss << "1> Forward adjustment (in isolation) of block " << currentBlock + 1 << " complete." << endl;
//ss << "1> Forward adjustment (in isolation) of block " << currentBlock + 1 << " complete." << std::endl;

//adj_file_mutex.lock();
//main_adj_->ThreadSafeWritetoAdjFile(ss.str());
Expand Down Expand Up @@ -453,7 +453,7 @@ void adjust_forward_thread::operator()()
///////////////////////////////////
// protected write to adj file
//ss.str("");
//ss << "1> Forward adjustment of block " << currentBlock << " complete." << endl;
//ss << "1> Forward adjustment of block " << currentBlock << " complete." << std::endl;

//main_adj_->ThreadSafeWritetoAdjFile(ss.str());
///////////////////////////////////
Expand Down Expand Up @@ -482,7 +482,7 @@ void adjust_forward_thread::operator()()
// notify all threads waiting on combineAdjustmentQueue
//combineAdjustmentQueue.notify_all();

//this_thread::sleep(milliseconds(10));
//this_thread::sleep(boost::posix_time::milliseconds(10));

// notify all threads waiting on combineAdjustmentQueue
//combineAdjustmentQueue.notify_all();
Expand All @@ -491,7 +491,7 @@ void adjust_forward_thread::operator()()

void adjust_reverse_thread::operator()()
{
stringstream ss;
std::stringstream ss;
UINT32 currentBlock(main_adj_->blockCount_-1), block;

concurrentAdjustments.reverse_run_started();
Expand All @@ -516,7 +516,7 @@ void adjust_reverse_thread::operator()()
/////////////////////////////////////
//// protected write to adj file
//ss.str("");
//ss << "2> Adjusted block " << currentBlock + 1 << " (reverse, in isolation)... " << endl;
//ss << "2> Adjusted block " << currentBlock + 1 << " (reverse, in isolation)... " << std::endl;
//main_adj_->ThreadSafeWritetoAdjFile(ss.str());
/////////////////////////////////////

Expand All @@ -543,7 +543,7 @@ void adjust_reverse_thread::operator()()
/////////////////////////////////////
//// protected write to adj file
//ss.str("");
//ss << "2> Reverse adjustment (in isolation) of block " << currentBlock + 1 << " complete." << endl;
//ss << "2> Reverse adjustment (in isolation) of block " << currentBlock + 1 << " complete." << std::endl;

//adj_file_mutex.lock();
//main_adj_->ThreadSafeWritetoAdjFile(ss.str());
Expand Down Expand Up @@ -583,7 +583,7 @@ void adjust_reverse_thread::operator()()
///////////////////////////////////
// protected write to adj file
//ss.str("");
//ss << "2> Reverse adjustment of block " << currentBlock << " complete." << endl;
//ss << "2> Reverse adjustment of block " << currentBlock << " complete." << std::endl;

//main_adj_->ThreadSafeWritetoAdjFile(ss.str());
///////////////////////////////////
Expand All @@ -609,7 +609,7 @@ void adjust_reverse_thread::operator()()

void adjust_process_combine_thread::operator()()
{
stringstream ss;
std::stringstream ss;
UINT32 pseudomsrJSLCount;
UINT32 currentBlock;

Expand All @@ -629,7 +629,7 @@ void adjust_process_combine_thread::operator()()
// Wait here until blocks have been placed on the queue
if (!combineAdjustmentQueue.front_and_pop(currentBlock))
{
boost::this_thread::sleep(milliseconds(2));
boost::this_thread::sleep(boost::posix_time::milliseconds(2));
continue;
}

Expand Down Expand Up @@ -675,15 +675,15 @@ void adjust_combine_thread::operator()()
UINT32 thread_id, cores(boost::thread::hardware_concurrency());

// Set up exception pointers
vector<boost::exception_ptr> cmb_errors;
std::vector<boost::exception_ptr> cmb_errors;
cmb_errors.resize(cores);

// Create the thread pool
#if defined(__ICC) || defined(__INTEL_COMPILER) // Intel compiler
boost::shared_ptr<thread> c;
vector< boost::shared_ptr<thread> > mt_combine_threads_sp;
std::vector< boost::shared_ptr<thread> > mt_combine_threads_sp;
#else
vector<boost::thread> mt_combine_threads;
std::vector<boost::thread> mt_combine_threads;
#endif

for (thread_id=0; thread_id<cores; ++thread_id)
Expand Down Expand Up @@ -732,7 +732,7 @@ void adjust_combine_thread::operator()()

void adjust_process_prepare_thread::operator()()
{
stringstream ss;
std::stringstream ss;
UINT32 currentBlock;

try {
Expand All @@ -748,7 +748,7 @@ void adjust_process_prepare_thread::operator()()
// Wait here until blocks have been placed on the queue
if (!prepareAdjustmentQueue.front_and_pop(currentBlock))
{
boost::this_thread::sleep(milliseconds(2));
boost::this_thread::sleep(boost::posix_time::milliseconds(2));
continue;
}

Expand Down Expand Up @@ -782,15 +782,15 @@ void adjust_prepare_thread::operator()()
UINT32 thread_id, cores(boost::thread::hardware_concurrency());

// Set up exception pointers
vector<boost::exception_ptr> prep_errors;
std::vector<boost::exception_ptr> prep_errors;
prep_errors.resize(cores);

// Create the thread pool
#if defined(__ICC) || defined(__INTEL_COMPILER) // Intel compiler
boost::shared_ptr<thread> p;
vector< boost::shared_ptr<thread> > mt_prepare_threads_sp;
std::vector< boost::shared_ptr<thread> > mt_prepare_threads_sp;
#else
vector<boost::thread> mt_prepare_threads;
std::vector<boost::thread> mt_prepare_threads;
#endif


Expand Down
Loading
Loading