// Socket作成
BOOL CClientASock::Create(CAsyncClientDlg *dlgP)
{
    m_dlgP = dlgP;
    return CAsyncSocket::Create();
}
// Receive通知
void CClientASock::OnReceive(int nErrorCode)
{
    if (m_dlgP) m_dlgP->OnReceive(nErrorCode);
    CAsyncSocket::OnReceive(nErrorCode);
}
// Send通知
void CClientASock::OnSend(int nErrorCode)
{
    if (m_dlgP) m_dlgP->OnSend(nErrorCode);
    CAsyncSocket::OnSend(nErrorCode);
}
// Connect通知
void CClientASock::OnConnect(int nErrorCode)
{
    if (m_dlgP) m_dlgP->OnConnect(nErrorCode);
    CAsyncSocket::OnConnect(nErrorCode);
}

// "接続"ボタン押下
void CAsyncClientDlg::OnBnClickedBtnCnct()
{
    unsigned int    port = 0;
    int             err = 0;

    UpdateData();
    m_sock.Close();
    
    // (1)ソケット作成
    if (!err) if (!m_sock.Create(this)) err = 1;
    // (2)ポート取得
    if (!err) if (_stscanf_s(m_xvEditPort, _T("%d"), &port) != 1) err = 1;
    // (3)接続
    if (!err)
    {
        if (!m_sock.Connect(m_xvEditIP, port)) err = 1;
        // WSAEWOULDBLOCKはエラーとしない
        if (err) if (m_sock.GetLastError() == WSAEWOULDBLOCK) err = 0;
    }
    // (4)エラー表示
    if (err) {DispErr(m_sock.GetLastError()), m_sock.Close();}

    return;
}

// エラー表示
void CAsyncClientDlg::DispErr(int code)
{
    LPVOID        lpMsgBuf = NULL;

    ::FormatMessage(
        FORMAT_MESSAGE_ALLOCATE_BUFFER |
        FORMAT_MESSAGE_FROM_SYSTEM |
        FORMAT_MESSAGE_IGNORE_INSERTS,
        NULL, code,
        MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT),
        (LPTSTR)&lpMsgBuf, 0, NULL);

    m_xvEditLog += _T("Error : ");
    m_xvEditLog += static_cast<LPTSTR>(lpMsgBuf);
    UpdateData(FALSE);
    LocalFree(lpMsgBuf);

    return;
}

// Connect通知
void CAsyncClientDlg::OnConnect(int nErrorCode)
{
    if (nErrorCode) {DispErr(nErrorCode), m_sock.Close();}
    return;
}

// "送信"ボタン押下
void CAsyncClientDlg::OnBnClickedBtnSend()
{
    CString           sendStr;
    int               send;
    LPCSTR            byteCP = NULL;
    int               err = 0;

    UpdateData();
    // 送信(20バイト固定)
    if (!err)
    {
        sendStr = m_xvEditMes;
        while (sendStr.GetLength() < 20) sendStr += _T(" ");
        sendStr = sendStr.Left(20);
        
        if (m_sendSum >= 20) m_sendSum = 0;
        // Send()は20バイト送るまで繰り返す
        while (m_sendSum < 20)
        {
            byteCP = static_cast<LPCSTR>(sendStr) +m_sendSum;
            send = m_sock.Send(byteCP, 20 -m_sendSum);
            if (send == SOCKET_ERROR) err = 1;
            // WSAEWOULDBLOCKはエラーとしない。次のOnSendまで制御を戻す。
            if (err) if (m_sock.GetLastError() == WSAEWOULDBLOCK) {err = 0; break;}
            if (err) break;

            m_sendSum += send;
        }
    }
    if (!err)
    {
        if (m_sendSum >= 20)
        {
            m_sendSum = 0;
            m_xvEditLog += _T("Send : ");
            m_xvEditLog += sendStr +_T("\r\n");
        }
    }
    // エラー表示
    if (err)
    {
        DispErr(m_sock.GetLastError());
        m_sock.Close();
    }
    UpdateData(FALSE);

    return;
}

// Send通知
void CAsyncClientDlg::OnSend(int nErrorCode)
{
    int                err = 0;

    if (nErrorCode) err = 1;
    // 続きを送信
    if (!err) if (m_sendSum) OnBnClickedBtnSend();
    // エラー表示
    if (err)
    {
        DispErr(nErrorCode);
        m_sock.Close();
    }
    return;
}

// Receive通知
void CAsyncClientDlg::OnReceive(int nErrorCode)
{
    int              recv;
    LPSTR            byteP = NULL;
    int              err = 0;

    UpdateData();
    if (nErrorCode) err = 1;
    // 受信(20バイト固定)
    if (!err)
    {
        byteP = m_recvStr.GetBuffer(21);
        if (m_recvSum >= 20) m_recvSum = 0;
        // Receive()は一回のみ
        if (m_recvSum < 20)
        {
            recv = m_sock.Receive(byteP +m_recvSum, 20 -m_recvSum);
            if (recv == SOCKET_ERROR || recv == 0) err = 1;
            if (!err) m_recvSum += recv;
            // WSAEWOULDBLOCKはエラーとしない。次のOnReceiveまで制御を戻す。
            if (err) if (m_sock.GetLastError() == WSAEWOULDBLOCK) err = 0;
        }
        byteP[20] = '\0';
        m_recvStr.ReleaseBuffer();
    }
    if (!err)
    {
        if (m_recvSum >= 20)
        {
            m_recvSum = 0;
            m_xvEditLog += _T("Recv : ");
            m_xvEditLog += m_recvStr +_T("\r\n");
            m_sock.Close();
        }
    }
    // エラー表示
    if (err)
    {
        DispErr(nErrorCode ? nErrorCode : m_sock.GetLastError());
        m_sock.Close();
    }
    UpdateData(FALSE);

    return;
}