Commit 1a4d55ab authored by Miek Gieben's avatar Miek Gieben

fixes

Signed-off-by: default avatarMiek Gieben <miek@miek.nl>
parent 9d912fe2
...@@ -110,7 +110,7 @@ func (c *Client) Run() { ...@@ -110,7 +110,7 @@ func (c *Client) Run() {
} }
if first { if first {
log.Info("gRPC stream established to %q", c.to) log.Infof("gRPC stream established to %q", c.to)
c.setSynced() c.setSynced()
first = false first = false
} }
......
package xds package xds
// Assignment returns the current assignment map. // Assignments returns the current assignment map.
func (c *Client) Assignments() *assignment { func (c *Client) Assignments() *assignment {
c.mu.RLock() c.mu.RLock()
defer c.mu.RUnlock() defer c.mu.RUnlock()
return c.assignments return c.assignments
} }
// SetAssignment sets the assignment map. // SetAssignments sets the assignment map.
func (c *Client) SetAssignments(a *assignment) { func (c *Client) SetAssignments(a *assignment) {
c.mu.Lock() c.mu.Lock()
defer c.mu.Unlock() defer c.mu.Unlock()
...@@ -42,14 +42,14 @@ func (c *Client) SetNonce(typeURL, n string) { ...@@ -42,14 +42,14 @@ func (c *Client) SetNonce(typeURL, n string) {
c.nonce[typeURL] = n c.nonce[typeURL] = n
} }
// SetSynced sets the synced boolean to true. // setSynced sets the synced boolean to true.
func (c *Client) setSynced() { func (c *Client) setSynced() {
c.mu.Lock() c.mu.Lock()
defer c.mu.Unlock() defer c.mu.Unlock()
c.synced = true c.synced = true
} }
// Synced return true if the clients has synced. // HasSynced return true if the clients has synced.
func (c *Client) HasSynced() bool { func (c *Client) HasSynced() bool {
c.mu.RLock() c.mu.RLock()
defer c.mu.RUnlock() defer c.mu.RUnlock()
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment