.

go/neo/server/master.go

@@ -41,7 +41,7 @@ type Master struct {
 	clusterName	string
 
 	net		xnet.Network	// network we are sending/receiving on
-	masterAddr	string		// address of master
+	masterAddr	string		// address of current primary master
 	// ---- 8< ----
 
 	// last allocated oid & tid
@@ -82,16 +82,25 @@ type nodeLeave struct {
 	link *neo.NodeLink	// XXX better use uuid allocated on nodeCome ?
 }
 
-// NewMaster creates new master node that is listening on serveAddr
-// XXX ... call Run
+// NewMaster creates new master node that will listen on serveAddr
+// Use Run to actually start running the node.
 func NewMaster(clusterName, serveAddr string, net xnet.Network) *Master {
-	// XXX serveAddr + net
+	// convert serveAddr into neo format
+	addr, err := neo.AddrString(net.Network(), serveAddr)
+	if err != nil {
+		panic(err)	// XXX
+	}
+
+	m := &Master{
+		myInfo:		neo.NodeInfo{NodeType: neo.MASTER, Address: addr},
+		clusterName:	clusterName,
+		net:		net,
+		masterAddr:	serveAddr,	// XXX ok?
+	}
 
-	m := &Master{clusterName: clusterName}
 	m.myInfo.NodeUUID = m.allocUUID(neo.MASTER)
 	// TODO update nodeTab with self
 	m.clusterState = neo.ClusterRecovering	// XXX no elections - we are the only master
-//	go m.run(context.TODO())		// XXX ctx
 
 	return m
 }
@@ -116,6 +125,7 @@ func (m *Master) Run(ctx context.Context) error {
 	}
 
 	m.myInfo.Address = addr
+	m.masterAddr = l.Addr().String()
 
 	wg := sync.WaitGroup{}
 

go/neo/server/storage.go

@@ -47,7 +47,7 @@ type Storage struct {
 
 // NewStorage creates new storage node that will listen on serveAddr and talk to master on masterAddr
 // The storage uses zstor as underlying backend for storing data.
-// To actually start running the node - call Run.	XXX text
+// Use Run to actually start running the node.
 func NewStorage(cluster, masterAddr, serveAddr string, net xnet.Network, zstor zodb.IStorage) *Storage {
 	// convert serveAddr into neo format
 	addr, err := neo.AddrString(net.Network(), serveAddr)