Lines Matching refs:ty
91 Logging.xb_op ~tid:0 ~ty:Xenbus.Xb.Op.Debug ~con:"=======>" msg;
190 (*------------- Generic handling of ty ------------------*)
191 let send_response ty con t rid response =
194 Connection.send_ack con (Transaction.get_id t) rid ty;
198 Connection.send_reply con (Transaction.get_id t) rid ty ret
223 let function_of_type_simple_op ty =
224 match ty with
236 … -> error "called function_of_type_simple_op on operation %s" (Xenbus.Xb.Op.to_string ty);
237 raise (Invalid_argument (Xenbus.Xb.Op.to_string ty))
271 let write_access_log ~ty ~tid ~con ~data =
272 Logging.xb_op ~ty ~tid ~con data
274 let write_answer_log ~ty ~tid ~con ~data =
275 Logging.xb_answer ~ty ~tid ~con data
277 let write_response_log ~ty ~tid ~con ~response =
279 | Packet.Ack _ -> write_answer_log ~ty ~tid ~con ~data:""
280 | Packet.Reply x -> write_answer_log ~ty ~tid ~con ~data:x
281 | Packet.Error e -> write_answer_log ~ty:(Xenbus.Xb.Op.Error) ~tid ~con ~data:e
292 match t.Transaction.ty with
302 if wlog then write_access_log ~ty:request.Packet.ty ~tid ~con ~data:request.Packet.data;
303 let fct = function_of_type_simple_op request.Packet.ty in
305 if wlog then write_response_log ~ty:request.Packet.ty ~tid ~con ~response:response';
393 match t.Transaction.ty with
450 let function_of_type ty =
451 match ty with
464 | _ -> function_of_type_simple_op ty
471 let retain_op_in_history ty =
472 match ty with
500 let ty = req.Packet.ty in
504 let fct = function_of_type ty in
516 if tid = Transaction.none && retain_op_in_history ty then begin
535 send_response ty con t rid response
558 let tid, rid, ty, data = Xenbus.Xb.Packet.unpack packet in
559 let req = {Packet.tid=tid; Packet.rid=rid; Packet.ty=ty; Packet.data=data} in
564 (Xenbus.Xb.Op.to_string ty) (sanitize_data data); *)
566 write_access_log ~ty ~tid ~con:(Connection.get_domstr con) ~data;
574 let tid, rid, ty, data = Xenbus.Xb.Packet.unpack packet in
578 (Xenbus.Xb.Op.to_string ty) (sanitize_data data);*)
579 write_answer_log ~ty ~tid ~con:(Connection.get_domstr con) ~data;