scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-09-11 23:31:03 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

finish commenting methods as unprotected.

Browse source
This commit is contained in:
Matt Jaffee 2018-07-19 09:40:23 -05:00
parent 3b8b190849
commit 774e91ad30
No known key found for this signature in database
GPG key ID: 08A3DFFF987B11BF
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
cluster.go
View file

@ -1500,7 +1500,7 @@ func (t *Topology) encode() *internal.Topology {
return encodeTopology(t)
}
// loadTopology reads the topology for the node.
// loadTopology reads the topology for the node. unprotected.
func (c *cluster) loadTopology() error {
buf, err := ioutil.ReadFile(filepath.Join(c.Path, ".topology"))
if os.IsNotExist(err) {
@ -1523,7 +1523,7 @@ func (c *cluster) loadTopology() error {
return nil
}
// saveTopology writes the current topology to disk.
// saveTopology writes the current topology to disk. unprotected.
func (c *cluster) saveTopology() error {
if err := os.MkdirAll(c.Path, 0777); err != nil {
@ -1765,6 +1765,8 @@ func (c *cluster) mergeClusterStatus(cs *ClusterStatus) error {
return nil
}
// setStatic is unprotected, but only called before the cluster has been started
// (and therefore not concurrently).
func (c *cluster) setStatic(hosts []string) error {
c.Static = true
c.Coordinator = c.Node.ID