comparison libpurple/protocols/sametime/sametime.c @ 32772:6135b24cdc8a

Samtime: Move the "inpa" input watcher into protocol_data.

32771:a78523019e7a

  /** event id for the buddy list save callback */
  guint save_event;

  /** socket fd */
  int socket;
  gint outpa;  /* like inpa, but the other way */

  /** circular buffer for outgoing data */
  PurpleCircBuffer *sock_buf;

  if(pd->socket) {
    close(pd->socket);
    pd->socket = 0;
  }

  if(gc->inpa) {
    purple_input_remove(gc->inpa);
    gc->inpa = 0;
  }
}


static void mw_session_clear(struct mwSession *session) {

  if(pd->socket) {
    close(pd->socket);
    pd->socket = 0;
  }

  if(pd->gc->inpa) {
    purple_input_remove(pd->gc->inpa);
    pd->gc->inpa = 0;
  }

  if(! ret) {
    DEBUG_INFO("connection reset\n");
    purple_connection_error(pd->gc,

/** Callback passed to purple_proxy_connect when an account is logged
    in, and if the session logging in receives a redirect message */
static void connect_cb(gpointer data, gint source, const gchar *error_message) {

  struct mwPurplePluginData *pd = data;
  PurpleConnection *gc = pd->gc;

  if(source < 0) {
    /* connection failed */

    if(pd->socket) {

    /* stop any existing login attempt */
    mwSession_stop(pd->session, ERR_SUCCESS);
  }

  pd->socket = source;
  gc->inpa = purple_input_add(source, PURPLE_INPUT_READ,
			    read_cb, pd);

  mwSession_start(pd->session);
}

  /* no longer necessary */
  purple_connection_set_protocol_data(gc, NULL);

  /* stop watching the socket */
  if(gc->inpa) {
    purple_input_remove(gc->inpa);
    gc->inpa = 0;
  }

  /* clean up the rest */
  mwPurplePluginData_free(pd);
}

32772:6135b24cdc8a

  /** event id for the buddy list save callback */
  guint save_event;

  /** socket fd */
  int socket;
  guint inpa;  /* input watcher */
  gint outpa;  /* like inpa, but the other way */

  /** circular buffer for outgoing data */
  PurpleCircBuffer *sock_buf;

  if(pd->socket) {
    close(pd->socket);
    pd->socket = 0;
  }

  if(pd->inpa) {
    purple_input_remove(pd->inpa);
    pd->inpa = 0;
  }
}


static void mw_session_clear(struct mwSession *session) {

  if(pd->socket) {
    close(pd->socket);
    pd->socket = 0;
  }

  if(pd->inpa) {
    purple_input_remove(pd->inpa);
    pd->inpa = 0;
  }

  if(! ret) {
    DEBUG_INFO("connection reset\n");
    purple_connection_error(pd->gc,

/** Callback passed to purple_proxy_connect when an account is logged
    in, and if the session logging in receives a redirect message */
static void connect_cb(gpointer data, gint source, const gchar *error_message) {

  struct mwPurplePluginData *pd = data;

  if(source < 0) {
    /* connection failed */

    if(pd->socket) {

    /* stop any existing login attempt */
    mwSession_stop(pd->session, ERR_SUCCESS);
  }

  pd->socket = source;
  pd->inpa = purple_input_add(source, PURPLE_INPUT_READ,
			    read_cb, pd);

  mwSession_start(pd->session);
}

  /* no longer necessary */
  purple_connection_set_protocol_data(gc, NULL);

  /* stop watching the socket */
  if(pd->inpa) {
    purple_input_remove(pd->inpa);
    pd->inpa = 0;
  }

  /* clean up the rest */
  mwPurplePluginData_free(pd);
}