Description:
merge from algo-bm
Commit status:
[Not Reviewed]
References:
Diff options:
Comments:
0 Commit comments
0 Inline Comments
Unresolved TODOs:
There are no unresolved TODOs
r173:aa6e7ff3942c - - 9 files changed: 117 inserted, 27 deleted
@@ -46,11 +46,22 | |||
|
46 | 46 | puts <<USAGE |
|
47 | 47 | Grader. |
|
48 | 48 | using: (1) grader |
|
49 | - (2) grader environment [mode] | |
|
49 | + (2) grader environment [mode] [options] | |
|
50 | 50 | (3) grader stop [all|pids-list] |
|
51 | 51 | (4) grader --help |
|
52 | 52 | (1) call grader with environment = 'exam', mode = 'queue' |
|
53 | 53 | (2) possible modes are: 'queue', 'test_request', 'prob', 'sub', 'contest', and 'autonew' |
|
54 | + queue: repeatedly check the task queue and grade any available tasks | |
|
55 | + | |
|
56 | + prob: re-grade every user latest submission of the specific problem. | |
|
57 | + the problem name must be specified by the next argument. | |
|
58 | + | |
|
59 | + additional options: | |
|
60 | + | |
|
61 | + --all-sub re-grade every submissions instead of just the latest submission of each user. | |
|
62 | + sub: re-grader the specified submission. | |
|
63 | + The submission ID to be re-graded must be specified by the next argument. | |
|
64 | + | |
|
54 | 65 | (3) create stop-file to stop running grader in queue mode |
|
55 | 66 | (4) You are here. |
|
56 | 67 | USAGE |
@@ -105,6 +116,8 | |||
|
105 | 116 | if ARGV.length >=1 |
|
106 | 117 | options[:mode] = ARGV.shift |
|
107 | 118 | end |
|
119 | + else | |
|
120 | + puts 'no argument specified, using default mode and environment.' | |
|
108 | 121 | end |
|
109 | 122 | |
|
110 | 123 | options[:dry_run] = (ARGV.delete('--dry') != nil) |
@@ -119,6 +132,8 | |||
|
119 | 132 | exit(0) |
|
120 | 133 | end |
|
121 | 134 | |
|
135 | + options[:all_sub] = (ARGV.delete('--all-sub') != nil) | |
|
136 | + | |
|
122 | 137 | return options |
|
123 | 138 | end |
|
124 | 139 | |
@@ -295,7 +310,7 | |||
|
295 | 310 | if prob==nil |
|
296 | 311 | puts "cannot find problem: #{prob_name}" |
|
297 | 312 | else |
|
298 | - runner.grade_problem(prob) | |
|
313 | + runner.grade_problem(prob,options) | |
|
299 | 314 | end |
|
300 | 315 | end |
|
301 | 316 | |
@@ -378,6 +393,7 | |||
|
378 | 393 | dry_run = options[:dry_run] |
|
379 | 394 | |
|
380 | 395 | puts "environment: #{GRADER_ENV}" |
|
396 | + puts "grader mode: #{grader_mode}" | |
|
381 | 397 | require File.join(File.dirname(__FILE__),'config/environment') |
|
382 | 398 | |
|
383 | 399 | # add grader_mode to config |
@@ -25,19 +25,24 | |||
|
25 | 25 | end |
|
26 | 26 | |
|
27 | 27 | def grade_problem(problem, options={}) |
|
28 | - users = User.find(:all) | |
|
29 | - users.each do |u| | |
|
28 | + User.find_each do |u| | |
|
30 | 29 | puts "user: #{u.login}" |
|
31 | 30 | if options[:user_conditions]!=nil |
|
32 | 31 | con_proc = options[:user_conditions] |
|
33 | 32 | next if not con_proc.call(u) |
|
34 | 33 | end |
|
34 | + if options[:all_sub] | |
|
35 | + Submission.where(user_id: u.id,problem_id: problem.id).find_each do |sub| | |
|
36 | + @engine.grade(sub) | |
|
37 | + end | |
|
38 | + else | |
|
35 | 39 | last_sub = Submission.find_last_by_user_and_problem(u.id,problem.id) |
|
36 | 40 | if last_sub!=nil |
|
37 | 41 | @engine.grade(last_sub) |
|
38 | 42 | end |
|
39 | 43 | end |
|
40 | 44 | end |
|
45 | + end | |
|
41 | 46 | |
|
42 | 47 | def grade_submission(submission) |
|
43 | 48 | puts "Submission: #{submission.id} by #{submission.user.full_name}" |
@@ -66,6 +66,7 | |||
|
66 | 66 | |
|
67 | 67 | result_fname = "#{test_result_dir}/result" |
|
68 | 68 |
comment_fname = "#{test_result_dir}/comment" |
|
69 | + runstat_fname = "#{test_result_dir}/run_stat" | |
|
69 | 70 | if FileTest.exist?(result_fname) |
|
70 | 71 | comment = "" |
|
71 | 72 | begin |
@@ -85,9 +86,22 | |||
|
85 | 86 | comment += "" |
|
86 | 87 | end |
|
87 | 88 | |
|
88 | - return {:points => result, | |
|
89 | - :comment => comment, | |
|
90 | - :cmp_msg => cmp_msg} | |
|
89 | + begin | |
|
90 | + runstat_file = File.open(runstat_fname) | |
|
91 | + max_runtime = runstat_file.readline.to_f | |
|
92 | + peak_memory = runstat_file.readline.to_i | |
|
93 | + rescue | |
|
94 | + max_runtime = -1 | |
|
95 | + peak_memory = -1 | |
|
96 | + end | |
|
97 | + | |
|
98 | + | |
|
99 | + return {points: result, | |
|
100 | + comment: comment, | |
|
101 | + cmp_msg: cmp_msg, | |
|
102 | + max_runtime: max_runtime, | |
|
103 | + peak_memory: peak_memory | |
|
104 | + } | |
|
91 | 105 | else |
|
92 | 106 | if FileTest.exist?("#{test_result_dir}/a.out") |
|
93 | 107 | return {:points => 0, |
@@ -108,6 +122,10 | |||
|
108 | 122 | submission.points = points |
|
109 | 123 | comment = @config.report_comment(result[:comment]) |
|
110 | 124 | |
|
125 | + submission.peak_memory = result[:peak_memory] | |
|
126 | + submission.max_runtime = result[:max_runtime] | |
|
127 | + submission.effective_code_length =submission.source.length | |
|
128 | + | |
|
111 | 129 | # |
|
112 | 130 | # TODO: FIX THIS MESSAGE |
|
113 | 131 | # |
@@ -198,7 +198,7 | |||
|
198 | 198 | end |
|
199 | 199 | |
|
200 | 200 | # extract memory usage |
|
201 |
- if res = /s(.*) |
|
|
201 | + if res = /s(.*)kbytes/.match(running_stat_line) | |
|
202 | 202 | memory_used = res[1].to_i |
|
203 | 203 | else |
|
204 | 204 | memory_used = -1 |
@@ -160,7 +160,7 | |||
|
160 | 160 | //total is user |
|
161 | 161 | //wall is wall |
|
162 | 162 | // |
|
163 |
- fprintf(stderr,"%.4lfr%.4lfu%.4lfs%d |
|
|
163 | + fprintf(stderr,"%.4lfr%.4lfu%.4lfs%dkbytes\n", | |
|
164 | 164 | wall_time, user_time, system_time, mem_usage); |
|
165 | 165 | } |
|
166 | 166 | |
@@ -209,7 +209,7 | |||
|
209 | 209 | (double)wall_ms/1000, |
|
210 | 210 | (double)total_ms/1000, |
|
211 | 211 | (double)sys_ms/1000, |
|
212 |
- |
|
|
212 | + mem_peak_kb); | |
|
213 | 213 | meta_close(); |
|
214 | 214 | exit(rc); |
|
215 | 215 | } |
@@ -1456,11 +1456,6 | |||
|
1456 | 1456 | err("TO: Time limit exceeded (wall clock)"); |
|
1457 | 1457 | flush_line(); |
|
1458 | 1458 | fprintf(stderr,"OK\n"); |
|
1459 | - print_running_stat( | |
|
1460 | - (double)wall_ms/1000, | |
|
1461 | - (double)total_ms/1000, | |
|
1462 | - (double)sys_ms/1000, | |
|
1463 | - (mem_peak_kb + 1023) / 1024); | |
|
1464 | 1459 | box_exit(0); |
|
1465 | 1460 | } |
|
1466 | 1461 | if (WIFSIGNALED(stat)) |
@@ -30,12 +30,14 | |||
|
30 | 30 | RUBY_INTERPRETER = "/usr/bin/ruby" |
|
31 | 31 | PYTHON_INTERPRETER = "/usr/bin/python" |
|
32 | 32 | PYTHON_CHECKER = "/usr/bin/pyflakes" |
|
33 | + PHP_INTERPRETER = "/usr/bin/php" | |
|
33 | 34 | |
|
34 | 35 | C_OPTIONS = "-O2 -s -static -std=c99 -DCONTEST -lm -Wall" |
|
35 | - CPLUSPLUS_OPTIONS = "-O2 -s -static -DCONTEST -lm -Wall" | |
|
36 | + CPLUSPLUS_OPTIONS = "-O2 -s -std=c++11 -static -DCONTEST -lm -Wall" | |
|
36 | 37 | PASCAL_OPTIONS = "-O1 -XS -dCONTEST" |
|
37 | 38 | JAVA_OPTIONS = "" |
|
38 | 39 | PYTHON_OPTIONS = "" |
|
40 | + PHP_OPTIONS = "-l" | |
|
39 | 41 | |
|
40 | 42 | # Check for the correct number of arguments. Otherwise, print usage. |
|
41 | 43 | if ARGV.length == 0 or ARGV.length > 4 |
@@ -108,11 +110,18 | |||
|
108 | 110 | |
|
109 | 111 | #get the class name |
|
110 | 112 | classname = 'DUMMY' |
|
113 | + source = Array.new | |
|
111 | 114 | File.foreach(params[:source_file]) do |line| |
|
112 | 115 | md = /\s*public\s*class\s*(\w*)/.match(line) |
|
113 | 116 | classname=md[1] if md |
|
117 | + source << line unless line =~ /\s*package\s*\w+\s*\;/ | |
|
114 | 118 | end |
|
115 | - system("cp #{params[:source_file]} #{classname}.java") | |
|
119 | + File.open("#{classname}.java","w") do |file| | |
|
120 | + source.each do |s| | |
|
121 | + file.puts s | |
|
122 | + end | |
|
123 | + end | |
|
124 | + #system("cp #{params[:source_file]} #{classname}.java") | |
|
116 | 125 | command = "#{JAVA_COMPILER} #{classname}.java 2> #{params[:message_file]}" |
|
117 | 126 | system(command) |
|
118 | 127 | if File.exists?(classname + ".class") |
@@ -147,6 +156,19 | |||
|
147 | 156 | out_file.puts "#!#{PYTHON_INTERPRETER} #{params[:source_file]}c" |
|
148 | 157 | end |
|
149 | 158 | File.chmod(0755, params[:output_file]) |
|
159 | + FileUtils.cp("#{params[:source_file]}c",params[:output_file]) | |
|
160 | + end | |
|
161 | + | |
|
162 | + when "php" | |
|
163 | + command = "#{PHP_INTERPRETER} #{PHP_OPTIONS} #{params[:source_file]} 2> #{params[:message_file]}" | |
|
164 | + if system(command) | |
|
165 | + File.open(params[:output_file],"w") do |out_file| | |
|
166 | + out_file.puts "#!#{PHP_INTERPRETER}" | |
|
167 | + File.open(params[:source_file],"r").each do |line| | |
|
168 | + out_file.print line | |
|
169 | + end | |
|
170 | + end | |
|
171 | + File.chmod(0755, params[:output_file]) | |
|
150 | 172 | end |
|
151 | 173 | |
|
152 | 174 | else |
@@ -31,6 +31,17 | |||
|
31 | 31 | end |
|
32 | 32 | end |
|
33 | 33 | |
|
34 | + def extract_time(t) | |
|
35 | + #puts "TIME: #{t}" | |
|
36 | + if (result=/^(.*)r(.*)u(.*)s(.*)kbytes/.match(t)) | |
|
37 | + {:real => result[1], :user => result[2], :sys => result[3], :mem => result[4]} | |
|
38 | + else | |
|
39 | + #{:real => 0, :user => 0, :sys => 0} | |
|
40 | + #puts "ERROR READING RUNNING TIME: #{t}" | |
|
41 | + raise "Error reading running time: #{t}" | |
|
42 | + end | |
|
43 | + end | |
|
44 | + | |
|
34 | 45 | problem_home = ENV['PROBLEM_HOME'] |
|
35 | 46 | require "#{problem_home}/script/test_dsl.rb" |
|
36 | 47 | load "#{problem_home}/test_cases/all_tests.cfg" |
@@ -43,6 +54,8 | |||
|
43 | 54 | |
|
44 | 55 | all_score = 0 |
|
45 | 56 | all_comment = '' |
|
57 | + peak_memory = -1 | |
|
58 | + max_runtime = -1 | |
|
46 | 59 | (1..(problem.runs.length-1)).each do |k| |
|
47 | 60 | log "grade run #{k}" |
|
48 | 61 | run = problem.runs[k] |
@@ -58,10 +71,15 | |||
|
58 | 71 | else |
|
59 | 72 | result_file = File.new(result_file_name, "r") |
|
60 | 73 | result_file_lines = result_file.readlines |
|
61 |
- if result_file_lines.length>= |
|
|
74 | + if result_file_lines.length>=3 | |
|
62 | 75 | current_run_score = result_file_lines[1].to_i |
|
63 | 76 | run_comment += result_file_lines[0] |
|
64 | 77 | run_comment_short += char_comment(result_file_lines[0].chomp) |
|
78 | + | |
|
79 | + #update max runtime & memory | |
|
80 | + run_stat = extract_time result_file_lines[2] | |
|
81 | + peak_memory = [peak_memory,run_stat[:mem].to_i].max | |
|
82 | + max_runtime = [max_runtime,run_stat[:user].to_f + run_stat[:sys].to_f].max | |
|
65 | 83 | else |
|
66 | 84 | current_run_score = 0 |
|
67 | 85 | run_comment += "result file for test #{test_num} error\n" |
@@ -105,4 +123,11 | |||
|
105 | 123 | comment_file.write "#{all_comment}\n" |
|
106 | 124 | comment_file.close |
|
107 | 125 | |
|
108 | - log "score = #{all_score} comment = #{all_comment}" | |
|
126 | + | |
|
127 | + File.open("run_stat","w") do |file| | |
|
128 | + file.puts max_runtime | |
|
129 | + file.puts peak_memory | |
|
130 | + end | |
|
131 | + | |
|
132 | + log "score = #{all_score}\ncomment = #{all_comment}" | |
|
133 | + log "max_runtime = #{max_runtime}\npeak_memory = #{peak_memory}" |
@@ -53,12 +53,13 | |||
|
53 | 53 | end |
|
54 | 54 | |
|
55 | 55 | language = ARGV[0] |
|
56 | - if language != "c" && language != "c++" && language != "pas" && language != "java" && language != "ruby" && language != "python" | |
|
56 | + if language != "c" && language != "c++" && language != "pas" && language != "java" && language != "ruby" && language != "python" && language != "php" | |
|
57 | 57 | log "You specified a language that is not supported: #{language}." |
|
58 | 58 | exit(127) |
|
59 | 59 | end |
|
60 | 60 | |
|
61 | 61 | source_file = ARGV[1] |
|
62 | + ENV['SOURCE_NAME'] = source_file | |
|
62 | 63 | if File.exist?(source_file) == false |
|
63 | 64 | log "The source file does not exist." |
|
64 | 65 | exit(127) |
@@ -43,10 +43,13 | |||
|
43 | 43 | end |
|
44 | 44 | |
|
45 | 45 | problem_home = ENV['PROBLEM_HOME'] |
|
46 | + source_name = ENV['SOURCE_NAME'] | |
|
46 | 47 | require "#{problem_home}/script/test_dsl.rb" |
|
47 | 48 | load "#{problem_home}/test_cases/all_tests.cfg" |
|
48 | 49 | problem = Problem.get_instance |
|
49 | 50 | |
|
51 | + sandbox_dir = Dir.getwd | |
|
52 | + | |
|
50 | 53 | if problem.well_formed? == false |
|
51 | 54 | log "The problem specification is not well formed." |
|
52 | 55 | exit(127) |
@@ -81,29 +84,33 | |||
|
81 | 84 | |
|
82 | 85 | # Hide PROBLEM_HOME |
|
83 | 86 | ENV['PROBLEM_HOME'] = nil |
|
87 | + ENV['SOURCE_NAME'] = nil | |
|
84 | 88 | |
|
85 | 89 | # Run the program. |
|
86 | 90 | #run_command = "/usr/bin/time -f \"#{time_output_format}\" 2>run_result #{problem_home}/script/box_new -a 2 -f -t #{time_limit} -m #{mem_limit} -i #{input_file_name} -o output.txt #{program_name}" |
|
87 | 91 | # |
|
88 | 92 | |
|
89 | - | |
|
90 | - | |
|
93 | + JAVA_OPTION = "-s set_robust_list -s futex -s clone -s getppid -s clone -s wait4 -p /usr/bin/ -p ./" | |
|
94 | + RUBY_OPTION = "-p /usr/lib64/ -p /usr/local/lib64/ -p /usr/local/lib/ -p /lib64/ -p /dev/urandom -p #{sandbox_dir}/#{program_name} -p #{sandbox_dir}/ -s set_robust_list -s sched_getaffinity -s clock_gettime -s sigaltstack -s pipe2 -s clone -s futex -s openat -s pipe" | |
|
95 | + PYTHON_OPTION = "-p /usr/lib64/ -p /usr/local/lib64/ -p /usr/local/lib/ -p /usr/bin/ -p /lib64/ -p #{sandbox_dir}/#{program_name} -p ./#{program_name} -p #{sandbox_dir}/#{source_name} -s set_robust_list -s openat -s recvmsg -s connect -s socket -s sendto -s futex -E PYTHONNOUSERSITE=yes" | |
|
96 | + PHP_OPTION = "-p /usr/lib64/ -p/lib64/ -p /usr/bin/ -p #{sandbox_dir}/#{program_name} -p ./#{program_name} -p /usr/share/ -s setfsuid -s setfsgid -s openat -s set_robust_list -s futex -s clone -s socket -s connect" | |
|
91 | 97 | |
|
92 | 98 | case language |
|
93 | 99 | when "java" |
|
94 | - | |
|
95 | 100 | # for java, extract the classname |
|
96 | 101 | # wne have to add additional systemcall and we don't check the mem limit (dunno how to fix...) |
|
97 | 102 | classname = 'DUMMY' |
|
98 | 103 | File.open(program_name,"r").each do |line| |
|
99 | 104 | classname = line |
|
100 | 105 | end |
|
101 | - run_command = "#{problem_home}/script/box -T -t #{time_limit} -s getppid -s clone -s wait4 -p /usr/bin/ -p ./ -i #{input_file_name} -o output.txt /usr/bin/java #{classname} 2>run_result" | |
|
106 | + #for java, we cannot really check the memory limit... | |
|
107 | + run_command = "#{problem_home}/script/box -a 3 -f -T -t #{time_limit} #{JAVA_OPTION} -i #{input_file_name} -o output.txt /usr/bin/java #{classname} 2>run_result" | |
|
102 | 108 | when "ruby" |
|
103 |
- run_command = "#{problem_home}/script/box -T -t #{time_limit |
|
|
109 | + run_command = "#{problem_home}/script/box -a 2 -f -T -t #{time_limit*=2} -m #{mem_limit} #{RUBY_OPTION} -i #{input_file_name} -o output.txt /usr/bin/ruby #{program_name} 2>run_result" | |
|
104 | 110 | when "python" |
|
105 | - #this code just run without any checking | |
|
106 | - run_command = "#{problem_home}/script/box -T -t #{time_limit} -p #{problem_home}/ -i #{input_file_name} -o output.txt #{program_name} 2>run_result" | |
|
111 | + run_command = "#{problem_home}/script/box -a 2 -f -T -t #{time_limit*=2} -m #{mem_limit} #{PYTHON_OPTION} -i #{input_file_name} -o output.txt /usr/bin/python #{program_name} 2>run_result" | |
|
112 | + when "php" | |
|
113 | + run_command = "#{problem_home}/script/box -a 2 -f -T -t #{time_limit*=2} #{PHP_OPTION} -i #{input_file_name} -o output.txt /usr/bin/php #{program_name} 2>run_result" | |
|
107 | 114 | else # for c++, pascal, we do the normal checking |
|
108 | 115 | run_command = "#{problem_home}/script/box -a 2 -f -T -t #{time_limit} -m #{mem_limit} -i #{input_file_name} -o output.txt #{program_name} 2>run_result" |
|
109 | 116 | end |
@@ -154,6 +161,7 | |||
|
154 | 161 | exit(0) |
|
155 | 162 | } |
|
156 | 163 | |
|
164 | + | |
|
157 | 165 | if run_result[0][0,2] != "OK" |
|
158 | 166 | log "There was a runtime error." |
|
159 | 167 | report.call(run_result[0], 0, "No comment.\n") |
You need to be logged in to leave comments.
Login now