wip

Author: Lbqds

src/main.cu

@@ -70,7 +70,7 @@ void submit_new_block(mining_worker_t *worker)
 
     ssize_t buf_size = write_new_block(worker, write_buffer);
     uv_buf_t buf = uv_buf_init((char *)write_buffer, buf_size);
-    print_hex_with_info("new solution", (uint8_t *) hasher_hash(worker, true), 32, height, from_group, to_group);
+    print_hex_with_info("new solution", (uint8_t *) hasher_hash(worker, true), 32, height, from_group, to_group, worker->id);
 
     uv_write_t *write_req = (uv_write_t *)malloc(sizeof(uv_write_t));
     uint32_t buf_count = 1;
@@ -128,14 +128,16 @@ void after_mine(uv_work_t *req, int status)
 void worker_stream_callback(cudaStream_t stream, cudaError_t status, void *data)
 {
     mining_worker_t *worker = (mining_worker_t *)data;
+    mining_template_t *template_ptr = load_worker__template(worker);
+    job_t *job = template_ptr->job;
     if (hasher_found_good_hash(worker, true))
     {
         store_worker_found_good_hash(worker, true);
         submit_new_block(worker);
+    } else {
+        // LOG("Not found good hash: %d -> %d, height: %d, worker: %d\n", job->from_group, job->to_group, job->height, worker->id);
     }
 
-    mining_template_t *template_ptr = load_worker__template(worker);
-    job_t *job = template_ptr->job;
     uint32_t chain_index = job->from_group * group_nums + job->to_group;
     mining_counts[chain_index].fetch_sub(mining_steps);
     mining_counts[chain_index].fetch_add(hasher_hash_count(worker, true));
@@ -249,6 +251,8 @@ void try_to_reconnect(uv_timer_t *timer){
     uv_timer_stop(timer);
 }
 
+int job_counts = 0;
+
 void on_read(uv_stream_t *server, ssize_t nread, const uv_buf_t *buf)
 {
     if (nread < 0)
@@ -263,12 +267,15 @@ void on_read(uv_stream_t *server, ssize_t nread, const uv_buf_t *buf)
         return;
     }
 
+    LOG("=========== job conts %d\n", job_counts);
+
     server_message_t *message = decode_buf(buf, nread);
     if (message)
     {
         switch (message->kind)
         {
         case JOBS:
+            job_counts += 1;
             for (int i = 0; i < message->jobs->len; i++)
             {
                 update_templates(message->jobs->jobs[i]);

src/messages.h

@@ -40,10 +40,10 @@ char *bytes_to_hex(uint8_t *bytes, ssize_t len)
     return hex_string;
 }
 
-void print_hex_with_info(const char* prefix, uint8_t *data, ssize_t nread, int height, int from, int to)
+void print_hex_with_info(const char* prefix, uint8_t *data, ssize_t nread, int height, int from, int to, int worker_id)
 {
     char *hex_string = bytes_to_hex(data, nread);
-    LOG("%s: %d -> %d, height: %d, hash: %s\n", prefix, from, to, height, hex_string);
+    LOG("%s: %d -> %d, height: %d, hash: %s, worker: %d\n", prefix, from, to, height, hex_string, worker_id);
     free(hex_string);
 }
 
@@ -240,6 +240,7 @@ void extract_jobs(uint8_t **bytes, jobs_t *jobs)
     jobs->len = jobs_size;
     jobs->jobs = (job_t **)malloc(jobs_size * sizeof(job_t*));
     for(ssize_t i = 0; i < jobs_size; i++) {
+        // jobs->jobs[i] = NULL;
         jobs->jobs[i] = (job_t *)malloc(sizeof(job_t));
         extract_job(bytes, (jobs->jobs[i]));
     }

src/template.h

@@ -75,7 +75,7 @@ void update_templates(job_t *job)
         free_template(last_template);
     }
     store_template(chain_index, new_template);
-    LOG("Store new job: %d -> %d, height: %d\n", job->from_group, job->to_group, job->height);
+    // LOG("Store new job: %d -> %d, height: %d\n", job->from_group, job->to_group, job->height);
 }
 
 bool expire_template_for_new_block(mining_template_t *template_ptr)

src/worker.h

@@ -198,8 +198,8 @@ ssize_t write_new_block(mining_worker_t *worker, uint8_t *write_buf) {
 }
 
 void setup_template(mining_worker_t *worker, mining_template_t *template_ptr) {
-    LOG("Start mining job: %d -> %d, height: %d, worker: %d\n",
-        template_ptr->job->from_group, template_ptr->job->to_group, template_ptr->job->height, worker->id);
+    // LOG("Start mining job: %d -> %d, height: %d, worker: %d\n",
+    //     template_ptr->job->from_group, template_ptr->job->to_group, template_ptr->job->height, worker->id);
     add_template__ref_count(template_ptr, 1);
     store_worker__template(worker, template_ptr);
 }