diff --git a/headers/private/storage/AddOnMonitor.h b/headers/private/storage/AddOnMonitor.h index 84442d3b33..2de6c95871 100644 --- a/headers/private/storage/AddOnMonitor.h +++ b/headers/private/storage/AddOnMonitor.h @@ -1,35 +1,46 @@ +/* + * Copyright 2004-2010, Haiku, Inc. All rights reserved. + * Distributed under the terms of the MIT License. + */ #ifndef _ADD_ON_MONITOR_H #define _ADD_ON_MONITOR_H -#include + #include +#include +#include + #include #include -#include + namespace BPrivate { namespace Storage { + class AddOnMonitorHandler; + class AddOnMonitor : public BLooper { private: - typedef BLooper inherited; + typedef BLooper inherited; public: - AddOnMonitor(AddOnMonitorHandler * handler); - virtual ~AddOnMonitor(); + AddOnMonitor(AddOnMonitorHandler* handler); + virtual ~AddOnMonitor(); - virtual status_t InitCheck(); + virtual status_t InitCheck(); private: - status_t fInitCheck; - BMessage * fPulseMessage; - BMessageRunner * fPulseRunner; + status_t fInitCheck; + BMessageRunner* fPulseRunner; }; + }; // namespace Storage }; // namespace BPrivate + using namespace BPrivate::Storage; + #endif // _ADD_ON_MONITOR_H diff --git a/src/kits/storage/AddOnMonitor.cpp b/src/kits/storage/AddOnMonitor.cpp index 3b8e24073b..0a9934f922 100644 --- a/src/kits/storage/AddOnMonitor.cpp +++ b/src/kits/storage/AddOnMonitor.cpp @@ -1,3 +1,12 @@ +/* + * Copyright 2004-2010, Haiku, Inc. All rights reserved. + * Distributed under the terms of the MIT License. + * + * Authors: + * Andrew Bachmann + */ + + #include "AddOnMonitor.h" #include "AddOnMonitorHandler.h" #include @@ -5,50 +14,50 @@ #include #include -AddOnMonitor::AddOnMonitor(AddOnMonitorHandler * handler) - : BLooper("AddOnMonitor") + +AddOnMonitor::AddOnMonitor(AddOnMonitorHandler* handler) + : + BLooper("AddOnMonitor"), + fInitCheck(B_NO_INIT) { - fInitCheck = B_NO_INIT; AddHandler(handler); SetPreferredHandler(handler); + status_t status; BMessenger messenger(handler, this, &status); if (status != B_OK) { fInitCheck = status; return; } - if (!messenger.IsValid()) { - fInitCheck = B_ERROR; - return; - } - fPulseMessage = new BMessage(B_PULSE); - fPulseRunner = new BMessageRunner(messenger, fPulseMessage, 1000000); + + BMessage pulseMessage(B_PULSE); + fPulseRunner = new BMessageRunner(messenger, &pulseMessage, 1000000); status = fPulseRunner->InitCheck(); if (status != B_OK) { fInitCheck = status; - fprintf(stderr, "AddOnMonitor() : bad status returned by fPulseRunner->InitCheck()\n"); + fprintf(stderr, "AddOnMonitor() : bad status returned by " + "fPulseRunner->InitCheck()\n"); return; } + thread_id id = Run(); if (id < 0) { fInitCheck = (status_t)id; fprintf(stderr, "AddOnMonitor() : bad id returned by Run()\n"); return; } + fInitCheck = B_OK; - return; } -/* virtual */ AddOnMonitor::~AddOnMonitor() { - delete fPulseMessage; delete fPulseRunner; } -/* virtual */ status_t +status_t AddOnMonitor::InitCheck() { return fInitCheck;