Whitespace

eventmachine · Apr 24, 2018 · 6d770f5 · 6d770f5
1 parent 8d645e1
commit 6d770f5
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 14 deletions.
diff --git a/java/src/com/rubyeventmachine/EmReactor.java b/java/src/com/rubyeventmachine/EmReactor.java
@@ -539,15 +539,15 @@ public Object[] getPeerName (long sig) {
 	}
 
 	public Object[] getSockName (long sig) {
-    	EventableChannel channel = Connections.get(sig);
-    	if (channel != null) {
-    	    return Connections.get(sig).getSockName();
-    	}
-    	else {
-    	    ServerSocketChannel acceptor = Acceptors.get(sig);
-    	    return new Object[] { acceptor.socket().getLocalPort(),
-    	            acceptor.socket().getInetAddress().getHostAddress() };
-    	}
+		EventableChannel channel = Connections.get(sig);
+		if (channel != null) {
+			return Connections.get(sig).getSockName();
+		}
+		else {
+			ServerSocketChannel acceptor = Acceptors.get(sig);
+			return new Object[] { acceptor.socket().getLocalPort(),
+				acceptor.socket().getInetAddress().getHostAddress() };
+		}
 	}
 
 	public long attachChannel (SocketChannel sc, boolean watch_mode) {

diff --git a/java/src/com/rubyeventmachine/EventableDatagramChannel.java b/java/src/com/rubyeventmachine/EventableDatagramChannel.java
@@ -70,23 +70,23 @@ public EventableDatagramChannel (DatagramChannel dc, long _binding, Selector sel
 	}
 
 	public void scheduleOutboundData (ByteBuffer bb) {
- 		try {
+		try {
 			if ((!bCloseScheduled) && (bb.remaining() > 0)) {
 				outboundQ.addLast(new Packet(bb, returnAddress));
 				outboundS += bb.remaining();
- 				channel.register(selector, SelectionKey.OP_WRITE | SelectionKey.OP_READ, this);
+				channel.register(selector, SelectionKey.OP_WRITE | SelectionKey.OP_READ, this);
 			}
 		} catch (ClosedChannelException e) {
 			throw new RuntimeException ("no outbound data");			
 		}
 	}
 
 	public void scheduleOutboundDatagram (ByteBuffer bb, String recipAddress, int recipPort) {
- 		try {
+		try {
 			if ((!bCloseScheduled) && (bb.remaining() > 0)) {
 				outboundQ.addLast(new Packet (bb, new InetSocketAddress (recipAddress, recipPort)));
 				outboundS += bb.remaining();
- 				channel.register(selector, SelectionKey.OP_WRITE | SelectionKey.OP_READ, this);
+				channel.register(selector, SelectionKey.OP_WRITE | SelectionKey.OP_READ, this);
 			}
 		} catch (ClosedChannelException e) {
 			throw new RuntimeException ("no outbound data");			

diff --git a/java/src/com/rubyeventmachine/EventableSocketChannel.java b/java/src/com/rubyeventmachine/EventableSocketChannel.java
@@ -242,7 +242,7 @@ public boolean writeOutboundData() throws IOException {
 		// If anyone wants to close immediately, they're responsible for clearing
 		// the outbound queue.
 		return (bCloseScheduled && outboundQ.isEmpty()) ? false : true;
- 	}
+	}
 
 	public void setConnectPending() {
 		bConnectPending = true;