| 
									
										
										
										
											2021-03-16 09:00:00 +11:00
										 |  |  | --- a/net/minecraft/server/network/ServerConnection.java
 | 
					
						
							|  |  |  | +++ b/net/minecraft/server/network/ServerConnection.java
 | 
					
						
							| 
									
										
										
										
											2022-06-08 02:00:00 +10:00
										 |  |  | @@ -97,14 +97,24 @@
 | 
					
						
							| 
									
										
										
										
											2021-11-22 09:00:00 +11:00
										 |  |  |                      int j = ServerConnection.this.server.getRateLimitPacketsPerSecond(); | 
					
						
							| 
									
										
										
										
											2020-08-12 07:00:00 +10:00
										 |  |  |                      Object object = j > 0 ? new NetworkManagerServer(j) : new NetworkManager(EnumProtocolDirection.SERVERBOUND); | 
					
						
							|  |  |  |   | 
					
						
							| 
									
										
										
										
											2021-06-11 15:00:00 +10:00
										 |  |  | -                    ServerConnection.this.connections.add(object);
 | 
					
						
							|  |  |  | +                    ServerConnection.this.connections.add((NetworkManager) object); // CraftBukkit - decompile error
 | 
					
						
							| 
									
										
										
										
											2020-08-12 07:00:00 +10:00
										 |  |  |                      channel.pipeline().addLast("packet_handler", (ChannelHandler) object); | 
					
						
							| 
									
										
										
										
											2021-11-22 09:00:00 +11:00
										 |  |  |                      ((NetworkManager) object).setListener(new HandshakeListener(ServerConnection.this.server, (NetworkManager) object)); | 
					
						
							| 
									
										
										
										
											2019-07-30 20:45:45 +10:00
										 |  |  |                  } | 
					
						
							| 
									
										
										
										
											2021-11-22 09:00:00 +11:00
										 |  |  | -            }).group((EventLoopGroup) lazyinitvar.get()).localAddress(inetaddress, i)).bind().syncUninterruptibly());
 | 
					
						
							|  |  |  | +            }).group((EventLoopGroup) lazyinitvar.get()).localAddress(inetaddress, i)).option(ChannelOption.AUTO_READ, false).bind().syncUninterruptibly()); // CraftBukkit
 | 
					
						
							| 
									
										
										
										
											2019-07-30 20:45:45 +10:00
										 |  |  |          } | 
					
						
							|  |  |  |      } | 
					
						
							|  |  |  |   | 
					
						
							|  |  |  | +    // CraftBukkit start
 | 
					
						
							|  |  |  | +    public void acceptConnections() {
 | 
					
						
							| 
									
										
										
										
											2021-06-11 15:00:00 +10:00
										 |  |  | +        synchronized (this.channels) {
 | 
					
						
							|  |  |  | +            for (ChannelFuture future : this.channels) {
 | 
					
						
							| 
									
										
										
										
											2020-01-22 08:00:00 +11:00
										 |  |  | +                future.channel().config().setAutoRead(true);
 | 
					
						
							| 
									
										
										
										
											2019-07-30 20:45:45 +10:00
										 |  |  | +            }
 | 
					
						
							|  |  |  | +        }
 | 
					
						
							|  |  |  | +    }
 | 
					
						
							|  |  |  | +    // CraftBukkit end
 | 
					
						
							|  |  |  | +
 | 
					
						
							| 
									
										
										
										
											2021-11-22 09:00:00 +11:00
										 |  |  |      public SocketAddress startMemoryChannel() { | 
					
						
							| 
									
										
										
										
											2021-06-11 15:00:00 +10:00
										 |  |  |          List list = this.channels; | 
					
						
							|  |  |  |          ChannelFuture channelfuture; |