[Swift-commit] r2764 - in usertools/cio: falkon tools

[noreply at svn.ci.uchicago.edu]

Author: aespinosa
Date: 2009-03-29 14:39:42 -0500 (Sun, 29 Mar 2009)
New Revision: 2764

Added:
   usertools/cio/tools/hashserver.rb
Modified:
   usertools/cio/falkon/ciologic-bgp.sh
   usertools/cio/falkon/falkon-start-bgp-cio.sh
Log:
Added ruby hash server.  Cleanup and fix of falkon startup scripts

Modified: usertools/cio/falkon/ciologic-bgp.sh
===================================================================
--- usertools/cio/falkon/ciologic-bgp.sh	2009-03-29 19:38:38 UTC (rev 2763)
+++ usertools/cio/falkon/ciologic-bgp.sh	2009-03-29 19:39:42 UTC (rev 2764)
@@ -49,16 +49,15 @@
     $CIOROOT/tools/ifsslave.sh $DATACN >&2
   fi
 else
-  echo "[ $BG_RANK@$IO_RANK-$PSET ] Mounting Mosa data CN filesystem from $DATACN" >&2
   /bin/mkdir /dataifs
   export LD_LIBRARY_PATH=$LD_LIBRARY_PATH:/lib:/fuse/lib:/usr/lib
   sleep 30
-  # Contact / mount assigned IFS head
+  # Contact and mount assigned IFS head
   $CIOROOT/tools/ifsmount.sh $DATACN >&2
  
   echo "worker started..." >> ${ERROR_LOG}
 
-  # Regular Falon worker startup script
+  # Regular Falkon worker startup script
   
   FALKON_SERVICE_IP=$1
   TCPCORE_PORT1=$2

Modified: usertools/cio/falkon/falkon-start-bgp-cio.sh
===================================================================
--- usertools/cio/falkon/falkon-start-bgp-cio.sh	2009-03-29 19:38:38 UTC (rev 2763)
+++ usertools/cio/falkon/falkon-start-bgp-cio.sh	2009-03-29 19:39:42 UTC (rev 2764)
@@ -1,5 +1,7 @@
 #!/bin/bash
 
+CIOROOT=/home/espinosa/cio
+
 if [ $# -lt 3 ]; then
   cat << EOF
 Usage: $0 <QueueName> <NumNodes> <WallTime>
@@ -53,7 +55,7 @@
 
 
 
-WORKER_SCRIPT=cio-logic.sh
+WORKER_SCRIPT=$CIOROOT/falkon/ciologic-bgp.sh
 ZOID_JOB_ID=`cqsub -q ${QUEUE_NAME} -k ${PROFILE_NAME} -C ${HOME} -t \
     ${MAX_TIME_MIN} -n ${NUM_NODES} \
 	-e LD_LIBRARY_PATH=/lib:/fuse/lib:/fuse/usr/lib \
@@ -64,7 +66,12 @@
 EXIT_CODE=$? 
 
 if [ "${EXIT_CODE}" -ne "0" ]; then
-  echo "Error in submitting job to Cobalt.. 'cqsub -q ${QUEUE_NAME} -k ${PROFILE_NAME} -C ${HOME} -t ${MAX_TIME_MIN} -n ${NUM_NODES} -e LD_LIBRARY_PATH=/lib:/fuse/lib:/fuse/usr/lib /bgsys/linux/1.2.020080512/bin/bash /fuse/${FALKON_WORKER_HOME}/run.worker-c-bgp.sh-mosa ${SERVICE_IP} ${SERVICE_PORT1} ${SERVICE_PORT2} ${WORKERS_PER_NODE} ${USER} ${FALKON_JOB_ID} ${FALKON_ROOT}' "
+  echo "Error in submitting job to Cobalt.. 'cqsub -q ${QUEUE_NAME} \
+       -k ${PROFILE_NAME} -C ${HOME} -t ${MAX_TIME_MIN} -n ${NUM_NODES} \
+       -e LD_LIBRARY_PATH=/lib:/fuse/lib:/fuse/usr/lib \
+       /bgsys/linux/1.2.020080512/bin/bash $WORKER_SCRIPT \
+       ${SERVICE_IP} ${SERVICE_PORT1} ${SERVICE_PORT2} \
+       ${WORKERS_PER_NODE} ${USER} ${FALKON_JOB_ID} ${FALKON_ROOT}' "
   exit ${EXIT_CODE}
 fi
 

Added: usertools/cio/tools/hashserver.rb
===================================================================
--- usertools/cio/tools/hashserver.rb	                        (rev 0)
+++ usertools/cio/tools/hashserver.rb	2009-03-29 19:39:42 UTC (rev 2764)
@@ -0,0 +1,26 @@
+#!/home/espinosa/local/bin/ruby
+
+require 'drb'
+
+class HashServer
+  attr_reader :file
+
+  def initialize
+    @file = {}
+  end
+
+  def put(fname, rank)
+    @file[fname] = rank
+  end
+
+  def get(fname)
+    @file[fname]
+  end
+
+end
+
+server = HashServer.new
+
+DRb.start_service('druby://*:9000', server)
+DRb.thread.join
+


Property changes on: usertools/cio/tools/hashserver.rb
___________________________________________________________________
Name: svn:executable
   + *