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
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
|
-- Setting and clearing routes
-- TODO duplicate
local lntrans = { "A", "B" }
local function sigd_to_string(sigd)
return minetest.pos_to_string(sigd.p).." / "..lntrans[sigd.s]
end
local ildb = advtrains.interlocking.db
local ilrs = {}
-- table containing locked points
-- also manual locks (maintenance a.s.o.) are recorded here
-- [pts] = {
-- [n] = { [by = <ts_id>], rsn = <human-readable text>, [origin = <sigd>] }
-- }
ilrs.rte_locks = {}
-- Requests the given route
-- This function will try to set the designated route.
-- If this is not possible, route is inserted in the subscriber list for
-- the problematic lock points
function ilrs.request_route(signal, tcbs, routeid)
end
-- main route setting. First checks if everything can be set as designated,
-- then (if "try" is not set) actually sets it
-- returns:
-- true - route can be/was successfully set
-- false, message - something went wrong, what is contained in the message.
function ilrs.set_route(signal, route, try)
if not try then
atdebug("rteset real-run")
local tsuc, trsn = ilrs.set_route(signal, route, true)
if not tsuc then
return false, trsn
end
atdebug("doing stuff")
else
atdebug("rteset try-run")
end
-- we start at the tc designated by signal
local c_sigd = signal
local first = true
local i = 1
local rtename = route.name
local signalname = ildb.get_tcbs(signal).signal_name
local c_tcbs, c_ts_id, c_ts, c_rseg, c_lckp
while c_sigd and i<=#route do
c_tcbs = ildb.get_tcbs(c_sigd)
c_ts_id = c_tcbs.ts_id
if not c_ts_id then
if not try then atwarn("Encountered End-Of-Interlocking while setting route",rtename,"of",signal) end
return false, "No track section adjacent to "..sigd_to_string(c_sigd).."!"
end
c_ts = ildb.get_ts(c_ts_id)
c_rseg = route[i]
c_lckp = {}
if c_ts.route then
if not try then atwarn("Encountered ts lock while a real run of routesetting routine, at ts=",c_ts_id,"while setting route",rtename,"of",signal) end
return false, "Section '"..c_ts.name.."' already has route set from "..sigd_to_string(c_ts.route.origin).."!"
end
if c_ts.trains and #c_ts.trains>0 then
if not try then atwarn("Encountered ts occupied while a real run of routesetting routine, at ts=",c_ts_id,"while setting route",rtename,"of",signal) end
return false, "Section '"..c_ts.name.."' is occupied!"
end
for pts, state in pairs(c_rseg.locks) do
local confl = ilrs.has_route_lock(pts, state)
local pos = minetest.string_to_pos(pts)
local node = advtrains.ndb.get_node(pos)
local ndef = minetest.registered_nodes[node.name]
if ndef and ndef.luaautomation and ndef.luaautomation.setstate and ndef.luaautomation.getstate then
local cstate = ndef.luaautomation.getstate
if type(cstate)=="function" then cstate = cstate(pos) end
if cstate ~= state then
local confl = ilrs.has_route_lock(pts)
if confl then
if not try then atwarn("Encountered route lock while a real run of routesetting routine, at position",pts,"while setting route",rtename,"of",signal) end
return false, "Lock conflict at "..pts..", Held locked by:\n"..confl
elseif not try then
ndef.luaautomation.setstate(pos, state)
end
end
if not try then
ilrs.add_route_lock(pts, c_ts_id, "Route '"..rtename.."' from signal '"..signalname.."'", signal)
c_lckp[#c_lckp+1] = pts
end
else
if not try then atwarn("Encountered route lock misconfiguration (no passive component) while a real run of routesetting routine, at position",pts,"while setting route",rtename,"of",signal) end
return false, "Route misconfiguration: No passive component at "..pts..". Please reconfigure route!"
end
end
-- reserve ts and write locks
if not try then
c_ts.route = {
origin = signal,
entry = c_sigd,
rsn = "Route '"..rtename.."' from signal '"..signalname.."', segment #"..i,
first = first,
}
c_ts.route_post = {
locks = c_lckp,
next = c_rseg.next,
}
end
-- advance
first = nil
c_sigd = c_rseg.next
i = i + 1
end
return true
end
-- Checks whether there is a route lock that prohibits setting the component
-- to the wanted state. returns string with reasons on conflict
function ilrs.has_route_lock(pts)
-- look this up
local e = ilrs.rte_locks[pts]
if not e then return nil
elseif #e==0 then
ilrs.rte_locks[pts] = nil
return nil
end
local txts = {}
for _, ent in ipairs(e) do
txts[#txts+1] = ent.rsn
end
return table.concat(txts, "\n")
end
-- adds route lock for position
function ilrs.add_route_lock(pts, ts, rsn, origin)
ilrs.free_route_locks_indiv(pts, ts, true)
local elm = {by=ts, rsn=rsn, origin=origin}
if not ilrs.rte_locks[pts] then
ilrs.rte_locks[pts] = { elm }
else
table.insert(ilrs.rte_locks[pts], elm)
end
end
-- adds route lock for position
function ilrs.add_manual_route_lock(pts, rsn)
local elm = {rsn=rsn}
if not ilrs.rte_locks[pts] then
ilrs.rte_locks[pts] = { elm }
else
table.insert(ilrs.rte_locks[pts], elm)
end
end
-- frees route locking for all points (components) that were set by this ts
function ilrs.free_route_locks(ts, lcks, nocallbacks)
for _,pts in pairs(lcks) do
ilrs.free_route_locks_indiv(pts, ts, nocallbacks)
end
end
function ilrs.free_route_locks_indiv(pts, ts, nocallbacks)
local e = ilrs.rte_locks[pts]
if not e then return nil
elseif #e==0 then
ilrs.rte_locks[pts] = nil
return nil
end
local i = 1
while i <= #e do
if e[i].by == ts then
atdebug("free_route_locks_indiv",pts,"clearing entry",e[i].by,e[i].rsn)
table.remove(e,i)
else
i = i + 1
end
end
--TODO callbacks
end
-- frees all route locks, even manual ones set with the tool, at a specific position
function ilrs.remove_route_locks(pts, nocallbacks)
ilrs.rte_locks[pts] = nil
--TODO callbacks
end
local function sigd_equal(sigd, cmp)
return vector.equals(sigd.p, cmp.p) and sigd.s==cmp.s
end
-- starting from the designated sigd, clears all subsequent route and route_post
-- information from the track sections.
-- note that this does not clear the routesetting status from the entry signal,
-- only from the ts's
function ilrs.cancel_route_from(sigd)
-- we start at the tc designated by signal
local c_sigd = sigd
local c_tcbs, c_ts_id, c_ts, c_rseg, c_lckp
while c_sigd do
c_tcbs = ildb.get_tcbs(c_sigd)
c_ts_id = c_tcbs.ts_id
c_ts = ildb.get_ts(c_ts_id)
if not c_ts
or not c_ts.route
or not sigd_equal(c_ts.route.entry, c_sigd) then
return
end
c_ts.route = nil
if c_ts.route_post then
advtrains.interlocking.route.free_route_locks(c_ts_id, c_ts.route_post.locks)
c_sigd = c_ts.route_post.next
else
c_sigd = nil
end
c_ts.route_post = nil
end
end
advtrains.interlocking.route = ilrs
|
