BlockStorage/repertory-js
1
0
Fork 0
Code Issues Pull Requests Projects Releases Activity

increased r/w buffer size

Browse Source
This commit is contained in:
sgraves76
2025-02-14 07:05:50 -06:00
parent 63a49389f2
commit a846223777
3 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
.cspell/words.txt
View File

@@ -1 +1,2 @@
blockstorage blockstorage
uuidv4

5
src/ops/index.js
View File

@@ -3,6 +3,7 @@ import { Uint64BE } from 'int64-buffer';
import file from '../io/file'; import file from '../io/file';
import packet from '../networking/packet'; import packet from '../networking/packet';
import { RW_BUFFER_SIZE } from '../utils/constants';
const _snapshot_directory = async (conn, remote_path) => { const _snapshot_directory = async (conn, remote_path) => {
try { try {
@@ -218,7 +219,7 @@ export const download_file = async (
let remain = src_size - offset; let remain = src_size - offset;
while (remain > 0) { while (remain > 0) {
const to_write = remain >= 65536 ? 65536 : remain; const to_write = remain >= RW_BUFFER_SIZE ? RW_BUFFER_SIZE : remain;
const buffer = await src.read(offset, to_write); const buffer = await src.read(offset, to_write);
const written = fs.writeSync(dst_fd, buffer, 0, to_write, offset); const written = fs.writeSync(dst_fd, buffer, 0, to_write, offset);
if (written > 0) { if (written > 0) {
@@ -531,7 +532,7 @@ export const upload_file = async (
} }
let remain = src_st.size - offset; let remain = src_st.size - offset;
const default_buffer = Buffer.alloc(65536 * 2); const default_buffer = Buffer.alloc(RW_BUFFER_SIZE);
while (remain > 0) { while (remain > 0) {
const to_write = const to_write =
remain >= default_buffer.length ? default_buffer.length : remain; remain >= default_buffer.length ? default_buffer.length : remain;

1
src/utils/constants.js
View File

@@ -14,3 +14,4 @@ export const setCustomEncryption = (ce) => {
export const instance_id = uuidv4(); export const instance_id = uuidv4();
export const package_json = _package_json; export const package_json = _package_json;
export const get_version = () => _package_json.version; export const get_version = () => _package_json.version;
export const RW_BUFFER_SIZE = 1024 * 1024;