TudbuT/isbpl
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

add streams

Browse source
This commit is contained in:
Daniella 2022-03-06 18:13:25 +01:00
parent a61427702e
commit e9022405c9
2 changed files with 100 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

89
bootstrap/ISBPL.java
View file

@ -20,6 +20,7 @@ public class ISBPL {
HashMap<Object, ISBPLObject> vars = new HashMap<>();
ArrayList<String> lastWords = new ArrayList<>(16);
int exitCode;
private ISBPLStreamer streamer = new ISBPLStreamer(this);
public ISBPL() {
functionStack.push(new HashMap<>());
@ -741,6 +742,18 @@ public class ISBPL {
stack.push(new ISBPLObject(getType("long"), System.currentTimeMillis()));
};
break;
case "stream":
func = (File file) -> {
ISBPLObject action = stack.pop();
action.checkType(getType("int"));
int n = ((int) action.object);
try {
streamer.action(stack, n);
}
catch (IOException e) {
throw new ISBPLError("IO", e.getMessage());
}
};
}
functionStack.peek().put(name, func);
}
@ -1342,3 +1355,79 @@ class ISBPLDebugger extends Thread {
}
}
class ISBPLStreamer {
public static final int CREATE_FILE = 1;
public static final int CREATE_SOCKET = 2;
public static final int READ = 3;
public static final int WRITE = 4;
public static final int AREAD = 5;
public static final int AWRITE = 6;
static class ISBPLStream {
final InputStream in;
final OutputStream out;
static int gid = 0;
final int id = gid++;
public ISBPLStream(InputStream in, OutputStream out) {
this.in = in;
this.out = out;
}
}
final ISBPL isbpl;
public ISBPLStreamer(ISBPL isbpl) {
this.isbpl = isbpl;
}
public ArrayList<ISBPLStream> streams = new ArrayList<>();
public void action(Stack<ISBPLObject> stack, int action) throws IOException {
ISBPLStream stream;
ISBPLObject s, i;
switch (action) {
case CREATE_FILE:
s = stack.pop();
s.checkType(isbpl.getType("string"));
File f = new File(isbpl.toJavaString(s));
stream = new ISBPLStream(new FileInputStream(f), new FileOutputStream(f));
streams.add(stream);
stack.push(new ISBPLObject(isbpl.getType("int"), stream.id));
break;
case CREATE_SOCKET:
i = stack.pop();
s = stack.pop();
i.checkType(isbpl.getType("int"));
s.checkType(isbpl.getType("string"));
Socket socket = new Socket(isbpl.toJavaString(s), ((int) i.object));
stream = new ISBPLStream(socket.getInputStream(), socket.getOutputStream());
streams.add(stream);
stack.push(new ISBPLObject(isbpl.getType("int"), stream.id));
break;
case READ:
i = stack.pop();
i.checkType(isbpl.getType("int"));
try {
stack.push(new ISBPLObject(isbpl.getType("int"), streams.get(((int) i.object)).in.read()));
} catch (IndexOutOfBoundsException e) {
throw new ISBPLError("IllegalArgument", "streamid STREAM_READ stream called with non-existing stream argument");
}
break;
case WRITE:
i = stack.pop();
i.checkType(isbpl.getType("int"));
ISBPLObject bte = stack.pop();
bte.checkTypeMulti(isbpl.getType("int"), isbpl.getType("char"), isbpl.getType("byte"));
try {
streams.get(((int) i.object)).out.write(((int) bte.toLong()));
} catch (IndexOutOfBoundsException e) {
throw new ISBPLError("IllegalArgument", "streamid STREAM_READ stream called with non-existing stream argument");
}
break;
default:
throw new ISBPLError("NotImplemented", "Not implemented");
}
}
}

11
stream.isbpl Normal file
View file

@ -0,0 +1,11 @@
native stream
def STREAM_CREATE_FILE 1 =STREAM_CREATE_FILE
def STREAM_CREATE_SOCKET 2 =STREAM_CREATE_SOCKET
def STREAM_READ 3 =STREAM_READ
def STREAM_WRITE 4 =STREAM_WRITE
"not implemented:" #
"def STREAM_AREAD 5 =STREAM_AREAD" #
"def STREAM_AWRITE 6 =STREAM_AWRITE" #