|
6239
|
1 # server.py - inotify common protocol code
|
|
|
2 #
|
|
|
3 # Copyright 2006, 2007, 2008 Bryan O'Sullivan <bos@serpentine.com>
|
|
|
4 # Copyright 2007, 2008 Brendan Cully <brendan@kublai.com>
|
|
|
5 #
|
|
|
6 # This software may be used and distributed according to the terms
|
|
|
7 # of the GNU General Public License, incorporated herein by reference.
|
|
|
8
|
|
|
9 import cStringIO, socket, struct
|
|
|
10
|
|
|
11 version = 1
|
|
|
12
|
|
|
13 resphdrfmt = '>llllllll'
|
|
|
14 resphdrsize = struct.calcsize(resphdrfmt)
|
|
|
15
|
|
|
16 def recvcs(sock):
|
|
|
17 cs = cStringIO.StringIO()
|
|
|
18 s = True
|
|
|
19 try:
|
|
|
20 while s:
|
|
|
21 s = sock.recv(65536)
|
|
|
22 cs.write(s)
|
|
|
23 finally:
|
|
|
24 sock.shutdown(socket.SHUT_RD)
|
|
|
25 cs.seek(0)
|
|
|
26 return cs
|
