---

MousePipe.cpp

Go to the documentation of this file.

// MousePipe.cpp: implementation of the MousePipe class.


#include "stdafx.h"
#include "MousePipe.h"

#define BUFFER_LIES_INT_FACTOR 7    

#define QUEUE_LENGTH 4 

#define BUFFER_SIZE sizeof(mouseMessage) * QUEUE_LENGTH * BUFFER_LIES_INT_FACTOR

// Construction/Destruction

MousePipe::MousePipe(const TString &name)
:PServer(TString( TEXT("Mouse") ) + name, true, BUFFER_SIZE)
{
    semName = TString( TEXT("MOUSESEM") ) + name;
    numberInQueue = NULL;
}

MousePipe::~MousePipe()
{
    if(numberInQueue != NULL)
        CloseHandle(numberInQueue);
}

// Member Functions

bool MousePipe::queueMessage(const int x, const int y, const int buttonState)
{
    if( !isConnected() ){
        return false;
    }

    mouseMessage msg;
    msg.x = x;
    msg.y = y;
    msg.button = buttonState;

    DWORD bytesWritten;
    if( ReleaseSemaphore(numberInQueue, 1, NULL) ){ 
        // WriteFile will return very quickly since there is space in the buffer
        return WriteFile(hPipe, &msg, sizeof(mouseMessage), &bytesWritten, NULL)
            ? bytesWritten == sizeof(mouseMessage) : false;
    } else { // no space in buffer
        return false;
    }
}

bool MousePipe::serve()
{
    if( !PServer::serve() ) {
        return false;
    } else {
        numberInQueue = CreateSemaphore(
            NULL,           // default security
            0,             // initial count ie 0 messages in pipe
            QUEUE_LENGTH,   // maximum count
            semName);

        if(numberInQueue == NULL){
            disconnect();
            return false;
        }

        return true;
    }   
}

void MousePipe::disconnect()
{   
    PServer::disconnect();

    if(numberInQueue != NULL)
        CloseHandle(numberInQueue);
}

---