!9358 Add XTS for fs.Watcher interface

Merge pull request !9358 from 冯俊青/master

storage/storagefileiov9jstest/src/main/js/test/Common.js

@@ -83,6 +83,13 @@ export function randomString(num) {
   return pwd;
 }
 
+export async function sleep(times) {
+  if (!times) {
+      times = 10;
+  }
+  await new Promise((res) => setTimeout(res, times));
+}
+
 function isIntNum(val) {
   return typeof val === 'number' && val % 1 === 0;
 }

storage/storagefileiov9jstest/src/main/js/test/List.test.js

@@ -47,6 +47,7 @@ import fileIOStreamWrite from './class_stream/write.test.js'
 import fileIOSymlink from './members/symlink.test.js'
 import fileIOTruncate from './members/truncate.test.js'
 import fileIOUnlink from './members/unlink.test.js'
+import fileIOWatcher from './members/watcher.test.js'
 import fileIOWrite from './members/write.test.js'
 import fileIORW from './members/filerw.test.js'
 export default function testsuite() {
@@ -84,6 +85,7 @@ export default function testsuite() {
     fileIOSymlink()
     fileIOTruncate()
     fileIOUnlink()
+    fileIOWatcher()
     fileIOWrite()
     fileIORW()
 }

storage/storagefileiov9jstest/src/main/js/test/members/mkdir.test.js

@@ -224,9 +224,10 @@ describe('fileIO_fs_mkdir', function () {
     expect(prepareFile(fpath, FILE_CONTENT)).assertTrue();
 
     try {
-      await fileIO.mkdirSync(fpath);
+      await fileIO.mkdir(fpath);
       expect(false).assertTrue();
     } catch (e) {
+      fileIO.unlinkSync(fpath);
       console.log('fileIO_test_mkdir_async_004 has failed for ' + e.message + ', code: ' + e.code);
       expect(e.code == 13900015 && e.message == 'File exists').assertTrue();
     }

storage/storagefileiov9jstest/src/main/js/test/members/watcher.test.js

+/*
+ * Copyright (C) 2023 Huawei Device Co., Ltd.
+ * Licensed under the Apache License, Version 2.0 (the 'License');
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an 'AS IS' BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import fileio from '@ohos.fileio';
+import {
+  fileIO, FILE_CONTENT, prepareFile, sleep, nextFileName,
+  describe, it, expect,
+} from '../Common';
+
+  const WAIT_HALF_SECOND = 500;
+  const watcherEvent = {
+    'IN_ACCESS': 0x00000001,
+    'IN_MODIFY': 0x00000002,
+    'IN_ATTRIB': 0x00000004,
+    'IN_CLOSE_WRITE': 0x00000008,
+    'IN_CLOSE_NOWRITE': 0x00000010,
+    'IN_OPEN': 0x00000020,
+    'IN_MOVED_FROM': 0x00000040,
+    'IN_MOVED_TO': 0x00000080,
+    'IN_CREATE': 0x00000100,
+    'IN_DELETE': 0x00000200,
+    'IN_DELETE_SELF': 0x00000400,
+    'IN_MOVE_SELF': 0x00000800,
+    'IN_ISDIR': 0x40000000
+  }
+
+  const callback = (data) => {
+    console.log(`The watcher is triggered :{event: ${data.event}, fileName: ${data.fileName}, cookie:${data.cookie}}`);
+  }
+
+  function startWatcher(testNum, eventCode, watchPath) {
+    let ret = {
+      flag: false,
+      watcher: null
+    }
+    try {
+    ret.watcher = fileIO.createWatcher(watchPath, eventCode, (data) => {
+      console.log(`${testNum} :{event: ${data.event}, fileName: ${data.fileName}, cookie: ${data.cookie}}`);
+        if (eventCode === data.event) {
+          ret.flag = true;
+        }
+      });
+    } catch (e) {
+      console.log(testNum + ' startWatcher failed for ' + e.message + ', code: ' + e.code);
+    }
+    ret.watcher.start();
+    return ret;
+  }
+
+export default function fileIOWatcher() {
+  describe('fileIO_test_watcher', function () {
+  /**
+   * @tc.number SUB_DF_FILEIO_WATCHER_0000
+   * @tc.name fileIO_test_watcher_000
+   * @tc.desc Create multiple watcher events in multi-level directories.
+   * @tc.size MEDIUM
+   * @tc.type Function
+   * @tc.level Level 3
+   * @tc.require
+   */
+  it('fileIO_test_watcher_000', 3, async function (done) {
+    let testNum = 'fileIO_test_watcher_000';
+    let dpath = await nextFileName(testNum);
+    let fpath = dpath + '/file_000';
+    let ddpath = dpath + '/dir_000';
+    let ffpath = ddpath + '/file_000_1';
+    let dddpath = ddpath + '/dir_000_1';
+    let fffpath = dddpath + '/file_000_2';
+    fileIO.mkdirSync(dpath);
+    fileIO.mkdirSync(ddpath);
+    fileIO.mkdirSync(dddpath);
+    expect(prepareFile(fpath, FILE_CONTENT)).assertTrue();
+    expect(prepareFile(ffpath, FILE_CONTENT)).assertTrue();
+
+    try {
+      let resWatcher = [];
+      let file1 = fileIO.openSync(fpath, fileIO.OpenMode.WRITE_ONLY);
+      let file2 = fileIO.openSync(ffpath, fileIO.OpenMode.READ_ONLY);
+      resWatcher[0] = startWatcher(testNum, watcherEvent.IN_MODIFY, dpath);
+      resWatcher[1] = startWatcher(testNum, watcherEvent.IN_ACCESS, ddpath);
+      resWatcher[2] = startWatcher(testNum, watcherEvent.IN_CREATE, dddpath);
+      let file3 = fileIO.openSync(fffpath, fileIO.OpenMode.CREATE);
+      await sleep(WAIT_HALF_SECOND);
+      expect(resWatcher[2].flag == true).assertTrue();
+      fileIO.readSync(file2.fd, new ArrayBuffer(20));
+      await sleep(WAIT_HALF_SECOND);
+      expect(resWatcher[1].flag == true).assertTrue();
+      fileIO.writeSync(file1.fd, FILE_CONTENT);
+      await sleep(WAIT_HALF_SECOND);
+      expect(resWatcher[0].flag == true).assertTrue();
+      resWatcher.forEach(element => { element.watcher.stop(); });
+      fileIO.closeSync(file3);
+      fileIO.closeSync(file2);
+      fileIO.closeSync(file1);
+      fileIO.rmdirSync(dpath);
+      done();
+    } catch (e) {
+      console.log(testNum + ' has failed for ' + e.message + ', code: ' + e.code);
+      expect(false).assertTrue();
+    }
+  });
+
+  /**
+   * @tc.number SUB_DF_FILEIO_WATCHER_0100
+   * @tc.name fileIO_test_watcher_001
+   * @tc.desc Test watcher event '0x00000001': 'IN_ACCESS'
+   *    read a file, verifying the event is 'IN_ACCESS'.
+   * @tc.size MEDIUM
+   * @tc.type Function
+   * @tc.level Level 0
+   * @tc.require
+   */
+  it('fileIO_test_watcher_001', 0, async function (done) {
+    let testNum = 'fileIO_test_watcher_001';
+    let dpath = await nextFileName(testNum);
+    let fpath = dpath + '/file_001.txt';
+    fileIO.mkdirSync(dpath);
+    expect(prepareFile(fpath, FILE_CONTENT)).assertTrue();
+
+    try {
+      let file = fileIO.openSync(fpath, fileIO.OpenMode.READ_WRITE);
+      let resWatcher = startWatcher(testNum, watcherEvent.IN_ACCESS, dpath);
+      fileIO.readSync(file.fd, new ArrayBuffer(4096));
+      await sleep(WAIT_HALF_SECOND);
+      expect(resWatcher.flag == true).assertTrue();
+      resWatcher.watcher.stop();
+      fileIO.closeSync(file);
+      fileIO.rmdirSync(dpath);
+      done();
+    } catch (e) {
+      console.log(testNum + ' has failed for ' + e.message + ', code: ' + e.code);
+      expect(false).assertTrue();
+    }
+  });
+
+  /**
+   * @tc.number SUB_DF_FILEIO_WATCHER_0200
+   * @tc.name fileIO_test_watcher_002
+   * @tc.desc Test watcher event '0x00000002': 'IN_MODIFY'
+   *    write a file, verifying the event is 'IN_MODIFY'.
+   * @tc.size MEDIUM
+   * @tc.type Function
+   * @tc.level Level 0
+   * @tc.require
+   */
+  it('fileIO_test_watcher_002', 0, async function (done) {
+    let testNum = 'fileIO_test_watcher_002';
+    let dpath = await nextFileName(testNum);
+    let fpath = dpath + '/file_002.txt';
+    fileIO.mkdirSync(dpath);
+    expect(prepareFile(fpath, FILE_CONTENT)).assertTrue();
+
+    try {
+      let file = fileIO.openSync(fpath, fileIO.OpenMode.READ_WRITE);
+      let resWatcher = startWatcher(testNum, watcherEvent.IN_MODIFY, dpath);
+      fileIO.writeSync(file.fd, FILE_CONTENT);
+      await sleep(WAIT_HALF_SECOND);
+      expect(resWatcher.flag == true).assertTrue();
+      resWatcher.watcher.stop();
+      fileIO.closeSync(file);
+      fileIO.rmdirSync(dpath);
+      done();
+    } catch (e) {
+      console.log(testNum + ' has failed for ' + e.message + ', code: ' + e.code);
+      expect(false).assertTrue();
+    }
+  });
+
+  /**
+   * @tc.number SUB_DF_FILEIO_WATCHER_0300
+   * @tc.name fileIO_test_watcher_003
+   * @tc.desc Test watcher event '0x00000004': 'IN_ATTRIB'
+   *    chmod a file, verifying the event is 'IN_ATTRIB'.
+   * @tc.size MEDIUM
+   * @tc.type Function
+   * @tc.level Level 0
+   * @tc.require
+   */
+  it('fileIO_test_watcher_003', 0, async function (done) {
+    let testNum = 'fileIO_test_watcher_003';
+    let dpath = await nextFileName(testNum);
+    let fpath = dpath + '/file_003.txt';
+    fileIO.mkdirSync(dpath);
+    expect(prepareFile(fpath, FILE_CONTENT)).assertTrue();
+
+    try {
+      let file = fileIO.openSync(fpath, fileIO.OpenMode.READ_WRITE);
+      let resWatcher = startWatcher(testNum, watcherEvent.IN_ATTRIB, dpath);
+      fileio.fchmodSync(file.fd, 0o444);
+      await sleep(WAIT_HALF_SECOND);
+      expect(resWatcher.flag == true).assertTrue();
+      resWatcher.watcher.stop();
+      fileIO.closeSync(file);
+      fileIO.rmdirSync(dpath);
+      done();
+    } catch (e) {
+      console.log(testNum + ' has failed for ' + e.message + ', code: ' + e.code);
+      expect(false).assertTrue();
+    }
+  });
+
+  /**
+   * @tc.number SUB_DF_FILEIO_WATCHER_0400
+   * @tc.name fileIO_test_watcher_004
+   * @tc.desc Test watcher event '0x00000008': 'IN_CLOSE_WRITE'
+   *    open a file on read_write mode and then close the file.fd, verifying the event is 'IN_CLOSE_WRITE'.
+   * @tc.size MEDIUM
+   * @tc.type Function
+   * @tc.level Level 0
+   * @tc.require
+   */
+  it('fileIO_test_watcher_004', 0, async function (done) {
+    let testNum = 'fileIO_test_watcher_004';
+    let dpath = await nextFileName(testNum);
+    let fpath = dpath + '/file_004.txt';
+    fileIO.mkdirSync(dpath);
+    expect(prepareFile(fpath, FILE_CONTENT)).assertTrue();
+
+    try {
+      let file = fileIO.openSync(fpath, fileIO.OpenMode.READ_WRITE);
+      let resWatcher = startWatcher(testNum, watcherEvent.IN_CLOSE_WRITE, dpath);
+      fileIO.closeSync(file.fd);
+      await sleep(WAIT_HALF_SECOND);
+      expect(resWatcher.flag == true).assertTrue();
+      resWatcher.watcher.stop();
+      fileIO.rmdirSync(dpath);
+      done();
+    } catch (e) {
+      console.log(testNum + ' has failed for ' + e.message + ', code: ' + e.code);
+      expect(false).assertTrue();
+    }
+  });
+
+  /**
+   * @tc.number SUB_DF_FILEIO_WATCHER_0500
+   * @tc.name fileIO_test_watcher_005
+   * @tc.desc Test watcher event '0x00000020': 'IN_OPEN'
+   *    open a file on only read mode, verifying the event is 'IN_OPEN'.
+   * @tc.size MEDIUM
+   * @tc.type Function
+   * @tc.level Level 0
+   * @tc.require
+   */
+  it('fileIO_test_watcher_005', 0, async function (done) {
+    let testNum = 'fileIO_test_watcher_005';
+    let dpath = await nextFileName(testNum);
+    let fpath = dpath + '/file_005.txt';
+    fileIO.mkdirSync(dpath);
+    expect(prepareFile(fpath, FILE_CONTENT)).assertTrue();
+
+    try {
+      let resWatcher = startWatcher(testNum, watcherEvent.IN_OPEN, dpath);
+      let file = fileIO.openSync(fpath, fileIO.OpenMode.READ_ONLY);
+      await sleep(WAIT_HALF_SECOND);
+      expect(resWatcher.flag == true).assertTrue();
+      resWatcher.watcher.stop();
+      fileIO.closeSync(file);
+      fileIO.rmdirSync(dpath);
+      done();
+    } catch (e) {
+      console.log(testNum + ' has failed for ' + e.message + ', code: ' + e.code);
+      expect(false).assertTrue();
+    }
+  });
+
+  /**
+   * @tc.number SUB_DF_FILEIO_WATCHER_0600
+   * @tc.name fileIO_test_watcher_006
+   * @tc.desc Test watcher event '0x00000040': 'IN_MOVED_FROM', '0x00000080': 'IN_MOVED_TO',
+   *    rename a file, verifying the event is 'IN_MOVED_FROM' and 'IN_MOVED_TO'.
+   * @tc.size MEDIUM
+   * @tc.type Function
+   * @tc.level Level 0
+   * @tc.require
+   */
+  it('fileIO_test_watcher_006', 0, async function (done) {
+    let testNum = 'fileIO_test_watcher_006';
+    let dpath = await nextFileName(testNum);
+    let fpath = dpath + '/file_006.txt';
+    fileIO.mkdirSync(dpath);
+    expect(prepareFile(fpath, FILE_CONTENT)).assertTrue();
+
+    try {
+      let watcherFrom = 1;
+      let watcherTo = -1;
+      let watcher = fileIO.createWatcher(dpath, watcherEvent.IN_MOVED_FROM | watcherEvent.IN_MOVED_TO, (data) => {
+        console.log(`${testNum} :{event: ${data.event}, fileName: ${data.fileName}, cookie: ${data.cookie}}`);
+        if (watcherEvent.IN_MOVED_FROM === data.event) {
+          watcherFrom = data.cookie;
+        }
+        if (watcherEvent.IN_MOVED_TO === data.event) {
+          watcherTo = data.cookie;
+        }
+      });
+      watcher.start();
+      fileIO.renameSync(fpath, fpath + 'newf');
+      await sleep(WAIT_HALF_SECOND);
+      expect(watcherFrom == watcherTo).assertTrue();
+      watcher.stop();
+      fileIO.rmdirSync(dpath);
+      done();
+    } catch (e) {
+      console.log(testNum + ' has failed for ' + e.message + ', code: ' + e.code);
+      expect(false).assertTrue();
+    }
+  });
+
+  /**
+   * @tc.number SUB_DF_FILEIO_WATCHER_0700
+   * @tc.name fileIO_test_watcher_007
+   * @tc.desc Test watcher event '0x00000100': 'IN_CREATE'
+   *    open a nonexistent file on create mode, verifying the event is 'IN_CREATE'.
+   * @tc.size MEDIUM
+   * @tc.type Function
+   * @tc.level Level 0
+   * @tc.require
+   */
+  it('fileIO_test_watcher_007', 0, async function (done) {
+    let testNum = 'fileIO_test_watcher_007';
+    let dpath = await nextFileName(testNum);
+    let fpath = dpath + '/file_007.txt';
+    fileIO.mkdirSync(dpath);
+
+    try {
+      let resWatcher = startWatcher(testNum, watcherEvent.IN_CREATE, dpath);
+      let file = fileIO.openSync(fpath, fileIO.OpenMode.CREATE);
+      await sleep(WAIT_HALF_SECOND);
+      expect(resWatcher.flag == true).assertTrue();
+      resWatcher.watcher.stop();
+      fileIO.closeSync(file);
+      fileIO.rmdirSync(dpath);
+      done();
+    } catch (e) {
+      console.log(testNum + ' has failed for ' + e.message + ', code: ' + e.code);
+      expect(false).assertTrue();
+    }
+  });
+
+  /**
+   * @tc.number SUB_DF_FILEIO_WATCHER_0800
+   * @tc.name fileIO_test_watcher_008
+   * @tc.desc Test watcher event '0x00000100': 'IN_CREATE'
+   *    open a nonexistent folder on create mode, verifying the event is 'IN_ISDIR | IN_CREATE'.
+   * @tc.size MEDIUM
+   * @tc.type Function
+   * @tc.level Level 0
+   * @tc.require
+   */
+  it('fileIO_test_watcher_008', 0, async function (done) {
+    let testNum = 'fileIO_test_watcher_008';
+    let dpath = await nextFileName(testNum);
+    let ddpath = dpath + '/dir_008';
+    fileIO.mkdirSync(dpath);
+
+    try {
+      let flag = false;
+      let watcher = fileIO.createWatcher(dpath, watcherEvent.IN_CREATE, (data) => {
+        console.log(`${testNum} :{event: ${data.event}, fileName: ${data.fileName}, cookie: ${data.cookie}}`);
+        if ((watcherEvent.IN_ISDIR | watcherEvent.IN_CREATE) === data.event) {
+          flag = true;
+        }
+      });
+      watcher.start();
+      fileIO.mkdirSync(ddpath);
+      await sleep(WAIT_HALF_SECOND);
+      expect(flag == true).assertTrue();
+      watcher.stop();
+      fileIO.rmdirSync(dpath);
+      done();
+    } catch (e) {
+      console.log(testNum + ' has failed for ' + e.message + ', code: ' + e.code);
+      expect(false).assertTrue();
+    }
+  });
+
+  /**
+   * @tc.number SUB_DF_FILEIO_WATCHER_0900
+   * @tc.name fileIO_test_watcher_009
+   * @tc.desc Test watcher event '0x00000200': 'IN_DELETE'
+   *    delete a file , verifying the event is 'IN_DELETE'.
+   * @tc.size MEDIUM
+   * @tc.type Function
+   * @tc.level Level 0
+   * @tc.require
+   */
+  it('fileIO_test_watcher_009', 0, async function (done) {
+    let testNum = 'fileIO_test_watcher_009';
+    let dpath = await nextFileName(testNum);
+    let fpath = dpath + '/file_009.txt';
+    fileIO.mkdirSync(dpath);
+    expect(prepareFile(fpath, FILE_CONTENT)).assertTrue();
+
+    try {
+      let resWatcher = startWatcher(testNum, watcherEvent.IN_DELETE, dpath);
+      fileIO.unlinkSync(fpath);
+      await sleep(WAIT_HALF_SECOND);
+      expect(resWatcher.flag == true).assertTrue();
+      resWatcher.watcher.stop();
+      fileIO.rmdirSync(dpath);
+      done();
+    } catch (e) {
+      console.log(testNum + ' has failed for ' + e.message + ', code: ' + e.code);
+      expect(false).assertTrue();
+    }
+  });
+
+  /**
+   * @tc.number SUB_DF_FILEIO_WATCHER_1000
+   * @tc.name fileIO_test_watcher_010
+   * @tc.desc Test watcher event '0x00000200': 'IN_DELETE'
+   *    delete a file , verifying the event is 'IN_ISDIR | IN_DELETE'.
+   * @tc.size MEDIUM
+   * @tc.type Function
+   * @tc.level Level 0
+   * @tc.require
+   */
+  it('fileIO_test_watcher_010', 0, async function (done) {
+    let testNum = 'fileIO_test_watcher_010';
+    let dpath = await nextFileName(testNum);
+    let ddpath = dpath + '/dir_010';
+    fileIO.mkdirSync(dpath);
+    fileIO.mkdirSync(ddpath);
+
+    try {
+      let flag = false;
+      let watcher = fileIO.createWatcher(dpath, watcherEvent.IN_DELETE, (data) => {
+        console.log(`${testNum} :{event: ${data.event}, fileName: ${data.fileName}, cookie: ${data.cookie}}`);
+        if ((watcherEvent.IN_ISDIR | watcherEvent.IN_DELETE) === data.event) {
+          flag = true;
+        }
+      });
+      watcher.start();
+      fileIO.rmdirSync(ddpath);
+      await sleep(WAIT_HALF_SECOND);
+      expect(flag == true).assertTrue();
+      watcher.stop();
+      fileIO.rmdirSync(dpath);
+      done();
+    } catch (e) {
+      console.log(testNum + ' has failed for ' + e.message + ', code: ' + e.code);
+      expect(false).assertTrue();
+    }
+  });
+
+  /**
+   * @tc.number SUB_DF_FILEIO_WATCHER_1100
+   * @tc.name fileIO_test_watcher_011
+   * @tc.desc Test watcher event '0x00000400': 'IN_DELETE_SELF'
+   *    delete watcher folder , verifying the event is 'IN_DELETE_SELF'.
+   * @tc.size MEDIUM
+   * @tc.type Function
+   * @tc.level Level 0
+   * @tc.require
+   */
+  it('fileIO_test_watcher_011', 0, async function (done) {
+    let testNum = 'fileIO_test_watcher_011';
+    let dpath = await nextFileName(testNum);
+    fileIO.mkdirSync(dpath);
+
+    try {
+      let resWatcher = startWatcher(testNum, watcherEvent.IN_DELETE_SELF, dpath);
+      fileIO.rmdirSync(dpath);
+      await sleep(WAIT_HALF_SECOND);
+      expect(resWatcher.flag == true).assertTrue();
+      resWatcher.watcher.stop();
+      done();
+    } catch (e) {
+      console.log(testNum + ' has failed for ' + e.message + ', code: ' + e.code);
+      expect(false).assertTrue();
+    }
+  });
+
+  /**
+   * @tc.number SUB_DF_FILEIO_WATCHER_1200
+   * @tc.name fileIO_test_watcher_012
+   * @tc.desc Test watcher event '0x00000800': 'IN_MOVE_SELF'
+   *    rename watcher folder , verifying the event is 'IN_MOVE_SELF'.
+   * @tc.size MEDIUM
+   * @tc.type Function
+   * @tc.level Level 0
+   * @tc.require
+   */
+  it('fileIO_test_watcher_012', 0, async function (done) {
+    let testNum = 'fileIO_test_watcher_012';
+    let dpath = await nextFileName(testNum);
+    fileIO.mkdirSync(dpath);
+
+    try {
+      let resWatcher = startWatcher(testNum, watcherEvent.IN_MOVE_SELF, dpath);
+      fileIO.renameSync(dpath, dpath + 'newd');
+      await sleep(WAIT_HALF_SECOND);
+      expect(resWatcher.flag == true).assertTrue();
+      resWatcher.watcher.stop();
+      fileIO.rmdirSync(dpath + 'newd');
+      done();
+    } catch (e) {
+      console.log(testNum + ' has failed for ' + e.message + ', code: ' + e.code);
+      expect(false).assertTrue();
+    }
+  });
+
+  /**
+   * @tc.number SUB_DF_FILEIO_WATCHER_1300
+   * @tc.name fileIO_test_watcher_013
+   * @tc.desc Test watcher event '0x00000800': 'IN_MOVE_SELF'
+   *    rename watcher file , verifying the event is 'IN_MOVE_SELF'.
+   * @tc.size MEDIUM
+   * @tc.type Function
+   * @tc.level Level 3
+   * @tc.require
+   */
+  it('fileIO_test_watcher_013', 3, async function (done) {
+    let testNum = 'fileIO_test_watcher_013';
+    let fpath = await nextFileName(testNum);
+    expect(prepareFile(fpath, FILE_CONTENT)).assertTrue();
+
+    try {
+      let resWatcher = startWatcher(testNum, watcherEvent.IN_MOVE_SELF, fpath);
+      fileIO.renameSync(fpath, fpath + 'newd');
+      await sleep(WAIT_HALF_SECOND);
+      expect(resWatcher.flag == true).assertTrue();
+      resWatcher.watcher.stop();
+      fileIO.unlinkSync(fpath + 'newd');
+      done();
+    } catch (e) {
+      console.log(testNum + ' has failed for ' + e.message + ', code: ' + e.code);
+      expect(false).assertTrue();
+    }
+  });
+
+
+  /**
+   * @tc.number SUB_DF_FILEIO_WATCHER_1400
+   * @tc.name fileIO_test_watcher_014
+   * @tc.desc Test watcher event '0x00000010': 'IN_CLOSE_NOWRITE'
+   *    open a file on read only mode and then close the file.fd, verifying the event is 'IN_CLOSE_NOWRITE'.
+   * @tc.size MEDIUM
+   * @tc.type Function
+   * @tc.level Level 0
+   * @tc.require
+   */
+  it('fileIO_test_watcher_014', 0, async function (done) {
+    let testNum = 'fileIO_test_watcher_014';
+    let dpath = await nextFileName(testNum);
+    let fpath = dpath + '/file_014.txt';
+    fileIO.mkdirSync(dpath);
+    expect(prepareFile(fpath, FILE_CONTENT)).assertTrue();
+
+    try {
+      let file = fileIO.openSync(fpath, fileIO.OpenMode.READ_ONLY);
+      let resWatcher = startWatcher(testNum, watcherEvent.IN_CLOSE_NOWRITE, dpath);
+      fileIO.closeSync(file.fd);
+      await sleep(WAIT_HALF_SECOND);
+      expect(resWatcher.flag == true).assertTrue();
+      resWatcher.watcher.stop();
+      fileIO.rmdirSync(dpath);
+      done();
+    } catch (e) {
+      console.log(testNum + ' has failed for ' + e.message + ', code: ' + e.code);
+      expect(false).assertTrue();
+    }
+  });
+
+  /**
+   * @tc.number SUB_DF_FILEIO_WATCHER_1500
+   * @tc.name fileIO_test_watcher_015
+   * @tc.desc Create multiple watchers in the same directory.
+   * @tc.size MEDIUM
+   * @tc.type Function
+   * @tc.level Level 0
+   * @tc.require
+   */
+  it('fileIO_test_watcher_015', 0, async function (done) {
+    let testNum = 'fileIO_test_watcher_015';
+    let dpath = await nextFileName(testNum);
+    let fpath1 = dpath + '/file_015.txt';
+    let fpath2 = dpath + '/file_016.txt';
+    fileIO.mkdirSync(dpath);
+    expect(prepareFile(fpath1, FILE_CONTENT)).assertTrue();
+    expect(prepareFile(fpath2, FILE_CONTENT)).assertTrue();
+
+    try {
+      let resWatcher = [];
+      resWatcher[0] = fileIO.createWatcher(dpath, watcherEvent.IN_OPEN, callback);
+      resWatcher[1] = fileIO.createWatcher(dpath, watcherEvent.IN_ACCESS, callback);
+      resWatcher[2] = fileIO.createWatcher(dpath, watcherEvent.IN_CLOSE_NOWRITE, callback);
+      resWatcher[3] = fileIO.createWatcher(dpath, watcherEvent.IN_MODIFY, callback);
+      resWatcher[4] = fileIO.createWatcher(dpath, watcherEvent.IN_CLOSE_WRITE, callback);
+      resWatcher.forEach(element => { element.start(); });
+      let file1 = fileIO.openSync(fpath1, fileIO.OpenMode.READ_ONLY);
+      let file2 = fileIO.openSync(fpath2, fileIO.OpenMode.READ_WRITE);
+      await sleep(WAIT_HALF_SECOND);
+      fileIO.readSync(file1.fd, new ArrayBuffer(64));
+      await sleep(WAIT_HALF_SECOND);
+      fileIO.closeSync(file1);
+      await sleep(WAIT_HALF_SECOND);
+      fileIO.writeSync(file2.fd, FILE_CONTENT);
+      await sleep(WAIT_HALF_SECOND);
+      fileIO.closeSync(file2.fd);
+      await sleep(WAIT_HALF_SECOND);
+      resWatcher.forEach(element => { element.stop(); });
+      fileIO.rmdirSync(dpath);
+      done();
+    } catch (e) {
+      console.log(testNum + ' has failed for ' + e.message + ', code: ' + e.code);
+    }
+  });
+
+  /**
+   * @tc.number SUB_DF_FILEIO_WATCHER_1600
+   * @tc.name fileIO_test_watcher_016
+   * @tc.desc Same event, different callback function.
+   * @tc.size MEDIUM
+   * @tc.type Function
+   * @tc.level Level 3
+   * @tc.require
+   */
+  it('fileIO_test_watcher_016', 3, async function (done) {
+    let testNum = 'fileIO_test_watcher_016';
+    let dpath = await nextFileName(testNum);
+    let fpath = dpath + '/file_005.txt';
+    fileIO.mkdirSync(dpath);
+    expect(prepareFile(fpath, FILE_CONTENT)).assertTrue();
+
+    try {
+      let resWatcher1 = fileIO.createWatcher(dpath, watcherEvent.IN_OPEN, (data) => {
+        console.log(`cb_st: ${testNum} :{event: ${data.event}, fileName: ${data.fileName}, cookie: ${data.cookie}}`);
+      });
+      resWatcher1.start();
+      let resWatcher2 = fileIO.createWatcher(dpath, watcherEvent.IN_OPEN, (data) => {
+        console.log(`cb_nd: ${testNum} :{event: ${data.event}, fileName: ${data.fileName}, cookie: ${data.cookie}}`);
+      });
+      resWatcher2.start();
+      let file = fileIO.openSync(fpath, fileIO.OpenMode.READ_ONLY);
+      await sleep(WAIT_HALF_SECOND);
+      resWatcher1.stop();
+      resWatcher2.stop();
+      fileIO.closeSync(file);
+      fileIO.rmdirSync(dpath);
+      done();
+    } catch (e) {
+      console.log(testNum + ' has failed for ' + e.message + ', code: ' + e.code);
+      expect(false).assertTrue();
+    }
+  });
+
+  /**
+   * @tc.number SUB_DF_FILEIO_WATCHER_1700
+   * @tc.name fileIO_test_watcher_017
+   * @tc.desc Same parameter, throw errno.
+   * @tc.size MEDIUM
+   * @tc.type Function
+   * @tc.level Level 3
+   * @tc.require
+   */
+  it('fileIO_test_watcher_017', 3, async function (done) {
+    let testNum = 'fileIO_test_watcher_017';
+    let fpath = await nextFileName(testNum);
+    expect(prepareFile(fpath, FILE_CONTENT)).assertTrue();
+    let watcher = null;
+
+    try {
+      watcher = fileIO.createWatcher(fpath, watcherEvent.IN_ACCESS, callback);
+      watcher.start();
+      fileIO.createWatcher(fpath, watcherEvent.IN_ACCESS, callback);
+      expect(false).assertTrue();
+    } catch (e) {
+      watcher.stop();
+      fileIO.unlinkSync(fpath);
+      console.log(testNum + ' has failed for ' + e.message + ', code: ' + e.code);
+      expect(e.code == 13900020 && e.message == 'Invalid argument').assertTrue();
+      done();
+    }
+  });
+
+  /**
+   * @tc.number SUB_DF_FILEIO_WATCHER_1800
+   * @tc.name fileIO_test_watcher_018
+   * @tc.desc Test Invalid parameter, events = string.
+   * @tc.size MEDIUM
+   * @tc.type Function
+   * @tc.level Level 3
+   * @tc.require
+   */
+  it('fileIO_test_watcher_018', 3, async function (done) {
+    let testNum = 'fileIO_test_watcher_018';
+    let fpath = await nextFileName(testNum);
+    expect(prepareFile(fpath, FILE_CONTENT)).assertTrue();
+    const invalidEvent = 'invalid_event';
+
+    try {
+      fileIO.createWatcher(fpath, invalidEvent, (data) => {});
+      expect(false).assertTrue();
+    } catch (e) {
+      fileIO.unlinkSync(fpath);
+      console.log(testNum + ' has failed for ' + e.message + ', code: ' + e.code);
+      expect(e.code == 13900020 && e.message == 'Invalid argument').assertTrue();
+      done();
+    }
+  });
+
+  /**
+   * @tc.number SUB_DF_FILEIO_WATCHER_1900
+   * @tc.name fileIO_test_watcher_019
+   * @tc.desc Test Invalid parameter, put a parameter in watcher.start.
+   * @tc.size MEDIUM
+   * @tc.type Function
+   * @tc.level Level 3
+   * @tc.require
+   */
+  it('fileIO_test_watcher_019', 3, async function (done) {
+    let testNum = 'fileIO_test_watcher_019';
+    let fpath = await nextFileName(testNum);
+    expect(prepareFile(fpath, FILE_CONTENT)).assertTrue();
+
+    try {
+      let watcher = fileIO.createWatcher(fpath, watcherEvent.IN_ACCESS, (data) => {});
+      watcher.start(-1);
+      expect(false).assertTrue();
+    } catch (e) {
+      fileIO.unlinkSync(fpath);
+      console.log(testNum + ' has failed for ' + e.message + ', code: ' + e.code);
+      expect(e.code == 13900020 && e.message == 'Invalid argument').assertTrue();
+      done();
+    }
+  });
+
+  /**
+   * @tc.number SUB_DF_FILEIO_WATCHER_2000
+   * @tc.name fileIO_test_watcher_020
+   * @tc.desc Test Invalid parameter, put a parameter in watcher.stop.
+   * @tc.size MEDIUM
+   * @tc.type Function
+   * @tc.level Level 3
+   * @tc.require
+   */
+  it('fileIO_test_watcher_020', 3, async function (done) {
+    let testNum = 'fileIO_test_watcher_020';
+    let fpath = await nextFileName(testNum);
+    expect(prepareFile(fpath, FILE_CONTENT)).assertTrue();
+    let watcher;
+
+    try {
+      watcher = fileIO.createWatcher(fpath, watcherEvent.IN_ACCESS, (data) => {});
+      watcher.start();
+      watcher.stop(-1);
+      expect(false).assertTrue();
+    } catch (e) {
+      watcher.stop();
+      fileIO.unlinkSync(fpath);
+      console.log(testNum + ' has failed for ' + e.message + ', code: ' + e.code);
+      expect(e.code == 13900020 && e.message == 'Invalid argument').assertTrue();
+      done();
+    }
+  });
+
+  /**
+   * @tc.number SUB_DF_FILEIO_WATCHER_2100
+   * @tc.name fileIO_test_watcher_021
+   * @tc.desc No watcher started.
+   * @tc.size MEDIUM
+   * @tc.type Function
+   * @tc.level Level 3
+   * @tc.require
+   */
+  it('fileIO_test_watcher_021', 3, async function (done) {
+    let testNum = 'fileIO_test_watcher_021';
+    let fpath = await nextFileName(testNum);
+    expect(prepareFile(fpath, FILE_CONTENT)).assertTrue();
+
+    try {
+      let watcher = fileIO.createWatcher(fpath, watcherEvent.IN_ACCESS, (data) => {});
+      watcher.stop();
+      expect(false).assertTrue();
+    } catch (e) {
+      fileIO.unlinkSync(fpath);
+      console.log(testNum + ' has failed for ' + e.message + ', code: ' + e.code);
+      expect(e.code == 13900020 && e.message == 'Invalid argument').assertTrue();
+      done();
+    }
+  });
+
+  /**
+   * @tc.number SUB_DF_FILEIO_WATCHER_2200
+   * @tc.name fileIO_test_watcher_022
+   * @tc.desc Test Invalid parameter, callback = object.
+   * @tc.size MEDIUM
+   * @tc.type Function
+   * @tc.level Level 3
+   * @tc.require
+   */
+  it('fileIO_test_watcher_022', 3, async function (done) {
+    let testNum = 'fileIO_test_watcher_022';
+    let fpath = await nextFileName(testNum);
+    expect(prepareFile(fpath, FILE_CONTENT)).assertTrue();
+    const invalidListener = {};
+
+    try {
+      fileIO.createWatcher(fpath, watcherEvent.IN_OPEN, invalidListener);
+      expect(false).assertTrue();
+    } catch (e) {
+      fileIO.unlinkSync(fpath);
+      console.log(testNum + ' has failed for ' + e.message + ', code: ' + e.code);
+      expect(e.code == 13900020 && e.message == 'Invalid argument').assertTrue();
+      done();
+    }
+  });
+
+  /**
+   * @tc.number SUB_DF_FILEIO_WATCHER_2300
+   * @tc.name fileIO_test_watcher_023
+   * @tc.desc Test Invalid parameter, events = -1
+   * @tc.size MEDIUM
+   * @tc.type Function
+   * @tc.level Level 3
+   * @tc.require
+   */
+  it('fileIO_test_watcher_023', 3, async function (done) {
+    let testNum = 'fileIO_test_watcher_023';
+    let fpath = await nextFileName(testNum);
+    expect(prepareFile(fpath, FILE_CONTENT)).assertTrue();
+    const invalidEvent = -1;
+
+    try {
+      let watcher = fileIO.createWatcher(fpath, invalidEvent, (data) => {});
+      watcher.start();
+      expect(false).assertTrue();
+    } catch (e) {
+      fileIO.unlinkSync(fpath);
+      console.log(testNum + ' has failed for ' + e.message + ', code: ' + e.code);
+      expect(e.code == 13900020 && e.message == 'Invalid argument').assertTrue();
+      done();
+    }
+  });
+
+  /**
+   * @tc.number SUB_DF_FILEIO_WATCHER_2400
+   * @tc.name fileIO_test_watcher_024
+   * @tc.desc Missing the third parametor.
+   * @tc.size MEDIUM
+   * @tc.type Function
+   * @tc.level Level 3
+   * @tc.require
+   */
+  it('fileIO_test_watcher_024', 3, async function (done) {
+    let testNum = 'fileIO_test_watcher_024';
+    let fpath = await nextFileName(testNum);
+    expect(prepareFile(fpath, FILE_CONTENT)).assertTrue();
+
+    try {
+      fileIO.createWatcher(fpath, watcherEvent.IN_OPEN);
+      expect(false).assertTrue();
+    } catch (e) {
+      fileIO.unlinkSync(fpath);
+      console.log(testNum + ' has failed for ' + e.message + ', code: ' + e.code);
+      expect(e.code == 13900020 && e.message == 'Invalid argument').assertTrue();
+      done();
+    }
+  });
+
+  /**
+   * @tc.number SUB_DF_FILEIO_WATCHER_2500
+   * @tc.name fileIO_test_watcher_025
+   * @tc.desc The path point to nothing, no such file.
+   * @tc.size MEDIUM
+   * @tc.type Function
+   * @tc.level Level 3
+   * @tc.require
+   */
+  it('fileIO_test_watcher_025', 3, async function (done) {
+    let testNum = 'fileIO_test_watcher_025';
+    let fpath = await nextFileName(testNum);
+
+    try {
+      let watcher = fileIO.createWatcher(fpath, watcherEvent.IN_ACCESS, (data) => {});
+      watcher.start();
+      expect(false).assertTrue();
+    } catch (e) {
+      console.log(testNum + ' has failed for ' + e.message + ', code: ' + e.code);
+      expect(e.code == 13900002 && e.message == 'No such file or directory').assertTrue();
+      done();
+    }
+  });
+});
+}