driver-titan.c 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692
  1. /*
  2. * Copyright 2014 Vitalii Demianets
  3. * Copyright 2014 KnCMiner
  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 <fcntl.h>
  11. #include <sys/ioctl.h>
  12. #include "deviceapi.h"
  13. #include "logging.h"
  14. #include "miner.h"
  15. #include "util.h"
  16. #include "titan-asic.h"
  17. #define KNC_TITAN_DEFAULT_FREQUENCY 275
  18. #define KNC_TITAN_HWERR_DISABLE_SECS 10
  19. #define KNC_POLL_INTERVAL_US 10000
  20. /* Work queue pre-fill level.
  21. * Must be high enough to supply all ASICs with works after a flush */
  22. #define WORK_QUEUE_PREFILL 10
  23. /* Specify here minimum number of leading zeroes in hash */
  24. #define DEFAULT_DIFF_FILTERING_ZEROES 24
  25. #define DEFAULT_DIFF_FILTERING_FLOAT (1. / ((double)(0x00000000FFFFFFFF >> DEFAULT_DIFF_FILTERING_ZEROES)))
  26. #define DEFAULT_DIFF_HASHES_PER_NONCE (1 << DEFAULT_DIFF_FILTERING_ZEROES)
  27. BFG_REGISTER_DRIVER(knc_titan_drv)
  28. /* 3 - default number of threads per core */
  29. static int opt_knc_threads_per_core = 3;
  30. static const struct bfg_set_device_definition knc_titan_set_device_funcs[];
  31. struct knc_titan_core {
  32. int asicno;
  33. int dieno; /* inside asic */
  34. int coreno; /* inside die */
  35. struct knc_titan_die *die;
  36. struct cgpu_info *proc;
  37. int hwerr_in_row;
  38. int hwerr_disable_time;
  39. struct timeval enable_at;
  40. struct timeval first_hwerr;
  41. struct nonce_report last_nonce;
  42. };
  43. struct knc_titan_die {
  44. int asicno;
  45. int dieno; /* inside asic */
  46. int cores;
  47. struct cgpu_info *first_proc;
  48. int freq;
  49. };
  50. struct knc_titan_info {
  51. void *ctx;
  52. struct cgpu_info *cgpu;
  53. int cores;
  54. struct knc_titan_die dies[KNC_TITAN_MAX_ASICS][KNC_TITAN_DIES_PER_ASIC];
  55. /* Per-ASIC data */
  56. bool need_flush[KNC_TITAN_MAX_ASICS];
  57. int next_slot[KNC_TITAN_MAX_ASICS];
  58. /* First slot after flush. If next_slot reaches this, then
  59. * we need to re-flush all the cores to avoid duplicating slot numbers
  60. * for different works */
  61. int first_slot[KNC_TITAN_MAX_ASICS];
  62. struct work *workqueue;
  63. int workqueue_size;
  64. int workqueue_max;
  65. int next_id;
  66. struct work *devicework;
  67. };
  68. static bool knc_titan_detect_one(const char *devpath)
  69. {
  70. static struct cgpu_info *prev_cgpu = NULL;
  71. struct cgpu_info *cgpu;
  72. void *ctx;
  73. struct knc_titan_info *knc;
  74. int cores = 0, asic, die;
  75. struct knc_die_info die_info;
  76. char repr[6];
  77. cgpu = malloc(sizeof(*cgpu));
  78. if (unlikely(!cgpu))
  79. quit(1, "Failed to alloc cgpu_info");
  80. if (!prev_cgpu) {
  81. if (NULL == (ctx = knc_trnsp_new(NULL))) {
  82. free(cgpu);
  83. return false;
  84. }
  85. knc = calloc(1, sizeof(*knc));
  86. if (unlikely(!knc))
  87. quit(1, "Failed to alloc knc_titan_info");
  88. knc->ctx = ctx;
  89. knc->cgpu = cgpu;
  90. knc->workqueue_max = WORK_QUEUE_PREFILL;
  91. } else {
  92. knc = prev_cgpu->device_data;
  93. ctx = knc->ctx;
  94. }
  95. snprintf(repr, sizeof(repr), "%s %s", knc_titan_drv.name, devpath);
  96. asic = atoi(devpath);
  97. for (die = 0; die < KNC_TITAN_DIES_PER_ASIC; ++die) {
  98. die_info.cores = KNC_TITAN_CORES_PER_DIE; /* core hint */
  99. die_info.version = KNC_VERSION_TITAN;
  100. if (!knc_titan_get_info(repr, ctx, asic, die, &die_info))
  101. die_info.cores = -1;
  102. if (0 < die_info.cores) {
  103. knc->dies[asic][die] = (struct knc_titan_die) {
  104. .asicno = asic,
  105. .dieno = die,
  106. .cores = die_info.cores,
  107. .first_proc = cgpu,
  108. .freq = KNC_TITAN_DEFAULT_FREQUENCY,
  109. };
  110. cores += die_info.cores;
  111. } else {
  112. knc->dies[asic][die] = (struct knc_titan_die) {
  113. .asicno = -INT_MAX,
  114. .dieno = -INT_MAX,
  115. .cores = 0,
  116. .first_proc = NULL,
  117. };
  118. }
  119. }
  120. if (0 == cores) {
  121. free(cgpu);
  122. if (!prev_cgpu) {
  123. free(knc);
  124. knc_trnsp_free(ctx);
  125. }
  126. return false;
  127. }
  128. applog(LOG_NOTICE, "%s: Found ASIC with %d cores", repr, cores);
  129. *cgpu = (struct cgpu_info) {
  130. .drv = &knc_titan_drv,
  131. .device_path = strdup(devpath),
  132. .set_device_funcs = knc_titan_set_device_funcs,
  133. .deven = DEV_ENABLED,
  134. .procs = cores,
  135. .threads = prev_cgpu ? 0 : 1,
  136. .extra_work_queue = -1,
  137. .device_data = knc,
  138. };
  139. const bool rv = add_cgpu_slave(cgpu, prev_cgpu);
  140. if (!prev_cgpu)
  141. cgpu->extra_work_queue += WORK_QUEUE_PREFILL;
  142. prev_cgpu = cgpu;
  143. return rv;
  144. }
  145. static int knc_titan_detect_auto(void)
  146. {
  147. const int first = 0, last = KNC_TITAN_MAX_ASICS - 1;
  148. char devpath[256];
  149. int found = 0, i;
  150. for (i = first; i <= last; ++i) {
  151. sprintf(devpath, "%d", i);
  152. if (knc_titan_detect_one(devpath))
  153. ++found;
  154. }
  155. return found;
  156. }
  157. static void knc_titan_detect(void)
  158. {
  159. generic_detect(&knc_titan_drv, knc_titan_detect_one, knc_titan_detect_auto, GDF_REQUIRE_DNAME | GDF_DEFAULT_NOAUTO);
  160. }
  161. static void knc_titan_clean_flush(const char *repr, void * const ctx, int asic, int die)
  162. {
  163. struct knc_report report;
  164. bool unused;
  165. knc_titan_set_work(repr, ctx, asic, die, 0xFFFF, 0, NULL, true, &unused, &report);
  166. }
  167. static uint32_t nonce_tops[KNC_TITAN_DIES_PER_ASIC][KNC_TITAN_CORES_PER_DIE];
  168. static bool nonce_tops_inited = false;
  169. static void get_nonce_range(int dieno, int coreno, uint32_t *nonce_bottom, uint32_t *nonce_top)
  170. {
  171. if (!nonce_tops_inited) {
  172. uint32_t top;
  173. double nonce_f, nonce_step;
  174. int die, core;
  175. nonce_f = 0.0;
  176. nonce_step = 4294967296.0 / KNC_TITAN_CORES_PER_ASIC;
  177. for (die = 0; die < KNC_TITAN_DIES_PER_ASIC; ++die) {
  178. for (core = 0; core < KNC_TITAN_CORES_PER_DIE; ++core) {
  179. nonce_f += nonce_step;
  180. if ((core < (KNC_TITAN_CORES_PER_DIE - 1)) || (die < (KNC_TITAN_DIES_PER_ASIC - 1)))
  181. top = nonce_f;
  182. else
  183. top = 0xFFFFFFFF;
  184. nonce_tops[die][core] = top;
  185. }
  186. }
  187. nonce_tops_inited = true;
  188. }
  189. *nonce_top = nonce_tops[dieno][coreno];
  190. if (coreno > 0) {
  191. *nonce_bottom = nonce_tops[dieno][coreno - 1] + 1;
  192. return;
  193. }
  194. if (dieno > 0) {
  195. *nonce_bottom = nonce_tops[dieno - 1][KNC_TITAN_CORES_PER_DIE - 1] + 1;
  196. }
  197. *nonce_bottom = 0;
  198. }
  199. static bool knc_titan_init(struct thr_info * const thr)
  200. {
  201. const int max_cores = KNC_TITAN_CORES_PER_ASIC;
  202. struct thr_info *mythr;
  203. struct cgpu_info * const cgpu = thr->cgpu, *proc;
  204. struct knc_titan_core *knccore;
  205. struct knc_titan_info *knc;
  206. int i, asic, die, core_base;
  207. int total_cores = 0;
  208. int asic_cores[KNC_TITAN_MAX_ASICS] = {0};
  209. for (proc = cgpu; proc; ) {
  210. proc->min_nonce_diff = DEFAULT_DIFF_FILTERING_FLOAT;
  211. if (proc->device != proc) {
  212. applog(LOG_WARNING, "%"PRIpreprv": Extra processor?", proc->proc_repr);
  213. proc = proc->next_proc;
  214. continue;
  215. }
  216. asic = atoi(proc->device_path);
  217. knc = proc->device_data;
  218. die = 0;
  219. core_base = 0;
  220. for (i = 0; i < max_cores; ++i) {
  221. while (i >= (core_base + knc->dies[asic][die].cores)) {
  222. core_base += knc->dies[asic][die].cores;
  223. if (++die >= KNC_TITAN_DIES_PER_ASIC)
  224. break;
  225. }
  226. if (die >= KNC_TITAN_DIES_PER_ASIC)
  227. break;
  228. mythr = proc->thr[0];
  229. mythr->cgpu_data = knccore = malloc(sizeof(*knccore));
  230. if (unlikely(!knccore))
  231. quit(1, "Failed to alloc knc_titan_core");
  232. *knccore = (struct knc_titan_core) {
  233. .asicno = asic,
  234. .dieno = die,
  235. .coreno = i - core_base,
  236. .die = &(knc->dies[asic][die]),
  237. .proc = proc,
  238. .hwerr_in_row = 0,
  239. .hwerr_disable_time = KNC_TITAN_HWERR_DISABLE_SECS,
  240. };
  241. timer_set_now(&knccore->enable_at);
  242. proc->device_data = knc;
  243. ++total_cores;
  244. ++(asic_cores[asic]);
  245. applog(LOG_DEBUG, "%s Allocated core %d:%d:%d", proc->device->dev_repr, asic, die, (i - core_base));
  246. if (0 == knccore->coreno) {
  247. knc->dies[asic][die].first_proc = proc;
  248. knc_titan_clean_flush(proc->device->dev_repr, knc->ctx, knccore->asicno, knccore->dieno);
  249. }
  250. proc = proc->next_proc;
  251. if ((!proc) || proc->device == proc)
  252. break;
  253. }
  254. knc->cores = total_cores;
  255. }
  256. cgpu_set_defaults(cgpu);
  257. if (0 >= total_cores)
  258. return false;
  259. /* Init nonce ranges for cores */
  260. struct titan_setup_core_params setup_params = {
  261. .bad_address_mask = {0, 0},
  262. .bad_address_match = {0x3FF, 0x3FF},
  263. .difficulty = DEFAULT_DIFF_FILTERING_ZEROES - 1,
  264. .thread_enable = 0xFF,
  265. .thread_base_address = {0, 1, 2, 3, 4, 5, 6, 7},
  266. .lookup_gap_mask = {0x7, 0x7, 0x7, 0x7, 0x7, 0x7, 0x7, 0x7},
  267. .N_mask = {0, 0, 0, 0, 0, 0, 0, 0},
  268. .N_shift = {0, 0, 0, 0, 0, 0, 0, 0},
  269. .nonce_bottom = 0,
  270. .nonce_top = 0xFFFFFFFF,
  271. };
  272. fill_in_thread_params(opt_knc_threads_per_core, &setup_params);
  273. for (proc = cgpu; proc; proc = proc->next_proc) {
  274. knc = proc->device_data;
  275. mythr = proc->thr[0];
  276. knccore = mythr->cgpu_data;
  277. get_nonce_range(knccore->dieno, knccore->coreno, &setup_params.nonce_bottom, &setup_params.nonce_top);
  278. applog(LOG_DEBUG, "%s Setup core %d:%d:%d, nonces 0x%08X - 0x%08X", proc->device->dev_repr, knccore->asicno, knccore->dieno, knccore->coreno, setup_params.nonce_bottom, setup_params.nonce_top);
  279. knc_titan_setup_core_local(proc->device->dev_repr, knc->ctx, knccore->asicno, knccore->dieno, knccore->coreno, &setup_params);
  280. }
  281. for (asic = 0; asic < KNC_TITAN_MAX_ASICS; ++asic) {
  282. knc->next_slot[asic] = KNC_TITAN_MIN_WORK_SLOT_NUM;
  283. knc->first_slot[asic] = KNC_TITAN_MIN_WORK_SLOT_NUM;
  284. knc->need_flush[asic] = true;
  285. }
  286. timer_set_now(&thr->tv_poll);
  287. return true;
  288. }
  289. static bool die_enable(struct knc_titan_info * const knc, int asic, int die, char * const errbuf)
  290. {
  291. sprintf(errbuf, "die_enable[%d:%d] not imnplemented", asic, die);
  292. return false;
  293. }
  294. static bool die_disable(struct knc_titan_info * const knc, int asic, int die, char * const errbuf)
  295. {
  296. sprintf(errbuf, "die_disable[%d:%d] not imnplemented", asic, die);
  297. return false;
  298. }
  299. static bool die_reconfigure(struct knc_titan_info * const knc, int asic, int die, char * const errbuf)
  300. {
  301. sprintf(errbuf, "die_reconfigure[%d:%d] not imnplemented", asic, die);
  302. return false;
  303. }
  304. static bool knc_titan_prepare_work(struct thr_info *thr, struct work *work)
  305. {
  306. struct cgpu_info * const cgpu = thr->cgpu;
  307. work->nonce_diff = cgpu->min_nonce_diff;
  308. return true;
  309. }
  310. static void knc_titan_set_queue_full(struct knc_titan_info * const knc)
  311. {
  312. const bool full = (knc->workqueue_size >= knc->workqueue_max);
  313. struct cgpu_info *proc;
  314. for (proc = knc->cgpu; proc; proc = proc->next_proc) {
  315. struct thr_info * const thr = proc->thr[0];
  316. thr->queue_full = full;
  317. }
  318. }
  319. static void knc_titan_remove_local_queue(struct knc_titan_info * const knc, struct work * const work)
  320. {
  321. DL_DELETE(knc->workqueue, work);
  322. free_work(work);
  323. --knc->workqueue_size;
  324. }
  325. static void knc_titan_prune_local_queue(struct thr_info *thr)
  326. {
  327. struct cgpu_info * const cgpu = thr->cgpu;
  328. struct knc_titan_info * const knc = cgpu->device_data;
  329. struct work *work, *tmp;
  330. DL_FOREACH_SAFE(knc->workqueue, work, tmp) {
  331. if (stale_work(work, false))
  332. knc_titan_remove_local_queue(knc, work);
  333. }
  334. knc_titan_set_queue_full(knc);
  335. }
  336. static bool knc_titan_queue_append(struct thr_info * const thr, struct work * const work)
  337. {
  338. struct cgpu_info * const cgpu = thr->cgpu;
  339. struct knc_titan_info * const knc = cgpu->device_data;
  340. if (knc->workqueue_size >= knc->workqueue_max) {
  341. knc_titan_prune_local_queue(thr);
  342. if (thr->queue_full)
  343. return false;
  344. }
  345. DL_APPEND(knc->workqueue, work);
  346. ++knc->workqueue_size;
  347. knc_titan_set_queue_full(knc);
  348. if (thr->queue_full)
  349. knc_titan_prune_local_queue(thr);
  350. return true;
  351. }
  352. #define HASH_LAST_ADDED(head, out) \
  353. (out = (head) ? (ELMT_FROM_HH((head)->hh.tbl, (head)->hh.tbl->tail)) : NULL)
  354. static void knc_titan_queue_flush(struct thr_info * const thr)
  355. {
  356. struct cgpu_info * const cgpu = thr->cgpu;
  357. struct knc_titan_info * const knc = cgpu->device_data;
  358. struct work *work, *tmp;
  359. if (knc->cgpu != cgpu)
  360. return;
  361. DL_FOREACH_SAFE(knc->workqueue, work, tmp){
  362. knc_titan_remove_local_queue(knc, work);
  363. }
  364. knc_titan_set_queue_full(knc);
  365. HASH_LAST_ADDED(knc->devicework, work);
  366. if (work && stale_work(work, true)) {
  367. int asic;
  368. for (asic = 0; asic < KNC_TITAN_MAX_ASICS; ++asic)
  369. knc->need_flush[asic] = true;
  370. timer_set_now(&thr->tv_poll);
  371. }
  372. }
  373. static void knc_titan_poll(struct thr_info * const thr)
  374. {
  375. struct thr_info *mythr;
  376. struct cgpu_info * const cgpu = thr->cgpu, *proc;
  377. struct knc_titan_info * const knc = cgpu->device_data;
  378. struct knc_titan_core *knccore, *core1;
  379. struct work *work, *tmp;
  380. int workaccept = 0;
  381. unsigned long delay_usecs = KNC_POLL_INTERVAL_US;
  382. struct knc_report report;
  383. struct knc_die_info die_info;
  384. int asic;
  385. int die;
  386. int i, tmp_int;
  387. knc_titan_prune_local_queue(thr);
  388. for (asic = 0; asic < KNC_TITAN_MAX_ASICS; ++asic) {
  389. DL_FOREACH_SAFE(knc->workqueue, work, tmp) {
  390. bool work_accepted = false;
  391. bool need_replace;
  392. if (knc->first_slot[asic] > KNC_TITAN_MIN_WORK_SLOT_NUM)
  393. need_replace = ((knc->next_slot[asic] + 1) == knc->first_slot[asic]);
  394. else
  395. need_replace = (knc->next_slot[asic] == KNC_TITAN_MAX_WORK_SLOT_NUM);
  396. knccore = NULL;
  397. for (die = 0; die < KNC_TITAN_DIES_PER_ASIC; ++die) {
  398. if (0 >= knc->dies[asic][die].cores)
  399. continue;
  400. struct cgpu_info *first_proc = knc->dies[asic][die].first_proc;
  401. /* knccore is the core data of the first core in this asic */
  402. if (NULL == knccore)
  403. knccore = first_proc->thr[0]->cgpu_data;
  404. bool die_work_accepted = false;
  405. if (knc->need_flush[asic] || need_replace) {
  406. for (proc = first_proc; proc; proc = proc->next_proc) {
  407. mythr = proc->thr[0];
  408. core1 = mythr->cgpu_data;
  409. bool unused;
  410. if ((core1->dieno != die) || (core1->asicno != asic))
  411. break;
  412. if (knc_titan_set_work(proc->proc_repr, knc->ctx, asic, die, core1->coreno, knc->next_slot[asic], work, true, &unused, &report)) {
  413. core1->last_nonce.slot = report.nonce[0].slot;
  414. core1->last_nonce.nonce = report.nonce[0].nonce;
  415. die_work_accepted = true;
  416. }
  417. }
  418. } else {
  419. if (!knc_titan_set_work(first_proc->dev_repr, knc->ctx, asic, die, 0xFFFF, knc->next_slot[asic], work, false, &die_work_accepted, &report))
  420. die_work_accepted = false;
  421. }
  422. if (die_work_accepted)
  423. work_accepted = true;
  424. }
  425. if ((!work_accepted) || (NULL == knccore))
  426. break;
  427. bool was_flushed = false;
  428. if (knc->need_flush[asic] || need_replace) {
  429. struct work *work1, *tmp1;
  430. applog(LOG_NOTICE, "%s: Flushing stale works (%s)", knccore->proc->dev_repr,
  431. knc->need_flush[asic] ? "New work" : "Slot collision");
  432. knc->need_flush[asic] = false;
  433. knc->first_slot[asic] = knc->next_slot[asic];
  434. HASH_ITER(hh, knc->devicework, work1, tmp1) {
  435. if (asic == ((work1->device_id >> 8) & 0xFF)) {
  436. HASH_DEL(knc->devicework, work1);
  437. free_work(work1);
  438. }
  439. }
  440. delay_usecs = 0;
  441. was_flushed = true;
  442. }
  443. --knc->workqueue_size;
  444. DL_DELETE(knc->workqueue, work);
  445. work->device_id = (asic << 8) | knc->next_slot[asic];
  446. HASH_ADD(hh, knc->devicework, device_id, sizeof(work->device_id), work);
  447. if (++(knc->next_slot[asic]) > KNC_TITAN_MAX_WORK_SLOT_NUM)
  448. knc->next_slot[asic] = KNC_TITAN_MIN_WORK_SLOT_NUM;
  449. ++workaccept;
  450. /* If we know for sure that this work was urgent, then we don't need to hurry up
  451. * with filling next slot, we have plenty of time until current work completes.
  452. * So, better to proceed with other ASICs. */
  453. if (was_flushed)
  454. break;
  455. }
  456. }
  457. applog(LOG_DEBUG, "%s: %d jobs accepted to queue (max=%d)", knc_titan_drv.dname, workaccept, knc->workqueue_max);
  458. for (asic = 0; asic < KNC_TITAN_MAX_ASICS; ++asic) {
  459. for (die = 0; die < KNC_TITAN_DIES_PER_ASIC; ++die) {
  460. if (0 >= knc->dies[asic][die].cores)
  461. continue;
  462. die_info.cores = knc->dies[asic][die].cores; /* core hint */
  463. die_info.version = KNC_VERSION_TITAN;
  464. if (!knc_titan_get_info(cgpu->dev_repr, knc->ctx, asic, die, &die_info))
  465. continue;
  466. for (proc = knc->dies[asic][die].first_proc; proc; proc = proc->next_proc) {
  467. mythr = proc->thr[0];
  468. knccore = mythr->cgpu_data;
  469. if ((knccore->dieno != die) || (knccore->asicno != asic))
  470. break;
  471. if (!die_info.has_report[knccore->coreno])
  472. continue;
  473. if (!knc_titan_get_report(proc->proc_repr, knc->ctx, asic, die, knccore->coreno, &report))
  474. continue;
  475. for (i = 0; i < KNC_TITAN_NONCES_PER_REPORT; ++i) {
  476. if ((report.nonce[i].slot == knccore->last_nonce.slot) &&
  477. (report.nonce[i].nonce == knccore->last_nonce.nonce))
  478. break;
  479. tmp_int = (asic << 8) | report.nonce[i].slot;
  480. HASH_FIND_INT(knc->devicework, &tmp_int, work);
  481. if (!work) {
  482. applog(LOG_WARNING, "%"PRIpreprv": Got nonce for unknown work in slot %u (asic %d)", proc->proc_repr, (unsigned)report.nonce[i].slot, asic);
  483. continue;
  484. }
  485. if (submit_nonce(mythr, work, report.nonce[i].nonce)) {
  486. hashes_done2(mythr, DEFAULT_DIFF_HASHES_PER_NONCE, NULL);
  487. knccore->hwerr_in_row = 0;
  488. }
  489. }
  490. knccore->last_nonce.slot = report.nonce[0].slot;
  491. knccore->last_nonce.nonce = report.nonce[0].nonce;
  492. }
  493. }
  494. }
  495. if (workaccept) {
  496. if (workaccept >= knc->workqueue_max) {
  497. knc->workqueue_max = workaccept;
  498. delay_usecs = 0;
  499. }
  500. knc_titan_set_queue_full(knc);
  501. }
  502. timer_set_delay_from_now(&thr->tv_poll, delay_usecs);
  503. }
  504. /*
  505. * specify settings / options via RPC or command line
  506. */
  507. /* support for --set-device
  508. * must be set before probing the device
  509. */
  510. static void knc_titan_set_clock_freq(struct cgpu_info * const device, int const val)
  511. {
  512. }
  513. static const char *knc_titan_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)
  514. {
  515. knc_titan_set_clock_freq(device, atoi(setting));
  516. return NULL;
  517. }
  518. static const char *knc_titan_die_ena(struct cgpu_info * const device, const char * const option, const char * const setting, char * const replybuf, enum bfg_set_device_replytype * const success)
  519. {
  520. int asic, die;
  521. char str[256];
  522. /* command format: ASIC:N;DIE:N;MODE:ENABLE|DISABLE|RECONFIGURE */
  523. if (3 != sscanf(setting, "ASIC:%d;DIE:%d;MODE:%255s", &asic, &die, str)) {
  524. error_bad_params:
  525. sprintf(replybuf, "Die setup failed, bad parameters");
  526. return replybuf;
  527. }
  528. if (0 == strncasecmp(str, "enable", sizeof(str) - 1)) {
  529. if (!die_enable(device->device_data, asic, die, replybuf))
  530. return replybuf;
  531. } else if (0 == strncasecmp(str, "disable", sizeof(str) - 1)) {
  532. if (!die_disable(device->device_data, asic, die, replybuf))
  533. return replybuf;
  534. } else if (0 == strncasecmp(str, "reconfigure", sizeof(str) - 1)) {
  535. if (!die_reconfigure(device->device_data, asic, die, replybuf))
  536. return replybuf;
  537. } else
  538. goto error_bad_params;
  539. sprintf(replybuf, "Die setup Ok; asic %d die %d cmd %s", asic, die, str);
  540. *success = SDR_OK;
  541. return replybuf;
  542. }
  543. static const struct bfg_set_device_definition knc_titan_set_device_funcs[] = {
  544. { "clock", knc_titan_set_clock, NULL },
  545. { "die", knc_titan_die_ena, NULL },
  546. { NULL },
  547. };
  548. /*
  549. * specify settings / options via TUI
  550. */
  551. #ifdef HAVE_CURSES
  552. static void knc_titan_tui_wlogprint_choices(struct cgpu_info * const proc)
  553. {
  554. wlogprint("[C]lock speed ");
  555. }
  556. static const char *knc_titan_tui_handle_choice(struct cgpu_info * const proc, const int input)
  557. {
  558. static char buf[0x100]; /* Static for replies */
  559. switch (input)
  560. {
  561. case 'c': case 'C':
  562. {
  563. sprintf(buf, "Set clock speed");
  564. char * const setting = curses_input(buf);
  565. knc_titan_set_clock_freq(proc->device, atoi(setting));
  566. return "Clock speed changed\n";
  567. }
  568. }
  569. return NULL;
  570. }
  571. static void knc_titan_wlogprint_status(struct cgpu_info * const proc)
  572. {
  573. wlogprint("Clock speed: N/A\n");
  574. }
  575. #endif
  576. struct device_drv knc_titan_drv =
  577. {
  578. /* metadata */
  579. .dname = "titan",
  580. .name = "KNC",
  581. .supported_algos = POW_SCRYPT,
  582. .drv_detect = knc_titan_detect,
  583. .thread_init = knc_titan_init,
  584. /* specify mining type - queue */
  585. .minerloop = minerloop_queue,
  586. .queue_append = knc_titan_queue_append,
  587. .queue_flush = knc_titan_queue_flush,
  588. .poll = knc_titan_poll,
  589. .prepare_work = knc_titan_prepare_work,
  590. /* TUI support - e.g. setting clock via UI */
  591. #ifdef HAVE_CURSES
  592. .proc_wlogprint_status = knc_titan_wlogprint_status,
  593. .proc_tui_wlogprint_choices = knc_titan_tui_wlogprint_choices,
  594. .proc_tui_handle_choice = knc_titan_tui_handle_choice,
  595. #endif
  596. };