diff options
author | Jeff Garzik <jeff@garzik.org> | 2011-03-21 04:02:13 -0400 |
---|---|---|
committer | Jeff Garzik <jgarzik@pobox.com> | 2011-03-21 04:02:13 -0400 |
commit | 2fd9d54443755b82a45519f33cb0aaf4f7a1fee5 (patch) | |
tree | 7249cff984be6f2c7d3779c9fc57961b863c57f6 /cpu-miner.c | |
parent | 144cf62d7c3eed3f5412edb18b238b2c1209f4c1 (diff) |
Convert remaining [f]print to applog().
Also, remove a few superfluous printouts.
Diffstat (limited to 'cpu-miner.c')
-rw-r--r-- | cpu-miner.c | 50 |
1 files changed, 24 insertions, 26 deletions
diff --git a/cpu-miner.c b/cpu-miner.c index 554a297..7ce1470 100644 --- a/cpu-miner.c +++ b/cpu-miner.c @@ -203,12 +203,12 @@ static bool jobj_binary(const json_t *obj, const char *key, tmp = json_object_get(obj, key); if (!tmp) { - fprintf(stderr, "JSON key '%s' not found\n", key); + applog(LOG_ERR, "JSON key '%s' not found", key); return false; } hexstr = json_string_value(tmp); if (!hexstr) { - fprintf(stderr, "JSON key '%s' is not a string\n", key); + applog(LOG_ERR, "JSON key '%s' is not a string", key); return false; } if (!hex2bin(buf, hexstr, buflen)) @@ -221,22 +221,22 @@ static bool work_decode(const json_t *val, struct work *work) { if (!jobj_binary(val, "midstate", work->midstate, sizeof(work->midstate))) { - fprintf(stderr, "JSON inval midstate\n"); + applog(LOG_ERR, "JSON inval midstate"); goto err_out; } if (!jobj_binary(val, "data", work->data, sizeof(work->data))) { - fprintf(stderr, "JSON inval data\n"); + applog(LOG_ERR, "JSON inval data"); goto err_out; } if (!jobj_binary(val, "hash1", work->hash1, sizeof(work->hash1))) { - fprintf(stderr, "JSON inval hash1\n"); + applog(LOG_ERR, "JSON inval hash1"); goto err_out; } if (!jobj_binary(val, "target", work->target, sizeof(work->target))) { - fprintf(stderr, "JSON inval target\n"); + applog(LOG_ERR, "JSON inval target"); goto err_out; } @@ -258,7 +258,7 @@ static bool submit_upstream_work(CURL *curl, const struct work *work) /* build hex string */ hexstr = bin2hex(work->data, sizeof(work->data)); if (!hexstr) { - fprintf(stderr, "submit_upstream_work OOM\n"); + applog(LOG_ERR, "submit_upstream_work OOM"); goto out; } @@ -268,12 +268,12 @@ static bool submit_upstream_work(CURL *curl, const struct work *work) hexstr); if (opt_debug) - fprintf(stderr, "DBG: sending RPC call:\n%s", s); + applog(LOG_DEBUG, "DBG: sending RPC call: %s", s); /* issue JSON-RPC request */ val = json_rpc_call(curl, rpc_url, userpass, s, false, false); if (!val) { - fprintf(stderr, "submit_upstream_work json_rpc_call failed\n"); + applog(LOG_ERR, "submit_upstream_work json_rpc_call failed"); goto out; } @@ -339,16 +339,14 @@ static bool workio_get_work(struct workio_cmd *wc, CURL *curl) /* obtain new work from bitcoin via JSON-RPC */ while (!get_upstream_work(curl, ret_work)) { - fprintf(stderr, "json_rpc_call failed, "); - if ((opt_retries >= 0) && (++failures > opt_retries)) { - fprintf(stderr, "terminating workio thread\n"); + applog(LOG_ERR, "json_rpc_call failed, terminating workio thread"); free(ret_work); return false; } /* pause, then restart work-request loop */ - fprintf(stderr, "retry after %d seconds\n", + applog(LOG_ERR, "json_rpc_call failed, retry after %d seconds", opt_fail_pause); sleep(opt_fail_pause); } @@ -367,12 +365,12 @@ static bool workio_submit_work(struct workio_cmd *wc, CURL *curl) /* submit solution to bitcoin via JSON-RPC */ while (!submit_upstream_work(curl, wc->u.work)) { if ((opt_retries >= 0) && (++failures > opt_retries)) { - fprintf(stderr, "...terminating workio thread\n"); + applog(LOG_ERR, "...terminating workio thread"); return false; } /* pause, then restart work-request loop */ - fprintf(stderr, "...retry after %d seconds\n", + applog(LOG_ERR, "...retry after %d seconds", opt_fail_pause); sleep(opt_fail_pause); } @@ -388,7 +386,7 @@ static void *workio_thread(void *userdata) curl = curl_easy_init(); if (!curl) { - fprintf(stderr, "CURL initialization failed\n"); + applog(LOG_ERR, "CURL initialization failed"); return NULL; } @@ -513,8 +511,8 @@ static void *miner_thread(void *userdata) /* obtain new work from internal workio thread */ if (!get_work(mythr, &work)) { - fprintf(stderr, "work retrieval failed, exiting " - "mining thread %d\n", mythr->id); + applog(LOG_ERR, "work retrieval failed, exiting " + "mining thread %d", mythr->id); goto out; } @@ -639,7 +637,7 @@ static void *longpoll_thread(void *userdata) curl = curl_easy_init(); if (!curl) { - fprintf(stderr, "CURL initialization failed\n"); + applog(LOG_ERR, "CURL initialization failed"); goto out; } @@ -657,10 +655,10 @@ static void *longpoll_thread(void *userdata) } else { if (failures++ < 10) { sleep(30); - fprintf(stderr, + applog(LOG_ERR, "longpoll failed, sleeping for 30s\n"); } else { - fprintf(stderr, + applog(LOG_ERR, "longpoll failed, ending thread\n"); goto out; } @@ -715,7 +713,7 @@ static void parse_arg (int key, char *arg) json_decref(opt_config); opt_config = json_load_file(arg, &err); if (!json_is_object(opt_config)) { - fprintf(stderr, "JSON decode of %s failed\n", arg); + applog(LOG_ERR, "JSON decode of %s failed", arg); show_usage(); } break; @@ -810,7 +808,7 @@ static void parse_config(void) } else if (!options[i].has_arg && json_is_true(val)) parse_arg(options[i].val, ""); else - fprintf(stderr, "JSON option %s invalid\n", + applog(LOG_ERR, "JSON option %s invalid", options[i].name); } } @@ -870,7 +868,7 @@ int main (int argc, char *argv[]) /* start work I/O thread */ if (pthread_create(&thr->pth, NULL, workio_thread, thr)) { - fprintf(stderr, "workio thread create failed\n"); + applog(LOG_ERR, "workio thread create failed"); return 1; } @@ -885,7 +883,7 @@ int main (int argc, char *argv[]) /* start longpoll thread */ if (pthread_create(&thr->pth, NULL, longpoll_thread, thr)) { - fprintf(stderr, "longpoll thread create failed\n"); + applog(LOG_ERR, "longpoll thread create failed"); return 1; } } else @@ -901,7 +899,7 @@ int main (int argc, char *argv[]) return 1; if (pthread_create(&thr->pth, NULL, miner_thread, thr)) { - fprintf(stderr, "thread %d create failed\n", i); + applog(LOG_ERR, "thread %d create failed", i); return 1; } |