File tree Expand file tree Collapse file tree 3 files changed +40
-1
lines changed Expand file tree Collapse file tree 3 files changed +40
-1
lines changed Original file line number Diff line number Diff line change 11{
22 "name" : " cos-nodejs-sdk-v5" ,
3- "version" : " 2.11.19 " ,
3+ "version" : " 2.11.20 " ,
44 "description" : " cos nodejs sdk v5" ,
55 "main" : " index.js" ,
66 "types" : " index.d.ts" ,
Original file line number Diff line number Diff line change @@ -88,6 +88,7 @@ function sliceUploadFile(params, callback) {
8888 AsyncLimit : AsyncLimit ,
8989 ServerSideEncryption : ServerSideEncryption ,
9090 UploadData : UploadData ,
91+ Headers : params . Headers ,
9192 onProgress : onProgress
9293 } , function ( err , data ) {
9394 if ( ! self . _isRunningTask ( TaskId ) ) return ;
@@ -537,6 +538,7 @@ function uploadSliceList(params, cb) {
537538 ServerSideEncryption : ServerSideEncryption ,
538539 FilePath : FilePath ,
539540 UploadData : UploadData ,
541+ Headers : params . Headers ,
540542 onProgress : function ( data ) {
541543 FinishSize += data . loaded - preAddSize ;
542544 preAddSize = data . loaded ;
Original file line number Diff line number Diff line change @@ -782,6 +782,43 @@ group('sliceUploadFile() 完整上传文件', function () {
782782 fs . rmSync ( filePath ) ;
783783 } , 1000 ) ;
784784 } ) ;
785+ test ( 'sliceUploadFile() 上传过程中本地文件修改' , function ( done , assert ) {
786+ var filename = '30mb.zip' ;
787+ var filePath = createFileSync ( path . resolve ( __dirname , filename ) , 1024 * 1024 * 30 ) ;
788+ var taskId ;
789+ cos . sliceUploadFile ( {
790+ Bucket : config . Bucket ,
791+ Region : config . Region ,
792+ Key : filename ,
793+ FilePath : filePath ,
794+ onTaskReady : function ( id ) {
795+ taskId = id ;
796+ }
797+ } , function ( err , data ) {
798+ assert ( err ) ;
799+ done ( ) ;
800+ } ) ;
801+ setTimeout ( ( ) => {
802+ cos . pauseTask ( id ) ;
803+ cos . sliceUploadFile ( {
804+ Bucket : config . Bucket ,
805+ Region : config . Region ,
806+ Key : filename ,
807+ FilePath : filePath ,
808+ onTaskReady : function ( id ) {
809+ taskId = id ;
810+ }
811+ } , function ( err , data ) {
812+ assert ( err ) ;
813+ done ( ) ;
814+ } ) ;
815+ // 2秒后修改文件内容
816+ setTimeout ( ( ) => {
817+ const fd = fs . openSync ( filePath , "r+" ) ;
818+ fs . writeSync ( fd , 'test' , 10240 , 'utf8' ) ;
819+ } , 2000 ) ;
820+ } , 2000 ) ;
821+ } ) ;
785822} ) ;
786823
787824group ( 'abortUploadTask()' , function ( ) {
You can’t perform that action at this time.
0 commit comments