Lines Matching refs:Connection
21 anonymous: (Unix.file_descr, Connection.t) Hashtbl.t;
22 domains: (int, Connection.t) Hashtbl.t;
23 ports: (Xeneventchn.t, Connection.t) Hashtbl.t;
24 mutable watches: (string, Connection.watch list) Trie.t;
36 let con = Connection.create xbcon None in
41 let con = Connection.create xbcon (Some dom) in
50 let fd = Connection.get_fd con in
51 (fd :: ins, if Connection.has_output con then fd :: outs else outs)
66 match List.filter (fun w -> Connection.get_con w != con) watches with
72 Hashtbl.remove cons.anonymous (Connection.get_fd con);
74 Connection.close con
82 (match Connection.get_domain con with
89 Connection.close con
105 if Connection.has_more_work con then con :: acc else acc)
117 let apath, watch = Connection.add_watch con path token in
128 let apath, watch = Connection.del_watch con path token in
138 Connection.del_watches con;
148 | Some watches -> List.iter (fun w -> Connection.fire_watch roots w path) watches
153 List.iter (Connection.fire_single_watch roots) watches
161 List.iter (Connection.fire_single_watch (None, root)) (Connection.get_watches con specpath))
165 Connection.set_target con target_domain
170 res := Connection.number_of_transactions con + !res
181 let con_watchs, con_ops = Connection.stats con in
186 let con_watchs, con_ops = Connection.stats con in
194 let anonymous = Hashtbl.fold (fun _ con accu -> Connection.debug con :: accu) cons.anonymous [] in
195 let domains = Hashtbl.fold (fun _ con accu -> Connection.debug con :: accu) cons.domains [] in