diff options
author | Max Kellermann <max@duempel.org> | 2014-01-24 00:02:24 +0100 |
---|---|---|
committer | Max Kellermann <max@duempel.org> | 2014-01-24 00:02:24 +0100 |
commit | 51adaf2c47761e3f2095a52a7037cd8458b77990 (patch) | |
tree | 46d78d52708a1f75460908187a239cc5c60d1858 /src/decoder/plugins/OggFind.cxx | |
parent | ea5b901bcce20949a8d1fd622a7b03ff6f56ae20 (diff) | |
download | mpd-51adaf2c47761e3f2095a52a7037cd8458b77990.tar.gz mpd-51adaf2c47761e3f2095a52a7037cd8458b77990.tar.xz mpd-51adaf2c47761e3f2095a52a7037cd8458b77990.zip |
decoder/*: move to decoder/plugins/
Diffstat (limited to 'src/decoder/plugins/OggFind.cxx')
-rw-r--r-- | src/decoder/plugins/OggFind.cxx | 68 |
1 files changed, 68 insertions, 0 deletions
diff --git a/src/decoder/plugins/OggFind.cxx b/src/decoder/plugins/OggFind.cxx new file mode 100644 index 000000000..df4318da2 --- /dev/null +++ b/src/decoder/plugins/OggFind.cxx @@ -0,0 +1,68 @@ +/* + * Copyright (C) 2003-2014 The Music Player Daemon Project + * http://www.musicpd.org + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation; either version 2 of the License, or + * (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License along + * with this program; if not, write to the Free Software Foundation, Inc., + * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. + */ + +#include "config.h" +#include "OggFind.hxx" +#include "OggSyncState.hxx" +#include "util/Error.hxx" + +#include <stdio.h> + +bool +OggFindEOS(OggSyncState &oy, ogg_stream_state &os, ogg_packet &packet) +{ + while (true) { + int r = ogg_stream_packetout(&os, &packet); + if (r == 0) { + if (!oy.ExpectPageIn(os)) + return false; + + continue; + } else if (r > 0 && packet.e_o_s) + return true; + } +} + +bool +OggSeekPageAtOffset(OggSyncState &oy, ogg_stream_state &os, InputStream &is, + InputStream::offset_type offset, int whence) +{ + oy.Reset(); + + /* reset the stream to clear any previous partial packet + data */ + ogg_stream_reset(&os); + + return is.LockSeek(offset, whence, IgnoreError()) && + oy.ExpectPageSeekIn(os); +} + +bool +OggSeekFindEOS(OggSyncState &oy, ogg_stream_state &os, ogg_packet &packet, + InputStream &is) +{ + if (is.size > 0 && is.size - is.offset < 65536) + return OggFindEOS(oy, os, packet); + + if (!is.CheapSeeking()) + return false; + + return OggSeekPageAtOffset(oy, os, is, -65536, SEEK_END) && + OggFindEOS(oy, os, packet); +} |