Hash :
4b55ab7e
Author :
Date :
2014-05-20T15:46:57
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 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86
/*
* Copyright 2014 Andrew Smith
*
* 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 "miner.h"
#include "klist.h"
// Nonce
typedef struct nitem {
uint32_t work_id;
uint32_t nonce;
struct timeval when;
} NITEM;
#define DATAN(_item) ((NITEM *)(_item->data))
struct dupdata {
int timelimit;
K_LIST *nfree_list;
K_STORE *nonce_list;
uint64_t checked;
uint64_t dup;
};
void dupalloc(struct cgpu_info *cgpu, int timelimit)
{
struct dupdata *dup;
dup = calloc(1, sizeof(*dup));
if (unlikely(!dup))
quithere(1, "Failed to calloc dupdata");
dup->timelimit = timelimit;
dup->nfree_list = k_new_list("Nonces", sizeof(NITEM), 1024, 0, true);
dup->nonce_list = k_new_store(dup->nfree_list);
cgpu->dup_data = dup;
}
bool isdupnonce(struct cgpu_info *cgpu, struct work *work, uint32_t nonce)
{
struct dupdata *dup = (struct dupdata *)(cgpu->dup_data);
struct timeval now;
bool unique = true;
K_ITEM *item;
if (!dup)
return false;
cgtime(&now);
dup->checked++;
K_WLOCK(dup->nfree_list);
item = dup->nonce_list->tail;
while (unique && item) {
if (DATAN(item)->work_id == work->id && DATAN(item)->nonce == nonce) {
unique = false;
applog(LOG_WARNING, "%s%d: Duplicate nonce %08x",
cgpu->drv->name, cgpu->device_id, nonce);
} else
item = item->prev;
}
if (unique) {
item = k_unlink_head(dup->nfree_list);
DATAN(item)->work_id = work->id;
DATAN(item)->nonce = nonce;
memcpy(&(DATAN(item)->when), &now, sizeof(now));
k_add_head(dup->nonce_list, item);
}
item = dup->nonce_list->tail;
while (item && tdiff(&(DATAN(item)->when), &now) > dup->timelimit) {
item = k_unlink_tail(dup->nonce_list);
k_add_head(dup->nfree_list, item);
item = dup->nonce_list->tail;
}
K_WUNLOCK(dup->nfree_list);
if (!unique)
dup->dup++;
return !unique;
}