C / C++ / MFC

This is the code which i am trying to extend:

<pre>#include &lt;windows.h&gt;
#include &lt;stdio.h&gt;
#include &lt;tchar.h&gt;
//#include &lt;strsafe.h&gt;

//#include &lt;glib.h&gt;

#define CONNECTING_STATE 0
#define READING_STATE 1
#define WRITING_STATE 2
#define INSTANCES 4
#define PIPE_TIMEOUT 5000
#define BUFSIZE 4096

typedef struct
{
   OVERLAPPED oOverlap;
   HANDLE hPipeInst;
   TCHAR chRequest[BUFSIZE];
   DWORD cbRead;
   TCHAR chReply[BUFSIZE];
   DWORD cbToWrite;
   DWORD dwState;
   BOOL fPendingIO;
   int processId;
} PIPEINST, *LPPIPEINST;


typedef struct
{
char appName[256];
int processId;
}PIPEHANDSHAKE;



VOID DisconnectAndReconnect(DWORD);
BOOL ConnectToNewClient(HANDLE, LPOVERLAPPED);
VOID GetAnswerToRequest(LPPIPEINST);

PIPEINST Pipe[INSTANCES];
HANDLE hEvents[INSTANCES];

HANDLE responsePipeHandle[INSTANCES];


DWORD WINAPI InstanceThread(LPVOID);

HANDLE hPipeHandles[10];
PULONG  s;

LPTSTR lpszPipename = TEXT("\\\\.\\pipe\\mynamedpipe");
LPTSTR lpszResponsePipe = TEXT("\\\\.\\pipe\\mynamedpipe1");


//GHashTable* hash;

int responsePipeConnectionHandler(VOID)
{
   BOOL   fConnected = FALSE;
   DWORD  dwThreadId = 0;
   HANDLE hPipe = INVALID_HANDLE_VALUE, hThread = NULL;
   int cbBytesRead;
   INT threadCount=0;
   //hash = g_hash_table_new(g_str_hash, g_str_equal);
   char bufferSize[512];
   for (;;)
   {
      _tprintf( TEXT("\nPipe Server: Main thread awaiting client connection on %s\n"), lpszResponsePipe);
      hPipe = CreateNamedPipe(
    		  lpszResponsePipe,             // pipe name
          PIPE_ACCESS_DUPLEX,       // read/write access
          PIPE_TYPE_MESSAGE |       // message type pipe
          PIPE_READMODE_MESSAGE |   // message-read mode
          PIPE_WAIT,                // blocking mode
          PIPE_UNLIMITED_INSTANCES, // max. instances
          BUFSIZE,                  // output buffer size
          BUFSIZE,                  // input buffer size
          0,                        // client time-out
          NULL);                    // default security attribute

      if (hPipe == INVALID_HANDLE_VALUE)
      {
          _tprintf(TEXT("CreateNamedPipe failed, GLE=%d.\n"), GetLastError());
          return -1;
      }

      // Wait for the client to connect; if it succeeds,
      // the function returns a nonzero value. If the function
      // returns zero, GetLastError returns ERROR_PIPE_CONNECTED.

      fConnected = ConnectNamedPipe(hPipe, NULL) ?
         TRUE : (GetLastError() == ERROR_PIPE_CONNECTED);

      if(fConnected){
    	  PIPEHANDSHAKE processData;
    	  fConnected = ReadFile(
             hPipe,        // handle to pipe
             bufferSize,    // buffer to receive data
             sizeof(PIPEHANDSHAKE), // size of buffer
             &amp;cbBytesRead, // number of bytes read
             NULL);        // not overlapped I/O
          memset(&amp;processData,0,sizeof(PIPEHANDSHAKE));
          memcpy(&amp;processData,&amp;bufferSize,sizeof(PIPEHANDSHAKE));
          printf("APP Process id: %d , app name: %s",processData.processId,processData.appName);

      }

    /*  if (fConnected)
      {
         printf("Client connected, creating a processing thread.\n");

         // Create a thread for this client.
         hThread = CreateThread(
            NULL,              // no security attribute
            0,                 // default stack size
            InstanceThread,    // thread proc
            (LPVOID) hPipe,    // thread parameter
            0,                 // not suspended
            &amp;dwThreadId);      // returns thread ID

         if (hThread == NULL)
         {
            _tprintf(TEXT("CreateThread failed, GLE=%d.\n"), GetLastError());
            return -1;
         }
         else CloseHandle(hThread);
       }
      else
        // The client could not connect, so close the pipe.
         CloseHandle(hPipe);*/
   }

   return 0;
}

DWORD WINAPI InstanceThread(LPVOID lpvParam)
{
   HANDLE hHeap      = GetProcessHeap();
   TCHAR* pchRequest = (TCHAR*)HeapAlloc(hHeap, 0, BUFSIZE*sizeof(TCHAR));
   TCHAR* pchReply   = (TCHAR*)HeapAlloc(hHeap, 0, BUFSIZE*sizeof(TCHAR));

   DWORD cbBytesRead = 0, cbReplyBytes = 0, cbWritten = 0;
   BOOL fSuccess = FALSE;
   HANDLE hPipe  = NULL;

   if (lpvParam == NULL)
   {
       printf( "\nERROR - Pipe Server Failure:\n");
       printf( "   InstanceThread got an unexpected NULL value in lpvParam.\n");
       printf( "   InstanceThread exitting.\n");
       if (pchReply != NULL) HeapFree(hHeap, 0, pchReply);
       if (pchRequest != NULL) HeapFree(hHeap, 0, pchRequest);
       return (DWORD)-1;
   }

   if (pchRequest == NULL)
   {
       printf( "\nERROR - Pipe Server Failure:\n");
       printf( "   InstanceThread got an unexpected NULL heap allocation.\n");
       printf( "   InstanceThread exitting.\n");
       if (pchReply != NULL) HeapFree(hHeap, 0, pchReply);
       return (DWORD)-1;
   }

   if (pchReply == NULL)
   {
       printf( "\nERROR - Pipe Server Failure:\n");
       printf( "   InstanceThread got an unexpected NULL heap allocation.\n");
       printf( "   InstanceThread exitting.\n");
       if (pchRequest != NULL) HeapFree(hHeap, 0, pchRequest);
       return (DWORD)-1;
   }
   printf("InstanceThread created, receiving and processing messages.\n");

   hPipe = (HANDLE) lpvParam;
   while (1)
   {
      fSuccess = ReadFile(
         hPipe,        // handle to pipe
         pchRequest,    // buffer to receive data
         BUFSIZE*sizeof(TCHAR), // size of buffer
         &amp;cbBytesRead, // number of bytes read
         NULL);        // not overlapped I/O

      if (!fSuccess || cbBytesRead == 0)
      {
          if (GetLastError() == ERROR_BROKEN_PIPE)
          {
              _tprintf(TEXT("InstanceThread: client disconnected.\n"), GetLastError());
          }
          else
          {
              _tprintf(TEXT("InstanceThread ReadFile failed, GLE=%d.\n"), GetLastError());
          }
          break;
      }
      else{
    	  printf(" Recieved data in PIPE");
      }
     cbReplyBytes = (strlen(pchRequest)+1)*sizeof(TCHAR);
      fSuccess = WriteFile(
         hPipe,        // handle to pipe
         pchRequest,     // buffer to write from
         cbReplyBytes, // number of bytes to write
         &amp;cbWritten,   // number of bytes written
         NULL);        // not overlapped I/O

      if (!fSuccess || cbReplyBytes != cbWritten)
      {
          _tprintf(TEXT("InstanceThread WriteFile failed, GLE=%d.\n"), GetLastError());
          break;
      }
  }
   FlushFileBuffers(hPipe);
   DisconnectNamedPipe(hPipe);
   CloseHandle(hPipe);

   HeapFree(hHeap, 0, pchRequest);
   HeapFree(hHeap, 0, pchReply);

   printf("InstanceThread exitting.\n");
   return 1;
}


int _tmain(VOID)
{
   DWORD i, dwWait, cbRet, dwErr,hThread;
   BOOL fSuccess;
   int dwThreadId;

// The initial loop creates several instances of a named pipe
// along with an event object for each instance.  An
// overlapped ConnectNamedPipe operation is started for
// each instance.
   // Create response pipe thread
   	 hThread = CreateThread(
      NULL,              // no security attribute
      0,                 // default stack size
      responsePipeConnectionHandler,    // thread proc
      NULL,    // thread parameter
      0,                 // not suspended
      &amp;dwThreadId);      // returns thread ID


   if (hThread == NULL)
   {
       printf("Response server creation failed with %d.\n", GetLastError());
       return 0;
   }


   for (i = 0; i &lt; INSTANCES; i++)
   {

   // Create an event object for this instance.

      hEvents[i] = CreateEvent(
         NULL,    // default security attribute
         TRUE,    // manual-reset event
         TRUE,    // initial state = signaled
         NULL);   // unnamed event object

      if (hEvents[i] == NULL)
      {
         printf("CreateEvent failed with %d.\n", GetLastError());
         return 0;
      }

      Pipe[i].oOverlap.hEvent = hEvents[i];

      Pipe[i].hPipeInst = CreateNamedPipe(
         lpszPipename,            // pipe name
         PIPE_ACCESS_DUPLEX |     // read/write access
         FILE_FLAG_OVERLAPPED,    // overlapped mode
         PIPE_TYPE_MESSAGE |      // message-type pipe
         PIPE_READMODE_MESSAGE |  // message-read mode
         PIPE_WAIT,               // blocking mode
         INSTANCES,               // number of instances
         BUFSIZE*sizeof(TCHAR),   // output buffer size
         BUFSIZE*sizeof(TCHAR),   // input buffer size
         PIPE_TIMEOUT,            // client time-out
         NULL);                   // default security attributes

      if (Pipe[i].hPipeInst == INVALID_HANDLE_VALUE)
      {
         printf("CreateNamedPipe failed with %d.\n", GetLastError());
         return 0;
      }

   // Call the subroutine to connect to the new client

      Pipe[i].fPendingIO = ConnectToNewClient(
         Pipe[i].hPipeInst,
         &amp;Pipe[i].oOverlap);

      Pipe[i].dwState = Pipe[i].fPendingIO ?
         CONNECTING_STATE : // still connecting
         READING_STATE;     // ready to read
   }

   while (1)
   {
      dwWait = WaitForMultipleObjects(
         INSTANCES,    // number of event objects
         hEvents,      // array of event objects
         FALSE,        // does not wait for all
         INFINITE);    // waits indefinitely

   // dwWait shows which pipe completed the operation.

      i = dwWait - WAIT_OBJECT_0;  // determines which pipe
      if (i &lt; 0 || i &gt; (INSTANCES - 1))
      {
         printf("Index out of range.\n");
         return 0;
      }

   // Get the result if the operation was pending.

      if (Pipe[i].fPendingIO)
      {
         fSuccess = GetOverlappedResult(
            Pipe[i].hPipeInst, // handle to pipe
            &amp;Pipe[i].oOverlap, // OVERLAPPED structure
            &amp;cbRet,            // bytes transferred
            FALSE);            // do not wait

         switch (Pipe[i].dwState)
         {
         // Pending connect operation
            case CONNECTING_STATE:
               if (! fSuccess)
               {
                   printf("Error %d.\n", GetLastError());
                   return 0;
               }
               Pipe[i].dwState = READING_STATE;
               break;

         // Pending read operation
            case READING_STATE:
               if (! fSuccess || cbRet == 0)
               {
                  DisconnectAndReconnect(i);
                  continue;
               }
               Pipe[i].cbRead = cbRet;
               Pipe[i].dwState = WRITING_STATE;
               break;

         // Pending write operation
            case WRITING_STATE:
               if (! fSuccess || cbRet != Pipe[i].cbToWrite)
               {
                  DisconnectAndReconnect(i);
                  continue;
               }
               Pipe[i].dwState = READING_STATE;
               break;

            default:
            {
               printf("Invalid pipe state.\n");
               return 0;
            }
         }
      }

   // The pipe state determines which operation to do next.

      switch (Pipe[i].dwState)
      {
         case READING_STATE:
            fSuccess = ReadFile(
               Pipe[i].hPipeInst,
               Pipe[i].chRequest,
               BUFSIZE*sizeof(TCHAR),
               &amp;Pipe[i].cbRead,
               &amp;Pipe[i].oOverlap);
            if (fSuccess &amp;&amp; Pipe[i].cbRead != 0)
            {
               Pipe[i].fPendingIO = FALSE;
               Pipe[i].dwState = WRITING_STATE;
               continue;
            }
            dwErr = GetLastError();
            if (! fSuccess &amp;&amp; (dwErr == ERROR_IO_PENDING))
            {
               Pipe[i].fPendingIO = TRUE;
               continue;
            }
            DisconnectAndReconnect(i);
            break;
         case WRITING_STATE:
            GetAnswerToRequest(&amp;Pipe[i]);
            fSuccess = WriteFile(
               Pipe[i].hPipeInst,
               Pipe[i].chReply,
               Pipe[i].cbToWrite,
               &amp;cbRet,
               &amp;Pipe[i].oOverlap);
            if (fSuccess &amp;&amp; cbRet == Pipe[i].cbToWrite)
            {
               Pipe[i].fPendingIO = FALSE;
               Pipe[i].dwState = READING_STATE;
               continue;
            }
            dwErr = GetLastError();
            if (! fSuccess &amp;&amp; (dwErr == ERROR_IO_PENDING))
            {
               Pipe[i].fPendingIO = TRUE;
               continue;
            }
            DisconnectAndReconnect(i);
            break;

         default:
         {
            printf("Invalid pipe state.\n");
            return 0;
         }
      }
  }

  return 0;
}

VOID DisconnectAndReconnect(DWORD i)
{
  if (! DisconnectNamedPipe(Pipe[i].hPipeInst) )
   {
      printf("DisconnectNamedPipe failed with %d.\n", GetLastError());
   }

   Pipe[i].fPendingIO = ConnectToNewClient(
      Pipe[i].hPipeInst,
      &amp;Pipe[i].oOverlap);

   Pipe[i].dwState = Pipe[i].fPendingIO ?
      CONNECTING_STATE : // still connecting
      READING_STATE;     // ready to read
}

BOOL ConnectToNewClient(HANDLE hPipe, LPOVERLAPPED lpo)
{
   BOOL fConnected, fPendingIO = FALSE;
   fConnected = ConnectNamedPipe(hPipe, lpo);
   if (fConnected)
   {
      printf("ConnectNamedPipe failed with %d.\n", GetLastError());
      return 0;
   }

   switch (GetLastError())
   {
   // The overlapped connection in progress.
      case ERROR_IO_PENDING:
         fPendingIO = TRUE;
         break;
      case ERROR_PIPE_CONNECTED:
         if (SetEvent(lpo-&gt;hEvent))
            break;
      default:
      {
         printf("ConnectNamedPipe failed with %d.\n", GetLastError());
         return 0;
      }
   }

   return fPendingIO;
}

VOID GetAnswerToRequest(LPPIPEINST pipe)
{
   _tprintf( TEXT("[%d] %s\n"), pipe-&gt;hPipeInst, pipe-&gt;chRequest);
  // StringCchCopy( pipe-&gt;chReply, BUFSIZE, TEXT("Default answer from server") );
   strncpy(pipe-&gt;chReply, "Default answer from server",BUFSIZE);
   pipe-&gt;cbToWrite = (lstrlen(pipe-&gt;chReply)+1)*sizeof(TCHAR);
}</pre>

Current pending activities:
1. Need to get process id of the connected process. this will be mainly used for identifying the client to send response data.
   Since the system is developed under MINGW - WIN32 - server will not be able to get the process id directly by using (GetNamedPipeClientProcessId). need to form a  message structure on getting a client connection.

class PEN{public: HDC d; HPEN pen,old;
    PEN(HDC dc,COLORREF col);
    ~PEN();};

PEN::PEN(HDC dc,COLORREF col){ // constructor
    d=dc;
    pen=(HPEN)CreatePen(0,1,col);
    old=(HPEN)SelectObject(dc,pen);};
PEN::~PEN(){ // destructor
    SelectObject(d,old);
    DeleteObject(pen);};

if(xhairs) {
    PEN orange(WIdc,RGB(255,128,0)); // crosshairs
    Line(WIdc,0,b/2,(int)(2*a),(int)(b/2));
    Line(WIdc,(int)(a/2),0,(int)(a/2),b);
    Line(WIdc,(int)(a*1.5),0,(int)(a*1.5),b);}

int CMainFrame::OnCreate(LPCREATESTRUCT lpCreateStruct)
{     
   if (CFrameWnd::OnCreate(lpCreateStruct) == -1)
   return -1;
 
   toolbarIconSize.cx = toolbarIconSize.cy = TOOLBAR_MAIN_ICON_SIZE;
   if ( !m_wndMyFloatingToolbar.Create(this,m_wndMyFloatingToolbar.GetBarStyle() |WS_EX_PALETTEWINDOW  | WS_EX_TOPMOST  |CBRS_FLOATING | WS_VISIBLE) ||
    !m_wndMyFloatingToolbar.LoadToolBar(IDR_GENERAL_TOOLBAR, toolbarIconSize))
    {
       TRACE0("Failed to create My Floating Toolbar\n");
       return -1;      // fail to create
    }
 
   m_wndMyFloatingToolbar.EnableDocking(0);
   EnableDocking(0);
 
   if (!CreateCtrlBar())
   {
       TRACE0("Failed to create ctrl toolbar\n");
       return -1;      // fail to create
   }
 
   // ...
   //...
   return 0; 
}
 
void CMainFrame::OnViewToolBar()
{
   // ...
   //...

   CPoint Pos = MyFloatingToolbarGetLastPosition(); \\Get last pos 
   FloatControlBar( &m_wndMyFloatingToolbar, Pos, CBRS_ALIGN_LEFT );
   MyFloatingToolbarSetIsVisible();
   FloatControlBar( &m_wndMyFloatingToolbar, Pos, CBRS_ALIGN_LEFT );
}
void CMainFrame::MyFloatingToolbarSetIsVisible()
{
   WINDOWPLACEMENT wp;
   m_wndMyFloatingToolbar.GetParent()->GetParent()->GetWindowPlacement(&wp);
   wp.showCmd = SW_SHOW;
   m_wndMyFloatingToolbar.GetParent()->GetParent()->SetWindowPlacement(&wp);
 
   m_wndMyFloatingToolbar.GetParent()->GetWindowPlacement(&wp);
   wp.showCmd = SW_SHOW;
   m_wndMyFloatingToolbar.GetParent()->SetWindowPlacement(&wp);
 
   m_wndMyFloatingToolbar.GetWindowPlacement(&wp);
   wp.showCmd = SW_SHOW;
   m_wndMyFloatingToolbar.SetWindowPlacement(&wp);
}
void CWJToolBar::OnWindowPosChanging(WINDOWPOS FAR* lpwndpos)
{ 
   CToolBar::OnWindowPosChanging(lpwndpos); 
 
   if ( GetBarStyle() & CBRS_FLOATING )
   {
       if((lpwndpos->flags & SWP_HIDEWINDOW) && ((this->GetParentFrame())->m_hWnd !=(this->GetTopLevelFrame())->m_hWnd)) 
       { 
           CMainFrame* mf = (CMainFrame*)(AfxGetApp()->GetMainWnd());
           mf->MyFloatingToolbarSavePosition();         
       }
   }
}

error C2440: 'static_cast' : cannot convert from 'void (__thiscall COptionDBTransport::* )(PCTSTR)' to 'AFX_PMSG'

ON_BN_CLICKED(IDC_BUTTON_udpCheck, &COptionDBTransport::OnBnClickedButtonudpcheck)