v3run_internals.c

Path MPICH-V for MPICH the MPI Implementation

/*
  MPICH-V3
  Copyright (C) 2002, 2003 Groupe Cluster et Grid, LRI, Universite de Paris Sud


  This file is part of MPICH-V3.

  MPICH-V3 is free software; you can redistribute it and/or modify
  it under the terms of the GNU General Public License as published by
  the Free Software Foundation; either version 2 of the License, or
  (at your option) any later version.

  MPICH-V3 is distributed in the hope that it will be useful,
  but WITHOUT ANY WARRANTY; without even the implied warranty of
  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  GNU General Public License for more details.

  You should have received a copy of the GNU General Public License
  along with MPICH-V3; if not, write to the Free Software
  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

  $Id: v3run_internals.c,v 1.3 2004/02/13 00:55:03 gk Exp $
*/

#include <stdio.h>
#include "vrun_versions.h"
#include "v3run_prototypes.h"

/* We first consider the global dispatcher functions */

void parseClusterFile(JS *js) {
  FILE *fd;
  char line[4096];
  CD *newCD, *lastCD;
  int totalCD = 0;
  char remoteLaunch[3];
  js->csList = (CD *)NULL;
  lastCD = (CD *)malloc(sizeof(CD));

  if  ((fd = fopen(js->clusterFile,"r")) != NULL) {
    line = (char *)calloc(4096, sizeof(char));
    while(fgets(line, 4096, fd) ) {
      if (line[0] == '#') break;
      newCD = (CD *)malloc(sizeof(CD));
      sscanf(line, "%s %s %d %s %s %s", 
		      newCD->clusterName,
		      newCD->ipFrontalNode,
		      &newCD->maxAvailableNodes,
		      newCD->pathToMPICHV,
		      newCD->pathToExecutable,
		      remoteLaunch);
      newCD->remoteLaunch = strcmp(remoteLaunch, "yes");
      if (totalCD == 0)
    }
    free(line);
    fclose(fd);
  }

}

void localLocalDispatcherCommandLine(char **commandLine, JS* js, CD cluster) {
  sprintf(*commandLine, "%s/mpirun -xw-local-dispatcher -xw-local-ranks %s %s/%s",
		  cd.pathToMPICHV,
		  cd.mpiRanks,
		  cd.pathToExecutable, js->progCmd);
}

void remoteLocalDispatcherCommandLine(char **commandLine, JS* js, CD cluster) {
}

void waitConnectFromLocalDispatcher(JS *js, CD * cd) {
}

void waitConnectFromLocalDispatchers(JS * js) {
  CD *auxCD; 
  auxCD = js->clusterList;
  while (auxCD != NULL) {
    waitConnectFromLocalDispatcher(js, auxCD);
    auxCD = auxCD->next;
  }
}

/* Then we consider the local dispatcher functions */

void parseProgramFile(LJS * ljs) {

}

void remoteNodeCommandLine(char **commandLine, LJS * ljs, CN node) {
}

void localNodeCommandLine(char **commandLine, LJS * ljs, CN node) {
}

void remoteEventLoggerCommandLine(char **commandLine, LJS * ljs, CN node) {
}

void localEventLoggerCommandLine(char **commandLine, LJS * ljs, CN node) {
}