statestore-test.cc

Go to the documentation of this file.

// Copyright 2012 Cloudera Inc.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

#include "testutil/in-process-servers.h"

#include <gtest/gtest.h>
#include "common/init.h"
#include "util/metrics.h"
#include "statestore/statestore-subscriber.h"

#include "common/names.h"

using namespace impala;

DECLARE_int32(webserver_port);
DECLARE_int32(state_store_port);

namespace impala {

TEST(StatestoreTest, SmokeTest) {
  // All allocations done by 'new' to avoid problems shutting down Thrift servers
  // gracefully.

  InProcessStatestore* statestore =
      new InProcessStatestore(FLAGS_state_store_port, FLAGS_webserver_port);
  ASSERT_TRUE(statestore->Start().ok());

  InProcessStatestore* statestore_wont_start =
      new InProcessStatestore(FLAGS_state_store_port, FLAGS_webserver_port);
  ASSERT_FALSE(statestore_wont_start->Start().ok());

  StatestoreSubscriber* sub_will_start = new StatestoreSubscriber("sub1",
      MakeNetworkAddress("localhost", 12345),
      MakeNetworkAddress("localhost", FLAGS_state_store_port), new MetricGroup(""));
  ASSERT_TRUE(sub_will_start->Start().ok());

  // Confirm that a subscriber trying to use an in-use port will fail to start.
  StatestoreSubscriber* sub_will_not_start = new StatestoreSubscriber("sub2",
      MakeNetworkAddress("localhost", 12345),
      MakeNetworkAddress("localhost", FLAGS_state_store_port), new MetricGroup(""));
  ASSERT_FALSE(sub_will_not_start->Start().ok());

}

}

int main(int argc, char **argv) {
  InitCommonRuntime(argc, argv, false);
  ::testing::InitGoogleTest(&argc, argv);
  return RUN_ALL_TESTS();
}