← Back to branch summary

~p2psp/p2psp/jpl850

« back to all changes in this revision

Viewing changes to splitter.py

  • Committer: Joaquín Pérez
  • Date: 2013-05-20 16:41:33 UTC
  • Revision ID: joaqun_prez-20130520164133-mujnpuzrpy5cbw85
Buffering añadido en gatherer y peer

Show diffs side-by-side

added added

removed removed

Lines of Context:
splitter.py
108
108
                while True:
109
109
                        
110
110
                        block = self.recibir_bloque()
111
 
                        self.numero_bloques += 1
 
111
                        
112
112
                        message = Splitter.empaquetar_bloque(block, self.numero_bloques)
113
113
                        if len(self.lista_peers) > 0:
114
 
                                for peer in self.lista_peers:           
 
114
                                for peer in self.lista_peers:
115
115
                                        print "Enviando al peer --> ", peer
116
116
                                        self.sock_cluster.sendto(message, peer)
117
117
                        else:
118
118
                                print "Enviando al gatherer --> ", self.gatherer
119
119
                                self.sock_cluster.sendto(message, self.gatherer)
 
120
                        self.numero_bloques += 1
120
121
                        
121
122
 
122
123
class peer_handler(Thread):