##// END OF EJS Templates
jro_apps » redmine
RSS
Adds a test for #6579....
Jean-Philippe Lang -
r13646:8ad326f1609c
parent child
Show More
Side by Side Unified
Context file:
r13646:8ad326f1609c Loading diff...:
Show file before | Show file after | Hide comments
@@ -27,6 +27,7 class IssueNestedSetConcurrencyTest < ActiveSupport::TestCase
27 self.use_transactional_fixtures = false
27 self.use_transactional_fixtures = false
28
28
29 def setup
29 def setup
30 skip if sqlite?
30 CustomField.delete_all
31 CustomField.delete_all
31 end
32 end
32
33
@@ -35,8 +36,6 class IssueNestedSetConcurrencyTest < ActiveSupport::TestCase
35 end
36 end
36
37
37 def test_concurrency
38 def test_concurrency
38 skip if sqlite?
39 with_settings :notified_events => [] do
40 # Generates an issue and destroys it in order
39 # Generates an issue and destroys it in order
41 # to load all needed classes before starting threads
40 # to load all needed classes before starting threads
42 i = Issue.generate!
41 i = Issue.generate!
@@ -44,11 +43,7 class IssueNestedSetConcurrencyTest < ActiveSupport::TestCase
44
43
45 root = Issue.generate!
44 root = Issue.generate!
46 assert_difference 'Issue.count', 60 do
45 assert_difference 'Issue.count', 60 do
47 threads = []
46 threaded(3) do
48 3.times do |i|
49 threads << Thread.new(i) do
50 ActiveRecord::Base.connection_pool.with_connection do
51 begin
52 10.times do
47 10.times do
53 i = Issue.generate! :parent_issue_id => root.id
48 i = Issue.generate! :parent_issue_id => root.id
54 c1 = Issue.generate! :parent_issue_id => i.id
49 c1 = Issue.generate! :parent_issue_id => i.id
@@ -57,6 +52,35 class IssueNestedSetConcurrencyTest < ActiveSupport::TestCase
57 c2.reload.destroy
52 c2.reload.destroy
58 c1.reload.destroy
53 c1.reload.destroy
59 end
54 end
55 end
56 end
57 end
58
59 def test_concurrent_subtasks_creation
60 root = Issue.generate!
61 assert_difference 'Issue.count', 30 do
62 threaded(3) do
63 10.times do
64 Issue.generate! :parent_issue_id => root.id
65 end
66 end
67 end
68 root.reload
69 assert_equal [1, 62], [root.lft, root.rgt]
70 children_bounds = root.children.sort_by(&:lft).map {|c| [c.lft, c.rgt]}.flatten
71 assert_equal (2..61).to_a, children_bounds
72 end
73
74 private
75
76 def threaded(count, &block)
77 with_settings :notified_events => [] do
78 threads = []
79 count.times do |i|
80 threads << Thread.new(i) do
81 ActiveRecord::Base.connection_pool.with_connection do
82 begin
83 yield
60 rescue Exception => e
84 rescue Exception => e
61 Thread.current[:exception] = e.message
85 Thread.current[:exception] = e.message
62 end
86 end
@@ -70,4 +94,3 class IssueNestedSetConcurrencyTest < ActiveSupport::TestCase
70 end
94 end
71 end
95 end
72 end
96 end
73 end
General Comments 0
You need to be logged in to leave comments. Login now