1 /*
2  * Copyright (c) 2005 Atheme Development Group
3  * Rights to this code are as documented in doc/LICENSE.
4  *
5  * Datastream query stuff.
6  *
7  */
8 
9 #ifndef ATHEME_DATASTREAM_H
10 #define ATHEME_DATASTREAM_H
11 
12 E void sendq_add(connection_t *cptr, char *buf, size_t 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 E void sendq_set_limit(connection_t *cptr, size_t len);
17 
18 E int recvq_length(connection_t *cptr);
19 E void recvq_put(connection_t *cptr);
20 E int recvq_get(connection_t *cptr, char *buf, size_t len);
21 E int recvq_getline(connection_t *cptr, char *buf, size_t len);
22 
23 E void sendqrecvq_free(connection_t *cptr);
24 
25 #endif
26 
27 /* vim:cinoptions=>s,e0,n0,f0,{0,}0,^0,=s,ps,t0,c3,+s,(2s,us,)20,*30,gs,hs
28  * vim:ts=8
29  * vim:sw=8
30  * vim:noexpandtab
31  */
32