NamedPipe.cpp

[詳解]

// ----------------------------------------------------------------------------
 
#include "pch.h"
#include "NamedPipe.h"
 
using namespace alt;
 
BOOL NamedPipe::Create (LPCTSTR lpctszName, BOOL bStreamMode)
{
    BOOL ret = TRUE;
    TCHAR tszPipeName[MAX_PATH];
    // PIPE_ACCESS_INBOUND, PIPE_ACCESS_OUTBOUND, PIPE_ACCESS_DUPLEX
    // FILE_FLAG_WRITE_THROUGH バイトタイプ＆端点がリモートPCの時のみ有効
    // FILE_FLAG_OVERLAPPED 非同期モード
    DWORD dwOpenMode = PIPE_ACCESS_DUPLEX;
    // PIPE_TYPE_BYTE 通常のバイナリ操作
    // PIPE_TYPE_MESSAGE 一度に一文
    // PIPE_READMODE_BYTE バイトストリーム
    // PIPE_READMODE_MESSAGE メッセージストリーム
    // PIPE_WAIT 完了するまで制御を返さない
    // PIPE_NO_WAIT ReadFile, WriteFile, ConnectNamedPipeは制御をすぐ返す
    DWORD dwPipeMode =
        bStreamMode == FALSE ? PIPE_TYPE_BYTE | PIPE_READMODE_BYTE :
        PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE;
    DWORD dwMaxInstance = PIPE_UNLIMITED_INSTANCES;
    DWORD dwOutBuffSize = USHRT_MAX;
    DWORD dwInBufSize = USHRT_MAX;
    DWORD dwDefaultTimeOut = SHRT_MAX;
 
    wsprintf (tszPipeName, PIPE_NAME_FORMAT, lpctszName);
 
    _hObject = ::CreateNamedPipe (
        tszPipeName, dwOpenMode, dwPipeMode, dwMaxInstance, dwOutBuffSize,
        dwInBufSize, dwDefaultTimeOut, NULL);
    if (_hObject == INVALID_HANDLE_VALUE)
    {
        ret = FALSE;
    }
 
    return ret;
}
 
BOOL NamedPipe::Connect () const
{
    return ::ConnectNamedPipe (_hObject, NULL);
}
 
BOOL NamedPipe::Disconnect () const
{
    return ::DisconnectNamedPipe (_hObject);
}
 
BOOL NamedPipe::Open (LPCTSTR lpctszName)
{
    BOOL ret = TRUE;
    TCHAR tszPipeName[MAX_PATH];
 
    wsprintf (tszPipeName, PIPE_NAME_FORMAT, lpctszName);
 
    _hObject = ::CreateFile (
        tszPipeName, GENERIC_READ | GENERIC_WRITE, 0, NULL, OPEN_EXISTING,
        FILE_ATTRIBUTE_NORMAL, NULL);
    if (_hObject == INVALID_HANDLE_VALUE)
    {
        ret = FALSE;
    }
 
    return ret;
}
 
BOOL NamedPipe::Wait (LPCTSTR lpctszName, DWORD dwTimeout) const
{
    TCHAR tszPipeName[MAX_PATH];
 
    wsprintf (tszPipeName, PIPE_NAME_FORMAT, lpctszName);
 
    return ::WaitNamedPipe (tszPipeName, dwTimeout);
}
 
DWORD NamedPipe::PeekData (LPVOID lpvData, DWORD dwSize) const
{
    DWORD dwBytesRead;
    BOOL ret;
 
    ret = ::PeekNamedPipe (
        _hObject, lpvData, dwSize, &dwBytesRead, NULL, NULL);
 
    return ret == TRUE ? dwBytesRead : (DWORD)(-1);
}
 
DWORD NamedPipe::PeekRemain () const
{
    DWORD dwTotalBytesAvail;
    BOOL ret;
 
    ret = ::PeekNamedPipe (_hObject, NULL, 0, NULL, &dwTotalBytesAvail, NULL);
 
    return ret == FALSE ? -1 : dwTotalBytesAvail;
}