summaryrefslogtreecommitdiffhomepage
diff options
context:
space:
mode:
authorRobert James Kaes <rjkaes@users.sourceforge.net>2001-11-25 22:05:42 +0000
committerRobert James Kaes <rjkaes@users.sourceforge.net>2001-11-25 22:05:42 +0000
commite9cfd1f82e720be1854b0f72d4e6f041fe991dee (patch)
tree7f10d7a2960d615516c93e5696b3b1fcfd957863
parentb0748328d77ff60e91ad6d35dce4a7e075e2d2f0 (diff)
makenewline() now copies the data into the structure rather than just
storing the pointer to the data. add_to_buffer() is now exported. Renamed writebuff() and readbuff() to write_buffer() and read_buffer().
-rw-r--r--src/buffer.c41
-rw-r--r--src/buffer.h12
2 files changed, 26 insertions, 27 deletions
diff --git a/src/buffer.c b/src/buffer.c
index cfcdada..faf871d 100644
--- a/src/buffer.c
+++ b/src/buffer.c
@@ -1,4 +1,4 @@
-/* $Id: buffer.c,v 1.16 2001-11-22 00:31:10 rjkaes Exp $
+/* $Id: buffer.c,v 1.17 2001-11-25 22:05:42 rjkaes Exp $
*
* The buffer used in each connection is a linked list of lines. As the lines
* are read in and written out the buffer expands and contracts. Basically,
@@ -8,7 +8,7 @@
* functions act on each end (the names are taken from what Perl uses to act on
* the ends of an array. :)
*
- * Copyright (C) 1999 Robert James Kaes (rjkaes@flarenet.com)
+ * Copyright (C) 1999,2001 Robert James Kaes (rjkaes@users.sourceforge.net)
*
* This program is free software; you can redistribute it and/or modify it
* under the terms of the GNU General Public License as published by the
@@ -39,9 +39,8 @@ struct bufline_s {
/*
* Take a string of data and a length and make a new line which can be added
- * to the buffer. We don't make a copy of the data, but simply copy the
- * pointer into the structure. In other words, when you insert data into the
- * buffer, the buffer becomes responsible for freeing it.
+ * to the buffer. The data IS copied, so make sure if you allocated your
+ * data buffer on the heap, delete it because you now have TWO copies.
*/
static struct bufline_s *
makenewline(unsigned char *data, size_t length)
@@ -54,7 +53,13 @@ makenewline(unsigned char *data, size_t length)
if (!(newline = safemalloc(sizeof(struct bufline_s))))
return NULL;
- newline->string = data;
+ if (!(newline->string = safemalloc(length))) {
+ safefree(newline);
+ return NULL;
+ }
+
+ memcpy(newline->string, data, length);
+
newline->next = NULL;
newline->length = length;
@@ -123,9 +128,9 @@ delete_buffer(struct buffer_s *buffptr)
}
/*
- * Push a new line on to the end of the buffer
+ * Push a new line on to the end of the buffer.
*/
-static int
+int
add_to_buffer(struct buffer_s *buffptr, unsigned char *data, size_t length)
{
struct bufline_s *newline;
@@ -184,11 +189,10 @@ remove_from_buffer(struct buffer_s *buffptr)
*/
#define READ_BUFFER_SIZE (1024 * 2)
ssize_t
-readbuff(int fd, struct buffer_s * buffptr)
+read_buffer(int fd, struct buffer_s * buffptr)
{
ssize_t bytesin;
- unsigned char *buffer;
- unsigned char *newbuffer;
+ unsigned char buffer[READ_BUFFER_SIZE];
assert(fd >= 0);
assert(buffptr != NULL);
@@ -196,20 +200,10 @@ readbuff(int fd, struct buffer_s * buffptr)
if (BUFFER_SIZE(buffptr) >= READ_BUFFER_SIZE)
return 0;
- buffer = safemalloc(READ_BUFFER_SIZE);
- if (!buffer)
- return 0;
-
bytesin = read(fd, buffer, READ_BUFFER_SIZE - BUFFER_SIZE(buffptr));
if (bytesin > 0) {
- newbuffer = saferealloc(buffer, bytesin);
- if (!newbuffer) {
- safefree(buffer);
- return 0;
- }
-
- if (add_to_buffer(buffptr, newbuffer, bytesin) < 0) {
+ if (add_to_buffer(buffptr, buffer, bytesin) < 0) {
log_message(LOG_ERR,
"readbuff: add_to_buffer() error.");
return -1;
@@ -217,7 +211,6 @@ readbuff(int fd, struct buffer_s * buffptr)
return bytesin;
} else {
- safefree(buffer);
if (bytesin == 0) {
/* connection was closed by client */
return -1;
@@ -247,7 +240,7 @@ readbuff(int fd, struct buffer_s * buffptr)
* Takes a connection and returns the number of bytes written.
*/
ssize_t
-writebuff(int fd, struct buffer_s * buffptr)
+write_buffer(int fd, struct buffer_s * buffptr)
{
ssize_t bytessent;
struct bufline_s *line;
diff --git a/src/buffer.h b/src/buffer.h
index 825f643..0c2506c 100644
--- a/src/buffer.h
+++ b/src/buffer.h
@@ -1,4 +1,4 @@
-/* $Id: buffer.h,v 1.6 2001-11-22 00:31:10 rjkaes Exp $
+/* $Id: buffer.h,v 1.7 2001-11-25 22:05:42 rjkaes Exp $
*
* See 'buffer.c' for a detailed description.
*
@@ -36,7 +36,13 @@ struct buffer_s {
extern struct buffer_s *new_buffer(void);
extern void delete_buffer(struct buffer_s *buffptr);
-extern ssize_t readbuff(int fd, struct buffer_s *buffptr);
-extern ssize_t writebuff(int fd, struct buffer_s *buffptr);
+/*
+ * Add a new line to the given buffer. The data IS copied into the structure.
+ */
+extern int add_to_buffer(struct buffer_s *buffptr, unsigned char *data,
+ size_t length);
+
+extern ssize_t read_buffer(int fd, struct buffer_s *buffptr);
+extern ssize_t write_buffer(int fd, struct buffer_s *buffptr);
#endif /* __BUFFER_H_ */