service

Documentation

Index

• type Service
  • func InitService(port int, msgChan chan interface{}) *Service
  • func (s *Service) DirectReply(r *message.Reply) error
  • func (s *Service) Execute(v, n, seq int64, o *message.Request) (reply *message.Reply, err error)
  • func (s *Service) WaitRequest(sig chan interface{})

Types

type Service

type Service struct {
	SrvHub *net.UDPConn
	// contains filtered or unexported fields
}

func InitService

func InitService(port int, msgChan chan interface{}) *Service

func (*Service) DirectReply

func (s *Service) DirectReply(r *message.Reply) error

func (*Service) Execute

func (s *Service) Execute(v, n, seq int64, o *message.Request) (reply *message.Reply, err error)

Each replica i executes the operation requested by m  after committed-local(m, v, n, i)is true and i’s state

reflects the sequential execution of all requests with lower sequence numbers. This ensures that all non- faulty replicas execute requests in the same order as required to provide the safety property. After executing the requested operation, replicas send a reply to the client. Replicas discard requests whose timestamp is lower than the timestamp in the last reply they sent to the client to guarantee exactly-once semantics.

We do not rely on ordered message delivery, and therefore it is possible for a replica to commit requests out

of order. This does not matter since it keeps the pre- prepare, prepare, and commit messages logged until the corresponding request can be executed.

func (*Service) WaitRequest

func (s *Service) WaitRequest(sig chan interface{})