Skip to content
This repository has been archived by the owner on May 7, 2023. It is now read-only.

Commit

Permalink
Fixes for 1.1.0.24 (#11)
Browse files Browse the repository at this point in the history
  • Loading branch information
@se-bastiaan
se-bastiaan committed Apr 16, 2016
1 parent 7a6eed2 commit 6acab47
Show file tree
Hide file tree
Showing 4 changed files with 29 additions and 29 deletions.
50 changes: 25 additions & 25 deletions library/src/main/java/com/github/se_bastiaan/torrentstream/Torrent.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -74,7 +74,7 @@ public Torrent(TorrentHandle torrentHandle, TorrentListener listener, Long prepa

this.prepareSize = prepareSize;

torrentHandle.setPriority(Priority.NORMAL.getSwig());
torrentHandle.setPriority(Priority.NORMAL.swig());

if (selectedFileIndex == -1)
setLargestFile();
Expand All @@ -91,9 +91,9 @@ private void resetPriorities() {
Priority[] priorities = torrentHandle.getPiecePriorities();
for (int i = 0; i < priorities.length; i++) {
if (i >= firstPieceIndex && i <= lastPieceIndex) {
torrentHandle.setPiecePriority(i, Priority.NORMAL);
torrentHandle.piecePriority(i, Priority.NORMAL);
} else {
torrentHandle.setPiecePriority(i, Priority.IGNORE);
torrentHandle.piecePriority(i, Priority.IGNORE);
}
}
}
Expand All @@ -108,7 +108,7 @@ public TorrentHandle getTorrentHandle() {
}

public File getVideoFile() {
return new File(torrentHandle.getSavePath() + "/" + torrentHandle.getTorrentInfo().getFiles().getFilePath(selectedFileIndex));
return new File(torrentHandle.getSavePath() + "/" + torrentHandle.getTorrentInfo().files().filePath(selectedFileIndex));
}

/**
Expand Down Expand Up @@ -149,13 +149,13 @@ public void setLargestFile() {
*/
public void setSelectedFileIndex(Integer selectedFileIndex) {
TorrentInfo torrentInfo = torrentHandle.getTorrentInfo();
FileStorage fileStorage = torrentInfo.getFiles();
FileStorage fileStorage = torrentInfo.files();

if (selectedFileIndex == -1) {
long highestFileSize = 0;
int selectedFile = -1;
for (int i = 0; i < fileStorage.getNumFiles(); i++) {
long fileSize = fileStorage.getFileSize(i);
for (int i = 0; i < fileStorage.numFiles(); i++) {
long fileSize = fileStorage.fileSize(i);
if (highestFileSize < fileSize) {
highestFileSize = fileSize;
torrentHandle.setFilePriority(selectedFile, Priority.IGNORE);
Expand All @@ -167,7 +167,7 @@ public void setSelectedFileIndex(Integer selectedFileIndex) {
}
selectedFileIndex = selectedFile;
} else {
for (int i = 0; i < fileStorage.getNumFiles(); i++) {
for (int i = 0; i < fileStorage.numFiles(); i++) {
if (i == selectedFileIndex) {
torrentHandle.setFilePriority(i, Priority.NORMAL);
} else {
Expand Down Expand Up @@ -225,10 +225,10 @@ public void setSelectedFileIndex(Integer selectedFileIndex) {
* @return {@link String[]}
*/
public String[] getFileNames() {
FileStorage fileStorage = torrentHandle.getTorrentInfo().getFiles();
String[] fileNames = new String[fileStorage.getNumFiles()];
for (int i = 0; i < fileStorage.getNumFiles(); i++) {
fileNames[i] = fileStorage.getFileName(i);
FileStorage fileStorage = torrentHandle.getTorrentInfo().files();
String[] fileNames = new String[fileStorage.numFiles()];
for (int i = 0; i < fileStorage.numFiles(); i++) {
fileNames[i] = fileStorage.fileName(i);
}
return fileNames;
}
Expand All @@ -240,26 +240,26 @@ public String[] getFileNames() {
public void startDownload() {
if (state == State.STREAMING) return;
state = State.STARTING;
torrentHandle.setPriority(Priority.NORMAL.getSwig());
torrentHandle.setPriority(Priority.NORMAL.swig());

List<Integer> indices = new ArrayList<>();

Priority[] priorities = torrentHandle.getPiecePriorities();
for (int i = 0; i < priorities.length; i++) {
if (priorities[i] != Priority.IGNORE) {
torrentHandle.setPiecePriority(i, Priority.NORMAL);
torrentHandle.piecePriority(i, Priority.NORMAL);
}
}

for (int i = 0; i < piecesToPrepare; i++) {
indices.add(lastPieceIndex - i);
torrentHandle.setPiecePriority(lastPieceIndex - i, Priority.SEVEN);
torrentHandle.piecePriority(lastPieceIndex - i, Priority.SEVEN);
torrentHandle.setPieceDeadline(lastPieceIndex - i, 1000);
}

for (int i = 0; i < piecesToPrepare; i++) {
indices.add(firstPieceIndex + i);
torrentHandle.setPiecePriority(firstPieceIndex + i, Priority.SEVEN);
torrentHandle.piecePriority(firstPieceIndex + i, Priority.SEVEN);
torrentHandle.setPieceDeadline(firstPieceIndex + i, 1000);
}

Expand Down Expand Up @@ -290,7 +290,7 @@ private void startSequentialMode() {
torrentHandle.setSequentialDownload(true);
} else {
for (int i = firstPieceIndex + piecesToPrepare; i < firstPieceIndex + piecesToPrepare + 5; i++) {
torrentHandle.setPiecePriority(i, Priority.SEVEN);
torrentHandle.piecePriority(i, Priority.SEVEN);
torrentHandle.setPieceDeadline(i, 1000);
}
}
Expand All @@ -312,11 +312,11 @@ public State getState() {
*/
private void pieceFinished(PieceFinishedAlert alert) {
if (state == State.STREAMING && hasPieces != null) {
hasPieces[alert.getPieceIndex() - firstPieceIndex] = true;
hasPieces[alert.pieceIndex() - firstPieceIndex] = true;

for (int i = alert.getPieceIndex() - firstPieceIndex; i < hasPieces.length; i++) {
for (int i = alert.pieceIndex() - firstPieceIndex; i < hasPieces.length; i++) {
if (!hasPieces[i]) {
torrentHandle.setPiecePriority(i + firstPieceIndex, Priority.SEVEN);
torrentHandle.piecePriority(i + firstPieceIndex, Priority.SEVEN);
torrentHandle.setPieceDeadline(i + firstPieceIndex, 1000);
break;
}
Expand All @@ -325,13 +325,13 @@ private void pieceFinished(PieceFinishedAlert alert) {
Iterator<Integer> piecesIterator = preparePieces.iterator();
while (piecesIterator.hasNext()) {
int index = piecesIterator.next();
if (index == alert.getPieceIndex()) {
if (index == alert.pieceIndex()) {
piecesIterator.remove();
}
}

if (hasPieces != null) {
hasPieces[alert.getPieceIndex() - firstPieceIndex] = true;
hasPieces[alert.pieceIndex() - firstPieceIndex] = true;
}

if (preparePieces.size() == 0) {
Expand Down Expand Up @@ -373,14 +373,14 @@ private void sendStreamProgress() {
@Override
public int[] types() {
return new int[]{
AlertType.PIECE_FINISHED.getSwig(),
AlertType.BLOCK_FINISHED.getSwig()
AlertType.PIECE_FINISHED.swig(),
AlertType.BLOCK_FINISHED.swig()
};
}

@Override
public void alert(Alert<?> alert) {
switch (alert.getType()) {
switch (alert.type()) {
case PIECE_FINISHED:
pieceFinished((PieceFinishedAlert) alert);
break;
Expand Down
2 changes: 1 addition & 1 deletion library/src/main/java/com/github/se_bastiaan/torrentstream/TorrentStream.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -321,7 +321,7 @@ public void run() {
return;
}

Priority[] priorities = new Priority[torrentInfo.getNumPieces()];
Priority[] priorities = new Priority[torrentInfo.numPieces()];
for (int i = 0; i < priorities.length; i++) {
priorities[i] = Priority.IGNORE;
}
Expand Down
2 changes: 1 addition & 1 deletion ...y/src/main/java/com/github/se_bastiaan/torrentstream/listeners/DHTStatsAlertListener.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@
public abstract class DHTStatsAlertListener implements AlertListener {
@Override
public int[] types() {
return new int[]{AlertType.DHT_STATS.getSwig()};
return new int[]{AlertType.DHT_STATS.swig()};
}

public void alert(Alert<?> alert) {
Expand Down
4 changes: 2 additions & 2 deletions ...c/main/java/com/github/se_bastiaan/torrentstream/listeners/TorrentAddedAlertListener.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -24,12 +24,12 @@
public abstract class TorrentAddedAlertListener implements AlertListener {
@Override
public int[] types() {
return new int[]{AlertType.TORRENT_ADDED.getSwig()};
return new int[]{AlertType.TORRENT_ADDED.swig()};
}

@Override
public void alert(Alert<?> alert) {
switch (alert.getType()) {
switch (alert.type()) {
case TORRENT_ADDED:
torrentAdded((TorrentAddedAlert) alert);
break;
Expand Down

0 comments on commit 6acab47

Please sign in to comment.