driver-bitforce.c 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697
  1. /*
  2. * Copyright 2012 Luke Dashjr
  3. * Copyright 2012 Con Kolivas
  4. *
  5. * This program is free software; you can redistribute it and/or modify it
  6. * under the terms of the GNU General Public License as published by the Free
  7. * Software Foundation; either version 3 of the License, or (at your option)
  8. * any later version. See COPYING for more details.
  9. */
  10. #include <limits.h>
  11. #include <pthread.h>
  12. #include <stdint.h>
  13. #include <stdio.h>
  14. #include <strings.h>
  15. #include <sys/time.h>
  16. #include <unistd.h>
  17. #include "config.h"
  18. #ifdef WIN32
  19. #include <windows.h>
  20. #define dlsym (void*)GetProcAddress
  21. #define dlclose FreeLibrary
  22. typedef unsigned long FT_STATUS;
  23. typedef PVOID FT_HANDLE;
  24. __stdcall FT_STATUS (*FT_ListDevices)(PVOID pArg1, PVOID pArg2, DWORD Flags);
  25. __stdcall FT_STATUS (*FT_Open)(int idx, FT_HANDLE*);
  26. __stdcall FT_STATUS (*FT_GetComPortNumber)(FT_HANDLE, LPLONG lplComPortNumber);
  27. __stdcall FT_STATUS (*FT_Close)(FT_HANDLE);
  28. const uint32_t FT_OPEN_BY_DESCRIPTION = 2;
  29. const uint32_t FT_LIST_ALL = 0x20000000;
  30. const uint32_t FT_LIST_NUMBER_ONLY = 0x80000000;
  31. enum {
  32. FT_OK,
  33. };
  34. #endif /* WIN32 */
  35. #include "compat.h"
  36. #include "fpgautils.h"
  37. #include "miner.h"
  38. #define BITFORCE_SLEEP_MS 500
  39. #define BITFORCE_TIMEOUT_S 7
  40. #define BITFORCE_TIMEOUT_MS (BITFORCE_TIMEOUT_S * 1000)
  41. #define BITFORCE_LONG_TIMEOUT_S 15
  42. #define BITFORCE_LONG_TIMEOUT_MS (BITFORCE_LONG_TIMEOUT_S * 1000)
  43. #define BITFORCE_CHECK_INTERVAL_MS 10
  44. #define WORK_CHECK_INTERVAL_MS 50
  45. #define MAX_START_DELAY_US 100000
  46. #define tv_to_ms(tval) (tval.tv_sec * 1000 + tval.tv_usec / 1000)
  47. #define TIME_AVG_CONSTANT 8
  48. #define KNAME_WORK "full work"
  49. #define KNAME_RANGE "nonce range"
  50. struct device_api bitforce_api;
  51. // Code must deal with a timeout
  52. #define BFopen(devpath) serial_open(devpath, 0, 10, true)
  53. static void BFgets(char *buf, size_t bufLen, int fd)
  54. {
  55. do {
  56. buf[0] = '\0';
  57. --bufLen;
  58. } while (likely(bufLen && read(fd, buf, 1) == 1 && (buf++)[0] != '\n'));
  59. buf[0] = '\0';
  60. }
  61. static ssize_t BFwrite(int fd, const void *buf, ssize_t bufLen)
  62. {
  63. if ((bufLen) != write(fd, buf, bufLen))
  64. return 0;
  65. else
  66. return bufLen;
  67. }
  68. #define BFclose(fd) close(fd)
  69. static bool bitforce_detect_one(const char *devpath)
  70. {
  71. int fdDev = BFopen(devpath);
  72. struct cgpu_info *bitforce;
  73. char pdevbuf[0x100];
  74. char *s;
  75. applog(LOG_DEBUG, "BFL: Attempting to open %s", devpath);
  76. if (unlikely(fdDev == -1)) {
  77. applog(LOG_DEBUG, "BFL: Failed to open %s", devpath);
  78. return false;
  79. }
  80. BFwrite(fdDev, "ZGX", 3);
  81. BFgets(pdevbuf, sizeof(pdevbuf), fdDev);
  82. if (unlikely(!pdevbuf[0])) {
  83. applog(LOG_DEBUG, "BFL: Error reading/timeout (ZGX)");
  84. return 0;
  85. }
  86. BFclose(fdDev);
  87. if (unlikely(!strstr(pdevbuf, "SHA256"))) {
  88. applog(LOG_DEBUG, "BFL: Didn't recognise BitForce on %s", devpath);
  89. return false;
  90. }
  91. // We have a real BitForce!
  92. bitforce = calloc(1, sizeof(*bitforce));
  93. bitforce->api = &bitforce_api;
  94. bitforce->device_path = strdup(devpath);
  95. bitforce->deven = DEV_ENABLED;
  96. bitforce->threads = 1;
  97. /* Initially enable support for nonce range and disable it later if it
  98. * fails */
  99. if (opt_bfl_noncerange) {
  100. bitforce->nonce_range = true;
  101. bitforce->sleep_ms = BITFORCE_SLEEP_MS;
  102. bitforce->kname = KNAME_RANGE;
  103. } else {
  104. bitforce->sleep_ms = BITFORCE_SLEEP_MS * 5;
  105. bitforce->kname = KNAME_WORK;
  106. }
  107. if (likely((!memcmp(pdevbuf, ">>>ID: ", 7)) && (s = strstr(pdevbuf + 3, ">>>")))) {
  108. s[0] = '\0';
  109. bitforce->name = strdup(pdevbuf + 7);
  110. }
  111. mutex_init(&bitforce->device_mutex);
  112. return add_cgpu(bitforce);
  113. }
  114. #define LOAD_SYM(sym) do { \
  115. if (!(sym = dlsym(dll, #sym))) { \
  116. applog(LOG_DEBUG, "Failed to load " #sym ", not using FTDI bitforce autodetect"); \
  117. goto nogood; \
  118. } \
  119. } while(0)
  120. static char bitforce_autodetect_ftdi()
  121. {
  122. #ifdef WIN32
  123. FT_STATUS ftStatus;
  124. DWORD numDevs;
  125. HMODULE dll = LoadLibrary("FTD2XX.DLL");
  126. if (!dll)
  127. {
  128. applog(LOG_DEBUG, "FTD2XX.DLL failed to load, not using FTDI bitforce autodetect");
  129. return 0;
  130. }
  131. LOAD_SYM(FT_ListDevices);
  132. LOAD_SYM(FT_Open);
  133. LOAD_SYM(FT_GetComPortNumber);
  134. LOAD_SYM(FT_Close);
  135. ftStatus = FT_ListDevices(&numDevs, NULL, FT_LIST_NUMBER_ONLY);
  136. if (ftStatus != FT_OK)
  137. {
  138. applog(LOG_DEBUG, "FTDI device count failed, not using FTDI bitforce autodetect");
  139. nogood:
  140. dlclose(dll);
  141. return 0;
  142. }
  143. applog(LOG_DEBUG, "FTDI reports %u devices", (unsigned)numDevs);
  144. char buf[65 * numDevs];
  145. char*bufptrs[numDevs + 1];
  146. int i;
  147. for (i = 0; i < numDevs; ++i)
  148. bufptrs[i] = &buf[i * 65];
  149. bufptrs[numDevs] = NULL;
  150. ftStatus = FT_ListDevices(bufptrs, &numDevs, FT_LIST_ALL | FT_OPEN_BY_DESCRIPTION);
  151. if (ftStatus != FT_OK)
  152. {
  153. applog(LOG_DEBUG, "FTDI device list failed, not using FTDI bitforce autodetect");
  154. goto nogood;
  155. }
  156. char devpath[] = "\\\\.\\COMnnnnn";
  157. char *devpathnum = &devpath[7];
  158. char found = 0;
  159. for (i = numDevs; i > 0; )
  160. {
  161. --i;
  162. bufptrs[i][64] = '\0';
  163. if (!(strstr(bufptrs[i], "BitFORCE") && strstr(bufptrs[i], "SHA256")))
  164. continue;
  165. FT_HANDLE ftHandle;
  166. if (FT_OK != FT_Open(i, &ftHandle))
  167. continue;
  168. LONG lComPortNumber;
  169. ftStatus = FT_GetComPortNumber(ftHandle, &lComPortNumber);
  170. FT_Close(ftHandle);
  171. if (FT_OK != ftStatus || lComPortNumber < 0)
  172. continue;
  173. sprintf(devpathnum, "%d", (int)lComPortNumber);
  174. if (bitforce_detect_one(devpath))
  175. ++found;
  176. }
  177. dlclose(dll);
  178. return found;
  179. #else /* NOT WIN32 */
  180. return 0;
  181. #endif
  182. }
  183. static char bitforce_detect_auto()
  184. {
  185. return (serial_autodetect_udev (bitforce_detect_one, "BitFORCE*SHA256") ?:
  186. serial_autodetect_devserial(bitforce_detect_one, "BitFORCE_SHA256") ?:
  187. bitforce_autodetect_ftdi() ?:
  188. 0);
  189. }
  190. static void bitforce_detect()
  191. {
  192. serial_detect_auto(bitforce_api.dname, bitforce_detect_one, bitforce_detect_auto);
  193. }
  194. static void get_bitforce_statline_before(char *buf, struct cgpu_info *bitforce)
  195. {
  196. float gt = bitforce->temp;
  197. if (gt > 0)
  198. tailsprintf(buf, "%5.1fC ", gt);
  199. else
  200. tailsprintf(buf, " ", gt);
  201. tailsprintf(buf, " | ");
  202. }
  203. static bool bitforce_thread_prepare(struct thr_info *thr)
  204. {
  205. struct cgpu_info *bitforce = thr->cgpu;
  206. int fdDev = BFopen(bitforce->device_path);
  207. struct timeval now;
  208. if (unlikely(fdDev == -1)) {
  209. applog(LOG_ERR, "BFL%i: Failed to open %s", bitforce->device_id, bitforce->device_path);
  210. return false;
  211. }
  212. bitforce->device_fd = fdDev;
  213. applog(LOG_INFO, "BFL%i: Opened %s", bitforce->device_id, bitforce->device_path);
  214. gettimeofday(&now, NULL);
  215. get_datestamp(bitforce->init, &now);
  216. return true;
  217. }
  218. static void bitforce_clear_buffer(struct cgpu_info *bitforce)
  219. {
  220. int fdDev = bitforce->device_fd;
  221. char pdevbuf[0x100];
  222. int count = 0;
  223. if (!fdDev)
  224. return;
  225. applog(LOG_DEBUG, "BFL%i: Clearing read buffer", bitforce->device_id);
  226. mutex_lock(&bitforce->device_mutex);
  227. do {
  228. pdevbuf[0] = '\0';
  229. BFgets(pdevbuf, sizeof(pdevbuf), fdDev);
  230. } while (pdevbuf[0] && (++count < 10));
  231. mutex_unlock(&bitforce->device_mutex);
  232. }
  233. void bitforce_init(struct cgpu_info *bitforce)
  234. {
  235. const char *devpath = bitforce->device_path;
  236. int fdDev = bitforce->device_fd, retries = 0;
  237. char pdevbuf[0x100];
  238. char *s;
  239. applog(LOG_WARNING, "BFL%i: Re-initialising", bitforce->device_id);
  240. bitforce_clear_buffer(bitforce);
  241. mutex_lock(&bitforce->device_mutex);
  242. if (fdDev) {
  243. BFclose(fdDev);
  244. sleep(5);
  245. }
  246. bitforce->device_fd = 0;
  247. fdDev = BFopen(devpath);
  248. if (unlikely(fdDev == -1)) {
  249. mutex_unlock(&bitforce->device_mutex);
  250. applog(LOG_ERR, "BFL%i: Failed to open %s", bitforce->device_id, devpath);
  251. return;
  252. }
  253. do {
  254. BFwrite(fdDev, "ZGX", 3);
  255. BFgets(pdevbuf, sizeof(pdevbuf), fdDev);
  256. if (unlikely(!pdevbuf[0])) {
  257. mutex_unlock(&bitforce->device_mutex);
  258. applog(LOG_ERR, "BFL%i: Error reading/timeout (ZGX)", bitforce->device_id);
  259. return;
  260. }
  261. if (retries++)
  262. nmsleep(10);
  263. } while (!strstr(pdevbuf, "BUSY") && (retries * 10 < BITFORCE_TIMEOUT_MS));
  264. if (unlikely(!strstr(pdevbuf, "SHA256"))) {
  265. mutex_unlock(&bitforce->device_mutex);
  266. applog(LOG_ERR, "BFL%i: Didn't recognise BitForce on %s returned: %s", bitforce->device_id, devpath, pdevbuf);
  267. return;
  268. }
  269. if (likely((!memcmp(pdevbuf, ">>>ID: ", 7)) && (s = strstr(pdevbuf + 3, ">>>")))) {
  270. s[0] = '\0';
  271. bitforce->name = strdup(pdevbuf + 7);
  272. }
  273. bitforce->device_fd = fdDev;
  274. bitforce->sleep_ms = BITFORCE_SLEEP_MS;
  275. mutex_unlock(&bitforce->device_mutex);
  276. }
  277. static bool bitforce_get_temp(struct cgpu_info *bitforce)
  278. {
  279. int fdDev = bitforce->device_fd;
  280. char pdevbuf[0x100];
  281. char *s;
  282. if (!fdDev)
  283. return false;
  284. /* It is not critical getting temperature so don't get stuck if we
  285. * can't grab the mutex here */
  286. if (mutex_trylock(&bitforce->device_mutex))
  287. return false;
  288. BFwrite(fdDev, "ZLX", 3);
  289. BFgets(pdevbuf, sizeof(pdevbuf), fdDev);
  290. mutex_unlock(&bitforce->device_mutex);
  291. if (unlikely(!pdevbuf[0])) {
  292. applog(LOG_ERR, "BFL%i: Error: Get temp returned empty string/timed out", bitforce->device_id);
  293. bitforce->temp = 0;
  294. return false;
  295. }
  296. if ((!strncasecmp(pdevbuf, "TEMP", 4)) && (s = strchr(pdevbuf + 4, ':'))) {
  297. float temp = strtof(s + 1, NULL);
  298. if (temp > 0) {
  299. bitforce->temp = temp;
  300. if (unlikely(bitforce->cutofftemp > 0 && temp > bitforce->cutofftemp)) {
  301. applog(LOG_WARNING, "BFL%i: Hit thermal cutoff limit, disabling!", bitforce->device_id);
  302. bitforce->deven = DEV_RECOVER;
  303. bitforce->device_last_not_well = time(NULL);
  304. bitforce->device_not_well_reason = REASON_DEV_THERMAL_CUTOFF;
  305. bitforce->dev_thermal_cutoff_count++;
  306. }
  307. }
  308. } else {
  309. /* Use the temperature monitor as a kind of watchdog for when
  310. * our responses are out of sync and flush the buffer to
  311. * hopefully recover */
  312. applog(LOG_WARNING, "BFL%i: Garbled response probably throttling, clearing buffer");
  313. bitforce_clear_buffer(bitforce);
  314. return false;;
  315. }
  316. return true;
  317. }
  318. static bool bitforce_send_work(struct thr_info *thr, struct work *work)
  319. {
  320. struct cgpu_info *bitforce = thr->cgpu;
  321. int fdDev = bitforce->device_fd;
  322. unsigned char ob[70];
  323. char pdevbuf[0x100];
  324. char *s;
  325. if (!fdDev)
  326. return false;
  327. re_send:
  328. mutex_lock(&bitforce->device_mutex);
  329. if (bitforce->nonce_range)
  330. BFwrite(fdDev, "ZPX", 3);
  331. else
  332. BFwrite(fdDev, "ZDX", 3);
  333. BFgets(pdevbuf, sizeof(pdevbuf), fdDev);
  334. if (!pdevbuf[0] || !strncasecmp(pdevbuf, "B", 1)) {
  335. mutex_unlock(&bitforce->device_mutex);
  336. if (!restart_wait(WORK_CHECK_INTERVAL_MS))
  337. return false;
  338. goto re_send;
  339. } else if (unlikely(strncasecmp(pdevbuf, "OK", 2))) {
  340. mutex_unlock(&bitforce->device_mutex);
  341. if (bitforce->nonce_range) {
  342. applog(LOG_WARNING, "BFL%i: Does not support nonce range, disabling", bitforce->device_id);
  343. bitforce->nonce_range = false;
  344. bitforce->sleep_ms *= 5;
  345. bitforce->kname = KNAME_WORK;
  346. goto re_send;
  347. }
  348. applog(LOG_ERR, "BFL%i: Error: Send work reports: %s", bitforce->device_id, pdevbuf);
  349. bitforce_clear_buffer(bitforce);
  350. return false;
  351. }
  352. sprintf((char *)ob, ">>>>>>>>");
  353. memcpy(ob + 8, work->midstate, 32);
  354. memcpy(ob + 8 + 32, work->data + 64, 12);
  355. if (!bitforce->nonce_range) {
  356. sprintf((char *)ob + 8 + 32 + 12, ">>>>>>>>");
  357. work->blk.nonce = bitforce->nonces = 0xffffffff;
  358. BFwrite(fdDev, ob, 60);
  359. } else {
  360. uint32_t *nonce;
  361. nonce = (uint32_t *)(ob + 8 + 32 + 12);
  362. *nonce = htobe32(work->blk.nonce);
  363. nonce = (uint32_t *)(ob + 8 + 32 + 12 + 4);
  364. /* Split work up into 1/5th nonce ranges */
  365. bitforce->nonces = 0x33333332;
  366. *nonce = htobe32(work->blk.nonce + bitforce->nonces);
  367. work->blk.nonce += bitforce->nonces + 1;
  368. sprintf((char *)ob + 8 + 32 + 12 + 8, ">>>>>>>>");
  369. BFwrite(fdDev, ob, 68);
  370. }
  371. BFgets(pdevbuf, sizeof(pdevbuf), fdDev);
  372. mutex_unlock(&bitforce->device_mutex);
  373. if (opt_debug) {
  374. s = bin2hex(ob + 8, 44);
  375. applog(LOG_DEBUG, "BFL%i: block data: %s", bitforce->device_id, s);
  376. free(s);
  377. }
  378. if (unlikely(!pdevbuf[0])) {
  379. applog(LOG_ERR, "BFL%i: Error: Send block data returned empty string/timed out", bitforce->device_id);
  380. return false;
  381. }
  382. if (unlikely(strncasecmp(pdevbuf, "OK", 2))) {
  383. applog(LOG_ERR, "BFL%i: Error: Send block data reports: %s", bitforce->device_id, pdevbuf);
  384. bitforce_clear_buffer(bitforce);
  385. return false;
  386. }
  387. gettimeofday(&bitforce->work_start_tv, NULL);
  388. return true;
  389. }
  390. static inline int noisy_stale_wait(unsigned int mstime, struct work*work, bool checkend, struct cgpu_info*bitforce)
  391. {
  392. int rv = stale_wait(mstime, work, checkend);
  393. if (rv)
  394. applog(LOG_NOTICE, "BFL%i: Abandoning stale search to restart",
  395. bitforce->device_id);
  396. return rv;
  397. }
  398. #define noisy_stale_wait(mstime, work, checkend) noisy_stale_wait(mstime, work, checkend, bitforce)
  399. static int64_t bitforce_get_result(struct thr_info *thr, struct work *work)
  400. {
  401. struct cgpu_info *bitforce = thr->cgpu;
  402. int fdDev = bitforce->device_fd;
  403. unsigned int delay_time_ms;
  404. struct timeval elapsed;
  405. struct timeval now;
  406. char pdevbuf[0x100];
  407. char *pnoncebuf;
  408. uint32_t nonce;
  409. if (!fdDev)
  410. return -1;
  411. while (1) {
  412. mutex_lock(&bitforce->device_mutex);
  413. BFwrite(fdDev, "ZFX", 3);
  414. BFgets(pdevbuf, sizeof(pdevbuf), fdDev);
  415. mutex_unlock(&bitforce->device_mutex);
  416. gettimeofday(&now, NULL);
  417. timersub(&now, &bitforce->work_start_tv, &elapsed);
  418. if (elapsed.tv_sec >= BITFORCE_LONG_TIMEOUT_S) {
  419. applog(LOG_ERR, "BFL%i: took %dms - longer than %dms", bitforce->device_id,
  420. tv_to_ms(elapsed), BITFORCE_LONG_TIMEOUT_MS);
  421. return 0;
  422. }
  423. if (pdevbuf[0] && strncasecmp(pdevbuf, "B", 1)) /* BFL does not respond during throttling */
  424. break;
  425. /* if BFL is throttling, no point checking so quickly */
  426. delay_time_ms = (pdevbuf[0] ? BITFORCE_CHECK_INTERVAL_MS : 2 * WORK_CHECK_INTERVAL_MS);
  427. if (noisy_stale_wait(delay_time_ms, work, true))
  428. return 0;
  429. bitforce->wait_ms += delay_time_ms;
  430. }
  431. if (elapsed.tv_sec > BITFORCE_TIMEOUT_S) {
  432. applog(LOG_ERR, "BFL%i: took %dms - longer than %dms", bitforce->device_id,
  433. tv_to_ms(elapsed), BITFORCE_TIMEOUT_MS);
  434. bitforce->device_last_not_well = time(NULL);
  435. bitforce->device_not_well_reason = REASON_DEV_OVER_HEAT;
  436. bitforce->dev_over_heat_count++;
  437. if (!pdevbuf[0]) /* Only return if we got nothing after timeout - there still may be results */
  438. return 0;
  439. } else if (!strncasecmp(pdevbuf, "N", 1)) {/* Hashing complete (NONCE-FOUND or NO-NONCE) */
  440. /* Simple timing adjustment. Allow a few polls to cope with
  441. * OS timer delays being variably reliable. wait_ms will
  442. * always equal sleep_ms when we've waited greater than or
  443. * equal to the result return time.*/
  444. delay_time_ms = bitforce->sleep_ms;
  445. if (bitforce->wait_ms > bitforce->sleep_ms + (WORK_CHECK_INTERVAL_MS * 2))
  446. bitforce->sleep_ms += (bitforce->wait_ms - bitforce->sleep_ms) / 2;
  447. else if (bitforce->wait_ms == bitforce->sleep_ms) {
  448. if (bitforce->sleep_ms > WORK_CHECK_INTERVAL_MS)
  449. bitforce->sleep_ms -= WORK_CHECK_INTERVAL_MS;
  450. else if (bitforce->sleep_ms > BITFORCE_CHECK_INTERVAL_MS)
  451. bitforce->sleep_ms -= BITFORCE_CHECK_INTERVAL_MS;
  452. }
  453. if (delay_time_ms != bitforce->sleep_ms)
  454. applog(LOG_DEBUG, "BFL%i: Wait time changed to: %d, waited %u", bitforce->device_id, bitforce->sleep_ms, bitforce->wait_ms);
  455. /* Work out the average time taken. Float for calculation, uint for display */
  456. bitforce->avg_wait_f += (tv_to_ms(elapsed) - bitforce->avg_wait_f) / TIME_AVG_CONSTANT;
  457. bitforce->avg_wait_d = (unsigned int) (bitforce->avg_wait_f + 0.5);
  458. }
  459. applog(LOG_DEBUG, "BFL%i: waited %dms until %s", bitforce->device_id, bitforce->wait_ms, pdevbuf);
  460. if (!strncasecmp(&pdevbuf[2], "-", 1))
  461. return bitforce->nonces; /* No valid nonce found */
  462. else if (!strncasecmp(pdevbuf, "I", 1))
  463. return 0; /* Device idle */
  464. else if (strncasecmp(pdevbuf, "NONCE-FOUND", 11)) {
  465. applog(LOG_WARNING, "BFL%i: Error: Get result reports: %s", bitforce->device_id, pdevbuf);
  466. bitforce_clear_buffer(bitforce);
  467. return 0;
  468. }
  469. pnoncebuf = &pdevbuf[12];
  470. while (1) {
  471. hex2bin((void*)&nonce, pnoncebuf, 4);
  472. nonce = be32toh(nonce);
  473. if (unlikely(bitforce->nonce_range && (nonce >= work->blk.nonce ||
  474. (work->blk.nonce > 0 && nonce < work->blk.nonce - bitforce->nonces - 1)))) {
  475. applog(LOG_WARNING, "BFL%i: Disabling broken nonce range support", bitforce->device_id);
  476. bitforce->nonce_range = false;
  477. work->blk.nonce = 0xffffffff;
  478. bitforce->sleep_ms *= 5;
  479. bitforce->kname = KNAME_WORK;
  480. }
  481. submit_nonce(thr, work, nonce);
  482. if (strncmp(&pnoncebuf[8], ",", 1))
  483. break;
  484. pnoncebuf += 9;
  485. }
  486. return bitforce->nonces;
  487. }
  488. static void bitforce_shutdown(struct thr_info *thr)
  489. {
  490. struct cgpu_info *bitforce = thr->cgpu;
  491. BFclose(bitforce->device_fd);
  492. bitforce->device_fd = 0;
  493. }
  494. static void biforce_thread_enable(struct thr_info *thr)
  495. {
  496. struct cgpu_info *bitforce = thr->cgpu;
  497. bitforce_init(bitforce);
  498. }
  499. static int64_t bitforce_scanhash(struct thr_info *thr, struct work *work, int64_t __maybe_unused max_nonce)
  500. {
  501. struct cgpu_info *bitforce = thr->cgpu;
  502. unsigned int sleep_time;
  503. int64_t ret;
  504. if (!bitforce_send_work(thr, work)) {
  505. if (thr->work_restart)
  506. return 0;
  507. sleep(opt_fail_pause);
  508. goto commerr;
  509. }
  510. if (!bitforce->nonce_range) {
  511. /* Initially wait 2/3 of the average cycle time so we can request more
  512. work before full scan is up */
  513. sleep_time = (2 * bitforce->sleep_ms) / 3;
  514. if (noisy_stale_wait(sleep_time, work, true))
  515. return 0;
  516. bitforce->wait_ms = sleep_time;
  517. queue_request(thr, false);
  518. /* Now wait athe final 1/3rd; no bitforce should be finished by now */
  519. sleep_time = bitforce->sleep_ms - sleep_time;
  520. if (noisy_stale_wait(sleep_time, work, true))
  521. return 0;
  522. bitforce->wait_ms += sleep_time;
  523. } else {
  524. sleep_time = bitforce->sleep_ms;
  525. if (noisy_stale_wait(sleep_time, work, true))
  526. return 0;
  527. bitforce->wait_ms = sleep_time;
  528. }
  529. ret = bitforce_get_result(thr, work);
  530. if (ret == -1) {
  531. commerr:
  532. ret = 0;
  533. applog(LOG_ERR, "BFL%i: Comms error", bitforce->device_id);
  534. bitforce->device_last_not_well = time(NULL);
  535. bitforce->device_not_well_reason = REASON_DEV_COMMS_ERROR;
  536. bitforce->dev_comms_error_count++;
  537. /* empty read buffer */
  538. bitforce_clear_buffer(bitforce);
  539. }
  540. return ret;
  541. }
  542. static bool bitforce_get_stats(struct cgpu_info *bitforce)
  543. {
  544. return bitforce_get_temp(bitforce);
  545. }
  546. static bool bitforce_thread_init(struct thr_info *thr)
  547. {
  548. struct cgpu_info *bitforce = thr->cgpu;
  549. unsigned int wait;
  550. /* Pause each new thread at least 100ms between initialising
  551. * so the devices aren't making calls all at the same time. */
  552. wait = thr->id * MAX_START_DELAY_US;
  553. applog(LOG_DEBUG, "BFL%i: Delaying start by %dms", bitforce->device_id, wait / 1000);
  554. usleep(wait);
  555. return true;
  556. }
  557. static struct api_data *bitforce_api_stats(struct cgpu_info *cgpu)
  558. {
  559. struct api_data *root = NULL;
  560. // Warning, access to these is not locked - but we don't really
  561. // care since hashing performance is way more important than
  562. // locking access to displaying API debug 'stats'
  563. // If locking becomes an issue for any of them, use copy_data=true also
  564. root = api_add_uint(root, "Sleep Time", &(cgpu->sleep_ms), false);
  565. root = api_add_uint(root, "Avg Wait", &(cgpu->avg_wait_d), false);
  566. return root;
  567. }
  568. struct device_api bitforce_api = {
  569. .dname = "bitforce",
  570. .name = "BFL",
  571. .api_detect = bitforce_detect,
  572. .get_api_stats = bitforce_api_stats,
  573. .reinit_device = bitforce_init,
  574. .get_statline_before = get_bitforce_statline_before,
  575. .get_stats = bitforce_get_stats,
  576. .thread_prepare = bitforce_thread_prepare,
  577. .thread_init = bitforce_thread_init,
  578. .scanhash = bitforce_scanhash,
  579. .thread_shutdown = bitforce_shutdown,
  580. .thread_enable = biforce_thread_enable
  581. };