Project

General

Profile

Revision 3

Update

View differences:

Backup.java
1
package peer.protocols.backup;

2

  
3
import java.io.File;

4

  
5
import chunk.Chunk;

6
import peer.Peer;

7

  
8
/**

9
 * Backup

10
 */

11
public class Backup implements Runnable {

12

  
13
	private Peer peer;

14
	private File file;

15
	private int repDegree;

16

  
17
	public Backup(Peer peer, String path, int repDegree) {

18
		file = new 	File(path);

19
		this.peer = peer;

20
		this.repDegree = repDegree;

21
	}

22

  
23
	public void backupFile() {

24
		Chunk[] chunks = Chunk.splitFile(file, repDegree);

25
		for (int i = 0;i<chunks.length;i++){

26
			BackupChunk backupChunk = new BackupChunk(peer, chunks[i]);

27
			Thread bThread = new Thread(backupChunk);

28
			bThread.start();

29
		}

30
	}

31

  
32
	@Override

33
	public void run() {

34
		backupFile();

35
	}

1
package peer.protocols.backup;
2

  
3
import java.io.File;
4

  
5
import chunk.Chunk;
6
import peer.Peer;
7

  
8
/**
9
 * Backup
10
 */
11
public class Backup implements Runnable {
12

  
13
	private Peer peer;
14
	private File file;
15
	private int repDegree;
16

  
17
	public Backup(Peer peer, String path, int repDegree) {
18
		file = new 	File(path);
19
		this.peer = peer;
20
		this.repDegree = repDegree;
21
	}
22

  
23
	public void backupFile() {
24
		Chunk[] chunks = Chunk.splitFile(file, repDegree);
25
		for (int i = 0;i<chunks.length;i++){
26
			BackupChunk backupChunk = new BackupChunk(peer, chunks[i]);
27
			Thread bThread = new Thread(backupChunk);
28
			bThread.start();
29
		}
30
	}
31

  
32
	@Override
33
	public void run() {
34
		backupFile();
35
	}
36 36
}

Also available in: Unified diff