cafe-grader-web Commit - r182:f58cdc625e87

cafe-grader-web

Commit `r182:f58cdc625e87` public

parent | child

Description:

added simple grader messaging service git-svn-id: http://theory.cpe.ku.ac.th/grader/web/trunk@385 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

r182:f58cdc625e87 - Wed, 29 Apr 2009 03:07:16 - 5 files changed: 127 inserted, 1 deleted

app/models/grader_message.rb created 644 ¶ +85

@@ -0,0 +1,85
	1	+ class GraderMessage < ActiveRecord::Base
	2	+
	3	+ GRADE_SUBMISSION = 1
	4	+ GRADE_TEST_REQUEST = 2
	5	+ STOP = 3
	6	+
	7	+ def self.create_message(recipient, command, options=nil, target_id=nil)
	8	+ recipient_id = recipient
	9	+ if recipient == :all
	10	+ recipient_id = -1
	11	+ elsif recipient == :any
	12	+ recipient_id = 0
	13	+ end
	14	+
	15	+ GraderMessage.create(:grader_process_id => recipient_id,
	16	+ :command => command,
	17	+ :options => options,
	18	+ :target_id => target_id,
	19	+ :taken => false)
	20	+ end
	21	+
	22	+ def self.create_grade_submission(mode,submission)
	23	+ GraderMessage.create_message(:any,
	24	+ GraderMessage::GRADE_SUBMISSION,
	25	+ mode,
	26	+ submission.id)
	27	+ end
	28	+
	29	+ def self.create_grade_test_request(mode,test_request)
	30	+ GraderMessage.create_message(:any,
	31	+ GraderMessage::GRADE_TEST_REQUEST,
	32	+ mode,
	33	+ test_request.id)
	34	+ end
	35	+
	36	+ def self.create_stop(grader_process_id)
	37	+ GraderMessage.create_message(grader_process_id,
	38	+ GraderMessage::STOP)
	39	+ end
	40	+
	41	+ def self.get_message_for(recipient_id, accepting_commands=:all)
	42	+ command_conditions =
	43	+ GraderMessage.build_command_conditions(accepting_commands)
	44	+ recp_conditions= "((`grader_process_id` = #{recipient_id.to_i})" +
	45	+ " OR (`grader_process_id` = 0) OR (`grader_process_id` = -1))"
	46	+
	47	+ message = nil # need this to bind message in do-block for transaction
	48	+ begin
	49	+ GraderMessage.transaction do
	50	+ message = GraderMessage.find(:first,
	51	+ :order => "created_at",
	52	+ :conditions =>
	53	+ "(`taken`=0)" +
	54	+ "AND (#{recp_conditions})" +
	55	+ " AND (#{command_conditions})",
	56	+ :lock => true)
	57	+ if message!=nil
	58	+ message.taken = true
	59	+ message.save!
	60	+ end
	61	+ end
	62	+
	63	+ rescue
	64	+ message = nil
	65	+
	66	+ end
	67	+
	68	+ message
	69	+ end
	70	+
	71	+ protected
	72	+
	73	+ def self.build_command_conditions(accepting_commands)
	74	+ if accepting_commands==:all
	75	+ return '(1=1)'
	76	+ else
	77	+ conds = []
	78	+ accepting_commands.each do \|command\|
	79	+ conds << "(`command` = #{command.to_i})"
	80	+ end
	81	+ return "(" + conds.join(" OR ") + ")"
	82	+ end
	83	+ end
	84	+
	85	+ end

db/migrate/20090429014554_create_grader_messages.rb created 644 ¶ +16

@@ -0,0 +1,16
	1	+ class CreateGraderMessages < ActiveRecord::Migration
	2	+ def self.up
	3	+ create_table :grader_messages do \|t\|
	4	+ t.integer :grader_process_id
	5	+ t.integer :command
	6	+ t.string :options
	7	+ t.integer :target_id
	8	+ t.boolean :taken
	9	+ t.timestamps
	10	+ end
	11	+ end
	12	+
	13	+ def self.down
	14	+ drop_table :grader_messages
	15	+ end
	16	+ end

test/fixtures/grader_messages.yml created 644 ¶ +7

@@ -0,0 +1,7
	1	+ # Read about fixtures at http://ar.rubyonrails.org/classes/Fixtures.html
	2	+
	3	+ # one:
	4	+ # column: value
	5	+ #
	6	+ # two:
	7	+ # column: value

test/unit/grader_message_test.rb created 644 ¶ +8

@@ -0,0 +1,8
	1	+ require 'test_helper'
	2	+
	3	+ class GraderMessageTest < ActiveSupport::TestCase
	4	+ # Replace this with your real tests.
	5	+ test "the truth" do
	6	+ assert true
	7	+ end
	8	+ end

db/schema.rb ¶ +11 -1

               # This file is auto-generated from the current state of the database. Instead of editing this file,
               # please use the migrations feature of Active Record to incrementally modify your database, and
               # then regenerate this schema definition.
               #
               # Note that this schema.rb definition is the authoritative source for your database schema. If you need
               # to create the application database on another system, you should be using db:schema:load, not running
               # all the migrations from scratch. The latter is a flawed and unsustainable approach (the more migrations
               # you'll amass, the slower it'll run and the greater likelihood for issues).
               #
               # It's strongly recommended to check this file into your version control system.
-            - ActiveRecord::Schema.define(:version => 20090426131044) do
+            + ActiveRecord::Schema.define(:version => 20090429014554) do
                 create_table "announcements", :force => true do |t|
                   t.string   "author"
                   t.text     "body"
                   t.boolean  "published"
                   t.datetime "created_at"
                   t.datetime "updated_at"
                   t.boolean  "frontpage",    :default => false
                   t.boolean  "contest_only", :default => false
                 end
                 create_table "configurations", :force => true do |t|
                   t.string   "key"
                   t.string   "value_type"
                   t.string   "value"
                   t.datetime "created_at"
                   t.datetime "updated_at"
                 end
                 create_table "countries", :force => true do |t|
                   t.string   "name"
                   t.datetime "created_at"
                   t.datetime "updated_at"
                 end
                 create_table "descriptions", :force => true do |t|
                   t.text     "body"
                   t.boolean  "markdowned"
                   t.datetime "created_at"
                   t.datetime "updated_at"
                 end
+            +   create_table "grader_messages", :force => true do |t|
+            +     t.integer  "grader_process_id"
+            +     t.integer  "command"
+            +     t.string   "options"
+            +     t.integer  "target_id"
+            +     t.boolean  "taken"
+            +     t.datetime "created_at"
+            +     t.datetime "updated_at"
+            +   end
+            +
                 create_table "grader_processes", :force => true do |t|
                   t.string   "host",       :limit => 20
                   t.integer  "pid"
                   t.string   "mode"
                   t.boolean  "active"
                   t.datetime "created_at"
                   t.datetime "updated_at"
                   t.integer  "task_id"
                   t.string   "task_type"
                   t.boolean  "terminated"
                 end
                 add_index "grader_processes", ["host", "pid"], :name => "index_grader_processes_on_ip_and_pid"
                 create_table "languages", :force => true do |t|
                   t.string "name",        :limit => 10
                   t.string "pretty_name"
                   t.string "ext",         :limit => 10
                   t.string "common_ext"
                 end
                 create_table "messages", :force => true do |t|
                   t.integer  "sender_id"
                   t.integer  "receiver_id"
                   t.integer  "replying_message_id"
                   t.text     "body"
                   t.boolean  "replied"
                   t.datetime "created_at"
                   t.datetime "updated_at"
                 end
                 create_table "problems", :force => true do |t|
                   t.string  "name",           :limit => 30
                   t.string  "full_name"
                   t.integer "full_score"
                   t.date    "date_added"
                   t.boolean "available"
                   t.string  "url"
                   t.integer "description_id"
                   t.boolean "test_allowed"
                   t.boolean "output_only"
                 end
                 create_table "rights", :force => true do |t|
                   t.string "name"
                   t.string "controller"
                   t.string "action"
                 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

r182:f58cdc625e87 - Wed, 29 Apr 2009 03:07:16 - 5 files changed: 127 inserted, 1 deleted

Sign in to your account

Commit r182:f58cdc625e87 public

Author

r182:f58cdc625e87 - Wed, 29 Apr 2009 03:07:16 - 5 files changed: 127 inserted, 1 deleted

Commit `r182:f58cdc625e87` public