CEC-5431: increase concurrency (#487)

* increase concurrency

* fix unmounted component leak

src/components/BulkActions/actions/Cancel.jsx

@@ -14,7 +14,7 @@ export default forwardRef(({
   useImperativeHandle(ref, () => ({
     async submit() {
       return new Promise((resolve, reject) => {
-        const taskRunner = new TaskRunner(5, ids.length);
+        const taskRunner = new TaskRunner(30, ids.length);
         let errorCount = 0;
 
         const task = (id, index) => {

src/components/BulkActions/actions/Diagnostic.jsx

@@ -18,7 +18,7 @@ const commands = [
 
 async function getECUsByVINs(vins, token) {
   return new Promise((resolve, reject) => {
-    const taskRunner = new TaskRunner(10, vins.length);
+    const taskRunner = new TaskRunner(30, vins.length);
 
     const task = (vin) => {
       return async () => api.getECUs({ vin, unique: true }, token)

src/components/BulkActions/actions/Redeploy.jsx

@@ -14,7 +14,7 @@ export default forwardRef(({
   useImperativeHandle(ref, () => ({
     async submit() {
       return new Promise((resolve, reject) => {
-        const taskRunner = new TaskRunner(5, ids.length);
+        const taskRunner = new TaskRunner(30, ids.length);
         let errorCount = 0;
 
         const task = (id, index) => {

src/components/BulkActions/actions/SendSMS.jsx

@@ -23,7 +23,7 @@ export default forwardRef(({
   useImperativeHandle(ref, () => ({
     async submit() {
       return new Promise((resolve) => {
-        const taskRunner = new TaskRunner(5, ids.length);
+        const taskRunner = new TaskRunner(30, ids.length);
 
         ids.forEach((vin) => {
           taskRunner.push(async () => {

src/components/BulkActions/actions/UpdateConfig.jsx

@@ -20,7 +20,7 @@ export default forwardRef(({
   useImperativeHandle(ref, () => ({
     async submit() {
       return new Promise((resolve, reject) => {
-        const taskRunner = new TaskRunner(5, ids.length);
+        const taskRunner = new TaskRunner(30, ids.length);
         let errorCount = 0;
 
         const task = (vin, index) => {

src/components/Fleets/Status/Vehicles/Table/index.jsx

@@ -12,7 +12,7 @@ import {
 } from "@material-ui/core";
 import AddCircleIcon from "@material-ui/icons/AddCircle";
 import clsx from "clsx";
-import React, { useEffect, useState } from "react";
+import React, { useEffect, useState, useRef } from "react";
 import { Link } from "react-router-dom";
 
 import { logger } from "../../../../../services/monitoring";
@@ -70,6 +70,7 @@ const MainForm = ({ name }) => {
   const [order, setOrder] = useState("desc");
   const [search, setSearch] = useState("");
   const [selected, setSelected] = useState([]);
+  const componentMounted = useRef(true);
   const classes = useStyles();
   const { setMessage } = useStatusContext();
   const {
@@ -103,7 +104,9 @@ const MainForm = ({ name }) => {
           },
           token
         );
-        watchFleetVehicles.start({ token });
+        if (componentMounted.current) {
+          watchFleetVehicles.start({ token });
+        }
       } catch (e) {
         setMessage(e.message);
         logger.warn(e.stack);
@@ -111,6 +114,7 @@ const MainForm = ({ name }) => {
       }
     })();
     return () => {
+      componentMounted.current = false;
       watchFleetVehicles.end();
     }
     // eslint-disable-next-line react-hooks/exhaustive-deps

src/hooks/useUpdateManifest.js

@@ -8,7 +8,7 @@ export const useUpdateManifest = (token) => {
 
   const remove = async () => {
     return new Promise((resolve) => {
-      const taskRunner = new TaskRunner(5, updateManifestIds.length);
+      const taskRunner = new TaskRunner(30, updateManifestIds.length);
       let errorCount = 0;
 
       const task = (id) => {