/** * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you 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 #ifndef __CYGWIN__ #include #endif #include #include "commons.h" #include "Buffers.h" #include "FileSystem.h" #include "NativeObjectFactory.h" #include "test_commons.h" extern "C" { static void handler(int sig); // TODO: just for debug, should be removed void handler(int sig) { void *array[10]; size_t size; // print out all the frames to stderr fprintf(stderr, "Error: signal %d:\n", sig); #ifndef __CYGWIN__ // get void*'s for all entries on the stack size = backtrace(array, 10); backtrace_symbols_fd(array, size, 2); #endif exit(1); } } using namespace NativeTask; typedef char * CString; int main(int argc, char ** argv) { signal(SIGSEGV, handler); CString * newArgv = new CString[argc + 1]; memcpy(newArgv, argv, argc * sizeof(CString)); bool gen = false; if (argc > 1) { if (string("perf") == newArgv[1]) { newArgv[1] = (char *)"--gtest_filter=Perf.*"; } else if (string("noperf") == newArgv[1]) { newArgv[1] = (char *)"--gtest_filter=-Perf.*"; } else if (string("gen") == newArgv[1]) { gen = true; } } testing::InitGoogleTest(&argc, newArgv); if (argc > 0) { int skip = gen ? 2 : 1; TestConfig.parse(argc - skip, (const char **)(newArgv + skip)); } delete [] newArgv; try { if (gen == true) { string type = TestConfig.get("generate.type", "word"); string codec = TestConfig.get("generate.codec", ""); int64_t len = TestConfig.getInt("generate.length", 1024); string temp; GenerateKVTextLength(temp, len, type); if (codec.length() == 0) { fprintf(stdout, "%s", temp.c_str()); } else { OutputStream * fout = FileSystem::getLocal().create("/dev/stdout"); AppendBuffer app = AppendBuffer(); app.init(128 * 1024, fout, codec); app.write(temp.data(), temp.length()); fout->close(); delete fout; } NativeObjectFactory::Release(); return 0; } else { int ret = RUN_ALL_TESTS(); NativeObjectFactory::Release(); return ret; } } catch (std::exception & e) { fprintf(stderr, "Exception: %s", e.what()); NativeObjectFactory::Release(); return 1; } }