Skip to content

Commit 292233d

Browse files
committed
Switch to R::serializeToRaw() and R::unserializeFromRaw()
1 parent 42934b1 commit 292233d

File tree

2 files changed

+17
-17
lines changed

2 files changed

+17
-17
lines changed

DESCRIPTION

+1-1
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,6 @@ SystemRequirements: An available hiredis library (eg via package
1818
URL: https://github.com/eddelbuettel/rcppredis, https://dirk.eddelbuettel.com/code/rcpp.redis.html
1919
BugReports: https://github.com/eddelbuettel/rcppredis/issues
2020
License: GPL (>= 2)
21-
Imports: methods, Rcpp (>= 0.11.0), RApiSerialize
21+
Imports: methods, Rcpp (>= 0.11.0), RApiSerialize (>= 0.1.4)
2222
LinkingTo: Rcpp, RApiSerialize
2323
Suggests: RcppMsgPack, tinytest

src/Redis.cpp

+16-16
Original file line numberDiff line numberDiff line change
@@ -248,7 +248,7 @@ class Redis {
248248
std::string set(std::string key, SEXP s) {
249249

250250
// if raw, use as is else serialize to raw
251-
Rcpp::RawVector x = (TYPEOF(s) == RAWSXP) ? s : serializeToRaw(s);
251+
Rcpp::RawVector x = (TYPEOF(s) == RAWSXP) ? s : R::serializeToRaw(s);
252252

253253
// uses binary protocol, see hiredis doc at github
254254
redisReply *reply =
@@ -271,7 +271,7 @@ class Redis {
271271
int nc = reply->len;
272272
Rcpp::RawVector res(nc);
273273
memcpy(res.begin(), reply->str, nc);
274-
obj = unserializeFromRaw(res);
274+
obj = R::unserializeFromRaw(res);
275275
}
276276
freeReplyObject(reply);
277277
return(obj);
@@ -281,7 +281,7 @@ class Redis {
281281
int hset(std::string key, std::string field, SEXP s) {
282282

283283
// if raw, use as is else serialize to raw
284-
Rcpp::RawVector x = (TYPEOF(s) == RAWSXP) ? s : serializeToRaw(s);
284+
Rcpp::RawVector x = (TYPEOF(s) == RAWSXP) ? s : R::serializeToRaw(s);
285285

286286
// uses binary protocol, see hiredis doc at github
287287
redisReply *reply =
@@ -305,7 +305,7 @@ class Redis {
305305
Rcpp::RawVector res(nc);
306306
memcpy(res.begin(), reply->str, nc);
307307
freeReplyObject(reply);
308-
SEXP obj = unserializeFromRaw(res);
308+
SEXP obj = R::unserializeFromRaw(res);
309309
return(obj);
310310
}
311311

@@ -379,7 +379,7 @@ class Redis {
379379
int vlen = reply->element[valueidx]->len;
380380
Rcpp::RawVector res(vlen);
381381
memcpy(res.begin(), reply->element[valueidx]->str, vlen);
382-
SEXP obj = unserializeFromRaw(res);
382+
SEXP obj = R::unserializeFromRaw(res);
383383
vec[i] = obj;
384384
}
385385
vec.names() = keys;
@@ -391,7 +391,7 @@ class Redis {
391391
SEXP sadd(std::string key, SEXP s) {
392392

393393
// if raw, use as is else serialize to raw
394-
Rcpp::RawVector x = (TYPEOF(s) == RAWSXP) ? s : serializeToRaw(s);
394+
Rcpp::RawVector x = (TYPEOF(s) == RAWSXP) ? s : R::serializeToRaw(s);
395395
const char* cmdv[3] = {"SADD", key.c_str(), reinterpret_cast<char*>(x.begin())};
396396
size_t cmdlen[3] = {4, key.length(), static_cast<size_t>(x.size())};
397397

@@ -407,7 +407,7 @@ class Redis {
407407
SEXP srem(std::string key, SEXP s) {
408408

409409
// if raw, use as is else serialize to raw
410-
Rcpp::RawVector x = (TYPEOF(s) == RAWSXP) ? s : serializeToRaw(s);
410+
Rcpp::RawVector x = (TYPEOF(s) == RAWSXP) ? s : R::serializeToRaw(s);
411411
const char* cmdv[3] = {"SREM", key.c_str(), reinterpret_cast<char*>(x.begin())};
412412
size_t cmdlen[3] = {4, key.length(), static_cast<size_t>(x.size())};
413413

@@ -431,7 +431,7 @@ class Redis {
431431
int nc = reply->element[i]->len;
432432
Rcpp::RawVector res(nc);
433433
memcpy(res.begin(), reply->element[i]->str, nc);
434-
SEXP obj = unserializeFromRaw(res);
434+
SEXP obj = R::unserializeFromRaw(res);
435435
x[i] = obj;
436436
}
437437

@@ -479,7 +479,7 @@ class Redis {
479479
int nc = reply->element[i]->len;
480480
Rcpp::RawVector res(nc);
481481
memcpy(res.begin(), reply->element[i]->str, nc);
482-
SEXP obj = unserializeFromRaw(res);
482+
SEXP obj = R::unserializeFromRaw(res);
483483
x[i] = obj;
484484
}
485485

@@ -513,7 +513,7 @@ class Redis {
513513
int nc = reply->len;
514514
Rcpp::RawVector res(nc);
515515
memcpy(res.begin(), reply->str, nc);
516-
obj = unserializeFromRaw(res);
516+
obj = R::unserializeFromRaw(res);
517517
}
518518

519519
return(obj);
@@ -543,7 +543,7 @@ class Redis {
543543
SEXP lpush(std::string key, SEXP s) {
544544

545545
// if raw, use as is else serialize to raw
546-
Rcpp::RawVector x = (TYPEOF(s) == RAWSXP) ? s : serializeToRaw(s);
546+
Rcpp::RawVector x = (TYPEOF(s) == RAWSXP) ? s : R::serializeToRaw(s);
547547

548548
// uses binary protocol, see hiredis doc at github
549549
redisReply *reply =
@@ -561,7 +561,7 @@ class Redis {
561561
SEXP rpush(std::string key, SEXP s) {
562562

563563
// if raw, use as is else serialize to raw
564-
Rcpp::RawVector x = (TYPEOF(s) == RAWSXP) ? s : serializeToRaw(s);
564+
Rcpp::RawVector x = (TYPEOF(s) == RAWSXP) ? s : R::serializeToRaw(s);
565565

566566
// uses binary protocol, see hiredis doc at github
567567
redisReply *reply =
@@ -939,17 +939,17 @@ class Redis {
939939
vec[i] = extract_reply(reply->element[i]);
940940
} else
941941
{
942-
if(type == "string") {
942+
if (type == "string") {
943943
vec[i] = Rcpp::wrap(std::string(reply->element[i]->str));
944944
goto end;
945945
}
946946
int vlen = reply->element[i]->len;
947947
Rcpp::RawVector res(vlen);
948948
memcpy(res.begin(), reply->element[i]->str, vlen);
949-
if(type == "raw") {
949+
if (type == "raw") {
950950
vec[i] = res;
951951
} else {
952-
vec[i] = unserializeFromRaw(res);
952+
vec[i] = R::unserializeFromRaw(res);
953953
}
954954
}
955955
}
@@ -995,7 +995,7 @@ class Redis {
995995
SEXP publish(std::string channel, SEXP s) {
996996

997997
// if raw, use as is else serialize to raw
998-
Rcpp::RawVector x = (TYPEOF(s) == RAWSXP) ? s : serializeToRaw(s);
998+
Rcpp::RawVector x = (TYPEOF(s) == RAWSXP) ? s : R::serializeToRaw(s);
999999

10001000
// uses binary protocol, see hiredis doc at github
10011001
redisReply *reply =

0 commit comments

Comments
 (0)