Hi all,
Here is the R code function in where I called the two C++ and further below
are the 2 C++ functions I used to create the externalptr and use it :
soam.Rapply <- function (x, func, ...,
join.method=cbind,
njobs,
batch.size=100,
packages=NULL,
savelist=NULL)
{
if(missing(njobs))
njobs <- max(1,ceiling(nrow(x)/batch.size))
if(!is.matrix(x) && !is.data.frame(x))
stop("x must be a matrix or data frame")
if(njobs>1)
{rowSet <- lapply(splitIndices(nrow(x), njobs), function(i) x[i, ,
drop = FALSE])} else {rowSet <- list(x)}
sesCon <- .Call("soamInit")
script <- " "
fname <- tempfile(pattern = "Rsoam_data", tmpdir = getwd())
file(fname, open="w+")
if(!is.null(savelist)) {
dump(savelist, fname)
script<-readLines(fname)
}
if(!is.null(packages))
for(counter in 1:length(packages))
{
temp<-call("library", packages[counter], character.only=TRUE)
dput(temp, fname)
pack.call<-readLines(fname)
script<-append(script, pack.call)
}
for(counter in 1:njobs)
{
caller <- paste("caller", counter, sep = "")
soam.call<-call("dput", call("apply", X=rowSet[[counter]], MARGIN=1,
FUN=func), caller)
dput(soam.call, fname)
soam.call<-readLines(fname)
temp<-append(script, soam.call)
final.script = temp[1]
for(count in 2:length(temp)){
final.script<-paste(final.script, temp[count], "\n")}
.Call("soamSubmit", counter, sesCon, final.script, packages)
}
.Call("soamGetResults", sesCon, njobs, join.method, parent.frame())
for(job in 1:njobs)
{
caller <- paste("result", job, sep = "")
temp = dget(caller)
if(job==1) {retval=temp} else {retval=join.method(retval,temp)}
}
.Call("soamUninit")
retval
}
*** Here are the 2 C++ functions:
extern "C"
{
SEXP soamInit ()
{
// Initialize the API
SoamFactory::initialize();
// Set up application specific information to be supplied to Symphony
char appName[] = "SampleAppCPP";
// Set up application authentication information using the default
security provider
DefaultSecurityCallback securityCB("Guest", "Guest");
// Connect to the specified application
ConnectionPtr conPtr = SoamFactory::connect(appName, &securityCB);
// Set up session creation attributes
SessionCreationAttributes attributes;
attributes.setSessionName("mySession");
attributes.setSessionType("ShortRunningTasks");
attributes.setSessionFlags(SF_RECEIVE_SYNC);
// Create a synchronous session
Session* sesPtr = conPtr->createSession(attributes);
SEXP out = R_MakeExternalPtr((void*)temp, R_NilValue, R_NilValue);
return out;
}
}
extern "C"
{
void soamSubmit (SEXP jobID, //job ID
SEXP sesCon, //session pointer
SEXP caller, //objects
SEXP pack) //packages
{
char* savelist = CHAR(STRING_ELT(caller, 0));
string strTemp = "";
int job = INTEGER(jobID)[0];
void* temp = R_ExternalPtrAddr(sesCon);
Session* sesPtr = reinterpret_cast<Session*>(temp);
// Create a message
MyMessage inMsg(job, /*pack,*/ savelist);
// Send it
TaskInputHandlePtr input = sesPtr->sendTaskInput(&inMsg);
}
}
--
View this message in context:
http://www.nabble.com/Using-R_MakeExternalPtr-tf4142904.html#a11786494
Sent from the R devel mailing list archive at Nabble.com.
______________________________________________
R-devel@r-project.org mailing list
https://stat.ethz.ch/mailman/listinfo/r-devel
