aboutsummaryrefslogtreecommitdiff
path: root/cpu-miner.c
diff options
context:
space:
mode:
authorJeff Garzik <jeff@garzik.org>2011-03-21 04:02:13 -0400
committerJeff Garzik <jgarzik@pobox.com>2011-03-21 04:02:13 -0400
commit2fd9d54443755b82a45519f33cb0aaf4f7a1fee5 (patch)
tree7249cff984be6f2c7d3779c9fc57961b863c57f6 /cpu-miner.c
parent144cf62d7c3eed3f5412edb18b238b2c1209f4c1 (diff)
Convert remaining [f]print to applog().
Also, remove a few superfluous printouts.
Diffstat (limited to 'cpu-miner.c')
-rw-r--r--cpu-miner.c50
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;
}