comparison libfaim/conn.c @ 2034:6bdf9954097c

[gaim-migrate @ 2044] oscar is much less segfaulty. and more reliable. yes. committer: Tailor Script <[e-mail]>

2033:705783e5ab8c

 * @sess: Session to be cleared
 *
 * Clears out the connection list and kills any connections left.
 *
 */
faim_internal void aim_connrst(struct aim_session_t *sess)
{
  faim_mutex_init(&sess->connlistlock);
  if (sess->connlist) {
    struct aim_conn_t *cur = sess->connlist, *tmp;

 * @sess: Session
 *
 * Allocate a new empty connection structure.
 *
 */
faim_internal struct aim_conn_t *aim_conn_getnext(struct aim_session_t *sess)
{
  struct aim_conn_t *newconn, *cur;

  if (!(newconn = malloc(sizeof(struct aim_conn_t)))) 	
    return NULL;

  for (cur = sess->connlist; cur; cur = cur->next) {
    if ((cur->type == type) && !(cur->status & AIM_CONN_STATUS_INPROGRESS))
      break;
  }
  faim_mutex_unlock(&sess->connlistlock);
  return cur;
}

/**
 * aim_proxyconnect - An extrememly quick and dirty SOCKS5 interface. 

  conn->subtype = src->subtype;
  conn->seqnum = src->seqnum;
  conn->priv = src->priv;
  conn->lastactivity = src->lastactivity;
  conn->forcedlatency = src->forcedlatency;

  /* clone handler list */
  for (cur = src->handlerlist; cur; cur = cur->next) {
    aim_conn_addhandler(sess, conn, cur->family, cur->type, 
			cur->handler, cur->flags);

  if ((connstruct=aim_conn_getnext(sess))==NULL)
    return NULL;

  faim_mutex_lock(&connstruct->active);
  
  connstruct->type = type;

  if (!dest) { /* just allocate a struct */
    connstruct->fd = -1;
    connstruct->status = 0;

  aim_tx_flushqueue(sess);

  return 0;
}

/*
 * aim_logoff()
 *
 * Closes -ALL- open connections.
 *

2034:6bdf9954097c

 * @sess: Session to be cleared
 *
 * Clears out the connection list and kills any connections left.
 *
 */
static void aim_connrst(struct aim_session_t *sess)
{
  faim_mutex_init(&sess->connlistlock);
  if (sess->connlist) {
    struct aim_conn_t *cur = sess->connlist, *tmp;

 * @sess: Session
 *
 * Allocate a new empty connection structure.
 *
 */
static struct aim_conn_t *aim_conn_getnext(struct aim_session_t *sess)
{
  struct aim_conn_t *newconn, *cur;

  if (!(newconn = malloc(sizeof(struct aim_conn_t)))) 	
    return NULL;

  for (cur = sess->connlist; cur; cur = cur->next) {
    if ((cur->type == type) && !(cur->status & AIM_CONN_STATUS_INPROGRESS))
      break;
  }
  faim_mutex_unlock(&sess->connlistlock);

  return cur;
}

faim_export struct aim_conn_t *aim_getconn_type_all(struct aim_session_t *sess,
						    int type)
{
  struct aim_conn_t *cur;

  faim_mutex_lock(&sess->connlistlock);
  for (cur = sess->connlist; cur; cur = cur->next) {
    if (cur->type == type)
      break;
  }
  faim_mutex_unlock(&sess->connlistlock);

  return cur;
}

/* If you pass -1 for the fd, you'll get what you ask for.  Gibberish. */
faim_export struct aim_conn_t *aim_getconn_fd(struct aim_session_t *sess,
					      int fd)
{
  struct aim_conn_t *cur;

  faim_mutex_lock(&sess->connlistlock);
  for (cur = sess->connlist; cur; cur = cur->next) {
    if (cur->fd == fd)
      break;
  }
  faim_mutex_unlock(&sess->connlistlock);

  return cur;
}

/**
 * aim_proxyconnect - An extrememly quick and dirty SOCKS5 interface. 

  conn->subtype = src->subtype;
  conn->seqnum = src->seqnum;
  conn->priv = src->priv;
  conn->lastactivity = src->lastactivity;
  conn->forcedlatency = src->forcedlatency;
  conn->sessv = src->sessv;

  /* clone handler list */
  for (cur = src->handlerlist; cur; cur = cur->next) {
    aim_conn_addhandler(sess, conn, cur->family, cur->type, 
			cur->handler, cur->flags);

  if ((connstruct=aim_conn_getnext(sess))==NULL)
    return NULL;

  faim_mutex_lock(&connstruct->active);

  connstruct->sessv = (void *)sess;
  connstruct->type = type;

  if (!dest) { /* just allocate a struct */
    connstruct->fd = -1;
    connstruct->status = 0;

  aim_tx_flushqueue(sess);

  return 0;
}

faim_export struct aim_session_t *aim_conn_getsess(struct aim_conn_t *conn)
{

  if (!conn)
    return NULL;

  return (struct aim_session_t *)conn->sessv;
}

/*
 * aim_logoff()
 *
 * Closes -ALL- open connections.
 *