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