Skip to content

Instantly share code, notes, and snippets.

@nailor
Forked from mmalone/uuid.py
Created May 26, 2009 12:52
Show Gist options
  • Save nailor/118048 to your computer and use it in GitHub Desktop.
Save nailor/118048 to your computer and use it in GitHub Desktop.
import socket
def sockrecv(sock):
d = ''
while not d or d[-1] != '\n':
d += sock.recv(8192)
return d
class UUID(object):
def __init__(self):
self.sock = socket.socket()
self.sock.connect(('127.0.0.1', 8007))
self.sock.setsockopt(socket.SOL_TCP, socket.TCP_NODELAY, 1)
def uuid(self):
self.sock.sendall('gee\n')
uuid = sockrecv(self.sock).strip()
return uuid
def close(self):
self.sock.sendall('quit\n')
self.sock.close()
uuid = UUID()
if __name__ == '__main__':
while True:
print uuid.uuid()
from __future__ import with_statement
import fcntl
import sys
import os
import socket
import asyncore
STEP = 10000
if not os.path.exists('uuid.txt'):
with open('uuid.txt', 'wb+') as f:
f.write('0')
def uuids():
while True:
with open('uuid.txt', 'rb+') as uuid_file:
fcntl.lockf(uuid_file.fileno(), fcntl.LOCK_EX)
min = int(uuid_file.read() or 0)
max = min + STEP
uuid_file.seek(0)
uuid_file.write(str(max))
uuid_file.flush()
fcntl.lockf(uuid_file.fileno(), fcntl.LOCK_UN)
for uuid in xrange(min, max):
yield str(uuid)
uuids = uuids()
class UUIDConnection(asyncore.dispatcher):
def __init__(self, sock):
self.data = None
asyncore.dispatcher.__init__(self, sock)
def writable(self):
return bool(self.data)
def handle_write(self):
self.send(self.data + "\n")
self.data = None
def handle_read(self):
line = self.recv(1024)
line = line.strip()
if line == 'gee':
self.data = uuids.next()
elif line == 'quit':
self.close()
else:
self.data = "ERROR"
class UUIDServer(asyncore.dispatcher):
def __init__(self, port=8007):
asyncore.dispatcher.__init__(self)
self.port = port
self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
self.bind(("", port))
self.listen(1)
def handle_accept(self):
channel, addr = self.accept()
UUIDConnection(channel)
if __name__ == '__main__':
server = UUIDServer()
asyncore.loop()
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment