diff --git a/scripts/normalize.php b/scripts/normalize.php
index 5fbae4b..912def4 100755
--- a/scripts/normalize.php
+++ b/scripts/normalize.php
@@ -1,108 +1,127 @@
 #!/usr/bin/env php
 <?php
 set_time_limit(0);
 
 require '/etc/cdrtool/global.inc';
 require 'cdr_generic.php';
 require 'rating.php';
+// Function to handle SIGINT (CTRL+C)
+
+function signalHandler($signal) {
+    if ($signal === SIGINT) {
+        echo "\nCTRL+C detected! Exiting gracefully...\n";
+    }
+}
+
+// Check if pcntl extension is available
+if (!function_exists('pcntl_signal')) {
+    die("pcntl_signal() is not available. Make sure the PCNTL extension is enabled.\n");
+}
+
+// Define signal constant (for clarity)
+define('SIGINT', 2);
+
+// Register the signal handler
+pcntl_signal(SIGINT, 'signalHandler');
+echo "Press CTRL+C to exit...\n";
 
 // override logger for rating engine
 changeLoggerChannel('normalization');
 
 $lockFile = "/var/lock/CDRTool_normalize.lock";
 
 if ($argv[1]) {
     if (preg_match("/^\d{4}\d{2}$/", $argv[1], $m)) {
         $table = 'radacct'.$argv[1];
     } else {
         die("Error: Month must be in YYYYMM format\n");
     }
 }
 
 if ($f = fopen($lockFile, "w")) {
     if (flock($f, LOCK_EX + LOCK_NB, $w)) {
         if ($w) {
             criticalAndPrint("Another CDRTool normalization is in progress. Aborting.\n");
             exit(2);
         }
     } else {
         criticalAndPrint("Another CDRTool normalization is in progress. Aborting.\n");
         exit(1);
     }
 } else {
     $log = sprintf("Error: Cannot open lock file %s for writing\n", $lockFile);
     criticalAndPrint($log);
     exit(2);
 }
 
 foreach ($DATASOURCES as $k => $v) {
     if (strlen($v["normalizedField"] and !$v["skipNormalize"])) {
         $b = time();
         $class_name = $v["class"];
 
         unset($CDRS);
         $CDRS = new $class_name($k);
 
 
         if (is_array($CDRS->db_class)) {
             $db_class = $CDRS->db_class[0];
         } else {
             $db_class = $CDRS->db_class;
         }
 
         if ($table) $CDRS->table = $table;
 
         $log = sprintf("Normalize datasource %s, database %s, table %s\n", $k, $db_class, $CDRS->table);
         loggerAndPrint($log);
 
         $CDRS->NormalizeCDRS();
 
         $e = time();
         $d = $e - $b;
 
         if ($CDRS->status['cdr_to_normalize']) {
             $speed = 0;
             if ($d) $speed = number_format($CDRS->status['cdr_to_normalize']/$d, 0, "", "");
             $log = sprintf(
                 " CDR normalize: %6d new, %6d done, %6d minutes, %6.1f price, %d seconds, %s cps\n",
                 $CDRS->status['cdr_to_normalize'],
                 $CDRS->status['normalized'],
                 $CDRS->status['duration']/60,
                 $CDRS->status['price'],
                 $d,
                 $speed
             );
             loggerAndPrint($log);
         }
 
         if (!$table && preg_match("/^(\w+)\d{6}$/", $CDRS->table, $m)) {
             $lastMonthTable=$m[1].date('Ym', mktime(0, 0, 0, date("m")-1, "01", date("Y")));
 
             $log = sprintf("Normalize datasource %s, database %s, table %s\n", $k, $db_class, $lastMonthTable);
             loggerAndPrint($log);
 
             $b = time();
 
             $CDRS->table = $lastMonthTable;
             $CDRS->NormalizeCDRS();
 
             if ($CDRS->status['cdr_to_normalize']) {
                 $e = time();
                 $d = $e - $b;
 
                 $speed = 0;
                 if ($d) $speed = number_format($CDRS->status['cdr_to_normalize']/$d, 0, "", "");
                 $log = sprintf(
                     " %d CDRs, %d normalized in %s s @ %s cps\n",
                     $CDRS->status['cdr_to_normalize'],
                     $CDRS->status['normalized'],
                     $d,
                     $speed
                 );
                 loggerAndPrint($log);
             }
         }
     }
 }
 
 keepAliveRatingEngine();