Skip to content

Commit

Permalink
Implement light certificates optimization
Browse files Browse the repository at this point in the history
  • Loading branch information
ranchalp committed Aug 2, 2023
1 parent 27ae290 commit 6339959
Show file tree
Hide file tree
Showing 11 changed files with 1,893 additions and 6 deletions.
4 changes: 4 additions & 0 deletions pkg/accountability/simpleacc/accountability.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@ package simpleacc
import (
"github.com/filecoin-project/mir/pkg/accountability/simpleacc/common"
"github.com/filecoin-project/mir/pkg/accountability/simpleacc/internal/certificates/fullcertificates"
"github.com/filecoin-project/mir/pkg/accountability/simpleacc/internal/certificates/lightcertificates"
incommon "github.com/filecoin-project/mir/pkg/accountability/simpleacc/internal/common"
"github.com/filecoin-project/mir/pkg/accountability/simpleacc/internal/poms"
"github.com/filecoin-project/mir/pkg/accountability/simpleacc/internal/predecisions"
Expand Down Expand Up @@ -92,6 +93,9 @@ func NewModule(mc ModuleConfig, params *ModuleParams, logger logging.Logger) (mo

predecisions.IncludePredecisions(m, &mc, params, state, logger)
fullcertificates.IncludeFullCertificate(m, &mc, params, state, logger)
if params.LightCertificates {
lightcertificates.IncludeLightCertificate(m, &mc, params, state, logger)
}
poms.IncludePoMs(m, &mc, params, state, logger)

return m, nil
Expand Down
21 changes: 15 additions & 6 deletions pkg/accountability/simpleacc/internal/predecisions/predecisions.go
Original file line number Diff line number Diff line change
Expand Up @@ -149,12 +149,21 @@ func ApplySigVerified(

accpbdsl.Decided(m, mc.App, sp.Predecision)

transportpbdsl.SendMessage(
m,
mc.Net,
accpbmsgs.FullCertificate(mc.Self,
state.DecidedCertificate),
maputil.GetKeys(params.Membership.Nodes))
if params.LightCertificates {
transportpbdsl.SendMessage(
m,
mc.Net,
accpbmsgs.LightCertificate(mc.Self,
sp.Predecision),
maputil.GetKeys(params.Membership.Nodes))
} else {
transportpbdsl.SendMessage(
m,
mc.Net,
accpbmsgs.FullCertificate(mc.Self,
state.DecidedCertificate),
maputil.GetKeys(params.Membership.Nodes))
}
}

return nil
Expand Down
Loading

0 comments on commit 6339959

Please sign in to comment.