docs: synchronized public void takeMastership(int partitionId) {
          m_masterOfPartitions.add(partitionId);
          ExportGeneration generation = m_generation.get();
          if (generation == null) {
              return;
          }
          generation.takeMastership(partitionId);
      }