-#include "io.h"
+#include "imager.h"
#include "iolayer.h"
+#include "imerror.h"
#include "log.h"
#include <stdlib.h>
#include <stdio.h>
#ifdef _MSC_VER
#include <io.h>
#endif
+#include <string.h>
+#include <errno.h>
+#include "imageri.h"
#define IOL_DEB(x)
char *io_type_names[] = { "FDSEEK", "FDNOSEEK", "BUFFER", "CBSEEK", "CBNOSEEK", "BUFCHAIN" };
+typedef struct io_blink {
+ char buf[BBSIZ];
+ /* size_t cnt; */
+ size_t len; /* How large is this buffer = BBZIS for now */
+ struct io_blink *next;
+ struct io_blink *prev;
+} io_blink;
+
+
+/* Structures that describe callback interfaces */
+
+typedef struct {
+ off_t offset;
+ off_t cpos;
+} io_ex_rseek;
+
+
+typedef struct {
+ off_t offset;
+ off_t cpos;
+ io_blink *head;
+ io_blink *tail;
+ io_blink *cp;
+} io_ex_fseek;
+
+
+typedef struct {
+ off_t offset; /* Offset of the source - not used */
+ off_t length; /* Total length of chain in bytes */
+ io_blink *head; /* Start of chain */
+ io_blink *tail; /* End of chain */
+ off_t tfill; /* End of stream in last link */
+ io_blink *cp; /* Current element of list */
+ off_t cpos; /* Offset within the current */
+ off_t gpos; /* Global position in stream */
+} io_ex_bchain;
+
+typedef struct {
+ off_t offset; /* Offset of the source - not used */
+ off_t cpos; /* Offset within the current */
+} io_ex_buffer;
+
+static void io_obj_setp_buffer(io_obj *io, char *p, size_t len, i_io_closebufp_t closecb, void *closedata);
+static void io_obj_setp_cb2 (io_obj *io, void *p, i_io_readl_t readcb, i_io_writel_t writecb, i_io_seekl_t seekcb, i_io_closel_t closecb, i_io_destroyl_t destroycb);
+
+/* turn current offset, file length, whence and offset into a new offset */
+#define calc_seek_offset(curr_off, length, offset, whence) \
+ (((whence) == SEEK_SET) ? (offset) : \
+ ((whence) == SEEK_CUR) ? (curr_off) + (offset) : \
+ ((whence) == SEEK_END) ? (length) + (offset) : -1)
/*
=head1 NAME
break;
}
- io_glue_DESTROY(ig);
+ io_glue_destroy(ig);
// and much more
=head1 DESCRIPTION
Some of these functions are internal.
-=over 4
+=over
=cut
*/
-
-
+static ssize_t fd_read(io_glue *ig, void *buf, size_t count);
+static ssize_t fd_write(io_glue *ig, const void *buf, size_t count);
+static off_t fd_seek(io_glue *ig, off_t offset, int whence);
+static int fd_close(io_glue *ig);
+static ssize_t fd_size(io_glue *ig);
+static const char *my_strerror(int err);
/*
* Callbacks for sources that cannot seek
ssize_t
realseek_read(io_glue *ig, void *buf, size_t count) {
io_ex_rseek *ier = ig->exdata;
- int fd = (int)ig->source.cb.p;
+ void *p = ig->source.cb.p;
ssize_t rc = 0;
size_t bc = 0;
char *cbuf = buf;
- IOL_DEB( printf("realseek_read: fd = %d, ier->cpos = %ld, buf = %p, count = %d\n", fd, (long) ier->cpos, buf, count) );
- /* Is this a good idea? Would it be better to handle differently? skip handling? */
- while( count!=bc && (rc = ig->source.cb.readcb(fd,cbuf+bc,count-bc))>0 ) bc+=rc;
+ IOL_DEB( printf("realseek_read: buf = %p, count = %d\n",
+ buf, count) );
+ /* Is this a good idea? Would it be better to handle differently?
+ skip handling? */
+ while( count!=bc && (rc = ig->source.cb.readcb(p,cbuf+bc,count-bc))>0 ) {
+ bc+=rc;
+ }
ier->cpos += bc;
IOL_DEB( printf("realseek_read: rc = %d, bc = %d\n", rc, bc) );
- return bc;
+ return rc < 0 ? rc : bc;
}
ssize_t
realseek_write(io_glue *ig, const void *buf, size_t count) {
io_ex_rseek *ier = ig->exdata;
- int fd = (int)ig->source.cb.p;
+ void *p = ig->source.cb.p;
ssize_t rc = 0;
size_t bc = 0;
char *cbuf = (char*)buf;
- IOL_DEB( printf("realseek_write: fd = %d, ier->cpos = %ld, buf = %p, count = %d\n", fd, (long) ier->cpos, buf, count) );
- /* Is this a good idea? Would it be better to handle differently? skip handling? */
+ IOL_DEB( printf("realseek_write: ig = %p, ier->cpos = %ld, buf = %p, "
+ "count = %d\n", ig, (long) ier->cpos, buf, count) );
- while( count!=bc && (rc = ig->source.cb.writecb(fd,cbuf+bc,count-bc))>0 ) bc+=rc;
+ /* Is this a good idea? Would it be better to handle differently?
+ skip handling? */
+ while( count!=bc && (rc = ig->source.cb.writecb(p,cbuf+bc,count-bc))>0 ) {
+ bc+=rc;
+ }
ier->cpos += bc;
IOL_DEB( printf("realseek_write: rc = %d, bc = %d\n", rc, bc) );
- return bc;
+ return rc < 0 ? rc : bc;
}
/*
=item realseek_close(ig)
-Closes a source that can be seeked on. Not sure if this should be an actual close
-or not. Does nothing for now. Should be fixed.
+Closes a source that can be seeked on. Not sure if this should be an
+actual close or not. Does nothing for now. Should be fixed.
ig - data source
-=cut
-*/
+=cut */
static
-void
+int
realseek_close(io_glue *ig) {
mm_log((1, "realseek_close(ig %p)\n", ig));
- /* FIXME: Do stuff here */
+ if (ig->source.cb.closecb)
+ return ig->source.cb.closecb(ig->source.cb.p);
+ else
+ return 0;
}
off_t
realseek_seek(io_glue *ig, off_t offset, int whence) {
/* io_ex_rseek *ier = ig->exdata; Needed later */
- int fd = (int)ig->source.cb.p;
+ void *p = ig->source.cb.p;
int rc;
IOL_DEB( printf("realseek_seek(ig %p, offset %ld, whence %d)\n", ig, (long) offset, whence) );
- rc = lseek(fd, offset, whence);
+ rc = ig->source.cb.seekcb(p, offset, whence);
IOL_DEB( printf("realseek_seek: rc %ld\n", (long) rc) );
return rc;
/* FIXME: How about implementing this offset handling stuff? */
}
+static
+void
+realseek_destroy(io_glue *ig) {
+ io_ex_rseek *ier = ig->exdata;
+
+ if (ig->source.cb.destroycb)
+ ig->source.cb.destroycb(ig->source.cb.p);
+
+ myfree(ier);
+}
+
+/*
+ * Callbacks for sources that are a fixed size buffer
+ */
+
+/*
+=item buffer_read(ig, buf, count)
+
+Does the reading from a buffer source
+
+ ig - io_glue object
+ buf - buffer to return data in
+ count - number of bytes to read into buffer max
+
+=cut
+*/
+
+static
+ssize_t
+buffer_read(io_glue *ig, void *buf, size_t count) {
+ io_ex_buffer *ieb = ig->exdata;
+
+ IOL_DEB( printf("buffer_read: ieb->cpos = %ld, buf = %p, count = %d\n", (long) ieb->cpos, buf, count) );
+
+ if ( ieb->cpos+count > ig->source.buffer.len ) {
+ mm_log((1,"buffer_read: short read: cpos=%d, len=%d, count=%d\n", ieb->cpos, ig->source.buffer.len));
+ count = ig->source.buffer.len - ieb->cpos;
+ }
+
+ memcpy(buf, ig->source.buffer.data+ieb->cpos, count);
+ ieb->cpos += count;
+ IOL_DEB( printf("buffer_read: count = %d\n", count) );
+ return count;
+}
+
+
+/*
+=item buffer_write(ig, buf, count)
+
+Does nothing, returns -1
+
+ ig - io_glue object
+ buf - buffer that contains data
+ count - number of bytes to write
+
+=cut
+*/
+
+static
+ssize_t
+buffer_write(io_glue *ig, const void *buf, size_t count) {
+ mm_log((1, "buffer_write called, this method should never be called.\n"));
+ return -1;
+}
+
+
+/*
+=item buffer_close(ig)
+
+Closes a source that can be seeked on. Not sure if this should be an actual close
+or not. Does nothing for now. Should be fixed.
+
+ ig - data source
+
+=cut
+*/
+
+static
+int
+buffer_close(io_glue *ig) {
+ mm_log((1, "buffer_close(ig %p)\n", ig));
+
+ return 0;
+}
+
+/* buffer_seek(ig, offset, whence)
+Implements seeking for a buffer source.
+ ig - data source
+ offset - offset into stream
+ whence - whence argument a la lseek
+
+=cut
+*/
+
+static
+off_t
+buffer_seek(io_glue *ig, off_t offset, int whence) {
+ io_ex_buffer *ieb = ig->exdata;
+ off_t reqpos =
+ calc_seek_offset(ieb->cpos, ig->source.buffer.len, offset, whence);
+
+ if (reqpos > ig->source.buffer.len) {
+ mm_log((1, "seeking out of readable range\n"));
+ return (off_t)-1;
+ }
+ if (reqpos < 0) {
+ i_push_error(0, "seek before beginning of file");
+ return (off_t)-1;
+ }
+
+ ieb->cpos = reqpos;
+ IOL_DEB( printf("buffer_seek(ig %p, offset %ld, whence %d)\n", ig, (long) offset, whence) );
+
+ return reqpos;
+ /* FIXME: How about implementing this offset handling stuff? */
+}
+
+static
+void
+buffer_destroy(io_glue *ig) {
+ io_ex_buffer *ieb = ig->exdata;
+
+ if (ig->source.buffer.closecb) {
+ mm_log((1,"calling close callback %p for io_buffer\n",
+ ig->source.buffer.closecb));
+ ig->source.buffer.closecb(ig->source.buffer.closedata);
+ }
+ myfree(ieb);
+}
}
+
+/*
+=item io_bchain_destroy()
+
+frees all resources used by a buffer chain.
+
+=cut
+*/
+
+void
+io_destroy_bufchain(io_ex_bchain *ieb) {
+ io_blink *cp;
+ mm_log((1, "io_destroy_bufchain(ieb %p)\n", ieb));
+ cp = ieb->head;
+
+ while(cp) {
+ io_blink *t = cp->next;
+ myfree(cp);
+ cp = t;
+ }
+}
+
+
+
+
/*
static
*/
static
-void
+int
bufchain_close(io_glue *ig) {
mm_log((1, "bufchain_close(ig %p)\n",ig));
IOL_DEB( printf("bufchain_close(ig %p)\n", ig) );
- /* FIXME: Commit a seek point here */
-
+
+ return 0;
}
off_t
bufchain_seek(io_glue *ig, off_t offset, int whence) {
io_ex_bchain *ieb = ig->exdata;
- io_blink *ib = NULL;
int wrlen;
- off_t cof = 0;
- off_t scount = offset;
+ off_t scount = calc_seek_offset(ieb->gpos, ieb->length, offset, whence);
off_t sk;
mm_log((1, "bufchain_seek(ig %p, offset %ld, whence %d)\n", ig, offset, whence));
- switch (whence) {
- case SEEK_SET: /* SEEK_SET = 0, From the top */
- ieb->cp = ieb->head;
- ieb->cpos = 0;
- ieb->gpos = 0;
-
- while( scount ) {
- int clen = (ieb->cp == ieb->tail) ? ieb->tfill : ieb->cp->len;
- if (clen == ieb->cpos) {
- if (ieb->cp == ieb->tail) break; /* EOF */
- ieb->cp = ieb->cp->next;
- ieb->cpos = 0;
- clen = (ieb->cp == ieb->tail) ? ieb->tfill : ieb->cp->len;
- }
-
- sk = clen - ieb->cpos;
- sk = sk > scount ? scount : sk;
-
- scount -= sk;
- ieb->cpos += sk;
- ieb->gpos += sk;
- }
+ if (scount < 0) {
+ i_push_error(0, "invalid whence supplied or seek before start of file");
+ return (off_t)-1;
+ }
- wrlen = scount;
-
- if (wrlen > 0) {
- /*
- * extending file - get ieb into consistent state and then
- * call write which will get it to the correct position
- */
- char TB[BBSIZ];
- memset(TB, 0, BBSIZ);
- ieb->gpos = ieb->length;
- ieb->cpos = ieb->tfill;
-
- while(wrlen > 0) {
- ssize_t rc, wl = min(wrlen, BBSIZ);
- mm_log((1, "bufchain_seek: wrlen = %d, wl = %d\n", wrlen, wl));
- rc = bufchain_write( ig, TB, wl );
- if (rc != wl) m_fatal(0, "bufchain_seek: Unable to extend file\n");
- wrlen -= rc;
- }
+ ieb->cp = ieb->head;
+ ieb->cpos = 0;
+ ieb->gpos = 0;
+
+ while( scount ) {
+ int clen = (ieb->cp == ieb->tail) ? ieb->tfill : ieb->cp->len;
+ if (clen == ieb->cpos) {
+ if (ieb->cp == ieb->tail) break; /* EOF */
+ ieb->cp = ieb->cp->next;
+ ieb->cpos = 0;
+ clen = (ieb->cp == ieb->tail) ? ieb->tfill : ieb->cp->len;
}
- break;
-
- case SEEK_CUR:
- m_fatal(123, "SEEK_CUR IS NOT IMPLEMENTED\n");
-
- /*
- case SEEK_CUR:
- ib = ieb->cp;
- if (cof < 0) {
- cof += ib->cpos;
- cpos = 0;
- while(cof < 0 && ib->prev) {
- ib = ib->prev;
- cof += ib->len;
- }
- */
+ sk = clen - ieb->cpos;
+ sk = sk > scount ? scount : sk;
- case SEEK_END: /* SEEK_END = 2 */
- if (cof>0) m_fatal(0, "bufchain_seek: SEEK_END + %d : Extending files via seek not supported!\n", cof);
+ scount -= sk;
+ ieb->cpos += sk;
+ ieb->gpos += sk;
+ }
+
+ wrlen = scount;
- ieb->cp = ieb->tail;
+ if (wrlen > 0) {
+ /*
+ * extending file - get ieb into consistent state and then
+ * call write which will get it to the correct position
+ */
+ char TB[BBSIZ];
+ memset(TB, 0, BBSIZ);
+ ieb->gpos = ieb->length;
ieb->cpos = ieb->tfill;
- if (cof<0) {
- cof += ieb->cpos;
- ieb->cpos = 0;
-
- while(cof<0 && ib->prev) {
- ib = ib->prev;
- cof += ib->len;
- }
-
- if (cof<0) m_fatal(0, "bufchain_seek: Tried to seek before start of file\n");
- ieb->gpos = ieb->length+offset;
- ieb->cpos = cof;
+ while(wrlen > 0) {
+ ssize_t rc, wl = i_min(wrlen, BBSIZ);
+ mm_log((1, "bufchain_seek: wrlen = %d, wl = %d\n", wrlen, wl));
+ rc = bufchain_write( ig, TB, wl );
+ if (rc != wl) i_fatal(0, "bufchain_seek: Unable to extend file\n");
+ wrlen -= rc;
}
- break;
- default:
- m_fatal(0, "bufchain_seek: Unhandled seek request: whence = %d\n", whence );
}
mm_log((2, "bufchain_seek: returning ieb->gpos = %d\n", ieb->gpos));
return ieb->gpos;
}
+static
+void
+bufchain_destroy(io_glue *ig) {
+ io_ex_bchain *ieb = ig->exdata;
+ io_destroy_bufchain(ieb);
-
-
+ myfree(ieb);
+}
/*
* Methods for setting up data source
=cut
*/
-void
-io_obj_setp_buffer(io_obj *io, void *p, size_t len) {
- io->buffer.type = BUFFER;
- io->buffer.c = (char*) p;
- io->buffer.len = len;
+static void
+io_obj_setp_buffer(io_obj *io, char *p, size_t len, i_io_closebufp_t closecb,
+ void *closedata) {
+ io->buffer.type = BUFFER;
+ io->buffer.data = p;
+ io->buffer.len = len;
+ io->buffer.closecb = closecb;
+ io->buffer.closedata = closedata;
}
-/*
-=item io_obj_setp_cbuf(io, p)
-
-Sets an io_object for reading/writing from a buffer source
-
- io - io object that describes a source
- p - pointer to buffer
- len - length of buffer
-
-=cut
-*/
-
-void
-io_obj_setp_bufchain(io_obj *io) {
- io->type = BUFCHAIN;
-}
-
/*
-=item io_obj_setp_cb(io, p, readcb, writecb, seekcb)
+=item io_obj_setp_cb2(io, p, readcb, writecb, seekcb, closecb, destroycb)
Sets an io_object for reading from a source that uses callbacks
io - io object that describes a source
- p - pointer to data for callbacks
- readcb - read callback to read from source
- writecb - write callback to write to source
- seekcb - seek callback to seek on source
+ p - pointer to data for callbacks
+ readcb - read callback to read from source
+ writecb - write callback to write to source
+ seekcb - seek callback to seek on source
+ closecb - flush any pending data
+ destroycb - release any extra resources
=cut
*/
-void
-io_obj_setp_cb(io_obj *io, void *p, readl readcb, writel writecb, seekl seekcb) {
- io->cb.type = CBSEEK;
- io->cb.p = p;
- io->cb.readcb = readcb;
- io->cb.writecb = writecb;
- io->cb.seekcb = seekcb;
+static void
+io_obj_setp_cb2(io_obj *io, void *p, i_io_readl_t readcb, i_io_writel_t writecb, i_io_seekl_t seekcb, i_io_closel_t closecb, i_io_destroyl_t destroycb) {
+ io->cb.type = CBSEEK;
+ io->cb.p = p;
+ io->cb.readcb = readcb;
+ io->cb.writecb = writecb;
+ io->cb.seekcb = seekcb;
+ io->cb.closecb = closecb;
+ io->cb.destroycb = destroycb;
}
/*
=item io_glue_commit_types(ig)
-Creates buffers and initializes structures to read with the chosen interface.
-
- ig - io_glue object
+This is now effectively a no-op.
=cut
*/
void
io_glue_commit_types(io_glue *ig) {
io_type inn = ig->source.type;
-
+
mm_log((1, "io_glue_commit_types(ig %p)\n", ig));
mm_log((1, "io_glue_commit_types: source type %d (%s)\n", inn, io_type_names[inn]));
-
- switch (inn) {
- case BUFCHAIN:
- {
- io_ex_bchain *ieb = mymalloc(sizeof(io_ex_bchain));
-
- ieb->offset = 0;
- ieb->length = 0;
- ieb->cpos = 0;
- ieb->gpos = 0;
- ieb->tfill = 0;
-
- ieb->head = io_blink_new();
- ieb->cp = ieb->head;
- ieb->tail = ieb->head;
-
- ig->exdata = ieb;
- ig->readcb = bufchain_read;
- ig->writecb = bufchain_write;
- ig->seekcb = bufchain_seek;
- ig->closecb = bufchain_close;
- }
- break;
- case CBSEEK:
- default:
- {
- io_ex_rseek *ier = mymalloc(sizeof(io_ex_rseek));
-
- ier->offset = 0;
- ier->cpos = 0;
-
- ig->exdata = ier;
- ig->readcb = realseek_read;
- ig->writecb = realseek_write;
- ig->seekcb = realseek_seek;
- ig->closecb = realseek_close;
- }
+
+ if (ig->flags & 0x01) {
+ mm_log((1, "io_glue_commit_types: type already set up\n"));
+ return;
}
+
+ ig->flags |= 0x01; /* indicate source has been setup already */
}
/*
io_glue *
io_new_bufchain() {
- io_glue *ig = mymalloc(sizeof(io_glue));
- io_obj_setp_bufchain(&ig->source);
+ io_glue *ig;
+ io_ex_bchain *ieb = mymalloc(sizeof(io_ex_bchain));
+
+ mm_log((1, "io_new_bufchain()\n"));
+
+ ig = mymalloc(sizeof(io_glue));
+ memset(ig, 0, sizeof(*ig));
+ ig->source.type = BUFCHAIN;
+
+ ieb->offset = 0;
+ ieb->length = 0;
+ ieb->cpos = 0;
+ ieb->gpos = 0;
+ ieb->tfill = 0;
+
+ ieb->head = io_blink_new();
+ ieb->cp = ieb->head;
+ ieb->tail = ieb->head;
+
+ ig->exdata = ieb;
+ ig->readcb = bufchain_read;
+ ig->writecb = bufchain_write;
+ ig->seekcb = bufchain_seek;
+ ig->closecb = bufchain_close;
+ ig->destroycb = bufchain_destroy;
+
+ return ig;
+}
+
+/*
+=item io_new_buffer(data, len)
+
+Returns a new io_glue object that has the source defined as reading
+from specified buffer. Note that the buffer is not copied.
+
+ data - buffer to read from
+ len - length of buffer
+
+=cut
+*/
+
+io_glue *
+io_new_buffer(char *data, size_t len, i_io_closebufp_t closecb, void *closedata) {
+ io_glue *ig;
+ io_ex_buffer *ieb = mymalloc(sizeof(io_ex_buffer));
+
+ mm_log((1, "io_new_buffer(data %p, len %d, closecb %p, closedata %p)\n", data, len, closecb, closedata));
+
+ ig = mymalloc(sizeof(io_glue));
+ memset(ig, 0, sizeof(*ig));
+ io_obj_setp_buffer(&ig->source, data, len, closecb, closedata);
+ ig->flags = 0;
+
+ ieb->offset = 0;
+ ieb->cpos = 0;
+
+ ig->exdata = ieb;
+ ig->readcb = buffer_read;
+ ig->writecb = buffer_write;
+ ig->seekcb = buffer_seek;
+ ig->closecb = buffer_close;
+ ig->destroycb = buffer_destroy;
+
return ig;
}
io_glue *
io_new_fd(int fd) {
- io_glue *ig = mymalloc(sizeof(io_glue));
+ io_glue *ig;
+
+ mm_log((1, "io_new_fd(fd %d)\n", fd));
+
+ ig = mymalloc(sizeof(io_glue));
memset(ig, 0, sizeof(*ig));
-#ifdef _MSC_VER
- io_obj_setp_cb(&ig->source, (void*)fd, _read, _write, _lseek);
-#else
- io_obj_setp_cb(&ig->source, (void*)fd, read, write, lseek);
-#endif
+ ig->source.type = FDSEEK;
+ ig->source.fdseek.fd = fd;
+ ig->flags = 0;
+
+ ig->exdata = NULL;
+ ig->readcb = fd_read;
+ ig->writecb = fd_write;
+ ig->seekcb = fd_seek;
+ ig->closecb = fd_close;
+ ig->sizecb = fd_size;
+ ig->destroycb = NULL;
+
+ mm_log((1, "(%p) <- io_new_fd\n", ig));
return ig;
}
+io_glue *io_new_cb(void *p, i_io_readl_t readcb, i_io_writel_t writecb,
+ i_io_seekl_t seekcb, i_io_closel_t closecb,
+ i_io_destroyl_t destroycb) {
+ io_glue *ig;
+ io_ex_rseek *ier = mymalloc(sizeof(io_ex_rseek));
+
+ mm_log((1, "io_new_cb(p %p, readcb %p, writecb %p, seekcb %p, closecb %p, "
+ "destroycb %p)\n", p, readcb, writecb, seekcb, closecb, destroycb));
+ ig = mymalloc(sizeof(io_glue));
+ memset(ig, 0, sizeof(*ig));
+ io_obj_setp_cb2(&ig->source, p, readcb, writecb, seekcb, closecb, destroycb);
+ mm_log((1, "(%p) <- io_new_cb\n", ig));
+ ier->offset = 0;
+ ier->cpos = 0;
+
+ ig->exdata = ier;
+ ig->readcb = realseek_read;
+ ig->writecb = realseek_write;
+ ig->seekcb = realseek_seek;
+ ig->closecb = realseek_close;
+ ig->destroycb = realseek_destroy;
+
+ return ig;
+}
/*
=item io_slurp(ig)
io_type inn = ig->source.type;
if ( inn != BUFCHAIN ) {
- m_fatal(0, "io_slurp: called on a source that is not from a bufchain\n");
+ i_fatal(0, "io_slurp: called on a source that is not from a bufchain\n");
}
ieb = ig->exdata;
rc = bufchain_read(ig, cc, ieb->length);
if (rc != ieb->length)
- m_fatal(1, "io_slurp: bufchain_read returned an incomplete read: rc = %d, request was %d\n", rc, ieb->length);
+ i_fatal(1, "io_slurp: bufchain_read returned an incomplete read: rc = %d, request was %d\n", rc, ieb->length);
return rc;
}
+/*
+=item fd_read(ig, buf, count)
+
+=cut
+*/
+static ssize_t fd_read(io_glue *ig, void *buf, size_t count) {
+ ssize_t result;
+#ifdef _MSC_VER
+ result = _read(ig->source.fdseek.fd, buf, count);
+#else
+ result = read(ig->source.fdseek.fd, buf, count);
+#endif
+
+ /* 0 is valid - means EOF */
+ if (result < 0) {
+ i_push_errorf(0, "read() failure: %s (%d)", my_strerror(errno), errno);
+ }
+
+ return result;
+}
+
+static ssize_t fd_write(io_glue *ig, const void *buf, size_t count) {
+ ssize_t result;
+#ifdef _MSC_VER
+ result = _write(ig->source.fdseek.fd, buf, count);
+#else
+ result = write(ig->source.fdseek.fd, buf, count);
+#endif
+
+ if (result <= 0) {
+ i_push_errorf(errno, "write() failure: %s (%d)", my_strerror(errno), errno);
+ }
+
+ return result;
+}
+
+static off_t fd_seek(io_glue *ig, off_t offset, int whence) {
+ off_t result;
+#ifdef _MSC_VER
+ result = _lseek(ig->source.fdseek.fd, offset, whence);
+#else
+ result = lseek(ig->source.fdseek.fd, offset, whence);
+#endif
+
+ if (result == (off_t)-1) {
+ i_push_errorf(errno, "lseek() failure: %s (%d)", my_strerror(errno), errno);
+ }
+
+ return result;
+}
+
+static int fd_close(io_glue *ig) {
+ /* no, we don't close it */
+ return 0;
+}
+
+static ssize_t fd_size(io_glue *ig) {
+ mm_log((1, "fd_size(ig %p) unimplemented\n", ig));
+
+ return -1;
+}
/*
-=item io_glue_DESTROY(ig)
+=item io_glue_destroy(ig)
A destructor method for io_glue objects. Should clean up all related buffers.
Might leave us with a dangling pointer issue on some buffers.
*/
void
-io_glue_DESTROY(io_glue *ig) {
- free(ig);
- /* FIXME: Handle extradata and such */
+io_glue_destroy(io_glue *ig) {
+ mm_log((1, "io_glue_DESTROY(ig %p)\n", ig));
+
+ if (ig->destroycb)
+ ig->destroycb(ig);
+
+ myfree(ig);
+}
+
+/*
+=back
+
+=head1 INTERNAL FUNCTIONS
+
+=over
+
+=item my_strerror
+
+Calls strerror() and ensures we don't return NULL.
+
+On some platforms it's possible for strerror() to return NULL, this
+wrapper ensures we only get non-NULL values.
+
+=cut
+*/
+
+static
+const char *my_strerror(int err) {
+ const char *result = strerror(err);
+
+ if (!result)
+ result = "Unknown error";
+
+ return result;
}
+
+/*
+=back
+
+=head1 AUTHOR
+
+Arnar M. Hrafnkelsson <addi@umich.edu>
+
+=head1 SEE ALSO
+
+Imager(3)
+
+=cut
+*/
projects / imager.git / blobdiff