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

remove unecessary copy process for snapshot list 

Signed-off-by: Travis Glenn Hansen <travisghansen@yahoo.com>
This commit is contained in:
Travis Glenn Hansen 2021-12-11 18:30:21 -07:00
parent 3f86565292
commit 8273af7650
2 changed files with 2 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/driver/controller-zfs-ssh/index.js
View File

@ -1,4 +1,3 @@
const _ = require("lodash");
const { CsiBaseDriver } = require("../index"); const { CsiBaseDriver } = require("../index");
const SshClient = require("../../utils/ssh").SshClient; const SshClient = require("../../utils/ssh").SshClient;
const { GrpcError, grpc } = require("../../utils/grpc"); const { GrpcError, grpc } = require("../../utils/grpc");
@ -1710,7 +1709,6 @@ class ControllerZfsSshBaseDriver extends CsiBaseDriver {
} }
entries = this.ctx.cache.get(`ListSnapshots:result:${uuid}`); entries = this.ctx.cache.get(`ListSnapshots:result:${uuid}`);
if (entries) { if (entries) {
entries = _.cloneDeep(entries);
entries_length = entries.length; entries_length = entries.length;
entries = entries.slice(start_position, end_position); entries = entries.slice(start_position, end_position);
if (max_entries > 0 && end_position > entries_length) { if (max_entries > 0 && end_position > entries_length) {
@ -1918,7 +1916,7 @@ class ControllerZfsSshBaseDriver extends CsiBaseDriver {
if (max_entries && entries.length > max_entries) { if (max_entries && entries.length > max_entries) {
uuid = uuidv4(); uuid = uuidv4();
this.ctx.cache.set(`ListSnapshots:result:${uuid}`, _.cloneDeep(entries)); this.ctx.cache.set(`ListSnapshots:result:${uuid}`, entries);
next_token = `${uuid}:${max_entries}`; next_token = `${uuid}:${max_entries}`;
entries = entries.slice(0, max_entries); entries = entries.slice(0, max_entries);
} }

4
src/driver/freenas/api.js
View File

@ -1,4 +1,3 @@
const _ = require("lodash");
const { GrpcError, grpc } = require("../../utils/grpc"); const { GrpcError, grpc } = require("../../utils/grpc");
const { CsiBaseDriver } = require("../index"); const { CsiBaseDriver } = require("../index");
const HttpClient = require("./http").Client; const HttpClient = require("./http").Client;
@ -3272,7 +3271,6 @@ class FreeNASApiDriver extends CsiBaseDriver {
} }
entries = this.ctx.cache.get(`ListSnapshots:result:${uuid}`); entries = this.ctx.cache.get(`ListSnapshots:result:${uuid}`);
if (entries) { if (entries) {
entries = _.cloneDeep(entries);
entries_length = entries.length; entries_length = entries.length;
entries = entries.slice(start_position, end_position); entries = entries.slice(start_position, end_position);
if (max_entries > 0 && end_position > entries_length) { if (max_entries > 0 && end_position > entries_length) {
@ -3638,7 +3636,7 @@ class FreeNASApiDriver extends CsiBaseDriver {
if (max_entries && entries.length > max_entries) { if (max_entries && entries.length > max_entries) {
uuid = uuidv4(); uuid = uuidv4();
this.ctx.cache.set(`ListSnapshots:result:${uuid}`, _.cloneDeep(entries)); this.ctx.cache.set(`ListSnapshots:result:${uuid}`, entries);
next_token = `${uuid}:${max_entries}`; next_token = `${uuid}:${max_entries}`;
entries = entries.slice(0, max_entries); entries = entries.slice(0, max_entries);
} }