FilesExpand file tree

 master

/

FSServer.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

73 lines (60 loc) · 1.93 KB

 master

/

FSServer.java

Copy path

Top

File metadata and controls

• Code
• Blame

73 lines (60 loc) · 1.93 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

package javaFSMonitor;

import java.io.IOException;

import java.nio.file.FileSystems;

import java.nio.file.Paths;

import java.nio.file.StandardWatchEventKinds;

import java.nio.file.WatchEvent;

import java.nio.file.WatchKey;

import java.nio.file.WatchService;

import java.util.ArrayList;

public class FSServer {

private String dir;

private ArrayList<FSMonitor> clients;

private volatile boolean canWork;

public FSServer(String dir) {

this.dir = dir;

clients = new ArrayList<>();

}

public void addClient(FSMonitor client) {

clients.add(client);

}

public void removeClient(FSMonitor client) {

clients.remove(client);

}

public void start() {

canWork = true;

run();

}

public void stop() {

canWork = false;

}

private void run() {

try {

WatchService watch = FileSystems.getDefault().newWatchService();

Paths.get(dir).register(watch,

StandardWatchEventKinds.ENTRY_CREATE,

StandardWatchEventKinds.ENTRY_DELETE);

while (canWork) {

WatchKey key = watch.take();

for (WatchEvent event : key.pollEvents()) {

String fName = event.context().toString();

int kind = 0;

if (event.kind() == StandardWatchEventKinds.ENTRY_CREATE) {

kind = FSMonitor.CREATE;

} else {

kind = FSMonitor.REMOVE;

}

for (FSMonitor client : clients) {

client.event(fName, kind);

}

}

key.reset();

}

watch.close();

} catch (IOException ex) {

//....

} catch (InterruptedException ex) {

//....

}

}

}