[PVFS2-CVS] commit by slang in pvfs2/src/io/bmi: bmi-types.h bmi.c

[CVS commit program]

Update of /projects/cvsroot/pvfs2/src/io/bmi
In directory parlweb:/tmp/cvs-serv6522/src/io/bmi

Modified Files:
      Tag: slang-sio-branch
	bmi-types.h bmi.c 
Log Message:
small I/O changes in sio branch for now


Index: bmi-types.h
===================================================================
RCS file: /projects/cvsroot/pvfs2/src/io/bmi/bmi-types.h,v
diff -p -u -r1.24 -r1.24.2.1
--- bmi-types.h	25 Oct 2005 18:00:57 -0000	1.24
+++ bmi-types.h	4 Nov 2005 07:14:15 -0000	1.24.2.1
@@ -71,6 +71,7 @@ enum
 #ifdef USE_TRUSTED
     BMI_TRUSTED_CONNECTION = 9, /**< allows setting the TrustedPorts and Network options */
 #endif
+    BMI_GET_UNEXP_SIZE = 10     /**< get the maximum unexpected payload */
 };
 
 /* mappings from PVFS errors to BMI errors */

Index: bmi.c
===================================================================
RCS file: /projects/cvsroot/pvfs2/src/io/bmi/bmi.c,v
diff -p -u -r1.65 -r1.65.2.1
--- bmi.c	25 Oct 2005 18:00:57 -0000	1.65
+++ bmi.c	4 Nov 2005 07:14:15 -0000	1.65.2.1
@@ -79,6 +79,7 @@ static struct bmi_method_ops **known_met
  */
 static int active_method_count = 0;
 static gen_mutex_t active_method_count_mutex = GEN_MUTEX_INITIALIZER;
+
 static struct bmi_method_ops **active_method_table = NULL;
 static struct {
     struct timeval active;
@@ -1258,6 +1259,23 @@ int BMI_get_info(PVFS_BMI_addr_t addr,
 	gen_mutex_unlock(&ref_mutex);
 	*((void**) inout_parameter) = tmp_ref->method_addr;
 	break;
+    case BMI_GET_UNEXP_SIZE:
+        gen_mutex_lock(&ref_mutex);
+        tmp_ref = ref_list_search_addr(cur_ref_list, addr);
+        if(!tmp_ref)
+        {
+            gen_mutex_unlock(&ref_mutex);
+            return (bmi_errno_to_pvfs(-EINVAL));
+        }
+        gen_mutex_unlock(&ref_mutex);
+        ret = tmp_ref->interface->BMI_meth_get_info(
+            option, inout_parameter);
+        if(ret < 0)
+        {
+            return ret;
+        }
+        break;
+
     default:
 	return (bmi_errno_to_pvfs(-ENOSYS));
 	break;