Method Open

datanode/datanode.go:169–222

Open data node for serving

()

// Open data node for serving
func (d *dataNode) Open() error {
	d.startedAt = utils.Now()

	//1. start schema watch
	d.startSchemaWatch()

	// memstore fetch local disk schema
	err := d.memStore.FetchSchema()
	if err != nil {
		return err
	}

	// 2. start debug server
	go d.startDebugServer()

	// 3. first shard assignment
	d.mapWatch, err = d.topo.Watch()
	if err != nil {
		return utils.StackError(err, "failed to watch topology")
	}

	select {
	case <-d.mapWatch.C():
		hostShardSet, ok := d.mapWatch.Get().LookupHostShardSet(d.hostID)
		if ok {
			d.assignShardSet(hostShardSet.ShardSet())
		}
	default:
	}

	d.memStore.GetHostMemoryManager().Start()

	// 5. start scheduler
	if !d.opts.ServerConfig().SchedulerOff {
		d.logger.Info("starting scheduler")
		// disable archiving during redolog replay
		d.memStore.GetScheduler().EnableJobType(memCom.ArchivingJobType, false)
		// this will start scheduler of all jobs except archiving, archiving will be started individually
		d.memStore.GetScheduler().Start()
	} else {
		d.logger.Info("scheduler is turned off")
	}

	// 6. start table addition watch
	go d.startTableAdditionWatch()
	// 7. start active topology watch
	go d.startActiveTopologyWatch()
	// 8. start analyzing shard availability
	go d.startAnalyzingShardAvailability()
	// 9. start analyzing server readiness
	go d.startAnalyzingServerReadiness()

	return nil
}

func (d *dataNode) startSchemaWatch() {
	if d.opts.ServerConfig().Cluster.Enable {