Commit 98fdf05b authored by David COME's avatar David COME
Browse files

Renamed DiskReadThreadPool::DiskReadWorkerThread::_this to m_parent

parent 44c37b8f
...@@ -82,7 +82,7 @@ namespace daemon { ...@@ -82,7 +82,7 @@ namespace daemon {
void DiskReadThreadPool::DiskReadWorkerThread::run() { void DiskReadThreadPool::DiskReadWorkerThread::run() {
std::auto_ptr<DiskReadTaskInterface> task; std::auto_ptr<DiskReadTaskInterface> task;
while (1) { while (1) {
task.reset(_this.popAndRequestMore()); task.reset(m_parent.popAndRequestMore());
if (NULL != task.get()) { if (NULL != task.get()) {
task->execute(lc); task->execute(lc);
} else { } else {
......
...@@ -55,7 +55,7 @@ private: ...@@ -55,7 +55,7 @@ private:
class DiskReadWorkerThread: private castor::tape::threading::Thread { class DiskReadWorkerThread: private castor::tape::threading::Thread {
public: public:
DiskReadWorkerThread(DiskReadThreadPool & manager): DiskReadWorkerThread(DiskReadThreadPool & manager):
threadID(m_nbActiveThread++),_this(manager),lc(_this.m_lc) { threadID(m_nbActiveThread++),m_parent(manager),lc(m_parent.m_lc) {
log::LogContext::ScopedParam param(lc, log::Param("threadID", threadID)); log::LogContext::ScopedParam param(lc, log::Param("threadID", threadID));
lc.log(LOG_INFO,"DiskWrite Thread created"); lc.log(LOG_INFO,"DiskWrite Thread created");
} }
...@@ -64,7 +64,7 @@ private: ...@@ -64,7 +64,7 @@ private:
private: private:
static tape::threading::AtomicCounter<int> m_nbActiveThread; static tape::threading::AtomicCounter<int> m_nbActiveThread;
const int threadID; const int threadID;
DiskReadThreadPool & _this; DiskReadThreadPool & m_parent;
castor::log::LogContext lc; castor::log::LogContext lc;
virtual void run(); virtual void run();
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment