get_iqfeed_data - on WINDOWS - 6011 cannot be opened - Error in socketConnection

On windows when I execute, I get the following error

> get_iqfeed_data( 'MSFT', '2015-01-01', '2016-01-01', 'hour' )

Error in socketConnection(Sys.info()["nodename"], port = 6011) :
  cannot open the connection
In addition: Warning message:
In socketConnection(Sys.info()["nodename"], port = 6011) :
  TARGETSERVER:6011 cannot be opened

I try some simple debugging

> debug(QuantTools:::.get_iqfeed)

> get_iqfeed_data( 'MSFT', '2015-01-01', '2016-01-01', 'hour' )

Browse[2]>  con2 <- socketConnection(Sys.info()["nodename"], port = 6011)

Error in socketConnection(Sys.info()["nodename"], port = 6011) :
  cannot open the connection
In addition: Warning message:
In socketConnection(Sys.info()["nodename"], port = 6011) :
  TARGETSERVER:6011 cannot be opened

Browse[2]>

Seems, like 'server = TRUE' but does still the socket waits until timeout

> con2 <- socketConnection("localhost", port = 6011, timeout = 5)

In another window at the same time, ...

C:\Users\TargetUser>netstat -a -n | grep 6011

C:\Users\TargetUser>

server = TRUE

> con2 <- socketConnection("localhost", port = 6011, timeout = 5, server = TRUE)

Error in socketConnection("localhost", port = 6011, timeout = 5, server = TRUE) :
  cannot open the connection
In addition: Warning message:
In socketConnection("localhost", port = 6011, timeout = 5, server = TRUE) :
  problem in listening on this socket

In another window at the same time, ...

C:\Users\TargetUser>netstat -a -n | grep 6011
  TCP    0.0.0.0:6011           0.0.0.0:0              LISTENING

So it was listening but DID REQUIRE 'server = TRUE'

# SAME: wait - DOES not RETURN right AWAY
con2 <- socketConnection("localhost", port = 6011, timeout = 5, server = TRUE, blocking = FALSE)
con2 <- socketConnection("localhost", port = 6011, timeout = 5, server = TRUE, blocking = TRUE)
# WAIT 5 SECONDS, THEN
Error in socketConnection("localhost", port = 6011, timeout = 5, server = TRUE) :
  cannot open the connection
In addition: Warning message:
In socketConnection("localhost", port = 6011, timeout = 5, server = TRUE) :
  problem in listening on this socket

How does parallel do it?

library(parallel)

# Calculate the number of cores
no_cores <- detectCores() - 1

# Initiate cluster
cl <- makeCluster(no_cores)
# RETURNS RIGHT AWAY

> str(cl)
List of 1
 $ :List of 3
  ..$ con :Classes 'sockconn', 'connection'  atomic [1:1]
  .. .. ..- attr(*, "conn_id")=<externalptr>
  ..$ host: chr "localhost"
  ..$ rank: int 1
  ..- attr(*, "class")= chr "SOCKnode"
 - attr(*, "class")= chr [1:2] "SOCKcluster" "cluster"


# Finish
stopCluster(cl)

I look more close.

> debug(parallel:::newPSOCKnode)

debug: con <- socketConnection("localhost", port = port, server = TRUE,
    blocking = TRUE, open = "a+b", timeout = timeout)
Browse[2]> ls()
 [1] "arg"          "cmd"          "env"          "machine"      "manual"
 [6] "master"       "methods"      "options"      "outfile"      "port"
[11] "rank"         "renice"       "rscript"      "rscript_args" "timeout"
[16] "useXDR"
Browse[2]> port
[1] 11664
Browse[2]> timeout
[1] 2592000
Browse[2]> n
# WAITS, SO  server = TRUE is correct

I put in 'server = TRUE'

> debug(QuantTools:::.get_iqfeed)
> get_iqfeed_data( 'MSFT', '2015-01-01', '2016-01-01', 'hour' )

> fixInNamespace(".get_iqfeed", pos = "package:QuantTools")

function (cmd, verbose = .settings$iqfeed_verbose) 
{
    con = socketConnection(host = .settings$iqfeed_host, port = .settings$iqfeed_port, 
        open = "a+b", blocking = TRUE, timeout = .settings$iqfeed_timeout, server = TRUE)

I try again, but still it does not return right away

> get_iqfeed_data( 'MSFT', '2015-01-01', '2016-01-01', 'hour' )
Error in socketConnection(host = .settings$iqfeed_host, port = .settings$iqfeed_port,  :
  cannot open the connection
In addition: Warning message:
In socketConnection(host = .settings$iqfeed_host, port = .settings$iqfeed_port,  :
  problem in listening on this socket

I re-examine parallel to try to see what it is doing

makeCluster
makePSOCKcluster
parallel:::newPSOCKnode


    if (machine != "localhost") {
        rshcmd <- getClusterOption("rshcmd", options)
        user <- getClusterOption("user", options)
        cmd <- shQuote(cmd)
        cmd <- paste(rshcmd, "-l", user, machine, cmd)
    }
    if (.Platform$OS.type == "windows") {
        system(cmd, wait = FALSE, input = "")
    }
    else system(cmd, wait = FALSE)

[1] "\"C:/Users/TargetUser/Desktop/R-3.3.1/App/R-Portable/bin/x64/Rscript\" --default-packages=datasets,utils,grDevices,graphics,stats,methods -e \"parallel:::.slaveRSOCK()\" MASTER=localhost PORT=11664 OUT=/dev/null TIMEOUT=2592000 XDR=TRUE"

So it executed an Rscript with

parallel:::.slaveRSOCK()\" MASTER=localhost PORT=11664

before calling socketConnection.

Hmm, I do not have any more ideas, I am not a sockets expert on Windows

The httpuv package may be something to consider

> httpuv:::makeTcpServer
function (host, port, onHeaders, onBodyData, onRequest, onWSOpen,
    onWSMessage, onWSClose)
{
    .Call("httpuv_makeTcpServer", PACKAGE = "httpuv", host, port,
        onHeaders, onBodyData, onRequest, onWSOpen, onWSMessage,
        onWSClose)
}

> library(QuantTools)
Loading required package: data.table
data.table 1.9.6  For help type ?data.table or https://github.com/Rdatatable/data.table/wiki
The fastest way to learn (by data.table authors): https://www.datacamp.com/courses/data-analysis-the-data-table-way
> get_iqfeed_data( 'MSFT', '2015-01-01', '2016-01-01', 'hour' )
Error in socketConnection(host = .settings$iqfeed_host, port = .settings$iqfeed_port,  :
  cannot open the connection
In addition: Warning message:
In socketConnection(host = .settings$iqfeed_host, port = .settings$iqfeed_port,  :
  localhost:9100 cannot be opened
> sessionInfo()
R version 3.3.1 (2016-06-21)
Platform: x86_64-w64-mingw32/x64 (64-bit)
Running under: Windows 7 x64 (build 7601) Service Pack 1

locale:
[1] LC_COLLATE=English_United States.1252
[2] LC_CTYPE=English_United States.1252
[3] LC_MONETARY=English_United States.1252
[4] LC_NUMERIC=C
[5] LC_TIME=English_United States.1252

attached base packages:
[1] stats     graphics  grDevices utils     datasets  methods   base

other attached packages:
[1] QuantTools_0.5.0 data.table_1.9.6

loaded via a namespace (and not attached):
[1] Rcpp_0.12.7  chron_2.3-47
>

Comments (6)