ia64/xen-unstable

view tools/python/xen/web/unix.py @ 12725:36fe7ca48e54

Tidy up the creation of directories that Xend needs. This avoids potential
races in this creation.

Signed-off-by: Ewan Mellor <ewan@xensource.com>
author Ewan Mellor <ewan@xensource.com>
date Fri Dec 01 11:32:32 2006 +0000 (2006-12-01)
parents 9c2c55ba22e5
children 24af58657d8e
line source
1 #============================================================================
2 # This library is free software; you can redistribute it and/or
3 # modify it under the terms of version 2.1 of the GNU Lesser General Public
4 # License as published by the Free Software Foundation.
5 #
6 # This library is distributed in the hope that it will be useful,
7 # but WITHOUT ANY WARRANTY; without even the implied warranty of
8 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
9 # Lesser General Public License for more details.
10 #
11 # You should have received a copy of the GNU Lesser General Public
12 # License along with this library; if not, write to the Free Software
13 # Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
14 #============================================================================
15 # Copyright (C) 2005 Mike Wray <mike.wray@hp.com>
16 # Copyright (C) 2005-2006 XenSource Ltd.
17 #============================================================================
20 import os
21 import os.path
22 import socket
23 import stat
25 from xen.util import mkdir
27 import connection
30 def bind(path):
31 """Create a Unix socket, and bind it to the given path. The socket is
32 created such that only the current user may access it."""
34 parent = os.path.dirname(path)
35 mkdir.parents(parent, stat.S_IRWXU, True)
36 if os.path.exists(path):
37 os.unlink(path)
39 sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
40 sock.bind(path)
41 return sock
44 class UnixListener(connection.SocketListener):
45 def __init__(self, path, protocol_class):
46 self.path = path
47 connection.SocketListener.__init__(self, protocol_class)
50 def createSocket(self):
51 return bind(self.path)
54 def acceptConnection(self, sock, _):
55 connection.SocketServerConnection(sock, self.protocol_class)