node

Documentation

Index

• func GetConnection(addr string) *grpc.ClientConn
• type Node
  • func NewNode(id int, addr string) *Node
  • func (node *Node) CritcalZoneTimer()
  • func (node *Node) EnterCriticalZone()
  • func (node *Node) Listen()
  • func (node *Node) Running(peer *Peer)
  • func (node *Node) TokenRing(msg *protos.Message, stream protos.MutualExclusion_TokenRingServer) error
• type Peer
  • func CreatePeer(port string) *Peer
  • func NewPeer(addr string) *Peer
  • func (peer *Peer) Recieve(client protos.MutualExclusionClient)
  • func (peer *Peer) Running(node_ *Node)

Functions

func GetConnection

func GetConnection(addr string) *grpc.ClientConn

Types

type Node

type Node struct {
	protos.UnimplementedMutualExclusionServer

	Id         int
	Addr       string
	PeerAddr   string
	Peer       *Peer
	GrpcServer *grpc.Server

	IsTokenHolder bool
	// contains filtered or unexported fields
}

func NewNode

func NewNode(id int, addr string) *Node

func (*Node) CritcalZoneTimer

func (node *Node) CritcalZoneTimer()

func (*Node) EnterCriticalZone

func (node *Node) EnterCriticalZone()

CRITICAL ZONE (CZ)

func (*Node) Listen

func (node *Node) Listen()

SERVER Methods

func (*Node) Running

func (node *Node) Running(peer *Peer)

func (*Node) TokenRing

func (node *Node) TokenRing(msg *protos.Message, stream protos.MutualExclusion_TokenRingServer) error

type Peer

type Peer struct {
	Addr string // network address
	// contains filtered or unexported fields
}

peer is the the remote node that a local node can connect to.

func CreatePeer

func CreatePeer(port string) *Peer

func NewPeer

func NewPeer(addr string) *Peer

func (*Peer) Recieve

func (peer *Peer) Recieve(client protos.MutualExclusionClient)

func (*Peer) Running

func (peer *Peer) Running(node_ *Node)