archive-gh-me/thinkjs
1
0
Fork 0
mirror of https://github.com/thinkjs/thinkjs.git synced 2026-01-25 14:42:47 +00:00
Code Issues Projects Releases Wiki Activity

Try 3 times when can not get file content

Browse Source
This commit is contained in:
welefen 2016-11-02 15:57:19 +08:00
parent 0a08cff83f
commit ffb4123bb4
1 changed files with 10 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
src/adapter/store/file.js
View File

@ -3,12 +3,6 @@
import fs from 'fs';
import path from 'path';
/**
* lock files
* @type {Object}
*/
let lockFiles = {};
/**
* file store class
*/
@ -44,14 +38,18 @@ export default class extends think.adapter.base {
* @param {String} key []
* @return {Promise} []
*/
async get(key){
get(key, times = 1){
let filePath = this.getFilePath(key);
if(!think.isFile(filePath)){
if(times === 1 && !think.isFile(filePath)){
return Promise.resolve();
}
await lockFiles[filePath];
return think.promisify(fs.readFile, fs)(filePath, {encoding: 'utf8'});
// try 3 times when can not get file content
return think.promisify(fs.readFile, fs)(filePath, {encoding: 'utf8'}).then(content => {
if(!content && times <= 3){
return this.get(key, times + 1);
}
return content;
});
}
/**
* set file content
@ -63,12 +61,9 @@ export default class extends think.adapter.base {
think.mkdir(path.dirname(filePath));
let fn = think.promisify(fs.writeFile, fs);
let promise = fn(filePath, content).then(() => {
return fn(filePath, content).then(() => {
think.chmod(filePath);
delete lockFiles[filePath];
});
lockFiles[filePath] = promise;
return promise;
}
/**
* delete file