Function Run

IceFireDB-SQLProxy/internal/mysql/server.go:17–54

(ctx context.Context)

)

func Run(ctx context.Context) (err error) {
	ms := newMysqlProxy()
	ms.ctx = ctx
	ms.closed.Store(true)

	if err = ms.initClientPool(); err != nil {
		return fmt.Errorf("initClientPool error: %v", err)
	}
	ln, err := net.Listen("tcp4", config.Get().Server.Addr)
	if err != nil {
		logrus.Errorf("mysql%v", err)
		return
	}
	utils.GoWithRecover(func() {
		if <-ctx.Done(); true {
			_ = ln.Close()
			ms.closed.Store(true)
		}
	}, nil)

	ms.closed.Store(false)
	logrus.Infof("%s\n", config.Get().Server.Addr)
	// p2p
	if config.Get().P2P.Enable {
		initP2P(ms)
	}
	for {
		conn, err := ln.Accept()
		if err != nil {
			if errors.Is(err, io.EOF) || errors.Is(err, net.ErrClosed) {
				continue
			}
			panic(err)
		}
		go ms.onConn(conn)
	}
	return
}

func newMysqlProxy() *mysqlProxy {
	p := &mysqlProxy{}