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
104
105
|
// Copyright (C) 2019-2024 Algorand, Inc.
// This file is part of go-algorand
//
// go-algorand is free software: you can redistribute it and/or modify
// it under the terms of the GNU Affero General Public License as
// published by the Free Software Foundation, either version 3 of the
// License, or (at your option) any later version.
//
// go-algorand is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU Affero General Public License for more details.
//
// You should have received a copy of the GNU Affero General Public License
// along with go-algorand. If not, see <https://www.gnu.org/licenses/>.
package agreement
import (
"github.com/algorand/go-algorand/protocol"
"github.com/algorand/msgp/msgp"
)
// A message represents an internal message which is passed between components
// of the agreement service.
type message struct {
_struct struct{} `codec:","`
// this field is for backwards compatibility with crash state serialized using go-codec prior to explicit unexport.
// should be removed after the next consensus update.
MessageHandle msgp.Raw `codec:"MessageHandle,omitempty"`
// explicitly unexport this field since we can't define serializers for interface{} type
// the only implementation of this is gossip.messageMetadata which doesn't have exported fields to serialize.
messageHandle MessageHandle
Tag protocol.Tag
// note: if Vote, Proposal, or Bundle is set, some logic requires unauthenticated
// equivalents to be set
Vote vote
Proposal proposal
Bundle bundle
UnauthenticatedVote unauthenticatedVote
UnauthenticatedProposal unauthenticatedProposal
UnauthenticatedBundle unauthenticatedBundle
CompoundMessage compoundMessage
}
// A compoundMessage represents the concatenation of a proposal-vote and a
// proposal payload.
//
// These messages are concatenated as an optimization which prevents proposals
// from being dropped.
type compoundMessage struct {
_struct struct{} `codec:","`
Vote unauthenticatedVote
Proposal unauthenticatedProposal
}
// streamTokenizer is a function that returns an object of some type after
// deserializing from some stream.
type streamTokenizer func([]byte) (interface{}, error)
// decodeVote reads a vote from the given stream.
//
// It returns an error on failure.
func decodeVote(data []byte) (interface{}, error) {
var uv unauthenticatedVote
err := protocol.Decode(data, &uv)
if err != nil {
return nil, err
}
return uv, nil
}
// decodeBundle reads a bundle from the given stream.
//
// It returns an error on failure.
func decodeBundle(data []byte) (interface{}, error) {
var b unauthenticatedBundle
err := protocol.Decode(data, &b)
if err != nil {
return nil, err
}
return b, nil
}
// decodeProposal reads a proposal from the given stream.
//
// It returns an error on failure.
func decodeProposal(data []byte) (interface{}, error) {
var p transmittedPayload
err := protocol.Decode(data, &p)
if err != nil {
return nil, err
}
return compoundMessage{
Vote: p.PriorVote,
Proposal: p.unauthenticatedProposal,
}, nil
}
|
