mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-05-29 19:21:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

transport/server: CQL unset value support

Browse Source 
This patch implements support for CQL unset values at the protocol level.

Fixes #2039
This commit is contained in:
Pekka Enberg
2017-01-25 20:39:23 +02:00
parent 2bd560118e
commit 533c8d3949
1 changed files with 20 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
transport/server.cc
View File

@@ -1444,7 +1444,16 @@ void cql_server::connection::read_value_view_list(bytes_view& buf, std::vector<c
cql3::raw_value cql_server::connection::read_value(bytes_view& buf) {
auto len = read_int(buf);
if (len < 0) {
return cql3::raw_value::make_null();
if (_version < 4) {
return cql3::raw_value::make_null();
}
if (len == -1) {
return cql3::raw_value::make_null();
} else if (len == -2) {
return cql3::raw_value::make_unset_value();
} else {
throw exceptions::protocol_exception(sprint("invalid value length: %d", len));
}
}
check_room(buf, len);
bytes b(reinterpret_cast<const int8_t*>(buf.begin()), len);
@@ -1455,7 +1464,16 @@ cql3::raw_value cql_server::connection::read_value(bytes_view& buf) {
cql3::raw_value_view cql_server::connection::read_value_view(bytes_view& buf) {
auto len = read_int(buf);
if (len < 0) {
return cql3::raw_value_view::make_null();
if (_version < 4) {
return cql3::raw_value_view::make_null();
}
if (len == -1) {
return cql3::raw_value_view::make_null();
} else if (len == -2) {
return cql3::raw_value_view::make_unset_value();
} else {
throw exceptions::protocol_exception(sprint("invalid value length: %d", len));
}
}
check_room(buf, len);
bytes_view bv(reinterpret_cast<const int8_t*>(buf.begin()), len);