diff options
Diffstat (limited to 'gio/src/socket.ccg')
| -rw-r--r-- | gio/src/socket.ccg | 60 |
1 files changed, 33 insertions, 27 deletions
diff --git a/gio/src/socket.ccg b/gio/src/socket.ccg index a7e0ff69..6dfd71ee 100644 --- a/gio/src/socket.ccg +++ b/gio/src/socket.ccg @@ -27,86 +27,92 @@ namespace Gio { Socket::Socket(SocketFamily family, SocketType type, SocketProtocol protocol, - const Glib::RefPtr<Cancellable>& cancellable) -: - _CONSTRUCT("family", int(family), "type", int(type), "protocol", int(protocol)) + const Glib::RefPtr<Cancellable>& cancellable) +: _CONSTRUCT("family", int(family), "type", int(type), "protocol", int(protocol)) { init(cancellable); } -Socket::Socket(int fd, const Glib::RefPtr<Cancellable>& cancellable) -: - _CONSTRUCT("fd", fd) +Socket::Socket(int fd, const Glib::RefPtr<Cancellable>& cancellable) : _CONSTRUCT("fd", fd) { init(cancellable); } // static -Glib::RefPtr<Socket> Socket::create(SocketFamily family, SocketType type, SocketProtocol protocol, - const Glib::RefPtr<Cancellable>& cancellable) +Glib::RefPtr<Socket> +Socket::create(SocketFamily family, SocketType type, SocketProtocol protocol, + const Glib::RefPtr<Cancellable>& cancellable) { return Glib::RefPtr<Socket>(new Socket(family, type, protocol, cancellable)); } // static -Glib::RefPtr<Socket> Socket::create_from_fd(int fd, const Glib::RefPtr<Cancellable>& cancellable) +Glib::RefPtr<Socket> +Socket::create_from_fd(int fd, const Glib::RefPtr<Cancellable>& cancellable) { return Glib::RefPtr<Socket>(new Socket(fd, cancellable)); } -gssize Socket::receive_from(Glib::RefPtr<SocketAddress>& address, char* buffer, gsize size, const Glib::RefPtr<Cancellable>& cancellable) +gssize +Socket::receive_from(Glib::RefPtr<SocketAddress>& address, char* buffer, gsize size, + const Glib::RefPtr<Cancellable>& cancellable) { GError* gerror = nullptr; GSocketAddress* caddr = nullptr; - auto retvalue = g_socket_receive_from(gobj(), &caddr, buffer, size, const_cast<GCancellable*>(Glib::unwrap(cancellable)), &(gerror)); - if(gerror) + auto retvalue = g_socket_receive_from( + gobj(), &caddr, buffer, size, const_cast<GCancellable*>(Glib::unwrap(cancellable)), &(gerror)); + if (gerror) ::Glib::Error::throw_exception(gerror); if (caddr) - address = Glib::wrap (caddr); + address = Glib::wrap(caddr); return retvalue; } -gssize Socket::receive_from(Glib::RefPtr<SocketAddress>& address, char* buffer, gsize size) +gssize +Socket::receive_from(Glib::RefPtr<SocketAddress>& address, char* buffer, gsize size) { GError* gerror = nullptr; GSocketAddress* caddr = nullptr; auto retvalue = g_socket_receive_from(gobj(), &caddr, buffer, size, nullptr, &(gerror)); - if(gerror) + if (gerror) ::Glib::Error::throw_exception(gerror); if (caddr) - address = Glib::wrap (caddr); + address = Glib::wrap(caddr); return retvalue; } -gssize Socket::receive_with_blocking(gchar* buffer, gsize size, bool blocking, - const Glib::RefPtr<Cancellable>& cancellable) +gssize +Socket::receive_with_blocking( + gchar* buffer, gsize size, bool blocking, const Glib::RefPtr<Cancellable>& cancellable) { GError* gerror = nullptr; - const auto retvalue = g_socket_receive_with_blocking(gobj(), buffer, size, - blocking, Glib::unwrap(cancellable), &(gerror)); - if(gerror) + const auto retvalue = g_socket_receive_with_blocking( + gobj(), buffer, size, blocking, Glib::unwrap(cancellable), &(gerror)); + if (gerror) ::Glib::Error::throw_exception(gerror); return retvalue; } -gssize Socket::send_with_blocking(gchar* buffer, gsize size, bool blocking, - const Glib::RefPtr<Cancellable>& cancellable) +gssize +Socket::send_with_blocking( + gchar* buffer, gsize size, bool blocking, const Glib::RefPtr<Cancellable>& cancellable) { GError* gerror = nullptr; - const auto retvalue = g_socket_send_with_blocking(gobj(), buffer, size, - blocking, Glib::unwrap(cancellable), &(gerror)); - if(gerror) + const auto retvalue = g_socket_send_with_blocking( + gobj(), buffer, size, blocking, Glib::unwrap(cancellable), &(gerror)); + if (gerror) ::Glib::Error::throw_exception(gerror); return retvalue; } -Glib::RefPtr<SocketSource> Socket::create_source(Glib::IOCondition condition, const Glib::RefPtr<Cancellable>& cancellable) +Glib::RefPtr<SocketSource> +Socket::create_source(Glib::IOCondition condition, const Glib::RefPtr<Cancellable>& cancellable) { // The corresponding unreference() takes place in the dtor // of the Glib::RefPtr<Socket> object below. |