Browse Source

Add a --benchmark feature which works on a fake item indefinitely to compare device performance without any server or networking influence.

nfactor-troky
ckolivas 13 years ago
parent
commit
0db998c5d0
  1. 49
      cgminer.c

49
cgminer.c

@ -44,6 +44,7 @@ @@ -44,6 +44,7 @@
#include "adl.h"
#include "device-cpu.h"
#include "device-gpu.h"
#include "bench_block.h"
#if defined(unix)
#include <errno.h>
@ -78,6 +79,7 @@ static char packagename[255]; @@ -78,6 +79,7 @@ static char packagename[255];
int gpu_threads;
bool opt_protocol = false;
static bool opt_benchmark;
static bool want_longpoll = true;
static bool have_longpoll = false;
static bool want_per_device_stats = false;
@ -638,6 +640,9 @@ static struct opt_table opt_config_table[] = { @@ -638,6 +640,9 @@ static struct opt_table opt_config_table[] = {
opt_set_bool, &opt_autoengine,
"Automatically adjust all GPU engine clock speeds to maintain a target temperature"),
#endif
OPT_WITHOUT_ARG("--benchmark",
opt_set_bool, &opt_benchmark,
"Run cgminer in benchmark mode - produces no shares"),
#ifdef WANT_CPUMINE
OPT_WITH_ARG("--bench-algo|-b",
set_int_0_to_9999, opt_show_intval, &opt_bench_algo,
@ -1568,6 +1573,18 @@ static inline struct pool *select_pool(bool lagging) @@ -1568,6 +1573,18 @@ static inline struct pool *select_pool(bool lagging)
return pool;
}
static void get_benchmark_work(struct work *work)
{
// Use a random work block pulled from a pool
static uint8_t bench_block[] = { CGMINER_BENCHMARK_BLOCK };
size_t bench_size = sizeof(work);
size_t work_size = sizeof(bench_block);
size_t min_size = (work_size < bench_size ? work_size : bench_size);
memset(work, 0, sizeof(work));
memcpy(work, &bench_block, min_size);
}
static bool get_upstream_work(struct work *work, bool lagging)
{
bool rc = false, req_longpoll = false;
@ -1813,6 +1830,9 @@ static bool stale_work(struct work *work, bool share) @@ -1813,6 +1830,9 @@ static bool stale_work(struct work *work, bool share)
{
struct timeval now;
if (opt_benchmark)
return false;
gettimeofday(&now, NULL);
if (share) {
if ((now.tv_sec - work->tv_staged.tv_sec) >= opt_expiry)
@ -2105,6 +2125,9 @@ static void test_work_current(struct work *work) @@ -2105,6 +2125,9 @@ static void test_work_current(struct work *work)
{
char *hexstr;
if (opt_benchmark)
return;
hexstr = bin2hex(work->data, 18);
if (unlikely(!hexstr)) {
applog(LOG_ERR, "stage_thread OOM");
@ -3184,6 +3207,11 @@ static bool get_work(struct work *work, bool requested, struct thr_info *thr, @@ -3184,6 +3207,11 @@ static bool get_work(struct work *work, bool requested, struct thr_info *thr,
/* Tell the watchdog thread this thread is waiting on getwork and
* should not be restarted */
thread_reportout(thr);
if (opt_benchmark) {
get_benchmark_work(work);
return true;
}
retry:
pool = current_pool();
if (!requested || requests_queued() < opt_queue) {
@ -4282,6 +4310,23 @@ int main (int argc, char *argv[]) @@ -4282,6 +4310,23 @@ int main (int argc, char *argv[])
if (argc != 1)
quit(1, "Unexpected extra commandline arguments");
if (opt_benchmark) {
struct pool *pool;
want_longpoll = false;
pool = calloc(sizeof(struct pool), 1);
pool->pool_no = 0;
pools[total_pools++] = pool;
pthread_mutex_init(&pool->pool_lock, NULL);
pool->rpc_url = malloc(255);
strcpy(pool->rpc_url, "Benchmark");
pool->rpc_user = pool->rpc_url;
pool->rpc_pass = pool->rpc_url;
pool->enabled = true;
pool->idle = false;
successful_connect = true;
}
if (use_curses)
enable_curses();
@ -4477,6 +4522,9 @@ int main (int argc, char *argv[]) @@ -4477,6 +4522,9 @@ int main (int argc, char *argv[])
/* We use the getq mutex as the staged lock */
stgd_lock = &getq->mutex;
if (opt_benchmark)
goto begin_bench;
for (i = 0; i < total_pools; i++) {
struct pool *pool = pools[i];
@ -4527,6 +4575,7 @@ int main (int argc, char *argv[]) @@ -4527,6 +4575,7 @@ int main (int argc, char *argv[])
if (want_longpoll)
start_longpoll();
begin_bench:
gettimeofday(&total_tv_start, NULL);
gettimeofday(&total_tv_end, NULL);
get_datestamp(datestamp, &total_tv_start);

Loading…
Cancel
Save