Method Run

IceFireDB-SQLite/internal/mysql/server.go:20–52

(ctx context.Context)

}

func (m *mysqlProxy) Run(ctx context.Context) {
	m.ctx = ctx
	m.closed.Store(true)
	ln, err := net.Listen("tcp4", config.Get().Server.Addr)
	if err != nil {
		logrus.Errorf("IceFireDB-SQLite listen fail：%v", err)
		return
	}
	utils.GoWithRecover(func() {
		if <-ctx.Done(); true {
			_ = ln.Close()
			m.closed.Store(true)
		}
	}, nil)

	m.closed.Store(false)

	logrus.Infof("IceFireDB-SQLite listening:%s\n", config.Get().Server.Addr)

	// init sqlitedb
	db := sqlite.InitSQLite(ctx, config.Get().SQLite.Filename)
	m.db = db
	for {
		conn, err := ln.Accept()
		if err != nil {
			if errors.Is(err, io.EOF) || errors.Is(err, net.ErrClosed) {
				return
			}
			panic(err)
		}
		go m.onConn(conn)
	}
}

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