ermyth/include/datastream.h

/*
 * Copyright © 2005 Atheme Development Group
 * Rights to this code are as documented in doc/LICENSE.
 *
 * Datastream query stuff.
 *
 * $Id: datastream.h 7779 2007-03-03 13:55:42Z pippijn $
 */
#ifndef __CLARODATASTREAM
#define __CLARODATASTREAM

E void sendq_add (connection_t *cptr, char *buf, int len);
E void sendq_add_eof (connection_t *cptr);
E void sendq_flush (connection_t *cptr);
E bool sendq_nonempty (connection_t *cptr);

E int recvq_length (connection_t *cptr);
E void recvq_put (connection_t *cptr);
E int recvq_get (connection_t *cptr, char *buf, int len);
E int recvq_getline (connection_t *cptr, char *buf, int len);

E void sendqrecvq_free (connection_t *cptr);

#endif
Revision:	1.1
Committed:	Thu Jul 19 08:24:50 2007 UTC (16 years, 10 months ago) by pippijn
Content type:	text/plain
Branch:	MAIN
Log Message:	initial import. the most important changes since Atheme are: - fixed many memory leaks - fixed many bugs - converted to C++ and use more STL containers - added a (not very enhanced yet) perl module - greatly improved XML-RPC speed - added a JSON-RPC module with code from json-cpp - added a valgrind memcheck module to operserv - added a more object oriented base64 implementation - added a specialised unit test framework - improved stability - use gettimeofday() if available - reworked adding/removing commands - MemoServ IGNORE DEL can now remove indices
#	User	Rev	Content
1	pippijn	1.1	/*
2			* Copyright © 2005 Atheme Development Group
3			* Rights to this code are as documented in doc/LICENSE.
4			*
5			* Datastream query stuff.
6			*
7			* $Id: datastream.h 7779 2007-03-03 13:55:42Z pippijn $
8			*/
9			#ifndef __CLARODATASTREAM
10			#define __CLARODATASTREAM
11
12			E void sendq_add (connection_t cptr, char buf, int len);
13			E void sendq_add_eof (connection_t *cptr);
14			E void sendq_flush (connection_t *cptr);
15			E bool sendq_nonempty (connection_t *cptr);
16
17			E int recvq_length (connection_t *cptr);
18			E void recvq_put (connection_t *cptr);
19			E int recvq_get (connection_t cptr, char buf, int len);
20			E int recvq_getline (connection_t cptr, char buf, int len);
21
22			E void sendqrecvq_free (connection_t *cptr);
23
24			#endif