wip

Author: Lbqds

src/messages.h

@@ -79,12 +79,16 @@ typedef struct job_t {
     blob_t header_blob;
     blob_t txs_blob;
     blob_t target;
+    blob_t uncle_blob;
 } job_t;
 
 void free_job(job_t *job) {
     free_blob(&job->header_blob);
     free_blob(&job->txs_blob);
     free_blob(&job->target);
+    if (job->uncle_blob.len > 0) {
+        free_blob(&job->uncle_blob);
+    }
     free(job);
 }
 
@@ -210,6 +214,18 @@ void extract_blob(uint8_t **bytes, blob_t *blob)
     // LOG("%s\n", bytes_to_hex(blob->blob, blob->len));
 }
 
+void extract_uncle_blob(uint8_t **bytes, blob_t *blob)
+{
+    uint8_t flag = *bytes[0];
+    *bytes = *bytes + 1;
+    if (flag == 1) {
+        extract_blob(bytes, blob);
+    } else {
+        blob->len = 0;
+        blob->blob = NULL;
+    }
+}
+
 void extract_job(uint8_t **bytes, job_t *job)
 {
     job->from_group = extract_size(bytes);
@@ -218,6 +234,7 @@ void extract_job(uint8_t **bytes, job_t *job)
     extract_blob(bytes, &job->header_blob);
     extract_blob(bytes, &job->txs_blob);
     extract_blob(bytes, &job->target);
+    extract_uncle_blob(bytes, &job->uncle_blob);
 }
 
 void extract_jobs(uint8_t **bytes, jobs_t *jobs)

src/worker.h

@@ -183,7 +183,7 @@ ssize_t write_new_block(mining_worker_t *worker, uint8_t *write_buf) {
                                              : worker->host_hasher.ref_hasher->buf;
     uint8_t *write_pos = write_buf;
 
-    ssize_t block_size = 24 + job->header_blob.len + job->txs_blob.len;
+    ssize_t block_size = 24 + job->header_blob.len + job->txs_blob.len + job->uncle_blob.len;
     ssize_t message_size = 1 + 4 + block_size;
 
     write_size(&write_pos, message_size);
@@ -192,6 +192,9 @@ ssize_t write_new_block(mining_worker_t *worker, uint8_t *write_buf) {
     write_bytes(&write_pos, nonce, 24);
     write_blob(&write_pos, &job->header_blob);
     write_blob(&write_pos, &job->txs_blob);
+    if (job->uncle_blob.len > 0) {
+        write_blob(&write_pos, &job->uncle_blob);
+    }
 
     return message_size + 4;
 }