Changeset 188 for winamp-musepack/trunk/winamp-musepack/mpc_player.cpp

Timestamp:

12/23/06 17:07:21 (17 years ago)

Author:

r2d

Message:

• removed file info bug
• improved thread reactivity

File:

• winamp-musepack/trunk/winamp-musepack/mpc_player.cpp (modified) (10 diffs)

winamp-musepack/trunk/winamp-musepack/mpc_player.cpp

@@ -9 +9 @@
 mpc_player::mpc_player(In_Module * in_mod)
 {
+        init(in_mod);
+}
+
+mpc_player::mpc_player(char * fn, In_Module * in_mod)
+{
+        init(in_mod);
+        openFile(fn);
+}
+
+mpc_player::~mpc_player(void)
+{
+        closeFile();
+}
+
+void mpc_player::init(In_Module * in_mod)
+{
         thread_handle=INVALID_HANDLE_VALUE;
         killDecodeThread=0;
@@ -14 +30 @@
         demux = 0;
         mod = in_mod;
-}
-
-mpc_player::~mpc_player(void)
+        wait_event = 0;
+}
+
+int mpc_player::openFile(char * fn)
 {
         closeFile();
-}
-
-int mpc_player::openFile(char * fn)
-{
-        mpc_status err;
-
-    err = mpc_reader_init_stdio(&reader, fn);
+
+    mpc_status err = mpc_reader_init_stdio(&reader, fn);
     if(err < 0) return 1;
 
@@ -35 +47 @@
 
     mpc_demux_get_info(demux,  &si);
+        strcpy(lastfn, fn);
         return 0;
 }
@@ -45 +58 @@
                 mpc_reader_exit_stdio(&reader);
         }
+}
+
+void mpc_player::setOutputTime(int time_in_ms)
+{
+        seek_offset = time_in_ms;
+        if (wait_event) SetEvent(wait_event);
 }
 
@@ -73 +92 @@
 {
         int done = 0;
+
+        wait_event = CreateEvent(0, FALSE, FALSE, 0);
 
         while (!killDecodeThread) 
@@ -92 +113 @@
                                 break;
                         }
-                        Sleep(10);              // give a little CPU time back to the system.
+                        WaitForSingleObject(wait_event, 100);           // give a little CPU time back to the system.
                 } else if (mod->outMod->CanWrite() >= (MPC_FRAME_LENGTH * sizeof(short) * si.channels)*(mod->dsp_isactive()?2:1)) {
                         // CanWrite() returns the number of bytes you can write, so we check that
@@ -105 +126 @@
 
                         if(frame.bits == -1) {
-                                done=1;
+                                done = 1;
                         } else {
                                 short output_buffer[MPC_FRAME_LENGTH * 2]; // default 2 channels
@@ -124 +145 @@
                                 mod->outMod->Write((char*)output_buffer, frame.samples * sizeof(short) * si.channels);
                         }
-                } else Sleep(20);
-        }
+                } else WaitForSingleObject(wait_event, 1000);
+        }
+
+        CloseHandle(wait_event);
+        wait_event = 0;
+
         return 0;
 }
 
-void mpc_player::getFileInfo(char *filename, char *title, int *length_in_ms)
-{
-        if (!filename || !*filename) {
-                if (length_in_ms) *length_in_ms = getLength();
-                if (title) {
-                        char *p = lastfn + strlen(lastfn);
-                        while (*p != '\\' && p >= lastfn) p--;
-                        strcpy(title,++p);
-                }
-        } else {
-                if (length_in_ms) {
-                        if (openFile(filename) == 0) {
-                                closeFile();
-                                *length_in_ms = getLength();
-                        } else {
-                                *length_in_ms = -1000; // the default is unknown file length (-1000).
-                        }
-                }
-                if (title) {
-                        char *p = filename + strlen(filename);
-                        while (*p != '\\' && p >= filename) p--;
-                        strcpy(title,++p);
-                }
+void mpc_player::getFileInfo(char *title, int *length_in_ms)
+{
+        if (length_in_ms) *length_in_ms = getLength();
+        if (title) {
+                char *p = lastfn + strlen(lastfn);
+                while (*p != '\\' && p >= lastfn) p--;
+                strcpy(title,++p);
         }
 }
@@ -158 +167 @@
 void mpc_player::stop(void)
 { 
-        if (thread_handle != INVALID_HANDLE_VALUE)
-        {
-                killDecodeThread=1;
-                if (WaitForSingleObject(thread_handle,10000) == WAIT_TIMEOUT)
-                {
+        if (thread_handle != INVALID_HANDLE_VALUE) {
+                killDecodeThread = 1;
+                if (wait_event) SetEvent(wait_event);
+                if (WaitForSingleObject(thread_handle,10000) == WAIT_TIMEOUT) {
                         MessageBox(mod->hMainWindow,"error asking thread to die!\n",
-                                "error killing decode thread",0);
-                        TerminateThread(thread_handle,0);
+                                "error killing decode thread", 0);
+                        TerminateThread(thread_handle, 0);
                 }
                 CloseHandle(thread_handle);
@@ -189 +197 @@
 
         if (openFile(fn) != 0) return 1;
-        
-        strcpy(lastfn,fn);
 
         // -1 and -1 are to specify buffer and prebuffer lengths.