/[mojave]/metaprl/library/orb.ml
ViewVC logotype

Diff of /metaprl/library/orb.ml

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 2921 by nogin, Fri Oct 22 01:07:59 1999 UTC revision 2922 by lolorigo, Thu Mar 16 19:52:02 2000 UTC
# Line 249  Line 249 
249   * apply to table   * apply to table
250   *)   *)
251  let broadcast_eval env tstamp commit_stamp bcasts =  let broadcast_eval env tstamp commit_stamp bcasts =
252    (* print_string "num bcasts "; print_string (string_of_int (List.length bcasts));  print_newline(); *)    print_string "num bcasts "; print_string (string_of_int (List.length bcasts));  print_newline();
253      let count = ref 1 in
254    map (function bipass ->    map (function bipass ->
255          (* print_string "eval_bcast"; print_newline(); *)          print_string ".";
256          let ipass = term_of_unbound_term bipass in          (*print_string "eval_bcast "; print_string (string_of_int !count); print_newline();
257          match dest_term ipass with          count := !count + 1;*)  
258            let ipass = term_of_unbound_term bipass in
259            (*Mbterm.print_term ipass; print_newline(); *)
260            match dest_term ipass with
261            { term_op = pop; term_terms = [stamp; desc; bcast] }            { term_op = pop; term_terms = [stamp; desc; bcast] }
262              -> (match dest_op pop with              -> (match dest_op pop with
263                  { op_name = opn; op_params = [id; ttype] } when parmeq id ipassport_param                  { op_name = opn; op_params = [id; ttype] } when parmeq id ipassport_param
# Line 265  Line 269 
269                                  commit_stamp                                  commit_stamp
270                       with Not_found -> print_string "Broadcast for unknown table ignored. ";                       with Not_found -> print_string "Broadcast for unknown table ignored. ";
271                                         print_string (dest_token_param ttype); print_newline(); ()                                         print_string (dest_token_param ttype); print_newline(); ()
272                            | e -> raise e)                            | e -> (print_string "ap bcast failed"; raise e))
273                  |_ -> error ["term"; "!passport"; "op"] [] [ipass]                  |_ -> error ["term"; "!passport"; "op"] [] [ipass]
274                  )                  )
275            |_ -> error ["term"; "!passport"] [] [ipass]            |_ -> error ["term"; "!passport"] [] [ipass]
# Line 305  Line 309 
309      (function () -> (ivalue_term (f (cmd_of_icommand_term t))))      (function () -> (ivalue_term (f (cmd_of_icommand_term t))))
310      (function term -> ifail_term term)      (function term -> ifail_term term)
311    
312    (*
313    let local_eval_new f t =
314      unconditional_error_handler
315        (function () ->
316         (match dest_term t with {term_op = { op_name = opn; op_params = p :: oppl} ; term_terms = bts }
317            -> if parmeq p icommand_parameter then (ivalue_term (f (cmd_of_icommand_term t)))
318               else if parmeq p iexpression_parameter
319        (function term -> ifail_term term)
320    *)
321    
322  let imsg_parameter = make_param (Token "!msg")  let imsg_parameter = make_param (Token "!msg")
323    
# Line 518  Line 531 
531    
532      let connection =  { link = link; orb = orb; ro_address = address } in      let connection =  { link = link; orb = orb; ro_address = address } in
533        orb.connections <- (connection :: orb.connections);        orb.connections <- (connection :: orb.connections);
534          
535        connection        connection
536    
537  let irevoke_parameter = make_param (Token "!revoke")  let irevoke_parameter = make_param (Token "!revoke")
# Line 680  Line 694 
694                            (* nfg if we allow mulitple envs *)                            (* nfg if we allow mulitple envs *)
695                       nl0_description))                       nl0_description))
696    
697          in (* print_string "start_broadcasts : "; *)          in  print_string "start_broadcasts : ";
698                  let _ = orb_broadcast e (broadcasts_of_istart_term                  let _ = orb_broadcast e (broadcasts_of_istart_term
699                              (info_of_iinform_term t))                              (info_of_iinform_term t))
700        in ()        in ()
# Line 710  Line 724 
724          } in          } in
725      (connection.orb).environments <- env :: connection.orb.environments;      (connection.orb).environments <- env :: connection.orb.environments;
726      start_broadcasts env;      start_broadcasts env;
727        (*print_string "after sbc";*)
728      env      env
729    
730    
731  let join_library_environment connection tags ehook =  let join_library_environment connection tags ehook =
732    let lib_env_address = library_environment_join connection tags in    let lib_env_address = library_environment_join connection tags in
733        
734      let env =      let env =
735          { connection = connection          { connection = connection
736          ; re_address = lib_env_address          ; re_address = lib_env_address
# Line 725  Line 741 
741          } in          } in
742      (connection.orb).environments <- env :: connection.orb.environments;      (connection.orb).environments <- env :: connection.orb.environments;
743      start_broadcasts env;      start_broadcasts env;
744        (*print_string "after sbc";*)
745      env      env
746    
747  let restore_library_environment connection sstamp ehook =  let restore_library_environment connection sstamp ehook =

Legend:
Removed from v.2921  
changed lines
  Added in v.2922

  ViewVC Help
Powered by ViewVC 1.1.26