cafe-grader-judge-scripts Commit

cafe-grader-judge-scripts

Commit `r71:76c4d891d4d5` public

parent | child

Description:

MERGED changeset 380:381 from http://theory.cpe.ku.ac.th/grader/web/trunk/judge/scripts git-svn-id: http://theory.cpe.ku.ac.th/grader/judge/trunk/scripts@382 6386c4cd-e34a-4fa8-8920-d93eb39b512e

Commit status:

[Not Reviewed]

References:

default

Diff options:

| | | |

Comments:

0 Commit comments 0 Inline Comments

Unresolved TODOs:

There are no unresolved TODOs

Add another comment

r71:76c4d891d4d5 - Mon, 27 Apr 2009 13:49:37 - 3 files changed: 148 inserted, 2 deleted

lib/dir_init.rb created 644 ¶ +107

@@ -0,0 +1,107
	1	+ require 'ftools'
	2	+
	3	+ # DirInit::Manager handles directory initialization and clean-up when
	4	+ # there are many concurrent processes that wants to modify the
	5	+ # directory in the same way.
	6	+ #
	7	+ # An example usage is when each process wants to copy some temporary
	8	+ # files to the directory and delete these files after finishing its
	9	+ # job. Problems may occur when the first process delete the files
	10	+ # while the second process is still using the files.
	11	+ #
	12	+ # This library maintain a reference counter on the processes using the
	13	+ # directory. It locks the dir to manage critical section when
	14	+ # updating the reference counter.
	15	+
	16	+ module DirInit
	17	+
	18	+ class Manager
	19	+
	20	+ def initialize(dir_name, usage_filename='.usage_counter')
	21	+ @dir_name = dir_name
	22	+ @usage_filename = usage_filename
	23	+ end
	24	+
	25	+ # Check if someone has initialized the dir. If not, call block.
	26	+
	27	+ def setup # :yields: block
	28	+ dir = File.new(@dir_name)
	29	+ dir.flock(File::LOCK_EX)
	30	+ begin
	31	+ counter_filename = get_counter_filename
	32	+ if File.exist? counter_filename
	33	+ # someone is here
	34	+ f = File.new(counter_filename,"r+")
	35	+ counter = f.read.to_i
	36	+ f.seek(0)
	37	+ f.write("#{counter+1}\n")
	38	+ f.close
	39	+ else
	40	+ # i'm the first, create the counter file
	41	+ counter = 0
	42	+ f = File.new(counter_filename,"w")
	43	+ f.write("1\n")
	44	+ f.close
	45	+ end
	46	+
	47	+ # if no one is here
	48	+ if counter == 0
	49	+ if block_given?
	50	+ yield
	51	+ end
	52	+ end
	53	+
	54	+ rescue
	55	+ raise
	56	+
	57	+ ensure
	58	+ # make sure it unlock the directory
	59	+ dir.flock(File::LOCK_UN)
	60	+ end
	61	+ end
	62	+
	63	+ # Check if I am the last one using the dir. If true, call block.
	64	+
	65	+ def teardown
	66	+ dir = File.new(@dir_name)
	67	+ dir.flock(File::LOCK_EX)
	68	+ begin
	69	+ counter_filename = get_counter_filename
	70	+ if File.exist? counter_filename
	71	+ # someone is here
	72	+ f = File.new(counter_filename,"r+")
	73	+ counter = f.read.to_i
	74	+ f.seek(0)
	75	+ f.write("#{counter-1}\n")
	76	+ f.close
	77	+
	78	+ if counter == 1
	79	+ # i'm the last one
	80	+
	81	+ File.delete(counter_filename)
	82	+ if block_given?
	83	+ yield
	84	+ end
	85	+ end
	86	+ else
	87	+ # This is BAD
	88	+ raise "Error: reference count missing"
	89	+ end
	90	+
	91	+ rescue
	92	+ raise
	93	+
	94	+ ensure
	95	+ # make sure it unlock the directory
	96	+ dir.flock(File::LOCK_UN)
	97	+ end
	98	+ end
	99	+
	100	+ protected
	101	+
	102	+ def get_counter_filename
	103	+ return File.join(@dir_name,@usage_filename)
	104	+ end
	105	+
	106	+ end
	107	+ end

std-script/.gitignore created 644 ¶ +2

@@ -0,0 +1,2
	1	+ box
	2	+

lib/engine.rb ¶ +39 -2

               require 'fileutils'
+            + require 'ftools'
+            + require 'lib/dir_init'
               module Grader
                 #
                 # A grader engine grades a submission, against anything: a test
                 # data, or a user submitted test data.  It uses two helpers objects:
                 # room_maker and reporter.
                 #
                 class Engine
                   attr_writer :room_maker
                   attr_writer :reporter
                   def initialize(room_maker=nil, reporter=nil)
                     @config = Grader::Configuration.get_instance
                     @room_maker = room_maker || Grader::SubmissionRoomMaker.new
                     @reporter = reporter || Grader::SubmissionReporter.new
                   end
                   # takes a submission, asks room_maker to produce grading directories,
                   # calls grader scripts, and asks reporter to save the result
                   def grade(submission)
                     current_dir = `pwd`.chomp
                       lang_ext = 'c'
                     end
                     # FIX THIS
                     talk 'some hack on language'
                     if language == 'cpp'
                       language = 'c++'
                     end
                     # COMMENT: should it be only source.ext?
                     if problem!=nil
                       source_name = "#{problem.name}.#{lang_ext}"
                     else
                       source_name = "source.#{lang_ext}"
                     end
                     begin
                       grading_dir = @room_maker.produce_grading_room(submission)
                       @room_maker.save_source(submission,source_name)
                       problem_home = @room_maker.find_problem_home(submission)
                       # puts "GRADING DIR: #{grading_dir}"
                       # puts "PROBLEM DIR: #{problem_home}"
-            -         copy_log = copy_script(problem_home)
+            +         dinit = DirInit::Manager.new(problem_home)
+            +
+            +         dinit.setup do
+            +           copy_log = copy_script(problem_home)
+            +           save_copy_log(problem_home,copy_log)
+            +         end
                       call_judge(problem_home,language,grading_dir,source_name)
                       @reporter.report(submission,"#{grading_dir}/test-result")
-            -         clear_script(copy_log,problem_home)
+            +         dinit.teardown do
+            +           copy_log = load_copy_log(problem_home)
+            +           clear_copy_log(problem_home)
+            +           clear_script(copy_log,problem_home)
+            +         end
                     rescue RuntimeError => msg
                       @reporter.report_error(submission,"Grading error: #{msg}")
                     ensure
                       @room_maker.clean_up(submission)
                       Dir.chdir(current_dir)   # this is really important
                     end
                   end
                   protected
                   def talk(str)
                     if @config.talkative
                       puts str
                     end
                   end
                   def call_judge(problem_home,language,grading_dir,fname)
                     ENV['PROBLEM_HOME'] = problem_home
                     talk grading_dir
                     Dir.chdir grading_dir
                     cmd = "#{problem_home}/script/judge #{language} #{fname}"
                   def get_std_script_dir
                     GRADER_ROOT + '/std-script'
                   end
                   def copy_script(problem_home)
                     script_dir = "#{problem_home}/script"
                     std_script_dir = get_std_script_dir
                     raise "std-script directory not found" if !FileTest.exist?(std_script_dir)
                     scripts = Dir[std_script_dir + '/*']
                     copied = []
                     scripts.each do |s|
                       fname = File.basename(s)
                       if !FileTest.exist?("#{script_dir}/#{fname}")
                         copied << fname
                         system("cp #{s} #{script_dir}")
                       end
                     end
                     return copied
                   end
+            +
+            +     def copy_log_filename(problem_home)
+            +       return File.join(problem_home, '.scripts_copied')
+            +     end
+            +
+            +     def save_copy_log(problem_home, log)
+            +       f = File.new(copy_log_filename(problem_home),"w")
+            +       log.each do |fname|
+            +         f.write("#{fname}\n")
+            +       end
+            +       f.close
+            +     end
+            +     def load_copy_log(problem_home)
+            +       f = File.new(copy_log_filename(problem_home),"r")
+            +       log = []
+            +       f.readlines.each do |line|
+            +         log << line.strip
+            +       end
+            +       f.close
+            +       log
+            +     end
+            +
+            +     def clear_copy_log(problem_home)
+            +       File.delete(copy_log_filename(problem_home))
+            +     end
+            +
                   def clear_script(log,problem_home)
                     log.each do |s|
                       system("rm #{problem_home}/script/#{s}")
                     end
                   end
                   def mkdir_if_does_not_exist(dirname)
                     Dir.mkdir(dirname) if !FileTest.exist?(dirname)
                   end
                 end
               end

Write
Preview

You need to be logged in to leave comments. Login now

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository permissions settings

Sign in to your account

Author

r71:76c4d891d4d5 - Mon, 27 Apr 2009 13:49:37 - 3 files changed: 148 inserted, 2 deleted

Sign in to your account

Commit r71:76c4d891d4d5 public

Author

r71:76c4d891d4d5 - Mon, 27 Apr 2009 13:49:37 - 3 files changed: 148 inserted, 2 deleted

Commit `r71:76c4d891d4d5` public