Code Review
/
ric-plt
/
vespamgr.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Support for platform metrics
[ric-plt/vespamgr.git]
/
cmd
/
vesmgr
/
vesmgr_queryxappconfig_test.go
diff --git
a/cmd/vesmgr/vesmgr_queryxappconfig_test.go
b/cmd/vesmgr/vesmgr_queryxappconfig_test.go
index
11e7531
..
053adcc
100755
(executable)
--- a/
cmd/vesmgr/vesmgr_queryxappconfig_test.go
+++ b/
cmd/vesmgr/vesmgr_queryxappconfig_test.go
@@
-59,10
+59,11
@@
func runXAppMgr(listener net.Listener, url string, suite *QueryXAppsConfigTestSu
switch r.Method {
case "GET":
suite.mu.Lock()
switch r.Method {
case "GET":
suite.mu.Lock()
+ defer suite.mu.Unlock()
suite.xAppMgrFunc(w)
suite.xAppMgrFunc(w)
- suite.mu.Unlock()
}
})
}
})
+
http.Serve(listener, nil)
}
http.Serve(listener, nil)
}
@@
-70,7
+71,10
@@
func (suite *QueryXAppsConfigTestSuite) TestQueryXAppsConfigFailsWithTimeout() {
doSleep := func(w http.ResponseWriter) {
time.Sleep(time.Second * 2)
}
doSleep := func(w http.ResponseWriter) {
time.Sleep(time.Second * 2)
}
+
+ suite.mu.Lock()
suite.xAppMgrFunc = doSleep
suite.xAppMgrFunc = doSleep
+ suite.mu.Unlock()
data, err := queryXAppsConfig("http://"+suite.listener.Addr().String()+"/test_url/", 1)
suite.Equal([]byte("{}"), data)
data, err := queryXAppsConfig("http://"+suite.listener.Addr().String()+"/test_url/", 1)
suite.Equal([]byte("{}"), data)
@@
-84,7
+88,10
@@
func (suite *QueryXAppsConfigTestSuite) TestQueryXAppsConfigFailsWithAnErrorRepl
doReplyWithErr := func(w http.ResponseWriter) {
http.Error(w, "405 method not allowed", http.StatusMethodNotAllowed)
}
doReplyWithErr := func(w http.ResponseWriter) {
http.Error(w, "405 method not allowed", http.StatusMethodNotAllowed)
}
+
+ suite.mu.Lock()
suite.xAppMgrFunc = doReplyWithErr
suite.xAppMgrFunc = doReplyWithErr
+ suite.mu.Unlock()
data, err := queryXAppsConfig("http://"+suite.listener.Addr().String()+"/test_url/", 1)
suite.Equal([]byte("{}"), data)
data, err := queryXAppsConfig("http://"+suite.listener.Addr().String()+"/test_url/", 1)
suite.Equal([]byte("{}"), data)
@@
-96,7
+103,10
@@
func (suite *QueryXAppsConfigTestSuite) TestQueryXAppsConfigOk() {
doReply := func(w http.ResponseWriter) {
fmt.Fprintf(w, "reply message")
}
doReply := func(w http.ResponseWriter) {
fmt.Fprintf(w, "reply message")
}
+
+ suite.mu.Lock()
suite.xAppMgrFunc = doReply
suite.xAppMgrFunc = doReply
+ suite.mu.Unlock()
data, err := queryXAppsConfig("http://"+suite.listener.Addr().String()+"/test_url/", 1)
suite.NotNil(data)
data, err := queryXAppsConfig("http://"+suite.listener.Addr().String()+"/test_url/", 1)
suite.NotNil(data)