[truffle] Implement Decoder/ConcBlockingQueue/ConditionVariable/ReentrantMutex reprs

Author: pmurias

src/vm/jvm/runtime/org/perl6/nqp/truffle/sixmodel/REPRRegistry.java

@@ -3,23 +3,31 @@
 import java.util.ArrayList;
 import java.util.HashMap;
 
-import org.perl6.nqp.truffle.sixmodel.reprs.P6opaque;
+import org.perl6.nqp.truffle.sixmodel.reprs.ConditionVariable;
+import org.perl6.nqp.truffle.sixmodel.reprs.ConcBlockingQueue;
+import org.perl6.nqp.truffle.sixmodel.reprs.Decoder;
+import org.perl6.nqp.truffle.sixmodel.reprs.KnowHOWAttribute;
+import org.perl6.nqp.truffle.sixmodel.reprs.KnowHOWREPR;
 import org.perl6.nqp.truffle.sixmodel.reprs.P6int;
 import org.perl6.nqp.truffle.sixmodel.reprs.P6num;
+import org.perl6.nqp.truffle.sixmodel.reprs.P6opaque;
 import org.perl6.nqp.truffle.sixmodel.reprs.P6str;
-import org.perl6.nqp.truffle.sixmodel.reprs.KnowHOWREPR;
-import org.perl6.nqp.truffle.sixmodel.reprs.KnowHOWAttribute;
+import org.perl6.nqp.truffle.sixmodel.reprs.ReentrantMutex;
 import org.perl6.nqp.truffle.sixmodel.reprs.Uninstantiable;
 
 public class REPRRegistry {
     private static REPR create(String name, STable stable) {
         switch (name) {
+            case "ConcBlockingQueue": return new ConcBlockingQueue(stable);
+            case "ConditionVariable": return new ConditionVariable(stable);
+            case "Decoder": return new Decoder(stable);
             case "KnowHOWAttribute": return new KnowHOWAttribute(stable);
             case "KnowHOWREPR": return new KnowHOWREPR(stable);
             case "P6int": return new P6int(stable);
             case "P6num": return new P6num(stable);
             case "P6opaque": return new P6opaque(stable);
             case "P6str": return new P6str(stable);
+            case "ReentrantMutex": return new ReentrantMutex(stable);
             case "Uninstantiable": return new Uninstantiable();
             default: throw new RuntimeException("No REPR " + name);
         }

src/vm/jvm/runtime/org/perl6/nqp/truffle/sixmodel/reprs/ConcBlockingQueue.java

@@ -0,0 +1,22 @@
+package org.perl6.nqp.truffle.sixmodel.reprs;
+import org.perl6.nqp.truffle.sixmodel.SerializationReader;
+import org.perl6.nqp.truffle.sixmodel.STable;
+
+
+public class ConcBlockingQueue extends FixedSizeObjectREPR {
+    public ConcBlockingQueue(STable stable) {
+        super(stable);
+    }
+
+    public Object allocate() {
+        return new ConcBlockingQueueInstance(stable);
+    }
+
+    public Object deserializeStub() {
+        throw new RuntimeException("Cannot deserialize a concurrent blocking queue");
+    }
+
+    public void deserializeFinish(SerializationReader reader, Object obj) {
+        throw new RuntimeException("Cannot deserialize a concurrent blocking queue");
+    }
+}

src/vm/jvm/runtime/org/perl6/nqp/truffle/sixmodel/reprs/ConcBlockingQueueInstance.java

@@ -0,0 +1,13 @@
+package org.perl6.nqp.truffle.sixmodel.reprs;
+
+import java.util.concurrent.LinkedBlockingQueue;
+import org.perl6.nqp.truffle.sixmodel.STable;
+
+public class ConcBlockingQueueInstance extends FixedSizeObject {
+    public LinkedBlockingQueue<Object> queue;
+
+    public ConcBlockingQueueInstance(STable stable) {
+        super(stable);
+        queue = new LinkedBlockingQueue<Object>();
+    }
+}

src/vm/jvm/runtime/org/perl6/nqp/truffle/sixmodel/reprs/ConditionVariable.java

@@ -0,0 +1,23 @@
+package org.perl6.nqp.truffle.sixmodel.reprs;
+import org.perl6.nqp.truffle.sixmodel.SerializationReader;
+import org.perl6.nqp.truffle.sixmodel.STable;
+
+
+public class ConditionVariable extends FixedSizeObjectREPR {
+    public ConditionVariable(STable stable) {
+        super(stable);
+    }
+
+    public Object allocate() {
+        throw new RuntimeException("Cannot create a condition variable directly");
+    }
+
+
+    public Object deserializeStub() {
+        throw new RuntimeException("Cannot deserialize a lock");
+    }
+
+    public void deserializeFinish(SerializationReader reader, Object obj) {
+        throw new RuntimeException("Cannot deserialize a lock");
+    }
+}

src/vm/jvm/runtime/org/perl6/nqp/truffle/sixmodel/reprs/ConditionVariableInstance.java

@@ -0,0 +1,12 @@
+package org.perl6.nqp.truffle.sixmodel.reprs;
+
+import java.util.concurrent.locks.Condition;
+import org.perl6.nqp.truffle.sixmodel.STable;
+
+public class ConditionVariableInstance extends FixedSizeObject {
+    public Condition condvar;
+
+    public ConditionVariableInstance(STable stable) {
+        super(stable);
+    }
+}

src/vm/jvm/runtime/org/perl6/nqp/truffle/sixmodel/reprs/Decoder.java

@@ -0,0 +1,22 @@
+package org.perl6.nqp.truffle.sixmodel.reprs;
+import org.perl6.nqp.truffle.sixmodel.SerializationReader;
+import org.perl6.nqp.truffle.sixmodel.STable;
+
+
+public class Decoder extends FixedSizeObjectREPR {
+    public Decoder(STable stable) {
+        super(stable);
+    }
+
+    public Object allocate() {
+        return new DecoderInstance(stable);
+    }
+
+    public Object deserializeStub() {
+        throw new RuntimeException("Cannot deserialize a Decoder");
+    }
+
+    public void deserializeFinish(SerializationReader reader, Object obj) {
+        throw new RuntimeException("Cannot deserialize a Decoder");
+    }
+}

src/vm/jvm/runtime/org/perl6/nqp/truffle/sixmodel/reprs/DecoderInstance.java

@@ -0,0 +1,22 @@
+package org.perl6.nqp.truffle.sixmodel.reprs;
+
+import java.nio.ByteBuffer;
+import java.nio.CharBuffer;
+import java.nio.charset.Charset;
+import java.nio.charset.CharsetDecoder;
+import java.util.ArrayList;
+import java.util.List;
+
+import org.perl6.nqp.truffle.sixmodel.STable;
+
+public class DecoderInstance extends FixedSizeObject {
+    private Charset charset;
+    private CharsetDecoder decoder;
+    private List<ByteBuffer> toDecode;
+    private List<CharBuffer> decoded;
+    private List<String> lineSeps;
+
+    public DecoderInstance(STable stable) {
+        super(stable);
+    }
+}

src/vm/jvm/runtime/org/perl6/nqp/truffle/sixmodel/reprs/ReentrantMutex.java

@@ -0,0 +1,22 @@
+package org.perl6.nqp.truffle.sixmodel.reprs;
+import org.perl6.nqp.truffle.sixmodel.SerializationReader;
+import org.perl6.nqp.truffle.sixmodel.STable;
+
+
+public class ReentrantMutex extends FixedSizeObjectREPR {
+    public ReentrantMutex(STable stable) {
+        super(stable);
+    }
+
+    public Object allocate() {
+        return new ReentrantMutexInstance(stable);
+    }
+
+    public Object deserializeStub() {
+        return new ReentrantMutexInstance(stable);
+    }
+
+    public void deserializeFinish(SerializationReader reader, Object obj) {
+      /* Already did it all in deserializeStub. */
+    }
+}

src/vm/jvm/runtime/org/perl6/nqp/truffle/sixmodel/reprs/ReentrantMutexInstance.java

@@ -0,0 +1,12 @@
+package org.perl6.nqp.truffle.sixmodel.reprs;
+
+import java.util.concurrent.locks.ReentrantLock;
+import org.perl6.nqp.truffle.sixmodel.STable;
+
+public class ReentrantMutexInstance extends FixedSizeObject {
+    public ReentrantLock lock;
+    public ReentrantMutexInstance(STable stable) {
+        super(stable);
+        lock = new ReentrantLock();
+    }
+}