fixed wrong indentations
This commit is contained in:
@ -193,7 +193,7 @@ func (ctl *client_ctl) Cors(req *http.Request) bool {
|
|||||||
|
|
||||||
func (ctl *client_ctl) Authenticate(req *http.Request) (int, string) {
|
func (ctl *client_ctl) Authenticate(req *http.Request) (int, string) {
|
||||||
if ctl.c.ctl_auth == nil { return http.StatusOK, "" }
|
if ctl.c.ctl_auth == nil { return http.StatusOK, "" }
|
||||||
return ctl.c.ctl_auth.Authenticate(req)
|
return ctl.c.ctl_auth.Authenticate(req)
|
||||||
}
|
}
|
||||||
|
|
||||||
// ------------------------------------
|
// ------------------------------------
|
||||||
@ -1196,13 +1196,13 @@ func (ctl *client_ctl_ws) ServeWebsocket(ws *websocket.Conn) (int, error) {
|
|||||||
|
|
||||||
wg.Add(1)
|
wg.Add(1)
|
||||||
go func() {
|
go func() {
|
||||||
var c chan *ClientEvent
|
var c chan *ClientEvent
|
||||||
var err error
|
var err error
|
||||||
|
|
||||||
defer wg.Done()
|
defer wg.Done()
|
||||||
c = sbsc.C
|
c = sbsc.C
|
||||||
|
|
||||||
for c != nil {
|
for c != nil {
|
||||||
var e *ClientEvent
|
var e *ClientEvent
|
||||||
var ok bool
|
var ok bool
|
||||||
var msg[] byte
|
var msg[] byte
|
||||||
@ -1227,7 +1227,7 @@ func (ctl *client_ctl_ws) ServeWebsocket(ws *websocket.Conn) (int, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
ws.Close() // hack to break the recv loop. don't care about double closes
|
ws.Close() // hack to break the recv loop. don't care about double closes
|
||||||
}()
|
}()
|
||||||
|
|
||||||
ws_recv_loop:
|
ws_recv_loop:
|
||||||
for {
|
for {
|
||||||
|
@ -76,7 +76,7 @@ type json_out_server_stats struct {
|
|||||||
ServerPeers int64 `json:"server-peers"`
|
ServerPeers int64 `json:"server-peers"`
|
||||||
|
|
||||||
SshProxySessions int64 `json:"pxy-ssh-sessions"`
|
SshProxySessions int64 `json:"pxy-ssh-sessions"`
|
||||||
ServerPtySessions int64 `json:"server-pty-sessions"`
|
ServerPtySessions int64 `json:"server-pty-sessions"`
|
||||||
ServerRptySessions int64 `json:"server-rpty-sessions"`
|
ServerRptySessions int64 `json:"server-rpty-sessions"`
|
||||||
ServerRpxSessions int64 `json:"server-rpx-sessions"`
|
ServerRpxSessions int64 `json:"server-rpx-sessions"`
|
||||||
}
|
}
|
||||||
@ -979,13 +979,13 @@ func (ctl *server_ctl_ws) ServeWebsocket(ws *websocket.Conn) (int, error) {
|
|||||||
|
|
||||||
wg.Add(1)
|
wg.Add(1)
|
||||||
go func() {
|
go func() {
|
||||||
var c chan *ServerEvent
|
var c chan *ServerEvent
|
||||||
var err error
|
var err error
|
||||||
|
|
||||||
defer wg.Done()
|
defer wg.Done()
|
||||||
c = sbsc.C
|
c = sbsc.C
|
||||||
|
|
||||||
for c != nil {
|
for c != nil {
|
||||||
var e *ServerEvent
|
var e *ServerEvent
|
||||||
var ok bool
|
var ok bool
|
||||||
var msg[] byte
|
var msg[] byte
|
||||||
@ -1010,7 +1010,7 @@ func (ctl *server_ctl_ws) ServeWebsocket(ws *websocket.Conn) (int, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
ws.Close() // hack to break the recv loop. don't care about double closes
|
ws.Close() // hack to break the recv loop. don't care about double closes
|
||||||
}()
|
}()
|
||||||
|
|
||||||
ws_recv_loop:
|
ws_recv_loop:
|
||||||
for {
|
for {
|
||||||
|
@ -493,8 +493,8 @@ func (pxy *server_pxy_xterm_file) ServeHTTP(w http.ResponseWriter, req *http.Req
|
|||||||
route_id = PORT_ID_MARKER
|
route_id = PORT_ID_MARKER
|
||||||
_, err = s.FindServerRouteByIdStr(conn_id, route_id)
|
_, err = s.FindServerRouteByIdStr(conn_id, route_id)
|
||||||
if err != nil && s.wpx_foreign_port_proxy_maker != nil {
|
if err != nil && s.wpx_foreign_port_proxy_maker != nil {
|
||||||
_, err = s.wpx_foreign_port_proxy_maker("ssh", conn_id)
|
_, err = s.wpx_foreign_port_proxy_maker("ssh", conn_id)
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
conn_id = req.PathValue("conn_id")
|
conn_id = req.PathValue("conn_id")
|
||||||
route_id = req.PathValue("route_id")
|
route_id = req.PathValue("route_id")
|
||||||
|
Reference in New Issue
Block a user