enable event manager and directory manager services

git-svn-id: svn://opensvn.adaptivecomputing.com/maui/trunk@42 3f5042e3-fb1d-0410-be18-d6ca2573e517

include/moab.h

@@ -877,6 +877,7 @@ enum MClassAttrType {
   mclaDefReqFeature,
   mclaHostList,
   mclaName,
+  mclaNAPolicy,
   mclaMaxProcPerNode,
   mclaOCDProcFactor,
   mclaState,

include/msched-version.h

@@ -1 +1 @@
-#define MSCHED_VERSION "maui-3.2.6p14-snap.1129331854"
+#define MSCHED_VERSION "maui-3.2.6p14-snap.1129753176"

include/msched.h

@@ -1161,6 +1161,7 @@ typedef struct {
   int        IsDisabled;       /* queue cannot execute jobs */
 
   int        DistPolicy;
+  int        NAPolicy;
 
   char     **NodeList;
   char      *OCNodeName;       /* overcommit node */

src/moab/MClass.c

@@ -19,6 +19,7 @@ extern const char *MJobFlags[];
 extern const char *MClassAttr[];
 extern const char *MCredAttr[];
 extern const char *MXO[];
+extern const char *MNAccessPolicy[];
 
 
 
@@ -407,6 +408,12 @@ int MClassProcessConfig(
 
     switch(aindex)
       {
+      case mclaNAPolicy:
+
+        C->NAPolicy = MUGetIndex(ValLine,MNAccessPolicy,FALSE,0);
+
+        break;
+
       case mclaOCNode:
       case mclaDefReqFeature:
       case mclaMaxProcPerNode:

src/moab/MConst.c

@@ -578,6 +578,7 @@ const char *MClassAttr[] = {
   "DEFAULT.FEATURES",
   "HOSTLIST",
   "NAME",
+  "NODEACCESSPOLICY",
   "MAXPROCPERNODE",
   "OCDPROCFACTOR",
   "STATE",

src/moab/MRM.c

@@ -3644,6 +3644,10 @@ int MRMJobPostLoad(
       RQ = J->Req[0];
 
       MUBMOR(RQ->ReqFBM,J->Cred.C->DefFBM,MAX_MATTR);
+
+      if (J->Cred.C->NAPolicy != 0)
+        RQ->NAccessPolicy = J->Cred.C->NAPolicy;
+
       }  /* END for (rqindex) */
     }
 

src/moab/MSched.c

@@ -4968,13 +4968,61 @@ int MSchedProcessOConfig(
 
     case mcoDirectoryServer:
 
-      /* NYI */
+      {
+      int tmpI;
+
+      char *ptr;
+      char *TokPtr;
+
+      /* FORMAT:  <HOST>[:<PORT>] */
+
+      TokPtr = NULL;
+
+      ptr = MUStrTok(SVal,": \t\n",&TokPtr);
+
+      if (ptr != NULL)
+        MUStrDup(&MSched.DS.HostName,ptr);
+
+      ptr = MUStrTok(NULL,": \t\n",&TokPtr);
+
+      if (ptr != NULL)
+        {
+        tmpI = (int)strtol(ptr,NULL,10);
+
+        if (tmpI > 0)
+          MSched.DS.Port = tmpI;
+        }
+      }    /* END BLOCK */
 
       break;
 
     case mcoEventServer:
 
-      /* NYI */
+      {
+      int tmpI;
+
+      char *ptr;
+      char *TokPtr;
+
+      /* FORMAT:  <HOST>[:<PORT>] */
+
+      TokPtr = NULL;
+
+      ptr = MUStrTok(SVal,": \t\n",&TokPtr);
+
+      if (ptr != NULL)
+        MUStrDup(&MSched.EM.HostName,ptr);
+
+      ptr = MUStrTok(NULL,": \t\n",&TokPtr);
+
+      if (ptr != NULL)
+        {
+        tmpI = (int)strtol(ptr,NULL,10);
+
+        if (tmpI > 0)
+          MSched.EM.Port = tmpI;
+        }
+      }    /* END BLOCK */
 
       break;