hcq/oceanbase
hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

[VectorIndex] serialize add null ptr check

Browse Source
This commit is contained in:
obdev 2024-09-20 06:19:52 +00:00 committed by ob-robot
parent 65097c9a88
commit 25c9b0f385
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/share/vector_index/ob_plugin_vector_index_serialize.cpp
View File

@ -29,6 +29,9 @@ std::streamsize ObOStreamBuf::xsputn(const char* s, std::streamsize count)
{
std::streamsize written_size = 0;
std::streamsize left_size = 0;
if (OB_ISNULL(s)) {
last_error_code_ = OB_INVALID_ARGUMENT;
}
while (is_valid() && is_success() && written_size < count) {
left_size = epptr() - pptr();
std::streamsize sub_size = std::min(count - written_size, left_size);
@ -122,7 +125,9 @@ std::streamsize ObIStreamBuf::xsgetn(char* s, std::streamsize n)
{
std::streamsize get_size = 0;
std::streamsize data_size = 0;
if (is_success() && !is_valid()) {
if (OB_ISNULL(s)) {
last_error_code_ = OB_INVALID_ARGUMENT;
} else if (is_success() && !is_valid()) {
last_error_code_ = do_callback();
}
while (is_valid() && is_success() && get_size < n) {