1
0
Fork 0

Fix reporting of new collection in Current (shardID instead of DBserverID)

This commit is contained in:
Max Neunhoeffer 2014-01-21 09:56:54 +01:00
parent 41b35c82da
commit 18436b6b27
1 changed files with 4 additions and 4 deletions

View File

@ -271,8 +271,8 @@ function handleDatabaseChanges (plan, current) {
function createLocalCollections (plannedCollections) { function createLocalCollections (plannedCollections) {
var ourselves = ArangoServerState.id(); var ourselves = ArangoServerState.id();
var createCollectionAgency = function (database, payload) { var createCollectionAgency = function (database, shard, payload) {
ArangoAgency.set("Current/Collections/" + database + "/" + payload.id + "/" + ourselves, ArangoAgency.set("Current/Collections/" + database + "/" + payload.id + "/" + shard,
payload); payload);
}; };
@ -336,7 +336,7 @@ function createLocalCollections (plannedCollections) {
writeLocked({ part: "Current" }, writeLocked({ part: "Current" },
createCollectionAgency, createCollectionAgency,
[ database, payload ]); [ database, shard, payload ]);
} }
else { else {
// collection exists, now compare collection properties // collection exists, now compare collection properties
@ -370,7 +370,7 @@ function createLocalCollections (plannedCollections) {
writeLocked({ part: "Current" }, writeLocked({ part: "Current" },
createCollectionAgency, createCollectionAgency,
[ database, payload ]); [ database, shard, payload ]);
} }
} }
} }