|
Packit Service |
d3d246 |
/* GIO - GLib Input, Output and Streaming Library
|
|
Packit Service |
d3d246 |
*
|
|
Packit Service |
d3d246 |
* Copyright (C) 2010 Red Hat, Inc.
|
|
Packit Service |
d3d246 |
*
|
|
Packit Service |
d3d246 |
* This library is free software; you can redistribute it and/or
|
|
Packit Service |
d3d246 |
* modify it under the terms of the GNU Lesser General Public
|
|
Packit Service |
d3d246 |
* License as published by the Free Software Foundation; either
|
|
Packit Service |
d3d246 |
* version 2.1 of the License, or (at your option) any later version.
|
|
Packit Service |
d3d246 |
*
|
|
Packit Service |
d3d246 |
* This library is distributed in the hope that it will be useful,
|
|
Packit Service |
d3d246 |
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
Packit Service |
d3d246 |
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
Packit Service |
d3d246 |
* Lesser General Public License for more details.
|
|
Packit Service |
d3d246 |
*
|
|
Packit Service |
d3d246 |
* You should have received a copy of the GNU Lesser General
|
|
Packit Service |
d3d246 |
* Public License along with this library; if not, see <http://www.gnu.org/licenses/>.
|
|
Packit Service |
d3d246 |
*/
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
#include "config.h"
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
#include <errno.h>
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
#include "gpollableoutputstream.h"
|
|
Packit Service |
d3d246 |
#include "gasynchelper.h"
|
|
Packit Service |
d3d246 |
#include "gfiledescriptorbased.h"
|
|
Packit Service |
d3d246 |
#include "glibintl.h"
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
/**
|
|
Packit Service |
d3d246 |
* SECTION:gpollableoutputstream
|
|
Packit Service |
d3d246 |
* @short_description: Interface for pollable output streams
|
|
Packit Service |
d3d246 |
* @include: gio/gio.h
|
|
Packit Service |
d3d246 |
* @see_also: #GOutputStream, #GFileDescriptorBased, #GPollableInputStream
|
|
Packit Service |
d3d246 |
*
|
|
Packit Service |
d3d246 |
* #GPollableOutputStream is implemented by #GOutputStreams that
|
|
Packit Service |
d3d246 |
* can be polled for readiness to write. This can be used when
|
|
Packit Service |
d3d246 |
* interfacing with a non-GIO API that expects
|
|
Packit Service |
d3d246 |
* UNIX-file-descriptor-style asynchronous I/O rather than GIO-style.
|
|
Packit Service |
d3d246 |
*
|
|
Packit Service |
d3d246 |
* Since: 2.28
|
|
Packit Service |
d3d246 |
*/
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
G_DEFINE_INTERFACE (GPollableOutputStream, g_pollable_output_stream, G_TYPE_OUTPUT_STREAM)
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
static gboolean g_pollable_output_stream_default_can_poll (GPollableOutputStream *stream);
|
|
Packit Service |
d3d246 |
static gssize g_pollable_output_stream_default_write_nonblocking (GPollableOutputStream *stream,
|
|
Packit Service |
d3d246 |
const void *buffer,
|
|
Packit Service |
d3d246 |
gsize count,
|
|
Packit Service |
d3d246 |
GError **error);
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
static void
|
|
Packit Service |
d3d246 |
g_pollable_output_stream_default_init (GPollableOutputStreamInterface *iface)
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
iface->can_poll = g_pollable_output_stream_default_can_poll;
|
|
Packit Service |
d3d246 |
iface->write_nonblocking = g_pollable_output_stream_default_write_nonblocking;
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
static gboolean
|
|
Packit Service |
d3d246 |
g_pollable_output_stream_default_can_poll (GPollableOutputStream *stream)
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
return TRUE;
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
/**
|
|
Packit Service |
d3d246 |
* g_pollable_output_stream_can_poll:
|
|
Packit Service |
d3d246 |
* @stream: a #GPollableOutputStream.
|
|
Packit Service |
d3d246 |
*
|
|
Packit Service |
d3d246 |
* Checks if @stream is actually pollable. Some classes may implement
|
|
Packit Service |
d3d246 |
* #GPollableOutputStream but have only certain instances of that
|
|
Packit Service |
d3d246 |
* class be pollable. If this method returns %FALSE, then the behavior
|
|
Packit Service |
d3d246 |
* of other #GPollableOutputStream methods is undefined.
|
|
Packit Service |
d3d246 |
*
|
|
Packit Service |
d3d246 |
* For any given stream, the value returned by this method is constant;
|
|
Packit Service |
d3d246 |
* a stream cannot switch from pollable to non-pollable or vice versa.
|
|
Packit Service |
d3d246 |
*
|
|
Packit Service |
d3d246 |
* Returns: %TRUE if @stream is pollable, %FALSE if not.
|
|
Packit Service |
d3d246 |
*
|
|
Packit Service |
d3d246 |
* Since: 2.28
|
|
Packit Service |
d3d246 |
*/
|
|
Packit Service |
d3d246 |
gboolean
|
|
Packit Service |
d3d246 |
g_pollable_output_stream_can_poll (GPollableOutputStream *stream)
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
g_return_val_if_fail (G_IS_POLLABLE_OUTPUT_STREAM (stream), FALSE);
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
return G_POLLABLE_OUTPUT_STREAM_GET_INTERFACE (stream)->can_poll (stream);
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
/**
|
|
Packit Service |
d3d246 |
* g_pollable_output_stream_is_writable:
|
|
Packit Service |
d3d246 |
* @stream: a #GPollableOutputStream.
|
|
Packit Service |
d3d246 |
*
|
|
Packit Service |
d3d246 |
* Checks if @stream can be written.
|
|
Packit Service |
d3d246 |
*
|
|
Packit Service |
d3d246 |
* Note that some stream types may not be able to implement this 100%
|
|
Packit Service |
d3d246 |
* reliably, and it is possible that a call to g_output_stream_write()
|
|
Packit Service |
d3d246 |
* after this returns %TRUE would still block. To guarantee
|
|
Packit Service |
d3d246 |
* non-blocking behavior, you should always use
|
|
Packit Service |
d3d246 |
* g_pollable_output_stream_write_nonblocking(), which will return a
|
|
Packit Service |
d3d246 |
* %G_IO_ERROR_WOULD_BLOCK error rather than blocking.
|
|
Packit Service |
d3d246 |
*
|
|
Packit Service |
d3d246 |
* Returns: %TRUE if @stream is writable, %FALSE if not. If an error
|
|
Packit Service |
d3d246 |
* has occurred on @stream, this will result in
|
|
Packit Service |
d3d246 |
* g_pollable_output_stream_is_writable() returning %TRUE, and the
|
|
Packit Service |
d3d246 |
* next attempt to write will return the error.
|
|
Packit Service |
d3d246 |
*
|
|
Packit Service |
d3d246 |
* Since: 2.28
|
|
Packit Service |
d3d246 |
*/
|
|
Packit Service |
d3d246 |
gboolean
|
|
Packit Service |
d3d246 |
g_pollable_output_stream_is_writable (GPollableOutputStream *stream)
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
g_return_val_if_fail (G_IS_POLLABLE_OUTPUT_STREAM (stream), FALSE);
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
return G_POLLABLE_OUTPUT_STREAM_GET_INTERFACE (stream)->is_writable (stream);
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
/**
|
|
Packit Service |
d3d246 |
* g_pollable_output_stream_create_source:
|
|
Packit Service |
d3d246 |
* @stream: a #GPollableOutputStream.
|
|
Packit Service |
d3d246 |
* @cancellable: (nullable): a #GCancellable, or %NULL
|
|
Packit Service |
d3d246 |
*
|
|
Packit Service |
d3d246 |
* Creates a #GSource that triggers when @stream can be written, or
|
|
Packit Service |
d3d246 |
* @cancellable is triggered or an error occurs. The callback on the
|
|
Packit Service |
d3d246 |
* source is of the #GPollableSourceFunc type.
|
|
Packit Service |
d3d246 |
*
|
|
Packit Service |
d3d246 |
* As with g_pollable_output_stream_is_writable(), it is possible that
|
|
Packit Service |
d3d246 |
* the stream may not actually be writable even after the source
|
|
Packit Service |
d3d246 |
* triggers, so you should use g_pollable_output_stream_write_nonblocking()
|
|
Packit Service |
d3d246 |
* rather than g_output_stream_write() from the callback.
|
|
Packit Service |
d3d246 |
*
|
|
Packit Service |
d3d246 |
* Returns: (transfer full): a new #GSource
|
|
Packit Service |
d3d246 |
*
|
|
Packit Service |
d3d246 |
* Since: 2.28
|
|
Packit Service |
d3d246 |
*/
|
|
Packit Service |
d3d246 |
GSource *
|
|
Packit Service |
d3d246 |
g_pollable_output_stream_create_source (GPollableOutputStream *stream,
|
|
Packit Service |
d3d246 |
GCancellable *cancellable)
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
g_return_val_if_fail (G_IS_POLLABLE_OUTPUT_STREAM (stream), NULL);
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
return G_POLLABLE_OUTPUT_STREAM_GET_INTERFACE (stream)->
|
|
Packit Service |
d3d246 |
create_source (stream, cancellable);
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
static gssize
|
|
Packit Service |
d3d246 |
g_pollable_output_stream_default_write_nonblocking (GPollableOutputStream *stream,
|
|
Packit Service |
d3d246 |
const void *buffer,
|
|
Packit Service |
d3d246 |
gsize count,
|
|
Packit Service |
d3d246 |
GError **error)
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
if (!g_pollable_output_stream_is_writable (stream))
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
g_set_error_literal (error, G_IO_ERROR, G_IO_ERROR_WOULD_BLOCK,
|
|
Packit Service |
d3d246 |
g_strerror (EAGAIN));
|
|
Packit Service |
d3d246 |
return -1;
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
return G_OUTPUT_STREAM_GET_CLASS (stream)->
|
|
Packit Service |
d3d246 |
write_fn (G_OUTPUT_STREAM (stream), buffer, count, NULL, error);
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
/**
|
|
Packit Service |
d3d246 |
* g_pollable_output_stream_write_nonblocking:
|
|
Packit Service |
d3d246 |
* @stream: a #GPollableOutputStream
|
|
Packit Service |
d3d246 |
* @buffer: (array length=count) (element-type guint8): a buffer to write
|
|
Packit Service |
d3d246 |
* data from
|
|
Packit Service |
d3d246 |
* @count: the number of bytes you want to write
|
|
Packit Service |
d3d246 |
* @cancellable: (nullable): a #GCancellable, or %NULL
|
|
Packit Service |
d3d246 |
* @error: #GError for error reporting, or %NULL to ignore.
|
|
Packit Service |
d3d246 |
*
|
|
Packit Service |
d3d246 |
* Attempts to write up to @count bytes from @buffer to @stream, as
|
|
Packit Service |
d3d246 |
* with g_output_stream_write(). If @stream is not currently writable,
|
|
Packit Service |
d3d246 |
* this will immediately return %G_IO_ERROR_WOULD_BLOCK, and you can
|
|
Packit Service |
d3d246 |
* use g_pollable_output_stream_create_source() to create a #GSource
|
|
Packit Service |
d3d246 |
* that will be triggered when @stream is writable.
|
|
Packit Service |
d3d246 |
*
|
|
Packit Service |
d3d246 |
* Note that since this method never blocks, you cannot actually
|
|
Packit Service |
d3d246 |
* use @cancellable to cancel it. However, it will return an error
|
|
Packit Service |
d3d246 |
* if @cancellable has already been cancelled when you call, which
|
|
Packit Service |
d3d246 |
* may happen if you call this method after a source triggers due
|
|
Packit Service |
d3d246 |
* to having been cancelled.
|
|
Packit Service |
d3d246 |
*
|
|
Packit Service |
d3d246 |
* Also note that if %G_IO_ERROR_WOULD_BLOCK is returned some underlying
|
|
Packit Service |
d3d246 |
* transports like D/TLS require that you send the same @buffer and @count.
|
|
Packit Service |
d3d246 |
*
|
|
Packit Service |
d3d246 |
* Virtual: write_nonblocking
|
|
Packit Service |
d3d246 |
* Returns: the number of bytes written, or -1 on error (including
|
|
Packit Service |
d3d246 |
* %G_IO_ERROR_WOULD_BLOCK).
|
|
Packit Service |
d3d246 |
*/
|
|
Packit Service |
d3d246 |
gssize
|
|
Packit Service |
d3d246 |
g_pollable_output_stream_write_nonblocking (GPollableOutputStream *stream,
|
|
Packit Service |
d3d246 |
const void *buffer,
|
|
Packit Service |
d3d246 |
gsize count,
|
|
Packit Service |
d3d246 |
GCancellable *cancellable,
|
|
Packit Service |
d3d246 |
GError **error)
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
gssize res;
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
g_return_val_if_fail (G_IS_POLLABLE_OUTPUT_STREAM (stream), -1);
|
|
Packit Service |
d3d246 |
g_return_val_if_fail (buffer != NULL, 0);
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
if (g_cancellable_set_error_if_cancelled (cancellable, error))
|
|
Packit Service |
d3d246 |
return -1;
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
if (count == 0)
|
|
Packit Service |
d3d246 |
return 0;
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
if (((gssize) count) < 0)
|
|
Packit Service |
d3d246 |
{
|
|
Packit Service |
d3d246 |
g_set_error (error, G_IO_ERROR, G_IO_ERROR_INVALID_ARGUMENT,
|
|
Packit Service |
d3d246 |
_("Too large count value passed to %s"), G_STRFUNC);
|
|
Packit Service |
d3d246 |
return -1;
|
|
Packit Service |
d3d246 |
}
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
if (cancellable)
|
|
Packit Service |
d3d246 |
g_cancellable_push_current (cancellable);
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
res = G_POLLABLE_OUTPUT_STREAM_GET_INTERFACE (stream)->
|
|
Packit Service |
d3d246 |
write_nonblocking (stream, buffer, count, error);
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
if (cancellable)
|
|
Packit Service |
d3d246 |
g_cancellable_pop_current (cancellable);
|
|
Packit Service |
d3d246 |
|
|
Packit Service |
d3d246 |
return res;
|
|
Packit Service |
d3d246 |
}
|