neitris_cli.py

#
#    Neitris - A multiplayer Tetris clone 
#    Copyright (C) 2006 Alexandros Kostopoulos (akostopou@gmail.com)
#
#    This program is free software; you can redistribute it and/or modify
#    it under the terms of the GNU General Public License as published by
#    the Free Software Foundation; either version 2 of the License, or
#    (at your option) any later version.
#
#    This program is distributed in the hope that it will be useful,
#    but WITHOUT ANY WARRANTY; without even the implied warranty of
#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
#    GNU General Public License for more details.
#
#    You should have received a copy of the GNU General Public License along
#    with this program; if not, write to the Free Software Foundation, Inc.,
#    51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
#
import time, sys
import struct

from socket import socket, AF_INET, SOCK_STREAM

#import neitris


# These are server side calls
#sockobj.bind((HOSTNAME, PORT))
#sockobj.listen(5)

message = ["Ping!"]

connected = 0
#readsock = None

#------------ Threaded Stuff ----------------#
DONE = 0
# I'm using PORTS 7777 and 7778
def ChatRead(PORT, rqueue, readsock):
#    global readsock
    

    buf = ''
    while not DONE:
        data = readsock.recv(1024)
#        print "read from socket: ", data
        buf = buf + data

        while 1:
            if len(buf) >= 2:
                (lenbuf,) = struct.unpack("!H", buf[:2])
            else:
                break

            if len(buf) >= lenbuf + 2:
            #print "playername: ", buf[0]
#            if buf[2] != playername:
                rqueue.put_nowait(buf[:lenbuf+2])
                
                buf = buf[(lenbuf+2):]
                
            else:
                break

        
    readsock.close()
    return

def ChatWrite(PORT, wqueue, readsock):
#    global readsock

    while not DONE:
   
        while not wqueue.empty():
            data = wqueue.get_nowait()
#            print "written ", data

            readsock.send(data)

        time.sleep(0.2)
    #writesock.close()
    return