Kaladaran/briar
0
0
Fork 0
mirror of https://code.briarproject.org/briar/briar.git synced 2026-02-12 18:59:06 +01:00
Code Issues Projects Releases Wiki Activity

Enter success state after sending ack

Browse Source
This commit is contained in:
ameba23
2021-04-13 18:22:19 +02:00
parent b07206c898
commit f13cc15661
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
briar-core/src/main/java/org/briarproject/briar/socialbackup/recovery/SecretOwnerTaskImpl.java
View File

@@ -1,6 +1,5 @@
package org.briarproject.briar.socialbackup.recovery;
import org.briarproject.bramble.api.FormatException;
import org.briarproject.bramble.api.client.ClientHelper;
import org.briarproject.bramble.api.crypto.CryptoComponent;
import org.briarproject.bramble.api.crypto.KeyPair;
@@ -34,7 +33,7 @@ public class SecretOwnerTaskImpl implements SecretOwnerTask {
@Inject
SecretOwnerTaskImpl(CryptoComponent crypto,
@IoExecutor Executor ioExecutor, ClientHelper clientHelper) {
@IoExecutor Executor ioExecutor, ClientHelper clientHelper) {
this.crypto = crypto;
this.ioExecutor = ioExecutor;
this.clientHelper = clientHelper;
@@ -77,7 +76,7 @@ public class SecretOwnerTaskImpl implements SecretOwnerTask {
try {
socket = serverSocket.accept();
observer.onStateChanged(new State.ReceivingShard());
InputStream inputStream = socket.getInputStream();
InputStream inputStream = socket.getInputStream();
byte[] payloadRaw = new byte[7];
int read = inputStream.read(payloadRaw);
if (read < 0) throw new IOException("Payload not read");
@@ -85,6 +84,7 @@ public class SecretOwnerTaskImpl implements SecretOwnerTask {
OutputStream outputStream = socket.getOutputStream();
outputStream.write("ack".getBytes());
serverSocket.close();
observer.onStateChanged(new State.Success());
} catch (IOException e) {
observer.onStateChanged(new State.Failure());
}
@@ -92,9 +92,9 @@ public class SecretOwnerTaskImpl implements SecretOwnerTask {
@Override
public void cancel() {
cancelled = true;
cancelled = true;
try {
serverSocket.close();
serverSocket.close();
} catch (IOException e) {
observer.onStateChanged(new State.Failure());
}