1 /* GIO - GLib Input, Output and Streaming Library
2 *
3 * Copyright (C) 2006-2007 Red Hat, Inc.
4 *
5 * This library is free software; you can redistribute it and/or
6 * modify it under the terms of the GNU Lesser General Public
7 * License as published by the Free Software Foundation; either
8 * version 2 of the License, or (at your option) any later version.
9 *
10 * This library is distributed in the hope that it will be useful,
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 * Lesser General Public License for more details.
14 *
15 * You should have received a copy of the GNU Lesser General
16 * Public License along with this library; if not, write to the
17 * Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
18 * Boston, MA 02110-1301, USA.
19 *
20 * Author: Alexander Larsson <alexl@redhat.com>
21 */
22
23 #include <config.h>
24
25 #include <unistd.h>
26 #include <sys/types.h>
27 #include <sys/socket.h>
28 #include <sys/un.h>
29
30 #include <glib.h>
31 #include <glib/gi18n.h>
32 #include "gvfsreadchannel.h"
33 #include "gvfsjobread.h"
34 #include "gvfsdaemonutils.h"
35
36 G_DEFINE_TYPE (GVfsJobRead, g_vfs_job_read, G_VFS_TYPE_JOB)
37
38 static void run (GVfsJob *job);
39 static gboolean try (GVfsJob *job);
40 static void send_reply (GVfsJob *job);
41
42 static void
g_vfs_job_read_finalize(GObject * object)43 g_vfs_job_read_finalize (GObject *object)
44 {
45 GVfsJobRead *job;
46
47 job = G_VFS_JOB_READ (object);
48
49 g_object_unref (job->channel);
50 g_free (job->buffer);
51
52 if (G_OBJECT_CLASS (g_vfs_job_read_parent_class)->finalize)
53 (*G_OBJECT_CLASS (g_vfs_job_read_parent_class)->finalize) (object);
54 }
55
56 static void
g_vfs_job_read_class_init(GVfsJobReadClass * klass)57 g_vfs_job_read_class_init (GVfsJobReadClass *klass)
58 {
59 GObjectClass *gobject_class = G_OBJECT_CLASS (klass);
60 GVfsJobClass *job_class = G_VFS_JOB_CLASS (klass);
61
62 gobject_class->finalize = g_vfs_job_read_finalize;
63
64 job_class->run = run;
65 job_class->try = try;
66 job_class->send_reply = send_reply;
67 }
68
69 static void
g_vfs_job_read_init(GVfsJobRead * job)70 g_vfs_job_read_init (GVfsJobRead *job)
71 {
72 }
73
74 GVfsJob *
g_vfs_job_read_new(GVfsReadChannel * channel,GVfsBackendHandle handle,gsize bytes_requested,GVfsBackend * backend)75 g_vfs_job_read_new (GVfsReadChannel *channel,
76 GVfsBackendHandle handle,
77 gsize bytes_requested,
78 GVfsBackend *backend)
79 {
80 GVfsJobRead *job;
81
82 job = g_object_new (G_VFS_TYPE_JOB_READ,
83 NULL);
84
85 job->backend = backend;
86 job->channel = g_object_ref (channel);
87 job->handle = handle;
88 job->buffer = g_malloc (bytes_requested);
89 job->bytes_requested = bytes_requested;
90
91 return G_VFS_JOB (job);
92 }
93
94 /* Might be called on an i/o thread */
95 static void
send_reply(GVfsJob * job)96 send_reply (GVfsJob *job)
97 {
98 GVfsJobRead *op_job = G_VFS_JOB_READ (job);
99
100 g_debug ("send_reply(%p), bytes=%"G_GSIZE_FORMAT", failed=%d (%s)\n",
101 job, op_job->data_count,
102 job->failed, job->failed ? job->error->message : "");
103
104 if (job->failed)
105 g_vfs_channel_send_error (G_VFS_CHANNEL (op_job->channel), job->error);
106 else
107 {
108 g_vfs_read_channel_send_data (op_job->channel,
109 op_job->buffer,
110 op_job->data_count);
111 }
112 }
113
114 static void
run(GVfsJob * job)115 run (GVfsJob *job)
116 {
117 GVfsJobRead *op_job = G_VFS_JOB_READ (job);
118 GVfsBackendClass *class = G_VFS_BACKEND_GET_CLASS (op_job->backend);
119
120 if (class->read == NULL)
121 {
122 g_vfs_job_failed (job, G_IO_ERROR, G_IO_ERROR_NOT_SUPPORTED,
123 _("Operation not supported"));
124 return;
125 }
126
127 class->read (op_job->backend,
128 op_job,
129 op_job->handle,
130 op_job->buffer,
131 op_job->bytes_requested);
132 }
133
134 static gboolean
try(GVfsJob * job)135 try (GVfsJob *job)
136 {
137 GVfsJobRead *op_job = G_VFS_JOB_READ (job);
138 GVfsBackendClass *class = G_VFS_BACKEND_GET_CLASS (op_job->backend);
139
140 if (class->try_read == NULL)
141 return FALSE;
142
143 return class->try_read (op_job->backend,
144 op_job,
145 op_job->handle,
146 op_job->buffer,
147 op_job->bytes_requested);
148 }
149
150
151 /* Takes ownership */
152 void
g_vfs_job_read_set_size(GVfsJobRead * job,gsize data_size)153 g_vfs_job_read_set_size (GVfsJobRead *job,
154 gsize data_size)
155 {
156 job->data_count = data_size;
157 }
158