mirror of
https://github.com/ChronosX88/psyced.git
synced 2024-11-09 12:01:00 +00:00
54 lines
1.1 KiB
C
54 lines
1.1 KiB
C
// $Id: outputb.c,v 1.2 2007/08/27 16:54:11 lynx Exp $
|
|
//
|
|
// buffered output object
|
|
// inspired by fippo's async_http_base.c
|
|
//
|
|
// activate by passing a buffer init string, usually init_buffer("").
|
|
// write to buffer using any of emit or write
|
|
// flush to object or myself when done, using flush_buffer().
|
|
//
|
|
// if you want to use w() and textdb, consider that you have to
|
|
// #include <text.h> AFTER inheriting this, so that w() feeds this emit().
|
|
|
|
#include <net.h>
|
|
|
|
virtual inherit NET_PATH "output";
|
|
|
|
protected string _buffer;
|
|
|
|
#define BUFF(DATA) \
|
|
P3(("outputb in %O adding %O\n", ME, DATA)) \
|
|
_buffer += DATA; \
|
|
return 1;
|
|
|
|
void init_buffer(string what) {
|
|
// initiate buffering mode
|
|
_buffer = what;
|
|
}
|
|
|
|
int emit(string output) {
|
|
if (_buffer) {
|
|
BUFF(output)
|
|
}
|
|
else return ::emit(output);
|
|
}
|
|
|
|
// not sure if i like this one.. it may be incorrect to map to emit
|
|
int write(mixed output) {
|
|
if (_buffer) {
|
|
BUFF(output)
|
|
}
|
|
else {
|
|
efun::write(output);
|
|
return 1;
|
|
}
|
|
}
|
|
|
|
flush_buffer(object out) {
|
|
P2(("flush_buffer for %O and data %O\n", out, _buffer))
|
|
if (out) out->emit(_buffer);
|
|
else ::emit(_buffer);
|
|
// terminate buffering mode
|
|
_buffer = 0;
|
|
}
|