| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | Recorder::~Recorder(){ |
|---|
| | | // if (out_){ |
|---|
| | | // stop_recorder_.store(true); |
|---|
| | | // cv_.notify_one(); |
|---|
| | | // int try_cnt = 0; |
|---|
| | | // while(stop_recorder_.load()){ |
|---|
| | | // logIt("REC WAIT TO QUIT ID %s", id_.c_str()); |
|---|
| | | // if (try_cnt > 100){ |
|---|
| | | // logIt("REC TRY %d TIMES TO QUIT..., BREAK!!!", try_cnt); |
|---|
| | | // break; |
|---|
| | | // } |
|---|
| | | // try_cnt++; |
|---|
| | | // sleep(1); |
|---|
| | | // } |
|---|
| | | // }else if (stop_recorder_.load()){ |
|---|
| | | // logIt("REC NORMAL QUIT"); |
|---|
| | | // } |
|---|
| | | |
|---|
| | | if (thrd_){ |
|---|
| | | stop_recorder_.store(true); |
|---|
| | | thrd_->join(); |
|---|
| | | logIt("REC THREAD JOINED, QUIT!!!"); |
|---|
| | | try |
|---|
| | | { |
|---|
| | | if (thrd_){ |
|---|
| | | stop_recorder_.store(true); |
|---|
| | | cv_.notify_one(); |
|---|
| | | thrd_->join(); |
|---|
| | | logIt("REC THREAD JOINED, QUIT!!!"); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | catch(const std::exception& e) |
|---|
| | | { |
|---|
| | | logIt("RECODER DESTRUCTOR EXCEPTION: ", e.what()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | int Recorder::init_writer(){ |
|---|
| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
