home *** CD-ROM | disk | FTP | other *** search
/ OS/2 Shareware BBS: 10 Tools / 10-Tools.zip / memlink.zip / MDEMO.C next >
C/C++ Source or Header  |  1995-08-09  |  8KB  |  264 lines
  1. /*************************************************************************
  2. * 
  3. *  Filename:             mdemo.c
  4. *                  
  5. *  Description:          
  6. *            This module is meant to be a demo program to show
  7. *                       how the MEMLINK.DLL library works for Interprocess
  8. *                       Communication. 
  9. *************************************************************************/
  10.  
  11. #define INCL_GPI
  12. #define INCL_WIN
  13. #define INCL_DOS
  14. #include <os2.h>
  15. #include <stdlib.h>
  16. #include "mdemo.h"
  17. #include "pipes.h"
  18.  
  19. #define THREAD_STACK_SIZE    8000
  20.  
  21. /* function prototypes */
  22. static VOID APIENTRY thread1_routine(ULONG DummyValue);
  23. static VOID APIENTRY thread2_routine(ULONG DummyValue);
  24. static void HandleOutput(char *MsgString);
  25. static MRESULT EXPENTRY ClientWindowProc(HWND window, ULONG message,
  26.                                           MPARAM param1, MPARAM param2 );
  27. /* global variables */
  28. static HAB anchor_block;
  29. static char *pszMainWindowClass = "MEMLINK DEMO PROGRAM";
  30. static HWND  client_window;
  31. static HWND  main_window;
  32. static TID thread1_id, thread2_id;
  33. static short slowflag;
  34.  
  35. /*mmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmm
  36. *  Description: This function is the main routine for the application.
  37. /*mmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmm*/
  38. int main( void )
  39. {
  40.  
  41.    HMQ   message_queue = NULLHANDLE;        
  42.    ULONG frame_flags   = 0UL;          
  43.    QMSG  message;                 
  44.    int   return_value  = 1;
  45.  
  46.    do
  47.      {
  48.      if (( anchor_block = WinInitialize(0UL)) == NULLHANDLE )
  49.        break;
  50.  
  51.      if (( message_queue = WinCreateMsgQueue( anchor_block, 0UL )) == 
  52.           NULLHANDLE )
  53.        break;
  54.  
  55.      if ( !WinRegisterClass( anchor_block, pszMainWindowClass, 
  56.             (PFNWP) ClientWindowProc, CS_SIZEREDRAW, 0UL ))       
  57.                break;
  58.  
  59.       /* Create the main window */
  60.       frame_flags = FCF_STANDARD & ~FCF_TASKLIST;
  61.       main_window =  WinCreateStdWindow( HWND_DESKTOP,  
  62.                                          WS_VISIBLE,    
  63.                                          &frame_flags,     
  64.                                          pszMainWindowClass,  
  65.                                          "",            
  66.                                          CS_SIZEREDRAW | WS_VISIBLE,
  67.                                          0UL,           
  68.                                          ID_WINDOW,     
  69.                                          &client_window );
  70.       if ( main_window == NULLHANDLE )
  71.         break;
  72.  
  73.       WinSetWindowText(main_window, pszMainWindowClass);
  74.  
  75.       while( WinGetMsg( anchor_block, &message, 0UL, 0UL, 0UL ) )
  76.         WinDispatchMsg( anchor_block, &message );  
  77.       return_value = 0;
  78.  
  79.    }  while ( FALSE );
  80.  
  81.    if ( main_window != NULLHANDLE )
  82.      WinDestroyWindow( main_window ); 
  83.  
  84.    if ( message_queue != NULLHANDLE )
  85.       WinDestroyMsgQueue( message_queue );
  86.  
  87.    if ( anchor_block != NULLHANDLE )
  88.      WinTerminate( anchor_block );
  89.  
  90.    return return_value;
  91. }
  92.  
  93.  
  94. /*mmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmm
  95. *                                                                       
  96. *  Description: This function is the window procedure for the client
  97. *               window.
  98. *                                                                       
  99. /*mmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmm*/
  100. MRESULT EXPENTRY ClientWindowProc( HWND window, ULONG message, 
  101.                                    MPARAM param1, MPARAM param2 )
  102. {
  103.   APIRET    rc;
  104.   CONVCONTEXT   context;
  105.   RECTL         update_rect;
  106.   HPS           present_space;
  107.   HWND        ClientWnd, ServerWnd;
  108.   int           i;
  109.   static short  TimerFlag = 0;
  110.   short        MenuPick;
  111.  
  112.  
  113.   switch( message )
  114.     {
  115.     case WM_CLOSE:
  116.       WinPostMsg( window, WM_QUIT, NULL, NULL );
  117.       break;
  118.  
  119.     case WM_PAINT:
  120.       present_space = WinBeginPaint(window, NULLHANDLE, (PRECTL)&update_rect);
  121.       WinFillRect( present_space, (PRECTL)&update_rect, SYSCLR_WINDOW);
  122.       WinEndPaint( present_space );
  123.       break;
  124.  
  125.     case WM_COMMAND:
  126.       MenuPick = SHORT1FROMMP(param1);
  127.       switch (MenuPick)
  128.          {
  129.          case IDM_GOSLOW:
  130.          case IDM_GOFAST:
  131.               slowflag = (MenuPick == IDM_GOSLOW) ? 1 : 0;
  132.  
  133.           if (thread1_id || thread2_id) break;
  134.  
  135.           HandleOutput("Starting Thread1."); 
  136.               rc = DosCreateThread(&thread1_id, thread1_routine, 0L, 0L, THREAD_STACK_SIZE);
  137.               if (rc != 0) 
  138.               { 
  139.             DosBeep(4000,500); 
  140.             HandleOutput("Error in DosCreateThread()!  Could'nt start thread1." );
  141.           }
  142.  
  143.               rc = DosCreateThread(&thread2_id, thread2_routine, 0L, 0L, THREAD_STACK_SIZE);
  144.               if (rc != 0) 
  145.               { 
  146.             DosBeep(4000,500); 
  147.             HandleOutput("Error in DosCreateThread()!  Could'nt start thread2.");
  148.           }
  149.  
  150.           break;
  151.  
  152.          case IDM_STOP:
  153.              if (thread1_id) DosKillThread(thread1_id);
  154.              if (thread2_id) DosKillThread(thread2_id);
  155.              thread1_id = 0;
  156.              thread2_id = 0;
  157.          break;
  158.  
  159.          case IDM_EXITPROG:
  160.              WinPostMsg( window, WM_CLOSE, NULL, NULL );
  161.              break;
  162.          }
  163.       break;
  164.  
  165.     default:
  166.       return ( WinDefWindowProc( window, message, param1, param2 ) );
  167.     }
  168.  
  169.   return NULL;
  170. }
  171.  
  172. /*mmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmm
  173. // thread1_routine    Routine that writes to the MEMLINK.DLL pipe used
  174. //            to communicate synchronously between thread1 (this 
  175. //                      thread) and thread2.  Thread1 writes the data
  176. //            to the MEMLINK pipe and thread2 reads it.
  177. //mmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmm*/
  178. static VOID APIENTRY thread1_routine(ULONG DummyValue)
  179. {
  180.     struct message m;
  181.     static long counter = 0;
  182.     char TempBuff[100];
  183.  
  184.     while (1)
  185.     {
  186.         counter++;
  187.         sprintf(m.Msg, "MESSAGE %d", counter);
  188.         sprintf(TempBuff, "thread1: sent %s", m.Msg); 
  189.     HandleOutput(TempBuff);
  190.     PipeWrite(PIPE_BOB, PIPE_END_SERVER, &m);
  191.         if (slowflag) DosSleep(1000);
  192.     }
  193. }
  194.  
  195. /*mmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmm
  196. // thread2_routine    Routine that reads from the MEMLINK.DLL pipe used
  197. //            to communicate synchronously between thread1 and 
  198. //            thread2 (this thread).  Thread1 writes the data
  199. //            to the MEMLINK pipe and thread2 reads it.
  200. //mmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmm*/
  201. static VOID APIENTRY thread2_routine(ULONG DummyValue)
  202. {
  203.     struct message m;
  204.     char TempBuff[100];
  205.  
  206.     while (1)
  207.     {
  208.     PipeRead(PIPE_BOB, PIPE_END_CLIENT, &m);
  209.         sprintf(TempBuff, "thread2: received %s", m.Msg);
  210.     HandleOutput(TempBuff);
  211.     }
  212. }
  213.  
  214. /*mmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmm
  215. // HandleOutput        Displays debug messages in test application window.
  216. //            Needs global variable "client_window" to be 
  217. //            initialized - the handle to the applications
  218. //            client window.
  219. //mmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmmm*/
  220. static void HandleOutput(char *MsgString)
  221. {
  222.     RECTL Rectl;
  223.     POINTL Pointl;
  224.     FONTMETRICS FontMetrics;
  225.     static hPS = NULLHANDLE;
  226.     static int cyChar;
  227.     static int cxChar;
  228.     static int Top;
  229.     SIZEL  sizel;
  230.     LONG   i, Delay = 1;
  231.     float  f;
  232.  
  233.     WinQueryWindowRect(client_window, (PRECTL) &Rectl);
  234.  
  235.     if (hPS == NULLHANDLE)
  236.     {
  237.         sizel.cx = sizel.cy = 0;
  238.         hPS = GpiCreatePS(anchor_block, WinOpenWindowDC(client_window),
  239.             (PSIZEL) &sizel, PU_PELS | GPIF_DEFAULT |
  240.             GPIT_MICRO | GPIA_ASSOC);
  241.         GpiSetCharMode(hPS, CM_DEFAULT);
  242.         GpiSetCharSet(hPS, LCID_DEFAULT);
  243.         GpiQueryFontMetrics(hPS, sizeof(FONTMETRICS),
  244.             (PFONTMETRICS) &FontMetrics);
  245.         cyChar = FontMetrics.lMaxBaselineExt;
  246.         cxChar = FontMetrics.lAveCharWidth;
  247.         Top = Rectl.yTop - cyChar;
  248.     }
  249.  
  250.     /* set text position */
  251.     if (Top < Rectl.yBottom) 
  252.     {
  253.         Top = Rectl.yTop - cyChar;
  254.         WinInvalidateRect(client_window, 0, 0);
  255.     }
  256.         
  257.     Pointl.x = 5; 
  258.     Pointl.y = Top;    
  259.     Top -= cyChar;
  260.     
  261.     GpiCharStringAt(hPS, &Pointl, strlen(MsgString), MsgString);
  262. }
  263.  
  264.