Skip to content
Snippets Groups Projects
Commit a59e9f3b authored by Tobias Winchen's avatar Tobias Winchen
Browse files

Merge branch 'multithread_dbdisk' into 'devel'

bug fix for output name on db_disk_multithread.

See merge request !12
parents cf0b0b7a 913f1830
Branches
Tags
1 merge request!12bug fix for output name on db_disk_multithread.
Pipeline #100325 failed
...@@ -44,7 +44,7 @@ bool DiskSinkMultithread::operator()(RawBytes& block) ...@@ -44,7 +44,7 @@ bool DiskSinkMultithread::operator()(RawBytes& block)
ascii_header_set(_loop_header, "OBS_OFFSET", "%ld", _counter + ii * block.used_bytes() / _nthread); ascii_header_set(_loop_header, "OBS_OFFSET", "%ld", _counter + ii * block.used_bytes() / _nthread);
ascii_header_set(_loop_header, "FILE_SIZE", "%ld", block.used_bytes() / _nthread); ascii_header_set(_loop_header, "FILE_SIZE", "%ld", block.used_bytes() / _nthread);
std::stringstream fname; std::stringstream fname;
fname << _start_time << std::setw(20) << "_" << std::setfill('0') << _counter + ii * block.used_bytes() / _nthread << ".dada"; fname << _start_time << "_" << std::setw(20) << std::setfill('0') << _counter + ii * block.used_bytes() / _nthread << ".dada";
BOOST_LOG_TRIVIAL(debug) << "filename" << fname.str(); BOOST_LOG_TRIVIAL(debug) << "filename" << fname.str();
_output_streams[ii].open(fname.str().c_str(), std::ios::out | std::ios::app | std::ios::binary); _output_streams[ii].open(fname.str().c_str(), std::ios::out | std::ios::app | std::ios::binary);
_output_streams[ii].write((char*) _loop_header, HEADER_SIZE); _output_streams[ii].write((char*) _loop_header, HEADER_SIZE);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment