summaryrefslogtreecommitdiff
path: root/src/vtestream-file.h
diff options
context:
space:
mode:
authorBehdad Esfahbod <behdad@behdad.org>2013-09-29 19:54:39 -0400
committerBehdad Esfahbod <behdad@behdad.org>2013-09-29 19:54:39 -0400
commit73e10d9bcf414696258dbf10245a111985311b9a (patch)
tree17ac23bb79fb264f8ce956414ab6b99e27baef30 /src/vtestream-file.h
parent480e1ae1cb9e343663896a19df31060f3bffb7b5 (diff)
downloadvte-73e10d9bcf414696258dbf10245a111985311b9a.tar.gz
[stream] Remove write_contents
The ring will now read the stream contents and write it out itself. Makes stream implementation(s) easier.
Diffstat (limited to 'src/vtestream-file.h')
-rw-r--r--src/vtestream-file.h38
1 files changed, 0 insertions, 38 deletions
diff --git a/src/vtestream-file.h b/src/vtestream-file.h
index c47b0b61..0badb318 100644
--- a/src/vtestream-file.h
+++ b/src/vtestream-file.h
@@ -123,22 +123,6 @@ _xpwrite (int fd, const char *data, gsize len, gsize offset)
}
}
-static gboolean
-_xwrite_contents (gint fd, GOutputStream *output, GCancellable *cancellable, GError **error)
-{
- gboolean ret;
- GInputStream *input;
-
- if (G_UNLIKELY (!fd))
- return TRUE;
-
- input = g_unix_input_stream_new (fd, FALSE);
- ret = -1 != g_output_stream_splice (output, input, G_OUTPUT_STREAM_SPLICE_NONE, cancellable, error);
- g_object_unref (input);
-
- return ret;
-}
-
/*
* VteFileStream: A POSIX file-based stream
@@ -288,27 +272,6 @@ _vte_file_stream_head (VteStream *astream, guint index)
return index == 0 ? stream->head : stream->offset[index - 1];
}
-static gboolean
-_vte_file_stream_write_contents (VteStream *astream, GOutputStream *output,
- gsize offset,
- GCancellable *cancellable, GError **error)
-{
- VteFileStream *stream = (VteFileStream *) astream;
-
- if (G_UNLIKELY (offset < stream->offset[1]))
- return FALSE;
-
- if (offset < stream->offset[0]) {
- lseek (stream->fd[1], offset - stream->offset[1], SEEK_SET);
- if (!_xwrite_contents (stream->fd[1], output, cancellable, error))
- return FALSE;
- offset = stream->offset[0];
- }
-
- lseek (stream->fd[0], offset - stream->offset[0], SEEK_SET);
- return _xwrite_contents (stream->fd[0], output, cancellable, error);
-}
-
static void
_vte_file_stream_class_init (VteFileStreamClass *klass)
{
@@ -322,5 +285,4 @@ _vte_file_stream_class_init (VteFileStreamClass *klass)
klass->truncate = _vte_file_stream_truncate;
klass->new_page = _vte_file_stream_new_page;
klass->head = _vte_file_stream_head;
- klass->write_contents = _vte_file_stream_write_contents;
}