cerc-io/lotus
16
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

lpwindow: proof_message -> proof_params rename

Browse Source
This commit is contained in:
Łukasz Magiera 2023-11-07 14:03:31 +01:00
parent 5c5055884c
commit de280a5708
4 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
lib/harmony/harmonydb/sql/20230823.sql
View File

@ -25,7 +25,7 @@ create table wdpost_proofs
partition bigint not null, partition bigint not null,
submit_at_epoch bigint not null, submit_at_epoch bigint not null,
submit_by_epoch bigint not null, submit_by_epoch bigint not null,
proof_message bytea, proof_params bytea,
submit_task_id bigint, submit_task_id bigint,
message_cid text, message_cid text,

2
provider/lpmessage/sender.go
View File

@ -157,6 +157,8 @@ func (s *Sender) Send(ctx context.Context, msg *types.Message, mss *api.MessageS
// push to mpool // push to mpool
_, err = s.api.MpoolPush(ctx, sigMsg) _, err = s.api.MpoolPush(ctx, sigMsg)
if err != nil { if err != nil {
// TODO: We may get nonce gaps here..
return cid.Undef, xerrors.Errorf("mpool push: failed to push message: %w", err) return cid.Undef, xerrors.Errorf("mpool push: failed to push message: %w", err)
} }

2
provider/lpwindow/compute_task.go
View File

@ -170,7 +170,7 @@ func (t *WdPostTask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done
partition, partition,
submit_at_epoch, submit_at_epoch,
submit_by_epoch, submit_by_epoch,
proof_message) proof_params)
VALUES ($1, $2, $3, $4, $5, $6, $7)`, VALUES ($1, $2, $3, $4, $5, $6, $7)`,
spID, spID,
pps, pps,

2
provider/lpwindow/submit_task.go
View File

@ -79,7 +79,7 @@ func (w *WdPostSubmitTask) Do(taskID harmonytask.TaskID, stillOwned func() bool)
var dbTask uint64 var dbTask uint64
err = w.db.QueryRow( err = w.db.QueryRow(
context.Background(), `SELECT sp_id, proving_period_start, deadline, partition, submit_at_epoch, submit_by_epoch, proof_message, submit_task_id context.Background(), `SELECT sp_id, proving_period_start, deadline, partition, submit_at_epoch, submit_by_epoch, proof_params, submit_task_id
FROM wdpost_proofs WHERE submit_task_id = $1`, taskID, FROM wdpost_proofs WHERE submit_task_id = $1`, taskID,
).Scan(&spID, &pps, &deadline, &partition, &submitAtEpoch, &submitByEpoch, &earlyParamBytes, &dbTask) ).Scan(&spID, &pps, &deadline, &partition, &submitAtEpoch, &submitByEpoch, &earlyParamBytes, &dbTask)
if err != nil { if err != nil {