blob: cefb129b90c3c70386b34fcc1c3e06e126b9d73e (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
|
#ifndef STATUSHANDLER_H_INCLUDED
#define STATUSHANDLER_H_INCLUDED
#include <wx/longlong.h>
class Zstring;
const int UI_UPDATE_INTERVAL = 100; //perform ui updates not more often than necessary, 100 seems to be a good value with only a minimal performance loss
bool updateUiIsAllowed(); //test if a specific amount of time is over
void updateUiNow(); //do the updating
//interfaces for status updates (can be implemented by GUI or Batch mode)
//overwrite virtual methods for respective functionality
class ErrorHandler
{
public:
ErrorHandler() {}
virtual ~ErrorHandler() {}
enum Response
{
IGNORE_ERROR = 10,
RETRY
};
virtual Response reportError(const Zstring& errorMessage) = 0;
};
class StatusHandler
{
public:
StatusHandler() : abortRequested(false) {}
virtual ~StatusHandler() {}
//identifiers of different processes
enum Process
{
PROCESS_NONE = 10,
PROCESS_SCANNING,
PROCESS_COMPARING_CONTENT,
PROCESS_SYNCHRONIZING
};
//these methods have to be implemented in the derived classes to handle error and status information
virtual void initNewProcess(int objectsTotal, wxLongLong dataTotal, Process processID) = 0; //informs about the total amount of data that will be processed from now on
virtual void updateStatusText(const Zstring& text) = 0;
virtual void updateProcessedData(int objectsProcessed, wxLongLong dataProcessed) = 0; //called periodically after data was processed
//this method is triggered repeatedly by requestUiRefresh() and can be used to refresh the ui by dispatching pending events
virtual void forceUiRefresh() = 0;
void requestUiRefresh(bool allowAbort = true); //opportunity to abort must be implemented in a frequently executed method like requestUiRefresh()
void requestAbortion(); //this does NOT call abortThisProcess immediately, but when appropriate (e.g. async. processes finished)
bool abortIsRequested();
//error handling:
virtual ErrorHandler::Response reportError(const wxString& errorMessage) = 0; //recoverable error situation
virtual void reportFatalError(const wxString& errorMessage) = 0; //non-recoverable error situation, implement abort!
virtual void reportWarning(const wxString& warningMessage, bool& warningActive) = 0;
private:
virtual void abortThisProcess() = 0;
bool abortRequested;
};
//##############################################################################
inline
void StatusHandler::requestUiRefresh(bool allowAbort)
{
if (updateUiIsAllowed()) //test if specific time span between ui updates is over
forceUiRefresh();
if (abortRequested && allowAbort)
abortThisProcess(); //abort can be triggered by requestAbortion()
}
inline
void StatusHandler::requestAbortion()
{
abortRequested = true;
}
inline
bool StatusHandler::abortIsRequested()
{
return abortRequested;
}
#endif // STATUSHANDLER_H_INCLUDED
|
