You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
114 lines
2.6 KiB
114 lines
2.6 KiB
3 months ago
|
/*
|
||
|
|
* UCW Library -- Charset Conversion Wrapper for Fast Buffered I/O
|
||
|
|
*
|
||
|
|
* (c) 2003--2005 Martin Mares <mj@ucw.cz>
|
||
|
|
*
|
||
|
|
* This software may be freely distributed and used according to the terms
|
||
|
|
* of the GNU Lesser General Public License.
|
||
|
|
*/
|
||
|
|
|
||
|
|
#include <ucw/lib.h>
|
||
|
|
#include <ucw/fastbuf.h>
|
||
|
|
#include <charset/charconv.h>
|
||
|
|
#include <charset/fb-charconv.h>
|
||
|
|
|
||
|
|
#define BUFSIZE 1024
|
||
|
|
|
||
|
|
struct fb_charconv {
|
||
|
|
struct fastbuf fb;
|
||
|
|
struct fastbuf *orig;
|
||
|
|
struct conv_context ctxt;
|
||
|
|
byte buf[BUFSIZE];
|
||
|
|
};
|
||
|
|
#define FB_CC(f) ((struct fb_charconv *)(f))
|
||
|
|
|
||
|
|
static void
|
||
|
|
fb_cc_spout(struct fastbuf *f)
|
||
|
|
{
|
||
|
|
struct conv_context *ct = &FB_CC(f)->ctxt;
|
||
|
|
int flags;
|
||
|
|
|
||
|
|
ct->source = f->buffer;
|
||
|
|
ct->source_end = f->bptr;
|
||
|
|
do
|
||
|
|
{
|
||
|
|
flags = conv_run(ct);
|
||
|
|
if (ct->dest > ct->dest_start)
|
||
|
|
bdirect_write_commit(FB_CC(f)->orig, ct->dest);
|
||
|
|
uint l = bdirect_write_prepare(FB_CC(f)->orig, &ct->dest_start);
|
||
|
|
ct->dest = ct->dest_start;
|
||
|
|
ct->dest_end = ct->dest + l;
|
||
|
|
}
|
||
|
|
while (!(flags & CONV_SOURCE_END));
|
||
|
|
|
||
|
|
f->bptr = f->buffer;
|
||
|
|
}
|
||
|
|
|
||
|
|
static int
|
||
|
|
fb_cc_refill(struct fastbuf *f)
|
||
|
|
{
|
||
|
|
struct conv_context *ct = &FB_CC(f)->ctxt;
|
||
|
|
int flags;
|
||
|
|
|
||
|
|
f->bptr = f->bstop = f->buffer;
|
||
|
|
do
|
||
|
|
{
|
||
|
|
byte *src;
|
||
|
|
uint len = bdirect_read_prepare(FB_CC(f)->orig, &src);
|
||
|
|
if (!len)
|
||
|
|
break;
|
||
|
|
ct->source = src;
|
||
|
|
ct->source_end = ct->source + len;
|
||
|
|
ct->dest = ct->dest_start = f->bstop;
|
||
|
|
ct->dest_end = f->bufend;
|
||
|
|
flags = conv_run(ct);
|
||
|
|
bdirect_read_commit(FB_CC(f)->orig, (byte*)ct->source);
|
||
|
|
f->bstop = ct->dest;
|
||
|
|
}
|
||
|
|
while (!(flags & CONV_DEST_END));
|
||
|
|
return (f->bstop > f->bptr);
|
||
|
|
}
|
||
|
|
|
||
|
|
static void
|
||
|
|
fb_cc_close(struct fastbuf *f)
|
||
|
|
{
|
||
|
|
bflush(FB_CC(f)->orig);
|
||
|
|
xfree(f);
|
||
|
|
}
|
||
|
|
|
||
|
|
struct fastbuf *
|
||
|
|
fb_wrap_charconv_out(struct fastbuf *f, int cs_from, int cs_to)
|
||
|
|
{
|
||
|
|
if (cs_from == cs_to)
|
||
|
|
return f;
|
||
|
|
|
||
|
|
struct fastbuf *g = xmalloc_zero(sizeof(struct fb_charconv));
|
||
|
|
FB_CC(g)->orig = f;
|
||
|
|
conv_init(&FB_CC(g)->ctxt);
|
||
|
|
conv_set_charset(&FB_CC(g)->ctxt, cs_from, cs_to);
|
||
|
|
g->name = "<charconv-out>";
|
||
|
|
g->spout = fb_cc_spout;
|
||
|
|
g->close = fb_cc_close;
|
||
|
|
g->buffer = g->bstop = g->bptr = FB_CC(g)->buf;
|
||
|
|
g->bufend = g->buffer + BUFSIZE;
|
||
|
|
return g;
|
||
|
|
}
|
||
|
|
|
||
|
|
struct fastbuf *
|
||
|
|
fb_wrap_charconv_in(struct fastbuf *f, int cs_from, int cs_to)
|
||
|
|
{
|
||
|
|
if (cs_from == cs_to)
|
||
|
|
return f;
|
||
|
|
|
||
|
|
struct fastbuf *g = xmalloc_zero(sizeof(struct fb_charconv));
|
||
|
|
FB_CC(g)->orig = f;
|
||
|
|
conv_init(&FB_CC(g)->ctxt);
|
||
|
|
conv_set_charset(&FB_CC(g)->ctxt, cs_from, cs_to);
|
||
|
|
g->name = "<charconv-in>";
|
||
|
|
g->refill = fb_cc_refill;
|
||
|
|
g->close = fb_cc_close;
|
||
|
|
g->buffer = g->bstop = g->bptr = FB_CC(g)->buf;
|
||
|
|
g->bufend = g->buffer + BUFSIZE;
|
||
|
|
return g;
|
||
|
|
}
|