From a8d65409decc86cf8d9f9ebadea28be551b3a4d2 Mon Sep 17 00:00:00 2001 From: Not Zed Date: Tue, 5 Dec 2000 11:50:32 +0000 Subject: stream_flush does make sense for a substream afterall (if you have a 2000-12-05 Not Zed * camel-seekable-substream.c (stream_flush): stream_flush does make sense for a substream afterall (if you have a stream_write). (stream_write): Implement this. (stream_seek): Change the STREAM_END behaviour to be more sane. if bounded go from the end of the bound, if unbounded, go from the end of the parent stream. * camel-stream-mem.c (stream_read): Dont return error if reading past the end of data, just return 0. * camel-stream-fs.c (camel_stream_fs_init): Initialise the stream to be unbound. (stream_seek): Fix the logic when seeking from the end of an unbounded stream. (camel_stream_fs_new_with_fd): If the fd is invalid (-1), then return NULL immediately. (stream_seek): Range check a SEEK_END so it fits within bound_start. 2000-12-01 Not Zed * tests/lib/folders.c (test_folder_basic): New test to perform basic store operations on folders (taken from folders/test1). (test_folder_message_ops): Tkane the guts out of folders/test2. svn path=/trunk/; revision=6790 --- camel/tests/stream/test1.c | 119 +++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 119 insertions(+) create mode 100644 camel/tests/stream/test1.c (limited to 'camel/tests/stream/test1.c') diff --git a/camel/tests/stream/test1.c b/camel/tests/stream/test1.c new file mode 100644 index 0000000000..452d45274f --- /dev/null +++ b/camel/tests/stream/test1.c @@ -0,0 +1,119 @@ +/* + test ... camelstreamfs */ + +#include "camel-test.h" +#include "streams.h" + +#include +#include +#include + +#include "camel/camel-stream-fs.h" + +int main(int argc, char **argv) +{ + CamelSeekableStream *ss = NULL; + int i; + int fd = -1; + struct stat st; + int size; + char buffer[1024]; + + camel_test_init(argc, argv); + + camel_test_start("CamelStream fs, open, seek, read, write, eos"); + for (i=0;i<2;i++) { + + (void)unlink("stream.txt"); + + push("trying to open a nonexistant stream, method %d", i); + switch(i) { + case 0: + ss = (CamelSeekableStream *)camel_stream_fs_new_with_name("stream.txt", O_RDWR, 0); + break; + case 1: + fd = open("stream.txt", O_RDWR, 0); + ss = (CamelSeekableStream *)camel_stream_fs_new_with_fd(fd); + break; + } + check(ss == NULL && errno == ENOENT); + check(stat("stream.txt", &st) == -1 && errno == ENOENT); + pull(); + + push("Creating stream using method %d", i); + switch(i) { + case 0: + ss = (CamelSeekableStream *)camel_stream_fs_new_with_name("stream.txt", O_CREAT|O_RDWR|O_TRUNC, 0600); + fd = ((CamelStreamFs *)ss)->fd; + break; + case 1: + fd = open("stream.txt", O_CREAT|O_RDWR|O_TRUNC, 0600); + ss = (CamelSeekableStream *)camel_stream_fs_new_with_fd(fd); + break; + } + check(ss != NULL); + check(stat("stream.txt", &st) == 0 && (st.st_mode&0777) == 0600 && S_ISREG(st.st_mode) && st.st_size == 0); + pull(); + + test_stream_seekable_writepart(ss); + test_stream_seekable_readpart(ss); + + push("getting filesize"); + check(stat("stream.txt", &st) == 0 && (st.st_mode&0777) == 0600 && S_ISREG(st.st_mode)); + size = st.st_size; + pull(); + + push("checking close closes"); + check_unref(ss, 1); + check(close(fd) == -1); + pull(); + + push("re-opening stream"); + switch(i) { + case 0: + ss = (CamelSeekableStream *)camel_stream_fs_new_with_name("stream.txt", O_RDWR, 0); + fd = ((CamelStreamFs *)ss)->fd; + break; + case 1: + fd = open("stream.txt", O_RDWR, 0); + ss = (CamelSeekableStream *)camel_stream_fs_new_with_fd(fd); + break; + } + check(ss != NULL); + check(stat("stream.txt", &st) == 0 && (st.st_mode&0777) == 0600 && S_ISREG(st.st_mode) && st.st_size == size); + + test_stream_seekable_readpart(ss); + + check_unref(ss, 1); + check(close(fd) == -1); + pull(); + + push("re-opening stream with truncate"); + switch(i) { + case 0: + ss = (CamelSeekableStream *)camel_stream_fs_new_with_name("stream.txt", O_RDWR|O_TRUNC, 0); + fd = ((CamelStreamFs *)ss)->fd; + break; + case 1: + fd = open("stream.txt", O_RDWR|O_TRUNC, 0); + ss = (CamelSeekableStream *)camel_stream_fs_new_with_fd(fd); + break; + } + check(ss != NULL); + check(stat("stream.txt", &st) == 0 && (st.st_mode&0777) == 0600 && S_ISREG(st.st_mode) && st.st_size == 0); + + /* read has to return 0 before eos is set */ + check(camel_stream_read(CAMEL_STREAM(ss), buffer, 1) == 0); + check(camel_stream_eos(CAMEL_STREAM(ss))); + + check_unref(ss, 1); + check(close(fd) == -1); + pull(); + + (void)unlink("stream.txt"); + } + + camel_test_end(); + + return 0; +} -- cgit v1.2.3