Module: Rserve

Defined in:
lib/R4rb/Rserve.rb

Overview

IMPORTANT, no use of R4rb tools! R2rb or Rserve mode only!

Defined Under Namespace

Classes: RVector

Class Method Summary collapse

Class Method Details

.<(code) ⇒ Object 



145
146
147
 
# File 'lib/R4rb/Rserve.rb', line 145

def Rserve.<(code)
	Rserve.output(code)
end

.<<(code) ⇒ Object 



131
132
133
 
# File 'lib/R4rb/Rserve.rb', line 131

def Rserve.<<(code)
	Rserve.eval(code)
end

.assign(code, var = nil, cli = nil) ⇒ Object 



149
150
151
152
153
154
155
156
 
# File 'lib/R4rb/Rserve.rb', line 149

def Rserve.assign(code,var=nil,cli=nil)
	code+=",quote(#{var})" if var
	cli=Rserve.cli unless cli
	code="RSassign(#{cli},#{code})"
	#p code
	#R2rb << code ###????
	Rserve << code
end

.cli ⇒ Object

the two following methods to be possibly redefined in particular inside Dyndoc to automatically allocate the R session related to the user!



48
49
50
 
# File 'lib/R4rb/Rserve.rb', line 48

def Rserve.cli
	@@cli
end

.cli=(cli) ⇒ Object 



52
53
54
 
# File 'lib/R4rb/Rserve.rb', line 52

def Rserve.cli=(cli)
	@@cli=cli
end

.client(cli = nil) ⇒ Object 



58
59
60
61
62
63
64
65
66
67
68
69
 
# File 'lib/R4rb/Rserve.rb', line 58

def Rserve.client(cli=nil)
	## automate the init process!
	#Rserve.init unless @@clients

	##return current client!
	unless cli 	
		return Rserve.cli
	## create a new client
	else 		
		Rserve.open(cli)
	end
end

.client=(cli = nil) ⇒ Object

change the current client!



72
73
74
75
 
# File 'lib/R4rb/Rserve.rb', line 72

def Rserve.client=(cli=nil)
	return nil unless @@clients.include? cli
	Rserve.cli=cli
end

.close(cli = nil) ⇒ Object 



83
84
85
86
87
88
 
# File 'lib/R4rb/Rserve.rb', line 83

def Rserve.close(cli=nil) 
	cli=Rserve.cli unless cli
	return unless @@clients.include? cli
	"RSclose(#{cli.to_s})".R2rb
	@@clients.delete(cli)
end

.complete_code!(code) ⇒ Object

interface



96
97
98
99
100
 
# File 'lib/R4rb/Rserve.rb', line 96

def Rserve.complete_code!(code)
	code.gsub!("\\","\\\\")
	code.gsub!("\"","\\\"")
	code.replace("RSeval(#{cli},\"capture.output({"+code+"})\")")
end

.completed_code(code, capture = true) ⇒ Object 



103
104
105
106
 
# File 'lib/R4rb/Rserve.rb', line 103

def Rserve.completed_code(code,capture=true)
	open,close= (capture ? ["capture.output({","})"] : ["",""])
	"RSeval(#{cli},\""+open+code.gsub("\\","\\\\").gsub("\"","\\\"")+close+"\")"
end

.eval(code, cli = nil) ⇒ Object 



108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
 
# File 'lib/R4rb/Rserve.rb', line 108

def Rserve.eval(code,cli=nil)
	cli=Rserve.cli unless cli
	return nil unless cli
	## check parsing locally (without RSeval)
	status=R2rb.parse code
	if status!=1
		R2rb.parse code,true
		return false
	end
	## RSeval completed in code!
	Rserve.complete_code!(code)
	#puts "Rserve.eval:";p code
	R2rb.eval code
	#@@out < code ##@@out.inR2rb code # since @@out < code but for R2rb
end

.init ⇒ Object 



32
33
34
35
36
37
38
39
40
41
42
 
# File 'lib/R4rb/Rserve.rb', line 32

def Rserve.init
	#puts "Rserve.init"
	Array.initR
	#puts "Rserve.init2"
	"require(Rserve)".R2rb
	#puts "Rserve.init3"
	@@clients,@@cli=[],nil
	@@out=[]
	@@out.rb2R=R2rb
	#puts "Rserve.init4"
end

.ls ⇒ Object 



90
91
92
 
# File 'lib/R4rb/Rserve.rb', line 90

def Rserve.ls
	@@clients
end

.open(cli) ⇒ Object 



77
78
79
80
81
 
# File 'lib/R4rb/Rserve.rb', line 77

def Rserve.open(cli)
	"#{cli.to_s} <- RSconnect()".R2rb
	@@clients << cli
	Rserve.cli=cli
end

.output(code, cli = nil) ⇒ Object 



135
136
137
138
139
140
141
142
143
 
# File 'lib/R4rb/Rserve.rb', line 135

def Rserve.output(code,cli=nil)
	#puts "Rserve.output:";p code
	cli=Rserve.cli unless cli
	return nil unless cli
	## RSeval completed in code!
	Rserve.complete_code!(code)
	@@out < code ##@@out.inR2rb rcode.to_s
   	return (@@out.length<=1 ? @@out[0] : @@out)
end

.pid ⇒ Object

server side



7
8
9
 
# File 'lib/R4rb/Rserve.rb', line 7

def Rserve.pid
	`ps -C Rserve -o pid=`.strip
end

.running? ⇒ Boolean

Returns:

  • (Boolean) 


11
12
13
 
# File 'lib/R4rb/Rserve.rb', line 11

def Rserve.running?
	!Rserve.pid.empty?
end

.start(rserve = File.expand_path("~/bin/Rserv")) ⇒ Object 



15
16
17
 
# File 'lib/R4rb/Rserve.rb', line 15

def Rserve.start(rserve=File.expand_path("~/bin/Rserv"))
	`R CMD #{rserve}` unless Rserve.running?
end

.stop ⇒ Object 



20
21
22
23
24
25
26
27
 
# File 'lib/R4rb/Rserve.rb', line 20

def Rserve.stop
		pid=Rserve.pid
	`kill #{pid}` unless pid.empty?
	sleep(2)
	if Rserve.running?
		puts "Sorry! but the Rserver is still running!"
	end
end

.try_eval(code, cli = nil) ⇒ Object 



124
125
126
127
128
129
 
# File 'lib/R4rb/Rserve.rb', line 124

def Rserve.try_eval(code,cli=nil)
		cli=Rserve.cli unless cli
 	try_code=".result_try_code<-try({\n"+code+"\n},silent=TRUE)\n"
 	puts Rserve.output(try_code,cli).join("\n")
 	puts R2rb.output(Rserve.completed_code(".result_try_code",false)) if "inherits(.result_try_code,'try-error')".to_R
end