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
|
/* Copyright (c) 2006-2018. The SimGrid Team.
* All rights reserved. */
/* This program is free software; you can redistribute it and/or modify it
* under the terms of the license (GNU LGPL) which comes with this package. */
package app.bittorrent;
import org.simgrid.msg.Task;
public class MessageTask extends Task {
public enum Type {
HANDSHAKE,
CHOKE,
UNCHOKE,
INTERESTED,
NOTINTERESTED,
HAVE,
BITFIELD,
REQUEST,
PIECE
}
protected Type type;
protected String issuerHostname;
protected String mailbox;
protected int peerId;
protected char[] bitfield;
protected int index;
protected int blockIndex;
protected int blockLength;
protected boolean stalled;
public MessageTask(Type type, String issuerHostname, String mailbox, int peerId) {
this(type,issuerHostname,mailbox,peerId,-1,false,-1,-1);
}
public MessageTask(Type type, String issuerHostname, String mailbox, int peerId, int index) {
this(type,issuerHostname,mailbox,peerId,index,false,-1,-1);
}
// builds a new bitfield message
public MessageTask(Type type, String issuerHostname, String mailbox, int peerId, char[] bitfield) {
this(type,issuerHostname,mailbox,peerId,-1,false,-1,-1);
this.bitfield = bitfield;
}
// build a new "request" message
public MessageTask(Type type, String issuerHostname, String mailbox, int peerId, int index, int blockIndex,
int blockLength) {
this(type,issuerHostname,mailbox,peerId,index,false,blockIndex,blockLength);
}
// build a new "piece" message
public MessageTask(Type type, String issuerHostname, String mailbox, int peerId, int index, boolean stalled,
int blockIndex, int blockLength) {
this.type = type;
this.issuerHostname = issuerHostname;
this.mailbox = mailbox;
this.peerId = peerId;
this.index = index;
this.stalled = stalled;
this.blockIndex = blockIndex;
this.blockLength = blockLength;
}
}
|
