home *** CD-ROM | disk | FTP | other *** search
/ Amiga Elysian Archive / AmigaElysianArchive.iso / prog / utils / asynch.lha / dos.async.example
Text File  |  1986-09-22  |  9KB  |  250 lines
  1.  
  2. From ptsfa!hoptoad!lll-crg!caip!cbmvax!phillip Sun Sep 14 00:38:56 PDT 1986 
  3. Article 4261 of net.micro.amiga: 
  4. Relay-Version: version B 2.10.3 4.3bsd-beta 6/6/85; site well.UUCP 
  5. Path: well!ptsfa!hoptoad!lll-crg!caip!cbmvax!phillip 
  6. >From: phillip@cbmvax.cbm.UUCP (Phillip Lindsay) 
  7. Newsgroups: net.micro.amiga 
  8. Subject: AmigaDos Asynchronous File I/O Example 
  9. Message-ID: <702@cbmvax.cbmvax.cbm.UUCP> 
  10. Date: 5 Sep 86 18:50:21 GMT 
  11. Date-Received: 6 Sep 86 11:14:55 GMT 
  12. Organization: Commodore Technology, West Chester, PA 
  13. Lines: 233 
  14.  
  15. [a line is to a line as is a line] 
  16.  
  17.    For all those people interested in implementing AmigaDos file I/O 
  18.    with an asynchronous design. 
  19.  
  20. ============================================================================== 
  21.   Phillip Lindsay - Commodore Business Machines - Amiga Technical Support 
  22.     Dirt: 1200 Wilson Drive, West Chester  PA 19380                 
  23.     uucp: {ihnp4|seismo|caip}!cbmvax!phillip 
  24.     arpa: cbmvax!phillip@seismo -or- phillip@cbmvax.UUCP@{seismo | harvard} 
  25.     Tel.: (215) 431-9180 
  26.   Disclaimer: [someone said I needed this] No warranty is implied or otherwise 
  27.    given in the form of suggestion or example. Any opinions found here are of 
  28.    my making. [unless Fred pops up (my other self)]  
  29. ============================================================================== 
  30.  
  31. /***CUT HERE***/ 
  32.  
  33. /* asendpacket.c - (asynchronous)        send multiple packets to a dos-      */ 
  34. /* 05-SEP-86                                handler                           */ 
  35. /* Phillip Lindsay - Commodore-Amiga                                          */ 
  36.  
  37. #include "exec/types.h" 
  38. #include "exec/ports.h" 
  39. #include "exec/io.h" 
  40. #include "exec/memory.h" 
  41. #include "libraries/dos.h" 
  42. #include "libraries/dosextens.h" 
  43. #include <stdio.h> 
  44. #include "functions.h"           /* aztec C include */ 
  45.  
  46.  
  47. #define DOSTRUE             -1L  /* AmigaDos TRUE */ 
  48. #define MAXARGS              7L  /* limit in packet structure (dosextens.h) */ 
  49.  
  50. /*  
  51.    asynchronous sendpkt routine  
  52.    you must supply a port for packet replies...This function returns the 
  53.    address of the pending packet.  
  54.  
  55. */  
  56. long asendpkt(replyport,pid,action,args,nargs) 
  57.  
  58. struct MsgPort *replyport; /* where all packet replies are sent */ 
  59. struct MsgPort *pid;      /* process indentifier ... (handlers message port ) */ 
  60. long action,             /* packet type ... (what you want handler to do )   */ 
  61.      args[],            /* a pointer to a argument list */ 
  62.      nargs;            /* number of arguments in list  */ 
  63. { 
  64.    
  65.  struct StandardPacket *packet; 
  66.   
  67.  long   count, *pargs;  
  68.  
  69.  if(nargs > MAXARGS) exit(FALSE);  
  70.   
  71.  packet = (struct StandardPacket *)  
  72.    AllocMem((long)sizeof(*packet),MEMF_PUBLIC | MEMF_CLEAR); 
  73.  if(!packet)  
  74.    { 
  75.     FreeMem(packet,(long)sizeof(*packet)); 
  76.     return(NULL); 
  77.    } 
  78.  
  79.  packet->sp_Msg.mn_Node.ln_Name = (char *) &(packet->sp_Pkt); /* link packet- */ 
  80.  packet->sp_Pkt.dp_Link         = &(packet->sp_Msg);        /* to message    */ 
  81.  packet->sp_Pkt.dp_Port         = replyport;         /* set-up reply port   */ 
  82.  packet->sp_Pkt.dp_Type         = action;           /* what to do... */ 
  83.  
  84.  /* move all the arguments to the packet */ 
  85.  pargs = &(packet->sp_Pkt.dp_Arg1);        /* address of first argument */ 
  86.  for(count=NULL;count < nargs;count++)  
  87.    pargs[count]=args[count]; 
  88.  
  89.  PutMsg(pid,packet); /* send packet */ 
  90.  
  91.  return((long)packet);   /* everything went ok...so far... give-em the packet */ 
  92.    
  93. } 
  94.  
  95. /* end of asendpkt.c */ 
  96.  
  97.  
  98. /*  
  99.    
  100.    simple packet flush with error detection ... returns ZERO for error 
  101.    or DOSTRUE (-1) for a-o-k. 
  102.     
  103.    A packet error can be detected in most cases by "Res1" being equal 
  104.    to zero--"Res2" will hold more information pertaining to the error.  
  105.    The problem with handling multiple packets is detecting an error for a  
  106.    particular packet. What makes things a little more difficult is the fact 
  107.    that the "Res1" member of the packet structure is not generally an  
  108.    indicator of an error. So depending on what type of packets you'll be 
  109.    handling you might want to deal with packet replies differently. 
  110.  
  111.    ( I was designing a elegant packet handling tool, but I found that 
  112.       AmigaDos doesn't handle ports like EXEC does. So I couldn't have 
  113.       a software interrupt generated on packet arrvial [sigh...] Tim?  )  
  114.  
  115. */ 
  116.  
  117. long pktflush(rport,pkts) 
  118. struct MsgPort *rport;      /* reply port for packets     */ 
  119. long           pkts;        /* number of packets to flush */ 
  120.  
  121. { 
  122.  struct StandardPacket *apkt; 
  123.  long res1,cres; 
  124.  
  125.  res1 = DOSTRUE; 
  126.  
  127.  while(pkts--)                          /* received all packets? */ 
  128.   { 
  129.    WaitPort(rport);                     /* sleep until a packet arrives */ 
  130.    apkt = (struct StandardPacket *) GetMsg(rport);       /* get packet */ 
  131.    cres = apkt->sp_Pkt.dp_Res1;         /* get result */ 
  132.    FreeMem(apkt,(long)sizeof(*apkt));   /* free packet structure from memory  */ 
  133.    res1 = (!cres ? cres : res1);        /* error?     */   
  134.   }  
  135.  
  136.  return(res1); 
  137. } 
  138.  
  139.    
  140. /*  
  141.    for all those people interested in implementing AmigaDos file I/O 
  142.    with an asynchronous design. 
  143. */ 
  144.   
  145.  
  146. /* start of example */ 
  147.  
  148. #define NARGS    3L                      /* number of arguments */ 
  149. #define NBUFFS   3L                      /* number of buffers   */ 
  150. #define BUFFLEN 60L                      /* buffer length       */ 
  151. #define ESC     27L 
  152.  
  153. main() 
  154. { 
  155.  
  156.  struct MsgPort        *filehdlr;      /* for process id  handler  */ 
  157.  struct MsgPort        *rport;         /* where all packets return */ 
  158.  long                  arg[NARGS],     /* array of arguments       */ 
  159.                        rpkt,           /* holds returned packet    */ 
  160.                        count;          /* count messages           */  
  161.  struct FileHandle     *filehandle;    /* our file handle          */ 
  162.  BPTR                  fh,             /* AmigaDos file handle     */ 
  163.                        fharg1;         /* Arg1 from filehandle     */ 
  164.  UBYTE                 *buff;          /* buffer pointer           */ 
  165.  struct StandardPacket *pkt;           /* our packet               */ 
  166.   
  167.  
  168. /* get buffers */ 
  169.  buff = (UBYTE *) AllocMem((BUFFLEN * NBUFFS),MEMF_PUBLIC | MEMF_CLEAR); 
  170.  if(!buff) exit(TRUE); 
  171.  
  172.  rport = (struct MsgPort *) CreatePort(NULL,NULL); /* make reply port */ 
  173.  if(!rport)  
  174.   {  
  175.    FreeMem(buff,(BUFFLEN * NBUFFS)); 
  176.    exit(TRUE); 
  177.   } 
  178.  
  179. /* here we open a dummy file */ 
  180.  fh = (BPTR) Open("df1:temp",MODE_NEWFILE); 
  181.  if(!fh)  
  182.   { 
  183.    FreeMem(buff,(BUFFLEN * NBUFFS)); 
  184.    DeletePort(rport); 
  185.    exit(TRUE); 
  186.   } 
  187.  
  188. /* bring our AmigaDos file handle into the real world... */ 
  189.  filehandle = (struct FileHandle *)  (fh << 2); 
  190.  
  191. /* read your AmigaDOS Technical Reference Manual for packet requirements */ 
  192.  
  193.  fharg1     = filehandle->fh_Arg1;  /* get Arg1 */ 
  194.   
  195.  filehdlr   = filehandle->fh_Type;  /* get handler for file */ 
  196.   
  197. /*  
  198.    you could get process id of the handler this way also ... 
  199.       filehdlr = (struct MsgPort *) DeviceProc("DF1:"); 
  200. */ 
  201.  
  202. /* give each buffer unique data */ 
  203.  
  204.  for(count=0;count < (BUFFLEN * NBUFFS);count ++) 
  205.   buff[count]= 0x31 + (count / BUFFLEN); 
  206.  
  207. /* set-up arguments and send packets */ 
  208.  
  209.  arg[0]= (long) fharg1;        /* file handle Arg1  */ 
  210.  arg[1]= (long) &buff[0];     /* buffer            */ 
  211.  arg[2]=        BUFFLEN;     /* buffer length     */ 
  212.  puts("one"); 
  213.  rpkt = asendpkt(rport,filehdlr,ACTION_WRITE,arg,NARGS); 
  214.  
  215.  arg[1]= (long) &buff[BUFFLEN]; 
  216.  puts("two"); 
  217.  rpkt = asendpkt(rport,filehdlr,ACTION_WRITE,arg,NARGS); 
  218.  
  219.  arg[1]= (long) &buff[BUFFLEN + BUFFLEN]; 
  220.  puts("three"); 
  221.  rpkt = asendpkt(rport,filehdlr,ACTION_WRITE,arg,NARGS); 
  222.  
  223. /* a more elegant packet flush routine would be nice */ 
  224.  
  225. if(!pktflush(rport,3L)) puts("Error in packets sent."); 
  226.  
  227. /* done clean up... */ 
  228.  Close(fh); 
  229.  FreeMem(buff,(BUFFLEN * NBUFFS)); 
  230.  DeletePort(rport); 
  231.  exit(FALSE); 
  232.   
  233. } 
  234.  
  235. /* eof */ 
  236. --  
  237.  
  238. ============================================================================== 
  239.   Phillip Lindsay - Commodore Business Machines - Amiga Technical Support 
  240.     Dirt: 1200 Wilson Drive, West Chester  PA 19380                 
  241.     uucp: {ihnp4|seismo|caip}!cbmvax!phillip 
  242.     arpa: cbmvax!phillip@seismo -or- phillip@cbmvax.UUCP@{seismo | harvard} 
  243.     Tel.: (215) 431-9180 
  244. Disclaimer: [someone said I needed this] No warranty is implied or otherwise 
  245.    given in the form of suggestion or example. Any opinions found here are of 
  246.    my making. [unless Fred pops up (my other self)]  
  247. ============================================================================== 
  248.  
  249.  
  250. $