diff options
author | Matthias Schiffer <mschiffer@universe-factory.net> | 2010-06-17 02:23:53 +0200 |
---|---|---|
committer | Matthias Schiffer <mschiffer@universe-factory.net> | 2010-06-17 02:23:53 +0200 |
commit | ca7a0bfa5dd63fc45df0a46800a76d7048e70f2b (patch) | |
tree | 9af785b9d1171999b5894251c88146faac1366fe /gui/CoreConnector.vala | |
parent | c3354ad1fd4f843d80ebdd290c8dbaf81919ca38 (diff) | |
download | ephraim-ca7a0bfa5dd63fc45df0a46800a76d7048e70f2b.tar ephraim-ca7a0bfa5dd63fc45df0a46800a76d7048e70f2b.zip |
Started writing GUI
Diffstat (limited to 'gui/CoreConnector.vala')
-rw-r--r-- | gui/CoreConnector.vala | 72 |
1 files changed, 72 insertions, 0 deletions
diff --git a/gui/CoreConnector.vala b/gui/CoreConnector.vala new file mode 100644 index 0000000..a3f0910 --- /dev/null +++ b/gui/CoreConnector.vala @@ -0,0 +1,72 @@ +using Erl; + + +public class CoreConnector { + unowned Thread thread; + bool running; + + private class TermStore { + public Erl.Term term; + } + + public CoreConnector() { + running = false; + } + + public bool start() { + if(running) + return true; + + running = true; + + try { + thread = Thread.create(receive, true); + return true; + } catch(ThreadError e) { + return false; + } + } + + public void stop() { + if(!running) + return; + + running = false; + thread.join(); + } + + private void* receive() { + Erl.Node node = Erl.Node("ephraim-gtk", "magiccookie", 0); + Erl.Connection con = node.connect("ephraim-core@avalon.local"); + + con.reg_send("ephraim", Erl.mk_self_pid(node)); + + while(running) { + TermStore response = new TermStore(); + Erl.ReceiveType ret = con.receive(out response.term, 1000); + + switch(ret) { + case Erl.ReceiveType.ERROR: + if(Erl.errno == Erl.Error.TIMEDOUT) + break; + + running = false; + break; + case Erl.ReceiveType.TICK: + // Do nothing + break; + case Erl.ReceiveType.MSG: + Idle.add(() => {handleTerm(response); return false;}); + break; + } + } + + return null; + } + + private void handleTerm(TermStore store) { + unowned Term term = store.term; + Erl.print_term(stdout, term); + stdout.printf("\n"); + } +} |