driver-futurebit.c 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716
  1. /*
  2. * Copyright 2015 John Stefanopoulos
  3. * Copyright 2014-2015 Luke Dashjr
  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 "config.h"
  11. #include <stdbool.h>
  12. #include <stdint.h>
  13. #include <stdlib.h>
  14. #include <string.h>
  15. #include <unistd.h>
  16. #include <stdio.h>
  17. #include <libusb.h>
  18. #include "deviceapi.h"
  19. #include "logging.h"
  20. #include "lowlevel.h"
  21. #include "lowl-vcom.h"
  22. #include "util.h"
  23. #include <bwltc-commands.h>
  24. static const uint8_t futurebit_max_chips = 0x01;
  25. #define FUTUREBIT_DEFAULT_FREQUENCY 600
  26. #define FUTUREBIT_MIN_CLOCK 384
  27. #define FUTUREBIT_MAX_CLOCK 1020
  28. // Number of seconds chip of 54 cores @ 352mhz takes to scan full range
  29. #define FUTUREBIT_HASH_SPEED 1130.0
  30. #define FUTUREBIT_MAX_NONCE 0xffffffff
  31. #define FUTUREBIT_READ_SIZE 8
  32. //#define futurebit_max_clusters_per_chip 6
  33. //#define futurebit_max_cores_per_cluster 9
  34. unsigned char job2[] = {
  35. 0x3c, 0xff, 0x40, 0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
  36. 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0xf8, 0xff,
  37. 0x07, 0x00, 0x00, 0x00, 0xd7, 0xa2, 0xea, 0xb0, 0xc2, 0xd7, 0x6f, 0x1e, 0x33, 0xa4, 0xb5, 0x3e,
  38. 0x0e, 0xb2, 0x84, 0x34, 0x89, 0x5a, 0x8b, 0x10, 0xfb, 0x19, 0x7d, 0x76, 0xe6, 0xe0, 0x38, 0x60,
  39. 0x15, 0x3f, 0x6a, 0x6e, 0x00, 0x00, 0x00, 0x04, 0xb5, 0x93, 0x93, 0x27, 0xf7, 0xc9, 0xfb, 0x26,
  40. 0xdf, 0x3b, 0xde, 0xc0, 0xa6, 0x6c, 0xae, 0x10, 0xb5, 0x53, 0xb7, 0x61, 0x5d, 0x67, 0xa4, 0x97,
  41. 0xe8, 0x7f, 0x06, 0xa6, 0x27, 0xfc, 0xd5, 0x57, 0x44, 0x38, 0xb8, 0x4d, 0xb1, 0xfe, 0x4f, 0x5f,
  42. 0x31, 0xaa, 0x47, 0x3d, 0x3d, 0xb4, 0xfc, 0x03, 0xa2, 0x78, 0x92, 0x44, 0xa1, 0x39, 0xb0, 0x35,
  43. 0xe1, 0x46, 0x04, 0x1e, 0x8c, 0x0a, 0xad, 0x28, 0x58, 0xec, 0x78, 0x3c, 0x1b, 0x00, 0xa4, 0x43
  44. };
  45. BFG_REGISTER_DRIVER(futurebit_drv)
  46. static const struct bfg_set_device_definition futurebit_set_device_funcs_probe[];
  47. struct futurebit_chip {
  48. uint8_t chipid;
  49. unsigned active_cores;
  50. unsigned freq;
  51. };
  52. static
  53. void futurebit_chip_init(struct futurebit_chip * const chip, const uint8_t chipid)
  54. {
  55. *chip = (struct futurebit_chip){
  56. .chipid = chipid,
  57. .active_cores = 64,
  58. .freq = FUTUREBIT_DEFAULT_FREQUENCY,
  59. };
  60. }
  61. static
  62. void futurebit_reset_board(const int fd)
  63. {
  64. applog(LOG_DEBUG, "RESET START");
  65. if(set_serial_rts(fd, BGV_HIGH) == BGV_ERROR)
  66. applog(LOG_DEBUG, "IOCTL RTS RESET FAILED");
  67. cgsleep_ms(1000);
  68. if(set_serial_rts(fd, BGV_LOW) == BGV_ERROR)
  69. applog(LOG_DEBUG, "IOCTL RTS RESET FAILED");
  70. applog(LOG_DEBUG, "RESET END");
  71. }
  72. int futurebit_write(const int fd, const void *buf, size_t buflen)
  73. {
  74. int repeat = 0;
  75. int size = 0;
  76. int ret = 0;
  77. int nwrite = 0;
  78. char output[(buflen * 2) + 1];
  79. bin2hex(output, buf, buflen);
  80. applog(LOG_DEBUG, "WRITE BUFFER %s", output);
  81. while(size < buflen)
  82. {
  83. nwrite = write(fd, buf, buflen);
  84. //applog(LOG_DEBUG, "FutureBit Write SIZE: %u", nwrite);
  85. if (nwrite < 0)
  86. {
  87. applog(LOG_ERR, "FutureBit Write error: %s", strerror(errno));
  88. break;
  89. }
  90. size += nwrite;
  91. if (repeat++ > 1)
  92. {
  93. break;
  94. }
  95. }
  96. return 0;
  97. }
  98. static
  99. bool futurebit_read (const int fd, unsigned char *buf, int read_amount)
  100. {
  101. ssize_t nread = 0;
  102. int size = 0;
  103. int repeat = 0;
  104. while(size < read_amount)
  105. {
  106. nread = read(fd, buf, read_amount);
  107. if(nread < 0)
  108. return false;
  109. size += nread;
  110. //char output[(read_amount * 2) + 1];
  111. // bin2hex(output, buf, read_amount);
  112. //applog(LOG_DEBUG, "READ BUFFER %s", output);
  113. if (repeat++ > 0)
  114. {
  115. break;
  116. }
  117. }
  118. #if 0
  119. int i;
  120. for (i=0; i<size; i++)
  121. {
  122. printf("0x%02x ", buf[i]);
  123. }
  124. printf("\n");
  125. #endif
  126. return true;
  127. }
  128. static
  129. char futurebit_read_register(const int fd, uint32_t chip, uint32_t moudle, uint32_t RegAddr)
  130. {
  131. uint8_t read_reg_data[8]={0};
  132. uint8_t read_reg_cmd[16]={0x3c, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,0xc3};
  133. read_reg_cmd[1] = chip;
  134. read_reg_cmd[2] = moudle;
  135. read_reg_cmd[3] = 0x80|RegAddr; //read
  136. static int nonce=0;
  137. futurebit_write(fd, read_reg_cmd, 9);
  138. cgsleep_us(100000);
  139. if(!futurebit_read(fd, read_reg_data, 8))
  140. applog(LOG_DEBUG, "FutureBit read register fail");
  141. applog(LOG_DEBUG, "FutureBit Read Return:");
  142. for (int i=0; i<8; i++)
  143. {
  144. applog(LOG_DEBUG,"0x%02x ", read_reg_data[i]);
  145. }
  146. applog(LOG_DEBUG,"\n");
  147. return read_reg_data[0];
  148. }
  149. unsigned
  150. int futurebit_write_register(const int fd, uint32_t chipId, uint32_t moudle, uint32_t Regaddr, uint32_t value)
  151. {
  152. bool ret =true;
  153. uint8_t read_reg_cmd[16]={0x3c, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,0xc3};
  154. read_reg_cmd[1] = chipId;
  155. read_reg_cmd[2] = moudle;
  156. read_reg_cmd[3] = 0x7f&Regaddr; //&0x7f->write\BF\BFbit[7]:1 read, 0 write
  157. read_reg_cmd[4] = value&0xff;
  158. read_reg_cmd[5] = (value>>8)&0xff;
  159. read_reg_cmd[6] = (value>>16)&0xff;
  160. read_reg_cmd[7] = (value>>24)&0xff;
  161. futurebit_write(fd, read_reg_cmd, 9);
  162. return ret;
  163. }
  164. static
  165. void futurebit_send_cmds(const int fd, const unsigned char *cmds[])
  166. {
  167. int i;
  168. for(i = 0; cmds[i] != NULL; i++)
  169. {
  170. futurebit_write(fd, cmds[i] + 1, cmds[i][0]);
  171. cgsleep_us(10000);
  172. }
  173. }
  174. static
  175. void futurebit_set_frequency(const int fd, uint32_t freq)
  176. {
  177. struct frequecy *p;
  178. unsigned char **cmd = cmd_set_600M;
  179. int i;
  180. for (i=0; i<ARRAY_LEN; i++)
  181. {
  182. if (fre_array[i].freq == freq)
  183. {
  184. cmd = fre_array[i].cmd;
  185. }
  186. }
  187. futurebit_send_cmds(fd, cmd);
  188. }
  189. void futurebit_config_all_chip(const int fd, uint32_t freq)
  190. {
  191. uint32_t reg_val;
  192. int i;
  193. futurebit_reset_board(fd);
  194. futurebit_send_cmds(fd, cmd_auto_address);
  195. cgsleep_us(100000);
  196. //futurebit_set_baudrate(fd);
  197. //cgsleep_us(100000);
  198. futurebit_set_frequency(fd, freq);
  199. cgsleep_us(100000);
  200. #if 1
  201. futurebit_write_register(fd, 0xff, 0xf8,0x22,0x11090005);//feed through
  202. cgsleep_us(100000);
  203. #endif
  204. reg_val = 0xffffffff/futurebit_max_chips;
  205. for (i=1; i<(futurebit_max_chips+1); i++)
  206. {
  207. futurebit_write_register(fd, i, 0x40, 0x00, reg_val*(i-1));
  208. cgsleep_us(100000);
  209. }
  210. futurebit_send_cmds(fd, gcp_cmd_reset);
  211. cgsleep_us(100000);
  212. }
  213. void futurebit_pull_up_payload(const int fd)
  214. {
  215. char i;
  216. unsigned int regval = 0;
  217. //pull up payload by steps.
  218. for (i=0; i<8; i++)
  219. {
  220. regval |= (0x0f<<(4*i));
  221. futurebit_write_register(fd, 0xff, 0xf8, 0x04, regval);
  222. cgsleep_us(35000);
  223. futurebit_write_register(fd, 0xff, 0xf8, 0x05, regval);
  224. cgsleep_us(35000);
  225. futurebit_write(fd, job2,144) ;
  226. cgsleep_us(35000);
  227. }
  228. }
  229. static
  230. bool futurebit_send_golden(const int fd, const struct futurebit_chip * const chip, const void * const data, const void * const target_p)
  231. {
  232. uint8_t buf[112];
  233. const uint8_t * const target = target_p;
  234. memcpy(buf, data, 80);
  235. if (target && !target[0x1f])
  236. memcpy(&buf[80], target, 0x20);
  237. else
  238. {
  239. memset(&buf[80], 0xff, 0x1f);
  240. buf[111] = 0;
  241. }
  242. //char output[(sizeof(buf) * 2) + 1];
  243. //bin2hex(output, buf, sizeof(buf));
  244. //applog(LOG_DEBUG, "GOLDEN OUTPUT %s", output);
  245. if (write(fd, buf, sizeof(buf)) != sizeof(buf))
  246. return false;
  247. return true;
  248. }
  249. static
  250. bool futurebit_send_work(const struct thr_info * const thr, struct work * const work)
  251. {
  252. struct cgpu_info *device = thr->cgpu;
  253. uint32_t *pdata = work->data;
  254. uint32_t *midstate = work->midstate;
  255. const uint32_t *ptarget = work->target;
  256. int i, bpos;
  257. unsigned char bin[156];
  258. // swab for big endian
  259. uint32_t midstate2[8];
  260. uint32_t data2[20];
  261. uint32_t target2[8];
  262. for(i = 0; i < 19; i++)
  263. {
  264. data2[i] = htole32(pdata[i]);
  265. if(i >= 8) continue;
  266. target2[i] = htole32(ptarget[i]);
  267. midstate2[i] = htole32(midstate[i]);
  268. }
  269. data2[19] = 0;
  270. memset(bin, 0, sizeof(bin));
  271. bpos = 0; memcpy(bin, "\x3c\xff\x40\x01", 4);
  272. // bpos += 4; memcpy(bin + bpos, "\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\x00\x00", 32); //target
  273. bpos += 4; memcpy(bin + bpos, (unsigned char *)target2, 32); memset(bin + bpos, 0, 24);
  274. bpos += 32; memcpy(bin + bpos, (unsigned char *)midstate2, 32); //midstateno
  275. bpos += 32; memcpy(bin + bpos, (unsigned char *)data2, 76); //blockheader 76 bytes (ignore last 4bytes nounce)
  276. bpos += 76;
  277. /* char szVal[] = "\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x80\xff\x7f\x00\x00\x00fb357fbeda2ee2a93b841afac3e58173d4a97a400a84a4ec27c47ef5e9322ca620000000b99512c06534b34f62d0a88a5f90ac1857f0c02a1b6e6bb3185aec323b0eb79d2983a6d34c0e59272444dc28b1041e6114939ca8cdbd99f4058ef4965e293ba7598b98cc1a25e34f"; // source string
  278. char szOutput[144];
  279. size_t nLen = strlen(szVal);
  280. // Make sure it is even.
  281. if ((nLen % 2) == 1)
  282. {
  283. printf("Error string must be even number of digits %s", szVal);
  284. }
  285. // Process each set of characters as a single character.
  286. nLen >>= 1;
  287. for (size_t idx = 0; idx < nLen; idx++)
  288. {
  289. char acTmp[3];
  290. sscanf(szVal + (idx << 1), "%2s", acTmp);
  291. szOutput[idx] = (char)strtol(acTmp, NULL, 16);
  292. }
  293. */
  294. futurebit_write(device->device_fd, bin, 144);//144bytes
  295. /* uint8_t buf[112];
  296. uint8_t cmd[112];
  297. const uint8_t * const target = work->target;
  298. unsigned char swpdata[80];
  299. //buf[0] = 0;
  300. //memset(&buf[1], 0xff, 0x1f);
  301. memset(&buf[0], 0, 0x18);
  302. memcpy(&buf[24], &target[24], 0x8);
  303. swap32tobe(swpdata, work->data, 80/4);
  304. memcpy(&buf[32], swpdata, 80);
  305. for (int i = 0; i<112; i++) {
  306. cmd[i] = buf[111 - i];
  307. }
  308. if (write(device->device_fd, cmd, sizeof(cmd)) != sizeof(cmd))
  309. return false;
  310. */
  311. work->blk.nonce = FUTUREBIT_MAX_NONCE;
  312. return true;
  313. }
  314. static
  315. bool futurebit_detect_one(const char * const devpath)
  316. {
  317. struct futurebit_chip *chips = NULL;
  318. unsigned total_cores = 0;
  319. uint32_t regval = 0;
  320. const int fd = serial_open(devpath, 115200, 1, true);
  321. if (fd < 0)
  322. return_via_applog(err, , LOG_DEBUG, "%s: %s %s", futurebit_drv.dname, "Failed to open", devpath);
  323. applog(LOG_DEBUG, "%s: %s %s", futurebit_drv.dname, "Successfully opened", devpath);
  324. futurebit_reset_board(fd);
  325. if(futurebit_read_register(fd, 0xff, 0xf8, 0xa6) != 0x3c)
  326. return_via_applog(err, , LOG_DEBUG, "%s: Failed to (%s) %s", futurebit_drv.dname, "find chip", devpath);
  327. // Init chips, setup PLL, and scan for good cores
  328. chips = malloc(futurebit_max_chips * sizeof(*chips));
  329. struct futurebit_chip * const dummy_chip = &chips[0];
  330. futurebit_chip_init(dummy_chip, 0);
  331. // pick up any user-defined settings passed in via --set
  332. drv_set_defaults(&futurebit_drv, futurebit_set_device_funcs_probe, dummy_chip, devpath, detectone_meta_info.serial, 1);
  333. unsigned freq = dummy_chip->freq;
  334. applog(LOG_DEBUG, "%s: %s %u mhz", futurebit_drv.dname, "Core clock set to", freq);
  335. struct futurebit_chip * const chip = &chips[0];
  336. futurebit_chip_init(chip, 0);
  337. chip->freq = freq;
  338. futurebit_config_all_chip(fd, freq);
  339. futurebit_pull_up_payload(fd);
  340. //chip->global_reg[1] = 0x05;
  341. //if (!futurebit_write_global_reg(fd, chip))
  342. // return_via_applog(err, , LOG_DEBUG, "%s: Failed to (%s) %s", futurebit_drv.dname, "global", devpath);
  343. //cgsleep_ms(50);
  344. /*futurebit_set_diag_mode(chip, true);
  345. if (!futurebit_init_pll(fd, chip))
  346. return_via_applog(err, , LOG_DEBUG, "%s: Failed to (%s) %s", futurebit_drv.dname, "init PLL", devpath);
  347. cgsleep_ms(50);
  348. if (!futurebit_send_golden(fd, chip, futurebit_g_head, NULL))
  349. return_via_applog(err, , LOG_DEBUG, "%s: Failed to (%s) %s", futurebit_drv.dname, "send scan job", devpath);
  350. while (serial_read(fd, buf, 8) == 8)
  351. {
  352. const uint8_t clsid = buf[7];
  353. if (clsid >= futurebit_max_clusters_per_chip)
  354. applog(LOG_DEBUG, "%s: Bad %s id (%u) during scan of %s chip %u", futurebit_drv.dname, "cluster", clsid, devpath, i);
  355. const uint8_t coreid = buf[6];
  356. if (coreid >= futurebit_max_cores_per_cluster)
  357. applog(LOG_DEBUG, "%s: Bad %s id (%u) during scan of %s chip %u", futurebit_drv.dname, "core", coreid, devpath, i);
  358. if (buf[0] != 0xd9 || buf[1] != 0xeb || buf[2] != 0x86 || buf[3] != 0x63) {
  359. //chips[i].chip_good[clsid][coreid] = false;
  360. applog(LOG_DEBUG, "%s: Bad %s at core (%u) during scan of %s chip %u cluster %u", futurebit_drv.dname, "nonce", coreid, devpath, i, clsid);
  361. } else {
  362. ++total_cores;
  363. chips[i].chip_mask[clsid] |= (1 << coreid);
  364. }
  365. }
  366. }
  367. }
  368. applog(LOG_DEBUG, "%s: Identified %d cores on %s", futurebit_drv.dname, total_cores, devpath);
  369. if (total_cores == 0)
  370. goto err;
  371. futurebit_reset_board(fd);
  372. // config nonce ranges per cluster based on core responses
  373. unsigned mutiple = FUTUREBIT_MAX_NONCE / total_cores;
  374. uint32_t n_offset = 0x00000000;
  375. for (unsigned i = 0; i < futurebit_max_chips; ++i)
  376. {
  377. struct futurebit_chip * const chip = &chips[i];
  378. chips[i].active_cores = total_cores;
  379. //chip->global_reg[1] = 0x04;
  380. //if (!futurebit_write_global_reg(fd, chip))
  381. //return_via_applog(err, , LOG_DEBUG, "%s: Failed to (%s) %s", futurebit_drv.dname, "global", devpath);
  382. //cgsleep_ms(50);
  383. futurebit_set_diag_mode(chip, false);
  384. if (!futurebit_init_pll(fd, chip))
  385. return_via_applog(err, , LOG_DEBUG, "%s: Failed to (%s) %s", futurebit_drv.dname, "init PLL", devpath);
  386. cgsleep_ms(50);
  387. for (unsigned x = 0; x < futurebit_max_clusters_per_chip; ++x) {
  388. unsigned gc = 0;
  389. uint16_t core_mask = chips[i].chip_mask[x];
  390. chips[i].clst_offset[x] = n_offset;
  391. applog(LOG_DEBUG, "OFFSET %u MASK %u CHIP %u CLUSTER %u", n_offset, core_mask, i, x);
  392. if (!futurebit_write_cluster_reg(fd, chip, core_mask, n_offset, x))
  393. return_via_applog(err, , LOG_DEBUG, "%s: Failed to (%s) %s", futurebit_drv.dname, "send config register", devpath);
  394. for (unsigned z = 0; z < 15; ++z) {
  395. if (core_mask & 0x0001)
  396. gc += 1;
  397. core_mask >>= 1;
  398. }
  399. n_offset += mutiple * gc;
  400. cgsleep_ms(50);
  401. }
  402. }
  403. */
  404. if (serial_claim_v(devpath, &futurebit_drv))
  405. goto err;
  406. //serial_close(fd);
  407. struct cgpu_info * const cgpu = malloc(sizeof(*cgpu));
  408. *cgpu = (struct cgpu_info){
  409. .drv = &futurebit_drv,
  410. .device_path = strdup(devpath),
  411. .deven = DEV_ENABLED,
  412. .procs = 1,
  413. .threads = 1,
  414. .device_data = chips,
  415. };
  416. // NOTE: Xcode's clang has a bug where it cannot find fields inside anonymous unions (more details in fpgautils)
  417. cgpu->device_fd = fd;
  418. return add_cgpu(cgpu);
  419. err:
  420. if (fd >= 0)
  421. serial_close(fd);
  422. free(chips);
  423. return false;
  424. }
  425. /*
  426. * scanhash mining loop
  427. */
  428. static
  429. void futurebit_submit_nonce(struct thr_info * const thr, const uint8_t buf[8], struct work * const work, struct timeval const start_tv)
  430. {
  431. struct cgpu_info *device = thr->cgpu;
  432. struct futurebit_chip *chips = device->device_data;
  433. uint32_t nonce;
  434. // swab for big endian
  435. memcpy((unsigned char *)&nonce, buf+4, 4);
  436. nonce = htole32(nonce);
  437. char output[(8 * 2) + 1];
  438. bin2hex(output, buf, 8);
  439. applog(LOG_DEBUG, "NONCE %s", output);
  440. submit_nonce(thr, work, nonce);
  441. /* hashrate calc
  442. const uint8_t clstid = buf[7];
  443. uint32_t range = chips[0].clst_offset[clstid];
  444. struct timeval now_tv;
  445. timer_set_now(&now_tv);
  446. int elapsed_ms = ms_tdiff(&now_tv, &start_tv);
  447. double total_hashes = ((nonce - range)/9.0) * chips[0].active_cores;
  448. double hashes_per_ms = total_hashes/elapsed_ms;
  449. uint64_t hashes = hashes_per_ms * ms_tdiff(&now_tv, &thr->_tv_last_hashes_done_call);
  450. if(hashes_per_ms < 1500 && hashes < 100000000)
  451. hashes_done2(thr, hashes, NULL);
  452. else
  453. hashes_done2(thr, 100000, NULL);
  454. */
  455. }
  456. // send work to the device
  457. static
  458. int64_t futurebit_scanhash(struct thr_info *thr, struct work *work, int64_t __maybe_unused max_nonce)
  459. {
  460. struct cgpu_info *device = thr->cgpu;
  461. int fd = device->device_fd;
  462. struct futurebit_chip *chips = device->device_data;
  463. struct timeval start_tv, nonce_range_tv;
  464. // amount of time it takes this device to scan a nonce range:
  465. uint32_t nonce_full_range_sec = FUTUREBIT_HASH_SPEED * 352.0 / FUTUREBIT_DEFAULT_FREQUENCY * 54.0 / chips[0].active_cores;
  466. // timer to break out of scanning should we close in on an entire nonce range
  467. // should break out before the range is scanned, so we are doing 95% of the range
  468. uint64_t nonce_near_range_usec = (nonce_full_range_sec * 1000000. * 0.95);
  469. timer_set_delay_from_now(&nonce_range_tv, nonce_near_range_usec);
  470. // start the job
  471. timer_set_now(&start_tv);
  472. if (!futurebit_send_work(thr, work)) {
  473. applog(LOG_DEBUG, "Failed to start job");
  474. dev_error(device, REASON_DEV_COMMS_ERROR);
  475. }
  476. unsigned char buf[12];
  477. int read = 0;
  478. bool range_nearly_scanned = false;
  479. while (!thr->work_restart // true when new work is available (miner.c)
  480. && ((read = serial_read(fd, buf, 8)) >= 0) // only check for failure - allow 0 bytes
  481. && !(range_nearly_scanned = timer_passed(&nonce_range_tv, NULL))) // true when we've nearly scanned a nonce range
  482. {
  483. if (read == 0)
  484. continue;
  485. if (read == 8) {
  486. futurebit_submit_nonce(thr, buf, work, start_tv);
  487. }
  488. else
  489. applog(LOG_ERR, "%"PRIpreprv": Unrecognized response", device->proc_repr);
  490. }
  491. if (read == -1)
  492. {
  493. applog(LOG_ERR, "%s: Failed to read result", device->dev_repr);
  494. dev_error(device, REASON_DEV_COMMS_ERROR);
  495. }
  496. return 0;
  497. }
  498. /*
  499. * setup & shutdown
  500. */
  501. static
  502. bool futurebit_lowl_probe(const struct lowlevel_device_info * const info)
  503. {
  504. return vcom_lowl_probe_wrapper(info, futurebit_detect_one);
  505. }
  506. static
  507. void futurebit_thread_shutdown(struct thr_info *thr)
  508. {
  509. struct cgpu_info *device = thr->cgpu;
  510. futurebit_reset_board(device->device_fd);
  511. serial_close(device->device_fd);
  512. }
  513. /*
  514. * specify settings / options via RPC or command line
  515. */
  516. // support for --set
  517. // must be set before probing the device
  518. // for setting clock and chips during probe / detect
  519. static
  520. const char *futurebit_set_clock(struct cgpu_info * const device, const char * const option, const char * const setting, char * const replybuf, enum bfg_set_device_replytype * const success)
  521. {
  522. struct futurebit_chip * const chip = device->device_data;
  523. int val = atoi(setting);
  524. if (val < FUTUREBIT_MIN_CLOCK || val > FUTUREBIT_MAX_CLOCK ) {
  525. sprintf(replybuf, "invalid clock: '%s' valid range %d-%d. Clock must be a mutiple of 8 between 104-200mhz, and a mutiple of 16 between 208-400mhz",
  526. setting, FUTUREBIT_MIN_CLOCK, FUTUREBIT_MAX_CLOCK);
  527. return replybuf;
  528. } else
  529. chip->freq = val;
  530. return NULL;
  531. }
  532. static
  533. const struct bfg_set_device_definition futurebit_set_device_funcs_probe[] = {
  534. { "clock", futurebit_set_clock, NULL },
  535. { NULL },
  536. };
  537. struct device_drv futurebit_drv = {
  538. .dname = "futurebit",
  539. .name = "MLD",
  540. .drv_min_nonce_diff = common_scrypt_min_nonce_diff,
  541. // detect device
  542. .lowl_probe = futurebit_lowl_probe,
  543. // specify mining type - scanhash
  544. .minerloop = minerloop_scanhash,
  545. // scanhash mining hooks
  546. .scanhash = futurebit_scanhash,
  547. // teardown device
  548. .thread_shutdown = futurebit_thread_shutdown,
  549. };