// ************************************************************************** // * This file is part of the FreeFileSync project. It is distributed under * // * GNU General Public License: http://www.gnu.org/licenses/gpl.html * // * Copyright (C) Zenju (zenju AT gmx DOT de) - All Rights Reserved * // ************************************************************************** #include "progress_indicator.h" #include #include #include #include #include #include #include #include //wxTextDataObject #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include "gui_generated.h" #include "../lib/ffs_paths.h" #include "../lib/resources.h" #include "../lib/perf_check.h" #include "tray_icon.h" #include "taskbar.h" #include "exec_finished_box.h" #include using namespace zen; warn_static("remove after test") #include namespace { const int GAUGE_FULL_RANGE = 50000; //window size used for statistics in milliseconds const int WINDOW_REMAINING_TIME = 60000; //some scenarios have dropouts of 40 seconds -> 60 sec. window size handles them well const int WINDOW_BYTES_PER_SEC = 5000; // } class CompareProgressDialog::Pimpl : public CompareProgressDlgGenerated { public: Pimpl(wxFrame& parentWindow); void init(const Statistics& syncStat); //constructor/destructor semantics, but underlying Window is reused void finalize(); // void switchToCompareBytewise(); void updateStatusPanelNow(); private: wxFrame& parentWindow_; wxString titleTextBackup; wxStopWatch timeElapsed; long binCompStartMs; //begin of binary comparison phase in [ms] const Statistics* syncStat_; //only bound while sync is running std::unique_ptr taskbar_; std::unique_ptr perf; //estimate remaining time long lastStatCallSpeed; //used for calculating intervals between showing and collecting perf samples }; CompareProgressDialog::Pimpl::Pimpl(wxFrame& parentWindow) : CompareProgressDlgGenerated(&parentWindow), parentWindow_(parentWindow), binCompStartMs(0), syncStat_(nullptr), lastStatCallSpeed(-1000000) //some big number { //init(); -> needed? } void CompareProgressDialog::Pimpl::init(const Statistics& syncStat) { syncStat_ = &syncStat; titleTextBackup = parentWindow_.GetTitle(); try //try to get access to Windows 7/Ubuntu taskbar { taskbar_ = make_unique(parentWindow_); } catch (const TaskbarNotAvailable&) {} //initialize gauge m_gauge2->SetRange(GAUGE_FULL_RANGE); m_gauge2->SetValue(0); perf.reset(); timeElapsed.Start(); //measure total time //initially hide status that's relevant for comparing bytewise only bSizerFilesFound ->Show(true); bSizerFilesRemaining->Show(false); sSizerSpeed ->Show(false); sSizerTimeRemaining ->Show(false); updateStatusPanelNow(); m_gauge2->Hide(); bSizer42->Layout(); Layout(); } void CompareProgressDialog::Pimpl::finalize() { syncStat_ = nullptr; parentWindow_.SetTitle(titleTextBackup); taskbar_.reset(); } void CompareProgressDialog::Pimpl::switchToCompareBytewise() { //start to measure perf perf = make_unique(WINDOW_REMAINING_TIME, WINDOW_BYTES_PER_SEC); lastStatCallSpeed = -1000000; //some big number binCompStartMs = timeElapsed.Time(); //show status for comparing bytewise bSizerFilesFound ->Show(false); bSizerFilesRemaining->Show(true); sSizerSpeed ->Show(true); sSizerTimeRemaining ->Show(true); m_gauge2->Show(); bSizer42->Layout(); Layout(); } void CompareProgressDialog::Pimpl::updateStatusPanelNow() { if (!syncStat_) //no comparison running!! return; //wxWindowUpdateLocker dummy(this) -> not needed const wxString& scannedObjects = toGuiString(syncStat_->getObjectsCurrent(ProcessCallback::PHASE_SCANNING)); auto setTitle = [&](const wxString& title) { if (parentWindow_.GetTitle() != title) parentWindow_.SetTitle(title); }; bool layoutChanged = false; //avoid screen flicker by calling layout() only if necessary const long timeNow = timeElapsed.Time(); //status texts setText(*m_textCtrlStatus, replaceCpy(syncStat_->currentStatusText(), L'\n', L' ')); //no layout update for status texts! //write status information to taskbar, parent title ect. switch (syncStat_->currentPhase()) { case ProcessCallback::PHASE_NONE: case ProcessCallback::PHASE_SCANNING: //dialog caption, taskbar setTitle(scannedObjects + L" - " + _("Scanning...")); if (taskbar_.get()) //support Windows 7 taskbar taskbar_->setStatus(Taskbar::STATUS_INDETERMINATE); break; case ProcessCallback::PHASE_COMPARING_CONTENT: { auto objectsCurrent = syncStat_->getObjectsCurrent(ProcessCallback::PHASE_COMPARING_CONTENT); auto objectsTotal = syncStat_->getObjectsTotal (ProcessCallback::PHASE_COMPARING_CONTENT); auto dataCurrent = syncStat_->getDataCurrent (ProcessCallback::PHASE_COMPARING_CONTENT); auto dataTotal = syncStat_->getDataTotal (ProcessCallback::PHASE_COMPARING_CONTENT); //add both data + obj-count, to handle "deletion-only" cases const double fraction = dataTotal + objectsTotal == 0 ? 0 : std::max(0.0, to(dataCurrent + objectsCurrent) / to(dataTotal + objectsTotal)); //dialog caption, taskbar setTitle(fractionToString(fraction) + wxT(" - ") + _("Comparing content...")); if (taskbar_.get()) { taskbar_->setProgress(fraction); taskbar_->setStatus(Taskbar::STATUS_NORMAL); } //progress indicator, shown for binary comparison only m_gauge2->SetValue(numeric::round(fraction * GAUGE_FULL_RANGE)); //remaining objects and bytes for file comparison setText(*m_staticTextFilesRemaining, toGuiString(objectsTotal - objectsCurrent), &layoutChanged); setText(*m_staticTextDataRemaining, L"(" + filesizeToShortString(dataTotal - dataCurrent) + L")", &layoutChanged); //remaining time and speed: only visible during binary comparison assert(perf); if (perf) if (numeric::dist(lastStatCallSpeed, timeNow) >= 500) { lastStatCallSpeed = timeNow; if (numeric::dist(binCompStartMs, timeNow) >= 1000) //discard stats for first second: probably messy perf->addSample(objectsCurrent, to(dataCurrent), timeNow); //current speed -> Win 7 copy uses 1 sec update interval instead Opt bps = perf->getBytesPerSecond(); setText(*m_staticTextSpeed, bps ? *bps : L"-", &layoutChanged); //remaining time: display with relative error of 10% - based on samples taken every 0.5 sec only //-> call more often than once per second to correctly show last few seconds countdown, but don't call too often to avoid occasional jitter Opt rt = perf->getRemainingTime(to(dataTotal - dataCurrent)); setText(*m_staticTextRemTime, rt ? *rt : L"-", &layoutChanged); } } break; case ProcessCallback::PHASE_SYNCHRONIZING: assert(false); break; } //nr of scanned objects setText(*m_staticTextScanned, scannedObjects, &layoutChanged); //time elapsed const long timeElapSec = timeNow / 1000; setText(*m_staticTextTimeElapsed, timeElapSec < 3600 ? wxTimeSpan::Seconds(timeElapSec).Format( L"%M:%S") : wxTimeSpan::Seconds(timeElapSec).Format(L"%H:%M:%S"), &layoutChanged); if (layoutChanged) bSizer42->Layout(); //do the ui update wxTheApp->Yield(); } //######################################################################################## //redirect to implementation CompareProgressDialog::CompareProgressDialog(wxFrame& parentWindow) : pimpl(new Pimpl(parentWindow)) {} //owned by parentWindow wxWindow* CompareProgressDialog::getAsWindow() { return pimpl; } void CompareProgressDialog::init(const Statistics& syncStat) { pimpl->init(syncStat); } void CompareProgressDialog::finalize() { pimpl->finalize(); } void CompareProgressDialog::switchToCompareBytewise() { pimpl->switchToCompareBytewise(); } void CompareProgressDialog::updateStatusPanelNow() { pimpl->updateStatusPanelNow(); } //######################################################################################## namespace { inline wxBitmap buttonPressed(const std::string& name) { wxBitmap background = getResourceImage(L"log button pressed"); return layOver(getResourceImage(utfCvrtTo(name)), background); } inline wxBitmap buttonReleased(const std::string& name) { wxImage output = greyScale(getResourceImage(utfCvrtTo(name))).ConvertToImage(); //getResourceImage(utfCvrtTo(name)).ConvertToImage().ConvertToGreyscale(1.0/3, 1.0/3, 1.0/3); //treat all channels equally! //brighten(output, 30); zen::move(output, 0, -1); //move image right one pixel return output; } //a vector-view on ErrorLog considering multi-line messages: prepare consumption by Grid class MessageView { public: MessageView(const ErrorLog& log) : log_(log) {} size_t rowsOnView() const { return viewRef.size(); } struct LogEntryView { time_t time; MessageType type; MsgString messageLine; bool firstLine; //if LogEntry::message spans multiple rows }; bool getEntry(size_t row, LogEntryView& out) const { if (row < viewRef.size()) { const Line& line = viewRef[row]; out.time = line.entry_->time; out.type = line.entry_->type; out.messageLine = extractLine(line.entry_->message, line.rowNumber_); out.firstLine = line.rowNumber_ == 0; //this is virtually always correct, unless first line of the original message is empty! return true; } return false; } void updateView(int includedTypes) //TYPE_INFO | TYPE_WARNING, ect. see error_log.h { viewRef.clear(); for (auto it = log_.begin(); it != log_.end(); ++it) if (it->type & includedTypes) { assert_static((IsSameType::Type, wchar_t>::value)); assert(!startsWith(it->message, L'\n')); size_t rowNumber = 0; bool lastCharNewline = true; std::for_each(it->message.begin(), it->message.end(), [&](wchar_t c) { typedef Line Line; //workaround MSVC compiler bug! if (c == L'\n') { if (!lastCharNewline) //do not reference empty lines! viewRef.push_back(Line(&*it, rowNumber)); ++rowNumber; lastCharNewline = true; } else lastCharNewline = false; }); if (!lastCharNewline) viewRef.push_back(Line(&*it, rowNumber)); } } private: static MsgString extractLine(const MsgString& message, size_t textRow) { auto iter1 = message.begin(); for (;;) { auto iter2 = std::find_if(iter1, message.end(), [](wchar_t c) { return c == L'\n'; }); if (textRow == 0) return iter1 == message.end() ? MsgString() : MsgString(&*iter1, iter2 - iter1); //must not dereference iterator pointing to "end"! if (iter2 == message.end()) { assert(false); return MsgString(); } iter1 = iter2 + 1; //skip newline --textRow; } } struct Line { Line(const LogEntry* entry, size_t rowNumber) : entry_(entry), rowNumber_(rowNumber) {} const LogEntry* entry_; //always bound! size_t rowNumber_; //LogEntry::message may span multiple rows }; std::vector viewRef; //partial view on log_ /* /|\ | updateView() | */ const ErrorLog log_; }; //----------------------------------------------------------------------------- enum ColumnTypeMsg { COL_TYPE_MSG_TIME, COL_TYPE_MSG_CATEGORY, COL_TYPE_MSG_TEXT, }; //Grid data implementation referencing MessageView class GridDataMessages : public GridData { static const int COLUMN_BORDER_LEFT = 4; //for left-aligned text public: GridDataMessages(const std::shared_ptr& msgView) : msgView_(msgView) {} virtual size_t getRowCount() const { return msgView_ ? msgView_->rowsOnView() : 0; } virtual wxString getValue(size_t row, ColumnType colType) const { MessageView::LogEntryView entry = {}; if (msgView_ && msgView_->getEntry(row, entry)) switch (static_cast(colType)) { case COL_TYPE_MSG_TIME: if (entry.firstLine) return formatTime(FORMAT_TIME, localTime(entry.time)); break; case COL_TYPE_MSG_CATEGORY: if (entry.firstLine) switch (entry.type) { case TYPE_INFO: return _("Info"); case TYPE_WARNING: return _("Warning"); case TYPE_ERROR: return _("Error"); case TYPE_FATAL_ERROR: return _("Fatal Error"); } break; case COL_TYPE_MSG_TEXT: return copyStringTo(entry.messageLine); } return wxEmptyString; } virtual void renderCell(Grid& grid, wxDC& dc, const wxRect& rect, size_t row, ColumnType colType) { wxRect rectTmp = rect; const wxColor colorGridLine = wxColour(192, 192, 192); //light grey wxDCPenChanger dummy2(dc, wxPen(colorGridLine, 1, wxSOLID)); const bool drawBottomLine = [&]() -> bool //don't separate multi-line messages { MessageView::LogEntryView nextEntry = {}; if (msgView_ && msgView_->getEntry(row + 1, nextEntry)) return nextEntry.firstLine; return true; }(); if (drawBottomLine) { dc.DrawLine(rect.GetBottomLeft(), rect.GetBottomRight() + wxPoint(1, 0)); --rectTmp.height; } //-------------------------------------------------------- MessageView::LogEntryView entry = {}; if (msgView_ && msgView_->getEntry(row, entry)) switch (static_cast(colType)) { case COL_TYPE_MSG_TIME: drawCellText(dc, rectTmp, getValue(row, colType), grid.IsEnabled(), wxALIGN_CENTER); break; case COL_TYPE_MSG_CATEGORY: if (entry.firstLine) switch (entry.type) { case TYPE_INFO: dc.DrawLabel(wxString(), getResourceImage(L"msg_info_small"), rectTmp, wxALIGN_CENTER); break; case TYPE_WARNING: dc.DrawLabel(wxString(), getResourceImage(L"msg_warning_small"), rectTmp, wxALIGN_CENTER); break; case TYPE_ERROR: case TYPE_FATAL_ERROR: dc.DrawLabel(wxString(), getResourceImage(L"msg_error_small"), rectTmp, wxALIGN_CENTER); break; } break; case COL_TYPE_MSG_TEXT: { rectTmp.x += COLUMN_BORDER_LEFT; rectTmp.width -= COLUMN_BORDER_LEFT; drawCellText(dc, rectTmp, getValue(row, colType), grid.IsEnabled()); } break; } } virtual size_t getBestSize(wxDC& dc, size_t row, ColumnType colType) { // -> synchronize renderCell() <-> getBestSize() MessageView::LogEntryView entry = {}; if (msgView_ && msgView_->getEntry(row, entry)) switch (static_cast(colType)) { case COL_TYPE_MSG_TIME: return 2 * COLUMN_BORDER_LEFT + dc.GetTextExtent(getValue(row, colType)).GetWidth(); case COL_TYPE_MSG_CATEGORY: return getResourceImage(L"msg_info_small").GetWidth(); case COL_TYPE_MSG_TEXT: return COLUMN_BORDER_LEFT + dc.GetTextExtent(getValue(row, colType)).GetWidth(); } return 0; } static int getColumnTimeDefaultWidth(Grid& grid) { wxClientDC dc(&grid.getMainWin()); dc.SetFont(grid.getMainWin().GetFont()); return 2 * COLUMN_BORDER_LEFT + dc.GetTextExtent(formatTime(FORMAT_TIME)).GetWidth(); } static int getColumnCategoryDefaultWidth() { return getResourceImage(L"msg_info_small").GetWidth(); } static int getRowDefaultHeight(const Grid& grid) { return std::max(getResourceImage(L"msg_info_small").GetHeight(), grid.getMainWin().GetCharHeight() + 2) + 1; //+ some space + bottom border } virtual wxString getToolTip(size_t row, ColumnType colType) const { MessageView::LogEntryView entry = {}; if (msgView_ && msgView_->getEntry(row, entry)) switch (static_cast(colType)) { case COL_TYPE_MSG_TIME: case COL_TYPE_MSG_TEXT: break; case COL_TYPE_MSG_CATEGORY: return getValue(row, colType); } return wxEmptyString; } virtual wxString getColumnLabel(ColumnType colType) const { return wxEmptyString; } private: const std::shared_ptr msgView_; }; } class LogPanel : public LogPanelGenerated { public: LogPanel(wxWindow* parent, const ErrorLog& log) : LogPanelGenerated(parent), msgView(std::make_shared(log)) { const int errorCount = log.getItemCount(TYPE_ERROR | TYPE_FATAL_ERROR); const int warningCount = log.getItemCount(TYPE_WARNING); const int infoCount = log.getItemCount(TYPE_INFO); auto initButton = [](ToggleButton& btn, const char* imgName, const wxString& tooltip) { btn.init(buttonPressed(imgName), buttonReleased(imgName)); btn.SetToolTip(tooltip); }; initButton(*m_bpButtonErrors, "msg_error", _("Error" ) + wxString::Format(L" (%d)", errorCount )); initButton(*m_bpButtonWarnings, "msg_warning", _("Warning") + wxString::Format(L" (%d)", warningCount)); initButton(*m_bpButtonInfo, "msg_info", _("Info" ) + wxString::Format(L" (%d)", infoCount )); m_bpButtonErrors ->setActive(true); m_bpButtonWarnings->setActive(true); m_bpButtonInfo ->setActive(errorCount + warningCount == 0); m_bpButtonErrors ->Show(errorCount != 0); m_bpButtonWarnings->Show(warningCount != 0); m_bpButtonInfo ->Show(infoCount != 0); //init grid, determine default sizes const int rowHeight = GridDataMessages::getRowDefaultHeight(*m_gridMessages); const int colMsgTimeWidth = GridDataMessages::getColumnTimeDefaultWidth(*m_gridMessages); const int colMsgCategoryWidth = GridDataMessages::getColumnCategoryDefaultWidth(); m_gridMessages->setDataProvider(std::make_shared(msgView)); m_gridMessages->setColumnLabelHeight(0); m_gridMessages->showRowLabel(false); m_gridMessages->setRowHeight(rowHeight); std::vector attr; attr.push_back(Grid::ColumnAttribute(static_cast(COL_TYPE_MSG_TIME ), colMsgTimeWidth, 0)); attr.push_back(Grid::ColumnAttribute(static_cast(COL_TYPE_MSG_CATEGORY), colMsgCategoryWidth, 0)); attr.push_back(Grid::ColumnAttribute(static_cast(COL_TYPE_MSG_TEXT ), -colMsgTimeWidth - colMsgCategoryWidth, 1)); m_gridMessages->setColumnConfig(attr); //support for CTRL + C m_gridMessages->getMainWin().Connect(wxEVT_KEY_DOWN, wxKeyEventHandler(LogPanel::onGridButtonEvent), nullptr, this); m_gridMessages->Connect(EVENT_GRID_MOUSE_RIGHT_UP, GridClickEventHandler(LogPanel::onMsgGridContext), nullptr, this); updateGrid(); } private: virtual void OnErrors(wxCommandEvent& event) { m_bpButtonErrors->toggle(); updateGrid(); } virtual void OnWarnings(wxCommandEvent& event) { m_bpButtonWarnings->toggle(); updateGrid(); } virtual void OnInfo(wxCommandEvent& event) { m_bpButtonInfo->toggle(); updateGrid(); } void updateGrid() { int includedTypes = 0; if (m_bpButtonErrors->isActive()) includedTypes |= TYPE_ERROR | TYPE_FATAL_ERROR; if (m_bpButtonWarnings->isActive()) includedTypes |= TYPE_WARNING; if (m_bpButtonInfo->isActive()) includedTypes |= TYPE_INFO; msgView->updateView(includedTypes); //update MVC "model" m_gridMessages->Refresh(); //update MVC "view" } void onGridButtonEvent(wxKeyEvent& event) { int keyCode = event.GetKeyCode(); if (event.ControlDown()) switch (keyCode) { case 'C': case WXK_INSERT: //CTRL + C || CTRL + INS copySelectionToClipboard(); return; // -> swallow event! don't allow default grid commands! } event.Skip(); //unknown keypress: propagate } void onMsgGridContext(GridClickEvent& event) { const std::vector selection = m_gridMessages->getSelectedRows(); ContextMenu menu; menu.addItem(_("Copy") + L"\tCtrl+C", [this] { copySelectionToClipboard(); }, nullptr, !selection.empty()); menu.popup(*this); } void copySelectionToClipboard() { try { typedef Zbase zxString; //guaranteed exponential growth, unlike wxString zxString clipboardString; if (auto prov = m_gridMessages->getDataProvider()) { std::vector colAttr = m_gridMessages->getColumnConfig(); vector_remove_if(colAttr, [](const Grid::ColumnAttribute& ca) { return !ca.visible_; }); if (!colAttr.empty()) { const std::vector selection = m_gridMessages->getSelectedRows(); std::for_each(selection.begin(), selection.end(), [&](size_t row) { #ifdef _MSC_VER typedef zxString zxString; //workaround MSVC compiler bug! #endif std::for_each(colAttr.begin(), --colAttr.end(), [&](const Grid::ColumnAttribute& ca) { clipboardString += copyStringTo(prov->getValue(row, ca.type_)); clipboardString += L'\t'; }); clipboardString += copyStringTo(prov->getValue(row, colAttr.back().type_)); clipboardString += L'\n'; }); } } //finally write to clipboard if (!clipboardString.empty()) if (wxClipboard::Get()->Open()) { ZEN_ON_SCOPE_EXIT(wxClipboard::Get()->Close()); wxClipboard::Get()->SetData(new wxTextDataObject(copyStringTo(clipboardString))); //ownership passed } } catch (const std::bad_alloc& e) { wxMessageBox(_("Out of memory.") + L" " + utfCvrtTo(e.what()), L"FreeFileSync - " + _("Error"), wxOK | wxICON_ERROR); } } std::shared_ptr msgView; //bound! }; //######################################################################################## namespace { class CurveDataStatistics : public SparseCurveData { public: CurveDataStatistics() : SparseCurveData(true), timeNow(0) {} void clear() { samples.clear(); timeNow = 0; } void addRecord(long timeNowMs, double value) { warn_static("review") timeNow = timeNowMs; if (!samples.empty() && samples.rbegin()->second == value) return; //don't insert duplicate values samples.insert(samples.end(), std::make_pair(timeNowMs, value)); //use fact that time is monotonously ascending //documentation differs about whether "hint" should be before or after the to be inserted element! //however "std::map<>::end()" is interpreted correctly by GCC and VS2010 if (samples.size() > MAX_BUFFER_SIZE) //limit buffer size samples.erase(samples.begin()); } private: virtual std::pair getRangeX() const final { if (samples.empty()) return std::make_pair(0.0, 0.0); double upperEndMs = std::max(timeNow, samples.rbegin()->first); //request some additional width by 5% elapsed time to make graph recalibrate before hitting the right border //caveat: graph for batch mode binary comparison does NOT start at elapsed time 0!! PHASE_COMPARING_CONTENT and PHASE_SYNCHRONIZING! //=> consider width of current sample set! upperEndMs += 0.05 *(upperEndMs - samples.begin()->first); return std::make_pair(samples.begin()->first / 1000.0, //need not start with 0, e.g. "binary comparison, graph reset, followed by sync" upperEndMs / 1000.0); } virtual Opt getLessEq(double x) const final //x: seconds since begin { const long timex = std::floor(x * 1000); //------ add artifical last sample value ------- if (!samples.empty() && samples.rbegin()->first < timeNow) if (timeNow <= timex) return CurvePoint(timeNow / 1000.0, samples.rbegin()->second); //-------------------------------------------------- //find first key > x, then go one step back: => samples must be a std::map, NOT std::multimap!!! auto it = samples.upper_bound(timex); if (it == samples.begin()) return NoValue(); //=> samples not empty in this context --it; return CurvePoint(it->first / 1000.0, it->second); } virtual Opt getGreaterEq(double x) const final { const long timex = std::ceil(x * 1000); //------ add artifical last sample value ------- if (!samples.empty() && samples.rbegin()->first < timeNow) if (samples.rbegin()->first < timex && timex <= timeNow) return CurvePoint(timeNow / 1000.0, samples.rbegin()->second); //-------------------------------------------------- auto it = samples.lower_bound(timex); if (it == samples.end()) return NoValue(); return CurvePoint(it->first / 1000.0, it->second); } static const size_t MAX_BUFFER_SIZE = 2500000; //sizeof(single node) worst case ~ 3 * 8 byte ptr + 16 byte key/value = 40 byte std::map samples; //time, unit: [ms] !don't use std::multimap, see getLessEq() long timeNow; //help create an artificial record at the end of samples to visualize current time! }; class CurveDataCurrentValue : public CurveData { public: CurveDataCurrentValue() : x(0), yCurrent_(0), yTotal_(0) {} void setValue(long xTimeNowMs, double yCurrent, double yTotal) { x = xTimeNowMs / 1000.0; yCurrent_ = yCurrent; yTotal_ = yTotal; } private: virtual std::pair getRangeX() const final { return std::make_pair(x, x); } //conceptually just a vertical line! virtual void getPoints(double minX, double maxX, int pixelWidth, std::vector& points) const final { warn_static("remove after test") #if 0 if (yTotal_ > 100) { points.push_back(CurvePoint(0.38552801074951426,0.3861846045528107)); points.push_back(CurvePoint(-0.5565680734345084,1.793989720937398)); points.push_back(CurvePoint(2.85210684934041,3.339141677944872)); points.push_back(CurvePoint(0.45404408959926135,0.7810567713436095)); points.push_back(CurvePoint(2.303978218542433,-0.6610850551966995)); points.push_back(CurvePoint(-2.5606633797896112,-0.4035597290287872)); points.push_back(CurvePoint(-0.5394390537220716,0.40335295963067147)); //points.push_back(CurvePoint(0.2885508231771302,-1.9264175407823294)); //points.push_back(CurvePoint(-1.9332518577512143,0.6244007597162101)); //points.push_back(CurvePoint(3.116299689813205,1.6973640131005165)); //points.push_back(CurvePoint(0.0,0.0)); //points.push_back(CurvePoint(-5.993091301993007,0.5231778112837284)); return; } #endif if (x <= maxX) { points.push_back(CurvePoint(x, 0)); points.push_back(CurvePoint(x, yCurrent_)); points.push_back(CurvePoint(maxX, yCurrent_)); points.push_back(CurvePoint(x, yCurrent_)); points.push_back(CurvePoint(x, yTotal_)); } } double x; //time elapsed in seconds double yCurrent_; //current bytes/items double yTotal_; }; class CurveDataTotalValue : public CurveData { public: CurveDataTotalValue () : x(0), yTotal_(0) {} void setValue(long xTimeNowMs, double yTotal) { x = xTimeNowMs / 1000.0; yTotal_ = yTotal; } private: virtual std::pair getRangeX() const final { return std::make_pair(x, x); } //conceptually just a vertical line! virtual void getPoints(double minX, double maxX, int pixelWidth, std::vector& points) const final { if (x <= maxX) { points.push_back(CurvePoint(x, yTotal_)); points.push_back(CurvePoint(maxX, yTotal_)); } } double x; //time elapsed in seconds double yTotal_; }; struct LabelFormatterBytes : public LabelFormatter { virtual double getOptimalBlockSize(double bytesProposed) const { if (bytesProposed <= 1) //never smaller than 1 byte return 1; bytesProposed *= 1.4; //enlarge block default size //round to next number which is a convenient to read block size const double k = std::floor(std::log(bytesProposed) / std::log(2.0)); const double e = std::pow(2.0, k); if (numeric::isNull(e)) return 0; const double a = bytesProposed / e; //bytesProposed = a * 2^k with a in [1, 2) assert(1 <= a && a < 2); const double steps[] = { 1, 2 }; return e * numeric::nearMatch(a, std::begin(steps), std::end(steps)); } virtual wxString formatText(double value, double optimalBlockSize) const { return filesizeToShortString(Int64(value)); }; }; struct LabelFormatterItemCount : public LabelFormatter { virtual double getOptimalBlockSize(double itemsProposed) const { const double steps[] = { 1, 2, 5, 10 }; if (itemsProposed <= 10) return numeric::nearMatch(itemsProposed, std::begin(steps), std::end(steps)); //similar to nextNiceNumber(), but without the 2.5 step! return nextNiceNumber(itemsProposed); } virtual wxString formatText(double value, double optimalBlockSize) const { return toGuiString(numeric::round(value)); //not enough room for a "%x items" representation }; }; struct LabelFormatterTimeElapsed : public LabelFormatter { LabelFormatterTimeElapsed(bool drawLabel) : drawLabel_(drawLabel) {} virtual double getOptimalBlockSize(double secProposed) const { const double stepsSec[] = { 20, 30, 60 }; //20 sec: minimum block size; (no 15: avoid flicker between 10<->15<->20 sec blocks) if (secProposed <= 60) return numeric::nearMatch(secProposed, std::begin(stepsSec), std::end(stepsSec)); const double stepsMin[] = { 1, 2, 5, 10, 15, 20, 30, 60 }; //nice numbers for minutes if (secProposed <= 3600) return 60.0 * numeric::nearMatch(secProposed / 60, std::begin(stepsMin), std::end(stepsMin)); if (secProposed <= 3600 * 24) return nextNiceNumber(secProposed / 3600) * 3600; //round up to full hours return nextNiceNumber(secProposed / (24 * 3600)) * 24 * 3600; //round to full days } virtual wxString formatText(double timeElapsed, double optimalBlockSize) const { if (!drawLabel_) return wxString(); return timeElapsed < 60 ? replaceCpy(_P("1 sec", "%x sec", numeric::round(timeElapsed)), L"%x", zen::numberTo(numeric::round(timeElapsed))) : timeElapsed < 3600 ? wxTimeSpan::Seconds(timeElapsed).Format( L"%M:%S") : wxTimeSpan::Seconds(timeElapsed).Format(L"%H:%M:%S"); } private: bool drawLabel_; }; } template //can be a wxFrame or wxDialog class SyncProgressDialogImpl : private TopLevelDialog, public SyncProgressDialog /*we need derivation, not composition! 1. SyncProgressDialogImpl IS a wxFrame/wxDialog 2. implement virtual ~wxFrame() 3. event handling below assumes lifetime is larger-equal than wxFrame's */ { public: SyncProgressDialogImpl(long style, //wxFrame/wxDialog style const std::function& getTaskbarFrame, AbortCallback& abortCb, const std::function& notifyWindowTerminate, const Statistics& syncStat, wxFrame* parentFrame, bool showProgress, const wxString& jobName, const std::wstring& execWhenFinished, std::vector& execFinishedHistory); virtual ~SyncProgressDialogImpl(); //call this in StatusUpdater derived class destructor at the LATEST(!) to prevent access to currentStatusUpdater virtual void processHasFinished(SyncResult resultId, const ErrorLog& log); virtual void closeWindowDirectly(); virtual wxWindow* getWindowIfVisible() { return this->IsShown() ? this : nullptr; } //workaround OS X bug: if "this" is used as parent window for a modal dialog then this dialog will erroneously un-hide its parent! virtual void initNewPhase(); virtual void notifyProgressChange(); virtual void updateGui() { warn_static("remove after test") #if 0 static bool init = false; static wxStopWatch sw; if (!init) { init = true; sw.Start(); } if (sw.Time() > 1000 * 10) { PERF_START for (int i = 0; i < 10000; ++i) //for (int i = 0; i < 1000000; ++i) updateGuiInt(true); sw.Start(); sw.Pause(); } #endif updateGuiInt(true); } virtual std::wstring getExecWhenFinishedCommand() const { return pnl.m_comboBoxExecFinished->getValue(); } virtual void stopTimer() //halt all internal counters! { pnl.m_animCtrlSyncing->Stop(); timeElapsed.Pause (); } virtual void resumeTimer() { pnl.m_animCtrlSyncing->Play(); timeElapsed.Resume(); } private: void updateGuiInt(bool allowYield); void OnKeyPressed(wxKeyEvent& event); void OnOkay (wxCommandEvent& event); void OnPause (wxCommandEvent& event); void OnCancel (wxCommandEvent& event); void OnClose (wxCloseEvent& event); void OnIconize(wxIconizeEvent& event); void OnMinimizeToTray(wxCommandEvent& event) { minimizeToTray(); } void minimizeToTray(); void resumeFromSystray(); void updateDialogStatus(); void setExternalStatus(const wxString& status, const wxString& progress); //progress may be empty! SyncProgressPanelGenerated& pnl; //wxPanel containing the GUI controls of *this const wxString jobName_; wxStopWatch timeElapsed; wxFrame* parentFrame_; //optional std::function notifyWindowTerminate_; //call once in OnClose(), NOT in destructor which is called far too late somewhere in wxWidgets main loop! bool wereDead; //after wxWindow::Delete, which is equal to "delete this" on OS X! //status variables const Statistics* syncStat_; // AbortCallback* abortCb_; //valid only while sync is running bool paused_; //valid only while sync is running SyncResult finalResult; //set after sync //remaining time std::unique_ptr perf; long lastStatCallSpeed; //used for calculating intervals between collecting perf samples //help calculate total speed long phaseStartMs; //begin of current phase in [ms] std::shared_ptr curveDataBytes; std::shared_ptr curveDataItems; std::shared_ptr curveDataBytesTotal; std::shared_ptr curveDataBytesCurrent; std::shared_ptr curveDataItemsTotal; std::shared_ptr curveDataItemsCurrent; wxString parentFrameTitleBackup; std::unique_ptr trayIcon; //optional: if filled all other windows should be hidden and conversely std::unique_ptr taskbar_; }; template SyncProgressDialogImpl::SyncProgressDialogImpl(long style, //wxFrame/wxDialog style const std::function& getTaskbarFrame, AbortCallback& abortCb, const std::function& notifyWindowTerminate, const Statistics& syncStat, wxFrame* parentFrame, bool showProgress, const wxString& jobName, const std::wstring& execWhenFinished, std::vector& execFinishedHistory) : TopLevelDialog(parentFrame, wxID_ANY, wxString(), wxDefaultPosition, wxDefaultSize, style), //title is overwritten anyway in setExternalStatus() pnl(*new SyncProgressPanelGenerated(this)), //ownership passed to "this" jobName_ (jobName), parentFrame_(parentFrame), notifyWindowTerminate_(notifyWindowTerminate), wereDead(false), syncStat_ (&syncStat), abortCb_ (&abortCb), paused_ (false), finalResult(RESULT_ABORTED), //dummy value lastStatCallSpeed(-1000000), //some big number phaseStartMs(0) { assert_static((IsSameType::value || IsSameType::value)); assert((IsSameType::value == !parentFrame)); //finish construction of this dialog: this->SetMinSize(wxSize(470, 280)); //== minimum size! no idea why SetMinSize() is not used... wxBoxSizer* bSizer170 = new wxBoxSizer(wxVERTICAL); bSizer170->Add(&pnl, 1, wxEXPAND); this->SetSizer(bSizer170); //pass ownership //this->Layout(); //bSizer170->Fit(this); this->Centre(wxBOTH); //lifetime of event sources is subset of this instance's lifetime => no wxEvtHandler::Disconnect() needed this->Connect(wxEVT_CLOSE_WINDOW, wxCloseEventHandler (SyncProgressDialogImpl::OnClose)); this->Connect(wxEVT_ICONIZE, wxIconizeEventHandler(SyncProgressDialogImpl::OnIconize)); this->Connect(wxEVT_CHAR_HOOK, wxKeyEventHandler(SyncProgressDialogImpl::OnKeyPressed), nullptr, this); pnl.m_buttonClose ->Connect(wxEVT_COMMAND_BUTTON_CLICKED, wxCommandEventHandler(SyncProgressDialogImpl::OnOkay ), NULL, this); pnl.m_buttonPause ->Connect(wxEVT_COMMAND_BUTTON_CLICKED, wxCommandEventHandler(SyncProgressDialogImpl::OnPause ), NULL, this); pnl.m_buttonCancel->Connect(wxEVT_COMMAND_BUTTON_CLICKED, wxCommandEventHandler(SyncProgressDialogImpl::OnCancel), NULL, this); pnl.m_bpButtonMinimizeToTray->Connect(wxEVT_COMMAND_BUTTON_CLICKED, wxCommandEventHandler(SyncProgressDialogImpl::OnMinimizeToTray), NULL, this); #ifdef ZEN_WIN new MouseMoveWindow(*this); //allow moving main dialog by clicking (nearly) anywhere...; ownership passed to "this" #endif assert(pnl.m_buttonClose->GetId() == wxID_OK); //we cannot use wxID_CLOSE else Esc key won't work: yet another wxWidgets bug?? setRelativeFontSize(*pnl.m_staticTextPhase, 1.5); if (parentFrame_) parentFrameTitleBackup = parentFrame_->GetTitle(); //save old title (will be used as progress indicator) pnl.m_animCtrlSyncing->SetAnimation(GlobalResources::instance().aniWorking); pnl.m_animCtrlSyncing->Play(); this->SetIcon(GlobalResources::instance().programIconFFS); this->EnableCloseButton(false); //this is NOT honored on OS X or during system shutdown on Windows! timeElapsed.Start(); //measure total time if (wxFrame* frame = getTaskbarFrame(*this)) try //try to get access to Windows 7/Ubuntu taskbar { taskbar_ = make_unique(*frame); //throw TaskbarNotAvailable } catch (const TaskbarNotAvailable&) {} //hide "processed" statistics until end of process pnl.m_notebookResult ->Hide(); pnl.m_panelItemsProcessed->Hide(); pnl.m_buttonClose ->Show(false); //set std order after button visibility was set setStandardButtonOrder(*pnl.bSizerStdButtons, StdButtons().setAffirmative(pnl.m_buttonPause).setCancel(pnl.m_buttonCancel)); pnl.m_bpButtonMinimizeToTray->SetBitmapLabel(getResourceImage(L"minimize_to_tray")); //init graph curveDataBytes = std::make_shared(); curveDataItems = std::make_shared(); curveDataBytesTotal = std::make_shared(); curveDataBytesCurrent = std::make_shared(); curveDataItemsTotal = std::make_shared(); curveDataItemsCurrent = std::make_shared(); const int xLabelHeight = 18; //we need to use the same height for both graphs to make sure they stretch evenly const int yLabelWidth = 70; pnl.m_panelGraphBytes->setAttributes(Graph2D::MainAttributes(). setLabelX(Graph2D::X_LABEL_BOTTOM, xLabelHeight, std::make_shared(true)). setLabelY(Graph2D::Y_LABEL_RIGHT, yLabelWidth, std::make_shared()). setSelectionMode(Graph2D::SELECT_NONE)); pnl.m_panelGraphItems->setAttributes(Graph2D::MainAttributes(). setLabelX(Graph2D::X_LABEL_BOTTOM, xLabelHeight, std::make_shared(false)). setLabelY(Graph2D::Y_LABEL_RIGHT, yLabelWidth, std::make_shared()). setSelectionMode(Graph2D::SELECT_NONE)); pnl.m_panelGraphBytes->setCurve(curveDataBytes, Graph2D::CurveAttributes().setLineWidth(2). fillCurveArea(wxColor(205, 255, 202)). //faint green setColor (wxColor( 20, 200, 0))); //medium green pnl.m_panelGraphItems->setCurve(curveDataItems, Graph2D::CurveAttributes().setLineWidth(2). fillCurveArea(wxColor(198, 206, 255)). //faint blue setColor (wxColor( 90, 120, 255))); //medium blue pnl.m_panelGraphBytes->addCurve(curveDataBytesTotal, Graph2D::CurveAttributes().setLineWidth(2).setColor(wxColor(12, 128, 0))); //dark green pnl.m_panelGraphBytes->addCurve(curveDataBytesCurrent, Graph2D::CurveAttributes().setLineWidth(1).setColor(wxColor(12, 128, 0))); // pnl.m_panelGraphItems->addCurve(curveDataItemsTotal, Graph2D::CurveAttributes().setLineWidth(2).setColor(wxColor(53, 25, 255))); //dark blue pnl.m_panelGraphItems->addCurve(curveDataItemsCurrent, Graph2D::CurveAttributes().setLineWidth(1).setColor(wxColor(53, 25, 255))); // //allow changing on completion command pnl.m_comboBoxExecFinished->initHistory(execFinishedHistory, execFinishedHistory.size()); //-> we won't use addItemHistory() later pnl.m_comboBoxExecFinished->setValue(execWhenFinished); updateDialogStatus(); //null-status will be shown while waiting for dir locks warn_static("remove after test") #if 0 pnl.m_panelGraphBytes->setAttributes(Graph2D::MainAttributes().setMinX(-1).setMaxX(1).setMinY(-1).setMaxY(1)); pnl.m_panelGraphBytes->setCurve(curveDataBytesCurrent, Graph2D::CurveAttributes().setLineWidth(6).setColor(wxColor(12, 128, 0)) .fillCurveArea(wxColor(198, 206, 255)) //faint blue ); // #endif this->Fit(); pnl.Layout(); if (showProgress) { this->Show(); pnl.m_buttonCancel->SetFocus(); //don't steal focus when starting in sys-tray! //clear gui flicker, remove dummy texts: window must be visible to make this work! updateGuiInt(true); //at least on OS X a real Yield() is required to flush pending GUI updates; Update() is not enough } else minimizeToTray(); } template SyncProgressDialogImpl::~SyncProgressDialogImpl() { if (parentFrame_) { parentFrame_->SetTitle(parentFrameTitleBackup); //restore title text //make sure main dialog is shown again if still "minimized to systray"! see SyncProgressDialog::closeWindowDirectly() parentFrame_->Show(); //if (parentFrame_->IsIconized()) //caveat: if window is maximized calling Iconize(false) will erroneously un-maximize! // parentFrame_->Iconize(false); } //our client is NOT expecting a second call via notifyWindowTerminate_()! } template void SyncProgressDialogImpl::OnKeyPressed(wxKeyEvent& event) { const int keyCode = event.GetKeyCode(); if (keyCode == WXK_ESCAPE) { wxCommandEvent dummy(wxEVT_COMMAND_BUTTON_CLICKED); //simulate click on abort button if (pnl.m_buttonCancel->IsShown()) //delegate to "cancel" button if available { if (wxEvtHandler* handler = pnl.m_buttonCancel->GetEventHandler()) handler->ProcessEvent(dummy); return; } else if (pnl.m_buttonClose->IsShown()) { if (wxEvtHandler* handler = pnl.m_buttonClose->GetEventHandler()) handler->ProcessEvent(dummy); return; } } event.Skip(); } template void SyncProgressDialogImpl::initNewPhase() { updateDialogStatus(); //evaluates "syncStat_->currentPhase()" //reset graphs (e.g. after binary comparison) curveDataBytesTotal ->setValue(0, 0); curveDataBytesCurrent->setValue(0, 0, 0); curveDataItemsTotal ->setValue(0, 0); curveDataItemsCurrent->setValue(0, 0, 0); curveDataBytes->clear(); curveDataItems->clear(); notifyProgressChange(); //start new measurement perf = make_unique(WINDOW_REMAINING_TIME, WINDOW_BYTES_PER_SEC); lastStatCallSpeed = -1000000; //some big number phaseStartMs = timeElapsed.Time(); updateGuiInt(false); } template void SyncProgressDialogImpl::notifyProgressChange() //noexcept! { if (syncStat_) //sync running switch (syncStat_->currentPhase()) { case ProcessCallback::PHASE_NONE: assert(false); case ProcessCallback::PHASE_SCANNING: break; case ProcessCallback::PHASE_COMPARING_CONTENT: case ProcessCallback::PHASE_SYNCHRONIZING: curveDataBytes->addRecord(timeElapsed.Time(), to(syncStat_->getDataCurrent (syncStat_->currentPhase()))); curveDataItems->addRecord(timeElapsed.Time(), syncStat_->getObjectsCurrent(syncStat_->currentPhase())); break; } } namespace { #ifdef ZEN_WIN enum Zorder { ZORDER_CORRECT, ZORDER_WRONG, ZORDER_INDEFINITE, }; Zorder evaluateZorder(const wxWindow& top, const wxWindow& bottom) { HWND hTop = static_cast(top.GetHWND()); HWND hBottom = static_cast(bottom.GetHWND()); assert(hTop && hBottom); for (HWND hAbove = hBottom; hAbove; hAbove = ::GetNextWindow(hAbove, GW_HWNDPREV)) //GW_HWNDPREV means "to foreground" if (hAbove == hTop) return ZORDER_CORRECT; for (HWND hAbove = hTop; hAbove; hAbove = ::GetNextWindow(hAbove, GW_HWNDPREV)) if (hAbove == hBottom) return ZORDER_WRONG; return ZORDER_INDEFINITE; } #endif std::wstring getDialogPhaseText(const Statistics* syncStat, bool paused, SyncProgressDialog::SyncResult finalResult) { if (syncStat) //sync running { if (paused) return _("Paused"); else switch (syncStat->currentPhase()) { case ProcessCallback::PHASE_NONE: return _("Initializing..."); //dialog is shown *before* sync starts, so this text may be visible! case ProcessCallback::PHASE_SCANNING: return _("Scanning..."); case ProcessCallback::PHASE_COMPARING_CONTENT: return _("Comparing content..."); case ProcessCallback::PHASE_SYNCHRONIZING: return _("Synchronizing..."); } } else //sync finished switch (finalResult) { case SyncProgressDialog::RESULT_ABORTED: return _("Aborted"); case SyncProgressDialog::RESULT_FINISHED_WITH_ERROR: case SyncProgressDialog::RESULT_FINISHED_WITH_WARNINGS: case SyncProgressDialog::RESULT_FINISHED_WITH_SUCCESS: return _("Completed"); } return std::wstring(); } } template void SyncProgressDialogImpl::setExternalStatus(const wxString& status, const wxString& progress) //progress may be empty! { //sys tray: order "top-down": jobname, status, progress wxString newTrayInfo = jobName_.empty() ? status : L"\"" + jobName_ + L"\"\n" + status; if (!progress.empty()) newTrayInfo += L" " + progress; //window caption/taskbar; inverse order: progress, status, jobname wxString newCaption = progress.empty() ? status : progress + L" - " + status; if (!jobName_.empty()) newCaption += L" - \"" + jobName_ + L"\""; //systray tooltip, if window is minimized if (trayIcon.get()) trayIcon->setToolTip(newTrayInfo); //show text in dialog title (and at the same time in taskbar) if (parentFrame_) { if (parentFrame_->GetTitle() != newCaption) parentFrame_->SetTitle(newCaption); } //always set a title: we don't wxGTK to show "nameless window" instead if (this->GetTitle() != newCaption) this->SetTitle(newCaption); } template void SyncProgressDialogImpl::updateGuiInt(bool allowYield) { if (!syncStat_) //sync not running return; //wxWindowUpdateLocker dummy(this); -> not needed bool layoutChanged = false; //avoid screen flicker by calling layout() only if necessary const long timeNow = timeElapsed.Time(); //sync status text setText(*pnl.m_staticTextStatus, replaceCpy(syncStat_->currentStatusText(), L'\n', L' ')); //no layout update for status texts! switch (syncStat_->currentPhase()) //no matter if paused or not { case ProcessCallback::PHASE_NONE: case ProcessCallback::PHASE_SCANNING: //dialog caption, taskbar, systray tooltip setExternalStatus(getDialogPhaseText(syncStat_, paused_, finalResult), toGuiString(syncStat_->getObjectsCurrent(ProcessCallback::PHASE_SCANNING))); //status text may be "paused"! //progress indicators if (trayIcon.get()) trayIcon->setProgress(1); //100% = regular FFS logo //ignore graphs: should already have been cleared in initNewPhase() //remaining objects and data setText(*pnl.m_staticTextRemainingObj , L"-", &layoutChanged); setText(*pnl.m_staticTextDataRemaining, L"", &layoutChanged); //remaining time and speed setText(*pnl.m_staticTextRemTime, L"-", &layoutChanged); pnl.m_panelGraphBytes->setAttributes(pnl.m_panelGraphBytes->getAttributes().setCornerText(wxString(), Graph2D::CORNER_TOP_LEFT)); pnl.m_panelGraphItems->setAttributes(pnl.m_panelGraphItems->getAttributes().setCornerText(wxString(), Graph2D::CORNER_TOP_LEFT)); break; case ProcessCallback::PHASE_COMPARING_CONTENT: case ProcessCallback::PHASE_SYNCHRONIZING: { const int itemsCurrent = syncStat_->getObjectsCurrent(syncStat_->currentPhase()); const int itemsTotal = syncStat_->getObjectsTotal (syncStat_->currentPhase()); const Int64 dataCurrent = syncStat_->getDataCurrent (syncStat_->currentPhase()); const Int64 dataTotal = syncStat_->getDataTotal (syncStat_->currentPhase()); //add both data + obj-count, to handle "deletion-only" cases const double fraction = dataTotal + itemsTotal == 0 ? 1 : std::max(0.0, to(dataCurrent + itemsCurrent) / to(dataTotal + itemsTotal)); //yes, this may legitimately become < 0: failed rename operation falls-back to copy + delete, reducing "dataCurrent" to potentially < 0! //---------------------------------------------------------------------------------------------------- //dialog caption, taskbar, systray tooltip setExternalStatus(getDialogPhaseText(syncStat_, paused_, finalResult), fractionToString(fraction)); //status text may be "paused"! //progress indicators if (trayIcon.get()) trayIcon->setProgress(fraction); if (taskbar_.get()) taskbar_->setProgress(fraction); //constant line graph curveDataBytesTotal ->setValue(timeNow, to(dataTotal)); curveDataBytesCurrent->setValue(timeNow, to(dataCurrent), to(dataTotal)); curveDataItemsTotal ->setValue(timeNow, itemsTotal); curveDataItemsCurrent->setValue(timeNow, itemsCurrent, itemsTotal); //even though notifyProgressChange() already set the latest data, let's add another sample to have all curves consider "timeNow" //no problem with adding too many records: CurveDataStatistics will remove duplicate entries! curveDataBytes->addRecord(timeNow, to(dataCurrent)); curveDataItems->addRecord(timeNow, itemsCurrent); //remaining objects and data setText(*pnl.m_staticTextRemainingObj, toGuiString(itemsTotal - itemsCurrent), &layoutChanged); setText(*pnl.m_staticTextDataRemaining, L"(" + filesizeToShortString(dataTotal - dataCurrent) + L")", &layoutChanged); //it's possible data remaining becomes shortly negative if last file synced has ADS data and the dataTotal was not yet corrected! //remaining time and speed assert(perf); if (perf) if (numeric::dist(lastStatCallSpeed, timeNow) >= 500) { lastStatCallSpeed = timeNow; if (numeric::dist(phaseStartMs, timeNow) >= 1000) //discard stats for first second: probably messy perf->addSample(itemsCurrent, to(dataCurrent), timeNow); //current speed -> Win 7 copy uses 1 sec update interval instead Opt bps = perf->getBytesPerSecond(); Opt ips = perf->getItemsPerSecond(); pnl.m_panelGraphBytes->setAttributes(pnl.m_panelGraphBytes->getAttributes().setCornerText(bps ? *bps : L"", Graph2D::CORNER_TOP_LEFT)); pnl.m_panelGraphItems->setAttributes(pnl.m_panelGraphItems->getAttributes().setCornerText(ips ? *ips : L"", Graph2D::CORNER_TOP_LEFT)); //setText(*pnl.m_staticTextSpeed, perf->getBytesPerSecond(), &layoutChanged); //remaining time: display with relative error of 10% - based on samples taken every 0.5 sec only //-> call more often than once per second to correctly show last few seconds countdown, but don't call too often to avoid occasional jitter Opt rt = perf->getRemainingTime(to(dataTotal - dataCurrent)); setText(*pnl.m_staticTextRemTime, rt ? *rt : L"-", &layoutChanged); } } break; } pnl.m_panelGraphBytes->Refresh(); pnl.m_panelGraphItems->Refresh(); //time elapsed const long timeElapSec = timeNow / 1000; setText(*pnl.m_staticTextTimeElapsed, timeElapSec < 3600 ? wxTimeSpan::Seconds(timeElapSec).Format( L"%M:%S") : wxTimeSpan::Seconds(timeElapSec).Format(L"%H:%M:%S"), &layoutChanged); //adapt layout after content changes above if (layoutChanged) { pnl.m_panelProgress->Layout(); //small statistics panels: //pnl.m_panelItemsProcessed->Layout(); pnl.m_panelItemsRemaining->Layout(); pnl.m_panelTimeRemaining ->Layout(); //pnl.m_panelTimeElapsed->Layout(); -> needed? } #ifdef ZEN_WIN //workaround Windows 7 bug messing up z-order after temporary application hangs: https://sourceforge.net/tracker/index.php?func=detail&aid=3376523&group_id=234430&atid=1093080 //This is still needed no matter if wxDialog or wxPanel is used! (2013-07) if (parentFrame_) if (evaluateZorder(*this, *parentFrame_) == ZORDER_WRONG) { HWND hProgress = static_cast(this->GetHWND()); if (::IsWindowVisible(hProgress)) { ::ShowWindow(hProgress, SW_HIDE); //make Windows recalculate z-order ::ShowWindow(hProgress, SW_SHOW); // } } #endif if (allowYield) { //support for pause button if (paused_) { /* ZEN_ON_SCOPE_EXIT(resumeTimer()); -> crashes on Fedora; WHY??? => likely compiler bug!!! 1. no crash on Fedora for: ZEN_ON_SCOPE_EXIT(this->resumeTimer()); 1. no crash if we derive from wxFrame instead of template "TopLevelDialog" 2. no crash on Ubuntu GCC 3. following makes GCC crash already during compilation: auto dfd = zen::makeGuard([this]{ resumeTimer(); }); */ stopTimer(); while (paused_) { wxTheApp->Yield(); //receive UI message that end pause OR forceful termination! //*first* refresh GUI (removing flicker) before sleeping! boost::this_thread::sleep(boost::posix_time::milliseconds(UI_UPDATE_INTERVAL)); } //if SyncProgressDialogImpl::OnClose() already wxWindow::Destroy() on OS X then this instance is already toast! if (wereDead) return; //GTFO and don't call this->resumeTimer() resumeTimer(); } else /* /|\ | keep this sequence to ensure one full progress update before entering pause mode! \|/ */ wxTheApp->Yield(); //receive UI message that sets pause status OR forceful termination! } else this->Update(); //don't wait until next idle event (who knows what blocking process comes next?) } template void SyncProgressDialogImpl::updateDialogStatus() //depends on "syncStat_, paused_, finalResult" { const wxString dlgStatusTxt = getDialogPhaseText(syncStat_, paused_, finalResult); pnl.m_staticTextPhase->SetLabel(dlgStatusTxt); //status bitmap if (syncStat_) //sync running { auto setStatusBitmap = [&](const wchar_t* bmpName) { pnl.m_animCtrlSyncing->Hide(); pnl.m_bitmapStatus->SetBitmap(getResourceImage(bmpName)); pnl.m_bitmapStatus->SetToolTip(dlgStatusTxt); pnl.m_bitmapStatus->Show(); }; if (paused_) setStatusBitmap(L"status_pause"); else switch (syncStat_->currentPhase()) { case ProcessCallback::PHASE_NONE: pnl.m_animCtrlSyncing->Hide(); pnl.m_bitmapStatus->Hide(); break; case ProcessCallback::PHASE_SCANNING: setStatusBitmap(L"status_scanning"); break; case ProcessCallback::PHASE_COMPARING_CONTENT: setStatusBitmap(L"status_binary_compare"); break; case ProcessCallback::PHASE_SYNCHRONIZING: pnl.m_bitmapStatus->SetBitmap(getResourceImage(L"status_syncing")); pnl.m_bitmapStatus->SetToolTip(dlgStatusTxt); pnl.m_bitmapStatus->Show(); pnl.m_animCtrlSyncing->Show(); pnl.m_animCtrlSyncing->SetToolTip(dlgStatusTxt); break; } } else //sync finished { auto setStatusBitmap = [&](const wchar_t* bmpName, const std::wstring& tooltip) { pnl.m_animCtrlSyncing->Hide(); pnl.m_bitmapStatus->SetBitmap(getResourceImage(bmpName)); pnl.m_bitmapStatus->Show(); pnl.m_bitmapStatus->SetToolTip(tooltip); }; switch (finalResult) { case RESULT_ABORTED: setStatusBitmap(L"status_aborted", _("Synchronization aborted")); break; case RESULT_FINISHED_WITH_ERROR: setStatusBitmap(L"status_finished_errors", _("Synchronization completed with errors")); break; case RESULT_FINISHED_WITH_WARNINGS: setStatusBitmap(L"status_finished_warnings", _("Synchronization completed with warnings")); break; case RESULT_FINISHED_WITH_SUCCESS: setStatusBitmap(L"status_finished_success", _("Synchronization completed successfully")); break; } } //show status on Windows 7 taskbar if (taskbar_.get()) { if (syncStat_) //sync running { if (paused_) taskbar_->setStatus(Taskbar::STATUS_PAUSED); else switch (syncStat_->currentPhase()) { case ProcessCallback::PHASE_NONE: case ProcessCallback::PHASE_SCANNING: taskbar_->setStatus(Taskbar::STATUS_INDETERMINATE); break; case ProcessCallback::PHASE_COMPARING_CONTENT: case ProcessCallback::PHASE_SYNCHRONIZING: taskbar_->setStatus(Taskbar::STATUS_NORMAL); break; } } else //sync finished switch (finalResult) { case RESULT_ABORTED: case RESULT_FINISHED_WITH_ERROR: taskbar_->setStatus(Taskbar::STATUS_ERROR); break; case RESULT_FINISHED_WITH_WARNINGS: case RESULT_FINISHED_WITH_SUCCESS: taskbar_->setStatus(Taskbar::STATUS_NORMAL); break; } } //pause button if (syncStat_) //sync running pnl.m_buttonPause->SetLabel(paused_ ? _("&Continue") : _("&Pause")); pnl.Layout(); this->Refresh(); //a few pixels below the status text need refreshing } template void SyncProgressDialogImpl::closeWindowDirectly() //this should really be called: do not call back + schedule deletion { paused_ = false; //you never know? //ATTENTION: dialog may live a little longer, so watch callbacks! //e.g. wxGTK calls OnIconize after wxWindow::Close() (better not ask why) and before physical destruction! => indirectly calls updateDialogStatus(), which reads syncStat_!!! syncStat_ = nullptr; abortCb_ = nullptr; //resumeFromSystray(); -> NO, instead ~SyncProgressDialogImpl() makes sure that main dialog is shown again! this->Close(); //generate close event: do NOT destroy window unconditionally! } template void SyncProgressDialogImpl::processHasFinished(SyncResult resultId, const ErrorLog& log) //essential to call this in StatusHandler derived class destructor { //at the LATEST(!) to prevent access to currentStatusHandler //enable okay and close events; may be set in this method ONLY wxWindowUpdateLocker dummy(this); //badly needed paused_ = false; //you never know? //update numbers one last time (as if sync were still running) notifyProgressChange(); //make one last graph entry at the *current* time updateGuiInt(false); switch (syncStat_->currentPhase()) //no matter if paused or not { case ProcessCallback::PHASE_NONE: case ProcessCallback::PHASE_SCANNING: //set overall speed -> not needed //items processed -> not needed break; case ProcessCallback::PHASE_COMPARING_CONTENT: case ProcessCallback::PHASE_SYNCHRONIZING: { const int itemsCurrent = syncStat_->getObjectsCurrent(syncStat_->currentPhase()); const int itemsTotal = syncStat_->getObjectsTotal (syncStat_->currentPhase()); const Int64 dataCurrent = syncStat_->getDataCurrent (syncStat_->currentPhase()); const Int64 dataTotal = syncStat_->getDataTotal (syncStat_->currentPhase()); assert(dataCurrent <= dataTotal); //set overall speed (instead of current speed) const long timeDelta = timeElapsed.Time() - phaseStartMs; //we need to consider "time within current phase" not total "timeElapsed"! const wxString overallBytesPerSecond = timeDelta == 0 ? wxString() : filesizeToShortString(dataCurrent * 1000 / timeDelta) + _("/sec"); const wxString overallItemsPerSecond = timeDelta == 0 ? wxString() : replaceCpy(_("%x items"), L"%x", formatThreeDigitPrecision(itemsCurrent * 1000.0 / timeDelta)) + _("/sec"); pnl.m_panelGraphBytes->setAttributes(pnl.m_panelGraphBytes->getAttributes().setCornerText(overallBytesPerSecond, Graph2D::CORNER_TOP_LEFT)); pnl.m_panelGraphItems->setAttributes(pnl.m_panelGraphItems->getAttributes().setCornerText(overallItemsPerSecond, Graph2D::CORNER_TOP_LEFT)); //show new element "items processed" pnl.m_panelItemsProcessed->Show(); pnl.m_staticTextProcessedObj ->SetLabel(toGuiString(itemsCurrent)); pnl.m_staticTextDataProcessed->SetLabel(L"(" + filesizeToShortString(dataCurrent) + L")"); //hide remaining elements... if (itemsCurrent == itemsTotal && //...if everything was processed successfully dataCurrent == dataTotal) pnl.m_panelItemsRemaining->Hide(); } break; } //------- change class state ------- finalResult = resultId; syncStat_ = nullptr; abortCb_ = nullptr; //---------------------------------- updateDialogStatus(); setExternalStatus(getDialogPhaseText(syncStat_, paused_, finalResult), wxString()); resumeFromSystray(); //if in tray mode... this->EnableCloseButton(true); pnl.m_bpButtonMinimizeToTray->Hide(); pnl.m_buttonCancel->Disable(); pnl.m_buttonCancel->Hide(); pnl.m_buttonPause->Disable(); pnl.m_buttonPause->Hide(); pnl.m_buttonClose->Show(); pnl.m_buttonClose->Enable(); pnl.m_buttonClose->SetFocus(); pnl.bSizerExecFinished->Show(false); //set std order after button visibility was set setStandardButtonOrder(*pnl.bSizerStdButtons, StdButtons().setAffirmative(pnl.m_buttonClose)); //hide current operation status pnl.bSizerStatusText->Show(false); //show and prepare final statistics pnl.m_notebookResult->Show(); #if defined ZEN_WIN || defined ZEN_LINUX pnl.m_staticlineFooter->Hide(); //win: m_notebookResult already has a window frame #endif //hide remaining time pnl.m_panelTimeRemaining->Hide(); //1. re-arrange graph into results listbook pnl.bSizerRoot->Detach(pnl.m_panelProgress); pnl.m_panelProgress->Reparent(pnl.m_notebookResult); #ifdef ZEN_LINUX //does not seem to be required on Win or OS X wxTheApp->Yield(); //wxGTK 2.9.3 fails miserably at "reparent" whithout this #endif pnl.m_notebookResult->AddPage(pnl.m_panelProgress, _("Statistics"), true); //AddPage() takes ownership! //2. log file const size_t posLog = 1; LogPanel* logPanel = new LogPanel(pnl.m_notebookResult, log); //owned by m_notebookResult pnl.m_notebookResult->AddPage(logPanel, _("Log"), false); //bSizerHoldStretch->Insert(0, logPanel, 1, wxEXPAND); //show log instead of graph if errors occurred! (not required for ignored warnings) if (log.getItemCount(TYPE_ERROR | TYPE_FATAL_ERROR) > 0) pnl.m_notebookResult->ChangeSelection(posLog); //this->Fit(); //not a good idea: will shrink even if window is maximized or was enlarged by the user pnl.Layout(); pnl.m_panelProgress->Layout(); //small statistics panels: pnl.m_panelItemsProcessed->Layout(); pnl.m_panelItemsRemaining->Layout(); //pnl.m_panelTimeRemaining->Layout(); //pnl.m_panelTimeElapsed->Layout(); -> needed? //play (optional) sound notification after sync has completed -> only play when waiting on results dialog, seems to be pointless otherwise! switch (finalResult) { case SyncProgressDialog::RESULT_ABORTED: break; case SyncProgressDialog::RESULT_FINISHED_WITH_ERROR: case SyncProgressDialog::RESULT_FINISHED_WITH_WARNINGS: case SyncProgressDialog::RESULT_FINISHED_WITH_SUCCESS: { const Zstring soundFile = getResourceDir() + Zstr("Sync_Complete.wav"); if (fileExists(soundFile)) wxSound::Play(utfCvrtTo(soundFile), wxSOUND_ASYNC); //warning: this may fail and show a wxWidgets error message! => must not play when running FFS as a service! } break; } //Raise(); -> don't! user may be watching a movie in the meantime ;) note: resumeFromSystray() also calls Raise()! } template void SyncProgressDialogImpl::OnOkay(wxCommandEvent& event) { this->Close(); //generate close event: do NOT destroy window unconditionally! } template void SyncProgressDialogImpl::OnCancel(wxCommandEvent& event) { paused_ = false; updateDialogStatus(); //update status + pause button //no Layout() or UI-update here to avoid cascaded Yield()-call if (abortCb_) abortCb_->requestAbortion(); } template void SyncProgressDialogImpl::OnPause(wxCommandEvent& event) { paused_ = !paused_; updateDialogStatus(); //update status + pause button } template void SyncProgressDialogImpl::OnClose(wxCloseEvent& event) { //this event handler may be called *during* sync, e.g. due to a system shutdown (Windows), anytime (OS X) //try to stop sync gracefully and cross fingers: if (abortCb_) abortCb_->requestAbortion(); //Note: we must NOT veto dialog destruction, else we will cancel system shutdown if this dialog is application main window (like in batch mode) notifyWindowTerminate_(); //don't wait until delayed "Destroy()" finally calls destructor -> avoid calls to processHasFinished()/closeWindowDirectly() paused_ = false; //[!] we could be pausing here! //now that we notified window termination prematurely, and since processHasFinished()/closeWindowDirectly() won't be called, make sure we don't call back, too! //e.g. the second notifyWindowTerminate_() in ~SyncProgressDialogImpl()!!! syncStat_ = nullptr; abortCb_ = nullptr; wereDead = true; this->Destroy(); //wxWidgets OS X: simple "delete"!!!!!!! } template void SyncProgressDialogImpl::OnIconize(wxIconizeEvent& event) { /* propagate progress dialog minimize/maximize to parent ----------------------------------------------------- Fedora/Debian/Ubuntu: - wxDialog cannot be minimized - worse, wxGTK sends stray iconize events *after* wxDialog::Destroy() - worse, on Fedora an iconize event is issued directly after calling Close() - worse, even wxDialog::Hide() causes iconize event! => nothing to do SUSE: - wxDialog can be minimized (it just vanishes!) and in general also minimizes parent: except for our progress wxDialog!!! - worse, wxDialog::Hide() causes iconize event - probably the same issues with stray iconize events like Fedora/Debian/Ubuntu - minimize button is always shown, even if wxMINIMIZE_BOX is omitted! => nothing to do Mac OS X: - wxDialog can be minimized and automatically minimizes parent - no iconize events seen by wxWidgets! => nothing to do Windows: - wxDialog can be minimized but does not also minimize parent - iconize events only seen for manual minimize => propagate event to parent */ #ifdef ZEN_WIN if (parentFrame_) if (parentFrame_->IsIconized() != event.IsIconized()) //caveat: if window is maximized calling Iconize(false) will erroneously un-maximize! parentFrame_->Iconize(event.IsIconized()); #endif event.Skip(); } template void SyncProgressDialogImpl::minimizeToTray() { if (!trayIcon.get()) { trayIcon = make_unique([this] { this->resumeFromSystray(); }); //FfsTrayIcon lifetime is a subset of "this"'s lifetime! //we may destroy FfsTrayIcon even while in the FfsTrayIcon callback!!!! updateGuiInt(false); //set tray tooltip + progress: e.g. no updates while paused this->Hide(); if (parentFrame_) parentFrame_->Hide(); } } template void SyncProgressDialogImpl::resumeFromSystray() { if (trayIcon) { trayIcon.reset(); if (parentFrame_) { //if (parentFrame_->IsIconized()) //caveat: if window is maximized calling Iconize(false) will erroneously un-maximize! // parentFrame_->Iconize(false); parentFrame_->Show(); parentFrame_->Raise(); } //if (IsIconized()) //caveat: if window is maximized calling Iconize(false) will erroneously un-maximize! // Iconize(false); this->Show(); this->Raise(); this->SetFocus(); updateDialogStatus(); //restore Windows 7 task bar status (e.g. required in pause mode) updateGuiInt(false); //restore Windows 7 task bar progress (e.g. required in pause mode) } } //######################################################################################## SyncProgressDialog* createProgressDialog(zen::AbortCallback& abortCb, const std::function& notifyWindowTerminate, //note: user closing window cannot be prevented on OS X! (And neither on Windows during system shutdown!) const zen::Statistics& syncStat, wxFrame* parentWindow, //may be nullptr bool showProgress, const wxString& jobName, const std::wstring& execWhenFinished, std::vector& execFinishedHistory) { if (parentWindow) //sync from GUI return new SyncProgressDialogImpl(wxDEFAULT_DIALOG_STYLE | wxMAXIMIZE_BOX | wxMINIMIZE_BOX | wxRESIZE_BORDER, [&](wxDialog& progDlg) { return parentWindow; }, abortCb, notifyWindowTerminate, syncStat, parentWindow, showProgress, jobName, execWhenFinished, execFinishedHistory); else //FFS batch job return new SyncProgressDialogImpl(wxDEFAULT_FRAME_STYLE, [](wxFrame& progDlg) { return &progDlg; }, abortCb, notifyWindowTerminate, syncStat, parentWindow, showProgress, jobName, execWhenFinished, execFinishedHistory); }