Changeset 50:6a65331c2df5 in livinglogic.python.tipimaid

Show
Ignore:
Timestamp:
12/22/08 17:00:57 (10 years ago)
Author:
Nikolas Tautenhahn <nik@…>
Branch:
default
Message:

move sending of \"1\" into try block

Files:
2 modified

Legend:

Unmodified
Added
Removed
  • liaalh_sender.py

    r49 r50  
    5858            signal.alarm(5) # wait 5 seconds for server to notify us that it got the message 
    5959            try: 
    60                 if self.s.recv(1024) == "": 
     60                ret = self.s.recv(1024) 
     61                if ret == "": 
    6162                    raise socket.timeout 
    6263            except (socket.timeout, socket.error), exc: 
  • liaalh_server.py

    r49 r50  
    3737            try: 
    3838                data = s.recv(size) 
     39                if data: 
     40                    s.send("1") # notify the sender that we got something DISABLE THIS IF WE USE NETCAT AS SENDER! 
     41                    inputs[s] += data 
     42                    pos = inputs[s].rfind("\n") 
     43                    if pos >= 0: 
     44                        sys.stdout.write(inputs[s][:pos+1]) 
     45                        sys.stdout.flush() 
     46                        inputs[s] = inputs[s][pos+1:] 
     47                else: 
     48                    raise socket.error 
    3949            except socket.error, exc: 
    4050                s.close() 
     
    4252                input.remove(s) # TODO: make sure that we don't create index errors here 
    4353                continue 
    44             if data: 
    45                 s.send("1") # notify the sender that we got something DISABLE THIS IF WE USE NETCAT AS SENDER! 
    46                 inputs[s] += data 
    47                 pos = inputs[s].rfind("\n") 
    48                 if pos >= 0: 
    49                     sys.stdout.write(inputs[s][:pos+1]) 
    50                     sys.stdout.flush() 
    51                     inputs[s] = inputs[s][pos+1:] 
    52             else: 
    53                 s.close() 
    54                 del inputs[s] 
    55                 input.remove(s)