placeholder for serialize

This commit is contained in:
tushicheng
2024-01-19 12:17:43 +00:00
committed by ob-robot
parent 7688f5aa8a
commit 690a0d5bb5
4 changed files with 11 additions and 0 deletions

View File

@ -41,6 +41,7 @@ ObTask::ObTask()
location_idx_(OB_INVALID_INDEX),
max_sql_no_(-1)
{
sql_string_[0] = '\0';
}
ObTask::~ObTask()
@ -92,6 +93,7 @@ OB_DEF_SERIALIZE(ObTask)
}
LST_DO_CODE(OB_UNIS_ENCODE, ranges_);
LST_DO_CODE(OB_UNIS_ENCODE, max_sql_no_);
OB_UNIS_ENCODE(ObString(sql_string_));
return ret;
}
@ -153,6 +155,8 @@ OB_DEF_DESERIALIZE(ObTask)
}
}
LST_DO_CODE(OB_UNIS_DECODE, max_sql_no_);
ObString sql_string;
OB_UNIS_DECODE(sql_string);
return ret;
}
@ -184,6 +188,7 @@ OB_DEF_SERIALIZE_SIZE(ObTask)
LST_DO_CODE(OB_UNIS_ADD_LEN, ranges_);
}
LST_DO_CODE(OB_UNIS_ADD_LEN, max_sql_no_);
OB_UNIS_ADD_LEN(ObString(sql_string_));
return len;
}

View File

@ -97,6 +97,7 @@ protected:
// 本Task涉及到的扫描范围,默认涉及的一张表(一个或者多个partition)
common::ObSEArray<ObNewRange, 32> ranges_;
int64_t max_sql_no_;
char sql_string_[common::OB_TINY_SQL_LENGTH + 1];
//DISALLOW_COPY_AND_ASSIGN(ObTask);
};