开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 嵌入式/单片机编程 > DSP编程 > 查看源码
dio_tsk.c
资源名称：DSP-C6000-DM642DEMO.rar　[点击查看]
上传用户：dahaojd
上传日期：2008-01-29
资源大小：14357k
文件大小：4k
源码类别：

DSP编程

开发平台：

C/C++

dio_tsk.c：源码内容
  1. /*
  2.  *  Copyright 2003 by Texas Instruments Incorporated.
  3.  *  All rights reserved. Property of Texas Instruments Incorporated.
  4.  *  Restricted rights to use, duplicate or disclose this code are
  5.  *  granted through contract.
  6.  *  
  7.  */
  8. /* "@(#) DDK 1.10.00.23 07-02-03 (ddk-b12)" */
  9. /*
  10.  *  ======== dio_tsk.c ========
  11.  *  SEM based functions of DIO.
  12.  *
  13.  */
  15. #include <std.h>
  17. #include <dev.h>
  18. #include <que.h>
  19. #include <sem.h>
  20. #include <sys.h>
  22. #include <iom.h>
  23. #include <dio.h>
  25. Int     DIO_tskIdle(DEV_Handle device, Bool flush);
  26. Int     DIO_tskIssue(DEV_Handle device);
  27. Bool    DIO_tskReady(DEV_Handle device, SEM_Handle sem);
  28. Int     DIO_tskReclaim(DEV_Handle device);
  29. Void    DIO_tskCallback(Ptr devp, DEV_Frame *frame);
  31. /*
  32.  *  ======== DIO_tskCallback ========
  33.  */
  34. Void DIO_tskCallback(Ptr devp, DEV_Frame *frame)
  35. {
  36.     DEV_Handle  device = (DEV_Handle)devp;
  37.     DIO_Handle  dio = (DIO_Handle)device->object;
  39.     if (frame->cmd == IOM_READ || frame->cmd == IOM_WRITE) {
  40.         QUE_put(device->fromdevice, frame); 
  42.         SEM_post(dio->context.sems.complete);
  44.         /*
  45.          * If semaphore was registered with DIO_ready(), dio->ready will
  46.          * be non-NULL.  In this case, SIO_select() is probably waiting for
  47.          * this semaphore to be posted by the first ready device.
  48.          */
  49.         if (dio->context.sems.ready) {
  50.             SEM_post(dio->context.sems.ready);
  51.         }
  52.     }
  53.     else {
  54.         SEM_post(dio->context.sems.complete);
  55.     }
  56. }
  58. /*
  59.  *  ======== DIO_tskIdle ========
  60.  *  DIO_tskIdle() puts the device back to the state it was in just after
  61.  *  DIO_open() was called.
  62.  */
  63. Int DIO_tskIdle(DEV_Handle device, Bool flush)
  64. {
  65.     DIO_Handle dio = (DIO_Handle)device->object;
  66.     Uns         pendCount = 0;
  67.     DEV_Frame   localFrame;
  68.     Int         status;
  70.     localFrame.status = IOM_PENDING;
  72.     if (device->mode == DEV_INPUT || flush) {
  73.         localFrame.cmd = IOM_ABORT;
  74.     }
  75.     else {
  76.         localFrame.cmd = IOM_FLUSH;
  77.     }
  79.     status = dio->fxns->mdSubmitChan(dio->chanp, &localFrame);
  81.     if (status == IOM_PENDING) {
  82.         for (;;) {
  83.             if (SEM_pend(dio->context.sems.complete, device->timeout)) {
  84.                 /*
  85.                  * Break out of the for loop when the local abort/flush
  86.                  * frame status shows that it is complete.
  87.                  */
  88.                 if (localFrame.status == IOM_COMPLETED) {
  89.                     break;
  90.                 }
  91.                 else {
  92.                     /* keep track of data frame completions */
  93.                     pendCount++;
  94.                 }
  95.             }
  96.             else {
  97.                 return (SYS_ETIMEOUT);
  98.             }
  99.         }
  101.         /* 
  102.          * Update complete semaphore so it corresponds to number of frames
  103.          * on the 'todevice' queue.  'for' loop above may have made the 
  104.          * complete sem count inconsistent.
  105.          */
  106.         while (pendCount--) {
  107.             SEM_post(dio->context.sems.complete);
  108.         }
  109.     }
  111.     return (SYS_OK);
  112. }
  114. /*
  115.  *  ======== DIO_tskIssue ========
  116.  */
  117. Int DIO_tskIssue(DEV_Handle device)
  118. {
  119.     DIO_Handle dio = (DIO_Handle)device->object;
  120.     DEV_Frame   *frame;
  121.     Int         status;
  123.     frame = QUE_get(device->todevice);
  125.     frame->cmd = (device->mode == DEV_INPUT) ? IOM_READ : IOM_WRITE;
  126.     frame->status = IOM_PENDING;
  128.     status = dio->fxns->mdSubmitChan(dio->chanp, frame);
  130.     if (status < 0) {
  131.         return (SYS_EBADIO);
  132.     }
  133.     else {
  134.         if (status == IOM_COMPLETED) {
  135.             QUE_put(device->fromdevice, frame);
  136.             SEM_post(dio->context.sems.complete);
  137.         }
  138.         
  139.         return (SYS_OK);
  140.     }
  141. }
  143. /*
  144.  *  ======== DIO_tskReady ========
  145.  */
  146. Bool DIO_tskReady(DEV_Handle device, SEM_Handle sem)
  147. {
  148.     DIO_Handle  dio = (DIO_Handle)device->object;
  150.     dio->context.sems.ready = sem;
  152.     return (!(QUE_empty(device->fromdevice)));
  153. }
  155. /*
  156.  *  ======== DIO_tskReclaim ========
  157.  */
  158. Int DIO_tskReclaim(DEV_Handle device)
  159. {
  160.     DIO_Handle  dio = (DIO_Handle)device->object;
  162.     /*
  163.      * Wait here if there are no buffers on the device->fromdevice
  164.      * queue.
  165.      */
  166.     if (SEM_pend(dio->context.sems.complete, device->timeout)) {
  167.         return (SYS_OK);
  168.     }
  169.     else {
  170.         return (SYS_ETIMEOUT);
  171.     }
  172. }