273 lines
8.4 KiB
Plaintext
273 lines
8.4 KiB
Plaintext
|
// -*- Mode: C++; indent-tabs-mode: nil; c-basic-offset: 2 -*-
|
||
|
|
||
|
/* Copyright (C) 2007 The gtkmm Development Team
|
||
|
*
|
||
|
* This library is free software; you can redistribute it and/or
|
||
|
* modify it under the terms of the GNU Library General Public
|
||
|
* License as published by the Free Software Foundation; either
|
||
|
* version 2 of the License, or (at your option) any later version.
|
||
|
*
|
||
|
* This library 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
|
||
|
* Library General Public License for more details.
|
||
|
*
|
||
|
* You should have received a copy of the GNU Library General Public
|
||
|
* License along with this library; if not, write to the Free
|
||
|
* Software Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
|
||
|
*/
|
||
|
|
||
|
#include <gio/gio.h>
|
||
|
#include "slot_async.h"
|
||
|
|
||
|
namespace Gio
|
||
|
{
|
||
|
|
||
|
#ifdef GLIBMM_EXCEPTIONS_ENABLED
|
||
|
guchar DataInputStream::read_byte()
|
||
|
#else
|
||
|
guchar DataInputStream::read_byte(std::auto_ptr<Glib::Error>& error)
|
||
|
#endif //GLIBMM_EXCEPTIONS_ENABLED
|
||
|
{
|
||
|
GError* gerror = 0;
|
||
|
guchar retvalue = g_data_input_stream_read_byte(gobj(), NULL, &(gerror));
|
||
|
#ifdef GLIBMM_EXCEPTIONS_ENABLED
|
||
|
if(gerror)
|
||
|
::Glib::Error::throw_exception(gerror);
|
||
|
#else
|
||
|
if(gerror)
|
||
|
error = ::Glib::Error::throw_exception(gerror);
|
||
|
#endif //GLIBMM_EXCEPTIONS_ENABLED
|
||
|
|
||
|
return retvalue;
|
||
|
}
|
||
|
|
||
|
#ifdef GLIBMM_EXCEPTIONS_ENABLED
|
||
|
gint16 DataInputStream::read_int16()
|
||
|
#else
|
||
|
gint16 DataInputStream::read_int16(std::auto_ptr<Glib::Error>& error)
|
||
|
#endif //GLIBMM_EXCEPTIONS_ENABLED
|
||
|
{
|
||
|
GError* gerror = 0;
|
||
|
gint16 retvalue = g_data_input_stream_read_int16(gobj(), NULL, &(gerror));
|
||
|
#ifdef GLIBMM_EXCEPTIONS_ENABLED
|
||
|
if(gerror)
|
||
|
::Glib::Error::throw_exception(gerror);
|
||
|
#else
|
||
|
if(gerror)
|
||
|
error = ::Glib::Error::throw_exception(gerror);
|
||
|
#endif //GLIBMM_EXCEPTIONS_ENABLED
|
||
|
|
||
|
return retvalue;
|
||
|
}
|
||
|
|
||
|
#ifdef GLIBMM_EXCEPTIONS_ENABLED
|
||
|
guint16 DataInputStream::read_uint16()
|
||
|
#else
|
||
|
guint16 DataInputStream::read_uint16(std::auto_ptr<Glib::Error>& error)
|
||
|
#endif //GLIBMM_EXCEPTIONS_ENABLED
|
||
|
{
|
||
|
GError* gerror = 0;
|
||
|
guint16 retvalue = g_data_input_stream_read_uint16(gobj(), NULL, &(gerror));
|
||
|
#ifdef GLIBMM_EXCEPTIONS_ENABLED
|
||
|
if(gerror)
|
||
|
::Glib::Error::throw_exception(gerror);
|
||
|
#else
|
||
|
if(gerror)
|
||
|
error = ::Glib::Error::throw_exception(gerror);
|
||
|
#endif //GLIBMM_EXCEPTIONS_ENABLED
|
||
|
|
||
|
return retvalue;
|
||
|
}
|
||
|
|
||
|
#ifdef GLIBMM_EXCEPTIONS_ENABLED
|
||
|
gint32 DataInputStream::read_int32()
|
||
|
#else
|
||
|
gint32 DataInputStream::read_int32(std::auto_ptr<Glib::Error>& error)
|
||
|
#endif //GLIBMM_EXCEPTIONS_ENABLED
|
||
|
{
|
||
|
GError* gerror = 0;
|
||
|
gint32 retvalue = g_data_input_stream_read_int32(gobj(), NULL, &(gerror));
|
||
|
#ifdef GLIBMM_EXCEPTIONS_ENABLED
|
||
|
if(gerror)
|
||
|
::Glib::Error::throw_exception(gerror);
|
||
|
#else
|
||
|
if(gerror)
|
||
|
error = ::Glib::Error::throw_exception(gerror);
|
||
|
#endif //GLIBMM_EXCEPTIONS_ENABLED
|
||
|
|
||
|
return retvalue;
|
||
|
}
|
||
|
|
||
|
#ifdef GLIBMM_EXCEPTIONS_ENABLED
|
||
|
guint32 DataInputStream::read_uint32()
|
||
|
#else
|
||
|
guint32 DataInputStream::read_uint32(std::auto_ptr<Glib::Error>& error)
|
||
|
#endif //GLIBMM_EXCEPTIONS_ENABLED
|
||
|
{
|
||
|
GError* gerror = 0;
|
||
|
guint32 retvalue = g_data_input_stream_read_uint32(gobj(), NULL, &(gerror));
|
||
|
#ifdef GLIBMM_EXCEPTIONS_ENABLED
|
||
|
if(gerror)
|
||
|
::Glib::Error::throw_exception(gerror);
|
||
|
#else
|
||
|
if(gerror)
|
||
|
error = ::Glib::Error::throw_exception(gerror);
|
||
|
#endif //GLIBMM_EXCEPTIONS_ENABLED
|
||
|
|
||
|
return retvalue;
|
||
|
}
|
||
|
|
||
|
#ifdef GLIBMM_EXCEPTIONS_ENABLED
|
||
|
gint64 DataInputStream::read_int64()
|
||
|
#else
|
||
|
gint64 DataInputStream::read_int64(std::auto_ptr<Glib::Error>& error)
|
||
|
#endif //GLIBMM_EXCEPTIONS_ENABLED
|
||
|
{
|
||
|
GError* gerror = 0;
|
||
|
gint64 retvalue = g_data_input_stream_read_int64(gobj(), NULL, &(gerror));
|
||
|
#ifdef GLIBMM_EXCEPTIONS_ENABLED
|
||
|
if(gerror)
|
||
|
::Glib::Error::throw_exception(gerror);
|
||
|
#else
|
||
|
if(gerror)
|
||
|
error = ::Glib::Error::throw_exception(gerror);
|
||
|
#endif //GLIBMM_EXCEPTIONS_ENABLED
|
||
|
|
||
|
return retvalue;
|
||
|
}
|
||
|
|
||
|
#ifdef GLIBMM_EXCEPTIONS_ENABLED
|
||
|
guint64 DataInputStream::read_uint64()
|
||
|
#else
|
||
|
guint64 DataInputStream::read_uint64(std::auto_ptr<Glib::Error>& error)
|
||
|
#endif //GLIBMM_EXCEPTIONS_ENABLED
|
||
|
{
|
||
|
GError* gerror = 0;
|
||
|
guint64 retvalue = g_data_input_stream_read_uint64(gobj(), NULL, &(gerror));
|
||
|
#ifdef GLIBMM_EXCEPTIONS_ENABLED
|
||
|
if(gerror)
|
||
|
::Glib::Error::throw_exception(gerror);
|
||
|
#else
|
||
|
if(gerror)
|
||
|
error = ::Glib::Error::throw_exception(gerror);
|
||
|
#endif //GLIBMM_EXCEPTIONS_ENABLED
|
||
|
|
||
|
return retvalue;
|
||
|
}
|
||
|
|
||
|
#ifdef GLIBMM_EXCEPTIONS_ENABLED
|
||
|
bool DataInputStream::read_line(std::string& line, const Glib::RefPtr<Cancellable>& cancellable)
|
||
|
#else
|
||
|
bool DataInputStream::read_line(std::string& line, const Glib::RefPtr<Cancellable>& cancellable, std::auto_ptr<Glib::Error>& error)
|
||
|
#endif //GLIBMM_EXCEPTIONS_ENABLED
|
||
|
{
|
||
|
GError* gerror = 0;
|
||
|
char* c_line = g_data_input_stream_read_line(gobj(),
|
||
|
NULL, // pass NULL since we can easily determine the length from the returned std::string
|
||
|
cancellable->gobj(),
|
||
|
&gerror);
|
||
|
#ifdef GLIBMM_EXCEPTIONS_ENABLED
|
||
|
if(gerror)
|
||
|
::Glib::Error::throw_exception(gerror);
|
||
|
#else
|
||
|
if(gerror)
|
||
|
error = ::Glib::Error::throw_exception(gerror);
|
||
|
#endif //GLIBMM_EXCEPTIONS_ENABLED
|
||
|
if (c_line) {
|
||
|
line = c_line;
|
||
|
g_free (c_line);
|
||
|
return true;
|
||
|
}
|
||
|
// end of stream reached, return failure status
|
||
|
return false;
|
||
|
}
|
||
|
|
||
|
#ifdef GLIBMM_EXCEPTIONS_ENABLED
|
||
|
bool DataInputStream::read_line(std::string& line)
|
||
|
#else
|
||
|
bool DataInputStream::read_line(std::string& line, std::auto_ptr<Glib::Error>& error)
|
||
|
#endif //GLIBMM_EXCEPTIONS_ENABLED
|
||
|
{
|
||
|
GError* gerror = 0;
|
||
|
char* c_line = g_data_input_stream_read_line(gobj(),
|
||
|
NULL, // pass NULL since we can easily determine the length from the returned std::string
|
||
|
NULL,
|
||
|
&gerror);
|
||
|
#ifdef GLIBMM_EXCEPTIONS_ENABLED
|
||
|
if(gerror)
|
||
|
::Glib::Error::throw_exception(gerror);
|
||
|
#else
|
||
|
if(gerror)
|
||
|
error = ::Glib::Error::throw_exception(gerror);
|
||
|
#endif //GLIBMM_EXCEPTIONS_ENABLED
|
||
|
if (c_line) {
|
||
|
line = c_line;
|
||
|
g_free(c_line);
|
||
|
return true;
|
||
|
}
|
||
|
// end of stream reached, return failure status
|
||
|
return false;
|
||
|
}
|
||
|
|
||
|
|
||
|
#ifdef GLIBMM_EXCEPTIONS_ENABLED
|
||
|
bool DataInputStream::read_until(std::string& data, const std::string& stop_chars, const Glib::RefPtr<Cancellable>& cancellable)
|
||
|
#else
|
||
|
bool DataInputStream::read_until(std::string& data, const std::string& stop_chars, const Glib::RefPtr<Cancellable>& cancellable, std::auto_ptr<Glib::Error>& error)
|
||
|
#endif //GLIBMM_EXCEPTIONS_ENABLED
|
||
|
{
|
||
|
GError* gerror = 0;
|
||
|
char* c_str = g_data_input_stream_read_until(gobj(),
|
||
|
stop_chars.c_str(),
|
||
|
NULL, // pass NULL since we can easily determine the length from the returned std::string
|
||
|
cancellable->gobj(),
|
||
|
&gerror);
|
||
|
#ifdef GLIBMM_EXCEPTIONS_ENABLED
|
||
|
if(gerror)
|
||
|
::Glib::Error::throw_exception(gerror);
|
||
|
#else
|
||
|
if(gerror)
|
||
|
error = ::Glib::Error::throw_exception(gerror);
|
||
|
#endif //GLIBMM_EXCEPTIONS_ENABLED
|
||
|
if (c_str) {
|
||
|
data = c_str;
|
||
|
g_free (c_str);
|
||
|
return true;
|
||
|
}
|
||
|
// end of stream reached, return failure status
|
||
|
return false;
|
||
|
}
|
||
|
|
||
|
/** non-cancellable version of read_until()
|
||
|
*/
|
||
|
#ifdef GLIBMM_EXCEPTIONS_ENABLED
|
||
|
bool DataInputStream::read_until(std::string& data, const std::string& stop_chars)
|
||
|
#else
|
||
|
bool DataInputStream::read_until(std::string& data, const std::string& stop_chars, std::auto_ptr<Glib::Error>& error)
|
||
|
#endif //GLIBMM_EXCEPTIONS_ENABLED
|
||
|
{
|
||
|
GError* gerror = 0;
|
||
|
char* c_str = g_data_input_stream_read_until(gobj(),
|
||
|
stop_chars.c_str(),
|
||
|
NULL, // pass NULL since we can easily determine the length from the returned std::string
|
||
|
NULL,
|
||
|
&gerror);
|
||
|
#ifdef GLIBMM_EXCEPTIONS_ENABLED
|
||
|
if(gerror)
|
||
|
::Glib::Error::throw_exception(gerror);
|
||
|
#else
|
||
|
if(gerror)
|
||
|
error = ::Glib::Error::throw_exception(gerror);
|
||
|
#endif //GLIBMM_EXCEPTIONS_ENABLED
|
||
|
if (c_str) {
|
||
|
data = c_str;
|
||
|
g_free (c_str);
|
||
|
return true;
|
||
|
}
|
||
|
// end of stream reached, return failure status
|
||
|
return false;
|
||
|
}
|
||
|
|
||
|
} // namespace Gio
|