diff --git a/src/frontend/query.c b/src/frontend/query.c
index 35ff1026d1d84686d10468b9fe5046d5a14d7a41..933ca04cae5a887156400b27fb78c086d0fc6c33 100644 (file)
--- a/src/frontend/query.c
+++ b/src/frontend/query.c
return -1;
}
- type = sdb_proto_get_int(conn->buf, 0);
+ type = sdb_proto_unmarshal_int32(SDB_STRBUF_STR(conn->buf));
strncpy(name, sdb_strbuf_string(conn->buf) + sizeof(uint32_t),
conn->cmd_len - sizeof(uint32_t));
name[sizeof(name) - 1] = '\0';
return -1;
if (conn->cmd_len == sizeof(uint32_t))
- type = sdb_proto_get_int(conn->buf, 0);
+ type = sdb_proto_unmarshal_int32(SDB_STRBUF_STR(conn->buf));
else if (conn->cmd_len) {
sdb_log(SDB_LOG_ERR, "frontend: Invalid command length %d for "
"LIST command", conn->cmd_len);
conn->cmd_len);
return -1;
}
- type = sdb_proto_get_int(conn->buf, 0);
+ type = sdb_proto_unmarshal_int32(SDB_STRBUF_STR(conn->buf));
matcher = sdb_strbuf_string(conn->buf) + sizeof(uint32_t);
matcher_len = conn->cmd_len - sizeof(uint32_t);