public_git
/
democratic-csi
mirror of https://github.com/democratic-csi/democratic-csi.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

more create race condition logic for iscsi

This commit is contained in:
Travis Glenn Hansen 2020-12-01 00:04:29 -07:00
parent 2a6590335c
commit 716cde8f29
1 changed files with 30 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
src/driver/freenas/index.js
View File

@ -655,6 +655,13 @@ class FreeNASDriver extends ControllerZfsSshBaseDriver {
); );
} }
if (target.iscsi_target_name != iscsiName) {
throw new GrpcError(
grpc.status.UNKNOWN,
`mismatch name error creating iscsi target`
);
}
this.ctx.logger.verbose("FreeNAS ISCSI TARGET: %j", target); this.ctx.logger.verbose("FreeNAS ISCSI TARGET: %j", target);
// set target.id on zvol // set target.id on zvol
@ -791,6 +798,14 @@ class FreeNASDriver extends ControllerZfsSshBaseDriver {
`unknown error creating iscsi extent` `unknown error creating iscsi extent`
); );
} }
if (extent.iscsi_target_extent_name != iscsiName) {
throw new GrpcError(
grpc.status.UNKNOWN,
`mismatch name error creating iscsi extent`
);
}
this.ctx.logger.verbose("FreeNAS ISCSI EXTENT: %j", extent); this.ctx.logger.verbose("FreeNAS ISCSI EXTENT: %j", extent);
await zb.zfs.set(datasetName, { await zb.zfs.set(datasetName, {
@ -933,6 +948,13 @@ class FreeNASDriver extends ControllerZfsSshBaseDriver {
); );
} }
if (target.name != iscsiName) {
throw new GrpcError(
grpc.status.UNKNOWN,
`mismatch name error creating iscsi target`
);
}
this.ctx.logger.verbose("FreeNAS ISCSI TARGET: %j", target); this.ctx.logger.verbose("FreeNAS ISCSI TARGET: %j", target);
// set target.id on zvol // set target.id on zvol
@ -987,6 +1009,14 @@ class FreeNASDriver extends ControllerZfsSshBaseDriver {
`unknown error creating iscsi extent` `unknown error creating iscsi extent`
); );
} }
if (extent.name != iscsiName) {
throw new GrpcError(
grpc.status.UNKNOWN,
`mismatch name error creating iscsi extent`
);
}
this.ctx.logger.verbose("FreeNAS ISCSI EXTENT: %j", extent); this.ctx.logger.verbose("FreeNAS ISCSI EXTENT: %j", extent);
await zb.zfs.set(datasetName, { await zb.zfs.set(datasetName, {