Miner.py

from Queue import Queue
from threading import Thread
from time import time


class Miner(object):
    def __init__(self, device_index, options):
        self.device_index = device_index
        self.options = options

        self.update_time_counter = 1
        self.share_count = [0, 0]
        self.work_queue = Queue()

        self.update = True

        self.accept_hist = []
        self.rate = self.estimated_rate = 0

    def start(self):
        self.should_stop = False
        Thread(target=self.mining_thread).start()
        self.start_time = time()

    def stop(self, message=None):
        if message: print '\n%s' % message
        self.should_stop = True

    def update_rate(self, now, iterations, t, targetQ, rate_divisor=1000):
        self.rate = int((iterations / t) / rate_divisor)
        self.rate = float(self.rate) / 1000
        if self.accept_hist:
            LAH = self.accept_hist.pop()
            if LAH[1] != self.share_count[1]:
                self.accept_hist.append(LAH)
        self.accept_hist.append((now, self.share_count[1]))
        while (self.accept_hist[0][0] < now - self.options.estimate):
            self.accept_hist.pop(0)
        new_accept = self.share_count[1] - self.accept_hist[0][1]
        self.estimated_rate = float(new_accept) * (targetQ) / min(int(now - self.start_time), self.options.estimate) / 1000
        self.estimated_rate = float(self.estimated_rate) / 1000

        self.switch.status_updated(self)