sprint/thread/pipe.h

Go to the documentation of this file.

/******************************************************************************
*   sprint::pipe
*
*   Copyright (C) 2003-2011  Paolo Medici <www.pmx.it>
*
*  This library is free software; you can redistribute it and/or
*  modify it under the terms of the GNU Lesser General Public
*  License as published by the Free Software Foundation; either
*  version 2.1 of the License, or (at your option) any later version.
*
*  This library 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
*  Lesser General Public License for more details.
*
*  You should have received a copy of the GNU Lesser General Public
*  License along with this library; if not, write to the Free Software
*  Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
*
*******************************************************************************/

#ifndef _SPRINT_PIPE_H_
#define _SPRINT_PIPE_H_

#ifndef DEFAULT_PIPE_BUFFER

#define DEFAULT_PIPE_BUFFER     8192
#endif

#ifdef WIN32
# include <windows.h>
#endif

namespace sprint {
          
#ifdef WIN32

class pipe {
private:
        HANDLE write;
        HANDLE read;
public:

        inline pipe(unsigned int _suggested_size = DEFAULT_PIPE_BUFFER)
        {
                CreatePipe(&read, &write, NULL, _suggested_size);
        }

        inline ~pipe()
        {
        CloseHandle(read);
        CloseHandle(write);
        }

        inline DWORD write(LPCVOID lpData, UINT uDataSize)
        {
                DWORD dwWrite;
                WriteFile(write, lpData, uDataSize, &dwWrite, NULL);
                return dwWrite;
        }

        inline DWORD read(LPVOID lpBuffer, UINT uDataToRead)
        {
                DWORD dwRead;
                ReadFile(read, lpBuffer, uDataToRead, &dwRead, NULL);
                return dwRead;
        }

        inline DWORD peek()
        {
                DWORD dwAvail;
                PeekNamedPipe(read, NULL, 0, NULL, &dwAvail, NULL);
                return dwAvail;
        }

};
#endif

} // namespace

#endif  // _SPRINT_PIPE_H_