ermyth/src/send.C

/*
 * send.C: Socket I/O.
 *
 * Copyright © 2007 Pippijn van Steenhoven / The Ermyth Team
 * Rights to this code are as documented in COPYING.
 *
 *
 * Portions of this file were derived from sources bearing the following license:
 * 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: send.C,v 1.8 2007-09-16 18:54:45 pippijn Exp $";

#include "atheme.h"
#include <libermyth.h>
#include <util/time.h>
#include "uplink.h"
#include "datastream.h"
#include "connection.h"

/* send a line to the server, append the \r\n */
int
sts (char const * const 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_t (now ());

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

      if (delay <= NOW)
        event_run ();

      connection_t::select (25000);

      gc.collect ();
    }
}
Revision:	1.9
Committed:	Sat Sep 22 14:27:30 2007 UTC (16 years, 7 months ago) by pippijn
Content type:	text/plain
Branch:	MAIN
CVS Tags:	HEAD
Changes since 1.8:	+3 -1 lines
Log Message:	split up ermyth into ermyth-modules, libermyth (currently just ermyth-util) and ermyth-core
#	Content
1	/*
2	* send.C: Socket I/O.
3	*
4	* Copyright © 2007 Pippijn van Steenhoven / The Ermyth Team
5	* Rights to this code are as documented in COPYING.
6	*
7	*
8	* Portions of this file were derived from sources bearing the following license:
9	* Rights to this code are documented in doc/pod/license.pod.
10	* Copyright © 2005-2007 Atheme Project (http://www.atheme.org)
11	*/
12
13	static char const rcsid[] = "$Id: send.C,v 1.8 2007-09-16 18:54:45 pippijn Exp $";
14
15	#include "atheme.h"
16	#include <libermyth.h>
17	#include <util/time.h>
18	#include "uplink.h"
19	#include "datastream.h"
20	#include "connection.h"
21
22	/* send a line to the server, append the \r\n */
23	int
24	sts (char const * const fmt, ...)
25	{
26	va_list ap;
27	char buf[513];
28	int len;
29
30	return_val_if_fail (fmt != NULL, 1);
31
32	va_start (ap, fmt);
33	vsnprintf (buf, 511, fmt, ap); /* leave two bytes for \r\n */
34	va_end (ap);
35
36	slog (LG_RAWDATA, "<- %s", buf);
37
38	len = strlen (buf);
39	buf[len++] = '\r';
40	buf[len++] = '\n';
41	buf[len] = '\0';
42
43	cnt.bout += len;
44
45	sendq_add (curr_uplink->conn, buf, len);
46
47	return 0;
48	}
49
50	void
51	reconn (void *arg)
52	{
53	if (me.connected)
54	return;
55
56	uplink_connect ();
57	}
58
59	/*
60	* io_loop()
61	*
62	* inputs:
63	* none
64	*
65	* outputs:
66	* none
67	*
68	* side effects:
69	* everything happens inside this loop.
70	*/
71	void
72	io_loop (void)
73	{
74	time_t delay;
75
76	while (!(runflags & (RF_SHUTDOWN \| RF_RESTART)))
77	{
78	/* update the current time */
79	NOW = time_t (now ());
80
81	/* check for events */
82	delay = event_next_time ();
83
84	if (delay <= NOW)
85	event_run ();
86
87	connection_t::select (25000);
88
89	gc.collect ();
90	}
91	}