Repost of earlier patch.
Regards,
Anthony Liguori

# HG changeset patch
# User anthony@xxxxxxxxxxxxxxxxxxxxx
# Node ID cf8e253723daf8b95b54b24f6988a8e74c6cc0aa
# Parent a0212dab2954807a979058d91b246564a7bf2cc2
Add an xm serve command.
This command proxies the Xend XML-RPC over stdio. This is similiar to
mercurial's hg serve --stdio command.
The most obvious use of this command is remote XML-RPC invocation over SSH.
Signed-off-by: Anthony Liguori <aliguori@xxxxxxxxxx>
diff -r a0212dab2954 -r cf8e253723da tools/python/xen/xm/main.py
--- a/tools/python/xen/xm/main.py Sat Jun 10 19:07:26 2006
+++ b/tools/python/xen/xm/main.py Sat Jun 10 19:11:55 2006
@@ -41,6 +41,7 @@
 import xen.xend.XendClient
 from xen.xend.XendClient import server
 from xen.util import security
+from select import select
 
 # getopt.gnu_getopt is better, but only exists in Python 2.3+. Use
 # getopt.getopt if gnu_getopt is not available. This will mean that options
@@ -124,6 +125,7 @@
 loadpolicy_help = "loadpolicy <policy> Load binary policy into 
hypervisor"
 makepolicy_help = "makepolicy <policy> Build policy and create 
.bin/.map files"
 labels_help = "labels [policy] [type=DOM|..] List <type> labels for 
(active) policy."
+serve_help = "serve Proxy Xend XML-RPC over 
stdio"
 
 short_command_list = [
 "console",
@@ -171,7 +173,8 @@
 host_commands = [
 "dmesg",
 "info",
- "log"
+ "log",
+ "serve",
 ]
 
 scheduler_commands = [
@@ -833,6 +836,32 @@
 arg_check(args, "log", 0)
 
 print server.xend.node.log()
+
+def xm_serve(args):
+ arg_check(args, "serve", 0)
+
+ from fcntl import fcntl, F_SETFL
+ 
+ s = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
+ s.connect(xen.xend.XendClient.XML_RPC_SOCKET)
+ fcntl(sys.stdin, F_SETFL, os.O_NONBLOCK)
+
+ while True:
+ iwtd, owtd, ewtd = select([sys.stdin, s], [], [])
+ if s in iwtd:
+ data = s.recv(4096)
+ if len(data) > 0:
+ sys.stdout.write(data)
+ sys.stdout.flush()
+ else:
+ break
+ if sys.stdin in iwtd:
+ data = sys.stdin.read(4096)
+ if len(data) > 0:
+ s.sendall(data)
+ else:
+ break
+ s.close()
 
 def parse_dev_info(info):
 def get_info(n, t, d):
@@ -1072,6 +1101,7 @@
 "dmesg": xm_dmesg,
 "info": xm_info,
 "log": xm_log,
+ "serve": xm_serve,
 # scheduler
 "sched-bvt": xm_sched_bvt,
 "sched-bvt-ctxallow": xm_sched_bvt_ctxallow,

_______________________________________________
Xen-devel mailing list
Xen-devel@xxxxxxxxxxxxxxxxxxx
http://lists.xensource.com/xen-devel