def get_tmaster(self, topologyName, callback=None):
if callback:<EOL><INDENT>self.tmaster_watchers[topologyName].append(callback)<EOL><DEDENT>else:<EOL><INDENT>tmaster_path = self.get_tmaster_path(topologyName)<EOL>with open(tmaster_path) as f:<EOL><INDENT>data = f.read()<EOL>tmaster = TMasterLocation()<EOL>tmaster.ParseFromString(data)<EOL>return tmaster<EOL><DEDENT><DEDENT>
Get tmaster