Hawkin
/
arangodb
mirror of https://gitee.com/bigwinds/arangodb
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Add more logging about shard creation/dropping/cleaning.

This commit is contained in:
Max Neunhoeffer 2016-10-13 13:26:20 +02:00
parent c576426bfa
commit 79c0f54072
1 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
js/server/modules/@arangodb/cluster.js
View File

@ -472,9 +472,13 @@ function createLocalCollections (plannedCollections, planVersion,
servers: [ ourselves ], servers: [ ourselves ],
planVersion: planVersion }; planVersion: planVersion };
console.error('creating Current/Collections/' + database + '/' +
collInfo.planId + '/' + shard);
global.ArangoAgency.set('Current/Collections/' + database + '/' + global.ArangoAgency.set('Current/Collections/' + database + '/' +
collInfo.planId + '/' + shard, collInfo.planId + '/' + shard,
payload); payload);
console.error('creating Current/Collections/' + database + '/' +
collInfo.planId + '/' + shard + ' done.');
}; };
var takeOver = createCollectionAgency; var takeOver = createCollectionAgency;
@ -782,7 +786,11 @@ function dropLocalCollections (plannedCollections, currentCollections,
var dropCollectionAgency = function (database, shardID, id) { var dropCollectionAgency = function (database, shardID, id) {
try { try {
console.error('dropping Current/Collections/' + database + '/' +
id + '/' + shardID);
global.ArangoAgency.remove('Current/Collections/' + database + '/' + id + '/' + shardID); global.ArangoAgency.remove('Current/Collections/' + database + '/' + id + '/' + shardID);
console.error('dropping Current/Collections/' + database + '/' +
id + '/' + shardID + ' done.');
} catch (err) { } catch (err) {
// ignore errors // ignore errors
} }
@ -888,7 +896,11 @@ function cleanupCurrentCollections (plannedCollections, currentCollections,
writeLocked) { writeLocked) {
var dropCollectionAgency = function (database, collection, shardID) { var dropCollectionAgency = function (database, collection, shardID) {
try { try {
console.error('cleaning Current/Collections/' + database + '/' +
collection + '/' + shardID);
global.ArangoAgency.remove('Current/Collections/' + database + '/' + collection + '/' + shardID); global.ArangoAgency.remove('Current/Collections/' + database + '/' + collection + '/' + shardID);
console.error('cleaning Current/Collections/' + database + '/' +
collection + '/' + shardID + ' done.');
} catch (err) { } catch (err) {
// ignore errors // ignore errors
} }