chiavdf 1.1.14

Bindings to the chiavdf C++ library.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103

#ifndef HW_PROOF_H
#define HW_PROOF_H

#include "vdf_base.hpp"
#include "hw_interface.hpp"
#include "hw_util.hpp"
#include "bqfc.h"

#include <atomic>
#include <deque>
#include <mutex>
#include <thread>

#define HW_VDF_VALUE_INTERVAL 4000
#define HW_VDF_VALUE_INTERVAL_DIVISORS { 2, 4, 5, 8, 10, 16, 20 }
#define HW_VDF_CHKP_INTERVAL 1000000
#define HW_VDF_MAX_AUX_THREADS 64
#define HW_VDF_DEFAULT_MAX_AUX_THREADS 4
#define HW_VDF_WQ_WARN_MULT 2
#define HW_VDF_B_SIZE 33

#define HW_VDF_PROOF_FLAG_DONE 1
#define HW_VDF_PROOF_FLAG_IS_REQ 2
#define HW_VDF_PROOF_FLAG_STARTED 4
#define HW_VDF_PROOF_NONE ((uint16_t)0xffff)

struct vdf_work {
    //size_t raw_idx;
    struct vdf_value start_val;
    uint64_t start_iters;
    uint32_t n_steps;
};

struct vdf_proof_req {
    uint64_t iters;
    bool is_chkp;
};

struct vdf_proof {
    uint64_t iters;
    uint64_t seg_iters;
    uint8_t y[BQFC_FORM_SIZE];
    uint8_t proof[BQFC_FORM_SIZE];
    uint8_t B[HW_VDF_B_SIZE];

    uint8_t flags;
    uint16_t prev;
    uint16_t ref_cnt;
};

struct vdf_proof_opts {
    uint8_t max_aux_threads;
    uint8_t max_proof_threads;
};

struct vdf_state {
    uint64_t target_iters;
    uint64_t iters_offset;
    uint64_t cur_iters;
    std::atomic<uint64_t> done_values;
    std::atomic<uint64_t> done_iters;
    std::atomic<uint64_t> elapsed_us;
    timepoint_t start_time;
    //std::vector<struct vdf_value> raw_values;
    struct vdf_value last_val;
    std::vector<form *> values;
    std::vector<uint8_t> valid_values;
    std::mutex valid_values_mtx;
    std::deque<struct vdf_proof_req> req_proofs;
    std::vector<struct vdf_proof> proofs;
    std::mutex proofs_resize_mtx;
    std::vector<uint16_t> queued_proofs; /* sorted queued proofs */
    std::vector<uint16_t> done_proofs; /* requested and not sent */
    integer D, L, a2;
    std::deque<struct vdf_work *> wq;
    uint32_t wq_warn_thres[2];
    //std::mutex wq_mtx;
    uint32_t interval;
    uint32_t chkp_interval;
    uint32_t n_bad;
    uint32_t n_skipped;
    uint32_t log_cnt;
    std::atomic<uint64_t> aux_threads_busy;
    std::atomic<uint8_t> n_proof_threads;
    uint8_t idx;
    uint8_t max_aux_threads;
    uint8_t max_proof_threads;
    bool completed;
    bool stopping;
    bool init_done;
};

int hw_proof_add_value(struct vdf_state *vdf, struct vdf_value *val);
form *hw_proof_last_good_form(struct vdf_state *vdf, size_t *out_pos);
void hw_proof_handle_value(struct vdf_state *vdf, struct vdf_value *val);
void hw_stop_proof(struct vdf_state *vdf);
void hw_request_proof(struct vdf_state *vdf, uint64_t iters, bool is_chkp);
void hw_compute_proof(struct vdf_state *vdf, size_t proof_idx, struct vdf_proof *out_proof, uint8_t thr_idx);
int hw_retrieve_proof(struct vdf_state *vdf, struct vdf_proof **proof);
void init_vdf_state(struct vdf_state *vdf, struct vdf_proof_opts *params, const char *d_str, const uint8_t *init_form, uint64_t n_iters, uint8_t idx);
void clear_vdf_state(struct vdf_state *vdf);

#endif // HW_PROOF_H