1 files changed, 95 insertions, 0 deletions
diff --git a/c_pgms/threaded_io/thread_fops.h b/c_pgms/threaded_io/thread_fops.h
new file mode 100644
index 0000000..44479e6
--- /dev/null
+++ b/c_pgms/threaded_io/thread_fops.h
@@ -0,0 +1,95 @@
+#include <stdio.h>
+#include <stdlib.h>
+#include <pthread.h>
+#include <unistd.h>
+#include <sys/stat.h>
+#include <sys/types.h>
+#include <fcntl.h>
+#include <errno.h>
+#include <string.h>
+#include <pthread.h>
+#include <dirent.h>
+
+void * open_thread (void *);
+void * fstat_thread (void *);
+void * read_thread (void *);
+void * write_truncate_thread (void *);
+void * chown_thread (void *);
+void * open_lock_close (void *);
+void * opendir_and_readdir ();
+
+int thread1_ret;
+int thread2_ret;
+int thread3_ret;
+int thread4_ret;
+int thread5_ret;
+int thread6_ret;
+int thread7_ret;
+
+struct open_attributes {
+        char *filename;
+        int flags;
+        mode_t mode;
+//        char *dirname;
+};
+
+typedef struct open_attributes open_t;
+
+struct fstat_attributes {
+        int fd;
+        struct stat *buf;
+};
+
+typedef struct fstat_attributes fstat_t;
+
+struct open_fstat {
+        open_t *open;
+        fstat_t *fstat;
+};
+
+typedef struct open_fstat oft;
+
+#define open_validate_error_goto(filename, flag, mode)   do {           \
+                pthread_mutex_lock (&info.mutex);                       \
+                {                                                       \
+                        info.num_open++;                                \
+                }                                                       \
+                pthread_mutex_unlock (&info.mutex);                     \
+                fd = open (filename, flag, mode);                       \
+                if (fd == -1) {                                         \
+                        ret = -1;                                       \
+                        goto out;                                       \
+                } else {                                                \
+                        pthread_mutex_lock (&info.mutex);               \
+                        {                                               \
+                                info.num_open_success++;                \
+                        }                                               \
+                        pthread_mutex_unlock (&info.mutex);             \
+                }                                                       \
+        } while (0);
+
+typedef struct info {
+        pthread_mutex_t mutex;
+        unsigned int num_open;
+        unsigned int num_open_success;
+        unsigned int flocks;
+        unsigned int flocks_success;
+        unsigned int fcntl_locks;
+        unsigned int fcntl_locks_success;
+        unsigned int read;
+        unsigned int read_success;
+        unsigned int write;
+        unsigned int write_success;
+        unsigned int fstat;
+        unsigned int fstat_success;
+        unsigned int truncate;
+        unsigned int truncate_success;
+        unsigned int chown;
+        unsigned int chown_success;
+        unsigned int opendir;
+        unsigned int opendir_success;
+        unsigned int readdir;
+        unsigned int readdir_success;
+} info_t;
+
+info_t info = {0,};