mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-04-24 10:30:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

storage_service: Add debug info in gossip state change callback

Browse Source 
Now, we can verify that get_tokens_for(ip) get the correct tokens
through gossip.

Start the seed node first:
$./seastar --listen-address 127.0.0.1 --seed-provider-parameters 127.0.0.1

Then start a normal node:
$./seastar --listen-address 127.0.0.2 --seed-provider-parameters 127.0.0.1

On the second node:

SS::on_join endpoint=127.0.0.1
endpoint=127.0.0.1,
tokens_string=8768e8a2d360bce8;d99d50eae7e514a2;f937ba030e4f1fa2
t=87 68 e8 a2 d3 60 bc e8
t=d9 9d 50 ea e7 e5 14 a2
t=f9 37 ba 03 0e 4f 1f a2

ep=127.0.0.1, eps=EndpointState: HeartBeatState = generation =
1432868747, version = 52, AppStateMap =  { 0 : Value(BOOT,TOKENS,11) }
{ 5 : Value(urchin_1_0,4) }  { 8 : Value(,3) }  { 11 : Value(ms_1_0,1) }
{ 12 : Value(9a6e8c60-05af-11e5-b9b8-000000000000,2) }  { 13 :
Value(8768e8a2d360bce8;d99d50eae7e514a2;f937ba030e4f1fa2,9) }
This commit is contained in:
Asias He
2015-05-29 10:59:00 +08:00
parent e1b9b2e09a
commit 3dc03738bc
1 changed files with 10 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
service/storage_service.hh
View File

@@ -645,6 +645,9 @@ private:
// FIXME: SystemKeyspace.incrementAndGetGeneration()
return gossiper.start(generation_number, app_states).then([] {
print("Start gossiper service ...\n");
#if SS_DEBUG
gms::get_local_gossiper().debug_show();
#endif
});
#if 0
// gossip snitch infos (local DC and rack)
@@ -1330,6 +1333,7 @@ public:
*/
void on_change(gms::inet_address endpoint, gms::application_state state, gms::versioned_value value) override
{
ss_debug("SS::on_change endpoint=%s\n", endpoint);
#if 0
if (state == ApplicationState.STATUS)
{
@@ -1976,6 +1980,11 @@ private:
public:
void on_join(gms::inet_address endpoint, gms::endpoint_state ep_state) override
{
ss_debug("SS::on_join endpoint=%s\n", endpoint);
auto tokens = get_tokens_for(endpoint);
for (auto t : tokens) {
ss_debug("t=%s\n", t);
}
#if 0
for (Map.Entry<ApplicationState, VersionedValue> entry : epState.getApplicationStateMap().entrySet())
{
@@ -1987,6 +1996,7 @@ public:
void on_alive(gms::inet_address endpoint, gms::endpoint_state state) override
{
ss_debug("SS::on_alive endpoint=%s\n", endpoint);
#if 0
MigrationManager.instance.scheduleSchemaPull(endpoint, state);