import socket, queue, threading, datetime
#from p2p.Packet import Packet
#from p2p.Types import Types
from p2p import *

class SendThread(threading.Thread):
	def __init__(self, socket, send_queue, out_queue, data_out):
		self.socket = socket
		self.send_queue = send_queue
		self.out_queue = out_queue
		self.data_out = data_out
		
		threading.Thread.__init__(self)
		
	def stop(self):
		self.running = 0
		
	def run(self):
		self.running = 1
		while self.running:
			packet = self.send_queue.get(True)
			self.socket.sendto(packet.pack(), packet.address)
			if packet.handlerId != Types.VERIFYHANDLER:
				packet.last_sent = datetime.datetime.now()
				packet.tries += 1
				self.out_queue.put(packet)
				self.data_out.append(packet)
			
		
		
		

150f7f01dc5bc4b175fc120577b813a9246ef54a
<mask token>


class SendThread(threading.Thread):
    <mask token>
    <mask token>
    <mask token>

<mask token>


class SendThread(threading.Thread):
    <mask token>

    def stop(self):
        self.running = 0

    def run(self):
        self.running = 1
        while self.running:
            packet = self.send_queue.get(True)
            self.socket.sendto(packet.pack(), packet.address)
            if packet.handlerId != Types.VERIFYHANDLER:
                packet.last_sent = datetime.datetime.now()
                packet.tries += 1
                self.out_queue.put(packet)
                self.data_out.append(packet)

<mask token>


class SendThread(threading.Thread):

    def __init__(self, socket, send_queue, out_queue, data_out):
        self.socket = socket
        self.send_queue = send_queue
        self.out_queue = out_queue
        self.data_out = data_out
        threading.Thread.__init__(self)

    def stop(self):
        self.running = 0

    def run(self):
        self.running = 1
        while self.running:
            packet = self.send_queue.get(True)
            self.socket.sendto(packet.pack(), packet.address)
            if packet.handlerId != Types.VERIFYHANDLER:
                packet.last_sent = datetime.datetime.now()
                packet.tries += 1
                self.out_queue.put(packet)
                self.data_out.append(packet)

import socket, queue, threading, datetime
from p2p import *


class SendThread(threading.Thread):

    def __init__(self, socket, send_queue, out_queue, data_out):
        self.socket = socket
        self.send_queue = send_queue
        self.out_queue = out_queue
        self.data_out = data_out
        threading.Thread.__init__(self)

    def stop(self):
        self.running = 0

    def run(self):
        self.running = 1
        while self.running:
            packet = self.send_queue.get(True)
            self.socket.sendto(packet.pack(), packet.address)
            if packet.handlerId != Types.VERIFYHANDLER:
                packet.last_sent = datetime.datetime.now()
                packet.tries += 1
                self.out_queue.put(packet)
                self.data_out.append(packet)

import socket, queue, threading, datetime
#from p2p.Packet import Packet
#from p2p.Types import Types
from p2p import *

class SendThread(threading.Thread):
	def __init__(self, socket, send_queue, out_queue, data_out):
		self.socket = socket
		self.send_queue = send_queue
		self.out_queue = out_queue
		self.data_out = data_out
		
		threading.Thread.__init__(self)
		
	def stop(self):
		self.running = 0
		
	def run(self):
		self.running = 1
		while self.running:
			packet = self.send_queue.get(True)
			self.socket.sendto(packet.pack(), packet.address)
			if packet.handlerId != Types.VERIFYHANDLER:
				packet.last_sent = datetime.datetime.now()
				packet.tries += 1
				self.out_queue.put(packet)
				self.data_out.append(packet)
			
		
		
		
