Worked on FCFS and session management

Author: PythonHacker24

cmd/laclm/main.go

@@ -177,7 +177,7 @@ func run(ctx context.Context) error {
 		call all the kill switches with context
 	*/
 
-	/* graceful shutdown of http server */
+	/* graceful shutdown of http server - 5 seconds for allowing completion current API requests */
 	shutdownCtx, shutdownCancel := context.WithTimeout(context.Background(), 5*time.Second)
 	defer shutdownCancel()
 

config.yaml

@@ -41,7 +41,7 @@ authentication:
     address: "ldap://openldap:389"  # Use the service name from docker-compose
     admin_dn: ${LACLM_LDAP_ADMIN_DN}
     admin_password: ${LACLM_LDAP_ADMIN_PASSWORD}
-    search_base: "cn=Princeton Plainsboro Hospital,dc=myorg,dc=local"
+    search_base: "dc=example,dc=org"
 
 backend_security:
   jwt_secret_token: ${JWT_SECRET_TOKEN}

internal/scheduler/fcfs/fcfs.go

@@ -1,9 +1,19 @@
 package fcfs
 
-import "github.com/PythonHacker24/linux-acl-management-backend/internal/session"
+import (
+	"runtime"
 
+	"github.com/PythonHacker24/linux-acl-management-backend/internal/session"
+)
+
+/* spawns a new FCFS scheduler */
 func NewFCFSScheduler(sm *session.Manager) *FCFSScheduler {
+	/* calculate max workers */
+	/* TODO: make it configurable and dynamic */
+	maxWorkers := runtime.NumCPU()
 	return &FCFSScheduler{
 		sessionManager: sm,
+		maxWorkers: maxWorkers,
+		semaphore: make(chan struct{}, maxWorkers),
 	}
 }

internal/scheduler/fcfs/model.go

@@ -4,11 +4,16 @@ import (
 	"context"
 
 	"github.com/PythonHacker24/linux-acl-management-backend/internal/session"
+	"go.uber.org/zap"
 )
 
-/* FCFS Scheduler attached with session.Manager */
+/* FCFS Scheduler attached with curSession.Manager */
 type FCFSScheduler struct {
-	sessionManager *session.Manager 
+	curSessionManager *session.Manager 
+	maxWorkers int
+
+	/* for limiting spawning of goroutines */
+	semaphore chan struct{}
 }
 
 /* run the fcfs scheduler with context */
@@ -23,7 +28,39 @@ func (f *FCFSScheduler) Run(ctx context.Context) error {
 		/* in case default is working hard - ctx is passed here so it must attempt to quit */
 		default:
 			/* RULE: ctx is propogates all over the coming functions */
-				
+			
+			curSession := f.curSessionManager.GetNextSession()
+			if curSession == nil {
+				/* might need a delay of 10 ms */
+				continue
+			}
+			
+			/* check if transaction queue of the session is empty */
+			curSession.Mutex.Lock()
+			if curSession.TransactionQueue.Len() == 0 {
+				curSession.Mutex.Unlock()
+				continue
+			}
+
+			/* get a transaction from the session to process */
+			transaction := curSession.TransactionQueue.Remove(curSession.TransactionQueue.Front())
+			curSession.Mutex.Unlock()
+
+			/* block if all workers are busy */
+			f.semaphore <- struct{}{}
+
+			/* go routine is available to be spawned */
+			go func(curSession *session.Session, transaction interface{}) {
+				/* defer clearing the semaphore channel */
+				defer func() { <-f.semaphore }()
+
+				/* process the transaction */
+				if err := f.processTransaction; err != nil {
+					zap.L().Error("Faild to process transaction", 
+						zap.Error(err),
+					)
+				}
+			}(curSession, transaction)
 		}
 	}	
 }