a8d65409de
2000-12-05 Not Zed <NotZed@HelixCode.com> * 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 <NotZed@HelixCode.com> * 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
120 lines
2.9 KiB
C
120 lines
2.9 KiB
C
/*
|
|
test ... camelstreamfs */
|
|
|
|
#include "camel-test.h"
|
|
#include "streams.h"
|
|
|
|
#include <errno.h>
|
|
#include <sys/stat.h>
|
|
#include <unistd.h>
|
|
|
|
#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;
|
|
}
|