| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701 |
- /*
- * Copyright 2012 Luke Dashjr
- * Copyright 2012 Con Kolivas
- *
- * This program is free software; you can redistribute it and/or modify it
- * under the terms of the GNU General Public License as published by the Free
- * Software Foundation; either version 3 of the License, or (at your option)
- * any later version. See COPYING for more details.
- */
- #include <limits.h>
- #include <pthread.h>
- #include <stdint.h>
- #include <stdio.h>
- #include <strings.h>
- #include <sys/time.h>
- #include <unistd.h>
- #include "config.h"
- #ifdef WIN32
- #include <windows.h>
- #define dlsym (void*)GetProcAddress
- #define dlclose FreeLibrary
- typedef unsigned long FT_STATUS;
- typedef PVOID FT_HANDLE;
- __stdcall FT_STATUS (*FT_ListDevices)(PVOID pArg1, PVOID pArg2, DWORD Flags);
- __stdcall FT_STATUS (*FT_Open)(int idx, FT_HANDLE*);
- __stdcall FT_STATUS (*FT_GetComPortNumber)(FT_HANDLE, LPLONG lplComPortNumber);
- __stdcall FT_STATUS (*FT_Close)(FT_HANDLE);
- const uint32_t FT_OPEN_BY_DESCRIPTION = 2;
- const uint32_t FT_LIST_ALL = 0x20000000;
- const uint32_t FT_LIST_NUMBER_ONLY = 0x80000000;
- enum {
- FT_OK,
- };
- #endif /* WIN32 */
- #include "compat.h"
- #include "fpgautils.h"
- #include "miner.h"
- #define BITFORCE_SLEEP_MS 500
- #define BITFORCE_TIMEOUT_S 7
- #define BITFORCE_TIMEOUT_MS (BITFORCE_TIMEOUT_S * 1000)
- #define BITFORCE_LONG_TIMEOUT_S 25
- #define BITFORCE_LONG_TIMEOUT_MS (BITFORCE_LONG_TIMEOUT_S * 1000)
- #define BITFORCE_CHECK_INTERVAL_MS 10
- #define WORK_CHECK_INTERVAL_MS 50
- #define MAX_START_DELAY_US 100000
- #define tv_to_ms(tval) (tval.tv_sec * 1000 + tval.tv_usec / 1000)
- #define TIME_AVG_CONSTANT 8
- #define KNAME_WORK "full work"
- #define KNAME_RANGE "nonce range"
- struct device_api bitforce_api;
- // Code must deal with a timeout
- #define BFopen(devpath) serial_open(devpath, 0, 250, true)
- static void BFgets(char *buf, size_t bufLen, int fd)
- {
- do {
- buf[0] = '\0';
- --bufLen;
- } while (likely(bufLen && read(fd, buf, 1) == 1 && (buf++)[0] != '\n'));
- buf[0] = '\0';
- }
- static ssize_t BFwrite(int fd, const void *buf, ssize_t bufLen)
- {
- if ((bufLen) != write(fd, buf, bufLen))
- return 0;
- else
- return bufLen;
- }
- #define BFclose(fd) close(fd)
- static bool bitforce_detect_one(const char *devpath)
- {
- int fdDev = serial_open(devpath, 0, 10, true);
- struct cgpu_info *bitforce;
- char pdevbuf[0x100];
- char *s;
- applog(LOG_DEBUG, "BFL: Attempting to open %s", devpath);
- if (unlikely(fdDev == -1)) {
- applog(LOG_DEBUG, "BFL: Failed to open %s", devpath);
- return false;
- }
- BFwrite(fdDev, "ZGX", 3);
- BFgets(pdevbuf, sizeof(pdevbuf), fdDev);
- if (unlikely(!pdevbuf[0])) {
- applog(LOG_DEBUG, "BFL: Error reading/timeout (ZGX)");
- return 0;
- }
- BFclose(fdDev);
- if (unlikely(!strstr(pdevbuf, "SHA256"))) {
- applog(LOG_DEBUG, "BFL: Didn't recognise BitForce on %s", devpath);
- return false;
- }
- // We have a real BitForce!
- bitforce = calloc(1, sizeof(*bitforce));
- bitforce->api = &bitforce_api;
- bitforce->device_path = strdup(devpath);
- bitforce->deven = DEV_ENABLED;
- bitforce->threads = 1;
- /* Initially enable support for nonce range and disable it later if it
- * fails */
- if (opt_bfl_noncerange) {
- bitforce->nonce_range = true;
- bitforce->sleep_ms = BITFORCE_SLEEP_MS;
- bitforce->kname = KNAME_RANGE;
- } else {
- bitforce->sleep_ms = BITFORCE_SLEEP_MS * 5;
- bitforce->kname = KNAME_WORK;
- }
- if (likely((!memcmp(pdevbuf, ">>>ID: ", 7)) && (s = strstr(pdevbuf + 3, ">>>")))) {
- s[0] = '\0';
- bitforce->name = strdup(pdevbuf + 7);
- }
- mutex_init(&bitforce->device_mutex);
- return add_cgpu(bitforce);
- }
- #define LOAD_SYM(sym) do { \
- if (!(sym = dlsym(dll, #sym))) { \
- applog(LOG_DEBUG, "Failed to load " #sym ", not using FTDI bitforce autodetect"); \
- goto out; \
- } \
- } while(0)
- #ifdef WIN32
- static int bitforce_autodetect_ftdi(void)
- {
- char devpath[] = "\\\\.\\COMnnnnn";
- char *devpathnum = &devpath[7];
- char **bufptrs;
- char *buf;
- int found = 0;
- int i;
- FT_STATUS ftStatus;
- DWORD numDevs;
- HMODULE dll = LoadLibrary("FTD2XX.DLL");
- if (!dll) {
- applog(LOG_DEBUG, "FTD2XX.DLL failed to load, not using FTDI bitforce autodetect");
- return 0;
- }
- LOAD_SYM(FT_ListDevices);
- LOAD_SYM(FT_Open);
- LOAD_SYM(FT_GetComPortNumber);
- LOAD_SYM(FT_Close);
-
- ftStatus = FT_ListDevices(&numDevs, NULL, FT_LIST_NUMBER_ONLY);
- if (ftStatus != FT_OK) {
- applog(LOG_DEBUG, "FTDI device count failed, not using FTDI bitforce autodetect");
- goto out;
- }
- applog(LOG_DEBUG, "FTDI reports %u devices", (unsigned)numDevs);
- buf = alloca(65 * numDevs);
- bufptrs = alloca(sizeof(*bufptrs) * (numDevs + 1));
- for (i = 0; i < numDevs; ++i)
- bufptrs[i] = &buf[i * 65];
- bufptrs[numDevs] = NULL;
- ftStatus = FT_ListDevices(bufptrs, &numDevs, FT_LIST_ALL | FT_OPEN_BY_DESCRIPTION);
- if (ftStatus != FT_OK) {
- applog(LOG_DEBUG, "FTDI device list failed, not using FTDI bitforce autodetect");
- goto out;
- }
-
- for (i = numDevs; i > 0; ) {
- --i;
- bufptrs[i][64] = '\0';
-
- if (!(strstr(bufptrs[i], "BitFORCE") && strstr(bufptrs[i], "SHA256")))
- continue;
-
- FT_HANDLE ftHandle;
- if (FT_OK != FT_Open(i, &ftHandle))
- continue;
- LONG lComPortNumber;
- ftStatus = FT_GetComPortNumber(ftHandle, &lComPortNumber);
- FT_Close(ftHandle);
- if (FT_OK != ftStatus || lComPortNumber < 0)
- continue;
-
- sprintf(devpathnum, "%d", (int)lComPortNumber);
-
- if (bitforce_detect_one(devpath))
- ++found;
- }
- out:
- dlclose(dll);
- return found;
- }
- #else
- static int bitforce_autodetect_ftdi(void)
- {
- return 0;
- }
- #endif
- static int bitforce_detect_auto(void)
- {
- return (serial_autodetect_udev (bitforce_detect_one, "BitFORCE*SHA256") ?:
- serial_autodetect_devserial(bitforce_detect_one, "BitFORCE_SHA256") ?:
- bitforce_autodetect_ftdi() ?:
- 0);
- }
- static void bitforce_detect(void)
- {
- serial_detect_auto(bitforce_api.dname, bitforce_detect_one, bitforce_detect_auto);
- }
- static void get_bitforce_statline_before(char *buf, struct cgpu_info *bitforce)
- {
- float gt = bitforce->temp;
- if (gt > 0)
- tailsprintf(buf, "%5.1fC ", gt);
- else
- tailsprintf(buf, " ", gt);
- tailsprintf(buf, " | ");
- }
- static bool bitforce_thread_prepare(struct thr_info *thr)
- {
- struct cgpu_info *bitforce = thr->cgpu;
- int fdDev = BFopen(bitforce->device_path);
- struct timeval now;
- if (unlikely(fdDev == -1)) {
- applog(LOG_ERR, "BFL%i: Failed to open %s", bitforce->device_id, bitforce->device_path);
- return false;
- }
- bitforce->device_fd = fdDev;
- applog(LOG_INFO, "BFL%i: Opened %s", bitforce->device_id, bitforce->device_path);
- gettimeofday(&now, NULL);
- get_datestamp(bitforce->init, &now);
- return true;
- }
- static void bitforce_clear_buffer(struct cgpu_info *bitforce)
- {
- int fdDev = bitforce->device_fd;
- char pdevbuf[0x100];
- int count = 0;
- if (!fdDev)
- return;
- applog(LOG_DEBUG, "BFL%i: Clearing read buffer", bitforce->device_id);
- mutex_lock(&bitforce->device_mutex);
- do {
- pdevbuf[0] = '\0';
- BFgets(pdevbuf, sizeof(pdevbuf), fdDev);
- } while (pdevbuf[0] && (++count < 10));
- mutex_unlock(&bitforce->device_mutex);
- }
- void bitforce_init(struct cgpu_info *bitforce)
- {
- const char *devpath = bitforce->device_path;
- int fdDev = bitforce->device_fd, retries = 0;
- char pdevbuf[0x100];
- char *s;
- applog(LOG_WARNING, "BFL%i: Re-initialising", bitforce->device_id);
- bitforce_clear_buffer(bitforce);
- mutex_lock(&bitforce->device_mutex);
- if (fdDev) {
- BFclose(fdDev);
- sleep(5);
- }
- bitforce->device_fd = 0;
- fdDev = BFopen(devpath);
- if (unlikely(fdDev == -1)) {
- mutex_unlock(&bitforce->device_mutex);
- applog(LOG_ERR, "BFL%i: Failed to open %s", bitforce->device_id, devpath);
- return;
- }
- do {
- BFwrite(fdDev, "ZGX", 3);
- BFgets(pdevbuf, sizeof(pdevbuf), fdDev);
- if (unlikely(!pdevbuf[0])) {
- mutex_unlock(&bitforce->device_mutex);
- applog(LOG_ERR, "BFL%i: Error reading/timeout (ZGX)", bitforce->device_id);
- return;
- }
- if (retries++)
- nmsleep(10);
- } while (!strstr(pdevbuf, "BUSY") && (retries * 10 < BITFORCE_TIMEOUT_MS));
- if (unlikely(!strstr(pdevbuf, "SHA256"))) {
- mutex_unlock(&bitforce->device_mutex);
- applog(LOG_ERR, "BFL%i: Didn't recognise BitForce on %s returned: %s", bitforce->device_id, devpath, pdevbuf);
- return;
- }
-
- if (likely((!memcmp(pdevbuf, ">>>ID: ", 7)) && (s = strstr(pdevbuf + 3, ">>>")))) {
- s[0] = '\0';
- bitforce->name = strdup(pdevbuf + 7);
- }
- bitforce->device_fd = fdDev;
- bitforce->sleep_ms = BITFORCE_SLEEP_MS;
- mutex_unlock(&bitforce->device_mutex);
- }
- static bool bitforce_get_temp(struct cgpu_info *bitforce)
- {
- int fdDev = bitforce->device_fd;
- char pdevbuf[0x100];
- char *s;
- if (!fdDev)
- return false;
- /* Do not try to get the temperature if we're polling for a result to
- * minimise the change of interleaved results */
- if (bitforce->polling)
- return true;
- /* It is not critical getting temperature so don't get stuck if we
- * can't grab the mutex here */
- if (mutex_trylock(&bitforce->device_mutex))
- return false;
- BFwrite(fdDev, "ZLX", 3);
- BFgets(pdevbuf, sizeof(pdevbuf), fdDev);
- mutex_unlock(&bitforce->device_mutex);
-
- if (unlikely(!pdevbuf[0])) {
- applog(LOG_ERR, "BFL%i: Error: Get temp returned empty string/timed out", bitforce->device_id);
- bitforce->hw_errors++;
- return false;
- }
- if ((!strncasecmp(pdevbuf, "TEMP", 4)) && (s = strchr(pdevbuf + 4, ':'))) {
- float temp = strtof(s + 1, NULL);
- if (temp > 0) {
- bitforce->temp = temp;
- if (unlikely(bitforce->cutofftemp > 0 && temp > bitforce->cutofftemp)) {
- applog(LOG_WARNING, "BFL%i: Hit thermal cutoff limit, disabling!", bitforce->device_id);
- bitforce->deven = DEV_RECOVER;
- bitforce->device_last_not_well = time(NULL);
- bitforce->device_not_well_reason = REASON_DEV_THERMAL_CUTOFF;
- bitforce->dev_thermal_cutoff_count++;
- }
- }
- } else {
- /* Use the temperature monitor as a kind of watchdog for when
- * our responses are out of sync and flush the buffer to
- * hopefully recover */
- applog(LOG_WARNING, "BFL%i: Garbled response probably throttling, clearing buffer", bitforce->device_id);
- /* Count throttling episodes as hardware errors */
- bitforce->hw_errors++;
- bitforce_clear_buffer(bitforce);
- return false;;
- }
- return true;
- }
- static bool bitforce_send_work(struct thr_info *thr, struct work *work)
- {
- struct cgpu_info *bitforce = thr->cgpu;
- int fdDev = bitforce->device_fd;
- unsigned char ob[70];
- char pdevbuf[0x100];
- char *s;
- if (!fdDev)
- return false;
- re_send:
- mutex_lock(&bitforce->device_mutex);
- if (bitforce->nonce_range)
- BFwrite(fdDev, "ZPX", 3);
- else
- BFwrite(fdDev, "ZDX", 3);
- BFgets(pdevbuf, sizeof(pdevbuf), fdDev);
- if (!pdevbuf[0] || !strncasecmp(pdevbuf, "B", 1)) {
- mutex_unlock(&bitforce->device_mutex);
- if (!restart_wait(WORK_CHECK_INTERVAL_MS))
- return false;
- goto re_send;
- } else if (unlikely(strncasecmp(pdevbuf, "OK", 2))) {
- mutex_unlock(&bitforce->device_mutex);
- if (bitforce->nonce_range) {
- applog(LOG_WARNING, "BFL%i: Does not support nonce range, disabling", bitforce->device_id);
- bitforce->nonce_range = false;
- bitforce->sleep_ms *= 5;
- bitforce->kname = KNAME_WORK;
- goto re_send;
- }
- applog(LOG_ERR, "BFL%i: Error: Send work reports: %s", bitforce->device_id, pdevbuf);
- return false;
- }
- sprintf((char *)ob, ">>>>>>>>");
- memcpy(ob + 8, work->midstate, 32);
- memcpy(ob + 8 + 32, work->data + 64, 12);
- if (!bitforce->nonce_range) {
- sprintf((char *)ob + 8 + 32 + 12, ">>>>>>>>");
- work->blk.nonce = bitforce->nonces = 0xffffffff;
- BFwrite(fdDev, ob, 60);
- } else {
- uint32_t *nonce;
- nonce = (uint32_t *)(ob + 8 + 32 + 12);
- *nonce = htobe32(work->blk.nonce);
- nonce = (uint32_t *)(ob + 8 + 32 + 12 + 4);
- /* Split work up into 1/5th nonce ranges */
- bitforce->nonces = 0x33333332;
- *nonce = htobe32(work->blk.nonce + bitforce->nonces);
- work->blk.nonce += bitforce->nonces + 1;
- sprintf((char *)ob + 8 + 32 + 12 + 8, ">>>>>>>>");
- BFwrite(fdDev, ob, 68);
- }
- BFgets(pdevbuf, sizeof(pdevbuf), fdDev);
- mutex_unlock(&bitforce->device_mutex);
- if (opt_debug) {
- s = bin2hex(ob + 8, 44);
- applog(LOG_DEBUG, "BFL%i: block data: %s", bitforce->device_id, s);
- free(s);
- }
- if (unlikely(!pdevbuf[0])) {
- applog(LOG_ERR, "BFL%i: Error: Send block data returned empty string/timed out", bitforce->device_id);
- return false;
- }
- if (unlikely(strncasecmp(pdevbuf, "OK", 2))) {
- applog(LOG_ERR, "BFL%i: Error: Send block data reports: %s", bitforce->device_id, pdevbuf);
- return false;
- }
- gettimeofday(&bitforce->work_start_tv, NULL);
- return true;
- }
- static inline int noisy_stale_wait(unsigned int mstime, struct work*work, bool checkend, struct cgpu_info*bitforce)
- {
- int rv = stale_wait(mstime, work, checkend);
- if (rv)
- applog(LOG_NOTICE, "BFL%i: Abandoning stale search to restart",
- bitforce->device_id);
- return rv;
- }
- #define noisy_stale_wait(mstime, work, checkend) noisy_stale_wait(mstime, work, checkend, bitforce)
- static int64_t bitforce_get_result(struct thr_info *thr, struct work *work)
- {
- struct cgpu_info *bitforce = thr->cgpu;
- int fdDev = bitforce->device_fd;
- unsigned int delay_time_ms;
- struct timeval elapsed;
- struct timeval now;
- char pdevbuf[0x100];
- char *pnoncebuf;
- uint32_t nonce;
- if (!fdDev)
- return -1;
- while (1) {
- mutex_lock(&bitforce->device_mutex);
- BFwrite(fdDev, "ZFX", 3);
- BFgets(pdevbuf, sizeof(pdevbuf), fdDev);
- mutex_unlock(&bitforce->device_mutex);
- gettimeofday(&now, NULL);
- timersub(&now, &bitforce->work_start_tv, &elapsed);
- if (elapsed.tv_sec >= BITFORCE_LONG_TIMEOUT_S) {
- applog(LOG_ERR, "BFL%i: took %dms - longer than %dms", bitforce->device_id,
- tv_to_ms(elapsed), BITFORCE_LONG_TIMEOUT_MS);
- return 0;
- }
- if (pdevbuf[0] && strncasecmp(pdevbuf, "B", 1)) /* BFL does not respond during throttling */
- break;
- /* if BFL is throttling, no point checking so quickly */
- delay_time_ms = (pdevbuf[0] ? BITFORCE_CHECK_INTERVAL_MS : 2 * WORK_CHECK_INTERVAL_MS);
- if (noisy_stale_wait(delay_time_ms, work, true))
- return 0;
- bitforce->wait_ms += delay_time_ms;
- }
- if (elapsed.tv_sec > BITFORCE_TIMEOUT_S) {
- applog(LOG_ERR, "BFL%i: took %dms - longer than %dms", bitforce->device_id,
- tv_to_ms(elapsed), BITFORCE_TIMEOUT_MS);
- bitforce->device_last_not_well = time(NULL);
- bitforce->device_not_well_reason = REASON_DEV_OVER_HEAT;
- bitforce->dev_over_heat_count++;
- /* If the device truly throttled, it didn't process the job and there
- * are no results. But check first, just in case we're wrong about it
- * throttling.
- */
- if (strncasecmp(pdevbuf, "NONCE-FOUND", 11))
- return 0;
- } else if (!strncasecmp(pdevbuf, "N", 1)) {/* Hashing complete (NONCE-FOUND or NO-NONCE) */
- /* Simple timing adjustment. Allow a few polls to cope with
- * OS timer delays being variably reliable. wait_ms will
- * always equal sleep_ms when we've waited greater than or
- * equal to the result return time.*/
- delay_time_ms = bitforce->sleep_ms;
- if (bitforce->wait_ms > bitforce->sleep_ms + (WORK_CHECK_INTERVAL_MS * 2))
- bitforce->sleep_ms += (bitforce->wait_ms - bitforce->sleep_ms) / 2;
- else if (bitforce->wait_ms == bitforce->sleep_ms) {
- if (bitforce->sleep_ms > WORK_CHECK_INTERVAL_MS)
- bitforce->sleep_ms -= WORK_CHECK_INTERVAL_MS;
- else if (bitforce->sleep_ms > BITFORCE_CHECK_INTERVAL_MS)
- bitforce->sleep_ms -= BITFORCE_CHECK_INTERVAL_MS;
- }
- if (delay_time_ms != bitforce->sleep_ms)
- applog(LOG_DEBUG, "BFL%i: Wait time changed to: %d, waited %u", bitforce->device_id, bitforce->sleep_ms, bitforce->wait_ms);
- /* Work out the average time taken. Float for calculation, uint for display */
- bitforce->avg_wait_f += (tv_to_ms(elapsed) - bitforce->avg_wait_f) / TIME_AVG_CONSTANT;
- bitforce->avg_wait_d = (unsigned int) (bitforce->avg_wait_f + 0.5);
- }
- applog(LOG_DEBUG, "BFL%i: waited %dms until %s", bitforce->device_id, bitforce->wait_ms, pdevbuf);
- if (!strncasecmp(&pdevbuf[2], "-", 1))
- return bitforce->nonces; /* No valid nonce found */
- else if (!strncasecmp(pdevbuf, "I", 1))
- return 0; /* Device idle */
- else if (strncasecmp(pdevbuf, "NONCE-FOUND", 11)) {
- bitforce->hw_errors++;
- applog(LOG_WARNING, "BFL%i: Error: Get result reports: %s", bitforce->device_id, pdevbuf);
- bitforce_clear_buffer(bitforce);
- return 0;
- }
- pnoncebuf = &pdevbuf[12];
- while (1) {
- hex2bin((void*)&nonce, pnoncebuf, 4);
- nonce = be32toh(nonce);
- if (unlikely(bitforce->nonce_range && (nonce >= work->blk.nonce ||
- (work->blk.nonce > 0 && nonce < work->blk.nonce - bitforce->nonces - 1)))) {
- applog(LOG_WARNING, "BFL%i: Disabling broken nonce range support", bitforce->device_id);
- bitforce->nonce_range = false;
- work->blk.nonce = 0xffffffff;
- bitforce->sleep_ms *= 5;
- bitforce->kname = KNAME_WORK;
- }
-
- submit_nonce(thr, work, nonce);
- if (strncmp(&pnoncebuf[8], ",", 1))
- break;
- pnoncebuf += 9;
- }
- return bitforce->nonces;
- }
- static void bitforce_shutdown(struct thr_info *thr)
- {
- struct cgpu_info *bitforce = thr->cgpu;
- BFclose(bitforce->device_fd);
- bitforce->device_fd = 0;
- }
- static void biforce_thread_enable(struct thr_info *thr)
- {
- struct cgpu_info *bitforce = thr->cgpu;
- bitforce_init(bitforce);
- }
- static int64_t bitforce_scanhash(struct thr_info *thr, struct work *work, int64_t __maybe_unused max_nonce)
- {
- struct cgpu_info *bitforce = thr->cgpu;
- int64_t ret;
- if (!bitforce_send_work(thr, work)) {
- if (thr->work_restart)
- return 0;
- sleep(opt_fail_pause);
- goto commerr;
- }
- if (noisy_stale_wait(bitforce->sleep_ms, work, true))
- return 0;
- bitforce->wait_ms = bitforce->sleep_ms;
- {
- bitforce->polling = true;
- ret = bitforce_get_result(thr, work);
- bitforce->polling = false;
- }
- if (ret == -1) {
- commerr:
- ret = 0;
- applog(LOG_ERR, "BFL%i: Comms error", bitforce->device_id);
- bitforce->device_last_not_well = time(NULL);
- bitforce->device_not_well_reason = REASON_DEV_COMMS_ERROR;
- bitforce->dev_comms_error_count++;
- bitforce->hw_errors++;
- BFclose(bitforce->device_fd);
- int fd = bitforce->device_fd = BFopen(bitforce->device_path);
- if (fd == -1) {
- applog(LOG_ERR, "BFL%i: Error reopening");
- return -1;
- }
- /* empty read buffer */
- bitforce_clear_buffer(bitforce);
- }
- return ret;
- }
- static bool bitforce_get_stats(struct cgpu_info *bitforce)
- {
- return bitforce_get_temp(bitforce);
- }
- static bool bitforce_thread_init(struct thr_info *thr)
- {
- struct cgpu_info *bitforce = thr->cgpu;
- unsigned int wait;
- /* Pause each new thread at least 100ms between initialising
- * so the devices aren't making calls all at the same time. */
- wait = thr->id * MAX_START_DELAY_US;
- applog(LOG_DEBUG, "BFL%i: Delaying start by %dms", bitforce->device_id, wait / 1000);
- usleep(wait);
- return true;
- }
- static struct api_data *bitforce_api_stats(struct cgpu_info *cgpu)
- {
- struct api_data *root = NULL;
- // Warning, access to these is not locked - but we don't really
- // care since hashing performance is way more important than
- // locking access to displaying API debug 'stats'
- // If locking becomes an issue for any of them, use copy_data=true also
- root = api_add_uint(root, "Sleep Time", &(cgpu->sleep_ms), false);
- root = api_add_uint(root, "Avg Wait", &(cgpu->avg_wait_d), false);
- return root;
- }
- struct device_api bitforce_api = {
- .dname = "bitforce",
- .name = "BFL",
- .api_detect = bitforce_detect,
- .get_api_stats = bitforce_api_stats,
- .reinit_device = bitforce_init,
- .get_statline_before = get_bitforce_statline_before,
- .get_stats = bitforce_get_stats,
- .thread_prepare = bitforce_thread_prepare,
- .thread_init = bitforce_thread_init,
- .scanhash = bitforce_scanhash,
- .thread_shutdown = bitforce_shutdown,
- .thread_enable = biforce_thread_enable
- };
|