WebSVN – Kolibri OS – Diff – /programs/media/ac97snd/ac97snd/ac97wav.c

 #include "string.h"
 #include "ac97wav.h"
 #include "../mpg/mpg123.h"
 #include "../sound.h"
-typedef struct
-{
-  int sender;
-  int size;
-  int code;
-  char data[1];
-} IPC;
 int ipc_client = 0;
 #define MP3_ERROR_OUT_OF_BUFFER  5
 int m_last_error;
 void _stdcall thread_proc(void *param);
-void _stdcall create_thread(void *proc, void *param, int stack_size);
-void _stdcall init_ipc(void);
+void _stdcall thread_proc(void *param);
-void _stdcall send_ipc(int dst, DWORD code);
+void _stdcall create_thread(void *proc, void *param, int stack_size);
-IPC * _stdcall recieve_ipc(void);
+void _stdcall send_ipc(int dst, DWORD code);
 void touch(char *buf, int size);
 int mp3FindSync(byte* buf, int size, int* sync);
-int stream_read_raw(struct reader *rd,unsigned char *buf, int size);
-char *fname;
-struct reader rd;
-struct frame fr;
 int stream_read_raw(struct reader *rd,unsigned char *buf, int size);
 void draw_window();
-void draw_progress_bar();
+char *fname;
-void do_ipc();
 void exit();
 struct reader rd;
 int l_vol=-700;     //-7db
 int r_vol=-700;
 int pan =0;
-DWORD status;
-DWORD offset;
+DWORD status;
 DWORD first_sync;
 unsigned char *testbuff;
 int inpsize;
 int outsize;
 int outremain;
 int totalout;
 int done;
-char path[1024];
 char header[] = "AC97 MP3 player";
 char buttons_text[]=" Play    Stop     <<      >>     Vol-    Vol+";
-void (*snd_play)();
-int main(int argc, char *argv[])      //int argc, char *argv[])
-{
-   int err;
-   int ver;
-   int evnt;
-   int key;
-   int pos;
-   int msg;
-   int cnt;
-   IPC *incom;
-   _asm
-   {
-     mov eax, 40
-     mov ebx, 0x47  ;recieve ipc
-     int 0x40
-     mov eax, 66
-     mov ebx, 1
-     mov ecx, 1
-     int 0x40
-   };
-   init_ipc();
-   InitHeap(0);
-   if(err = InitSound(&ver))
-   { debug_out_str("Sound service not installed\n\r");
-     return 0;
-   }
-   if( (SOUND_VERSION>(ver&0xFFFF)) ||
-       (SOUND_VERSION<(ver >> 16)))
-   { debug_out_str("Sound service version mismatch\n\r");
-     return 0;
-   }
-   make_decode_tables(32767);
-   init_layer2();
-   init_layer3(32);
-   fr.single = -1;
-   outremain = 0x40000 ;
-   if( !(outbuf=UserAlloc(outremain)))
-     return 0;
-   touch(outbuf, outremain);
-   if ( !(testbuff=UserAlloc(4096)))
-     return 0;
-   if (! (inpbuf=UserAlloc(0x10000)))
-     return 0;
-   touch(inpbuf, 0x10000);
-   create_reader(&rd, inpbuf, 0x10000);
-   fname = argv[1];
-   if(get_fileinfo(fname, &fileinfo)==FILE_NOT_FOUND)
-   {
-     _asm
-     {
-       mov eax, 23
-       mov ebx, 100
-       int 0x40
-       mov [msg], eax
-     }
-     if (msg != 7)
-     {
-       debug_out_str("\n\rfile not found\n\r");
-       return 0;
-     };
-     incom = recieve_ipc();
-     if(incom->code != 'CNCT')
-     {
-       debug_out_str("\n\rinvalid ipc code\n\r");
-       status = ST_EXIT;
-       return 0;
-     };
-     ipc_client = incom->sender;
-     send_ipc(ipc_client,'CNCT');
-   };
-   snd_init=0;
-   create_thread(thread_proc, 0, 4096);
-   for(snd_init=0,cnt=100; (snd_init==0)&&(cnt!=0); cnt--)
-     delay(10);
-   if (!snd_init)
-     return 0;
-   draw_window();
-   while(1)
-  {  if(status==ST_PLAY)
-     {  draw_progress_bar();
-        evnt = wait_for_event(80);
-     }
-     else
-        evnt = wait_for_event_infinite();
-    switch(evnt)
-    {
-      case EV_REDRAW:
-        draw_window();
-        break;
-      case EV_KEY:
-        if(!get_key(&key))
-        {
-          switch(key)
-          {  case 0xE0:
-             case 0xE1:
-               break;
-             default:
-               switch (key)
-               {
-                 case 0x01:  //Esc
-                   status = ST_EXIT;
-                   exit();
-                   break;
-                 case 0x47:  //Home
-                   if(l_vol < 0)
-                   { l_vol+=100;
-                     r_vol+=100;
-                     SetVolume(hBuff,l_vol,r_vol);
-                   };
-                   break;
-                 case 0x4F:  //End
-                   if(l_vol > -10000)
-                   { l_vol-=100;
-                     r_vol-=100;
-                     SetVolume(hBuff,l_vol,r_vol);
-                   };
-                   break;
-                 case 0x53:
-                   if(pan > -10000)
-                   { pan -=100;
-                     SetPan(hBuff,pan);
-                   };
-                   break;
-                 case 0x51:
-                   if(pan < 10000)
-                   { pan +=100;
-                     SetPan(hBuff,pan);
-                   };
-                   break;
-               }
-          };
-        };
-        break;
-      case EV_BUTTON:
-        switch(get_button_id())
-        {  case 1:
-             status = ST_EXIT;
-             exit();
-             break;
-           case 0x10:
-             status = ST_PLAY;
-             continue;
-           case 0x11:
-             status = ST_STOP;
-             break;
-//           case 0x12:
-//           case 0x13:
-           case 0x14:
-            if(l_vol > -10000)
-            {
-              l_vol-=100;
-              r_vol-=100;
-              SetVolume(hBuff,l_vol,r_vol);
-            };
-            break;
-           case 0x15:
-            if(l_vol < 0)
-            { l_vol+=100;
-              r_vol+=100;
-              SetVolume(hBuff,l_vol,r_vol);
-            };
-            break;
-           case 0x30:
-            if(status==ST_DONE)
-              break;
-            pos = (GetMousePos(REL_WINDOW)>>16)-7;
-            offset = ((fileinfo.size-44)/286*pos+44)&0xFFFFFFFC;
-            set_reader(&rd, offset);
-            draw_progress_bar();
-            break;
-        };
-        break;
-      case EV_IPC:
-        do_ipc();
-        break;
-    };
-  };
-   return 0;
-};
 void (*snd_play)();
 void draw_window()
+{
     debug_out(*str);
     str++;
+  }
+}
+int main(int argc, char *argv[])      //int argc, char *argv[])
+{
+   DWORD fmt;
+   DWORD r_bytes;
+   int retval;
+   int err;
+   int ver;
+   fname = argv[1];
+   debug_out_str("\n\rPlay file ");
+   debug_out_str(fname);
+   debug_out_str("\n\r");
+   InitHeap(1024*1024);
+   if(get_fileinfo(fname, &fileinfo)==FILE_NOT_FOUND)
+   {  debug_out_str("\n\rfile not found\n\r");
+      return 0;
+   };
+   if(err = InitSound(&ver))
+   {
+     debug_out_str("Sound service not installed\n\r");
+     return 0;
+   }
+   if( (SOUND_VERSION>(ver&0xFFFF)) ||
+       (SOUND_VERSION<(ver >> 16)))
+   {
+     debug_out_str("Sound service version mismatch\n\r");
+     return 0;
+   }
+   testbuff = UserAlloc(4096);
+   get_fileinfo(fname, &fileinfo);
+   r_bytes=0;
+   retval=read_file (fname,testbuff,0,2048,&r_bytes);
+   if ( retval && (r_bytes==0))
+     return 0;
+   inpbuf = UserAlloc(0x10000);
+   touch(inpbuf, 0x10000);
+   create_reader(&rd, inpbuf, 0x10000);
+   init_reader(&rd,fname);
+   fmt = test_wav((WAVEHEADER*)testbuff);
+   if (fmt != 0)
+   {
+     snd_play = &play_wave;
+     set_reader(&rd, 44);
+     outbuf = UserAlloc(32*1024);
+     touch(outbuf, 32768);
+   }
+   else
+   { fmt = test_mp3(testbuff);
+     if(fmt ==0) return 0;
+     snd_play = &play_mp3;
+     outremain = 0x40000 ;
+     outbuf = UserAlloc(outremain);
+     touch(outbuf, outremain);
+     make_decode_tables(32767);
+     init_layer2();
+     init_layer3(32);
+     fr.single = -1;
+   };
+   status = ST_PLAY;
+   if (err = CreateBuffer(fmt,0, &hBuff))
+   {
+     debug_out_str("create buffer return error\n\r");
+    ; return 0;
+   }
+   SetVolume(hBuff,l_vol,r_vol);
+   GetVolume(hBuff,&l_vol,&r_vol);
+   create_thread(thread_proc, 0, 4096);
+   while(1)
+   {  delay(10);
+      switch(status)
+      {  case ST_PLAY:
+           snd_play();
+           continue;
+         case ST_STOP:
+           StopBuffer(hBuff);
+           status = ST_DONE;
+           continue;
+         case ST_EXIT:
+           StopBuffer(hBuff);
+           DestroyBuffer(hBuff);
+           return 0;
+      };
+   };
+   return 0;
 };
 void touch(char *buf, int size)
 { int i;
     {  if(rd.filepos > 102400)
           return 0;
         if(!rd.head_read(&rd,&hdr))
-           return 0;
+                        return 0;
         if(!decode_header(&fr,hdr))
-        {
-           if((hdr & 0xffffff00) == 0x49443300)
- 	       {
- 		     int id3length = 0;
-		     id3length = parse_new_id3(&rd, hdr);
-		     continue;
-	       };
-           rd.strpos-=3;
+        {  rd.strpos-=3;
-           rd.stream-=3;
+            rd.stream-=3;
-           rd.strremain+=3;
+            rd.strremain+=3;
-           continue;
+            continue;
         };
         break;
 void play_mp3()
 {  char *outPtr;
     int totalout;
     int outcount;
  //   memset(&fr,0,sizeof(fr));
     fr.down_sample_sblimit = 32;
     fr.single = -1;
     reset_mpg();
-      { if(totalout < 4096)
+    { if(totalout < 4096)
-        {  memset(outPtr,0,4096-totalout);
+      {  memset(outPtr,0,4096-totalout);
-           totalout = 4096;
+                totalout = 4096;
-        };
+      };
+    }
+    else
-      else if(totalout < 8192) continue;
+      if(totalout < 8192)
+        continue;
-      outPtr = outbuf;
+    outPtr = outbuf;
-      while (totalout >= 4096)
+    while (totalout >= 4096)
+    {
-        WaveOut(hBuff,outPtr,4096);
+      WaveOut(hBuff,outPtr,4096);
+      if(status!=ST_PLAY)
-        if(status!=ST_PLAY)
+      { if(status != ST_EXIT)
-        { StopBuffer(hBuff);
+         status =  ST_STOP;
-          return;
+        return;
-        };
+      };
-        totalout-=4096;
+      totalout-=4096;
-        outPtr+=4096;
+      outPtr+=4096;
-        outremain+=4096;
+      outremain+=4096;
-      };
     };
-      if(done)
+    if(done)
-      { status = ST_STOP;
-        if( ipc_client)
-          send_ipc(ipc_client,'DONE');
-        return;
+      break;
-      memmove(outbuf,outPtr, totalout);
-      outPtr = outbuf+totalout;
-    };
-};
-int play_track(char *path)
-{
-   DWORD fmt;
-   DWORD r_bytes;
-   int retval;
-   int err;
-//   int err;
-   retval = ST_DONE;
-   get_fileinfo(path, &fileinfo);
-   offset = 0;
-   err=read_file (path,testbuff,0,2048,&r_bytes);
-   if (err)
-     return ST_DONE;
-   init_reader(&rd,path);
-   fmt = test_wav((WAVEHEADER*)testbuff);
-   if (fmt != 0)
-   {
-     snd_play = &play_wave;
-     set_reader(&rd, 44);
+    memmove(outbuf,outPtr, totalout);
-     retval = ST_PLAY;
-   }
-   else
-   { fmt = test_mp3(testbuff);
-     if(fmt ==0)
-       return ST_DONE;
-     snd_play = &play_mp3;
-     outremain = 0x40000;
-     retval = ST_PLAY;
+    outPtr = outbuf+totalout;
-   };
+   }
-   SetFormat(hBuff, fmt);
-   return retval;
+    if(status != ST_EXIT)
-};
+      status =  ST_STOP;
 };
 void snd_stop()
+{
   StopBuffer(hBuff);
 };
+void _stdcall thread_proc(void *param)
+{  int evnt;
+   int pos;
+   int key;
+   DWORD offset;
-void do_ipc()
+  _asm
-{
+  {
-  IPC *incom;
-  incom = recieve_ipc();
-  switch(incom->code)
-  {
+    mov eax, 66
-    case 'PLAY':
+    mov ebx, 1
-      fname = incom->data;
+    mov ecx, 1
-      status = ST_TRACK;
+    int 0x40
-      return;
+  };
-    case 'STOP':
-      status = ST_STOP;
-      return;
+  draw_window();
+  while(1)
-    case 'EXIT':
+  {  if(status==ST_PLAY)
-      status = ST_EXIT;
+     {  draw_progress_bar();
+        evnt = wait_for_event(80);
-      exit();
+     }
-  };
+     else
+        evnt = wait_for_event_infinite();
-};
+    switch(evnt)
+    {
+      case EV_REDRAW:
-void _stdcall thread_proc(void *param)
+        draw_window();
+        break;
+      case EV_KEY:
+        if(!get_key(&key))
+        {
+          switch(key)
+          {  case 0xE0:
+             case 0xE1:
-{
+               break;
-   int err;
+             default:
+               switch (key)
+               {
+                 case 0x01:  //Esc
+                   status = ST_EXIT;
+                   exit();
-   if (err = CreateBuffer(PCM_ALL|PCM_OUT,0, &hBuff))
+                   break;
+                 case 0x47:  //Home
+                   if(l_vol < 0)
+                   { l_vol+=100;
+                     r_vol+=100;
+                     SetVolume(hBuff,l_vol,r_vol);
-   {
+                   };
+                   break;
-     debug_out_str("create buffer return error\n\r");
+                 case 0x4F:  //End
-     exit();
+                   if(l_vol > -10000)
+                   { l_vol-=100;
+                     r_vol-=100;
+                     SetVolume(hBuff,l_vol,r_vol);
+                   };
-   };
+                   break;
+                 case 0x53:
-   SetVolume(hBuff,l_vol,r_vol);
+                   if(pan > -10000)
+                   { pan -=100;
+                     SetPan(hBuff,pan);
-   GetVolume(hBuff,&l_vol,&r_vol);
+                   };
-//   debug_out_hex(l_vol);
+                   break;
+                 case 0x51:
+                   if(pan < 10000)
+                   { pan +=100;
+                     SetPan(hBuff,pan);
+                   };
-//   debug_out_str("\n\r");
+                   break;
+               }
+          };
-//   debug_out_hex(r_vol);
+        };
-//   debug_out_str("\n\r");
+        break;
+      case EV_BUTTON:
+        switch(get_button_id())
-   if(fname[0] !='/0')
+        {  case 1:
+             status = ST_EXIT;
-     status = play_track(fname);
+             exit();
+             break;
+           case 0x10:
+             status = ST_PLAY;
-   debug_out_str("\n\rPlay file ");
+             continue;
-   debug_out_str(fname);
-   debug_out_str("\n\r");
+           case 0x11:
-   snd_init = 1;
+             status = ST_STOP;
-   while(1)
-   {  delay(10);
+             break;
+//           case 0x12:
-      switch(status)
+//           case 0x13:
-      {
+           case 0x14:
-         case ST_TRACK:
+            if(l_vol > -10000)
-           strcpy(path, fname);
-           status = play_track(fname);
+            {
-           if( ipc_client & (status == ST_DONE))
+              l_vol-=100;
-           { send_ipc(ipc_client,'DONE');
+              r_vol-=100;
-             continue;
+              SetVolume(hBuff,l_vol,r_vol);
-           };
+            };
+            break;
-         case ST_PLAY:
+           case 0x15:
+            if(l_vol < 0)
-           snd_play();
+            { l_vol+=100;
-           continue;
+              r_vol+=100;
+              SetVolume(hBuff,l_vol,r_vol);
+            };
-         case ST_STOP:
+            break;
            StopBuffer(hBuff);
-           status = ST_DONE;
-           continue;
            case 0x30:
-         case ST_EXIT:
+            if(status==ST_DONE)
-           StopBuffer(hBuff);
+              break;
-           DestroyBuffer(hBuff);
+            pos = (GetMousePos(REL_WINDOW)>>16)-7;

Subversion Repositories Kolibri OS

(root)/programs/media/ac97snd/ac97snd/ac97wav.c @ 576 – Rev 576 → 577