Lines Matching refs:cons
59 let process_watch t cons =
63 let do_op_watch op cons =
69 Connections.fire_watches ?oldroot root cons (snd op) recurse in
70 List.iter (fun op -> do_op_watch op cons) ops
88 let do_debug con t _domains cons data =
100 let watches = Connections.debug cons in
104 let con = Connections.find_domain cons domid in
182 let do_reset_watches con _t _domains cons _data =
183 Connections.del_watches cons con;
187 let do_set_target con _t _domains cons data =
191 …| [ domid; target_domid; "" ] -> Connections.set_target cons (c_int_of_string domid) (c_int_of_str…
206 let reply_ack fct con t doms cons data =
207 fct con t doms cons data;
210 process_watch t cons
213 let reply_data fct con t doms cons data =
214 let ret = fct con t doms cons data in
217 let reply_data_or_ack fct con t doms cons data =
218 match fct con t doms cons data with
222 let reply_none fct con t doms cons data =
224 fct con t doms cons data
252 let input_handle_error ~cons ~doms ~fct ~con ~t ~req =
256 fct con t doms cons req.Packet.data
295 let transaction_replay c t doms cons =
308 let response' = input_handle_error ~cons ~doms ~fct ~con:c ~t:txn ~req:request in
358 let do_watch con t _domains cons data =
364 let watch = Connections.add_watch cons con node token in
370 let do_unwatch con _t _domains cons data =
376 ignore @@ Connections.del_watch cons con node token
384 let do_transaction_end con t domains cons data =
394 …let commit = if commit then Some (fun con trans -> transaction_replay con trans domains cons) else…
399 process_watch t cons;
407 let do_introduce con t domains cons data =
419 if (Domain.get_mfn edom) = mfn && (Connections.find_domain cons domid) != con then begin
427 Connections.add_domain cons ndom;
428 Connections.fire_spec_watches (Transaction.get_root t) cons Store.Path.introduce_domain;
435 let do_release con t domains cons data =
445 Connections.del_domain cons domid;
448 then Connections.fire_spec_watches (Transaction.get_root t) cons Store.Path.release_domain
521 let process_packet ~store ~cons ~doms ~con ~req =
534 let execute () = input_handle_error ~cons ~doms ~fct ~con ~t ~req in
563 let do_input store cons doms con =
588 process_packet ~store ~cons ~doms ~con ~req;