Commit 254d8b16e0a5ae09420b673a88bcf49dfd3b1608
2014-01-23T15:45:53
bab - cleanup old work for dead chips also
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70
diff --git a/driver-bab.c b/driver-bab.c
index 37e49eb..fb7f795 100644
--- a/driver-bab.c
+++ b/driver-bab.c
@@ -1730,12 +1730,14 @@ static bool bab_do_work(struct cgpu_info *babcgpu)
applog(LOG_DEBUG, "%s%i: Did get work reply ...",
babcgpu->drv->name, babcgpu->device_id);
- ritem = NULL;
for (chip = 0; chip < babinfo->chips; chip++) {
-/* TODO: For now just test it anyway
- if (!babinfo->chip_conf[chip])
- goto nexti;
-*/
+ K_WLOCK(babinfo->rfree_list);
+ ritem = k_unlink_head(babinfo->rfree_list);
+ K_WUNLOCK(babinfo->rfree_list);
+
+ DATAR(ritem)->chip = chip;
+ DATAR(ritem)->not_first_reply = babinfo->not_first_reply[chip];
+ memcpy(&(DATAR(ritem)->when), &when, sizeof(when));
nonces = 0;
for (rep = 0; rep < BAB_REPLY_NONCES; rep++) {
@@ -1743,34 +1745,24 @@ static bool bab_do_work(struct cgpu_info *babcgpu)
if (nonce != babinfo->chip_prev[chip].nonce[rep]) {
if ((nonce & BAB_EVIL_MASK) == BAB_EVIL_NONCE)
babinfo->discarded_e0s++;
- else {
- if (ritem == NULL) {
- K_WLOCK(babinfo->rfree_list);
- ritem = k_unlink_head(babinfo->rfree_list);
- K_WUNLOCK(babinfo->rfree_list);
-
- DATAR(ritem)->chip = chip;
- DATAR(ritem)->not_first_reply = babinfo->not_first_reply[chip];
- memcpy(&(DATAR(ritem)->when), &when, sizeof(when));
- }
+ else
DATAR(ritem)->nonce[nonces++] = nonce;
- }
}
}
- if (ritem) {
- DATAR(ritem)->nonces = nonces;
- K_WLOCK(babinfo->res_list);
- k_add_head(babinfo->res_list, ritem);
- K_WUNLOCK(babinfo->res_list);
- ritem = NULL;
+ /*
+ * Send even with zero nonces
+ * so cleanup_older() is called for the chip
+ */
+ DATAR(ritem)->nonces = nonces;
+ K_WLOCK(babinfo->res_list);
+ k_add_head(babinfo->res_list, ritem);
+ K_WUNLOCK(babinfo->res_list);
- cgsem_post(&(babinfo->process_reply));
+ cgsem_post(&(babinfo->process_reply));
- babinfo->not_first_reply[chip] = true;
- }
+ babinfo->not_first_reply[chip] = true;
-//nexti:
memcpy((void *)(&(babinfo->chip_prev[chip])),
(void *)(&(babinfo->chip_results[chip])),
sizeof(struct bab_work_reply));