| 1 | | /* |
| 2 | | * created by dewin dennis.winter@uni-duessldorf.de 2008 |
| 3 | | */ |
| 4 | | |
| 5 | | :- module(h_int, [promela_transition/3, promela_property/2, open_promela_file/1,eval/4]). |
| 6 | | :- use_module(library(codesio)). |
| 7 | | :- use_module(library(samsort)). |
| 8 | | :- use_module(library(avl)). |
| 9 | | |
| 10 | | :- use_module(probsrc(module_information)). |
| 11 | | :- module_info(group,promela). |
| 12 | | :- module_info(description,'This is the Promela (the Spin model checker language) extension.'). |
| 13 | | |
| 14 | | :- dynamic inst/2, line/5. |
| 15 | | |
| 16 | | :- public current_promela_file_opened/1. % for Spider; currently not used |
| 17 | | :- volatile current_promela_file_opened/1. |
| 18 | | :- dynamic current_promela_file_opened/1. |
| 19 | | |
| 20 | | open_promela_file(File) :- |
| 21 | | print(open_promela_file(File)),nl, |
| 22 | | consult_without_redefine_warning(File), |
| 23 | | retractall(current_promela_file_opened(_)), |
| 24 | | assert(current_promela_file_opened(File)), |
| 25 | | print(new_xtl_file(File)),nl. |
| 26 | | |
| 27 | | consult_without_redefine_warning(File) :- |
| 28 | | prolog_flag(redefine_warnings, Old, off), |
| 29 | | prolog_flag(single_var_warnings, Old2, off), |
| 30 | | (consult(File) |
| 31 | | -> OK=true ; OK=false), |
| 32 | | prolog_flag(redefine_warnings, _, Old), |
| 33 | | prolog_flag(single_var_warnings, _, Old2), |
| 34 | | OK=true. |
| 35 | | |
| 36 | | promela_transition(root, start_Promela, X) :- start(X). |
| 37 | ? | promela_transition(S, L, S2) :- trans(L,S,S2). |
| 38 | | |
| 39 | | % -------------------------------------------------------- |
| 40 | | |
| 41 | | start(Out) :- |
| 42 | | print('promela interpreter version 1.5, created by dennis winter'),nl, |
| 43 | | empty_avl(Vars), |
| 44 | | empty_avl(Procs), |
| 45 | | empty_avl(Chans), |
| 46 | | define(env(Vars,Procs,Chans), var(sys(pid),0), global, In2), |
| 47 | | define(In2, var(sys(chan_id),0), global, In3), |
| 48 | | define(In3, var(sys(unsafe),false), global, In4), |
| 49 | | define(In4, var(sys(mode),normal), global, In5), |
| 50 | | init(1,PC2,In5,In6), |
| 51 | | init2(PC2,In6,Out). |
| 52 | | |
| 53 | | init(PC, PC2, In, Out) :- |
| 54 | | inst(PC,S), |
| 55 | | %print(inst(PC,S)),nl, |
| 56 | | handle(S,In,In2), |
| 57 | | NewPC is PC+1, |
| 58 | | init(NewPC,PC2,In2,Out),!. |
| 59 | | |
| 60 | | init(PC,PC,In,In). |
| 61 | | |
| 62 | | |
| 63 | | % define array variable |
| 64 | | get_init_value(def(Type,array(Name,K)), Value, In, Out) :- |
| 65 | | ( Type=bool |
| 66 | | -> generate_false(K,Value), In=Out; |
| 67 | | Type=chan |
| 68 | | -> generate_chanid_array(K, Value, In, Out); |
| 69 | ? | (Type=bit; Type=byte; |
| 70 | | Type=pid; Type=short; Type=int; |
| 71 | | Type=unsigned; Type=mtype) |
| 72 | | -> generate_zero(K,Value), In=Out; |
| 73 | | %else: user-defined type |
| 74 | | generate_usertype_array(K, Type, Value, In, In2), |
| 75 | | define(In2, var(type(Name),Type), global, Out) ),!. |
| 76 | | |
| 77 | | % define variable |
| 78 | | get_init_value(def(Type,Name), Value, In, Out) :- |
| 79 | | ( Type=bool |
| 80 | | -> Value=false, In=Out; |
| 81 | | Type=chan |
| 82 | | -> generate_chanid(Value, In, Out); |
| 83 | ? | (Type=bit; Type=byte; |
| 84 | | Type=pid; Type=short; Type=int; |
| 85 | | Type=unsigned; Type=mtype) |
| 86 | | -> Value=0, In=Out; |
| 87 | | %else: user-defined type |
| 88 | | generate_usertype(Type, 0, [], Value, In, In2), |
| 89 | | define(In2, var(type(Name),Type), global, Out) ). |
| 90 | | |
| 91 | | % generate channel-id array |
| 92 | | generate_chanid_array(0, [], In, In) :- !. |
| 93 | | generate_chanid_array(K, [CID|Tail], In, Out) :- |
| 94 | | generate_chanid(CID, In, In2), |
| 95 | | K2 is K-1, |
| 96 | | generate_chanid_array(K2, Tail, In2, Out). |
| 97 | | |
| 98 | | % generate channel-id |
| 99 | | generate_chanid(CID, In, Out) :- |
| 100 | | lookup(var(sys(chan_id)), global, In, CID), |
| 101 | | CID2 is CID+1, |
| 102 | | define(In, var(sys(chan_id),CID2), global, In2), |
| 103 | | store(In2, chan(CID,empty), global, Out),!. |
| 104 | | |
| 105 | | % generate usertype array |
| 106 | | generate_usertype_array(0, _, [], In, In) :-!. |
| 107 | | generate_usertype_array(K, Type, [Value|Tail], In, Out) :- |
| 108 | | generate_usertype(Type, 0, [], Value, In, In2), |
| 109 | | K2 is K-1, |
| 110 | | generate_usertype_array(K2, Type, Tail, In2, Out). |
| 111 | | |
| 112 | | % generate usertype |
| 113 | | generate_usertype(Type, N, ValueIn, ValueOut, In, Out) :- |
| 114 | | inst(_,typedef(Type,N,def(EType,EName))), |
| 115 | | get_init_value(def(EType,EName), Value, In, In2), |
| 116 | | append(ValueIn, [Value], ValueIn2), |
| 117 | | N2 is N+1, |
| 118 | | generate_usertype(Type, N2, ValueIn2, ValueOut ,In2, Out),!. |
| 119 | | |
| 120 | | generate_usertype(_, _, Value, Value, In, In). |
| 121 | | |
| 122 | | % define globals |
| 123 | | handle(def(Type,Name), In, Out) :- |
| 124 | | trans3(def(Type,Name), global, In, Out). |
| 125 | | |
| 126 | | % typedef |
| 127 | | handle(typedef(_,_,_),In,In). |
| 128 | | |
| 129 | | % assign |
| 130 | | handle(assign(mtype,Value), In, Out) :- |
| 131 | | define(In, var(mtype,Value), global, Out),!. |
| 132 | | |
| 133 | | handle(assign(Name,Value), In, Out) :- |
| 134 | | trans3(assign(Name,Value), global, In, Out). |
| 135 | | |
| 136 | | % stop global initialisation here. |
| 137 | | handle(proctype(_,_,_), _, _) :- fail. |
| 138 | | |
| 139 | | |
| 140 | | set_record_element(Type, [array(EName,expr(K))], Value, V, PID, In, NewValue) :- |
| 141 | | inst(_, typedef(Type,X,def(_,array(EName,_)))), |
| 142 | | get_element(X, Value, Value2), |
| 143 | | eval(K, PID, In, K2), |
| 144 | | set_element(K2, Value2, V, Value3), |
| 145 | | set_element(X, Value, Value3, NewValue),!. |
| 146 | | set_record_element(Type, [EName], Value, V, _, _, NewValue) :- |
| 147 | | inst(_, typedef(Type,X,def(_,EName))), |
| 148 | | set_element(X, Value, V, NewValue),!. |
| 149 | | set_record_element(Type, [array(EName,expr(K))|T], Value, V, PID, In, NewValue) :- |
| 150 | | inst(_, typedef(Type,X,def(EType,array(EName,_)))), |
| 151 | | get_element(X, Value, Value2), |
| 152 | | eval(K, PID, In, K2), |
| 153 | | get_element(K2, Value2, V2), |
| 154 | | set_record_element(EType, T, V2, V, PID, In, V3), |
| 155 | | set_element(K2, Value2, V3, Value3), |
| 156 | | set_element(X, Value, Value3, NewValue),!. |
| 157 | | set_record_element(Type, [EName|T], Value, V, PID, In, NewValue) :- |
| 158 | | inst(_, typedef(Type,X,def(EType,EName))), |
| 159 | | get_element(X, Value, V2), |
| 160 | | set_record_element(EType, T, V2, V, PID, In, V3), |
| 161 | | set_element(X, Value, V3, NewValue). |
| 162 | | |
| 163 | | |
| 164 | | init2(PC, In, Out) :- |
| 165 | | inst(PC,S), |
| 166 | | %print(inst(PC,S)),nl, |
| 167 | ? | handle2(S,PC,In,In2), |
| 168 | | NewPC is PC+1, |
| 169 | | init2(NewPC,In2,Out),!. |
| 170 | | |
| 171 | | init2(_,In,In). |
| 172 | | |
| 173 | | |
| 174 | | handle2(proctype(active(X),Proc,_), PC, In, Out) :- |
| 175 | | NewPC is PC+1, |
| 176 | | lookup(var(sys(pid)), global, In, PID), |
| 177 | | store(In, proc(active(PID,Proc),NewPC), global, In2), |
| 178 | | NewPID is PID+1, |
| 179 | | define(In2, var(sys(pid),NewPID), global, In3), |
| 180 | | (X =< 1 |
| 181 | | -> In3=Out |
| 182 | | ; NewX is X-1, |
| 183 | | handle2(proctype(active(NewX),Proc,_), PC, In3, Out) |
| 184 | | ),!. |
| 185 | | |
| 186 | | handle2(proctype(inactive,_,_), _, In, In). |
| 187 | | |
| 188 | | handle2(init, PC, In, Out) :- |
| 189 | | NewPC is PC+1, |
| 190 | | lookup(var(sys(pid)), global, In, PID), |
| 191 | | store(In, proc(active(PID,init),NewPC), global, In2), |
| 192 | | NewPID is PID+1, |
| 193 | | define(In2, var(sys(pid),NewPID), global, Out). |
| 194 | | |
| 195 | | handle2(_,_,In,In). |
| 196 | | |
| 197 | | /********************************************************************/ |
| 198 | | |
| 199 | | %para_func(def(_,Name),Name). |
| 200 | | |
| 201 | | %map([], _, []). |
| 202 | | %map([H|T], P, [H2|T2]) :- |
| 203 | | % Call =.. [P,H,H2], call(Call), map(T,P,T2). |
| 204 | | |
| 205 | | |
| 206 | | % for type bool or mtype hone_value() must be called every time. |
| 207 | | % for all other types, hone_value() must only be called in case of an overflow. |
| 208 | | check_type(Name,Type,Value,NewValue,In) :- |
| 209 | | ( check_type2(Type,Value,Value2,In) |
| 210 | | -> ( (Type == bool; Type == mtype) |
| 211 | | -> hone_value(Type,Value2,NewValue,In) |
| 212 | | ; NewValue = Value2 ) |
| 213 | | ; print('Warning: Overflow of '),print(variable(Name,Type,Value)), |
| 214 | | hone_value(Type,Value,NewValue,In), |
| 215 | | print(', '),print(new_value(NewValue)),print('.'),nl ). |
| 216 | | |
| 217 | | check_type2(bit, Value, NewValue, _) :- |
| 218 | | number(Value), |
| 219 | | NewValue is round(Value), |
| 220 | | (NewValue == 0; NewValue == 1),!. |
| 221 | | |
| 222 | | check_type2(bool, Value, NewValue, _) :- |
| 223 | | number(Value), |
| 224 | | NewValue is round(Value), |
| 225 | | (NewValue == 0; NewValue == 1),!. |
| 226 | | |
| 227 | | check_type2(byte, Value, NewValue, _) :- |
| 228 | | number(Value), |
| 229 | | NewValue is round(Value), |
| 230 | | NewValue >= 0, |
| 231 | | NewValue =< 255,!. |
| 232 | | |
| 233 | | check_type2(pid, Value, NewValue, _) :- |
| 234 | | number(Value), |
| 235 | | NewValue is round(Value), |
| 236 | | NewValue >= 0, |
| 237 | | NewValue =< 255,!. |
| 238 | | |
| 239 | | check_type2(short, Value, NewValue, _) :- |
| 240 | | number(Value), |
| 241 | | NewValue is round(Value), |
| 242 | | NewValue >= -32768, |
| 243 | | NewValue =< 32767,!. |
| 244 | | |
| 245 | | check_type2(int, Value, NewValue, _) :- |
| 246 | | number(Value), |
| 247 | | NewValue is round(Value), |
| 248 | | NewValue >= -2147483648, |
| 249 | | NewValue =< 2147483647,!. |
| 250 | | |
| 251 | | check_type2(mtype, Value, Value2, In) :- |
| 252 | | number(Value), |
| 253 | | Value2 is round(Value), |
| 254 | | lookup(var(mtype), global, In, MList), |
| 255 | | length(MList, N), |
| 256 | | Value2 >= 1, |
| 257 | | Value2 =< N,!. |
| 258 | | |
| 259 | | check_type2(chan, Value, _, _) :- |
| 260 | | % what's the maximum chan_id? |
| 261 | | number(Value), |
| 262 | | print('chan typecheck. Use define(In var(chan(..)..) instead. chan_id: '),print(Value),nl. |
| 263 | | |
| 264 | | hone_value(bit, Value, NewValue, _) :- |
| 265 | | NewValue is Value mod 2,!. |
| 266 | | |
| 267 | | hone_value(bool, Value, NewValue, _) :- |
| 268 | | Value2 is Value mod 2, |
| 269 | | ( false(Value2) |
| 270 | | -> NewValue = false |
| 271 | | ; NewValue = true ),!. |
| 272 | | |
| 273 | | hone_value(byte, Value, NewValue, _) :- |
| 274 | | NewValue is Value mod 256,!. |
| 275 | | |
| 276 | | hone_value(pid, Value, NewValue, _) :- |
| 277 | | NewValue is Value mod 256,!. |
| 278 | | |
| 279 | | hone_value(short, Value, NewValue, _) :- |
| 280 | | ( Value > 32767 |
| 281 | | -> Value2 is Value mod 32768, |
| 282 | | NewValue is Value2 - 32768 ), |
| 283 | | ( Value < -32768 |
| 284 | | -> Value2 is Value mod 32769, |
| 285 | | NewValue is Value2 - 1 ),!. |
| 286 | | |
| 287 | | hone_value(int, Value, NewValue, _) :- |
| 288 | | ( Value > 2147483647 |
| 289 | | -> Value2 is Value mod 2147483648, |
| 290 | | NewValue is Value2 - 2147483648 ), |
| 291 | | ( Value < -2147483648 |
| 292 | | -> Value2 is Value mod 2147483649, |
| 293 | | NewValue is Value2 - 1 ),!. |
| 294 | | |
| 295 | | hone_value(mtype, Value, ctype(NewValue), In) :- |
| 296 | | lookup(var(mtype), global, In, MList), |
| 297 | | length(MList, N), |
| 298 | | Value2 is Value -1, |
| 299 | | Value3 is Value2 mod N, |
| 300 | | Value4 is Value3 + 1, |
| 301 | | K is N - Value4, |
| 302 | | get_element(K, MList, NewValue),!. |
| 303 | | |
| 304 | | hone_value(chan, Value, Value, _). |
| 305 | | |
| 306 | | /********************************************************************/ |
| 307 | | |
| 308 | | % store variable |
| 309 | | % (stores singles, arrays, records; all of them as global or as local variable) |
| 310 | | store(env(Vars,Procs,Chans), var(Name,Type,expr(V)), PID, env(NewVars,Procs,Chans)) :- |
| 311 | | % set Name4 |
| 312 | ? | ( Name = record([Name2|Tail]) -> true; Name2 = Name ), |
| 313 | ? | ( Name2 = array(Name3,expr(K)) -> true; Name3 = Name2 ), |
| 314 | ? | ( (PID \= global, lookup2(key(Name3,PID),Vars,_)) |
| 315 | | -> Name4 = key(Name3,PID) |
| 316 | | ; Name4 = Name3 ), |
| 317 | ? | lookup2(Name4, Vars, Value), |
| 318 | ? | eval(V, PID, env(Vars,Procs,Chans), V1), |
| 319 | ? | check_type(Name,Type,V1,V2,env(Vars,_,_)), |
| 320 | | % set Value4 |
| 321 | ? | ( Name2 = array(_,_) |
| 322 | ? | -> eval(K,PID,env(Vars,Procs,Chans),K2), get_element(K2,Value,Value2) |
| 323 | | ; Value2 = Value ), |
| 324 | ? | ( Name = record(_) |
| 325 | | -> lookup2(type(Name3),Vars,DType), set_record_element(DType,Tail,Value2,V2,PID,env(Vars,_,_),Value3) |
| 326 | | ; Value3 = V2 ), |
| 327 | ? | ( Name2 = array(_,_) |
| 328 | ? | -> set_element(K2,Value,Value3,Value4) |
| 329 | | % Value = [_|_]: for example short c[3] = 3, then set all elements of c to 3. |
| 330 | | ; Name \= record(_), Value = [_|_] |
| 331 | | -> set_all_elements(Value,V2,Value4) |
| 332 | | ; Value4 = Value3 ), |
| 333 | | %print(end_store(Name,Type,expr(V))),nl, |
| 334 | | store2(Vars,Name4,Value4,NewVars). |
| 335 | | |
| 336 | | % store global proctype |
| 337 | | store(env(Vars,Procs,Chans), proc(PID,PC), global, env(Vars,NewProcs,Chans)) :- |
| 338 | | store2(Procs, PID, PC, NewProcs). |
| 339 | | |
| 340 | | % store global channel |
| 341 | | store(env(Vars,Procs,Chans), chan(Name,Value), _, env(Vars,Procs,NewChans)) :- |
| 342 | | store2(Chans, Name, Value, NewChans). |
| 343 | | |
| 344 | | |
| 345 | | % define local variable |
| 346 | | define(env(Vars,Procs,Chans), var(Name,Value), PID, env(NewVars,Procs,Chans)) :- |
| 347 | | PID \= global, |
| 348 | | store2(Vars, key(Name,PID), Value, NewVars),!. |
| 349 | | |
| 350 | | % define global variable |
| 351 | | define(env(Vars,Procs,Chans), var(Name,Value), global, env(NewVars,Procs,Chans)) :- |
| 352 | | store2(Vars, Name, Value, NewVars). |
| 353 | | |
| 354 | | |
| 355 | | %store2([],Key,Value,[Key/Value]) :- |
| 356 | | % print(store_new_var(Key,Value)),nl. |
| 357 | | %store2([Key/_|T],Key,Value,[Key/Value|T]). |
| 358 | | %store2([Key2/Value2|T],Key,Value,[Key2/Value2|BT]) :- |
| 359 | | % Key \= Key2, store2(T,Key,Value,BT). |
| 360 | | |
| 361 | | store2(AVL,Key,Value,NewAVL) :- |
| 362 | | avl_store(Key, AVL, Value, NewAVL). |
| 363 | | |
| 364 | | % lookup variable |
| 365 | | % (looks up singles, arrays, records; all of them as global or as local variable) |
| 366 | | lookup(var(Name), PID, env(Vars,Procs,Chans), Value3) :- |
| 367 | | % set Name4 |
| 368 | | %print(lookup(var(Name))),nl, |
| 369 | ? | ( Name = record([Name2|Tail]) -> true; Name2 = Name ), |
| 370 | ? | ( Name2 = array(Name3,expr(K)) -> true; Name3 = Name2 ), |
| 371 | ? | ( (PID \= global, lookup2(key(Name3,PID),Vars,_)) |
| 372 | | -> Name4 = key(Name3,PID) |
| 373 | | ; Name4 = Name3 ), |
| 374 | ? | lookup2(Name4, Vars, Value), |
| 375 | | % get Value3 |
| 376 | ? | ( Name2 = array(_,_) |
| 377 | ? | -> (eval(K,PID,env(Vars,Procs,Chans),K2), get_element(K2,Value,Value2)) |
| 378 | | ; Value2 = Value ), |
| 379 | | ( Name = record(_) |
| 380 | | -> (lookup2(type(Name3),Vars,Type), get_record_element(Type,Tail,Value2,PID,env(Vars,_,_),Value3)) |
| 381 | | ; Value3 = Value2 ). |
| 382 | | |
| 383 | | % lookup global proctype |
| 384 | | lookup(proc(PID), global, env(_,Procs,_), PC) :- |
| 385 | ? | lookup3(PID, Procs, PC). |
| 386 | | |
| 387 | | % lookup global channel |
| 388 | | lookup(chan(Name), global, env(_,_,Chans), Value) :- |
| 389 | | lookup2(Name, Chans, Value). |
| 390 | | |
| 391 | | |
| 392 | | %lookup2(Key,[],_) :- |
| 393 | | % %ground(Key), |
| 394 | | % print(lookup_var_not_found(Key)),nl,fail. |
| 395 | | %lookup2(Key,[Key/Value|_T],Value). |
| 396 | | %lookup2(Key,[Key2/_|T],Value) :- |
| 397 | | % Key \= Key2, lookup2(Key,T,Value). |
| 398 | | |
| 399 | | % look up, given a key |
| 400 | | lookup2(Key,AVL,Value) :- |
| 401 | | avl_fetch(Key,AVL,Value). |
| 402 | | |
| 403 | | % look up, if there are possibly multiple matchings for key or value |
| 404 | | lookup3(Key,AVL,Value) :- |
| 405 | ? | avl_member(Key,AVL,Value). |
| 406 | | |
| 407 | | |
| 408 | | %remove(Key,[],_) :- |
| 409 | | % %print(remove_var_not_found(Key)),nl. |
| 410 | | % print(remove_var_not_found_error(Key)),nl,fail. |
| 411 | | %remove(Key,[Key/_|T],T). |
| 412 | | %remove(Key,[Key2/Value|T],[Key2/Value|T2]) :- |
| 413 | | % Key \= Key2, remove(Key,T,T2). |
| 414 | | |
| 415 | | remove(Key,AVL,NewAVL) :- |
| 416 | | avl_delete(Key, AVL, _, NewAVL). |
| 417 | | |
| 418 | | % remove local vars |
| 419 | | remove_vars(PID, env(Vars,Procs,Chans), env(NewVars,Procs,Chans)) :- |
| 420 | | %findall(key(Name,PID), lookup2(key(Name,PID),Vars,_), List), |
| 421 | | findall(key(Name,PID), lookup3(key(Name,PID),Vars,_), List), |
| 422 | | remove_func(List,Vars,NewVars). |
| 423 | | |
| 424 | | % remove pointers to channels and channels itself |
| 425 | | remove_chans(PID, env(Vars,Procs,Chans), env(NewVars,Procs,NewChans)) :- |
| 426 | | findall(key(chan(Name),PID), lookup3(key(chan(Name),PID),Vars,_), List), |
| 427 | | remove_func(List,Vars,NewVars), |
| 428 | | findall(CID, lookup3(key(chan(_),PID),Vars,CID), List2), |
| 429 | | remove_channels(List2,NewVars,Chans,NewChans). |
| 430 | | |
| 431 | | remove_children(PID2, env(Vars,Procs,Chans), env(NewVars,Procs,Chans)) :- |
| 432 | | findall(child(PID1, PID2), lookup3(child(PID1,PID2), Vars, true), List), |
| 433 | | remove_func(List,Vars,NewVars). |
| 434 | | |
| 435 | | remove_proc(active(PID,Name), env(Vars,Procs,Chans), env(Vars,NewProcs,Chans)) :- |
| 436 | | remove(active(PID,Name), Procs, NewProcs). |
| 437 | | |
| 438 | | remove_func([], Vars, Vars). |
| 439 | | remove_func([H|T], Vars, NewVars) :- |
| 440 | | remove(H, Vars, Vars2), |
| 441 | | remove_func(T, Vars2, NewVars). |
| 442 | | |
| 443 | | % remove global channels (only when no pointer is pointing to channel) |
| 444 | | remove_channels([], _, Chans, Chans). |
| 445 | | remove_channels([ID|Tail], Vars, Chans, NewChans) :- |
| 446 | | number(ID), |
| 447 | | ( (lookup3(chan(_),Vars,ID); lookup3(key(chan(_),_),Vars,ID)) |
| 448 | | -> Chans2=Chans |
| 449 | | ; remove(ID, Chans, Chans2) ), |
| 450 | | %print(remove_channel(ID)),nl, |
| 451 | | remove_channels(Tail, Vars, Chans2, NewChans). |
| 452 | | % list of CID's (array) |
| 453 | | remove_channels([[]|Tail], Vars, Chans, NewChans) :- |
| 454 | | remove_channels(Tail, Vars, Chans, NewChans). |
| 455 | | % list of CID's (array) |
| 456 | | remove_channels([[H|T]|Tail], Vars, Chans, NewChans) :- |
| 457 | | number(H), |
| 458 | | ( (lookup3(chan(_),Vars,H); lookup3(key(chan(_),_),Vars,H)) |
| 459 | | -> Chans2=Chans |
| 460 | | ; remove(H, Chans, Chans2) ), |
| 461 | | %print(remove_channels(H)),nl, |
| 462 | | remove_channels([T|Tail], Vars, Chans2, NewChans). |
| 463 | | |
| 464 | | |
| 465 | | /************************************************************/ |
| 466 | | |
| 467 | | eval_list([], _, _, []). |
| 468 | | eval_list([expr(H)|T], PID, In, [H2|T2]) :- |
| 469 | | eval(H, PID, In, H2), |
| 470 | | eval_list(T, PID, In, T2),!. |
| 471 | | |
| 472 | | eval(cond(X,Y,Z), PID, In, R) :- |
| 473 | | eval(X, PID, In, X1), |
| 474 | | ( true(X1) |
| 475 | | -> eval(Y, PID, In, R) |
| 476 | | ; eval(Z, PID, In, R) ). |
| 477 | | eval(or(X,Y), PID, In, R) :- |
| 478 | | eval(X, PID, In, R2), |
| 479 | | ( true(R2) |
| 480 | | -> R=R2 |
| 481 | | ; eval(Y, PID, In, R) ). |
| 482 | | eval(and(X,Y), PID, In, R) :- |
| 483 | | eval(X, PID, In, R2), |
| 484 | | ( true(R2) |
| 485 | | -> eval(Y, PID, In, R) |
| 486 | | ; R=R2 ). |
| 487 | | eval(eq(X,Y), PID, In, R) :- |
| 488 | | eval(X, PID, In, X1), eval(Y, PID, In, Y1), |
| 489 | | ( X1==Y1 |
| 490 | | -> R=1 |
| 491 | | ; R=0 ). |
| 492 | | eval(uneq(X,Y), PID, In, R) :- |
| 493 | | eval(X, PID, In, X1), eval(Y, PID, In, Y1), |
| 494 | | ( X1==Y1 |
| 495 | | -> R=0 |
| 496 | | ; R=1 ). |
| 497 | | eval(lt(X,Y), PID, In, R) :- |
| 498 | ? | eval(X, PID, In, X1), eval(Y, PID, In, Y1), |
| 499 | | ( X1<Y1 -> R=1; R=0 ). |
| 500 | | eval(gt(X,Y), PID, In, R) :- |
| 501 | | eval(X, PID, In, X1), eval(Y, PID, In, Y1), |
| 502 | | ( X1>Y1 -> R=1; R=0 ). |
| 503 | | eval(leqt(X,Y), PID, In, R) :- |
| 504 | | eval(X, PID, In, X1), eval(Y, PID, In, Y1), |
| 505 | | ( X1=<Y1 -> R=1; R=0 ). |
| 506 | | eval(geqt(X,Y), PID, In, R) :- |
| 507 | | eval(X, PID, In, X1), eval(Y, PID, In, Y1), |
| 508 | | ( X1>=Y1 -> R=1; R=0 ). |
| 509 | | eval('+'(X,Y), PID, In, R) :- |
| 510 | | eval(X, PID, In, X1), eval(Y, PID, In, Y1), R is X1+Y1. |
| 511 | | eval('-'(X,Y), PID, In, R) :- |
| 512 | | eval(X, PID, In, X1), eval(Y, PID, In, Y1), R is X1-Y1. |
| 513 | | eval('*'(X,Y), PID, In, R) :- |
| 514 | | eval(X, PID, In, X1), eval(Y, PID, In, Y1), R is X1*Y1. |
| 515 | | eval('/'(X,Y), PID, In, R) :- |
| 516 | | eval(X, PID, In, X1), eval(Y, PID, In, Y1), R is X1/Y1. |
| 517 | | eval('mod'(X,Y), PID, In, R) :- |
| 518 | | eval(X, PID, In, X1), eval(Y, PID, In, Y1), R is X1 mod Y1. |
| 519 | | eval(not(X), PID, In, R) :- |
| 520 | | eval(X, PID, In, X1), |
| 521 | | ( true(X1) -> R=0; R=1 ). |
| 522 | | % bit complement |
| 523 | | eval(compl(X), PID, In, R) :- |
| 524 | | eval(X, PID, In, X1), |
| 525 | | R is \ X1. |
| 526 | | eval(bitor(X,Y), PID, In, R) :- |
| 527 | | eval(X, PID, In, X1), eval(Y, PID, In, Y1), |
| 528 | | R is X1 \/ Y1. |
| 529 | | eval(bitxor(X,Y), PID, In, R) :- |
| 530 | | eval(X, PID, In, X1), eval(Y, PID, In, Y1), |
| 531 | | R is (X1 \/ Y1) /\ \(X1 /\ Y1). |
| 532 | | eval(bitand(X,Y), PID, In, R) :- |
| 533 | | eval(X, PID, In, X1), eval(Y, PID, In, Y1), |
| 534 | | R is X1 /\ Y1. |
| 535 | | eval(lshift(X,Y), PID, In, R) :- |
| 536 | | eval(X, PID, In, X1), eval(Y, PID, In, Y1), |
| 537 | | R is X1 << Y1. |
| 538 | | eval(rshift(X,Y), PID, In, R) :- |
| 539 | | eval(X, PID, In, X1), eval(Y, PID, In, Y1), |
| 540 | | R is X1 >> Y1. |
| 541 | | eval((expr(X)), PID, In, R) :- |
| 542 | | eval(X, PID, In, R),!. |
| 543 | | eval(true, _, _, 1) :- !. |
| 544 | | eval(false, _, _, 0) :- !. |
| 545 | | eval(skip, _, _, 1) :- !. |
| 546 | | eval(X, _, _, X) :- |
| 547 | ? | (number(X); X=[_|_]),!. |
| 548 | | eval(ctype(X), _, In, R) :- |
| 549 | | lookup(var(mtype), global, In, Value), |
| 550 | | get_element(K, Value, X), |
| 551 | | length(Value, N), |
| 552 | | R is N - K. |
| 553 | | eval(string(X), _, _, R) :- |
| 554 | | atom_codes(X,R). |
| 555 | | eval(timeout, _, In, R) :- |
| 556 | | ( find_exec(In) -> R=0; R=1 ),!. |
| 557 | | eval(pid, PID, _, PID) :- !. |
| 558 | | eval(nr_pr, _, env(_,Procs,_), R) :- |
| 559 | | %length(Procs,R),!. |
| 560 | | avl_size(Procs,R),!. |
| 561 | | eval(Name, PID, In, R) :- |
| 562 | | % looks up singles, chan(Name), array(Name,K), record(Name). |
| 563 | ? | (atomic(Name); Name=chan(_); Name=array(_,_); Name=record(_)), |
| 564 | ? | lookup(var(Name), PID, In, R2), |
| 565 | | eval(R2, PID, In, R). |
| 566 | | eval(nfull(chan(Name)), PID, In, R) :- |
| 567 | | eval(empty(chan(Name)), PID, In, R). % fixed by leuschel |
| 568 | | eval(empty(chan(Name)), PID, In, R) :- |
| 569 | | lookup(var(chan(Name)), PID, In, CID), |
| 570 | | lookup(chan(CID), global, In, Value), |
| 571 | | ( Value = [[empty]|_] -> R=1; R=0 ). |
| 572 | | eval(full(chan(Name)), PID, In, R) :- |
| 573 | | eval(nempty(chan(Name)), PID, In, R). |
| 574 | | eval(nempty(chan(Name)), PID, In, R) :- |
| 575 | | lookup(var(chan(Name)), PID, In, CID), |
| 576 | | lookup(chan(CID), global, In, Value), |
| 577 | | ( Value = [[empty]|_] -> R=0; R=1 ). |
| 578 | | eval(len(chan(Name)), PID, In, R) :- |
| 579 | | lookup(var(chan(Name)), PID, In, CID), |
| 580 | | lookup(chan(CID), global, In, Value), |
| 581 | | chan_length(Value,R). |
| 582 | | %print(chan_length(Value,R)),nl. |
| 583 | | eval(expr_poll(Name,Msg), PID, In, R) :- |
| 584 | | ( trans3(poll(Name,Msg),PID,In,_) -> R=1; R=0 ). |
| 585 | | eval(expr_random_poll(Name,Msg), PID, In, R) :- |
| 586 | | ( trans3(random_poll(Name,Msg),PID,In,_) -> R=1; R=0 ). |
| 587 | | |
| 588 | | true(X) :- |
| 589 | | \+false(X). |
| 590 | | false(X) :- |
| 591 | | X==0. |
| 592 | | |
| 593 | | |
| 594 | | chan_length(empty,0). |
| 595 | | chan_length([],0). |
| 596 | | chan_length([[empty]|_],0). |
| 597 | | chan_length([H|T],R) :- |
| 598 | | H \= [empty], chan_length(T,X), R is X+1. |
| 599 | | |
| 600 | | |
| 601 | | get_record_element(Type, [array(EName,expr(K))], Value, PID, In, R) :- |
| 602 | | inst(_, typedef(Type,X,def(_,array(EName,_)))), |
| 603 | | get_element(X, Value, Value2), |
| 604 | | eval(K, PID, In, K2), |
| 605 | | get_element(K2, Value2, R),!. |
| 606 | | get_record_element(Type, [EName], Value, _, _, R) :- |
| 607 | | inst(_, typedef(Type,X,def(_,EName))), |
| 608 | | get_element(X,Value,R),!. |
| 609 | | get_record_element(Type, [array(EName,expr(K))|T], Value, PID, In, R) :- |
| 610 | | inst(_, typedef(Type,X,def(EType,array(EName,_)))), |
| 611 | | get_element(X, Value, Value2), |
| 612 | | eval(K, PID, In, K2), |
| 613 | | get_element(K2, Value2, V2), |
| 614 | | get_record_element(EType, T, V2, PID, In, R),!. |
| 615 | | get_record_element(Type, [EName|T], Value, PID, In, R) :- |
| 616 | | inst(_, typedef(Type,X,def(EType,EName))), |
| 617 | | get_element(X, Value, V2), |
| 618 | | get_record_element(EType, T, V2, PID, In, R). |
| 619 | | |
| 620 | | |
| 621 | | /************************************************************/ |
| 622 | | |
| 623 | | % e.g.: get_element(4,[1,2,3,4,5],5), means 4th element of L is 5. |
| 624 | ? | get_element(R,List,E) :- get_element2(0,List,E,R). |
| 625 | | get_element2(X,[E|_],E,X). |
| 626 | ? | get_element2(X,[_|T],E,R) :- Y is X+1, get_element2(Y,T,E,R). |
| 627 | | |
| 628 | | % e.g.: set_element(1,[1,2,3,4],8,[1,8,3,4]) |
| 629 | | set_element(0,[_|T1],V,[V|T1]). |
| 630 | ? | set_element(X,[H1|T1],V,[H1|T2]) :- Y is X-1, set_element(Y,T1,V,T2). |
| 631 | | |
| 632 | | % e.g.: set_all_elements([1,2,3,4],6,[6,6,6,6]) |
| 633 | | set_all_elements([],_,[]). |
| 634 | | set_all_elements([_|T1],E,[E|T2]) :- |
| 635 | | set_all_elements(T1,E,T2). |
| 636 | | |
| 637 | | |
| 638 | | % e.g.: remove_element(2,[1,2,3,4],[1,2,4]) |
| 639 | | remove_element(0,[_|T1],T1). |
| 640 | | remove_element(X,[H1|T1],[H1|T2]) :- Y is X-1, remove_element(Y,T1,T2). |
| 641 | | |
| 642 | | % e.g.: X=4 -> L=[0,0,0,0] |
| 643 | | generate_zero(0,[]) :- !. |
| 644 | | generate_zero(X,[0|R]) :- Y is X-1, generate_zero(Y,R). |
| 645 | | |
| 646 | | generate_false(0,[]) :- !. |
| 647 | | generate_false(X,[false|R]) :- Y is X-1, generate_false(Y,R). |
| 648 | | |
| 649 | | generate_chan(0,_,[]) :- !. |
| 650 | | generate_chan(X,Msg,[Msg|R]) :- Y is X-1, generate_chan(Y,Msg,R). |
| 651 | | |
| 652 | | /************************************************************/ |
| 653 | | |
| 654 | | trans(io([Statement], proc(PID,Proc), Span), In, Out) :- |
| 655 | ? | lookup(proc(active(PID,Proc)), global, In, PC), |
| 656 | ? | inst(PC, S), |
| 657 | ? | lookup(var(sys(mode)), global, In, MValue), |
| 658 | | %print(try_execute(PC,S)),nl, |
| 659 | ? | check_mode(MValue, S), |
| 660 | ? | trans2(S, Statement, PC, PC2, PID, Span, In, In2), |
| 661 | | %print(executed(PC,S)),nl, |
| 662 | | check_jump(PC2, NewPC), |
| 663 | | %print(jump(PC2,NewPC)),nl, |
| 664 | | ( NewPC \== dead |
| 665 | | -> store(In2, proc(active(PID,Proc),NewPC), global, Out) |
| 666 | | ; remove_proc(active(PID,Proc), In2, Out) ). |
| 667 | | |
| 668 | | check_mode(normal, _). |
| 669 | | check_mode(p_atomic, p_atomic(_)). |
| 670 | | check_mode(d_step, d_step(_)). |
| 671 | | |
| 672 | | % executes igoto or ibreak when necessary. |
| 673 | | check_jump(PC, NewPC) :- |
| 674 | ? | ( inst(PC,S), check_jump2(S, PC2) |
| 675 | | -> check_jump(PC2, NewPC) |
| 676 | | ; NewPC = PC ). |
| 677 | | |
| 678 | | check_jump2(igoto(X), NewPC) :- |
| 679 | | ( number(X) |
| 680 | | -> NewPC is X |
| 681 | | ; inst(Y,label(X)), NewPC is Y ). |
| 682 | | check_jump2(ibreak(X), NewPC) :- |
| 683 | | number(X), |
| 684 | | NewPC is X. |
| 685 | | check_jump2(p_atomic(igoto(X)), NewPC) :- |
| 686 | | check_jump2(igoto(X), NewPC). |
| 687 | | check_jump2(p_atomic(ibreak(X)), NewPC) :- |
| 688 | | check_jump2(ibreak(X), NewPC). |
| 689 | | check_jump2(d_step(igoto(X)), NewPC) :- |
| 690 | | check_jump2(igoto(X), NewPC). |
| 691 | | check_jump2(d_step(ibreak(X)), NewPC) :- |
| 692 | | check_jump2(ibreak(X), NewPC). |
| 693 | | |
| 694 | | |
| 695 | | trans2(do(Alt), Statement, _, NewPC, PID, Span, In, Out) :- |
| 696 | ? | member(A,Alt), |
| 697 | ? | inst(A,S), |
| 698 | ? | ( (S=else; S=d_step(else); S=p_atomic(else)) |
| 699 | ? | -> delete(Alt,A,Alt2), |
| 700 | ? | ( find_exec(Alt2,PID,In) -> fail; true ) |
| 701 | | ; true ), |
| 702 | ? | trans2(S,Statement,A,NewPC,PID,Span,In,Out). |
| 703 | | |
| 704 | | trans2(if(Alt), Statement, _, NewPC, PID, Span, In, Out) :- |
| 705 | | trans2(do(Alt), Statement, _, NewPC, PID, Span, In, Out). |
| 706 | | |
| 707 | | trans2(unless(M,E), Statement, _, NewPC, PID, Span, In, Out) :- |
| 708 | | inst(E,Escape), |
| 709 | | ( trans2(Escape,Statement,E,NewPC,PID,Span,In,Out) |
| 710 | | -> true |
| 711 | | ; (inst(M,Main), trans2(Main,Statement,M,NewPC,PID,Span,In,Out)) ). |
| 712 | | |
| 713 | | % provided (constraint on proctypes) |
| 714 | | trans2(provided(expr(Expr)), Statement, PC, NewPC, PID, Span, In, Out) :- |
| 715 | | eval(Expr, PID, In, R), |
| 716 | | ( true(R) |
| 717 | | -> (PC2 is PC+1, inst(PC2,S), trans2(S,Statement,PC2,NewPC,PID,Span,In,Out)) |
| 718 | | ; fail ). |
| 719 | | |
| 720 | | % Distinction between d_step_start and d_step is important for to not recognize |
| 721 | | % a new starting d_step statement as a continuing d_step. |
| 722 | | trans2(d_step_start(S), Statement, PC, NewPC, PID, Span, In, Out) :- |
| 723 | | trans2(d_step(S), Statement, PC, NewPC, PID, Span, In, Out). |
| 724 | | |
| 725 | | trans2(p_atomic_start(S), Statement, PC, NewPC, PID, Span, In, Out) :- |
| 726 | ? | trans2(p_atomic(S), Statement, PC, NewPC, PID, Span, In, Out). |
| 727 | | |
| 728 | | trans2(d_step(S), Statement, PC, NewPC, PID, Span, In, Out) :- |
| 729 | | trans2(S, Statement, PC, PC2, PID, Span, In, In2), |
| 730 | | check_jump(PC2, NewPC), |
| 731 | | inst(NewPC, S2), |
| 732 | | % look, if next step is d_step |
| 733 | | ( S2 = d_step(_) |
| 734 | | -> define(In2, var(sys(mode),d_step), global, Out) |
| 735 | | ; define(In2, var(sys(mode),normal), global, Out) ),!. |
| 736 | | |
| 737 | | trans2(p_atomic(S), Statement, PC, NewPC, PID, Span, In, Out) :- |
| 738 | ? | trans2(S, Statement, PC, PC2, PID, Span, In, In2), |
| 739 | | check_jump(PC2, NewPC), |
| 740 | | inst(NewPC, S2), |
| 741 | | %print(p_atomic_inst(NewPC,S2)),nl, |
| 742 | | % look, if next step is p_atomic and is executable. |
| 743 | ? | ( S2 = p_atomic(S3), trans2(S3, _, NewPC, _, PID, _, In2, _) |
| 744 | | -> define(In2, var(sys(mode),p_atomic), global, Out)%, print(define(p_atomic)),nl |
| 745 | | ; define(In2, var(sys(mode),normal), global, Out) ).%, print(define(normal)),nl ). |
| 746 | | |
| 747 | | % destructor |
| 748 | | trans2(destructor, destructor, PC, NewPC, PID, src_span(SRow,SCol,ERow,ECol,_,_), In, Out) :- |
| 749 | | % ensure, PID has no child. |
| 750 | | In = env(Vars,_,_), |
| 751 | | \+ lookup3(child(PID,_), Vars, true), |
| 752 | | % remove channels that are not being referenced |
| 753 | | remove_chans(PID, In, In2), |
| 754 | | remove_vars(PID, In2, In3), |
| 755 | | remove_children(PID, In3, Out), |
| 756 | | NewPC = dead, |
| 757 | | line(PC,SRow,SCol,ERow,ECol),!. |
| 758 | | |
| 759 | | trans2(goto(X), goto(X), PC, NewPC, _, src_span(SRow,SCol,ERow,ECol,_,_), In, In) :- |
| 760 | | ( number(X) -> NewPC is X; inst(Y,label(X)), NewPC is Y ), |
| 761 | | inst(NewPC,S), |
| 762 | | % goto into a d_step is not allowed |
| 763 | | S \= d_step(_), |
| 764 | | line(PC,SRow,SCol,ERow,ECol). |
| 765 | | |
| 766 | | trans2(break(X), break(X), PC, NewPC, _, src_span(SRow,SCol,ERow,ECol,_,_), In, In) :- |
| 767 | | NewPC is X, |
| 768 | | line(PC,SRow,SCol,ERow,ECol). |
| 769 | | |
| 770 | | trans2(label(_), Statement, PC, NewPC, PID, Span, In, Out) :- |
| 771 | | PC2 is PC+1, |
| 772 | | inst(PC2,S), |
| 773 | | trans2(S, Statement, PC2, NewPC, PID, Span, In, Out). |
| 774 | | |
| 775 | | trans2(printf(TextList), printf(Text), PC, NewPC, _, src_span(SRow,SCol,ERow,ECol,_,_), In, In) :- |
| 776 | | % ex.: atom_codes(X,[97]). |
| 777 | | % X = a |
| 778 | | atom_codes(Text,TextList), |
| 779 | | NewPC is PC+1, |
| 780 | | line(PC,SRow,SCol,ERow,ECol). |
| 781 | | |
| 782 | | trans2(printf(TextList,VarList), printf(Result), PC, NewPC, PID, src_span(SRow,SCol,ERow,ECol,_,_), In, In) :- |
| 783 | | % ex.: format("~s~2f",[a,0.3]). |
| 784 | | % a0.30 |
| 785 | | % format_to_codes("a ~c",[13],R). |
| 786 | | % R = [97,32,13] ? |
| 787 | | % |
| 788 | | eval_list(VarList, PID, In, ValueList), |
| 789 | | atom_codes(Text,TextList), |
| 790 | | format_to_codes(Text,ValueList,ResultList), |
| 791 | | atom_codes(Result,ResultList), |
| 792 | | NewPC is PC+1, |
| 793 | | line(PC,SRow,SCol,ERow,ECol). |
| 794 | | |
| 795 | | trans2(printm(expr(Expr)), printm(Result), PC, NewPC, PID, src_span(SRow,SCol,ERow,ECol,_,_), In, In) :- |
| 796 | | eval(Expr, PID, In, Result), |
| 797 | | NewPC is PC+1, |
| 798 | | line(PC,SRow,SCol,ERow,ECol). |
| 799 | | |
| 800 | | trans2(Statement, Statement, PC, NewPC, PID, src_span(SRow,SCol,ERow,ECol,_,_), In, Out) :- |
| 801 | ? | trans3(Statement, PID, In, Out), |
| 802 | | NewPC is PC+1, |
| 803 | | line(PC,SRow,SCol,ERow,ECol). |
| 804 | | |
| 805 | | trans2(send(Name,Msg), Statement, PC, NewPC, PID, SpanOut, In, Out) :- |
| 806 | | lookup(var(Name), PID, In, CID), |
| 807 | | %% print(chan_id(CID)),nl, |
| 808 | | ( lookup(chan(CID), global, In, []) |
| 809 | | -> r_send(CID, Name, Msg, Statement, PID, Span2, In, Out), SpanOut = multi_span(SRow,SCol,ERow,ECol,_,_,Span2) |
| 810 | | ; n_send(CID, Name, Msg, Statement, PID, In, Out), SpanOut = src_span(SRow,SCol,ERow,ECol,_,_) ), |
| 811 | | NewPC is PC+1, |
| 812 | | line(PC,SRow,SCol,ERow,ECol). |
| 813 | | |
| 814 | | trans2(sorted_send(Name,Msg), Statement, PC, NewPC, PID, SpanOut, In, Out) :- |
| 815 | | lookup(var(Name), PID, In, CID), |
| 816 | | %% print(chan_id(CID)),nl, |
| 817 | | ( lookup(chan(CID), global, In, []) |
| 818 | | -> r_send(CID, Name, Msg, Statement, PID, Span2, In, Out), SpanOut = multi_span(SRow,SCol,ERow,ECol,_,_,Span2) |
| 819 | | ; s_send(CID, Name, Msg, Statement, PID, In, Out), SpanOut = src_span(SRow,SCol,ERow,ECol,_,_) ), |
| 820 | | NewPC is PC+1, |
| 821 | | line(PC,SRow,SCol,ERow,ECol). |
| 822 | | |
| 823 | | % normal send |
| 824 | | n_send(CID, Name, Msg, Statement, PID, In, Out) :- |
| 825 | | lookup(chan(CID), global, In, Value), |
| 826 | | get_element(K, Value, [empty]), % Backtracking! |
| 827 | | %print(map_send(Msg)),nl, |
| 828 | | eval_list(Msg, PID, In, Msg2), |
| 829 | | %print(map2_send(Msg2)),nl, |
| 830 | | set_element(K, Value, Msg2, NewValue), |
| 831 | | store(In, chan(CID,NewValue), global, Out), |
| 832 | | Statement = send(Name,Msg),!. |
| 833 | | |
| 834 | | % rendezvous-send |
| 835 | | r_send(CID, Name, Msg, Statement, PID, Span, In, Out) :- |
| 836 | | eval_list(Msg, PID, In, Msg2), |
| 837 | | %print(msg3(Msg2)),nl, |
| 838 | | store(In, chan(CID,[Msg2]), global, In2), |
| 839 | | % search matching receive |
| 840 | | lookup(proc(active(RPID,Proc)), global, In, PC), |
| 841 | | inst(PC, S), |
| 842 | | % S can be recv(), igoto(), ibreak(), etc. |
| 843 | | trans2(S,recv(RName,RMsg), PC, NewPC, RPID, Span, In2, In3), |
| 844 | | lookup(chan(CID), global, In3, [[empty]]), |
| 845 | | % reset channel |
| 846 | | store(In3, chan(CID,[]), global, In4), |
| 847 | | store(In4, proc(active(RPID,Proc), NewPC), global, Out), |
| 848 | | Statement = '.'(r_send(Name,Msg),r_recv(RName,RMsg)). |
| 849 | | % Permit Backtracking in this clause! |
| 850 | | |
| 851 | | % sorted send |
| 852 | | s_send(CID, Name, Msg, Statement, PID, In, Out) :- |
| 853 | | lookup(chan(CID), global, In, Value), |
| 854 | | get_element(K, Value, [empty]), % Backtracking! |
| 855 | | %print(map_send(Msg)),nl, |
| 856 | | eval_list(Msg, PID, In, Msg2), |
| 857 | | %print(map2_send(Msg2)),nl, |
| 858 | | set_element(K, Value, Msg2, NewValue), |
| 859 | | %print(newValue(NewValue)),nl, |
| 860 | | samsort(NewValue, SortedValue), |
| 861 | | %print(sortedValue(SortedValue)),nl, |
| 862 | | store(In, chan(CID,SortedValue), global, Out), |
| 863 | | Statement = sorted_send(Name,Msg),!. |
| 864 | | |
| 865 | | % normal receive |
| 866 | | trans3(recv(Name,Msg), PID, In, Out) :- |
| 867 | | lookup(var(Name), PID, In, Id), |
| 868 | | lookup(chan(Id), global, In, Value), |
| 869 | | get_element(0, Value, Msg2), |
| 870 | | Msg2 \== [empty], |
| 871 | | %print(map_recv(Msg)),nl, |
| 872 | | recv_eval(Msg, PID, In, In2, Msg2), |
| 873 | | %print(map2_recv(Msg2)),nl, |
| 874 | | remove_element(0, Value, Value2), |
| 875 | | append(Value2, [[empty]], NewValue), |
| 876 | | store(In2, chan(Id,NewValue), global, Out). |
| 877 | | |
| 878 | | % random receive |
| 879 | | trans3(random_recv(Name,Msg), PID, In, Out) :- |
| 880 | | lookup(var(Name), PID, In, Id), |
| 881 | | lookup(chan(Id), global, In, Value), |
| 882 | | get_element(K, Value, Msg2), % Backtracking! |
| 883 | | Msg2 \== [empty], |
| 884 | | %print(map_recv(Msg)),nl, |
| 885 | | recv_eval(Msg, PID, In, In2, Msg2), |
| 886 | | %print(map2_recv(Msg2)),nl, |
| 887 | | remove_element(K, Value, Value2), |
| 888 | | append(Value2, [[empty]], NewValue), |
| 889 | | store(In2, chan(Id,NewValue), global, Out),!. |
| 890 | | |
| 891 | | % normal poll |
| 892 | | trans3(poll(Name,Msg), PID, In, Out) :- |
| 893 | | lookup(var(Name), PID, In, Id), |
| 894 | | lookup(chan(Id), global, In, Value), |
| 895 | | get_element(0, Value, Msg2), |
| 896 | | Msg2 \== [empty], |
| 897 | | %print(map_recv(Msg)),nl, |
| 898 | | recv_eval(Msg, PID, In, Out, Msg2). |
| 899 | | %print(map2_recv(Msg2)),nl. |
| 900 | | |
| 901 | | % random poll |
| 902 | | trans3(random_poll(Name,Msg), PID, In, Out) :- |
| 903 | | lookup(var(Name), PID, In, Id), |
| 904 | | lookup(chan(Id), global, In, Value), |
| 905 | | get_element(_, Value, Msg2), % Backtracking! |
| 906 | | Msg2 \== [empty], |
| 907 | | %print(map_recv(Msg)),nl, |
| 908 | | recv_eval(Msg, PID, In, Out, Msg2),!. |
| 909 | | %print(map2_recv(Msg2)),nl,!. |
| 910 | | |
| 911 | | trans3(expr(run(Proc,ValueList)), PID, In, Out) :- |
| 912 | | inst(PC,proctype(_,Proc,PList)), |
| 913 | | PC2 is PC + 1, |
| 914 | | %-----------------% |
| 915 | | lookup(var(sys(pid)), global, In, PID2), |
| 916 | | store(In, proc(active(PID2,Proc),PC2), global, In2), |
| 917 | | set_local_vars(PList, ValueList, PID, PID2, In2, In3), |
| 918 | | PID3 is PID2+1, |
| 919 | | define(In3, var(sys(pid),PID3), global, In4), |
| 920 | | define(In4, var(child(PID,PID2),true), global, Out),!. |
| 921 | | |
| 922 | | trans3(expr(Name), PID, In, In) :- |
| 923 | ? | eval(Name, PID, In, R), |
| 924 | | %print(evaluated_expr(PID,Name,R)),nl, |
| 925 | | ( false(R) -> fail; true ). |
| 926 | | |
| 927 | | trans3(assert(expr(Name)), PID, In, Out) :- |
| 928 | | eval(Name, PID, In, R), |
| 929 | | %% print(evaluated_expr(Name,R)),nl, |
| 930 | | ( false(R) |
| 931 | | -> define(In, var(sys(unsafe),true), global, Out) |
| 932 | | ; In=Out ). |
| 933 | | |
| 934 | | trans3(else, _, In, In). |
| 935 | | trans3(skip, _, In, In). |
| 936 | | |
| 937 | | % define locals |
| 938 | | trans3(def(Type,Name), PID, In, Out) :- |
| 939 | | get_init_value(def(Type,Name), Value, In, In2), |
| 940 | | ( Name = array(Name2,_) -> true; Name2 = Name ), |
| 941 | | ( Type = chan |
| 942 | | -> define(In2, var(chan(Name2),Value), PID, Out) |
| 943 | | ; define(In2, var(Name2,Value), PID, Out) ). |
| 944 | | |
| 945 | | % assign rendezvous-channel |
| 946 | | trans3(assign(array(Name,expr(K)),chan(0,_)), PID, In, Out) :- |
| 947 | | lookup(var(chan(Name)), PID, In, CIDList), |
| 948 | | eval(K, PID, In, K2), |
| 949 | | get_element(K2, CIDList, CID), |
| 950 | | store(In, chan(CID,[]), global, Out),!. |
| 951 | | trans3(assign(Name,chan(0,_)), PID, In, Out) :- |
| 952 | | lookup(var(chan(Name)), PID, In, CID), |
| 953 | | assign_channel_value(CID, [], In, Out),!. |
| 954 | | % assign channel |
| 955 | | trans3(assign(array(Name,expr(K)),chan(N,_)), PID, In, Out) :- |
| 956 | | lookup(var(chan(Name)), PID, In, CIDList), |
| 957 | | eval(K, PID, In, K2), |
| 958 | | get_element(K2, CIDList, CID), |
| 959 | | generate_chan(N, [empty], Value), |
| 960 | | store(In, chan(CID,Value), global, Out),!. |
| 961 | | trans3(assign(Name,chan(N,_)), PID, In, Out) :- |
| 962 | | lookup(var(chan(Name)), PID, In, CID), |
| 963 | | generate_chan(N, [empty], Value), |
| 964 | | assign_channel_value(CID, Value, In, Out),!. |
| 965 | | |
| 966 | | % assign channel to an existing CID |
| 967 | | trans3(assign(array(chan(Name),expr(K)),expr(chan(Name2))), PID, In, Out) :- |
| 968 | | lookup(var(chan(Name)), PID, In, CIDList), |
| 969 | | eval(K, PID, In, K2), |
| 970 | | lookup(var(chan(Name2)), PID, In, CID), |
| 971 | | set_element(K2, CIDList, CID, NewCIDList), |
| 972 | | define(In, var(chan(Name),NewCIDList), PID, Out),!. |
| 973 | | trans3(assign(chan(Name),expr(chan(Name2))), PID, In, Out) :- |
| 974 | | lookup(var(chan(Name2)), PID, In, CID), |
| 975 | | define(In, var(chan(Name),CID), PID, Out),!. |
| 976 | | |
| 977 | | trans3(assign(vt(Name,Type),Value), PID, In, Out) :- |
| 978 | ? | store(In, var(Name,Type,Value), PID, Out). |
| 979 | | |
| 980 | | trans3(inc(vt(Name,Type)), PID, In, Out) :- |
| 981 | | lookup(var(Name), PID, In, Value), |
| 982 | | R is Value+1, |
| 983 | | store(In, var(Name,Type,expr(R)), PID, Out). |
| 984 | | |
| 985 | | trans3(dec(vt(Name,Type)), PID, In, Out) :- |
| 986 | | lookup(var(Name), PID, In, Value), |
| 987 | | R is Value-1, |
| 988 | | store(In, var(Name,Type,expr(R)), PID, Out). |
| 989 | | |
| 990 | | /**************************************************************/ |
| 991 | | |
| 992 | | % assign Value to CID |
| 993 | | assign_channel_value(CID, Value, In, Out) :- |
| 994 | | number(CID), |
| 995 | | store(In, chan(CID,Value), global, Out),!. |
| 996 | | % assign Value to a list of CID's |
| 997 | | assign_channel_value([], _, In, In). |
| 998 | | assign_channel_value([H|Tail], Value, In, Out) :- |
| 999 | | store(In, chan(H,Value), global, In2), |
| 1000 | | assign_channel_value(Tail,Value, In2, Out). |
| 1001 | | |
| 1002 | | % set_local_vars(NameList, ValueList, PID, PID2, In, Out) |
| 1003 | | set_local_vars([], [], _, _, In, In). |
| 1004 | | % H2 = single-chan or array-chan |
| 1005 | | set_local_vars([def(chan,H1)|T1], [expr(H2)|T2], PID, PID2, In, Out) :- |
| 1006 | | lookup(var(H2), PID, In, Value), |
| 1007 | | define(In, var(chan(H1),Value), PID2, In2), |
| 1008 | | set_local_vars(T1, T2, PID, PID2, In2, Out),!. |
| 1009 | | set_local_vars([def(Type,H1)|T1], [expr(H2)|T2], PID, PID2, In, Out) :- |
| 1010 | | eval(H2,PID,In,V), |
| 1011 | | check_type(H1,Type,V,V2,In), |
| 1012 | | define(In, var(H1,V2), PID2, In2), |
| 1013 | | set_local_vars(T1, T2, PID, PID2, In2, Out). |
| 1014 | | |
| 1015 | | |
| 1016 | | % recv_eval(NameList, PID, In, Out, ValueList) |
| 1017 | | recv_eval([], _, In, In, []). |
| 1018 | | recv_eval([ctype(A)|T], PID, In, Out, [R|T2]) :- |
| 1019 | | check_type(recv(ctype(A)),mtype,R,ctype(A),In), |
| 1020 | | recv_eval(T, PID, In, Out, T2),!. |
| 1021 | | recv_eval([true|T], PID, In, Out, [R|T2]) :- |
| 1022 | | check_type(recv(true),bool,R,true,In), |
| 1023 | | recv_eval(T, PID, In, Out, T2),!. |
| 1024 | | recv_eval([false|T], PID, In, Out, [R|T2]) :- |
| 1025 | | check_type(recv(false),bool,R,false,In), |
| 1026 | | recv_eval(T, PID, In, Out, T2),!. |
| 1027 | | recv_eval([skip|T], PID, In, Out, [skip|T2]) :- |
| 1028 | | recv_eval(T, PID, In, Out, T2),!. |
| 1029 | | recv_eval([chan(A)|T], PID, In, Out, [CID|T2]) :- |
| 1030 | | define(In, var(chan(A),CID), PID, In2), |
| 1031 | | recv_eval(T, PID, In2, Out, T2),!. |
| 1032 | | recv_eval([A|T], PID, In, Out, [A|T2]) :- |
| 1033 | | number(A), |
| 1034 | | recv_eval(T, PID, In, Out, T2),!. |
| 1035 | | recv_eval([underscore|T], PID, In, Out, [_|T2]) :- |
| 1036 | | recv_eval(T, PID, In, Out, T2),!. |
| 1037 | | recv_eval([eval(Expr)|T], PID, In, Out, [R|T2]) :- |
| 1038 | | eval(Expr, PID, In, R), |
| 1039 | | %% print(evaluated_expr(Expr,R)),nl, |
| 1040 | | recv_eval(T, PID, In, Out, T2),!. |
| 1041 | | recv_eval([vt(A,AType)|T], PID, In, Out, [R|T2]) :- |
| 1042 | | atomic(A), |
| 1043 | | store(In, var(A,AType,expr(R)), PID, In2), |
| 1044 | | recv_eval(T, PID, In2, Out, T2). |
| 1045 | | |
| 1046 | | % else check |
| 1047 | | find_exec(Alt, PID, In) :- |
| 1048 | ? | member(A, Alt), |
| 1049 | ? | inst(A,Statement), |
| 1050 | ? | trans2(Statement, _, A, _, PID, _, In, _). |
| 1051 | | |
| 1052 | | % timeout check |
| 1053 | | find_exec(In) :- |
| 1054 | | lookup(proc(active(PID,_)), global, In, PC), |
| 1055 | | inst(PC,Statement), |
| 1056 | | Statement \= expr(timeout), |
| 1057 | | trans2(Statement, _, PC, _, PID, _, In, _). |
| 1058 | | %print(find_exec(PC,Statement)),nl. |
| 1059 | | |
| 1060 | | |
| 1061 | | delete([X|T],X,T). |
| 1062 | ? | delete([Y|T],X,[Y|DT]) :- delete(T,X,DT). |
| 1063 | | |
| 1064 | | /***************************************************************/ |
| 1065 | | |
| 1066 | | promela_property(env(Vars,_,_), '='('OrderedPair'(PID,Name),Value)) :- %var(key(Name,PID),Value)) :- |
| 1067 | | lookup3(key(Name,PID), Vars, Value). |
| 1068 | | promela_property(env(Vars,_,_), var(Name,Value)) :- |
| 1069 | | lookup3(Name, Vars, Value), Name \= key(_,_). |
| 1070 | | promela_property(env(_,Procs,_), proc(active(PID,Name),PC)) :- |
| 1071 | | lookup3(active(PID,Name), Procs, PC). |
| 1072 | | promela_property(env(_,_,Chans), chan(Id,Value)) :- |
| 1073 | | Chans \= [], |
| 1074 | | lookup3(Id, Chans, Value). |
| 1075 | | |
| 1076 | | promela_property(env(_,Procs,_), active_proctypes(N)) :- |
| 1077 | | avl_size(Procs,N). |
| 1078 | | promela_property(env(Vars,_,_), unsafe) :- |
| 1079 | | lookup2(sys(unsafe), Vars, Value), |
| 1080 | | ( Value == true |
| 1081 | | -> true |
| 1082 | | ; fail ). |
| 1083 | | |
| 1084 | | % debugging: |
| 1085 | | %promela_property(env(Vars,_,_), true) :- |
| 1086 | | % avl_to_list(Vars,List), |
| 1087 | | % print(vars(List)),nl. |
| 1088 | | |
| 1089 | | %promela_property(env(_,Procs,_), true) :- |
| 1090 | | % avl_to_list(Procs,List), |
| 1091 | | % print(procs(List)),nl. |
| 1092 | | |
| 1093 | | %promela_property(env(_,_,Chans), true) :- |
| 1094 | | % avl_to_list(Chans,List), |
| 1095 | | % print(chans(List)),nl. |
| 1096 | | |
| 1097 | | %promela_property(env(Vars,Procs,Chans), 0) :- |
| 1098 | | % print('Vars: '),portray_avl(Vars),nl, |
| 1099 | | % print('Procs: '),portray_avl(Procs),nl, |
| 1100 | | % print('Chans: '),portray_avl(Chans),nl,fail. |