open_memstream.c 1.7 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889
  1. #include "stdio_impl.h"
  2. #include <errno.h>
  3. #include <limits.h>
  4. #include <string.h>
  5. struct cookie {
  6. char **bufp;
  7. size_t *sizep;
  8. size_t pos;
  9. char *buf;
  10. size_t len;
  11. size_t space;
  12. };
  13. static off_t ms_seek(FILE *f, off_t off, int whence)
  14. {
  15. ssize_t base;
  16. struct cookie *c = f->cookie;
  17. if (whence>2U) {
  18. fail:
  19. errno = EINVAL;
  20. return -1;
  21. }
  22. base = (size_t [3]){0, c->pos, c->len}[whence];
  23. if (off < -base || off > SSIZE_MAX-base) goto fail;
  24. return c->pos = base+off;
  25. }
  26. static size_t ms_write(FILE *f, const unsigned char *buf, size_t len)
  27. {
  28. struct cookie *c = f->cookie;
  29. size_t len2 = f->wpos - f->wbase;
  30. char *newbuf;
  31. if (len2) {
  32. f->wpos = f->wbase;
  33. if (ms_write(f, f->wbase, len2) < len2) return 0;
  34. }
  35. if (len + c->pos >= c->space) {
  36. len2 = 2*c->space+1 | c->pos+len+1;
  37. newbuf = realloc(c->buf, len2);
  38. if (!newbuf) return 0;
  39. *c->bufp = c->buf = newbuf;
  40. memset(c->buf + c->space, 0, len2 - c->space);
  41. c->space = len2;
  42. }
  43. memcpy(c->buf+c->pos, buf, len);
  44. c->pos += len;
  45. if (c->pos >= c->len) c->len = c->pos;
  46. *c->sizep = c->pos;
  47. return len;
  48. }
  49. static int ms_close(FILE *f)
  50. {
  51. return 0;
  52. }
  53. FILE *open_memstream(char **bufp, size_t *sizep)
  54. {
  55. FILE *f;
  56. struct cookie *c;
  57. if (!(f=malloc(sizeof *f + sizeof *c + BUFSIZ))) return 0;
  58. memset(f, 0, sizeof *f + sizeof *c);
  59. f->cookie = c = (void *)(f+1);
  60. c->bufp = bufp;
  61. c->sizep = sizep;
  62. c->pos = c->len = c->space = 0;
  63. c->buf = 0;
  64. f->flags = F_NORD;
  65. f->fd = -1;
  66. f->buf = (void *)(c+1);
  67. f->buf_size = BUFSIZ;
  68. f->lbf = EOF;
  69. f->write = ms_write;
  70. f->seek = ms_seek;
  71. f->close = ms_close;
  72. if (!libc.threaded) f->lock = -1;
  73. OFLLOCK();
  74. f->next = libc.ofl_head;
  75. if (libc.ofl_head) libc.ofl_head->prev = f;
  76. libc.ofl_head = f;
  77. OFLUNLOCK();
  78. return f;
  79. }