Fixed inWork key calculation bug in MultiStaged
This commit is contained in:
parent
e209e5039c
commit
dfdeb5e52c
4 changed files with 7 additions and 7 deletions
|
@ -17,7 +17,7 @@
|
|||
using namespace std;
|
||||
|
||||
#define BATCH_MAX 4096
|
||||
#define WIN_SIZE 21
|
||||
#define WIN_SIZE 16
|
||||
|
||||
int main() {
|
||||
util::bytestr key("db53d9bbd1f3a83b094eeca7dd970bd85b492fa2");
|
||||
|
|
|
@ -20,7 +20,7 @@ public class CnC {
|
|||
public static final int MAX_BITS = 62;
|
||||
|
||||
public static void main(String[] args) {
|
||||
KeyServer kts = KSFactory.build(54, 30, 15, TimeUnit.MINUTES, 0.62f);
|
||||
KeyServer kts = KSFactory.build(50, 26, 1, TimeUnit.MINUTES, 0.62f);
|
||||
CommServer server = new CommServer(PORT, kts);
|
||||
try {
|
||||
server.listen();
|
||||
|
|
|
@ -101,7 +101,7 @@ public class ClientWorker implements Runnable {
|
|||
|
||||
private void retrieveResult() {
|
||||
try {
|
||||
String[] result = in.readLine().split(" ");
|
||||
String[] result = in.readLine().split(" "); // TODO: null check for in.readLine()
|
||||
KeyRange kr = new KeyRange(Long.parseLong(result[0], 16), Long.parseLong(result[1], 16));
|
||||
|
||||
synchronized (keyServer) {
|
||||
|
|
|
@ -81,9 +81,9 @@ public class MultiStagedServer implements KeyServer {
|
|||
keyRangeBuffer.setInWork(keyRange);
|
||||
|
||||
// strip out partition bits -> get subspace KeyRange only
|
||||
long mask = ((long) 1 << subIndex) - 1;
|
||||
long mask = ((long) 1 << subIndex + 1) - 1;
|
||||
// add leading bit
|
||||
long lb = ((long) 1 << subIndex);
|
||||
long lb = ((long) 1 << subIndex + 1);
|
||||
|
||||
KeyRange secKR =
|
||||
new KeyRange(((keyRange.getStart() & mask) | lb), ((keyRange.getEnd() & mask) | lb));
|
||||
|
@ -96,9 +96,9 @@ public class MultiStagedServer implements KeyServer {
|
|||
|
||||
keyRangeBuffer.setSearched(keyRange);
|
||||
// strip out partition bits -> get subspace KeyRange only
|
||||
long mask = ((long) 1 << subIndex) - 1;
|
||||
long mask = ((long) 1 << subIndex + 1) - 1;
|
||||
// add leading bit
|
||||
long lb = ((long) 1 << subIndex);
|
||||
long lb = ((long) 1 << subIndex + 1);
|
||||
|
||||
KeyRange secKR =
|
||||
new KeyRange(((keyRange.getStart() & mask) | lb), ((keyRange.getEnd() & mask) | lb));
|
||||
|
|
Loading…
Reference in a new issue