This is an automated email from the git hooks/post-receive script.
js pushed a commit to tag 0.55
in repository libinline-java-perl.
commit 1fed783127687458c8e115e216df4431c7d4e20b
Author: Patrick LeBoutillier <p...@cpan.org>
Date: Mon Dec 10 13:38:59 2001 +0000
*** empty log message ***
---
Java/Init.pm | 115 +++++++++++++++++++++++++++++++++++++++++++++++++----------
Java/JVM.pm | 9 +++++
2 files changed, 105 insertions(+), 19 deletions(-)
diff --git a/Java/Init.pm b/Java/Init.pm
index e22cd7b..5eb53ef 100644
--- a/Java/Init.pm
+++ b/Java/Init.pm
@@ -11,10 +11,11 @@ my $ARRAY_DATA = join('', <Inline::Java::Array::DATA>) ;
my $CLASS_DATA = join('', <Inline::Java::Class::DATA>) ;
my $PROTO_DATA = join('', <Inline::Java::Protocol::DATA>) ;
+my $CALLBACK_DATA = join('', <Inline::Java::Callback::DATA>) ;
+
sub DumpUserJavaCode {
my $fh = shift ;
- my $modfname = shift ;
my $code = shift ;
print $fh $code ;
@@ -23,7 +24,6 @@ sub DumpUserJavaCode {
sub DumpServerJavaCode {
my $fh = shift ;
- my $modfname = shift ;
my $java = $DATA ;
my $java_obj = $OBJECT_DATA ;
@@ -40,6 +40,15 @@ sub DumpServerJavaCode {
}
+sub DumpCallbackJavaCode {
+ my $fh = shift ;
+
+ my $java = $CALLBACK_DATA ;
+
+ print $fh $java ;
+}
+
+
1 ;
@@ -57,23 +66,26 @@ import java.lang.reflect.* ;
objects.
*/
public class InlineJavaServer {
- boolean debug ;
- int port = 0 ;
- boolean shared_jvm = false ;
+ static public InlineJavaServer instance = null ;
+ private boolean debug ;
+ private int port = 0 ;
+ private boolean shared_jvm = false ;
- public HashMap thread_objects = new HashMap() ;
- public int objid = 1 ;
+ private HashMap thread_objects = new HashMap() ;
+ private int objid = 1 ;
// This constructor is used in JNI mode
InlineJavaServer(boolean d) {
+ init() ;
debug = d ;
- thread_objects.put(Thread.currentThread().getName(), new
HashMap()) ;
+ thread_objects.put(Thread.currentThread().getName(), new
HashMap()) ;
}
// This constructor is used in server mode
InlineJavaServer(String[] argv) {
+ init() ;
debug = new Boolean(argv[0]).booleanValue() ;
port = Integer.parseInt(argv[1]) ;
shared_jvm = new Boolean(argv[2]).booleanValue() ;
@@ -109,11 +121,16 @@ public class InlineJavaServer {
}
+ private void init(){
+ instance = this ;
+ }
+
+
/*
Since this function is also called from the JNI XS extension,
it's best if it doesn't throw any exceptions.
*/
- public String ProcessCommand(String cmd) {
+ private String ProcessCommand(String cmd) {
debug(" packet recv is " + cmd) ;
String resp = null ;
@@ -224,15 +241,50 @@ public class InlineJavaServer {
}
+ public Object Callback(String pkg, String method, Object args[]) throws
InlineJavaException {
+ try {
+ Thread t = Thread.currentThread() ;
+ if (t instanceof InlineJavaThread){
+ // Client-server mode
+ InlineJavaProtocol ijp = new
InlineJavaProtocol(this, null) ;
+ StringBuffer cmd = new StringBuffer("callback "
+ pkg + " " + method) ;
+ if (args != null){
+ for (int i = 0 ; i < args.length ; i++){
+ cmd.append(" " +
ijp.SerializeObject(args[i])) ;
+ }
+ }
+ System.out.println("Callback command: " +
cmd.toString()) ;
+ debug("Callback command: " + cmd.toString()) ;
+
+ InlineJavaThread ijt = (InlineJavaThread)t ;
+ ijt.bw.write(cmd.toString() + "\n") ;
+ ijt.bw.flush() ;
+
+ String resp = ijt.br.readLine() ;
+
+ System.out.println("Callback response: " +
resp) ;
+ }
+ else{
+ // JNI mode
+ }
+ }
+ catch (IOException e){
+ throw new InlineJavaException("IO error: " +
e.getMessage()) ;
+ }
+
+ return null ;
+ }
+
+
/*
Creates a string representing a method signature
*/
- String CreateSignature(Class param[]){
+ public String CreateSignature(Class param[]){
return CreateSignature(param, ", ") ;
}
- String CreateSignature(Class param[], String del){
+ public String CreateSignature(Class param[], String del){
StringBuffer ret = new StringBuffer() ;
for (int i = 0 ; i < param.length ; i++){
if (i > 0){
@@ -293,9 +345,16 @@ public class InlineJavaServer {
}
- class InlineJavaIOException extends IOException {
- InlineJavaIOException(String m){
+ class InlineJavaInvocationTargetException extends InlineJavaException {
+ Throwable t = null ;
+
+ InlineJavaInvocationTargetException(String m, Throwable _t){
super(m) ;
+ t = _t ;
+ }
+
+ public Throwable getThrowable(){
+ return t ;
}
}
@@ -303,11 +362,18 @@ public class InlineJavaServer {
class InlineJavaThread extends Thread {
InlineJavaServer ijs ;
Socket client ;
+ BufferedReader br ;
+ BufferedWriter bw ;
- InlineJavaThread(InlineJavaServer _ijs, Socket _client){
+ InlineJavaThread(InlineJavaServer _ijs, Socket _client) throws
IOException {
super() ;
client = _client ;
ijs = _ijs ;
+
+ br = new BufferedReader(
+ new InputStreamReader(client.getInputStream()))
;
+ bw = new BufferedWriter(
+ new
OutputStreamWriter(client.getOutputStream())) ;
}
@@ -315,11 +381,6 @@ public class InlineJavaServer {
try {
ijs.thread_objects.put(getName(), new
HashMap()) ;
- BufferedReader br = new BufferedReader(
- new
InputStreamReader(client.getInputStream())) ;
- BufferedWriter bw = new BufferedWriter(
- new
OutputStreamWriter(client.getOutputStream())) ;
-
while (true){
String cmd = br.readLine() ;
@@ -340,5 +401,21 @@ public class InlineJavaServer {
ijs.thread_objects.remove(getName()) ;
}
}
+
+ public void test(){
+ }
+ }
+}
+
+
+class InlineJavaServerThrown {
+ Throwable t = null ;
+
+ InlineJavaServerThrown(Throwable _t){
+ t = _t ;
+ }
+
+ public Throwable getThrowable(){
+ return t ;
}
}
diff --git a/Java/JVM.pm b/Java/JVM.pm
index 9a38839..f153975 100644
--- a/Java/JVM.pm
+++ b/Java/JVM.pm
@@ -235,6 +235,15 @@ sub process_command {
$resp = $this->{JNI}->process_command($data) ;
}
+ # We got an answer from the server. Is it a callback?
+ if ($resp =~ s/^callback //){
+ print "Callback!!! ($resp)\n" ;
+ }
+
+
+
+
+
Inline::Java::debug(" packet recv is $resp") ;
return $resp ;
--
Alioth's /usr/local/bin/git-commit-notice on
/srv/git.debian.org/git/pkg-perl/packages/libinline-java-perl.git
_______________________________________________
Pkg-perl-cvs-commits mailing list
Pkg-perl-cvs-commits@lists.alioth.debian.org
http://lists.alioth.debian.org/cgi-bin/mailman/listinfo/pkg-perl-cvs-commits
