Skip to content
Snippets Groups Projects
Commit 3c910849 authored by Benjamin Wenger's avatar Benjamin Wenger
Browse files

fixed a bug in broadcast and fixed missing functions on the interface

parent 0a1932b2
No related branches found
No related tags found
5 merge requests!510Release,!419rewrote the health tracker to both consider if there are waiting rounds and...,!371[Channel RSAtoPrivate] Implement Reverse Asymmetric in Client/Broadcast,!354Channels impl,!340Project/channels
...@@ -56,7 +56,7 @@ func (p *processor) Process(msg format.Message, ...@@ -56,7 +56,7 @@ func (p *processor) Process(msg format.Message,
jww.ERROR.Printf("Unrecognized broadcast method %d", p.method) jww.ERROR.Printf("Unrecognized broadcast method %d", p.method)
} }
go p.cb(payload, receptionID, round) p.cb(payload, receptionID, round)
} }
// String returns a string identifying the symmetricProcessor for debugging purposes. // String returns a string identifying the symmetricProcessor for debugging purposes.
......
...@@ -25,6 +25,15 @@ import ( ...@@ -25,6 +25,15 @@ import (
var ValidForever = time.Duration(math.MaxInt64) var ValidForever = time.Duration(math.MaxInt64)
type Manager interface { type Manager interface {
// JoinChannel joins the given channel. It will fail if the channel has
// already been joined.
JoinChannel(channel *cryptoBroadcast.Channel) error
// LeaveChannel leaves the given channel. It will return an error if the
// channel was not previously joined.
LeaveChannel(channelID *id.ID) error
// SendGeneric is used to send a raw message over a channel. In general, it // SendGeneric is used to send a raw message over a channel. In general, it
// should be wrapped in a function which defines the wire protocol // should be wrapped in a function which defines the wire protocol
// If the final message, before being sent over the wire, is too long, this will // If the final message, before being sent over the wire, is too long, this will
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment