diff options
author | Max Kellermann <max@duempel.org> | 2015-01-14 20:11:00 +0100 |
---|---|---|
committer | Max Kellermann <max@duempel.org> | 2015-01-14 20:11:00 +0100 |
commit | bf5963528045b65125fb379570f7c8a86a61ae5e (patch) | |
tree | f27b27d6902c18ce152fbb2703e567c7a04c759b /src/encoder/ToOutputStream.cxx | |
parent | 5d6f75aaef6f50b74fefa237927b4e93b649b1af (diff) | |
download | mpd-bf5963528045b65125fb379570f7c8a86a61ae5e.tar.gz mpd-bf5963528045b65125fb379570f7c8a86a61ae5e.tar.xz mpd-bf5963528045b65125fb379570f7c8a86a61ae5e.zip |
output/recorder: move code to encoder/ToOutputStream.cxx
Diffstat (limited to '')
-rw-r--r-- | src/encoder/ToOutputStream.cxx | 41 |
1 files changed, 41 insertions, 0 deletions
diff --git a/src/encoder/ToOutputStream.cxx b/src/encoder/ToOutputStream.cxx new file mode 100644 index 000000000..43345cf70 --- /dev/null +++ b/src/encoder/ToOutputStream.cxx @@ -0,0 +1,41 @@ +/* + * Copyright (C) 2003-2015 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 "ToOutputStream.hxx" +#include "EncoderInterface.hxx" +#include "fs/io/OutputStream.hxx" + +bool +EncoderToOutputStream(OutputStream &os, Encoder &encoder, Error &error) +{ + while (true) { + /* read from the encoder */ + + char buffer[32768]; + size_t nbytes = encoder_read(&encoder, buffer, sizeof(buffer)); + if (nbytes == 0) + return true; + + /* write everything to the stream */ + + if (!os.Write(buffer, nbytes, error)) + return false; + } +} |