home *** CD-ROM | disk | FTP | other *** search
/ Fresh Fish 5 / FreshFish_July-August1994.bin / bbs / dev / rkrm.lha / RKRM / Commodities / broker.c next >
Encoding:
C/C++ Source or Header  |  1992-09-03  |  6.3 KB  |  178 lines
  1. ;/* broker.c - Simple skeletal example of opening a broker.  Compiled with SASC 5.10b
  2. LC -b0 -cfist -v -y -j73 broker.c
  3. Blink FROM LIB:c.o,broker.o TO broker LIBRARY LIB:LC.lib,LIB:Amiga.lib
  4. quit
  5. */
  6.  
  7. /*
  8. Copyright (c) 1992 Commodore-Amiga, Inc.
  9.  
  10. This example is provided in electronic form by Commodore-Amiga, Inc. for
  11. use with the "Amiga ROM Kernel Reference Manual: Libraries", 3rd Edition,
  12. published by Addison-Wesley (ISBN 0-201-56774-1).
  13.  
  14. The "Amiga ROM Kernel Reference Manual: Libraries" contains additional
  15. information on the correct usage of the techniques and operating system
  16. functions presented in these examples.  The source and executable code
  17. of these examples may only be distributed in free electronic form, via
  18. bulletin board or as part of a fully non-commercial and freely
  19. redistributable diskette.  Both the source and executable code (including
  20. comments) must be included, without modification, in any copy.  This
  21. example may not be published in printed form or distributed with any
  22. commercial product.  However, the programming techniques and support
  23. routines set forth in these examples may be used in the development
  24. of original executable software products for Commodore Amiga computers.
  25.  
  26. All other rights reserved.
  27.  
  28. This example is provided "as-is" and is subject to change; no
  29. warranties are made.  All use is at your own risk. No liability or
  30. responsibility is assumed.
  31. */
  32.  
  33. #include <exec/libraries.h>
  34. #include <libraries/commodities.h>
  35. #include <dos/dos.h>
  36. #include <clib/exec_protos.h>
  37. #include <clib/alib_protos.h>
  38. #include <clib/alib_stdio_protos.h>
  39. #include <clib/commodities_protos.h>
  40.  
  41. #ifdef LATTICE
  42. int CXBRK(void) { return(0); }  /* Disable Lattice CTRL/C handling */
  43. int chkabort(void) { return(0); }
  44. #endif
  45.  
  46. void main(void);
  47. void ProcessMsg(void);
  48.  
  49. struct Library *CxBase;
  50.  
  51. CxObj *broker;
  52. struct MsgPort *broker_mp;
  53. ULONG cxsigflag;
  54.  
  55. struct NewBroker newbroker = {
  56.     NB_VERSION,   /* nb_Version - Version of the NewBroker structure */
  57.     "RKM broker", /* nb_Name - Name Commodities uses to identify this commodity */
  58.     "Broker",     /* nb_Title - Title of commodity that appears in CXExchange */
  59.     "A simple example of a broker",  /* nb_Descr - Description of the commodity */
  60.     0,            /* nb_Unique - Tells CX not to launch another commodity with same name */
  61.     0,            /* nb_Flags - Tells CX if this commodity has a window */
  62.     0,            /* nb_Pri - This commodity's priority */
  63.     0,            /* nb_Port - MsgPort CX talks to */
  64.     0             /* nb_ReservedChannel - reserved for later use */
  65. };
  66.  
  67.  
  68. void main(void)
  69. {
  70.     CxMsg *msg;
  71.  
  72.     /* Before bothering with anything else, open the library */
  73.     if (CxBase = OpenLibrary("commodities.library", 37L))
  74.     {
  75.         /* Commodities talks to a Commodities application through */
  76.         /* an Exec Message port, which the application provides   */
  77.         if (broker_mp = CreateMsgPort())
  78.         {
  79.             newbroker.nb_Port = broker_mp;
  80.  
  81.             /* The commodities.library function CxBroker() adds a borker to the
  82.              * master list.  It takes two arguments, a pointer to a NewBroker
  83.              * structure and a pointer to a LONG.  The NewBroker structure contains
  84.              * information to set up the broker.  If the second argument is not
  85.              * NULL, CxBroker will fill it in with an error code.
  86.              */
  87.             if (broker = CxBroker(&newbroker, NULL))
  88.             {
  89.                 cxsigflag = 1L << broker_mp->mp_SigBit;
  90.  
  91.                 /* After it's set up correctly, the broker has to be activated */
  92.                 ActivateCxObj(broker, 1L);
  93.  
  94.                 /* the main processing loop */
  95.                 ProcessMsg();
  96.  
  97.                 /* It's time to clean up.  Start by removing the broker from the
  98.                  * Commodities master list.  The DeleteCxObjAll() function will
  99.                  * take care of removing a CxObject and all those connected
  100.                  * to it from the Commodities network
  101.                  */
  102.                 DeleteCxObj(broker);
  103.  
  104.                 /* Empty the port of CxMsgs */
  105.                 while(msg = (CxMsg *)GetMsg(broker_mp))
  106.                         ReplyMsg((struct Message *)msg);
  107.             }
  108.             DeletePort(broker_mp);
  109.         }
  110.         CloseLibrary(CxBase);
  111.     }
  112. }
  113.  
  114.  
  115.  
  116. void ProcessMsg(void)
  117. {
  118.     CxMsg *msg;
  119.  
  120.     ULONG sigrcvd, msgid, msgtype;
  121.     LONG returnvalue = 1L;
  122.  
  123.     while (returnvalue)
  124.     {
  125.         /* wait for something to happen */
  126.         sigrcvd = Wait(SIGBREAKF_CTRL_C | cxsigflag);
  127.  
  128.         /* process any messages */
  129.         while(msg = (CxMsg *)GetMsg(broker_mp))
  130.         {
  131.             /* Extract necessary information from the CxMessage and return it */
  132.             msgid = CxMsgID(msg);
  133.             msgtype = CxMsgType(msg);
  134.             ReplyMsg((struct Message *)msg);
  135.  
  136.             switch(msgtype)
  137.             {
  138.                 case CXM_IEVENT:
  139.                     /* Shouldn't get any of these in this example */
  140.                     break;
  141.                 case CXM_COMMAND:
  142.                     /* Commodities has sent a command */
  143.                     printf("A command: ");
  144.                     switch(msgid)
  145.                     {
  146.                         case CXCMD_DISABLE:
  147.                             printf("CXCMD_DISABLE\n");
  148.                             /* The user clicked Commodities Exchange disable
  149.                              * gadget better disable
  150.                              */
  151.                             ActivateCxObj(broker, 0L);
  152.                             break;
  153.                         case CXCMD_ENABLE:
  154.                             /* user clicked enable gadget */
  155.                             printf("CXCMD_ENABLE\n");
  156.                             ActivateCxObj(broker, 1L);
  157.                             break;
  158.                         case CXCMD_KILL:
  159.                             /* user clicked kill gadget, better quit */
  160.                             printf("CXCMD_KILL\n");
  161.                             returnvalue = 0L;
  162.                             break;
  163.                     }
  164.                     break;
  165.                 default:
  166.                     printf("Unknown msgtype\n");
  167.                     break;
  168.             }
  169.         }
  170.         /* Test to see if user tried to break */
  171.         if (sigrcvd & SIGBREAKF_CTRL_C)
  172.         {
  173.             returnvalue = 0L;
  174.             printf("CTRL C signal break\n");
  175.         }
  176.     }
  177. }
  178.