Kinda returns 1 all the time

This commit is contained in:
Alexander Munch-Hansen 2019-11-11 00:44:29 +01:00
parent 73841f1cd1
commit a1d1a0a16c
6 changed files with 81 additions and 23 deletions

View File

@ -1,10 +1,13 @@
package dk.au.pir; package dk.au.pir;
import dk.alexandra.fresco.framework.builder.numeric.field.FieldElement; import dk.alexandra.fresco.framework.builder.numeric.field.FieldElement;
import dk.au.pir.protocols.general.interpoly.GeneralInterPolyClient;
import dk.au.pir.protocols.general.interpoly.GeneralInterPolyServer;
import dk.au.pir.protocols.interpoly.InterPolyClient; import dk.au.pir.protocols.interpoly.InterPolyClient;
import dk.au.pir.protocols.interpoly.InterPolyServer; import dk.au.pir.protocols.interpoly.InterPolyServer;
import dk.au.pir.settings.PIRSettings; import dk.au.pir.settings.PIRSettings;
import dk.au.pir.utils.ComparableIntList; import dk.au.pir.utils.ComparableIntList;
import dk.au.pir.utils.IntegerUtils;
import dk.au.pir.utils.ProtocolUtils; import dk.au.pir.utils.ProtocolUtils;
import org.w3c.dom.ls.LSOutput; import org.w3c.dom.ls.LSOutput;
@ -38,9 +41,16 @@ public class Driver {
public static void generalInterPolyTest() { public static void generalInterPolyTest() {
ProtocolUtils utils = new ProtocolUtils(); ProtocolUtils utils = new ProtocolUtils();
GeneralInterPolyClient client = new GeneralInterPolyClient(22);
int s = utils.findSizeOfS(2, PIRSettings.DATABASE_SIZE); int s = utils.findSizeOfS(2, PIRSettings.DATABASE_SIZE);
int[] database = new int[PIRSettings.DATABASE_SIZE];
int[][] database = new int[PIRSettings.DATABASE_SIZE][s]; GeneralInterPolyServer[] servers = new GeneralInterPolyServer[PIRSettings.MOD_BIT_LENGTH + 1];
client.generateSRandomFieldElements();
database[24] = 1;
int[][] sequences = new int[PIRSettings.DATABASE_SIZE][s];
Set<ComparableIntList> candidates = new HashSet<ComparableIntList>(); Set<ComparableIntList> candidates = new HashSet<ComparableIntList>();
@ -53,14 +63,21 @@ public class Driver {
listCandidates.addAll(candidates); listCandidates.addAll(candidates);
Collections.sort(listCandidates); Collections.sort(listCandidates);
for (ComparableIntList elem : listCandidates) { BigInteger[] results = new BigInteger[PIRSettings.MOD_BIT_LENGTH + 1];
System.out.println(elem);
for (int z = 0; z < PIRSettings.MOD_BIT_LENGTH+1; z++) {
servers[z] = new GeneralInterPolyServer(database, sequences);
servers[z].receiveGs(client.sendGs(z));
results[z] = servers[z].F();
} }
BigInteger res = client.receiveResults(results);
System.out.println(res);
} }
public static void main(String[] args) { public static void main(String[] args) {
generalInterPolyTest(); generalInterPolyTest();
} }
} }

View File

@ -4,6 +4,7 @@ import dk.au.pir.BigIntegerField;
import dk.au.pir.settings.PIRSettings; import dk.au.pir.settings.PIRSettings;
import dk.au.pir.utils.BigIntegerLagrange; import dk.au.pir.utils.BigIntegerLagrange;
import dk.au.pir.utils.FieldElement; import dk.au.pir.utils.FieldElement;
import dk.au.pir.utils.IntegerUtils;
import java.math.BigInteger; import java.math.BigInteger;
import java.util.Random; import java.util.Random;
@ -29,12 +30,7 @@ public class GeneralInterPolyClient {
} }
public BigInteger g(int l, int z) { public BigInteger g(int l, int z) {
String iString = Integer.toBinaryString(i); BigInteger il = BigInteger.valueOf(IntegerUtils.leastSignificantBit(i, l)).mod(field.getGroupOrder());
String pads = new String(new char[PIRSettings.MOD_BIT_LENGTH - iString.length()]).replace("\0", "0");
iString = pads + iString;
char lChar = iString.charAt(iString.length() - 1 - l); // lol
String ilString = Character.toString(lChar);
BigInteger il = new BigInteger(ilString).mod(field.getGroupOrder());
return field.add(field.multiply(fieldElements[l].getValue(), (BigInteger.valueOf(z))), il); return field.add(field.multiply(fieldElements[l].getValue(), (BigInteger.valueOf(z))), il);
} }

View File

@ -0,0 +1,45 @@
package dk.au.pir.protocols.general.interpoly;
import dk.au.pir.settings.PIRSettings;
import dk.au.pir.utils.IntegerUtils;
import java.math.BigInteger;
public class GeneralInterPolyServer {
private BigInteger[] gs;
private int[][] sequences;
private int[] database;
public GeneralInterPolyServer(int[] database, int[][] sequences) {
this.sequences = sequences; this.database = database;
}
public void receiveGs(BigInteger[] gs){
this.gs = gs;
}
public BigInteger f(int j){
BigInteger product = BigInteger.ONE;
for (int l = 0; l < PIRSettings.MOD_BIT_LENGTH; l++) {
if (sequences[j][l] == 1) {
// j(l) * g_l(z) + ((1 - j(l)) * (1 - g_l(z)))
BigInteger tmp = gs[l].multiply(BigInteger.valueOf(sequences[j][l])).add((BigInteger.ONE.subtract(BigInteger.valueOf(sequences[j][l])).multiply(BigInteger.ONE.subtract(gs[l]))));
product = product.multiply(tmp);
}
}
return product;
}
public BigInteger F() {
BigInteger sum = BigInteger.ZERO;
for (int j = 0; j < PIRSettings.DATABASE_SIZE; j++) {
// Database consist of 0's or 1'
sum = sum.add(f(j).multiply(BigInteger.valueOf(database[j])));
}
return sum;
}
}

View File

@ -4,6 +4,7 @@ import dk.au.pir.BigIntegerField;
import dk.au.pir.settings.PIRSettings; import dk.au.pir.settings.PIRSettings;
import dk.au.pir.utils.BigIntegerLagrange; import dk.au.pir.utils.BigIntegerLagrange;
import dk.au.pir.utils.FieldElement; import dk.au.pir.utils.FieldElement;
import dk.au.pir.utils.IntegerUtils;
import java.math.BigInteger; import java.math.BigInteger;
import java.util.Random; import java.util.Random;
@ -29,12 +30,7 @@ public class InterPolyClient {
} }
public BigInteger g(int l, int z) { public BigInteger g(int l, int z) {
String iString = Integer.toBinaryString(i); BigInteger il = BigInteger.valueOf(IntegerUtils.leastSignificantBit(i, l)).mod(field.getGroupOrder());
String pads = new String(new char[PIRSettings.MOD_BIT_LENGTH - iString.length()]).replace("\0", "0");
iString = pads + iString;
char lChar = iString.charAt(iString.length() - 1 - l); // lol
String ilString = Character.toString(lChar);
BigInteger il = new BigInteger(ilString).mod(field.getGroupOrder());
return field.add(field.multiply(fieldElements[l].getValue(), (BigInteger.valueOf(z))), il); return field.add(field.multiply(fieldElements[l].getValue(), (BigInteger.valueOf(z))), il);
} }

View File

@ -1,6 +1,7 @@
package dk.au.pir.protocols.interpoly; package dk.au.pir.protocols.interpoly;
import dk.au.pir.settings.PIRSettings; import dk.au.pir.settings.PIRSettings;
import dk.au.pir.utils.IntegerUtils;
import java.math.BigInteger; import java.math.BigInteger;
@ -20,13 +21,7 @@ public class InterPolyServer {
public BigInteger f(int j){ public BigInteger f(int j){
BigInteger product = BigInteger.ONE; BigInteger product = BigInteger.ONE;
for (int l = 0; l < PIRSettings.MOD_BIT_LENGTH; l++) { for (int l = 0; l < PIRSettings.MOD_BIT_LENGTH; l++) {
String iString = Integer.toBinaryString(j); if (IntegerUtils.leastSignificantBit(j, l) == 1){
String pads = new String(new char[PIRSettings.MOD_BIT_LENGTH - iString.length()]).replace("\0", "0");
iString = pads + iString;
char lChar = iString.charAt(iString.length() - 1 - l); // lol
String jlString = Character.toString(lChar);
if (jlString.equals("1")){
product = product.multiply(gs[l]); product = product.multiply(gs[l]);
} else { } else {
product = product.multiply(BigInteger.ONE.subtract(gs[l])); product = product.multiply(BigInteger.ONE.subtract(gs[l]));

View File

@ -0,0 +1,9 @@
package dk.au.pir.utils;
import dk.au.pir.settings.PIRSettings;
public class IntegerUtils {
public static int leastSignificantBit(int integer, int index) {
return (integer >> index) & 1;
}
}