Project

General

Profile

Revision 3

Update

View differences:

Delete.java
1
package peer.protocols.delete;

2

  
3
import java.io.File;

4
import java.io.IOException;

5

  
6
import chunk.Chunk;

7
import message.Message;

8
import peer.Peer;

9

  
10
/**

11
 * Delete

12
 */

13
public class Delete implements Runnable {

14

  
15
	private Peer peer;

16
	private String fileId;

17

  
18
	public Delete(Peer peer, String fileId) {

19
		this.peer = peer;

20
		File originalFile = new File(fileId);

21
		this.fileId = Chunk.generateFileId(originalFile);

22
	}

23

  
24
	public void sendDelete() {

25
		Message message = Message.parseDeleteMessage(fileId, peer);

26
		try {

27
			peer.sendToMc(message);

28
		} catch (IOException e) {

29
			e.printStackTrace();

30
		}

31
	}

32

  
33
	public void delete() {

34
		peer.getDisk().deleteFileDirectory(fileId);

35
		sendDelete();

36
	}

37

  
38
	@Override

39
	public void run() {

40
		delete();

41
	}

42

  
1
package peer.protocols.delete;
2

  
3
import java.io.File;
4
import java.io.IOException;
5

  
6
import chunk.Chunk;
7
import message.Message;
8
import peer.Peer;
9

  
10
/**
11
 * Delete
12
 */
13
public class Delete implements Runnable {
14

  
15
	private Peer peer;
16
	private String fileId;
17

  
18
	public Delete(Peer peer, String fileId) {
19
		this.peer = peer;
20
		File originalFile = new File(fileId);
21
		this.fileId = Chunk.generateFileId(originalFile);
22
	}
23

  
24
	public void sendDelete() {
25
		Message message = Message.parseDeleteMessage(fileId, peer);
26
		try {
27
			peer.sendToMc(message);
28
		} catch (IOException e) {
29
			e.printStackTrace();
30
		}
31
	}
32

  
33
	public void delete() {
34
		peer.getDisk().deleteFileDirectory(fileId);
35
		sendDelete();
36
	}
37

  
38
	@Override
39
	public void run() {
40
		delete();
41
	}
42

  
43 43
}

Also available in: Unified diff