Mercurial Hosting > luan
annotate src/luan/modules/http/LuanHandler.java @ 1274:383f924dfe9d
support multipart files in http request
author | Franklin Schmidt <fschmidt@gmail.com> |
---|---|
date | Tue, 04 Dec 2018 06:08:20 -0700 |
parents | 9fa8b8389578 |
children | 503bde9a7c80 |
rev | line source |
---|---|
1171 | 1 package luan.modules.http; |
175
bdbd4740121f
finish web server
fschmidt@gmail.com <fschmidt@gmail.com@21e917c8-12df-6dd8-5cb6-c86387c605b9>
parents:
diff
changeset
|
2 |
1231 | 3 import java.io.Closeable; |
1160 | 4 import java.io.Writer; |
5 import java.io.PrintWriter; | |
175
bdbd4740121f
finish web server
fschmidt@gmail.com <fschmidt@gmail.com@21e917c8-12df-6dd8-5cb6-c86387c605b9>
parents:
diff
changeset
|
6 import java.io.IOException; |
1264 | 7 import java.lang.ref.Reference; |
8 import java.lang.ref.WeakReference; | |
786
fe63c508a177
add Http.reset_luan()
Franklin Schmidt <fschmidt@gmail.com>
parents:
785
diff
changeset
|
9 import java.lang.reflect.Method; |
1004
3fa54d9d19cd
better handling of BindException
Franklin Schmidt <fschmidt@gmail.com>
parents:
1000
diff
changeset
|
10 import java.net.BindException; |
1264 | 11 import java.util.List; |
12 import java.util.ArrayList; | |
13 import java.util.concurrent.locks.ReadWriteLock; | |
14 import java.util.concurrent.locks.ReentrantReadWriteLock; | |
280
2164b4479661
log web exceptions
fschmidt@gmail.com <fschmidt@gmail.com@21e917c8-12df-6dd8-5cb6-c86387c605b9>
parents:
264
diff
changeset
|
15 import org.slf4j.Logger; |
2164b4479661
log web exceptions
fschmidt@gmail.com <fschmidt@gmail.com@21e917c8-12df-6dd8-5cb6-c86387c605b9>
parents:
264
diff
changeset
|
16 import org.slf4j.LoggerFactory; |
1160 | 17 import luan.webserver.Request; |
18 import luan.webserver.Response; | |
1265
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
19 import luan.webserver.Status; |
1160 | 20 import luan.webserver.Server; |
21 import luan.webserver.Handler; | |
22 import luan.webserver.ResponseOutputStream; | |
786
fe63c508a177
add Http.reset_luan()
Franklin Schmidt <fschmidt@gmail.com>
parents:
785
diff
changeset
|
23 import luan.Luan; |
175
bdbd4740121f
finish web server
fschmidt@gmail.com <fschmidt@gmail.com@21e917c8-12df-6dd8-5cb6-c86387c605b9>
parents:
diff
changeset
|
24 import luan.LuanState; |
743
2c41f2aec92f
improve Rpc and implement rpc call for local webserver
Franklin Schmidt <fschmidt@gmail.com>
parents:
693
diff
changeset
|
25 import luan.LuanTable; |
2c41f2aec92f
improve Rpc and implement rpc call for local webserver
Franklin Schmidt <fschmidt@gmail.com>
parents:
693
diff
changeset
|
26 import luan.LuanFunction; |
786
fe63c508a177
add Http.reset_luan()
Franklin Schmidt <fschmidt@gmail.com>
parents:
785
diff
changeset
|
27 import luan.LuanJavaFunction; |
781
fbbdd369a13a
rename DeepCloner to LuanCloner
Franklin Schmidt <fschmidt@gmail.com>
parents:
777
diff
changeset
|
28 import luan.LuanCloner; |
175
bdbd4740121f
finish web server
fschmidt@gmail.com <fschmidt@gmail.com@21e917c8-12df-6dd8-5cb6-c86387c605b9>
parents:
diff
changeset
|
29 import luan.LuanException; |
743
2c41f2aec92f
improve Rpc and implement rpc call for local webserver
Franklin Schmidt <fschmidt@gmail.com>
parents:
693
diff
changeset
|
30 import luan.modules.PackageLuan; |
1263
382c444a6c77
add Http.eval_in_root and Http.handle_error
Franklin Schmidt <fschmidt@gmail.com>
parents:
1257
diff
changeset
|
31 import luan.modules.BasicLuan; |
175
bdbd4740121f
finish web server
fschmidt@gmail.com <fschmidt@gmail.com@21e917c8-12df-6dd8-5cb6-c86387c605b9>
parents:
diff
changeset
|
32 |
bdbd4740121f
finish web server
fschmidt@gmail.com <fschmidt@gmail.com@21e917c8-12df-6dd8-5cb6-c86387c605b9>
parents:
diff
changeset
|
33 |
1265
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
34 public final class LuanHandler implements Handler, LuanState.OnClose { |
1186 | 35 private final LuanState luanInit; |
627
a98812908fbc
add loggerRoot param to LuanHandler
Franklin Schmidt <fschmidt@gmail.com>
parents:
531
diff
changeset
|
36 private final Logger logger; |
1265
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
37 private final ReadWriteLock lock = new ReentrantReadWriteLock(); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
38 private final List<Reference<Closeable>> onClose = new ArrayList<Reference<Closeable>>(); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
39 private volatile LuanState currentLuan; |
786
fe63c508a177
add Http.reset_luan()
Franklin Schmidt <fschmidt@gmail.com>
parents:
785
diff
changeset
|
40 |
1186 | 41 private static final Method resetLuanMethod; |
1263
382c444a6c77
add Http.eval_in_root and Http.handle_error
Franklin Schmidt <fschmidt@gmail.com>
parents:
1257
diff
changeset
|
42 private static final Method evalInRootMethod; |
1186 | 43 static { |
44 try { | |
1263
382c444a6c77
add Http.eval_in_root and Http.handle_error
Franklin Schmidt <fschmidt@gmail.com>
parents:
1257
diff
changeset
|
45 resetLuanMethod = LuanHandler.class.getMethod( "reset_luan" ); |
382c444a6c77
add Http.eval_in_root and Http.handle_error
Franklin Schmidt <fschmidt@gmail.com>
parents:
1257
diff
changeset
|
46 evalInRootMethod = LuanHandler.class.getMethod( "eval_in_root", String.class ); |
1186 | 47 } catch(NoSuchMethodException e) { |
48 throw new RuntimeException(e); | |
49 } | |
50 } | |
51 | |
1263
382c444a6c77
add Http.eval_in_root and Http.handle_error
Franklin Schmidt <fschmidt@gmail.com>
parents:
1257
diff
changeset
|
52 public LuanHandler(LuanState luanInit,String loggerRoot) { |
1231 | 53 this.luanInit = luanInit; |
627
a98812908fbc
add loggerRoot param to LuanHandler
Franklin Schmidt <fschmidt@gmail.com>
parents:
531
diff
changeset
|
54 if( loggerRoot==null ) |
a98812908fbc
add loggerRoot param to LuanHandler
Franklin Schmidt <fschmidt@gmail.com>
parents:
531
diff
changeset
|
55 loggerRoot = ""; |
a98812908fbc
add loggerRoot param to LuanHandler
Franklin Schmidt <fschmidt@gmail.com>
parents:
531
diff
changeset
|
56 logger = LoggerFactory.getLogger(loggerRoot+LuanHandler.class.getName()); |
1186 | 57 try { |
58 LuanTable Http = (LuanTable)PackageLuan.require(luanInit,"luan:http/Http.luan"); | |
59 Http.rawPut( "reset_luan", new LuanJavaFunction(resetLuanMethod,this) ); | |
1263
382c444a6c77
add Http.eval_in_root and Http.handle_error
Franklin Schmidt <fschmidt@gmail.com>
parents:
1257
diff
changeset
|
60 Http.rawPut( "eval_in_root", new LuanJavaFunction(evalInRootMethod,this) ); |
1186 | 61 } catch(LuanException e) { |
62 throw new RuntimeException(e); | |
63 } | |
1265
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
64 currentLuan = newLuan(); |
1186 | 65 } |
1265
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
66 |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
67 private LuanState newLuan() { |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
68 LuanCloner cloner = new LuanCloner(LuanCloner.Type.COMPLETE); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
69 LuanState luan = (LuanState)cloner.clone(luanInit); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
70 luan.onClose = this; |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
71 try { |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
72 PackageLuan.load(luan,"site:/init.luan"); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
73 } catch(LuanException e) { |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
74 String err = e.getLuanStackTraceString(); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
75 logger.error(err); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
76 } |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
77 return luan; |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
78 } |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
79 |
1264 | 80 /* |
1257
e38f5869e9df
don't reset in send_redirect and other improvements
Franklin Schmidt <fschmidt@gmail.com>
parents:
1256
diff
changeset
|
81 public LuanState getLuan() { |
e38f5869e9df
don't reset in send_redirect and other improvements
Franklin Schmidt <fschmidt@gmail.com>
parents:
1256
diff
changeset
|
82 return luan; |
e38f5869e9df
don't reset in send_redirect and other improvements
Franklin Schmidt <fschmidt@gmail.com>
parents:
1256
diff
changeset
|
83 } |
1264 | 84 */ |
1160 | 85 @Override public Response handle(Request request) { |
1167 | 86 if( request.path.endsWith("/") ) |
87 return null; | |
88 String modName = "site:" + request.path +".luan"; | |
89 return handle(request,modName); | |
90 } | |
91 | |
92 Response handle(Request request,String modName) { | |
1265
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
93 Thread thread = Thread.currentThread(); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
94 String oldName = thread.getName(); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
95 thread.setName(request.headers.get("host")+request.path); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
96 lock.readLock().lock(); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
97 try { |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
98 return HttpServicer.service(currentLuan,request,modName); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
99 } catch(LuanException e) { |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
100 String err = e.getLuanStackTraceString(); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
101 logger.error(err+"\n"+request.rawHead.trim()+"\n"); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
102 String msg = "Internel Server Error\n\n" + err; |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
103 return Response.errorResponse( Status.INTERNAL_SERVER_ERROR, msg ); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
104 } finally { |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
105 lock.readLock().unlock(); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
106 thread.setName(oldName); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
107 } |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
108 } |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
109 |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
110 public void onClose(Closeable c) { |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
111 synchronized(onClose) { |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
112 onClose.add(new WeakReference<Closeable>(c)); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
113 } |
175
bdbd4740121f
finish web server
fschmidt@gmail.com <fschmidt@gmail.com@21e917c8-12df-6dd8-5cb6-c86387c605b9>
parents:
diff
changeset
|
114 } |
786
fe63c508a177
add Http.reset_luan()
Franklin Schmidt <fschmidt@gmail.com>
parents:
785
diff
changeset
|
115 |
1231 | 116 public void close() { |
1265
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
117 synchronized(onClose) { |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
118 for( Reference<Closeable> ref : onClose ) { |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
119 Closeable c = ref.get(); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
120 if( c != null ) { |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
121 try { |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
122 c.close(); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
123 } catch(IOException e) { |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
124 logger.error(c.toString(),e); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
125 } |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
126 } |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
127 } |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
128 onClose.clear(); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
129 } |
517
8dcf9e12446b
add Luan.on_luan_close()
Franklin Schmidt <fschmidt@gmail.com>
parents:
494
diff
changeset
|
130 } |
1185
94cf2576a922
implement WebHandler for nginx
Franklin Schmidt <fschmidt@gmail.com>
parents:
1171
diff
changeset
|
131 |
743
2c41f2aec92f
improve Rpc and implement rpc call for local webserver
Franklin Schmidt <fschmidt@gmail.com>
parents:
693
diff
changeset
|
132 public Object call_rpc(String fnName,Object... args) throws LuanException { |
1265
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
133 lock.readLock().lock(); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
134 try { |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
135 LuanFunction fn; |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
136 LuanState luan = currentLuan; |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
137 synchronized(luan) { |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
138 PackageLuan.enableLoad(luan,"luan:Rpc.luan"); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
139 LuanTable rpc = (LuanTable)PackageLuan.require(luan,"luan:Rpc.luan"); |
1267 | 140 LuanTable fns = (LuanTable)rpc.get("functions"); |
141 fn = (LuanFunction)fns.get(fnName); | |
1265
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
142 if( fn == null ) |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
143 throw new LuanException( "function not found: " + fnName ); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
144 LuanCloner cloner = new LuanCloner(LuanCloner.Type.INCREMENTAL); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
145 luan = (LuanState)cloner.clone(luan); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
146 fn = (LuanFunction)cloner.get(fn); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
147 } |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
148 return fn.call(luan,args); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
149 } finally { |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
150 lock.readLock().unlock(); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
151 } |
743
2c41f2aec92f
improve Rpc and implement rpc call for local webserver
Franklin Schmidt <fschmidt@gmail.com>
parents:
693
diff
changeset
|
152 } |
2c41f2aec92f
improve Rpc and implement rpc call for local webserver
Franklin Schmidt <fschmidt@gmail.com>
parents:
693
diff
changeset
|
153 |
1186 | 154 public void reset_luan() { |
1264 | 155 new Thread() { |
156 public void run() { | |
1265
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
157 lock.writeLock().lock(); |
1264 | 158 try { |
1265
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
159 close(); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
160 currentLuan = newLuan(); |
1264 | 161 } finally { |
1265
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
162 lock.writeLock().unlock(); |
1264 | 163 } |
164 } | |
165 }.start(); | |
1186 | 166 } |
167 | |
786
fe63c508a177
add Http.reset_luan()
Franklin Schmidt <fschmidt@gmail.com>
parents:
785
diff
changeset
|
168 public Object runLuan(String sourceText,String sourceName) throws LuanException { |
1265
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
169 lock.readLock().lock(); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
170 try { |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
171 LuanFunction fn = Luan.load(sourceText,sourceName); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
172 LuanState luan = currentLuan; |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
173 synchronized(luan) { |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
174 LuanCloner cloner = new LuanCloner(LuanCloner.Type.INCREMENTAL); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
175 LuanState luan2 = (LuanState)cloner.clone(luan); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
176 return fn.call(luan2); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
177 } |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
178 } finally { |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
179 lock.readLock().unlock(); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
180 } |
786
fe63c508a177
add Http.reset_luan()
Franklin Schmidt <fschmidt@gmail.com>
parents:
785
diff
changeset
|
181 } |
fe63c508a177
add Http.reset_luan()
Franklin Schmidt <fschmidt@gmail.com>
parents:
785
diff
changeset
|
182 |
1263
382c444a6c77
add Http.eval_in_root and Http.handle_error
Franklin Schmidt <fschmidt@gmail.com>
parents:
1257
diff
changeset
|
183 public void eval_in_root(String text) throws LuanException { |
1265
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
184 LuanState oldLuan = currentLuan; |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
185 LuanState luan; |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
186 synchronized(oldLuan) { |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
187 LuanCloner cloner = new LuanCloner(LuanCloner.Type.COMPLETE); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
188 luan = (LuanState)cloner.clone(oldLuan); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
189 } |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
190 luan.onClose = this; |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
191 BasicLuan.load(text,"<eval_in_root>",null).call(luan); |
3f4644246e39
LuanHandler cleanup and add Server.serve_for_proxy
Franklin Schmidt <fschmidt@gmail.com>
parents:
1264
diff
changeset
|
192 currentLuan = luan; |
1263
382c444a6c77
add Http.eval_in_root and Http.handle_error
Franklin Schmidt <fschmidt@gmail.com>
parents:
1257
diff
changeset
|
193 } |
382c444a6c77
add Http.eval_in_root and Http.handle_error
Franklin Schmidt <fschmidt@gmail.com>
parents:
1257
diff
changeset
|
194 |
1004
3fa54d9d19cd
better handling of BindException
Franklin Schmidt <fschmidt@gmail.com>
parents:
1000
diff
changeset
|
195 public static void start(Server server) throws Exception { |
3fa54d9d19cd
better handling of BindException
Franklin Schmidt <fschmidt@gmail.com>
parents:
1000
diff
changeset
|
196 try { |
3fa54d9d19cd
better handling of BindException
Franklin Schmidt <fschmidt@gmail.com>
parents:
1000
diff
changeset
|
197 server.start(); |
3fa54d9d19cd
better handling of BindException
Franklin Schmidt <fschmidt@gmail.com>
parents:
1000
diff
changeset
|
198 } catch(BindException e) { |
3fa54d9d19cd
better handling of BindException
Franklin Schmidt <fschmidt@gmail.com>
parents:
1000
diff
changeset
|
199 throw new LuanException(e.toString()); |
3fa54d9d19cd
better handling of BindException
Franklin Schmidt <fschmidt@gmail.com>
parents:
1000
diff
changeset
|
200 } |
3fa54d9d19cd
better handling of BindException
Franklin Schmidt <fschmidt@gmail.com>
parents:
1000
diff
changeset
|
201 } |
1077
ca968ef1747a
better handling of BindException
Franklin Schmidt <fschmidt@gmail.com>
parents:
800
diff
changeset
|
202 |
175
bdbd4740121f
finish web server
fschmidt@gmail.com <fschmidt@gmail.com@21e917c8-12df-6dd8-5cb6-c86387c605b9>
parents:
diff
changeset
|
203 } |