← Back to branch summary

~p2psp/p2psp/diagram

« back to all changes in this revision

Viewing changes to src/peer_dbs_orig.py

  • Committer: Cristóbal Medina López
  • Date: 2014-12-03 12:37:37 UTC
  • Revision ID: cristobalmedinalopez@gmail.com-20141203123737-uozn9bsv2zpimbqo
data file for diagram with timestamp

Show diffs side-by-side

added added

removed removed

Lines of Context:
src/peer_dbs_orig.py
15
15
import time
16
16
from _print_ import _print_
17
17
from peer_ims import Peer_IMS
 
18
import time
18
19
 
19
20
# }}}
20
21
 
172
173
                        _print_(self.team_socket.getsockname(), \
173
174
                            Color.red, "<-", Color.none, chunk_number, "-", sender)
174
175
 
175
 
                    if Peer_IMS.DIAGRAM:
176
 
                        print(sender, " -> ", self.team_socket.getsockname()," : ",chunk_number)
 
176
                    if Peer_IMS.DIAGRAM != "":
 
177
                        ts = int(time.time())
 
178
                        s = str(ts)+" = "+str(sender) + " -> " + str(self.team_socket.getsockname()) + " : " + str(chunk_number)+'\n'
 
179
                        Peer_IMS.DIAGRAM_FILE.write(s)
177
180
 
178
181
                    # }}}
179
182
 
190
193
                                                               self.receive_and_feed_previous)[0]),\
191
194
                                Color.green, "->", Color.none, peer)
192
195
 
193
 
                        if Peer_IMS.DIAGRAM:
194
 
                            print (self.team_socket.getsockname(), " -> ",peer, " : ",\
195
 
                                                 socket.ntohs(struct.unpack(self.message_format, self.receive_and_feed_previous)[0]))
 
196
                        if Peer_IMS.DIAGRAM != "":
 
197
                            ts = int(time.time())
 
198
                            s = str(ts)+" = "+ str(self.team_socket.getsockname())+ " -> "+str(peer)+ " : "+ str(socket.ntohs(struct.unpack(self.message_format, self.receive_and_feed_previous)[0]))+'\n'
 
199
                            Peer_IMS.DIAGRAM_FILE.write(s)
196
200
                        # }}}
197
201
 
198
202
                        self.debt[peer] += 1
216
220
                        print (self.team_socket.getsockname(), \
217
221
                            Color.green, "<-", Color.none, chunk_number, "-", sender)
218
222
 
219
 
                    if Peer_IMS.DIAGRAM:
220
 
                        print(sender, " -> ", self.team_socket.getsockname()," : ",chunk_number)
 
223
                    if Peer_IMS.DIAGRAM != "":
 
224
                        ts = int(time.time())
 
225
                        s = str(ts)+" = "+str(sender)+ " -> "+ str(self.team_socket.getsockname())+" : "+str(chunk_number)+'\n'
 
226
                        Peer_IMS.DIAGRAM_FILE.write(s)
221
227
                    # }}}
222
228
 
223
229
                    if sender not in self.peer_list:
254
260
                            socket.ntohs(struct.unpack(self.message_format, self.receive_and_feed_previous)[0]),\
255
261
                            Color.green, "->", Color.none, peer)
256
262
 
257
 
                    if Peer_IMS.DIAGRAM:
258
 
                        print (self.team_socket.getsockname(), " -> ",peer, " : ",\
259
 
                             socket.ntohs(struct.unpack(self.message_format, self.receive_and_feed_previous)[0]))
 
263
                    if Peer_IMS.DIAGRAM != "":
 
264
                        ts = int(time.time())
 
265
                        s = str(ts)+" = "+str(self.team_socket.getsockname())+ " -> "+str(peer)+ " : "+\
 
266
                             str(socket.ntohs(struct.unpack(self.message_format, self.receive_and_feed_previous)[0]))+'\n'
 
267
                        Peer_IMS.DIAGRAM_FILE.write(s)
260
268
                    # }}}
261
269
 
262
270
                    self.receive_and_feed_counter += 1
322
330
        for peer in self.peer_list:
323
331
            self.say_goodbye(peer)
324
332
 
 
333
        Peer_IMS.DIAGRAM_FILE.close()
325
334
        # }}}
326
335
 
327
336
    def buffer_data(self):