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

源码开发语言/平台
当前位置：首页 > 源码/资料 > 多媒体 > 流媒体/Mpeg4/MP4 > 查看源码
ixjasync.c
资源名称：rtsp-1.0.1.tar.gz　[点击查看]
上传用户：sy_wanhua
上传日期：2013-07-25
资源大小：3048k
文件大小：7k
源码类别：

流媒体/Mpeg4/MP4

开发平台：

C/C++

ixjasync.c：源码内容
  1. #include <sys/types.h>
  2. #include <sys/time.h>
  3. #include <stdio.h>
  4. #include <stdlib.h>
  5. #include <strings.h>
  6. #include <signal.h>
  7. #include <sys/ioctl.h>
  8. #include <unistd.h>
  9. #include <fcntl.h>
  10. #include <errno.h>
  11. #include "ixjuser.h"
  13. void closeall(void);
  14. void getdata(int);
  15. int ixj1, ixj2, size1, size2, len, depth, frame, frame1, frame2;
  16. unsigned long write1, write2;
  17. char buff1[480], buff2[480];
  19. void usage(void);
  21. int main(int argc, char *argv[])
  22. {
  23.   char pname1[80], pname2[80];
  24.   int codec, oflags1, oflags2;
  26.   if(argc >= 6)
  27.   {
  28.     frame = atoi(argv[5]);
  29.   }
  30.   else
  31.   {
  32.     usage();
  33.     exit(-1);
  34.   }
  36.   sprintf(pname1, "/dev/ixj%s", argv[1]);
  37.   sprintf(pname2, "/dev/ixj%s", argv[2]);
  39.   ixj1 = open(pname1, O_RDWR);
  40.   if(ixj1 < 0)
  41.   {
  42.     printf("%s open failed %d %sn" ,pname1, ixj1, strerror(errno));
  43.     exit(-1);
  44.   }
  45.   ixj2 = open(pname2, O_RDWR);
  46.   if(ixj2 < 0)
  47.   {
  48.     printf("%s open failed %d %sn" ,pname2, ixj2, strerror(errno));
  49.     exit(-1);
  50.   }
  52.   if(argc >= 5)
  53.   {
  54.     depth = atoi(argv[4]);
  55.     ioctl(ixj1, IXJCTL_PLAY_DEPTH, depth);
  56.     ioctl(ixj1, IXJCTL_REC_DEPTH, depth);
  57.     ioctl(ixj2, IXJCTL_PLAY_DEPTH, depth);
  58.     ioctl(ixj2, IXJCTL_REC_DEPTH, depth);
  59.   }
  61.   frame1 = ioctl(ixj1, IXJCTL_FRAME, frame);
  62.   frame2 = ioctl(ixj2, IXJCTL_FRAME, frame);
  64.   atexit(closeall);
  66.   if(!ioctl(ixj1, IXJCTL_RING))
  67.   {
  68.     exit(0);
  69.   }
  71.   if(!ioctl(ixj2, IXJCTL_RING))
  72.   {
  73.     exit(0);
  74.   }
  75.   codec = atoi(argv[3]);
  76.   switch(codec)
  77.   {
  78.     case G723_63:
  79.       len = 24;
  80.       break;
  81.     case G723_53:
  82.       len = 20;
  83.       break;
  84.     case TS85:
  85.       len = 32;
  86.       break;
  87.     case TS48:
  88.       len = 18;
  89.       break;
  90.     case TS41:
  91.       len = 16;
  92.       break;
  93.     case G728:
  94.       len = 96;
  95.       break;
  96.     case G729:
  97.       len = 36;
  98.       break;
  99.     case ULAW:
  100.       switch(frame)
  101.       {
  102.         case 30:
  103.           len = 240;
  104.           break;
  105.         case 20:
  106.           len = 160;
  107.           break;
  108.         case 10:
  109.           len = 80;
  110.           break;
  111.       }
  112.       break;
  113.     case ALAW:
  114.       switch(frame)
  115.       {
  116.         case 30:
  117.           len = 240;
  118.           break;
  119.         case 20:
  120.           len = 160;
  121.           break;
  122.         case 10:
  123.           len = 80;
  124.           break;
  125.       }
  126.       break;
  127.     case LINEAR16:
  128.       switch(frame)
  129.       {
  130.         case 30:
  131.           len = 480;
  132.           break;
  133.         case 20:
  134.           len = 320;
  135.           break;
  136.         case 10:
  137.           len = 160;
  138.           break;
  139.       }
  140.       break;
  141.     case LINEAR8:
  142.       switch(frame)
  143.       {
  144.         case 30:
  145.           len = 240;
  146.           break;
  147.         case 20:
  148.           len = 160;
  149.           break;
  150.         case 10:
  151.           len = 80;
  152.           break;
  153.       }
  154.       break;
  155.     case WSS:
  156.       switch(frame)
  157.       {
  158.         case 30:
  159.           len = 240;
  160.           break;
  161.         case 20:
  162.           len = 160;
  163.           break;
  164.         case 10:
  165.           len = 80;
  166.           break;
  167.       }
  168.       break;
  169.   }
  170.   signal(SIGIO, &getdata);
  171.   fcntl(ixj1, F_SETOWN, getpid());
  172.   fcntl(ixj2, F_SETOWN, getpid());
  173.   oflags1 = fcntl(ixj1, F_GETFL);
  174.   fcntl(ixj1, F_SETFL, oflags1 | FASYNC);
  175.   oflags2 = fcntl(ixj2, F_GETFL);
  176.   fcntl(ixj2, F_SETFL, oflags2 | FASYNC);
  178.   write1 = write2 = 0;
  179.   ioctl(ixj1, IXJCTL_PLAY_CODEC, codec);
  180.   ioctl(ixj1, IXJCTL_REC_CODEC, codec);
  181.   ioctl(ixj2, IXJCTL_PLAY_CODEC, codec);
  182.   ioctl(ixj2, IXJCTL_REC_CODEC, codec);
  183.   ioctl(ixj1, IXJCTL_PLAY_START);
  184.   ioctl(ixj2, IXJCTL_REC_START);
  185.   ioctl(ixj2, IXJCTL_PLAY_START);
  186.   ioctl(ixj1, IXJCTL_REC_START);
  188.   printf("Frame1 = %d, Frame2 = %d, len = %d, depth = %d, codec = %dn",
  189.           frame1, frame2, len, depth, codec);
  190.   fflush(stdout);
  191.   
  192.   while(ioctl(ixj1, IXJCTL_HOOKSTATE) && ioctl(ixj2, IXJCTL_HOOKSTATE))
  193.   {
  194.     if(write1 == 500)
  195.     {
  196.       ioctl(ixj1, IXJCTL_AEC_START);
  197.       ioctl(ixj2, IXJCTL_AEC_START);
  198.       write1++;
  199.     }
  200.   }
  201.   printf("Write1 = %ld, Write2 = %ldn",write1,write2);
  202.   getchar();
  203. }
  204. void usage(void)
  205. {
  206.   printf("ixjasync card1 card2 codec depth framen");
  207.   printf("tcard1 and card2 - 0 = /dev/ixj0, 1 = /dev/ixj1 etc.n");
  208.   printf("tcodec  1 = g.723.1 6.3n");
  209.   printf("t       2 = g.723.1 5.3n");
  210.   printf("t       3 = TrueSpeech 8.5n");
  211.   printf("t       4 = TrueSpeech 4.8n");
  212.   printf("t       5 = TrueSpeech 4.1n");
  213.   printf("t       6 = g.728n");
  214.   printf("t       7 = g.729n");
  215.   printf("t       8 = uLawn");
  216.   printf("t       9 = aLawn");
  217.   printf("t      10 = Linear 16 Bitn");
  218.   printf("t      11 = Linear 8 Bitn");
  219.   printf("t      12 = Windows Sound Systemn");
  220.   printf("tdepth - DSP buffer depth in framesn");
  221.   printf("tframe - 10 = 10ms, 20 = 20ms, 30 = 30msn");
  222. }
  224. void closeall(void)
  225. {
  226.   ioctl(ixj1, IXJCTL_AEC_STOP);
  227.   ioctl(ixj2, IXJCTL_AEC_STOP);
  228.   ioctl(ixj1, IXJCTL_REC_STOP);
  229.   ioctl(ixj1, IXJCTL_PLAY_STOP);
  230.   ioctl(ixj2, IXJCTL_REC_STOP);
  231.   ioctl(ixj2, IXJCTL_PLAY_STOP);
  232.   close(ixj1);
  233.   close(ixj2);
  234. }
  236. void getdata(int x)
  237. {
  238.   fd_set  rfds,wfds,efds;
  239.   struct timeval  tv;
  240.   IXJ_EXCEPTION ixje1, ixje2;
  241.   int nmax, size;
  242.   char buf[480], dtmf1, dtmf2;
  244.   signal(SIGIO, &getdata);
  245.   nmax = (ixj1 > ixj2 ? ixj1+1 : ixj2+1);
  247.   FD_ZERO(&rfds);
  248.   FD_ZERO(&wfds);
  249.   FD_ZERO(&efds);
  250.   FD_SET(ixj1, &rfds);
  251.   FD_SET(ixj2, &rfds);
  252.   FD_SET(ixj1, &wfds);
  253.   FD_SET(ixj2, &wfds);
  254.   FD_SET(ixj1, &efds);
  255.   FD_SET(ixj2, &efds);
  256.   tv.tv_sec = 0;
  257.   tv.tv_usec = 300;
  258.   select(nmax,&rfds, &wfds, &efds, &tv);
  259.   if(FD_ISSET(ixj1,&rfds)) 
  260.   {
  261.     size1 = read(ixj1, buff1, len);
  262.   }
  263.   if(FD_ISSET(ixj2,&wfds)) 
  264.   {
  265.     if(size1 > 0)
  266.     {
  267.       write(ixj2, buff1, len);
  268.       write2++;
  269.       size1 = 0;
  270.     }
  271.   }
  273.   if(FD_ISSET(ixj2,&rfds)) 
  274.   {
  275.     size2 = read(ixj2, buff2, len);
  276.   }
  277.   if(FD_ISSET(ixj1,&wfds)) 
  278.   {
  279.     if(size2 > 0)
  280.     {
  281.       write(ixj1, buff2, len); 
  282.       write1++;
  283.       size2 = 0;
  284.     }
  285.   }
  286.   if(FD_ISSET(ixj1,&efds)) 
  287.   {
  288.     // Deal with DTMF
  289.     ixje1.bytes = ioctl(ixj1, IXJCTL_EXCEPTION);
  290.     if(ixje1.bits.dtmf_ready)
  291.     {
  292.       dtmf1 = ioctl(ixj1, IXJCTL_GET_DTMF_ASCII);
  293.       switch(dtmf1)
  294.       {
  295.         case '1':
  296.           ioctl(ixj1, IXJCTL_AEC_START);
  297.           printf("AEC On card1.n");
  298.           break;
  299.         case '2':
  300.           ioctl(ixj1, IXJCTL_AEC_STOP);
  301.           printf("AEC Off card1.n");
  302.           break;
  303.         default:
  304.           printf("DTMF from card 0 = %cn", dtmf1);
  305.           break;
  306.       }
  307.       fflush(stdout);
  308.     }
  309.   }
  310.   if(FD_ISSET(ixj2,&efds)) 
  311.   {
  312.     // Deal with DTMF
  313.     ixje2.bytes = ioctl(ixj2, IXJCTL_EXCEPTION);
  314.     if(ixje2.bits.dtmf_ready)
  315.     {
  316.       dtmf2 = ioctl(ixj2, IXJCTL_GET_DTMF_ASCII);
  317.       switch(dtmf2)
  318.       {
  319.         case '1':
  320.           ioctl(ixj2, IXJCTL_AEC_START);
  321.           printf("AEC On card2.n");
  322.           break;
  323.         case '2':
  324.           ioctl(ixj2, IXJCTL_AEC_STOP);
  325.           printf("AEC Off card2.n");
  326.           break;
  327.         default:
  328.           printf("DTMF from card 2 = %cn", dtmf2);
  329.           break;
  330.       }
  331.       fflush(stdout);
  332.     }
  333.   }
  334. }