change the order of grpc shutdown

server/cluster.go

@@ -297,7 +297,7 @@ func (c *Cluster) Master(msg *ClusterReq, rejected *bool) error {
 				return nil
 			}
 
-			sess, _ = globals.sessionStore.Create(node, msg.Sess.Sid)
+			sess, _ = globals.sessionStore.NewSession(node, msg.Sess.Sid)
 			go sess.rpcWriteLoop()
 		}
 

server/hdl_grpc.go

@@ -31,7 +31,7 @@ func (sess *Session) closeGrpc() {
 
 // Equivalent of starting a new session and a read loop in one
 func (*grpcNodeServer) MessageLoop(stream pbx.Node_MessageLoopServer) error {
-	sess, _ := globals.sessionStore.Create(stream, "")
+	sess, _ := globals.sessionStore.NewSession(stream, "")
 
 	defer func() {
 		sess.closeGrpc()

server/hdl_longpoll.go

@@ -115,7 +115,7 @@ func serveLongPoll(wrt http.ResponseWriter, req *http.Request) {
 	if sid == "" {
 		// New session
 		var count int
-		sess, count = globals.sessionStore.Create(wrt, "")
+		sess, count = globals.sessionStore.NewSession(wrt, "")
 		log.Println("lp: session started", sess.sid, count)
 		wrt.WriteHeader(http.StatusCreated)
 		pkt := NoErrCreated(req.FormValue("id"), "", now)

server/hdl_websock.go

@@ -157,7 +157,7 @@ func serveWebSocket(wrt http.ResponseWriter, req *http.Request) {
 		return
 	}
 
-	sess, count := globals.sessionStore.Create(ws, "")
+	sess, count := globals.sessionStore.NewSession(ws, "")
 
 	log.Println("ws: session started", sess.sid, count)
 

server/http.go

@@ -152,14 +152,14 @@ loop:
 			// Shutdown local cluster node, if it's a part of a cluster.
 			globals.cluster.shutdown()
 
+			// Terminate plugin connections
+			pluginsShutdown()
+
 			// Shutdown gRPC server, if one is configured
 			if globals.grpcServer != nil {
 				globals.grpcServer.GracefulStop()
 			}
 
-			// Terminate plugin connections
-			pluginsShutdown()
-
 			// Shutdown the hub. The hub will shutdown topics
 			hubdone := make(chan bool)
 			globals.hub.shutdown <- hubdone

server/sessionstore.go

@@ -35,7 +35,7 @@ type SessionStore struct {
 }
 
 // Create creates a new session and adds it to store.
-func (ss *SessionStore) Create(conn interface{}, sid string) (*Session, int) {
+func (ss *SessionStore) NewSession(conn interface{}, sid string) (*Session, int) {
 	var s Session
 
 	s.sid = sid