1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
|
require_relative "../core"
require_relative "../lib/sonicpi/runtime"
require_relative "../lib/sonicpi/lang/core"
require_relative "../lib/sonicpi/event_history"
require_relative "../lib/sonicpi/thread_id"
require_relative "../lib/sonicpi/lang/western_theory"
require 'minitest'
require 'minitest/autorun'
module SonicPi
class MockStudio
end
class MockLang
attr_accessor :mod_sound_studio, :sample_loader, :msg_queue, :event_history
include SonicPi::RuntimeMethods
include SonicPi::Lang::Core
include SonicPi::Lang::WesternTheory
include SonicPi::Lang::Sound
include ActiveSupport
def initialize
@mod_sound_studio = MockStudio.new
@msg_queue = Queue.new
__set_default_user_thread_locals!
@system_init_thread_id = ThreadId.new(-1)
@settings = Config::Settings.new("/bogus/path/to/default/to/empty/settings.txt")
@version = Version.new(0, 0, 0, "test")
@server_version = Version.new(1, 0, 0, "final")
@life_hooks = LifeCycleHooks.new
@msg_queue = Queue.new
@cue_events = IncomingEvents.new
@sync_counter = Counter.new
@job_counter = Counter.new(-1) # Start counting jobs from 0
@job_subthreads = {}
@job_main_threads = {}
@named_subthreads = {}
@job_subthread_mutex = Mutex.new
@user_jobs = Jobs.new
@user_methods = []
@global_start_time = Time.now
@session_id = SecureRandom.uuid
@snippets = {}
@gui_cue_log_idxs = Counter.new
@system_state = EventHistory.new(@job_subthreads, @job_subthread_mutex)
@user_state = EventHistory.new(@job_subthreads, @job_subthread_mutex)
@event_history = EventHistory.new(@job_subthreads, @job_subthread_mutex)
@system_state.set 0, 0, @system_init_thread_id, 0, 0, 60, :sched_ahead_time, 0.5
@register_cue_event_lambda = lambda do |t, p, i, d, b, m, address, args, sched_ahead_time=0|
address, _sym = *address if address.is_a?(Array)
gui_log_id = @gui_cue_log_idxs.next
a = args.freeze
@event_history.set(t, p, i, d, b, m, address.freeze, a)
@cue_events.async_event("/spider_thread_sync/#{address}", {
:time => t,
:cue_splat_map_or_arr => a,
:cue => address })
sched_ahead_sync_t = t + sched_ahead_time
sleep_time = sched_ahead_sync_t - Time.now
if sleep_time > 0
Thread.new do
Kernel.sleep(sleep_time) if sleep_time > 0
__msg_queue.push({:type => :incoming, :time => t.to_s, :id => gui_log_id, :address => address, :args => a.inspect})
end
else
__msg_queue.push({:type => :incoming, :time => t.to_s, :id => gui_log_id, :address => address, :args => a.inspect})
end
end
end
def __error(e, m=nil)
raise e
end
def run(&blk)
id = 0
silent = false
info = {}.freeze
now = Time.now.freeze
job_in_thread = nil
job = Thread.new do
Thread.current.abort_on_exception = true
reg_job 0, Thread.current
__system_thread_locals.set_local :sonic_pi_local_thread_group, "job-#{id}"
__system_thread_locals.set_local :sonic_pi_spider_thread_id_path, ThreadId.new(id)
__system_thread_locals.set :sonic_pi_spider_job_id, id
__system_thread_locals.set :sonic_pi_spider_silent, silent
__system_thread_locals.set :sonic_pi_spider_job_info, info
__system_thread_locals.set :sonic_pi_spider_time, now
__system_thread_locals.set :sonic_pi_spider_start_time, now
__system_thread_locals.set :sonic_pi_spider_beat, 0
__system_thread_locals.set_local :sonic_pi_local_spider_delayed_messages, []
__set_default_system_thread_locals!
__set_default_user_thread_locals!
job_in_thread = in_thread do
clear
self.instance_eval(&blk)
end
end
@user_jobs.add_job(id, job, info)
t = Thread.new do
Thread.current.priority = -10
__system_thread_locals.set_local(:sonic_pi_local_thread_group, "job-#{id}-GC")
job.join
__system_thread_locals(job_in_thread).get(:sonic_pi_local_spider_subthread_empty).get
# wait until all synths are dead
@life_hooks.completed(id)
@life_hooks.exit(id, {:start_t => now})
deregister_job_and_return_subthreads(id)
@user_jobs.job_completed(id)
Kernel.sleep default_sched_ahead_time
unless @user_jobs.any_jobs_running?
@life_hooks.all_completed(silent)
end
end
t.join
end
def __schedule_delayed_blocks_and_messages!(*args)
# do nothing
end
end
end
|
