Skip to content
This repository was archived by the owner on Sep 27, 2019. It is now read-only.

Commit e7fc857

Browse files
committed
Revert "Removed serialization"
This reverts commit d055ff9.
1 parent c99abdc commit e7fc857

File tree

2 files changed

+2
-4
lines changed

2 files changed

+2
-4
lines changed

src/network/service/peloton_service.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -357,7 +357,7 @@ void PelotonService::QueryPlan(::google::protobuf::RpcController *controller,
357357
LOG_ERROR("Queryplan recived desen't have type");
358358
break;
359359
}
360-
#if 0
360+
361361
case PlanNodeType::SEQSCAN: {
362362
LOG_TRACE("SEQSCAN revieved");
363363
std::string plan = request->plan();
@@ -400,7 +400,7 @@ void PelotonService::QueryPlan(::google::protobuf::RpcController *controller,
400400

401401
break;
402402
}
403-
#endif
403+
404404
default: {
405405
LOG_ERROR("Queryplan recived :: Unsupported TYPE: %s",
406406
PlanNodeTypeToString(plan_type).c_str());

test/network/rpc_queryplan_test.cpp

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,6 @@ namespace test {
2222
class RpcQueryPlanTests : public PelotonTest {};
2323

2424
TEST_F(RpcQueryPlanTests, BasicTest) {
25-
#if 0
2625
peloton::planner::SeqScanPlan mapped_plan_ptr;
2726

2827
const peloton::PlanNodeType type = mapped_plan_ptr.GetPlanNodeType();
@@ -33,7 +32,6 @@ TEST_F(RpcQueryPlanTests, BasicTest) {
3332
bool serialize = mapped_plan_ptr.SerializeTo(output_plan);
3433
// Becuase the plan is not completed, so it is false
3534
EXPECT_FALSE(serialize);
36-
#endif
3735
}
3836
}
3937
}

0 commit comments

Comments
 (0)