src/Operation/ThreadedOperationEnvironment.cpp

   1 /*
   2 Copyright_License {
   3
   4   XCSoar Glide Computer - http://www.xcsoar.org/
   5   Copyright (C) 2000-2013 The XCSoar Project
   6   A detailed list of copyright holders can be found in the file "AUTHORS".
   7
   8   This program is free software; you can redistribute it and/or
   9   modify it under the terms of the GNU General Public License
  10   as published by the Free Software Foundation; either version 2
  11   of the License, or (at your option) any later version.
  12
  13   This program is distributed in the hope that it will be useful,
  14   but WITHOUT ANY WARRANTY; without even the implied warranty of
  15   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  16   GNU General Public License for more details.
  17
  18   You should have received a copy of the GNU General Public License
  19   along with this program; if not, write to the Free Software
  20   Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
  21 }
  22 */
  23
  24 #include "ThreadedOperationEnvironment.hpp"
  25 #include "OS/Sleep.h"
  26
  27 ThreadedOperationEnvironment::ThreadedOperationEnvironment(OperationEnvironment &_other)
  28   :DelayedNotify(250), other(_other)
  29 {
  30 }
  31
  32 bool
  33 ThreadedOperationEnvironment::IsCancelled() const
  34 {
  35   return cancelled.Test();
  36 }
  37
  38 void
  39 ThreadedOperationEnvironment::Sleep(unsigned ms)
  40 {
  41   cancelled.Wait(ms);
  42 }
  43
  44 void
  45 ThreadedOperationEnvironment::SetErrorMessage(const TCHAR *_error)
  46 {
  47   mutex.Lock();
  48   data.SetErrorMessage(_error);
  49   mutex.Unlock();
  50
  51   SendNotification();
  52 }
  53
  54 void
  55 ThreadedOperationEnvironment::SetText(const TCHAR *_text)
  56 {
  57   mutex.Lock();
  58   data.SetText(_text);
  59   mutex.Unlock();
  60
  61   SendNotification();
  62 }
  63
  64 void
  65 ThreadedOperationEnvironment::SetProgressRange(unsigned range)
  66 {
  67   mutex.Lock();
  68   bool modified = data.SetProgressRange(range);
  69   mutex.Unlock();
  70
  71   if (modified)
  72     SendNotification();
  73 }
  74
  75 void
  76 ThreadedOperationEnvironment::SetProgressPosition(unsigned position)
  77 {
  78   mutex.Lock();
  79   bool modified = data.SetProgressPosition(position);
  80   mutex.Unlock();
  81
  82   if (modified)
  83     SendNotification();
  84 }
  85
  86 void
  87 ThreadedOperationEnvironment::OnNotification()
  88 {
  89   mutex.Lock();
  90   Data new_data = data;
  91   data.ClearUpdate();
  92   mutex.Unlock();
  93
  94   /* forward the method calls to the other OperationEnvironment */
  95
  96   if (new_data.update_error)
  97     other.SetErrorMessage(new_data.error);
  98
  99   if (new_data.update_text)
 100     other.SetText(new_data.text);
 101
 102   if (new_data.update_progress_range)
 103     other.SetProgressRange(new_data.progress_range);
 104
 105   if (new_data.update_progress_position)
 106     other.SetProgressPosition(new_data.progress_position);
 107 }