repositories
/
e-mobility-charging-stations-simulator.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge pull request #813 from SAP/combined-prs-branch
[e-mobility-charging-stations-simulator.git]
/
src
/
charging-station
/
ChargingStationWorker.ts
diff --git
a/src/charging-station/ChargingStationWorker.ts
b/src/charging-station/ChargingStationWorker.ts
index db7ae2cb4462ff79f50359dc989b50536a73edd6..6201bf07e2b52fe7e6d1931412da74e89043717c 100644
(file)
--- a/
src/charging-station/ChargingStationWorker.ts
+++ b/
src/charging-station/ChargingStationWorker.ts
@@
-6,9
+6,10
@@
import { parentPort } from 'node:worker_threads';
import { ThreadWorker } from 'poolifier';
import { ChargingStation } from './ChargingStation';
import { ThreadWorker } from 'poolifier';
import { ChargingStation } from './ChargingStation';
+import { BaseError } from '../exception';
import type { ChargingStationWorkerData } from '../types';
import { Configuration } from '../utils';
import type { ChargingStationWorkerData } from '../types';
import { Configuration } from '../utils';
-import {
WorkerConstants,
type WorkerMessage, WorkerMessageEvents } from '../worker';
+import { type WorkerMessage, WorkerMessageEvents } from '../worker';
const moduleName = 'ChargingStationWorker';
const moduleName = 'ChargingStationWorker';
@@
-48,10
+49,10
@@
class ChargingStationWorker extends AsyncResource {
}
break;
default:
}
break;
default:
- throw new Error(
+ throw new
Base
Error(
`Unknown worker event: '${message.event}' received with data: '${JSON.stringify(
message.data,
`Unknown worker event: '${message.event}' received with data: '${JSON.stringify(
message.data,
-
null
,
+
undefined
,
2,
)}'`,
);
2,
)}'`,
);
@@
-62,9
+63,7
@@
class ChargingStationWorker extends AsyncResource {
export let chargingStationWorker: ChargingStationWorker | ThreadWorker<ChargingStationWorkerData>;
if (Configuration.workerPoolInUse()) {
export let chargingStationWorker: ChargingStationWorker | ThreadWorker<ChargingStationWorkerData>;
if (Configuration.workerPoolInUse()) {
- chargingStationWorker = new ThreadWorker<ChargingStationWorkerData>(startChargingStation, {
- maxInactiveTime: WorkerConstants.POOL_MAX_INACTIVE_TIME,
- });
+ chargingStationWorker = new ThreadWorker<ChargingStationWorkerData>(startChargingStation);
} else {
chargingStationWorker = new ChargingStationWorker();
}
} else {
chargingStationWorker = new ChargingStationWorker();
}