* Copyright (C) 2013 Red Hat, Inc.
* SPDX-License-Identifier: LGPL-2.1-or-later
*/
#ifndef __COCKPIT_PIPE_H__
#define __COCKPIT_PIPE_H__
#include <gio/gio.h>
G_BEGIN_DECLS
typedef enum {
COCKPIT_PIPE_FLAGS_NONE = 0,
COCKPIT_PIPE_STDERR_TO_STDOUT = 1 << 1,
COCKPIT_PIPE_STDERR_TO_NULL = 1 << 2,
COCKPIT_PIPE_STDERR_TO_MEMORY = 1 << 3,
} CockpitPipeFlags;
#define COCKPIT_TYPE_PIPE (cockpit_pipe_get_type ())
G_DECLARE_DERIVABLE_TYPE(CockpitPipe, cockpit_pipe, COCKPIT, PIPE, GObject)
struct _CockpitPipeClass {
GObjectClass parent_class;
void (* read) (CockpitPipe *pipe,
GByteArray *buffer,
gboolean eof);
void (* close) (CockpitPipe *pipe,
const gchar *problem);
};
CockpitPipe * cockpit_pipe_new (const gchar *name,
gint in_fd,
gint out_fd);
CockpitPipe * cockpit_pipe_new_user_fd (const gchar *name,
gint fd);
CockpitPipe * cockpit_pipe_spawn (const gchar **argv,
const gchar **env,
const gchar *directory,
CockpitPipeFlags flags);
CockpitPipe * cockpit_pipe_connect (const gchar *name,
GSocketAddress *address);
#define cockpit_pipe_write(s, d) (_cockpit_pipe_write (s, d, G_STRFUNC, __LINE__))
void _cockpit_pipe_write (CockpitPipe *self,
GBytes *data,
const gchar *caller,
gint line);
void cockpit_pipe_close (CockpitPipe *self,
const gchar *problem);
gint cockpit_pipe_exit_status (CockpitPipe *self);
const gchar * cockpit_pipe_get_name (CockpitPipe *self);
GByteArray * cockpit_pipe_get_buffer (CockpitPipe *self);
GByteArray * cockpit_pipe_get_stderr (CockpitPipe *self);
gchar * cockpit_pipe_take_stderr_as_utf8 (CockpitPipe *self);
gboolean cockpit_pipe_get_pid (CockpitPipe *self,
GPid *pid);
gboolean cockpit_pipe_is_closed (CockpitPipe *self);
void cockpit_pipe_skip (GByteArray *buffer,
gsize skip);
GBytes * cockpit_pipe_consume (GByteArray *buffer,
gsize before,
gsize length,
gsize after);
G_END_DECLS
#endif
