Active Connection State

sockjs.go

type httpTransaction struct {
	req       *http.Request
	rw        http.ResponseWriter
	done      chan bool
	...
}

func activeConnectionState(c *conn) connectionStateFn {
	select {
	...
	case httpTx := <-c.httpTransactions:
		conn_closed := make(chan bool)
		// spawn new go routine to reject parallel connections (with the same session id)
		go c.activeConnectionGuard(conn_closed)
		// perform necessary stuff on current connection
		// ...  
		// notifify "guard" to terminate when done
                conn_closed <- true
		return activeConnectionState // return back the same state
	case <- time.After(TIMEOUT):
		return nil // return back nil state which means to terminate connection
	}
}