src/Protection.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 "Protection.hpp"
  25 #include "MainWindow.hpp"
  26 #include "Gauge/GlueGaugeVario.hpp"
  27 #include "Interface.hpp"
  28 #include "Components.hpp"
  29 #include "Computer/GlideComputer.hpp"
  30 #include "CalculationThread.hpp"
  31 #include "MergeThread.hpp"
  32 #include "DrawThread.hpp"
  33 #include "Blackboard/DeviceBlackboard.hpp"
  34
  35 #include <assert.h>
  36
  37 bool global_running;
  38
  39 void
  40 TriggerMergeThread()
  41 {
  42   if (merge_thread != NULL)
  43     merge_thread->Trigger();
  44 }
  45
  46 /**
  47  * Triggers a GPS update resulting in a run of the calculation thread
  48  */
  49 void
  50 TriggerGPSUpdate()
  51 {
  52   if (calculation_thread == NULL)
  53     return;
  54
  55   calculation_thread->Trigger();
  56 }
  57
  58 void
  59 ForceCalculation()
  60 {
  61   if (calculation_thread != NULL)
  62     calculation_thread->ForceTrigger();
  63 }
  64
  65 void
  66 TriggerVarioUpdate()
  67 {
  68   assert(CommonInterface::main_window != NULL);
  69
  70   CommonInterface::main_window->SendGPSUpdate();
  71 }
  72
  73 void
  74 TriggerMapUpdate()
  75 {
  76   assert(CommonInterface::main_window != NULL);
  77
  78   CommonInterface::main_window->FullRedraw();
  79 }
  80
  81 void
  82 TriggerCalculatedUpdate()
  83 {
  84   assert(CommonInterface::main_window != NULL);
  85
  86   CommonInterface::main_window->SendCalculatedUpdate();
  87 }
  88
  89 void
  90 TriggerAirspaceWarning()
  91 {
  92   assert(CommonInterface::main_window != NULL);
  93
  94   CommonInterface::main_window->SendAirspaceWarning();
  95 }
  96
  97 void
  98 CreateCalculationThread()
  99 {
 100   assert(glide_computer != NULL);
 101
 102   /* copy settings to DeviceBlackboard */
 103   device_blackboard->ReadComputerSettings(CommonInterface::GetComputerSettings());
 104
 105   /* create and run MergeThread, because GlideComputer's first
 106      iteration depends on MergeThread's results */
 107   merge_thread = new MergeThread(*device_blackboard);
 108   merge_thread->FirstRun();
 109
 110   /* initialise the GlideComputer and run the first iteration */
 111   glide_computer->ReadBlackboard(device_blackboard->Basic());
 112   glide_computer->ReadComputerSettings(device_blackboard->GetComputerSettings());
 113   glide_computer->ProcessGPS(true);
 114
 115   /* copy GlideComputer results to DeviceBlackboard */
 116   device_blackboard->ReadBlackboard(glide_computer->Calculated());
 117
 118   calculation_thread = new CalculationThread(*glide_computer);
 119   calculation_thread->SetComputerSettings(CommonInterface::GetComputerSettings());
 120 }
 121
 122 void
 123 SuspendAllThreads()
 124 {
 125   assert(CommonInterface::main_window != NULL);
 126   assert(calculation_thread != NULL);
 127
 128   /* not suspending MergeThread, because it does not access shared
 129      unprotected data structures */
 130
 131   CommonInterface::main_window->SuspendThreads();
 132   calculation_thread->Suspend();
 133 }
 134
 135 void
 136 ResumeAllThreads()
 137 {
 138   assert(calculation_thread != NULL);
 139   assert(CommonInterface::main_window != NULL);
 140
 141   calculation_thread->Resume();
 142   CommonInterface::main_window->ResumeThreads();
 143 }