chiark / gitweb /
Playing checkbox in Disobedience choose tab is now only visible for
[disorder] / disobedience / client.c
CommitLineData
460b9539 1/*
2 * This file is part of DisOrder.
5aff007d 3 * Copyright (C) 2006, 2007, 2008 Richard Kettlewell
460b9539 4 *
5 * This program is free software; you can redistribute it and/or modify
6 * it under the terms of the GNU General Public License as published by
7 * the Free Software Foundation; either version 2 of the License, or
8 * (at your option) any later version.
9 *
10 * This program is distributed in the hope that it will be useful, but
11 * WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 * General Public License for more details.
14 *
15 * You should have received a copy of the GNU General Public License
16 * along with this program; if not, write to the Free Software
17 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
18 * USA
19 */
219dc95c
RK
20/** @file disobedience/client.c
21 * @brief GLIB integration for @ref lib/eclient.c client
22 */
460b9539 23
24#include "disobedience.h"
25
219dc95c 26/** @brief GSource subclass for disorder_eclient */
460b9539 27struct eclient_source {
28 GSource gsource;
29 disorder_eclient *client;
30 time_t last_poll;
31 GPollFD pollfd;
32};
33
219dc95c
RK
34/** @brief Called before FDs are polled to choose a timeout.
35 *
36 * We ask for a 3s timeout and every 10s or so we force a dispatch.
37 */
460b9539 38static gboolean gtkclient_prepare(GSource *source,
39 gint *timeout) {
40 const struct eclient_source *esource = (struct eclient_source *)source;
41 D(("gtkclient_prepare"));
42 if(time(0) > esource->last_poll + 10)
43 return TRUE; /* timed out */
44 *timeout = 3000/*milliseconds*/;
45 return FALSE; /* please poll */
46}
47
219dc95c 48/** @brief Check whether we're ready to dispatch */
460b9539 49static gboolean gtkclient_check(GSource *source) {
50 const struct eclient_source *esource = (struct eclient_source *)source;
51 D(("gtkclient_check fd=%d events=%x revents=%x",
52 esource->pollfd.fd, esource->pollfd.events, esource->pollfd.revents));
53 return esource->pollfd.fd != -1 && esource->pollfd.revents != 0;
54}
55
219dc95c 56/** @brief Called after poll() (or otherwise) to dispatch an event */
460b9539 57static gboolean gtkclient_dispatch(GSource *source,
58 GSourceFunc attribute((unused)) callback,
59 gpointer attribute((unused)) user_data) {
60 struct eclient_source *esource = (struct eclient_source *)source;
61 unsigned revents, mode;
62
63 D(("gtkclient_dispatch"));
64 revents = esource->pollfd.revents & esource->pollfd.events;
65 mode = 0;
66 if(revents & (G_IO_IN|G_IO_HUP|G_IO_ERR))
67 mode |= DISORDER_POLL_READ;
68 if(revents & (G_IO_OUT|G_IO_HUP|G_IO_ERR))
69 mode |= DISORDER_POLL_WRITE;
70 time(&esource->last_poll);
e9e8a16d
RK
71 if(!login_window)
72 disorder_eclient_polled(esource->client, mode);
460b9539 73 return TRUE; /* ??? not documented */
74}
75
219dc95c 76/** @brief Table of callbacks for GSource subclass */
460b9539 77static const GSourceFuncs sourcefuncs = {
78 gtkclient_prepare,
79 gtkclient_check,
80 gtkclient_dispatch,
81 0,
82 0,
83 0,
84};
85
219dc95c 86/** @brief Tell the mainloop what we need */
460b9539 87static void gtkclient_poll(void *u,
88 disorder_eclient attribute((unused)) *c,
89 int fd, unsigned mode) {
90 struct eclient_source *esource = u;
91 GSource *source = u;
92
93 D(("gtkclient_poll fd=%d mode=%x", fd, mode));
94 /* deconfigure the source if currently configured */
95 if(esource->pollfd.fd != -1) {
96 D(("calling g_source_remove_poll"));
97 g_source_remove_poll(source, &esource->pollfd);
98 esource->pollfd.fd = -1;
99 esource->pollfd.events = 0;
100 }
101 /* install new settings */
102 if(fd != -1 && mode) {
103 esource->pollfd.fd = fd;
104 esource->pollfd.events = 0;
105 if(mode & DISORDER_POLL_READ)
106 esource->pollfd.events |= G_IO_IN | G_IO_HUP | G_IO_ERR;
107 if(mode & DISORDER_POLL_WRITE)
108 esource->pollfd.events |= G_IO_OUT | G_IO_ERR;
109 /* reconfigure the source */
110 D(("calling g_source_add_poll"));
111 g_source_add_poll(source, &esource->pollfd);
112 }
113}
114
219dc95c
RK
115/** @brief Report a communication-level error
116 *
117 * Any operations still outstanding are automatically replied by the underlying
118 * @ref lib/eclient.c code.
119 */
460b9539 120static void gtkclient_comms_error(void attribute((unused)) *u,
121 const char *msg) {
122 D(("gtkclient_comms_error %s", msg));
123 gtk_label_set_text(GTK_LABEL(report_label), msg);
124}
125
219dc95c
RK
126/** @brief Report a protocol-level error
127 *
128 * The error will not be retried. We offer a callback to the submitter of the
129 * original command and if none is supplied we pop up an error box.
130 */
460b9539 131static void gtkclient_protocol_error(void attribute((unused)) *u,
132 void *v,
133 int code,
134 const char *msg) {
135 struct callbackdata *cbd = v;
136
137 D(("gtkclient_protocol_error %s", msg));
138 if(cbd && cbd->onerror)
139 cbd->onerror(cbd, code, msg);
140 else
141 popup_protocol_error(code, msg);
142}
143
219dc95c 144/** @brief Report callback from eclient */
460b9539 145static void gtkclient_report(void attribute((unused)) *u,
146 const char *msg) {
147 if(!msg)
148 /* We're idle - clear the report line */
149 gtk_label_set_text(GTK_LABEL(report_label), "");
150}
151
219dc95c 152/** @brief Repoort an unhandled protocol-level error to the user */
460b9539 153void popup_protocol_error(int attribute((unused)) code,
154 const char *msg) {
155 gtk_label_set_text(GTK_LABEL(report_label), msg);
043d60b1 156 popup_msg(GTK_MESSAGE_ERROR, msg);
460b9539 157}
158
219dc95c 159/** @brief Table of eclient callbacks */
460b9539 160static const disorder_eclient_callbacks gtkclient_callbacks = {
161 gtkclient_comms_error,
162 gtkclient_protocol_error,
163 gtkclient_poll,
164 gtkclient_report
165};
166
717ba987 167/** @brief Create a @ref disorder_eclient using the GLib main loop */
460b9539 168disorder_eclient *gtkclient(void) {
169 GSource *source;
170 struct eclient_source *esource;
171
172 D(("gtkclient"));
173 source = g_source_new((GSourceFuncs *)&sourcefuncs,
174 sizeof (struct eclient_source));
175 esource = (struct eclient_source *)source;
176 esource->pollfd.fd = -1;
177 esource->client = disorder_eclient_new(&gtkclient_callbacks, source);
1c0d78bd
RK
178 if(!esource->client) {
179 g_source_destroy(source);
180 return 0;
181 }
460b9539 182 g_source_attach(source, 0);
183 return esource->client;
184}
185
186/*
187Local Variables:
188c-basic-offset:2
189comment-column:40
190fill-column:79
191indent-tabs-mode:nil
192End:
193*/