ermyth/src/send.C

/*
 * send.C: Socket I/O.
 * Rights to this code are documented in doc/pod/license.pod.
 *
 * Copyright © 2005-2007 Atheme Project (http://www.atheme.org)
 */

static char const rcsid[] = "$Id$";

#include "atheme.h"
#include "uplink.h"
#include "datastream.h"

/* send a line to the server, append the \r\n */
int
sts (char *fmt, ...)
{
  va_list ap;
  char buf[513];
  int len;

  return_val_if_fail (fmt != NULL, 1);

  va_start (ap, fmt);
  vsnprintf (buf, 511, fmt, ap);        /* leave two bytes for \r\n */
  va_end (ap);

  slog (LG_RAWDATA, "<- %s", buf);

  len = strlen (buf);
  buf[len++] = '\r';
  buf[len++] = '\n';
  buf[len] = '\0';

  cnt.bout += len;

  sendq_add (curr_uplink->conn, buf, len);

  return 0;
}

void
reconn (void *arg)
{
  if (me.connected)
    return;

  uplink_connect ();
}

/*
 * io_loop()
 *
 * inputs:
 *       none
 *
 * outputs:
 *       none
 *
 * side effects:
 *       everything happens inside this loop.
 */
void
io_loop (void)
{
  time_t delay;

  while (!(runflags & (RF_SHUTDOWN | RF_RESTART)))
    {
      /* update the current time */
      NOW = time (NULL);

      /* check for events */
      delay = event_next_time ();

      if (delay <= NOW)
        event_run ();

      connection_select (25000);
    }
}
Revision:	1.3
Committed:	Sat Jul 21 13:23:22 2007 UTC (16 years, 10 months ago) by pippijn
Content type:	text/plain
Branch:	MAIN
Changes since 1.2:	+1 -1 lines
Log Message:	- added rcsid to some files - more documentation tweaks - made most protocol commands local to phandler.C - added ircd metadata (inspircd only for now) - added inspircd swhois support
#	Content
1	/*
2	* send.C: Socket I/O.
3	* Rights to this code are documented in doc/pod/license.pod.
4	*
5	* Copyright © 2005-2007 Atheme Project (http://www.atheme.org)
6	*/
7
8	static char const rcsid[] = "$Id$";
9
10	#include "atheme.h"
11	#include "uplink.h"
12	#include "datastream.h"
13
14	/* send a line to the server, append the \r\n */
15	int
16	sts (char *fmt, ...)
17	{
18	va_list ap;
19	char buf[513];
20	int len;
21
22	return_val_if_fail (fmt != NULL, 1);
23
24	va_start (ap, fmt);
25	vsnprintf (buf, 511, fmt, ap); /* leave two bytes for \r\n */
26	va_end (ap);
27
28	slog (LG_RAWDATA, "<- %s", buf);
29
30	len = strlen (buf);
31	buf[len++] = '\r';
32	buf[len++] = '\n';
33	buf[len] = '\0';
34
35	cnt.bout += len;
36
37	sendq_add (curr_uplink->conn, buf, len);
38
39	return 0;
40	}
41
42	void
43	reconn (void *arg)
44	{
45	if (me.connected)
46	return;
47
48	uplink_connect ();
49	}
50
51	/*
52	* io_loop()
53	*
54	* inputs:
55	* none
56	*
57	* outputs:
58	* none
59	*
60	* side effects:
61	* everything happens inside this loop.
62	*/
63	void
64	io_loop (void)
65	{
66	time_t delay;
67
68	while (!(runflags & (RF_SHUTDOWN \| RF_RESTART)))
69	{
70	/* update the current time */
71	NOW = time (NULL);
72
73	/* check for events */
74	delay = event_next_time ();
75
76	if (delay <= NOW)
77	event_run ();
78
79	connection_select (25000);
80	}
81	}