Public Member Functions | |
| SeisSequentialWriter (SeisTrcWriter *, int buffsize=-1) | |
| ~SeisSequentialWriter () | |
| bool | announceTrace (const BinID &) |
| bool | submitTrace (SeisTrc *, bool waitforbuffer=true) |
| const char * | errMsg () const |
Protected Attributes | |
| SeisTrcWriter * | writer_ |
| TypeSet< BinID > | announcedtraces_ |
| Threads::ConditionVar | lock_ |
| ObjectSet< SeisTrc > | outputs_ |
| const int | maxbuffersize_ |
| BinID | latestbid_ |
| FixedString | errmsg_ |
Writes traces that are submitted in random order in the correct sequence.
| SeisSequentialWriter::SeisSequentialWriter | ( | SeisTrcWriter * | , | |
| int | buffsize = -1 | |||
| ) |
Writer is owned by caller, not mine. Default bufsize is 2xnrprocessors.
| SeisSequentialWriter::~SeisSequentialWriter | ( | ) |
| bool SeisSequentialWriter::announceTrace | ( | const BinID & | ) |
Tell the writer that this binid will be submitted later.
| const char* SeisSequentialWriter::errMsg | ( | ) | const [inline] |
| bool SeisSequentialWriter::submitTrace | ( | SeisTrc * | , | |
| bool | waitforbuffer = true | |||
| ) |
Trc becomes mine. If waitforbuffer is true and buffer is full, wait until buffer gets smaller.
TypeSet<BinID> SeisSequentialWriter::announcedtraces_ [protected] |
FixedString SeisSequentialWriter::errmsg_ [protected] |
BinID SeisSequentialWriter::latestbid_ [protected] |
Threads::ConditionVar SeisSequentialWriter::lock_ [protected] |
const int SeisSequentialWriter::maxbuffersize_ [protected] |
ObjectSet<SeisTrc> SeisSequentialWriter::outputs_ [protected] |
SeisTrcWriter* SeisSequentialWriter::writer_ [protected] |
1.7.1