Compare commits
4 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
8bfdb4ed0c | ||
|
|
70bd35abe2 | ||
|
|
0efb67b51e | ||
|
|
54ebf2a699 |
5
NEWS
5
NEWS
@@ -1,3 +1,8 @@
|
|||||||
|
ver 0.18.11 (2014/05/12)
|
||||||
|
* decoder
|
||||||
|
- opus: fix missing song length on high-latency files
|
||||||
|
* fix race condition when using GLib event loop (non-Linux)
|
||||||
|
|
||||||
ver 0.18.10 (2014/04/10)
|
ver 0.18.10 (2014/04/10)
|
||||||
* decoder
|
* decoder
|
||||||
- ffmpeg: fix seeking bug
|
- ffmpeg: fix seeking bug
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
AC_PREREQ(2.60)
|
AC_PREREQ(2.60)
|
||||||
|
|
||||||
AC_INIT(mpd, 0.18.10, mpd-devel@musicpd.org)
|
AC_INIT(mpd, 0.18.11, mpd-devel@musicpd.org)
|
||||||
|
|
||||||
VERSION_MAJOR=0
|
VERSION_MAJOR=0
|
||||||
VERSION_MINOR=18
|
VERSION_MINOR=18
|
||||||
|
|||||||
@@ -81,7 +81,7 @@ bool
|
|||||||
OggExpectPageSeek(ogg_sync_state &oy, ogg_page &page,
|
OggExpectPageSeek(ogg_sync_state &oy, ogg_page &page,
|
||||||
Decoder *decoder, InputStream &input_stream)
|
Decoder *decoder, InputStream &input_stream)
|
||||||
{
|
{
|
||||||
size_t remaining_skipped = 16384;
|
size_t remaining_skipped = 32768;
|
||||||
|
|
||||||
while (true) {
|
while (true) {
|
||||||
int r = ogg_sync_pageseek(&oy, &page);
|
int r = ogg_sync_pageseek(&oy, &page);
|
||||||
|
|||||||
@@ -27,9 +27,11 @@ DeferredMonitor::Cancel()
|
|||||||
#ifdef USE_EPOLL
|
#ifdef USE_EPOLL
|
||||||
pending = false;
|
pending = false;
|
||||||
#else
|
#else
|
||||||
const auto id = source_id.exchange(0);
|
const ScopeLock protect(mutex);
|
||||||
if (id != 0)
|
if (source_id != 0) {
|
||||||
g_source_remove(id);
|
g_source_remove(source_id);
|
||||||
|
source_id = 0;
|
||||||
|
}
|
||||||
#endif
|
#endif
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -40,10 +42,9 @@ DeferredMonitor::Schedule()
|
|||||||
if (!pending.exchange(true))
|
if (!pending.exchange(true))
|
||||||
fd.Write();
|
fd.Write();
|
||||||
#else
|
#else
|
||||||
const unsigned id = loop.AddIdle(Callback, this);
|
const ScopeLock protect(mutex);
|
||||||
const auto old_id = source_id.exchange(id);
|
if (source_id == 0)
|
||||||
if (old_id != 0)
|
source_id = loop.AddIdle(Callback, this);
|
||||||
g_source_remove(old_id);
|
|
||||||
#endif
|
#endif
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -65,9 +66,16 @@ DeferredMonitor::OnSocketReady(unsigned)
|
|||||||
void
|
void
|
||||||
DeferredMonitor::Run()
|
DeferredMonitor::Run()
|
||||||
{
|
{
|
||||||
const auto id = source_id.exchange(0);
|
{
|
||||||
if (id != 0)
|
const ScopeLock protect(mutex);
|
||||||
RunDeferred();
|
if (source_id == 0)
|
||||||
|
/* cancelled */
|
||||||
|
return;
|
||||||
|
|
||||||
|
source_id = 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
RunDeferred();
|
||||||
}
|
}
|
||||||
|
|
||||||
gboolean
|
gboolean
|
||||||
|
|||||||
@@ -27,6 +27,7 @@
|
|||||||
#include "SocketMonitor.hxx"
|
#include "SocketMonitor.hxx"
|
||||||
#include "WakeFD.hxx"
|
#include "WakeFD.hxx"
|
||||||
#else
|
#else
|
||||||
|
#include "thread/Mutex.hxx"
|
||||||
#include <glib.h>
|
#include <glib.h>
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
@@ -48,7 +49,9 @@ class DeferredMonitor
|
|||||||
#else
|
#else
|
||||||
EventLoop &loop;
|
EventLoop &loop;
|
||||||
|
|
||||||
std::atomic<guint> source_id;
|
Mutex mutex;
|
||||||
|
|
||||||
|
guint source_id;
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
public:
|
public:
|
||||||
|
|||||||
Reference in New Issue
Block a user