1 files changed, 12 insertions, 0 deletions

diff --git a/src/main/java/org/gnunet/dht/DistributedHashTable.java b/src/main/java/org/gnunet/dht/DistributedHashTable.java
index 27bac92..1ff0912 100644
--- a/src/main/java/org/gnunet/dht/DistributedHashTable.java
+++ b/src/main/java/org/gnunet/dht/DistributedHashTable.java
@@ -66,6 +66,7 @@ public class DistributedHashTable {
         public int type;
         public Continuation cont;
         public long uid;
+        private int options;
 
         public PutRequest() {
             this.uid = nextUID++;
@@ -80,6 +81,7 @@ public class DistributedHashTable {
             cpm.expiration = expiration.asMessage();
             cpm.type = type;
             cpm.uid = uid;
+            cpm.options = options;
             return new Envelope(cpm);
         }
 
@@ -95,6 +97,7 @@ public class DistributedHashTable {
         public int type;
         public int replication;
         public byte[] xquery;
+        public int options;
 
         public GetRequest() {
             uid = DistributedHashTable.this.nextUID++;
@@ -108,6 +111,7 @@ public class DistributedHashTable {
             gm.xquery = xquery == null ? new byte[0] : xquery;
             gm.key = key;
             gm.uniqueId = uid;
+            gm.options = options;
             return new Envelope(gm);
         }
         public void onCancel() {
@@ -269,6 +273,10 @@ public class DistributedHashTable {
         pr.expiration = expiration;
         pr.type = type;
         pr.cont = cont;
+        pr.options = 0;
+        for (RouteOption routeOption : routeOptions) {
+            pr.options |= routeOption.val;
+        }
 
         putRequests.addRequest(pr.uid, pr);
     }
@@ -297,6 +305,10 @@ public class DistributedHashTable {
         getRequest.replication = type;
         getRequest.xquery = xquery;
         getRequest.replication = replication;
+        getRequest.options = 0;
+        for (RouteOption routeOption : routeOptions) {
+            getRequest.options |= routeOption.val;
+        }
 
         return getRequests.addRequest(getRequest.uid, getRequest);
     }