#define MFI_1068_FW_HANDSHAKE_OFFSET           0x64
 #define MFI_1068_FW_READY                      0xDDDD0000
 
+#define MEGASAS_RAID1_FAST_PATH_STATUS_CHECK_INTERVAL HZ
+
 #define MR_MAX_REPLY_QUEUES_OFFSET              0X0000001F
 #define MR_MAX_REPLY_QUEUES_EXT_OFFSET          0X003FC000
 #define MR_MAX_REPLY_QUEUES_EXT_OFFSET_SHIFT    14
        atomic_t ldio_outstanding;
        atomic_t fw_reset_no_pci_access;
 
+       atomic64_t bytes_wrote; /* used for raid1 fast path enable or disable */
+       atomic_t r1_write_fp_capable;
+
+
        struct megasas_instance_template *instancet;
        struct tasklet_struct isr_tasklet;
        struct work_struct work_init;
        long reset_flags;
        struct mutex reset_mutex;
        struct timer_list sriov_heartbeat_timer;
+       struct timer_list r1_fp_hold_timer;
        char skip_heartbeat_timer_del;
        u8 requestorId;
        char PlasmaFW111;
        bool is_ventura;
        bool msix_combined;
        u16 max_raid_mapsize;
+       u64 pci_threshold_bandwidth; /* used to control the fp writes */
 };
 struct MR_LD_VF_MAP {
        u32 size;
 
        }
        /* Complete outstanding ioctls when adapter is killed */
        megasas_complete_outstanding_ioctls(instance);
+       if (instance->is_ventura)
+               del_timer_sync(&instance->r1_fp_hold_timer);
+
 }
 
  /**
        }
 }
 
+/*Handler for disabling/enabling raid 1 fast paths*/
+void megasas_change_r1_fp_status(unsigned long instance_addr)
+{
+       struct megasas_instance *instance =
+                       (struct megasas_instance *)instance_addr;
+       if (atomic64_read(&instance->bytes_wrote) >=
+                                       instance->pci_threshold_bandwidth) {
+
+               atomic64_set(&instance->bytes_wrote, 0);
+               atomic_set(&instance->r1_write_fp_capable, 0);
+       } else {
+               atomic64_set(&instance->bytes_wrote, 0);
+               atomic_set(&instance->r1_write_fp_capable, 1);
+       }
+       mod_timer(&instance->r1_fp_hold_timer,
+        jiffies + MEGASAS_RAID1_FAST_PATH_STATUS_CHECK_INTERVAL);
+}
+
 /**
  * megasas_wait_for_outstanding -      Wait for all outstanding cmds
  * @instance:                          Adapter soft state
                        instance->skip_heartbeat_timer_del = 1;
        }
 
+       if (instance->is_ventura) {
+               atomic64_set(&instance->bytes_wrote, 0);
+               atomic_set(&instance->r1_write_fp_capable, 1);
+               megasas_start_timer(instance,
+                           &instance->r1_fp_hold_timer,
+                           megasas_change_r1_fp_status,
+                           MEGASAS_RAID1_FAST_PATH_STATUS_CHECK_INTERVAL);
+                               dev_info(&instance->pdev->dev, "starting the raid 1 fp timer with interval %d\n",
+                               MEGASAS_RAID1_FAST_PATH_STATUS_CHECK_INTERVAL);
+       }
+
        return 0;
 
 fail_get_ld_pd_list:
        if (instance->requestorId && !instance->skip_heartbeat_timer_del)
                del_timer_sync(&instance->sriov_heartbeat_timer);
 
+       if (instance->is_ventura)
+               del_timer_sync(&instance->r1_fp_hold_timer);
+
        megasas_flush_cache(instance);
        megasas_shutdown_controller(instance, MR_DCMD_HIBERNATE_SHUTDOWN);
 
        megasas_setup_jbod_map(instance);
        instance->unload = 0;
 
+       if (instance->is_ventura) {
+               atomic64_set(&instance->bytes_wrote, 0);
+               atomic_set(&instance->r1_write_fp_capable, 1);
+               megasas_start_timer(instance,
+                           &instance->r1_fp_hold_timer,
+                           megasas_change_r1_fp_status,
+                           MEGASAS_RAID1_FAST_PATH_STATUS_CHECK_INTERVAL);
+       }
+
+
        /*
         * Initiate AEN (Asynchronous Event Notification)
         */
        if (instance->requestorId && !instance->skip_heartbeat_timer_del)
                del_timer_sync(&instance->sriov_heartbeat_timer);
 
+       if (instance->is_ventura)
+               del_timer_sync(&instance->r1_fp_hold_timer);
+
        if (instance->fw_crash_state != UNAVAILABLE)
                megasas_free_host_crash_buffer(instance);
        scsi_remove_host(instance->host);
 
 
        if (instance->max_raid_mapsize) {
                fw_map_dyn = fusion->ld_map[(instance->map_id & 1)];
+               if (fw_map_dyn->pci_threshold_bandwidth)
+                       instance->pci_threshold_bandwidth =
+                       le64_to_cpu(fw_map_dyn->pci_threshold_bandwidth);
 #if VD_EXT_DEBUG
                dev_dbg(&instance->pdev->dev, "raidMapSize 0x%x fw_map_dyn->descTableOffset 0x%x\n",
                        le32_to_cpu(fw_map_dyn->raid_map_size),
                dev_dbg(&instance->pdev->dev, "descTableSize 0x%x descTableNumElements 0x%x\n",
                        le32_to_cpu(fw_map_dyn->desc_table_size),
                        le32_to_cpu(fw_map_dyn->desc_table_num_elements));
+               dev_dbg(&instance->pdev->dev, "PCIThreasholdBandwidth %llu\n",
+                       instance->pci_threshold_bandwidth);
                dev_dbg(&instance->pdev->dev, "drv map %p ldCount %d\n",
                        drv_map, fw_map_dyn->ld_count);
 #endif
                        sizeof(struct MR_DEV_HANDLE_INFO) *
                        MAX_RAIDMAP_PHYSICAL_DEVICES);
        }
+       if (instance->is_ventura && !instance->pci_threshold_bandwidth)
+               instance->pci_threshold_bandwidth = ULLONG_MAX;
 }
 
 /*
 
 extern unsigned int dual_qdepth_disable;
 static void megasas_free_rdpq_fusion(struct megasas_instance *instance);
 static void megasas_free_reply_fusion(struct megasas_instance *instance);
+void megasas_change_r1_fp_status(unsigned long instance_addr);
 
 
 
         *      to get new command
         */
        if (cmd->is_raid_1_fp_write &&
-               atomic_inc_return(&instance->fw_outstanding) >
-                       (instance->host->can_queue)) {
+               (atomic_inc_return(&instance->fw_outstanding) >
+                       (instance->host->can_queue) ||
+               (!atomic_read(&instance->r1_write_fp_capable)))) {
                megasas_fpio_to_ldio(instance, cmd, cmd->scmd);
                atomic_dec(&instance->fw_outstanding);
        } else if (cmd->is_raid_1_fp_write) {
                megasas_prepare_secondRaid1_IO(instance, cmd, r1_cmd);
        }
 
-
        /*
         * Issue the command to the FW
         */
+       if (scmd->sc_data_direction == PCI_DMA_TODEVICE && instance->is_ventura)
+               atomic64_add(scsi_bufflen(scmd), &instance->bytes_wrote);
 
        megasas_fire_cmd_fusion(instance, req_desc, instance->is_ventura);
 
-       if (r1_cmd)
+       if (r1_cmd) {
+               atomic64_add(scsi_bufflen(scmd), &instance->bytes_wrote);
                megasas_fire_cmd_fusion(instance, r1_cmd->request_desc,
-                               instance->is_ventura);
-
+                       instance->is_ventura);
+       }
 
        return 0;
 }
 
        u32 desc_table_size;  /* Total Size of desc table */
        /* Total Number of elements in the desc table */
        u32 desc_table_num_elements;
-       u64     reserved1;
+       u64     pci_threshold_bandwidth;
        u32     reserved2[3];   /*future use */
        /* timeout value used by driver in FP IOs */
        u8 fp_pd_io_timeout_sec;