chiark - git - mdw - disorder/blob - disobedience/client.c

   1 /*
   2  * This file is part of DisOrder.
   3  * Copyright (C) 2006, 2007, 2008 Richard Kettlewell
   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  */
  20 /** @file disobedience/client.c
  21  * @brief GLIB integration for @ref lib/eclient.c client
  22  */
  23
  24 #include "disobedience.h"
  25
  26 /** @brief GSource subclass for disorder_eclient */
  27 struct eclient_source {
  28   GSource gsource;
  29   disorder_eclient *client;
  30   time_t last_poll;
  31   GPollFD pollfd;
  32 };
  33
  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  */
  38 static 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
  48 /** @brief Check whether we're ready to dispatch */
  49 static 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
  56 /** @brief Called after poll() (or otherwise) to dispatch an event */
  57 static 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);
  71   disorder_eclient_polled(esource->client, mode);
  72   return TRUE;                          /* ??? not documented */
  73 }
  74
  75 /** @brief Table of callbacks for GSource subclass */
  76 static const GSourceFuncs sourcefuncs = {
  77   gtkclient_prepare,
  78   gtkclient_check,
  79   gtkclient_dispatch,
  80   0,
  81   0,
  82   0,
  83 };
  84
  85 /** @brief Tell the mainloop what we need */
  86 static void gtkclient_poll(void *u,
  87                            disorder_eclient attribute((unused)) *c,
  88                            int fd, unsigned mode) {
  89   struct eclient_source *esource = u;
  90   GSource *source = u;
  91
  92   D(("gtkclient_poll fd=%d mode=%x", fd, mode));
  93   /* deconfigure the source if currently configured */
  94   if(esource->pollfd.fd != -1) {
  95     D(("calling g_source_remove_poll"));
  96     g_source_remove_poll(source, &esource->pollfd);
  97     esource->pollfd.fd = -1;
  98     esource->pollfd.events = 0;
  99   }
 100   /* install new settings */
 101   if(fd != -1 && mode) {
 102     esource->pollfd.fd = fd;
 103     esource->pollfd.events = 0;
 104     if(mode & DISORDER_POLL_READ)
 105       esource->pollfd.events |= G_IO_IN | G_IO_HUP | G_IO_ERR;
 106     if(mode & DISORDER_POLL_WRITE)
 107       esource->pollfd.events |= G_IO_OUT | G_IO_ERR;
 108     /* reconfigure the source */
 109     D(("calling g_source_add_poll"));
 110     g_source_add_poll(source, &esource->pollfd);
 111   }
 112 }
 113
 114 /** @brief Report a communication-level error
 115  *
 116  * Any operations still outstanding are automatically replied by the underlying
 117  * @ref lib/eclient.c code.
 118  */
 119 static void gtkclient_comms_error(void attribute((unused)) *u,
 120                                   const char *msg) {
 121   D(("gtkclient_comms_error %s", msg));
 122   gtk_label_set_text(GTK_LABEL(report_label), msg);
 123 }
 124
 125 /** @brief Report a protocol-level error
 126  *
 127  * The error will not be retried.  We offer a callback to the submitter of the
 128  * original command and if none is supplied we drop the error message in the
 129  * status bar.
 130  */
 131 static 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     gtk_label_set_text(GTK_LABEL(report_label), msg);
 142 }
 143
 144 /** @brief Report callback from eclient */
 145 static 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
 152 /** @brief Repoort an unhandled protocol-level error to the user */
 153 void popup_protocol_error(int attribute((unused)) code,
 154                           const char *msg) {
 155   gtk_label_set_text(GTK_LABEL(report_label), msg);
 156   popup_msg(GTK_MESSAGE_ERROR, msg);
 157 }
 158
 159 /** @brief Table of eclient callbacks */
 160 static const disorder_eclient_callbacks gtkclient_callbacks = {
 161   gtkclient_comms_error,
 162   gtkclient_protocol_error,
 163   gtkclient_poll,
 164   gtkclient_report
 165 };
 166
 167 /** @brief Create a @ref disorder_eclient using the GLib main loop */
 168 disorder_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);
 178   if(!esource->client) {
 179     g_source_destroy(source);
 180     return 0;
 181   }
 182   g_source_attach(source, 0);
 183   return esource->client;
 184 }
 185
 186 /*
 187 Local Variables:
 188 c-basic-offset:2
 189 comment-column:40
 190 fill-column:79
 191 indent-tabs-mode:nil
 192 End:
 193 */