Code Review
/
src
/
xds
/
xds-server.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
update xds-server package in docker
[src/xds/xds-server.git]
/
lib
/
xdsserver
/
xdsserver.go
diff --git
a/lib/xdsserver/xdsserver.go
b/lib/xdsserver/xdsserver.go
index
1079eba
..
ba2a560
100644
(file)
--- a/
lib/xdsserver/xdsserver.go
+++ b/
lib/xdsserver/xdsserver.go
@@
-52,6
+52,7
@@
type Context struct {
WWWServer *WebServer
sessions *Sessions
events *Events
WWWServer *WebServer
sessions *Sessions
events *Events
+ lock Lock
Exit chan os.Signal
}
Exit chan os.Signal
}
@@
-88,6
+89,7
@@
func NewXdsServer(cliCtx *cli.Context) *Context {
Log: log,
LogLevelSilly: logSilly,
LogSillyf: sillyFunc,
Log: log,
LogLevelSilly: logSilly,
LogSillyf: sillyFunc,
+ lock: Lock{LockCpt: 0},
Exit: make(chan os.Signal, 1),
}
Exit: make(chan os.Signal, 1),
}
@@
-206,6
+208,10
@@
func (ctx *Context) Run() (int, error) {
// Sessions manager
ctx.sessions = ClientSessionsConstructor(ctx, cookieMaxAge)
// Sessions manager
ctx.sessions = ClientSessionsConstructor(ctx, cookieMaxAge)
+ // Check if a new package version is available
+ // and monitor updates
+ MonitorUpdates(ctx)
+
// Run Web Server until exit requested (blocking call)
if err = ctx.WWWServer.Serve(); err != nil {
ctx.Log.Println(err)
// Run Web Server until exit requested (blocking call)
if err = ctx.WWWServer.Serve(); err != nil {
ctx.Log.Println(err)