Merge branch 'master' into sup-102

This commit is contained in:
reesporte 2021-11-17 08:11:03 -06:00
commit 7390ae072d
5 changed files with 16 additions and 17 deletions

View file

@ -4,6 +4,6 @@
# very slow but oh well what are you gonna do, not test things?
# note it skips the roaring migrate
echo "mode: atomic" > coverage.out
for pkg in $(go list all | grep featurebase | grep -v roaring-migrate); do
for pkg in $(go list all | grep featurebase ); do
go test -coverprofile=pkgcoverage.out -covermode=atomic $pkg;
tail -n +2 pkgcoverage.out >> coverage.out; done

View file

@ -538,25 +538,17 @@ func (s *Server) SetAPI(api *API) {
// UpAndDown brings the server up minimally and shuts it down
// again; basically, it exists for testing holder open and close.
func (s *Server) UpAndDown() error {
s.logger.Infof("open server. PID %v", os.Getpid())
// Log startup
err := s.holder.logStartup()
if err != nil {
log.Println(errors.Wrap(err, "logging startup"))
}
// Open holder.
if err := s.holder.Open(); err != nil {
return errors.Wrap(err, "opening Holder")
s.logger.Infof("open server. PID %v", os.Getpid())
if err = s.Open(); err != nil {
return errors.Wrap(err, "starting server")
}
errh := s.holder.Close()
if errh != nil {
return errors.Wrap(errh, "closing holder")
}
return nil
err = s.Close()
return errors.Wrap(err, "shutting down server")
}
// Open opens and initializes the server.

View file

@ -293,6 +293,7 @@ func (m *Command) UpAndDown() (err error) {
if err != nil {
return errors.Wrap(err, "setting up server")
}
m.logger.Infof("bringing server up and shutting it down immediately")
go func() {
err := m.Handler.Serve()
@ -306,7 +307,7 @@ func (m *Command) UpAndDown() (err error) {
return errors.Wrap(err, "bringing server up and down")
}
m.logger.Errorf("brought up and shut down again")
m.logger.Infof("teardown complete")
return nil
}

View file

@ -531,6 +531,14 @@ func TestClusteringNodesReplica1(t *testing.T) {
}
}
func TestUpAndDown(t *testing.T) {
c := test.NewCommandNode(t)
err := c.UpAndDown()
if err != nil {
t.Fatalf("server up-and-down: %v", err)
}
}
func TestClusteringNodesReplica2(t *testing.T) {
// Because this test shuts down 2 nodes, it needs to start as a 5-node
// cluster in order to retain enough available nodes for raft leader

View file

@ -60,8 +60,6 @@ func newCommand(tb testing.TB, opts ...server.CommandOption) *Command {
// a problem with PDK tests which used pilosa/client as well. We put it at the
// beginning of the option slice so that it can be overridden by user-passed
// options.
// Also set TranslateFile MapSize to a smaller number so memory allocation
// does not fail on 32-bit systems.
opts = append([]server.CommandOption{
server.OptCommandCloseTimeout(time.Millisecond * 2),
}, opts...)