Home
last modified time | relevance | path

Searched refs:con (Results 1 – 15 of 15) sorted by relevance

/xen/tools/ocaml/xenstored/
A Dconnection.ml24 con: t; RecordField
66 con = con;
78 let get_domain con = con.dom
115 con
117 let get_fd con = Xenbus.Xb.get_fd con.xb
171 con.nb_watches <- con.nb_watches + 1;
183 con.nb_watches <- con.nb_watches - 1;
225 let con = get_domstr watch.con in
282 let do_input con = Xenbus.Xb.input con.xb
294 has_more_input con || not (has_old_output con) && has_new_output con
[all …]
A Dconnections.ml49 if (only_if con) then (
70 let del_anonymous cons con =
74 Connection.close con
89 Connection.close con
104 (fun _id con acc ->
105 if Connection.has_more_work con then con :: acc else acc)
137 let del_watches cons con =
138 Connection.del_watches con;
160 iter cons (fun con ->
169 let aux con =
[all …]
A Dprocess.ml53 let split_one_path data con =
172 if not (Connection.is_dom0 con)
207 fct con t doms cons data;
224 fct con t doms cons data
566 Connection.do_input con
569 Connection.reconnect con;
575 Connection.mark_as_bad con;
589 write_access_log ~ty ~tid ~con:(Connection.get_domstr con) ~data;
590 Connection.incr_ops con;
602 write_answer_log ~ty ~tid ~con:(Connection.get_domstr con) ~data;
[all …]
A Dhistory.ml16 con: Connection.t; (* connection that made a change *) RecordField
51 let end_transaction txn con tid commit =
52 let success = Connection.end_transaction con tid commit in
57 let dom = x.con.Connection.dom in
64 (* The "mem" call is an optimisation, to avoid calling f if we have picked con already. *)
68 && not (hist_rec.con == ignore)
69 && not (Hashtbl.mem acc hist_rec.con)
71 then Hashtbl.replace acc hist_rec.con ();
A Dlogging.ml212 let string_of_tid ~con tid =
214 then sprintf "%-12s" con
215 else sprintf "%-12s" (sprintf "%s.%i" con tid)
289 let access_logging ~con ~tid ?(data="") ~level access_type =
294 let tid = string_of_tid ~con tid in
305 let read_coalesce ~tid ~con data =
312 let xb_op ~tid ~con ~ty data =
322 let start_transaction ~tid ~con =
326 let end_transaction ~tid ~con =
330 let xb_answer ~tid ~con ~ty data =
[all …]
A Dxenstored.ml61 let con = Connections.find_domain cons (Domain.get_id domain) in
62 Process.do_input store cons domains con;
63 Process.do_output store cons domains con;
193 let con = Connections.find_domain cons domid in
194 ignore (Connections.add_watch cons con path token)
213 Connections.iter_domains cons (fun con -> Connection.dump con chan);
368 let con = Connections.find_domain cons (Domain.get_id dom) in
369 if not (Connection.has_more_work con) then (
370 Process.do_output store cons domains con;
371 Process.do_input store cons domains con;
[all …]
A Dtransaction.ml197 let commit ~con t =
215 Logging.write_coalesce ~tid:(get_id t) ~con (Store.Path.to_string p);
218 Logging.read_coalesce ~tid:(get_id t) ~con (Store.Path.to_string p)
251 then Logging.conflict ~tid:(get_id t) ~con
253 then Logging.commit ~tid:(get_id t) ~con;
/xen/tools/console/daemon/
A Dio.c305 con->buffer.size < con->buffer.max_capacity) in buffer_available()
341 xenevtchn_notify(con->xce_handle, con->local_port); in buffer_append()
718 if (ring_ref != con->ring_ref && con->ring_ref != -1) in console_create_ring()
721 if (!con->interface && xgt_handle && con->use_gnttab) { in console_create_ring()
788 con->log_fd = create_console_log(con); in console_create_ring()
837 con->d = dom; in console_init()
1047 xenevtchn_notify(con->xce_handle, con->local_port); in handle_tty_read()
1062 len = write(con->master_fd, con->buffer.data + con->buffer.consumed, in handle_tty_write()
1063 con->buffer.size - con->buffer.consumed); in handle_tty_write()
1198 con->log_fd = create_console_log(con); in console_open_log()
[all …]
/xen/tools/ocaml/libs/xb/
A Dxb.ml70 let queue con pkt = Queue.push pkt con.pkt_out
126 let input con =
186 let is_mmap con = not (is_fd con)
188 let output_len con = Queue.length con.pkt_out
189 let has_new_output con = Queue.length con.pkt_out > 0
190 let has_old_output con = String.length con.partial_out > 0
192 let has_output con = has_new_output con || has_old_output con
194 let peek_output con = Queue.peek con.pkt_out
196 let input_len con = Queue.length con.pkt_in
197 let has_in_packet con = Queue.length con.pkt_in > 0
[all …]
/xen/tools/ocaml/libs/xs/
A Dqueueop.ml24 let directory tid path con = queue_path Xb.Op.Directory tid path con
25 let read tid path con = queue_path Xb.Op.Read tid path con
27 let getperms tid path con = queue_path Xb.Op.Getperms tid path con
29 let debug commands con =
32 let watch path data con =
36 let unwatch path data con =
40 let transaction_start con =
53 let release domid con =
57 let resume domid con =
69 let mkdir tid path con = queue_path Xb.Op.Mkdir tid path con
[all …]
A Dxsraw.ml31 type con = { type
36 let close con =
37 Xb.close con.xb
87 let pkt_send con =
97 let pkt_recv con =
126 let has_watchevents con = Queue.length con.watchevents > 0
127 let get_watchevent con = Queue.pop con.watchevents
153 let sync f con =
155 f con.xb;
159 pkt_send con;
[all …]
A Dxsraw.mli21 val close : con -> unit
22 val open_fd : Unix.file_descr -> con
28 val pkt_send : con -> unit
29 val pkt_recv : con -> Xenbus.Xb.Packet.t
32 val has_watchevents : con -> bool
41 val debug : string list -> con -> string
47 val transaction_start : con -> int
50 val release : int -> con -> unit
51 val resume : int -> con -> unit
52 val getdomainpath : int -> con -> string
[all …]
A Dxs.ml18 type con = Xsraw.con type
23 con: con; RecordField
43 let get_operations con = {
44 con = con;
47 read = (fun path -> Xsraw.read 0 path con);
52 rm = (fun path -> Xsraw.rm 0 path con);
57 release = (fun id -> Xsraw.release id con);
58 resume = (fun id -> Xsraw.resume id con);
64 let transaction xsh = Xst.transaction xsh.con
133 if Xsraw.has_watchevents xsh.con
[all …]
A Dxs.mli30 type con type
33 con : con; RecordField
55 val get_operations : con -> xsh
A Dxst.mli29 val get_operations : int -> Xsraw.con -> ops
30 val transaction : Xsraw.con -> (ops -> 'a) -> 'a

Completed in 22 milliseconds