负载同步

game/game_cluster/nodes/db/module/actor_save_db.go

@@ -96,6 +96,7 @@ func (p *ActorSaves) saveAccountDB() {
 			clog.Fatalf("saveAccountDB Bulk write failed: %v", err)
 		}
 		mdb.RDB.HDel(ctx, constant.NewAccounts, updAccount...)
+		clog.Infof("update account to db count=%v", len(bulkUpdOps))
 	}
 
 	if len(bulkInsAccountOps) > 0 {
@@ -104,6 +105,7 @@ func (p *ActorSaves) saveAccountDB() {
 			log.Fatalf("Bulk write failed: %v", err)
 		}
 		mdb.RDB.HDel(ctx, constant.NewAccounts, insAccount...)
+		clog.Infof("insert account to db count=%v", len(bulkInsAccountOps))
 	}
 	if len(bulkInsPlayerOps) > 0 {
 		_, err := mdb.MDB.Collection(constant.CNamePlayer).BulkWrite(context.Background(), bulkInsPlayerOps)
@@ -111,6 +113,7 @@ func (p *ActorSaves) saveAccountDB() {
 			log.Fatalf("Bulk write failed: %v", err)
 		}
 		mdb.RDB.HDel(ctx, constant.NewPlayers, insPlayer...)
+		clog.Infof("insert player info to db count=%v", len(bulkInsPlayerOps))
 	}
 
 }
@@ -144,6 +147,7 @@ func (p *ActorSaves) savePlayerDB() {
 			clog.Fatalf("saveAccountDB Bulk write failed: %v", err)
 		}
 		mdb.RDB.HDel(ctx, constant.NewPlayers, updPlayer...)
+		clog.Infof("update player info to db count=%v", len(bulkUpdOps))
 	}
 }