Contents

require 'ffi'
class CodeRunner
  class Trinity
    module TrinityDriver                                                                         
      extend FFI::Library                                                                        
      ffi_lib ENV['TRINITY'] + '/libtrin.so'                                                     
      attach_function :runtr, :run_trinity_c, [:string, :size_t], :void                       
      attach_function :runtr2, :run_trinity_test, [], :void                       
    end 
    def run_trin_actual2(input_file, mpicomm_int)
      puts ['calling TrinityDriver.runtr',mpicomm_int.class]
      TrinityDriver.runtr(input_file, mpicomm_int)
    end
    def self.run_trin_standalone(input_file)
      require 'mpi'
      MPI.Init
      obj = CodeRunner::Trinity.new
      obj.run_trinity(input_file, MPI::Comm::WORLD)
      MPI.Finalize
    end
    private :run_trin_actual2
  end
end
require 'trinitycrdriver/trinitycrdriver'
require 'mpi'

class CodeRunner::Trinity
	# We overwrite the system module's implemenation of this command.
	# Instead of running trinity via a bash command or a batch script,
	# we run it directly via its API.
	@delay_execution = false
  def queue_status
    ""
  end
	def execute
		if rcp.delay_execution
      eputs 'Delaying execution...'
			return
		else
			execute_actual
		end
	end
	def execute_actual
		Dir.chdir(@directory){
			if rcp.mpi_communicator?
				start_mpi = false
				mpicomm = rcp.mpi_communicator
			else
				start_mpi = true
				MPI.Init
				mpicomm = MPI::Comm::WORLD
				puts ["INITIALISED MPI", mpicomm.size ]
			end
			run_trinity(@run_name + ".trin", mpicomm)
			if start_mpi
				MPI.Finalize
			end

		}
	end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
trinitycrdriver-0.1.3	lib/trinitycrdriver.rb
trinitycrdriver-0.1.2	lib/trinitycrdriver.rb