fix: moving concurency on transaction layer with now increased perfor…

…mance

dialog_integration_test.go

@@ -79,7 +79,6 @@ func TestIntegrationDialog(t *testing.T) {
 	)
 	// Wait server to be ready
 	<-srvReady
-
 	// Client
 	{
 		ua, _ := NewUA()
@@ -107,7 +106,7 @@ func TestIntegrationDialog(t *testing.T) {
 		go srv.ListenAndServe(ctx, "udp", contactHDR.Address.HostPort())
 		// Wait server to be ready
 		<-srvReady
-		time.Sleep(200 * time.Millisecond)
+		time.Sleep(200 * time.Millisecond) // just to avoid race with listeners on UDP
 
 		t.Run("UAS hangup", func(t *testing.T) {
 			// INVITE

server.go

@@ -242,8 +242,8 @@ func (srv *Server) ServeWSS(l net.Listener) error {
 func (srv *Server) onRequest(req *sip.Request, tx sip.ServerTransaction) {
 	// Transaction layer is the one who controls concurency execution of every request
 	// so in this case we should avoid adding more concurency
-	// srv.handleRequest(req, tx)
-	go srv.handleRequest(req, tx)
+	srv.handleRequest(req, tx)
+	// go srv.handleRequest(req, tx)
 }
 
 // handleRequest must be run in seperate goroutine

sip/transaction_layer.go

@@ -64,11 +64,11 @@ func (txl *TransactionLayer) handleMessage(msg Message) {
 
 	switch msg := msg.(type) {
 	case *Request:
-		// go txl.handleRequest(msg)
-		txl.handleRequest(msg)
+		go txl.handleRequest(msg)
+		// txl.handleRequest(msg)
 	case *Response:
-		// go txl.handleResponse(msg)
-		txl.handleResponse(msg)
+		go txl.handleResponse(msg)
+		// txl.handleResponse(msg)
 	default:
 		txl.log.Error().Msg("unsupported message, skip it")
 	}