diff options
Diffstat (limited to 'src/cprlisten.cc')
-rw-r--r-- | src/cprlisten.cc | 106 |
1 files changed, 0 insertions, 106 deletions
diff --git a/src/cprlisten.cc b/src/cprlisten.cc deleted file mode 100644 index 0a4958e..0000000 --- a/src/cprlisten.cc +++ /dev/null @@ -1,106 +0,0 @@ -/* -*- Mode: C++; tab-width: 2; indent-tabs-mode: tab; c-basic-offset: 2 -*- */ -/*************************************************************************** - * cprlisten.cc - * - * Tue Dec 27 17:05:42 CET 2005 - * Copyright 2005 Bent Bisballe Nyeng - * deva@aasimon.org - ****************************************************************************/ - -/* - * This file is part of the Aasimon c++ framework. - * - * This is free software; you can redistribute it and/or modify - * it under the terms of the GNU General Public License as published by - * the Free Software Foundation; either version 2 of the License, or - * (at your option) any later version. - * - * It is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with it; if not, write to the Free Software - * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA. - */ - -#include "cprlisten.h" -#include "aa_socket.h" - -#include <iostream> -#include <string> -using namespace std; - -#define MAGIC_STOP_STRING "SHUTTHEFUCKUP" - -CPRListen::CPRListen(Info *info, unsigned short port) -{ - this->info = info; - this->port = port; - cpr = "N/A"; - cprchanged = false; - running = true; -} - -CPRListen::~CPRListen() -{ -} - -void CPRListen::stop() -{ - running = false; - try { - AASocket socket; - socket.connect("localhost", port); - socket.send_string(MAGIC_STOP_STRING); - } catch(Network_error &e) { - info->error("In stop(): %s.", e.error.c_str()); - } -} - -void CPRListen::thread_main() -{ - info->log("Listening for CPRs."); - while(running) { - try { - string newcpr; - AASocket socket; - socket.listen(port); - newcpr = socket.receive_string(); - - if(newcpr == MAGIC_STOP_STRING) { - running = false; - } else { - mutex.lock(); - cprchanged = true; - cpr = newcpr; - mutex.unlock(); - info->log("Got CPR: %s.", cpr.c_str()); - } - - } catch(Network_error &e) { - info->error("In thread_main(): %s.", e.error.c_str()); - running = false; - } - } - info->log("Stopped listening for CPRs."); -} - -bool CPRListen::cprChanged() -{ - return cprchanged; -} - -string CPRListen::getCpr() -{ - string cpr_copy; - - mutex.lock(); - cpr_copy = cpr; - mutex.unlock(); - - cprchanged = false; - - return cpr_copy; -} |