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 |