/* -*- Mode: C++; tab-width: 2; indent-tabs-mode: nil; c-basic-offset: 2 -*- */ /*************************************************************************** * networksender.cc * * Mon Mar 6 20:14:35 CET 2006 * Copyright 2006 Bent Bisballe Nyeng * deva@aasimon.org ****************************************************************************/ /* * This file is part of MIaV. * * MIaV 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. * * MIaV 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 MIaV; if not, write to the Free Software * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA. */ #include "networksender.h" #include "info.h" #include NetworkSender::NetworkSender(QString cpr) { ip = "127.0.0.1"; port = 6666; // Connect // sleep(1); server_diskspace = 0xffffffff; server_diskspace_max = 0xffffffff; server_load = 0xffffffff; server_load_max = 0xffffffff; server_ping_ms = 0xffffffff; server_fps = -1.0; running = true; fprintf(stderr, "Connect [%p]\n", this); } NetworkSender::~NetworkSender() { // Disconnect sleep_1_frame(); sleep_1_frame(); sleep_1_frame(); sleep_1_frame(); fprintf(stderr, "Disconnect [%p]\n", this); } void NetworkSender::pushFrame(Frame* frame, bool freeze, bool snapshot) { printf("F: %d S %d\n", freeze, snapshot); // Frame *frame = new Frame((unsigned char*)framedata); frame->freeze = freeze; frame->shoot = snapshot; mutex.lock(); framelist.push_back(frame); mutex.unlock(); semaphore.release(); } unsigned int NetworkSender::queueSize() { unsigned int sz; mutex.lock(); sz = framelist.size(); mutex.unlock(); return sz; } void NetworkSender::run() { fprintf(stderr, " Run %p\n", this); while(running) { if(queueSize()) semaphore.acquire(); Frame *frame = NULL; mutex.lock(); if(framelist.isEmpty() == false) frame = framelist.takeLast(); mutex.unlock(); if(frame) { // TODO: Send it over the network sleep_1_frame(); sleep_1_frame(); sleep_1_frame(); sleep_1_frame(); if(frame->vframe) delete frame->vframe; if(frame->aframe) delete frame->aframe; delete frame; // TODO: Read status from network // Set status statusmutex.lock(); server_diskspace_max = 1000000; if(server_diskspace == 0xffffffff) server_diskspace = server_diskspace_max; server_diskspace -= (int)(((double)rand() / (double)RAND_MAX) * 10.0); server_load = 90 + (int)(((double)rand() / (double)RAND_MAX) * 10.0); server_load_max = 100; server_ping_ms = (int)(((double)rand() / (double)RAND_MAX) * 100); server_fps = 25.0; statusmutex.unlock(); } } terminatesemaphore.release(); // Signal the stop method that the thread has stopped running. fprintf(stderr, " Stop %p\n", this); } void NetworkSender::stop() { running = false; semaphore.release(); // Kick the thread active terminatesemaphore.acquire(); // Wait for the thread to stop } void NetworkSender::getServerStatus(Status *status) { statusmutex.lock(); status->server_diskspace = server_diskspace; status->server_diskspace_max = server_diskspace_max; status->server_load = server_load; status->server_load_max = server_load_max; status->server_ping_ms = server_ping_ms; status->server_fps = server_fps; statusmutex.unlock(); }