forked from m0mchil/poclbm
-
Notifications
You must be signed in to change notification settings - Fork 0
/
poclbm.py
executable file
·107 lines (87 loc) · 5.3 KB
/
poclbm.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
#!/usr/bin/env python
from Switch import Switch
from optparse import OptionGroup, OptionParser
from time import sleep
from util import tokenize
from version import VERSION
import log
import socket
class LongPollingSocket(socket.socket):
"""
Socket wrapper to enable socket.TCP_NODELAY and KEEPALIVE
"""
def __init__(self, family=socket.AF_INET, type=socket.SOCK_STREAM, proto=0):
super(LongPollingSocket, self).__init__(family, type, proto)
if type == socket.SOCK_STREAM:
self.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1)
self.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1)
self.settimeout(5)
socket.socket = LongPollingSocket
usage = "usage: %prog [OPTION]... SERVER[#tag]...\nSERVER is one or more [http[s]|stratum://]user:pass@host:port (required)\n[#tag] is a per SERVER user friendly name displayed in stats (optional)"
parser = OptionParser(version=VERSION, usage=usage)
parser.add_option('--verbose', dest='verbose', action='store_true', help='verbose output, suitable for redirection to log file')
parser.add_option('-q', '--quiet', dest='quiet', action='store_true', help='suppress all output except hash rate display')
parser.add_option('--proxy', dest='proxy', default='', help='specify as [[socks4|socks5|http://]user:pass@]host:port (default proto is socks5)')
parser.add_option('--no-ocl', dest='no_ocl', action='store_true', help="don't use OpenCL")
parser.add_option('--no-bfl', dest='no_bfl', action='store_true', help="don't use Butterfly Labs")
parser.add_option('--stratum-proxies',dest='stratum_proxies',action='store_true', help="search for and use stratum proxies in subnet")
parser.add_option('-d', '--device', dest='device', default=[], help='comma separated device IDs, by default will use all (for OpenCL - only GPU devices)')
group = OptionGroup(parser, "Miner Options")
group.add_option('-r', '--rate', dest='rate', default=1, help='hash rate display interval in seconds, default=1 (60 with --verbose)', type='float')
group.add_option('-e', '--estimate', dest='estimate', default=900, help='estimated rate time window in seconds, default 900 (15 minutes)', type='int')
group.add_option('-t', '--tolerance', dest='tolerance', default=2, help='use fallback pool only after N consecutive connection errors, default 2', type='int')
group.add_option('-b', '--failback', dest='failback', default=60, help='attempt to fail back to the primary pool after N seconds, default 60', type='int')
group.add_option('--cutoff-temp', dest='cutoff_temp',default=[], help='AMD GPUs, BFL only. For GPUs requires github.com/mjmvisser/adl3. Comma separated temperatures at which to skip kernel execution, in C, default=95')
group.add_option('--cutoff-interval', dest='cutoff_interval',default=[], help='how long to not execute calculations if CUTOFF_TEMP is reached, in seconds, default=0.01')
group.add_option('--no-server-failbacks', dest='nsf', action='store_true', help='disable using failback hosts provided by server')
parser.add_option_group(group)
group = OptionGroup(parser,
"OpenCL Options",
"Every option except 'platform' and 'vectors' can be specified as a comma separated list. "
"If there aren't enough entries specified, the last available is used. "
"Use --vv to specify per-device vectors usage."
)
group.add_option('-p', '--platform', dest='platform', default=-1, help='use platform by id', type='int')
group.add_option('-w', '--worksize', dest='worksize', default=[], help='work group size, default is maximum returned by OpenCL')
group.add_option('-f', '--frames', dest='frames', default=[], help='will try to bring single kernel execution to 1/frames seconds, default=30, increase this for less desktop lag')
group.add_option('-s', '--sleep', dest='frameSleep', default=[], help='sleep per frame in seconds, default 0')
group.add_option('--vv', dest='vectors', default=[], help='use vectors, default false')
group.add_option('-v', '--vectors', dest='old_vectors',action='store_true', help='use vectors')
parser.add_option_group(group)
(options, options.servers) = parser.parse_args()
log.verbose = options.verbose
log.quiet = options.quiet
options.rate = max(options.rate, 60) if options.verbose else max(options.rate, 0.1)
options.version = VERSION
options.max_update_time = 60
options.device = tokenize(options.device, 'device', [])
options.cutoff_temp = tokenize(options.cutoff_temp, 'cutoff_temp', [95], float)
options.cutoff_interval = tokenize(options.cutoff_interval, 'cutoff_interval', [0.01], float)
switch = None
try:
switch = Switch(options)
if not options.no_ocl:
import OpenCLMiner
for miner in OpenCLMiner.initialize(options):
switch.add_miner(miner)
if not options.no_bfl:
import BFLMiner
for miner in BFLMiner.initialize(options):
switch.add_miner(miner)
if not switch.servers:
print '\nAt least one server is required\n'
elif not switch.miners:
print '\nNothing to mine on, exiting\n'
else:
for miner in switch.miners:
miner.start()
switch.loop()
except KeyboardInterrupt:
print '\nbye'
finally:
for miner in switch.miners:
miner.stop()
if switch: switch.stop()
if not options.no_ocl:
OpenCLMiner.shutdown()
sleep(1.1)