==47483== Memcheck, a memory error detector ==47483== Copyright (C) 2002-2017, and GNU GPL'd, by Julian Seward et al. ==47483== Using Valgrind-3.14.0 and LibVEX; rerun with -h for copyright info ==47483== Command: /data/blackswan/ripley/R/R-devel-vg/bin/exec/R --vanilla --encoding=UTF-8 ==47483== R Under development (unstable) (2019-04-14 r76395) -- "Unsuffered Consequences" Copyright (C) 2019 The R Foundation for Statistical Computing Platform: x86_64-pc-linux-gnu (64-bit) R is free software and comes with ABSOLUTELY NO WARRANTY. You are welcome to redistribute it under certain conditions. Type 'license()' or 'licence()' for distribution details. Natural language support but running in an English locale R is a collaborative project with many contributors. Type 'contributors()' for more information and 'citation()' on how to cite R or R packages in publications. Type 'demo()' for some demos, 'help()' for on-line help, or 'help.start()' for an HTML browser interface to help. Type 'q()' to quit R. > pkgname <- "msgpack" > source(file.path(R.home("share"), "R", "examples-header.R")) > options(warn = 1) > library('msgpack') > > base::assign(".oldSearch", base::search(), pos = 'CheckExEnv') > base::assign(".old_wd", base::getwd(), pos = 'CheckExEnv') > cleanEx() > nameEx("msgConnection") > ### * msgConnection > > flush(stderr()); flush(stdout()) > > ### Name: msgConnection > ### Title: Read and write msgpack formatted messages over R connections. > ### Aliases: msgConnection close.msgConnection partial > ### partial.msgConnection readMsgs status status.msgConnection > ### seek.msgConnection readMsg writeMsg writeMsgs > > ### ** Examples > > out <- rawConnection(raw(0), open="wb") > apply(quakes, 1, function(x) writeMsg(x, out)) NULL > length(rawConnectionValue(out)) [1] 57300 > inn <- msgConnection(rawConnection(rawConnectionValue(out), open="rb")) > readMsg(inn) lat long depth mag stations -20.42 181.62 562.00 4.80 41.00 > readMsgs(inn, 3) ==47483== Conditional jump or move depends on uninitialised value(s) ==47483== at 0x4623CB: Rf_RealFromInteger (svn/R-devel/src/main/coerce.c:194) ==47483== by 0x4623CB: coerceToReal (svn/R-devel/src/main/coerce.c:583) ==47483== by 0x4623CB: Rf_coerceVector (svn/R-devel/src/main/coerce.c:1276) ==47483== by 0x4623CB: Rf_coerceVector (svn/R-devel/src/main/coerce.c:1175) ==47483== by 0x172228D1: fill_vector (packages/tests-vg/msgpack/src/decode.c:589) ==47483== by 0x17221F0B: extract_simplified_vector (packages/tests-vg/msgpack/src/decode.c:412) ==47483== by 0x17221FD4: make_sexp_from_context (packages/tests-vg/msgpack/src/decode.c:348) ==47483== by 0x17222281: _unpack_msg_partial (packages/tests-vg/msgpack/src/decode.c:245) ==47483== by 0x496143: do_dotcall (svn/R-devel/src/main/dotcode.c:1252) ==47483== by 0x4CEDB6: bcEval (svn/R-devel/src/main/eval.c:7283) ==47483== by 0x4D908F: Rf_eval (svn/R-devel/src/main/eval.c:620) ==47483== by 0x4D9860: forcePromise (svn/R-devel/src/main/eval.c:516) ==47483== by 0x4D9D1F: FORCE_PROMISE (svn/R-devel/src/main/eval.c:4897) ==47483== by 0x4D9D1F: getvar (svn/R-devel/src/main/eval.c:4970) ==47483== by 0x4CE9A3: bcEval (svn/R-devel/src/main/eval.c:6517) ==47483== by 0x4D908F: Rf_eval (svn/R-devel/src/main/eval.c:620) ==47483== Uninitialised value was created by a client request ==47483== at 0x511B8F: Rf_allocVector3 (svn/R-devel/src/main/memory.c:2856) ==47483== by 0x17221EE7: extract_simplified_vector (packages/tests-vg/msgpack/src/decode.c:406) ==47483== by 0x17221FD4: make_sexp_from_context (packages/tests-vg/msgpack/src/decode.c:348) ==47483== by 0x17222281: _unpack_msg_partial (packages/tests-vg/msgpack/src/decode.c:245) ==47483== by 0x496143: do_dotcall (svn/R-devel/src/main/dotcode.c:1252) ==47483== by 0x4CEDB6: bcEval (svn/R-devel/src/main/eval.c:7283) ==47483== by 0x4D908F: Rf_eval (svn/R-devel/src/main/eval.c:620) ==47483== by 0x4D9860: forcePromise (svn/R-devel/src/main/eval.c:516) ==47483== by 0x4D9D1F: FORCE_PROMISE (svn/R-devel/src/main/eval.c:4897) ==47483== by 0x4D9D1F: getvar (svn/R-devel/src/main/eval.c:4970) ==47483== by 0x4CE9A3: bcEval (svn/R-devel/src/main/eval.c:6517) ==47483== by 0x4D908F: Rf_eval (svn/R-devel/src/main/eval.c:620) ==47483== by 0x4D9860: forcePromise (svn/R-devel/src/main/eval.c:516) ==47483== [[1]] lat long depth mag stations -20.62 181.03 650.00 4.20 15.00 [[2]] lat long depth mag stations -26.0 184.1 42.0 5.4 43.0 [[3]] lat long depth mag stations -17.97 181.66 626.00 4.10 19.00 > > > > cleanEx() > nameEx("packMsg") > ### * packMsg > > flush(stderr()); flush(stdout()) > > ### Name: packMsg > ### Title: Convert R objects to msgpack format. > ### Aliases: packMsg packMsgs packOpts prepack prepack.default > ### prepack.data.frame > > ### ** Examples > > packMsg( list(compact=TRUE, schema=0) ) [1] 82 a7 63 6f 6d 70 61 63 74 c3 a6 73 63 68 65 6d 61 00 > x <- packMsgs(list("one", "two", "three")) > unpackMsgs(x, 2) $msgs $msgs[[1]] [1] "one" $msgs[[2]] [1] "two" $remaining [1] a5 74 68 72 65 65 $status [1] "ok" $bytes_read [1] 8 > > > > cleanEx() > nameEx("unpackMsg") > ### * unpackMsg > > flush(stderr()); flush(stdout()) > > ### Name: unpackMsg > ### Title: Decode msgpack messages. > ### Aliases: unpackMsg unpackMsgs unpackOpts > > ### ** Examples > > msg <- as.raw(c(0x82, 0xa7, 0x63, 0x6f, 0x6d, 0x70, 0x61, 0x63, 0x74, 0xc3, + 0xa6, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x00)) > unpackMsg(msg) ==47483== Conditional jump or move depends on uninitialised value(s) ==47483== at 0x4628B2: Rf_ScalarLogical (svn/R-devel/src/include/Rinlinedfuns.h:980) ==47483== by 0x4628B2: coerceToVectorList (svn/R-devel/src/main/coerce.c:869) ==47483== by 0x4628B2: Rf_coerceVector (svn/R-devel/src/main/coerce.c:1292) ==47483== by 0x4628B2: Rf_coerceVector (svn/R-devel/src/main/coerce.c:1175) ==47483== by 0x172228D1: fill_vector (packages/tests-vg/msgpack/src/decode.c:589) ==47483== by 0x17221F0B: extract_simplified_vector (packages/tests-vg/msgpack/src/decode.c:412) ==47483== by 0x17221FD4: make_sexp_from_context (packages/tests-vg/msgpack/src/decode.c:348) ==47483== by 0x1722218A: _unpack_msg (packages/tests-vg/msgpack/src/decode.c:159) ==47483== by 0x496143: do_dotcall (svn/R-devel/src/main/dotcode.c:1252) ==47483== by 0x4CEDB6: bcEval (svn/R-devel/src/main/eval.c:7283) ==47483== by 0x4D908F: Rf_eval (svn/R-devel/src/main/eval.c:620) ==47483== by 0x4DAC3E: R_execClosure (svn/R-devel/src/main/eval.c:1780) ==47483== by 0x4DB994: Rf_applyClosure (svn/R-devel/src/main/eval.c:1706) ==47483== by 0x4D9215: Rf_eval (svn/R-devel/src/main/eval.c:743) ==47483== by 0x5071FC: Rf_ReplIteration (svn/R-devel/src/main/main.c:260) ==47483== by 0x5071FC: Rf_ReplIteration (svn/R-devel/src/main/main.c:200) ==47483== Uninitialised value was created by a client request ==47483== at 0x511E3D: Rf_allocVector3 (svn/R-devel/src/main/memory.c:2858) ==47483== by 0x17221EE7: extract_simplified_vector (packages/tests-vg/msgpack/src/decode.c:406) ==47483== by 0x17221FD4: make_sexp_from_context (packages/tests-vg/msgpack/src/decode.c:348) ==47483== by 0x1722218A: _unpack_msg (packages/tests-vg/msgpack/src/decode.c:159) ==47483== by 0x496143: do_dotcall (svn/R-devel/src/main/dotcode.c:1252) ==47483== by 0x4CEDB6: bcEval (svn/R-devel/src/main/eval.c:7283) ==47483== by 0x4D908F: Rf_eval (svn/R-devel/src/main/eval.c:620) ==47483== by 0x4DAC3E: R_execClosure (svn/R-devel/src/main/eval.c:1780) ==47483== by 0x4DB994: Rf_applyClosure (svn/R-devel/src/main/eval.c:1706) ==47483== by 0x4D9215: Rf_eval (svn/R-devel/src/main/eval.c:743) ==47483== by 0x5071FC: Rf_ReplIteration (svn/R-devel/src/main/main.c:260) ==47483== by 0x5071FC: Rf_ReplIteration (svn/R-devel/src/main/main.c:200) ==47483== by 0x5074D7: R_ReplConsole (svn/R-devel/src/main/main.c:310) ==47483== $compact [1] TRUE $schema [1] 0 > x <- packMsgs(list("one", "two", "three")) > unpackMsgs(x, 2) $msgs $msgs[[1]] [1] "one" $msgs[[2]] [1] "two" $remaining [1] a5 74 68 72 65 65 $status [1] "ok" $bytes_read [1] 8 > > > > ### *