Merge pull request #1774 from molecula/fbholder

unbreak featurebase holder subcommand
This commit is contained in:
seebs 2021-11-16 15:18:06 -06:00 • committed by GitHub
commit 2e0b5cb55b
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
4 changed files with 15 additions and 16 deletions

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...)