diff --git a/source/libs/tcs/src/tcs.c b/source/libs/tcs/src/tcs.c index 73cb64c34d..a668eac60f 100644 --- a/source/libs/tcs/src/tcs.c +++ b/source/libs/tcs/src/tcs.c @@ -22,8 +22,6 @@ #include "az.h" #include "cos.h" -STcs tcs; - int32_t tcsInit() { int32_t code = 0; @@ -105,15 +103,3 @@ int32_t tcsGetObjectBlock(const char* object_name, int64_t offset, int64_t size, } void tcsDeleteObjectsByPrefix(const char* prefix) { return tcs.DeleteObjectsByPrefix(prefix); } - -int32_t tcsPutObjectFromFile2(const char* file, const char* object, int8_t withcp) { - return tcs.PutObjectFromFile2(file, object, withcp); -} - -int32_t tcsGetObjectsByPrefix(const char* prefix, const char* path) { return tcs.GetObjectsByPrefix(prefix, path); } - -int32_t tcsDeleteObjects(const char* object_name[], int nobject) { return tcs.DeleteObjects(object_name, nobject); } - -int32_t tcsGetObjectToFile(const char* object_name, const char* fileName) { - return tcs.GetObjectToFile(object_name, fileName); -} diff --git a/source/libs/tcs/src/tcsStream.c b/source/libs/tcs/src/tcsStream.c new file mode 100644 index 0000000000..f73bb028ba --- /dev/null +++ b/source/libs/tcs/src/tcsStream.c @@ -0,0 +1,31 @@ +/* + * Copyright (c) 2019 TAOS Data, Inc. + * + * This program is free software: you can use, redistribute, and/or modify + * it under the terms of the GNU Affero General Public License, version 3 + * or later ("AGPL"), as published by the Free Software Foundation. + * + * This program is distributed in the hope that it will be useful, but WITHOUT + * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or + * FITNESS FOR A PARTICULAR PURPOSE. + * + * You should have received a copy of the GNU Affero General Public License + * along with this program. If not, see . + */ + +#include "tcs.h" +#include "tcsInt.h" + +STcs tcs; + +int32_t tcsPutObjectFromFile2(const char* file, const char* object, int8_t withcp) { + return tcs.PutObjectFromFile2(file, object, withcp); +} + +int32_t tcsGetObjectsByPrefix(const char* prefix, const char* path) { return tcs.GetObjectsByPrefix(prefix, path); } + +int32_t tcsDeleteObjects(const char* object_name[], int nobject) { return tcs.DeleteObjects(object_name, nobject); } + +int32_t tcsGetObjectToFile(const char* object_name, const char* fileName) { + return tcs.GetObjectToFile(object_name, fileName); +} diff --git a/source/libs/tcs/test/tcsTest.cpp b/source/libs/tcs/test/tcsTest.cpp index e86c9e02b3..0eb0b4d071 100644 --- a/source/libs/tcs/test/tcsTest.cpp +++ b/source/libs/tcs/test/tcsTest.cpp @@ -59,8 +59,8 @@ int32_t tcsInitEnv(int8_t isBlob) { return code; } -// TEST(TcsTest, DISABLE_InterfaceTest) { -TEST(TcsTest, InterfaceTest) { +TEST(TcsTest, DISABLE_InterfaceTest) { + // TEST(TcsTest, InterfaceTest) { int code = 0; code = tcsInitEnv(true); @@ -97,8 +97,8 @@ TEST(TcsTest, InterfaceTest) { tcsUninit(); } -// TEST(TcsTest, DISABLE_InterfaceNonBlobTest) { -TEST(TcsTest, InterfaceNonBlobTest) { +TEST(TcsTest, DISABLE_InterfaceNonBlobTest) { + // TEST(TcsTest, InterfaceNonBlobTest) { int code = 0; code = tcsInitEnv(false);