"Fossies" - the Fresh Open Source Software archive

Member "tvnserver-2.0.4/desktop/Poller.cpp" of archive tvnserver-2.0.4-src.zip:

// Copyright (C) 2008, 2009, 2010 GlavSoft LLC.
// All rights reserved.
//
//-------------------------------------------------------------------------
// This file is part of the TightVNC software.  Please visit our Web site:
//
//                       http://www.tightvnc.com/
//
// This program 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.
//
// This program 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 this program; if not, write to the Free Software Foundation, Inc.,
// 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
//-------------------------------------------------------------------------
//

#include "util/CommonHeader.h"
#include "Poller.h"
#include "region/Region.h"
#include "server-config-lib/Configurator.h"
#include "util/Log.h"

Poller::Poller(UpdateKeeper *updateKeeper,
               UpdateListener *updateListener,
               ScreenGrabber *screenGrabber,
               FrameBuffer *backupFrameBuffer,
               LocalMutex *frameBufferCriticalSection)
: UpdateDetector(updateKeeper, updateListener),
m_screenGrabber(screenGrabber),
m_backupFrameBuffer(backupFrameBuffer),
m_fbMutex(frameBufferCriticalSection)
{
  m_pollingRect.setRect(0, 0, 16, 16);
}

Poller::~Poller()
{
  terminate();
  wait();
}

void Poller::onTerminate()
{
  m_intervalWaiter.notify();
}

void Poller::execute()
{
  Log::info(_T("poller thread id = %d"), getThreadId());

  FrameBuffer *screenFrameBuffer;

  {
    AutoLock al(m_fbMutex);
    screenFrameBuffer = m_screenGrabber->getScreenBuffer();
    Rect fullScreenRect(screenFrameBuffer->getDimension().getRect());
    m_updateKeeper->addChangedRect(&fullScreenRect);
  }

  while (!isTerminating()) {
    Region region;

    {
      AutoLock al(m_fbMutex);

      screenFrameBuffer = m_screenGrabber->getScreenBuffer();
      if (!screenFrameBuffer->isEqualTo(m_backupFrameBuffer)) {
        m_updateKeeper->setScreenSizeChanged();
      } else {
        Log::info(_T("grabbing screen for polling"));
        m_screenGrabber->grab();
        Log::info(_T("end of grabbing screen for polling"));

        int pollingWidth = m_pollingRect.getWidth();
        int pollingHeight = m_pollingRect.getHeight();
        int screenWidth = screenFrameBuffer->getDimension().width;
        int screenHeight = screenFrameBuffer->getDimension().height;

        Rect scanRect;
        for (int iRow = 0; iRow < screenHeight; iRow += pollingHeight) {
          for (int iCol = 0; iCol < screenWidth; iCol += pollingWidth) {
            scanRect.setRect(iCol, iRow, min(iCol + pollingWidth, screenWidth),
                             min(iRow + pollingHeight, screenHeight));
            if (!screenFrameBuffer->cmpFrom(&scanRect, m_backupFrameBuffer,
                                            scanRect.left, scanRect.top)) {
              region.addRect(&scanRect);
            }
          }
        }

        m_updateKeeper->addChangedRegion(®ion);
      }
    } 

    if (!region.isEmpty()) {
      doUpdate();
    }

    unsigned int pollInterval = Configurator::getInstance()->
                                getServerConfig()->getPollingInterval();
    m_intervalWaiter.waitForEvent(pollInterval);
  }
}