Added file I/O and file access API

git-svn-id: http://svn.pjsip.org/repos/pjproject/main@18 74dad513-b988-da41-8d7b-12977e46ad98

3 files changed, 206 insertions, 5 deletions

diff --git a/pjlib/src/pjlib-test/file.c b/pjlib/src/pjlib-test/file.c
new file mode 100644
index 00000000..aa863506
--- /dev/null
+++ b/pjlib/src/pjlib-test/file.c
@@ -0,0 +1,192 @@
+/* $Id$ */

+#include "test.h"

+#include <pjlib.h>

+

+#if INCLUDE_FILE_TEST

+

+#define FILENAME                "testfil1.txt"

+#define NEWNAME                 "testfil2.txt"

+#define INCLUDE_FILE_TIME_TEST  0

+

+static char buffer[11] = "Hello world";

+

+int file_test(void)

+{

+    enum { FILE_MAX_AGE = 1000 };

+    pj_oshandle_t fd = 0;

+    pj_status_t status;

+    char readbuf[sizeof(buffer)+16];

+    pj_file_stat stat;

+    pj_time_val start_time;

+    pj_ssize_t size;

+    pj_off_t pos;

+

+    PJ_LOG(3,("", "..file io test.."));

+

+    /* Get time. */

+    pj_gettimeofday(&start_time);

+

+    /* Delete original file if exists. */

+    if (pj_file_exists(FILENAME))

+        pj_file_delete(FILENAME);

+

+    /*

+     * Write data to the file.

+     */

+    status = pj_file_open(NULL, FILENAME, PJ_O_WRONLY, &fd);

+    if (status != PJ_SUCCESS) {

+        app_perror("...file_open() error", status);

+        return -10;

+    }

+

+    size = sizeof(buffer);

+    status = pj_file_write(fd, buffer, &size);

+    if (status != PJ_SUCCESS) {

+        app_perror("...file_write() error", status);

+        pj_file_close(fd);

+        return -20;

+    }

+    if (size != sizeof(buffer))

+        return -25;

+

+    status = pj_file_close(fd);

+    if (status != PJ_SUCCESS) {

+        app_perror("...file_close() error", status);

+        return -30;

+    }

+

+    /* Check the file existance and size. */

+    if (!pj_file_exists(FILENAME))

+        return -40;

+

+    if (pj_file_size(FILENAME) != sizeof(buffer))

+        return -50;

+

+    /* Get file stat. */

+    status = pj_file_getstat(FILENAME, &stat);

+    if (status != PJ_SUCCESS)

+        return -60;

+

+    /* Check stat size. */

+    if (stat.size != sizeof(buffer))

+        return -70;

+

+    /* Check file creation time >= start_time. */

+    if (!PJ_TIME_VAL_GTE(stat.ctime, start_time))

+#if INCLUDE_FILE_TIME_TEST

+        return -80;

+    /* Check file creation time is not much later. */

+    PJ_TIME_VAL_SUB(stat.ctime, start_time);

+    if (stat.ctime.sec > FILE_MAX_AGE)

+        return -90;

+

+    /* Check file modification time >= start_time. */

+    if (!PJ_TIME_VAL_GTE(stat.mtime, start_time))

+        return -80;

+    /* Check file modification time is not much later. */

+    PJ_TIME_VAL_SUB(stat.mtime, start_time);

+    if (stat.mtime.sec > FILE_MAX_AGE)

+        return -90;

+

+    /* Check file access time >= start_time. */

+    if (!PJ_TIME_VAL_GTE(stat.atime, start_time))

+        return -80;

+    /* Check file access time is not much later. */

+    PJ_TIME_VAL_SUB(stat.atime, start_time);

+    if (stat.atime.sec > FILE_MAX_AGE)

+        return -90;

+#endif

+

+    /*

+     * Re-open the file and read data.

+     */

+    status = pj_file_open(NULL, FILENAME, PJ_O_RDONLY, &fd);

+    if (status != PJ_SUCCESS) {

+        app_perror("...file_open() error", status);

+        return -100;

+    }

+

+    size = 0;

+    while (size < sizeof(readbuf)) {

+        pj_ssize_t read;

+        read = 1;

+        status = pj_file_read(fd, &readbuf[size], &read);

+        if (status != PJ_SUCCESS) {

+            app_perror("...file_read() error", status);

+            return -110;

+        }

+        if (read == 0) {

+            // EOF

+            break;

+        }

+        size += read;

+    }

+

+    if (size != sizeof(buffer))

+        return -120;

+

+    /*

+    if (!pj_file_eof(fd, PJ_O_RDONLY))

+        return -130;

+     */

+

+    if (pj_memcmp(readbuf, buffer, size) != 0)

+        return -140;

+

+    /* Seek test. */

+    status = pj_file_setpos(fd, 4, PJ_SEEK_SET);

+    if (status != PJ_SUCCESS) {

+        app_perror("...file_setpos() error", status);

+        return -141;

+    }

+

+    /* getpos test. */

+    status = pj_file_getpos(fd, &pos);

+    if (status != PJ_SUCCESS) {

+        app_perror("...file_getpos() error", status);

+        return -142;

+    }

+    if (pos != 4)

+        return -143;

+

+    status = pj_file_close(fd);

+    if (status != PJ_SUCCESS) {

+        app_perror("...file_close() error", status);

+        return -150;

+    }

+

+    /*

+     * Rename test.

+     */

+    status = pj_file_move(FILENAME, NEWNAME);

+    if (status != PJ_SUCCESS) {

+        app_perror("...file_move() error", status);

+        return -160;

+    }

+

+    if (pj_file_exists(FILENAME))

+        return -170;

+    if (!pj_file_exists(NEWNAME))

+        return -180;

+

+    if (pj_file_size(NEWNAME) != sizeof(buffer))

+        return -190;

+

+    /* Delete test. */

+    status = pj_file_delete(NEWNAME);

+    if (status != PJ_SUCCESS) {

+        app_perror("...file_delete() error", status);

+        return -200;

+    }

+

+    if (pj_file_exists(NEWNAME))

+        return -210;

+

+    PJ_LOG(3,("", "...success"));

+    return PJ_SUCCESS;

+}

+

+#else

+int dummy_file_test;

+#endif

+

diff --git a/pjlib/src/pjlib-test/test.c b/pjlib/src/pjlib-test/test.c
index 8ccdc568..b65fa9e7 100644
--- a/pjlib/src/pjlib-test/test.c
+++ b/pjlib/src/pjlib-test/test.c
@@ -30,6 +30,10 @@ int test_inner(void)
     int rc = 0;
 
     mem = &caching_pool.factory;
+

+    pj_log_set_level(3);

+    pj_log_set_decor(PJ_LOG_HAS_NEWLINE | PJ_LOG_HAS_TIME | 

+                     PJ_LOG_HAS_MICRO_SEC);

 
     rc = pj_init();
     if (rc != 0) {
@@ -37,8 +41,6 @@ int test_inner(void)
 	return rc;
     }
     
-    pj_log_set_level(3);
-    pj_log_set_decor(PJ_LOG_HAS_NEWLINE);
     pj_dump_config();
     pj_caching_pool_init( &caching_pool, &pj_pool_factory_default_policy, 0 );
 
@@ -125,6 +127,10 @@ int test_inner(void)
 #if INCLUDE_IOQUEUE_PERF_TEST

     DO_TEST( ioqueue_perf_test() );

 #endif

+

+#if INCLUDE_FILE_TEST

+    DO_TEST( file_test() );

+#endif

 
 #if INCLUDE_XML_TEST
     DO_TEST( xml_test() );
diff --git a/pjlib/src/pjlib-test/test.h b/pjlib/src/pjlib-test/test.h
index f4408513..b16aff69 100644
--- a/pjlib/src/pjlib-test/test.h
+++ b/pjlib/src/pjlib-test/test.h
@@ -8,7 +8,8 @@
 #define GROUP_LIBC                  0
 #define GROUP_OS                    0
 #define GROUP_DATA_STRUCTURE        0
-#define GROUP_NETWORK               1
+#define GROUP_NETWORK               0

+#define GROUP_FILE                  1
 #define GROUP_EXTRA                 0
 
 #define INCLUDE_ERRNO_TEST          GROUP_LIBC
@@ -31,7 +32,8 @@
 #define INCLUDE_SELECT_TEST	    GROUP_NETWORK
 #define INCLUDE_UDP_IOQUEUE_TEST    GROUP_NETWORK
 #define INCLUDE_TCP_IOQUEUE_TEST    GROUP_NETWORK

-#define INCLUDE_IOQUEUE_PERF_TEST   GROUP_NETWORK
+#define INCLUDE_IOQUEUE_PERF_TEST   GROUP_NETWORK

+#define INCLUDE_FILE_TEST           GROUP_FILE
 #define INCLUDE_XML_TEST	    GROUP_EXTRA
 
 #define INCLUDE_ECHO_SERVER         0
@@ -67,7 +69,8 @@ extern int sock_perf_test(void);
 extern int select_test(void);
 extern int udp_ioqueue_test(void);
 extern int tcp_ioqueue_test(void);

-extern int ioqueue_perf_test(void);
+extern int ioqueue_perf_test(void);

+extern int file_test(void);
 extern int xml_test(void);
 
 extern int echo_server(void);