projects
/
arvados.git
/ blobdiff
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
9397: test with multiple mount points under subdirectories
[arvados.git]
/
services
/
ws
/
router.go
diff --git
a/services/ws/router.go
b/services/ws/router.go
index 0ad8d7c088a6fb52f8bbe01e7d34112a7fa15f98..15b825f2abfa293f8ba2734f57508ba9306a03af 100644
(file)
--- a/
services/ws/router.go
+++ b/
services/ws/router.go
@@
-1,7
+1,6
@@
package main
import (
package main
import (
- "database/sql"
"encoding/json"
"io"
"net/http"
"encoding/json"
"io"
"net/http"
@@
-10,6
+9,7
@@
import (
"sync/atomic"
"time"
"sync/atomic"
"time"
+ "git.curoverse.com/arvados.git/sdk/go/ctxlog"
"github.com/Sirupsen/logrus"
"golang.org/x/net/websocket"
)
"github.com/Sirupsen/logrus"
"golang.org/x/net/websocket"
)
@@
-45,8
+45,6
@@
type debugStatuser interface {
DebugStatus() interface{}
}
DebugStatus() interface{}
}
-type sessionFactory func(wsConn, chan<- interface{}, *sql.DB, permChecker) (session, error)
-
func (rtr *router) setup() {
rtr.handler = &handler{
PingTimeout: rtr.Config.PingTimeout.Duration(),
func (rtr *router) setup() {
rtr.handler = &handler{
PingTimeout: rtr.Config.PingTimeout.Duration(),
@@
-71,7
+69,7
@@
func (rtr *router) makeServer(newSession sessionFactory) *websocket.Server {
stats := rtr.handler.Handle(ws, rtr.eventSource,
func(ws wsConn, sendq chan<- interface{}) (session, error) {
stats := rtr.handler.Handle(ws, rtr.eventSource,
func(ws wsConn, sendq chan<- interface{}) (session, error) {
- return newSession(ws, sendq, rtr.eventSource.DB(), rtr.newPermChecker())
+ return newSession(ws, sendq, rtr.eventSource.DB(), rtr.newPermChecker()
, &rtr.Config.Client
)
})
log.WithFields(logrus.Fields{
})
log.WithFields(logrus.Fields{
@@
-118,7
+116,7
@@
func (rtr *router) ServeHTTP(resp http.ResponseWriter, req *http.Request) {
logger := logger(req.Context()).
WithField("RequestID", rtr.newReqID())
logger := logger(req.Context()).
WithField("RequestID", rtr.newReqID())
- ctx := c
ontextWithLogger
(req.Context(), logger)
+ ctx := c
txlog.Context
(req.Context(), logger)
req = req.WithContext(ctx)
logger.WithFields(logrus.Fields{
"remoteAddr": req.RemoteAddr,
req = req.WithContext(ctx)
logger.WithFields(logrus.Fields{
"remoteAddr": req.RemoteAddr,