* First take at a shell for the COFS (Control Over File System) interface

for out of band messaging

This commit was SVN r219.

configure.ac

@@ -289,9 +289,9 @@ AC_SUBST(MCA_topo_STATIC_SUBDIRS)
 AC_SUBST(MCA_topo_DYNAMIC_SUBDIRS)
 AC_SUBST(MCA_topo_ALL_SUBDIRS)
 
-MCA_oob_STATIC_SUBDIRS=
+MCA_oob_STATIC_SUBDIRS="cofs"
 MCA_oob_DYNAMIC_SUBDIRS=
-MCA_oob_ALL_SUBDIRS=
+MCA_oob_ALL_SUBDIRS="${MCA_oob_STATIC_SUBDIRS}"
 AC_SUBST(MCA_oob_STATIC_SUBDIRS)
 AC_SUBST(MCA_oob_DYNAMIC_SUBDIRS)
 AC_SUBST(MCA_oob_ALL_SUBDIRS)
@@ -428,6 +428,8 @@ AC_CONFIG_FILES([
     src/mca/lam/Makefile
     src/mca/lam/oob/Makefile
     src/mca/lam/oob/base/Makefile
+    src/mca/lam/oob/cofs/Makefile
+    src/mca/lam/oob/cofs/src/Makefile
     src/mca/lam/pcm/Makefile
     src/mca/lam/pcm/base/Makefile
     src/mca/lam/registry/Makefile

src/mca/lam/oob/cofs/.cvsignore

@@ -0,0 +1,4 @@
+.libs
+libmca_lam_oob_cofs.la
+Makefile
+Makefile.in

src/mca/lam/oob/cofs/Makefile.am

@@ -0,0 +1,17 @@
+# -*- makefile -*-
+#
+# $HEADER$
+#
+
+include $(top_srcdir)/config/Makefile.options
+
+SUBDIRS			= src
+DIST_SUBDIRS		= $(SUBDIRS)
+
+module_noinst	= libmca_lam_oob_cofs.la
+module_install	=
+
+noinst_LTLIBRARIES = $(module_noinst)
+
+libmca_lam_oob_cofs_la_SOURCES=
+libmca_lam_oob_cofs_la_LIBADD	= src/libcofs.la

src/mca/lam/oob/cofs/src/.cvsignore

@@ -0,0 +1,7 @@
+.deps
+.libs
+libcofs.la
+Makefile
+Makefile.in
+oob_cofs.lo
+oob_cofs_module.lo

src/mca/lam/oob/cofs/src/Makefile.am

@@ -0,0 +1,18 @@
+#
+# $HEADER$
+#
+
+include $(top_srcdir)/config/Makefile.options
+
+noinst_LTLIBRARIES = libcofs.la
+
+# Source code files
+
+headers = \
+	oob_cofs.h
+
+libcofs_la_SOURCES = \
+        $(headers) \
+	oob_cofs_module.c \
+	oob_cofs.c
+

src/mca/lam/oob/cofs/src/oob_cofs.c

@@ -0,0 +1,41 @@
+/* -*- C -*-
+ * 
+ * $HEADER$
+ *
+ */
+
+#include "lam_config.h"
+
+#include "mca/lam/oob/oob.h"
+#include "mca/lam/oob/cofs/src/oob_cofs.h"
+
+int
+mca_oob_cofs_send(char* parallel_job_id, int vpid, int tag, 
+                  void* data, size_t data_len)
+{
+  return 0;
+}
+
+
+int
+mca_oob_cofs_recv(char* parallel_job_id, int* tag, int* vpid, 
+                  void** data, size_t* data_len)
+{
+  return 0;
+}
+
+
+int
+mca_oob_cofs_recv_nb(char* parallel_job_id, int* tag, int* vpid, 
+                     void** data, size_t* data_len)
+{
+  return 0;
+}
+
+
+int
+mca_oob_cofs_recv_cb(char* parallel_job_id, int tag, 
+                     mca_oob_recv_cb_t callback)
+{
+  return 0;
+}

src/mca/lam/oob/cofs/src/oob_cofs.h

@@ -0,0 +1,34 @@
+/* -*- C -*-
+ * 
+ * $HEADER$
+ *
+ */
+
+#include "mca/lam/oob/oob.h"
+
+/*
+ * Module open / close
+ */
+int mca_oob_cofs_open(lam_cmd_line_t *cmd);
+int mca_oob_cofs_close(void);
+
+
+/*
+ * Startup / Shutdown
+ */
+int mca_oob_cofs_query(int *priority);
+struct mca_oob_1_0_0* mca_oob_cofs_init(void);
+int mca_oob_cofs_finalize(void);
+
+
+/*
+ * "Action" functions
+ */
+int mca_oob_cofs_send(char* parallel_job_id, int vpid, int tag, 
+                      void* data, size_t data_len);
+int mca_oob_cofs_recv(char* parallel_job_id, int* tag, int* vpid, 
+                      void** data, size_t* data_len);
+int mca_oob_cofs_recv_nb(char* parallel_job_id, int* tag, int* vpid, 
+                         void** data, size_t* data_len);
+int mca_oob_cofs_recv_cb(char* parallel_job_id, int tag, 
+                         mca_oob_recv_cb_t callback);

src/mca/lam/oob/cofs/src/oob_cofs_module.c

@@ -0,0 +1,74 @@
+/* -*- C -*-
+ * 
+ * $HEADER$
+ *
+ */
+
+#include "lam_config.h"
+
+#include "lam/constants.h"
+#include "mca/mca.h"
+#include "mca/lam/oob/oob.h"
+#include "mca/lam/oob/cofs/src/oob_cofs.h"
+
+
+/*
+ * Struct of function pointers and all that to let us be initialized
+ */
+mca_oob_module_1_0_0_t mca_oob_cofs_module_1_0_0_0 = {
+  {
+    1,  /* MCA major version */
+    0,  /* MCA minor version */
+    0,  /* MCA release version */
+    "OOB", /* MCA type name */
+    1,  /* MCA type major version */
+    0,  /* MCA type minor version */
+    0,  /* MCA type release version */
+    "COFS", /* MCA module name */
+    1,  /* MCA module major version */
+    0,  /* MCA module minor version */
+    0,  /* MCA module release version */
+    mca_oob_cofs_open,  /* module open */
+    mca_oob_cofs_close, /* module close */
+    false   /* MCA module is not checkpointable */
+  },
+  mca_oob_cofs_query,  /* module query */
+  mca_oob_cofs_init,    /* module init */
+  mca_oob_cofs_finalize
+};
+
+
+int
+mca_oob_cofs_open(lam_cmd_line_t *cmd)
+{
+  return LAM_SUCCESS;
+}
+
+
+int
+mca_oob_cofs_close(void)
+{
+  return LAM_SUCCESS;
+}
+
+
+int
+mca_oob_cofs_query(int *priority)
+{
+  *priority = 0;
+  return LAM_SUCCESS;
+}
+
+
+struct mca_oob_1_0_0*
+mca_oob_cofs_init(void)
+{
+  return NULL;
+}
+
+
+int
+mca_oob_cofs_finalize(void)
+{
+  return LAM_SUCCESS;
+}

src/mca/lam/oob/oob.h

@@ -72,22 +72,22 @@ typedef int (*mca_oob_finalize_fn_t)(void);
 /*
  * Ver 1.0.0
  */
-typedef struct mca_oob_module_1_0_0 {
+struct mca_oob_module_1_0_0_t {
   mca_module_1_0_0_t super;
 
   mca_oob_query_fn_t oobm_query;
   mca_oob_init_fn_t oobm_init;
   mca_oob_finalize_fn_t oob_finalize;
-} mca_oob_module_1_0_0_t;
+};
-
+typedef struct mca_oob_module_1_0_0_t mca_oob_module_1_0_0_t;
-typedef struct mca_oob_1_0_0 {
-  mca_1_0_0_t super;
 
+struct mca_oob_1_0_0_t {
   mca_oob_send_fn_t oob_send;
   mca_oob_recv_fn_t oob_recv;
   mca_oob_recv_nb_fn_t oob_recv_nb;
   mca_oob_recv_cb_fn_t oob_recv_cb;
-} mca_oob_1_0_0_t;
+};
+typedef struct mca_oob_1_0_0_t mca_oob_1_0_0_t;
 
 typedef mca_oob_module_1_0_0_t mca_oob_module_t;
 typedef mca_oob_1_0_0_t mca_oob_t;
@@ -102,7 +102,7 @@ extern "C" {
   int mca_oob_base_open(lam_cmd_line_t *cmd);
   int mca_oob_base_close(void);
 
-  bool mca_oob_base_is_checkpointable(void)
+  bool mca_oob_base_is_checkpointable(void);
 
   int mca_oob_base_checkpoint(void);
   int mca_oob_base_continue(void);
@@ -111,10 +111,11 @@ extern "C" {
 }
 #endif
 
-
 /*
  * Global struct holding the selected module's function pointers
  */
+#if 0
 extern mca_oob_t mca_oob;
+#endif /* #if 0 */
 
 #endif