github_mirrors/puter
1
0
Fork 0
mirror of https://github.com/HeyPuter/puter.git synced 2025-01-24 15:20:21 +08:00
Code Issues Packages Projects Releases Wiki Activity

dev: track ll_readshares depth

Browse Source
This commit is contained in:
KernelDeimos 2024-11-13 21:14:56 -05:00
parent 249dc06201
commit caf8d2a055
1 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/backend/src/filesystem/ll_operations/ll_readshares.js
View File

@ -33,12 +33,13 @@ class LLReadShares extends LLFilesystemOperation {
async _run () { async _run () {
const results = []; const results = [];
await this.recursive_part(results, this.values); const stats = await this.recursive_part(results, this.values);
// console.log('LL_READ_SHARES_STATS !!!!!', stats);
return results; return results;
} }
async recursive_part (results, { subject, user, actor }) { async recursive_part (results, { subject, user, actor, depth = 0 }) {
actor = actor || Context.get('actor'); actor = actor || Context.get('actor');
const ll_readdir = new LLReadDir(); const ll_readdir = new LLReadDir();
const children = await ll_readdir.run({ const children = await ll_readdir.run({
@ -73,11 +74,15 @@ class LLReadShares extends LLFilesystemOperation {
} }
const p = this.recursive_part(results, { const p = this.recursive_part(results, {
subject: child, user }); subject: child,
user,
depth: depth + 1,
});
promises.push(p); promises.push(p);
} }
await Promise.all(promises); const stats = await Promise.all(promises);
return Math.max(depth, ...stats);
} }
} }