[Pvfs2-cvs] commit by pcarns in pvfs2-1/test/client/sysint:
getattr-test-threaded.c module.mk.in
CVS commit program
cvs at parl.clemson.edu
Wed Feb 6 10:15:57 EST 2008
Update of /projects/cvsroot/pvfs2-1/test/client/sysint
In directory parlweb1:/tmp/cvs-serv27645/test/client/sysint
Modified Files:
module.mk.in
Added Files:
getattr-test-threaded.c
Log Message:
added a toy test program for multithreaded calls to sys_getattr
--- /dev/null 2004-06-24 14:04:38.000000000 -0400
+++ getattr-test-threaded.c 2008-02-06 10:15:57.000000000 -0500
@@ -0,0 +1,282 @@
+/*
+ * (C) 2001 Clemson University and The University of Chicago
+ *
+ * See COPYING in top-level directory.
+ */
+
+/* based off of io-test.c. This is meant to exercise a bug found by Florin
+ * Isaila in which two concurrent threads running sys_io() will deadlock on a
+ * configuration struct lock ordering problem.
+ */
+
+#include <pthread.h>
+#include <time.h>
+#include "client.h"
+#include <sys/time.h>
+#include <unistd.h>
+#include <sys/types.h>
+#include <stdlib.h>
+#include <stdio.h>
+#include <assert.h>
+#include "pvfs2-util.h"
+#include "pvfs2-mgmt.h"
+#include "pvfs2-internal.h"
+
+struct thread_info
+{
+ PVFS_object_ref* pinode_refn;
+ PVFS_object_ref* pinode_refn2;
+ PVFS_credentials* credentials;
+};
+
+void* thread_fn(void* foo);
+pthread_mutex_t error_count_mutex = PTHREAD_MUTEX_INITIALIZER;
+int error_count = 0;
+
+int main(int argc, char **argv)
+{
+ PVFS_sysresp_lookup resp_lk;
+ PVFS_sysresp_create resp_cr;
+ int ret = -1;
+ int i;
+ PVFS_fs_id fs_id;
+ char name[512] = {0};
+ char *entry_name = NULL;
+ PVFS_credentials credentials;
+ PVFS_object_ref parent_refn;
+ PVFS_sys_attr attr;
+ PVFS_object_ref pinode_refn;
+ PVFS_object_ref pinode_refn2;
+ struct thread_info info;
+ pthread_t* thread_id_array;
+ int num_threads = 1;
+
+ if (argc != 4)
+ {
+ fprintf(stderr, "Usage: %s <num threads> <file name 1> <file name 2>\n", argv[0]);
+ return (-1);
+ }
+
+ if(sscanf(argv[1], "%d", &num_threads) != 1)
+ {
+ fprintf(stderr, "Usage: %s <num threads> <file name>\n", argv[0]);
+ return (-1);
+ }
+
+ thread_id_array = malloc(num_threads* sizeof(pthread_t));
+ if(!thread_id_array)
+ {
+ perror("malloc");
+ return(-1);
+ }
+
+ ret = PVFS_util_init_defaults();
+ if (ret < 0)
+ {
+ PVFS_perror("PVFS_util_init_defaults", ret);
+ return (-1);
+ }
+ ret = PVFS_util_get_default_fsid(&fs_id);
+ if (ret < 0)
+ {
+ PVFS_perror("PVFS_util_get_default_fsid", ret);
+ return (-1);
+ }
+
+ /* FIRST FILE */
+ if (argv[2][0] == '/')
+ {
+ snprintf(name, 512, "%s", argv[2]);
+ }
+ else
+ {
+ snprintf(name, 512, "/%s", argv[2]);
+ }
+
+ PVFS_util_gen_credentials(&credentials);
+ ret = PVFS_sys_lookup(fs_id, name, &credentials,
+ &resp_lk, PVFS2_LOOKUP_LINK_FOLLOW);
+ if (ret == -PVFS_ENOENT)
+ {
+ PVFS_sysresp_getparent gp_resp;
+
+ memset(&gp_resp, 0, sizeof(PVFS_sysresp_getparent));
+ ret = PVFS_sys_getparent(fs_id, name, &credentials, &gp_resp);
+ if (ret < 0)
+ {
+ PVFS_perror("PVFS_sys_getparent failed", ret);
+ return ret;
+ }
+
+ attr.owner = credentials.uid;
+ attr.group = credentials.gid;
+ attr.perms = PVFS_U_WRITE | PVFS_U_READ;
+ attr.atime = attr.ctime = attr.mtime = time(NULL);
+ attr.mask = PVFS_ATTR_SYS_ALL_SETABLE;
+ parent_refn = gp_resp.parent_ref;
+
+ entry_name = rindex(name, (int)'/');
+ assert(entry_name);
+ entry_name++;
+ assert(entry_name);
+
+ ret = PVFS_sys_create(entry_name, parent_refn, attr,
+ &credentials, NULL, NULL, &resp_cr);
+ if (ret < 0)
+ {
+ PVFS_perror("PVFS_sys_create() failure", ret);
+ return (-1);
+ }
+
+ pinode_refn.fs_id = fs_id;
+ pinode_refn.handle = resp_cr.ref.handle;
+ }
+ else
+ {
+ pinode_refn.fs_id = fs_id;
+ pinode_refn.handle = resp_lk.ref.handle;
+ }
+
+ /* SECOND FILE */
+ if (argv[3][0] == '/')
+ {
+ snprintf(name, 512, "%s", argv[3]);
+ }
+ else
+ {
+ snprintf(name, 512, "/%s", argv[3]);
+ }
+
+ PVFS_util_gen_credentials(&credentials);
+ ret = PVFS_sys_lookup(fs_id, name, &credentials,
+ &resp_lk, PVFS2_LOOKUP_LINK_FOLLOW);
+ if (ret == -PVFS_ENOENT)
+ {
+ PVFS_sysresp_getparent gp_resp;
+
+ memset(&gp_resp, 0, sizeof(PVFS_sysresp_getparent));
+ ret = PVFS_sys_getparent(fs_id, name, &credentials, &gp_resp);
+ if (ret < 0)
+ {
+ PVFS_perror("PVFS_sys_getparent failed", ret);
+ return ret;
+ }
+
+ attr.owner = credentials.uid;
+ attr.group = credentials.gid;
+ attr.perms = PVFS_U_WRITE | PVFS_U_READ;
+ attr.atime = attr.ctime = attr.mtime = time(NULL);
+ attr.mask = PVFS_ATTR_SYS_ALL_SETABLE;
+ parent_refn = gp_resp.parent_ref;
+
+ entry_name = rindex(name, (int)'/');
+ assert(entry_name);
+ entry_name++;
+ assert(entry_name);
+
+ ret = PVFS_sys_create(entry_name, parent_refn, attr,
+ &credentials, NULL, NULL, &resp_cr);
+ if (ret < 0)
+ {
+ PVFS_perror("PVFS_sys_create() failure", ret);
+ return (-1);
+ }
+
+ pinode_refn2.fs_id = fs_id;
+ pinode_refn2.handle = resp_cr.ref.handle;
+ }
+ else
+ {
+ pinode_refn2.fs_id = fs_id;
+ pinode_refn2.handle = resp_lk.ref.handle;
+ }
+
+
+ /* fill in information for threads */
+ info.pinode_refn = &pinode_refn;
+ info.pinode_refn2 = &pinode_refn2;
+ info.credentials = &credentials;
+
+ /* launch threads then wait for them to finish */
+ for(i=0; i<num_threads; i++)
+ {
+ ret = pthread_create(&thread_id_array[i], NULL, thread_fn, &info);
+ assert(ret == 0);
+ }
+
+ for(i=0; i<num_threads; i++)
+ {
+ pthread_join(thread_id_array[i], NULL);
+ }
+
+ /**************************************************************
+ * shut down pending interfaces
+ */
+
+ ret = PVFS_sys_finalize();
+ if (ret < 0)
+ {
+ fprintf(stderr, "Error: PVFS_sys_finalize() failed with errcode = %d\n",
+ ret);
+ return (-1);
+ }
+
+ pthread_mutex_lock(&error_count_mutex);
+ if(error_count != 0)
+ {
+ fprintf(stderr, "Error: %d threads had problems\n", error_count);
+ ret = -1;
+ }
+ else
+ {
+ ret = 0;
+ }
+ pthread_mutex_unlock(&error_count_mutex);
+
+ free(thread_id_array);
+
+ return (ret);
+}
+
+void* thread_fn(void* foo)
+{
+ PVFS_sysresp_getattr resp_getattr;
+ int ret = 0;
+ int i = 0;
+ struct thread_info* info = foo;
+
+ for(i=0; i<1000; i++)
+ {
+ ret = PVFS_sys_getattr(*info->pinode_refn, PVFS_ATTR_SYS_ALL,
+ info->credentials, &resp_getattr);
+ if (ret < 0)
+ {
+ PVFS_perror("PVFS_sys_getattr failure", ret);
+ pthread_mutex_lock(&error_count_mutex);
+ error_count++;
+ pthread_mutex_unlock(&error_count_mutex);
+ return (NULL);
+ }
+ ret = PVFS_sys_getattr(*info->pinode_refn2, PVFS_ATTR_SYS_ALL,
+ info->credentials, &resp_getattr);
+ if (ret < 0)
+ {
+ PVFS_perror("PVFS_sys_getattr failure", ret);
+ pthread_mutex_lock(&error_count_mutex);
+ error_count++;
+ pthread_mutex_unlock(&error_count_mutex);
+ return (NULL);
+ }
+ }
+
+ return(NULL);
+}
+
+/*
+ * Local variables:
+ * c-indent-level: 4
+ * c-basic-offset: 4
+ * End:
+ *
+ * vim: ts=8 sts=4 sw=4 expandtab
+ */
Index: module.mk.in
===================================================================
RCS file: /projects/cvsroot/pvfs2-1/test/client/sysint/module.mk.in,v
diff -p -u -r1.54 -r1.55
--- module.mk.in 10 Jan 2008 15:20:24 -0000 1.54
+++ module.mk.in 6 Feb 2008 15:15:57 -0000 1.55
@@ -25,6 +25,7 @@ TESTSRC += \
$(DIR)/io-test.c \
$(DIR)/io-test-offset.c \
$(DIR)/io-test-threaded.c \
+ $(DIR)/getattr-test-threaded.c \
$(DIR)/initialize.c \
$(DIR)/initialize-dyn.c \
$(DIR)/getparent.c \
@@ -43,6 +44,7 @@ TESTSRC += \
MODCFLAGS_$(DIR)/io-stress.c := -D_GNU_SOURCE
MODLDFLAGS_$(DIR) := -lrt
MODLDFLAGS_$(DIR)/io-test-threaded := -lpthread
+MODLDFLAGS_$(DIR)/getattr-test-threaded := -lpthread
#$(DIR)/io-test-threaded: $(DIR)/io-test-threaded.o
# $(Q) " LD $@"
More information about the Pvfs2-cvs
mailing list