| 183 | |
| 184 | template <typename T> |
| 185 | void TestBasic() { |
| 186 | { |
| 187 | BundleWriter writer(Env::Default(), Prefix("foo")); |
| 188 | TF_EXPECT_OK(writer.Add("foo_003", Constant_2x3(T(3)))); |
| 189 | TF_EXPECT_OK(writer.Add("foo_000", Constant_2x3(T(0)))); |
| 190 | TF_EXPECT_OK(writer.Add("foo_002", Constant_2x3(T(2)))); |
| 191 | TF_EXPECT_OK(writer.Add("foo_001", Constant_2x3(T(1)))); |
| 192 | TF_ASSERT_OK(writer.Finish()); |
| 193 | } |
| 194 | { |
| 195 | BundleReader reader(Env::Default(), Prefix("foo")); |
| 196 | TF_ASSERT_OK(reader.status()); |
| 197 | EXPECT_EQ( |
| 198 | AllTensorKeys(&reader), |
| 199 | std::vector<string>({"foo_000", "foo_001", "foo_002", "foo_003"})); |
| 200 | Expect<T>(&reader, "foo_000", Constant_2x3(T(0))); |
| 201 | Expect<T>(&reader, "foo_001", Constant_2x3(T(1))); |
| 202 | Expect<T>(&reader, "foo_002", Constant_2x3(T(2))); |
| 203 | Expect<T>(&reader, "foo_003", Constant_2x3(T(3))); |
| 204 | } |
| 205 | { |
| 206 | BundleReader reader(Env::Default(), Prefix("foo")); |
| 207 | TF_ASSERT_OK(reader.status()); |
| 208 | ExpectNext<T>(&reader, Constant_2x3(T(0))); |
| 209 | ExpectNext<T>(&reader, Constant_2x3(T(1))); |
| 210 | ExpectNext<T>(&reader, Constant_2x3(T(2))); |
| 211 | ExpectNext<T>(&reader, Constant_2x3(T(3))); |
| 212 | EXPECT_TRUE(reader.Valid()); |
| 213 | reader.Next(); |
| 214 | EXPECT_FALSE(reader.Valid()); |
| 215 | } |
| 216 | { |
| 217 | BundleWriter writer(Env::Default(), Prefix("bar")); |
| 218 | TF_EXPECT_OK(writer.Add("bar_003", Constant_2x3(T(3)))); |
| 219 | TF_EXPECT_OK(writer.Add("bar_000", Constant_2x3(T(0)))); |
| 220 | TF_EXPECT_OK(writer.Add("bar_002", Constant_2x3(T(2)))); |
| 221 | TF_EXPECT_OK(writer.Add("bar_001", Constant_2x3(T(1)))); |
| 222 | TF_ASSERT_OK(writer.Finish()); |
| 223 | } |
| 224 | { |
| 225 | BundleReader reader(Env::Default(), Prefix("bar")); |
| 226 | TF_ASSERT_OK(reader.status()); |
| 227 | EXPECT_EQ( |
| 228 | AllTensorKeys(&reader), |
| 229 | std::vector<string>({"bar_000", "bar_001", "bar_002", "bar_003"})); |
| 230 | Expect<T>(&reader, "bar_003", Constant_2x3(T(3))); |
| 231 | Expect<T>(&reader, "bar_002", Constant_2x3(T(2))); |
| 232 | Expect<T>(&reader, "bar_001", Constant_2x3(T(1))); |
| 233 | Expect<T>(&reader, "bar_000", Constant_2x3(T(0))); |
| 234 | } |
| 235 | { |
| 236 | BundleReader reader(Env::Default(), Prefix("bar")); |
| 237 | TF_ASSERT_OK(reader.status()); |
| 238 | ExpectNext<T>(&reader, Constant_2x3(T(0))); |
| 239 | ExpectNext<T>(&reader, Constant_2x3(T(1))); |
| 240 | ExpectNext<T>(&reader, Constant_2x3(T(2))); |
| 241 | ExpectNext<T>(&reader, Constant_2x3(T(3))); |
| 242 | EXPECT_TRUE(reader.Valid()); |
nothing calls this directly
no test coverage detected