// IPCClient.cpp : implementation file
//
#include "stdafx.h"
#include "resource.h"
#include "IPCClient.h"

#ifdef _DEBUG
#define new DEBUG_NEW
#undef THIS_FILE
static char THIS_FILE[] = __FILE__;
#endif

/////////////////////////////////////////////////////////////////////////////
// CIPCClient

/*
*構造函數
*/
CIPCClient::CIPCClient()
{
  m_ServerWinHwnd = 0;
  m_SessionHandle = 0;
  m_Active = false;
  //注冊消息常量
  m_ServerDisconnectHwnd = RegisterWindowMessage(IPCServerDisconnecting);
  m_ConnectRequestHwnd = RegisterWindowMessage(IPCConnectRequest);
  m_ConnectResposeHwnd = RegisterWindowMessage(IPCConnectRespose);
  m_ClientDisconnectHwnd = RegisterWindowMessage(IPCClientDisconnecting);
}

CIPCClient::~CIPCClient()
{
}


BEGIN_MESSAGE_MAP(CIPCClient, CWnd)
	//{{AFX_MSG_MAP(CIPCClient)
		// NOTE - the ClassWizard will add and remove mapping macros here.
	//}}AFX_MSG_MAP
END_MESSAGE_MAP()


/////////////////////////////////////////////////////////////////////////////
// CIPCClient message handlers

/*
*函數介紹：建立同服務器的連接
*入口參數：parentWnd指定創建此類的窗口指針
*出口參數：(無)
*返回值：(無)
*/

void CIPCClient::Open(CWnd *parentWnd)
{
  if (!m_Active)
  {
	m_ParentWnd = parentWnd;
    //注冊連接會話的消息標識符
    m_SessionHandle = RegisterWindowMessage(m_SessionName);
	::SendMessage(HWND_BROADCAST, m_ConnectRequestHwnd, WPARAM(m_hWnd), LPARAM(m_SessionHandle));
  }
}

/*
*函數介紹：關閉同服務器的連接
*入口參數：parentWnd指定創建此類的窗口指針
*出口參數：(無)
*返回值：(無)
*/
void CIPCClient::Close()
{
  if (m_Active)
  {
      //廣播消息，客戶端斷開
      ::SendMessage(HWND_BROADCAST, m_ClientDisconnectHwnd, WPARAM(m_hWnd), LPARAM(m_SessionHandle));
      m_Active = false;
  }
}
/*
*函數介紹：發送數據到服務器
*入口參數：MsgPointer : 發送的數據指針
           ASize : 發送的數據大小
*出口參數：(無)
*返回值：(無)
*/
void CIPCClient::SendMsg(LPVOID MsgPointer, DWORD ASize)
{
  COPYDATASTRUCT copyDataStruct;
  if (m_ServerWinHwnd != 0) 
  {
     copyDataStruct.dwData = DWORD(m_hWnd);
     copyDataStruct.cbData = ASize;
     copyDataStruct.lpData = MsgPointer;
	 //向服務器端窗口發送WM_COPYDATA消息
     ::SendMessage(m_ServerWinHwnd, WM_COPYDATA, m_SessionHandle, LPARAM(&copyDataStruct));
  }
}


LRESULT CIPCClient::WindowProc(UINT message, WPARAM wParam, LPARAM lParam) 
{
  
  LPVOID MsgPointer;
  DWORD bufLen;

  //根據消息種類，分別執行
  //WM_CopyData消息
  if (message == WM_COPYDATA) 
  {
	bufLen = ((PCOPYDATASTRUCT)lParam)->cbData;
    MsgPointer = ((PCOPYDATASTRUCT)lParam)->lpData;
    m_ClientDataArrive(m_ParentWnd,MsgPointer,bufLen);
    //處理客戶端接收數據事件
  }
  //連接響應消息
  else if (message == m_ConnectResposeHwnd) 
  {
    if (!m_Active)
	{
      m_ServerWinHwnd = HWND(wParam);

	  //連接響應事件
	  m_ClientConnected(m_ParentWnd,m_ServerWinHwnd);
      m_Active = true;
	}
  }
  //服務器端斷開連接消息
  else if (message == m_ServerDisconnectHwnd) 
  {
    if (m_Active)
    {
      if (wParam = DWORD(m_ServerWinHwnd))
      {

		//觸發斷開事件
	    m_ClientDisConnected(m_ParentWnd,m_ServerWinHwnd);
        m_ServerWinHwnd = 0;
        m_Active = false;
      }
    }
  }

  return CWnd::WindowProc(message, wParam, lParam);
}