ChromaGaming/ButtonWebsiteModule
1
0
Fork 0
Code Issues 4 Pull requests Projects Releases Packages Wiki Activity

IT WORKS!!! - Cleanup

Browse source
This commit is contained in:
Norbi Peti 2018-01-06 03:46:14 +01:00
parent 7f97683509
commit f6ba2929a4
No known key found for this signature in database
GPG key ID: DBA4C4549A927E56
1 changed files with 3 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
src/buttondevteam/website/page/BridgePage.java
View file

@ -39,7 +39,7 @@ public class BridgePage extends Page {
socket.setKeepAlive(true); socket.setKeepAlive(true);
socket.setTcpNoDelay(true); socket.setTcpNoDelay(true);
connections.put(id, socket); connections.put(id, socket);
System.out.println("[" + id + "] Created a bridge: " + id); System.out.println("[BWM] Created a bridge: " + id);
return new Response(201, "You know what you created. A bridge.", exchange); return new Response(201, "You know what you created. A bridge.", exchange);
case "PUT": case "PUT":
s = getSocket(exchange); s = getSocket(exchange);
@ -47,9 +47,7 @@ public class BridgePage extends Page {
return new Response(400, "No connection", exchange); return new Response(400, "No connection", exchange);
if (s.isClosed()) if (s.isClosed())
return new Response(410, "Socket Gone", exchange); return new Response(410, "Socket Gone", exchange);
System.out.println("[" + id + "] PUT " + copyStream(exchange.getRequestBody(), s.getOutputStream()) // Don't close the socket, PUT messages are sent individually
+ " bytes into the server");
// s.getOutputStream().close(); - Don't close the socket, PUT messages are sent individually
return new Response(200, "OK", exchange); return new Response(200, "OK", exchange);
case "GET": case "GET":
s = getSocket(exchange); s = getSocket(exchange);
@ -58,13 +56,10 @@ public class BridgePage extends Page {
if (s.isClosed()) if (s.isClosed())
return new Response(410, "Socket Gone", exchange); return new Response(410, "Socket Gone", exchange);
exchange.sendResponseHeaders(200, 0); // Chunked transfer, any amount of data exchange.sendResponseHeaders(200, 0); // Chunked transfer, any amount of data
System.out.println("[" + id + "] Sending to GET");
System.out.println("[" + id + "] Sent to GET "
+ copyStream(s.getInputStream(), exchange.getResponseBody()) + " bytes");
exchange.getResponseBody().close(); // It'll only get here when the communication is already done exchange.getResponseBody().close(); // It'll only get here when the communication is already done
return null; // Response already sent return null; // Response already sent
case "DELETE": case "DELETE":
System.out.println("[" + id + "] delet this"); System.out.println("[BWM] [" + id + "] delet this");
closeSocket(exchange); closeSocket(exchange);
return new Response(200, "OK", exchange); return new Response(200, "OK", exchange);
default: default: