performance: use cached version of well-known headers

Author: jknack

.envrc

@@ -0,0 +1,14 @@
+function setjdk() {  
+  if [ $# -ne 0 ]; then  
+   removeFromPath '/System/Library/Frameworks/JavaVM.framework/Home/bin'  
+   if [ -n "${JAVA_HOME+x}" ]; then  
+    removeFromPath $JAVA_HOME/bin  
+   fi  
+   export JAVA_HOME=`/usr/libexec/java_home -v $@`  
+   export PATH=$JAVA_HOME/bin:$PATH
+  fi  
+}  
+function removeFromPath() {  
+  export PATH=$(echo $PATH | sed -E -e "s;:$1;;" -e "s;$1:?;;")  
+}
+setjdk 21

.gitignore

@@ -37,4 +37,3 @@ node_modules
 build
 .gradle
 !gradle-wrapper.jar
-.envrc

modules/jooby-netty/src/main/java/io/jooby/internal/netty/NettyContext.java

@@ -6,8 +6,9 @@
 package io.jooby.internal.netty;
 
 import static io.jooby.internal.netty.NettyHeadersFactory.HEADERS;
+import static io.jooby.internal.netty.NettyString.CONTENT_LENGTH;
+import static io.jooby.internal.netty.NettyString.ZERO;
 import static io.netty.buffer.Unpooled.wrappedBuffer;
-import static io.netty.handler.codec.http.HttpHeaderNames.CONTENT_LENGTH;
 import static io.netty.handler.codec.http.HttpHeaderNames.CONTENT_TYPE;
 import static io.netty.handler.codec.http.HttpHeaderNames.RANGE;
 import static io.netty.handler.codec.http.HttpHeaderNames.SET_COOKIE;
@@ -546,13 +547,13 @@ public Context send(@NonNull String data) {
     return send(data, UTF_8);
   }
 
-  @Override
-  public final Context send(String data, Charset charset) {
+  @NonNull @Override
+  public final Context send(@NonNull String data, @NonNull Charset charset) {
     return send(wrappedBuffer(data.getBytes(charset)));
   }
 
-  @Override
-  public final Context send(byte[] data) {
+  @NonNull @Override
+  public final Context send(@NonNull byte[] data) {
     return send(wrappedBuffer(data));
   }
 
@@ -566,8 +567,8 @@ public Context send(@NonNull ByteBuffer[] data) {
     return send(Unpooled.wrappedBuffer(data));
   }
 
-  @Override
-  public final Context send(ByteBuffer data) {
+  @NonNull @Override
+  public final Context send(@NonNull ByteBuffer data) {
     return send(wrappedBuffer(data));
   }
 
@@ -738,12 +739,12 @@ public Context setResetHeadersOnError(boolean value) {
   }
 
   @NonNull @Override
-  public Context send(StatusCode statusCode) {
+  public Context send(@NonNull StatusCode statusCode) {
     try {
-      setResponseCode(statusCode);
+      setResponseCode(statusCode.value());
       responseStarted = true;
-      if (!setHeaders.contains(CONTENT_LENGTH)) {
-        setHeaders.set(CONTENT_LENGTH, "0");
+      if (contentLength == -1) {
+        setHeaders.set(CONTENT_LENGTH, ZERO);
       }
       var rsp =
           new DefaultFullHttpResponse(

modules/jooby-netty/src/main/java/io/jooby/internal/netty/NettyHandler.java

@@ -5,6 +5,7 @@
  */
 package io.jooby.internal.netty;
 
+import static io.jooby.internal.netty.NettyString.*;
 import static io.jooby.internal.netty.SlowPathChecks.*;
 import static io.netty.handler.codec.http.HttpUtil.isTransferEncodingChunked;
 
@@ -25,11 +26,6 @@
 
 public class NettyHandler extends ChannelInboundHandlerAdapter {
   private final Logger log = LoggerFactory.getLogger(NettyServer.class);
-  private static final CharSequence server = NettyString.of("N");
-  public static final CharSequence CONTENT_TYPE = NettyString.of("content-type");
-  public static final CharSequence TEXT_PLAIN = NettyString.of("text/plain");
-  public static final CharSequence DATE = NettyString.of("date");
-  public static final CharSequence SERVER = NettyString.of("server");
   private final NettyDateService serverDate;
   private final List<Jooby> applications;
   private Router router;

modules/jooby-netty/src/main/java/io/jooby/internal/netty/NettyString.java

@@ -10,12 +10,21 @@
 import edu.umd.cs.findbugs.annotations.NonNull;
 
 public class NettyString implements CharSequence {
+  static final CharSequence server = NettyString.of("N");
+  static final CharSequence CONTENT_TYPE = NettyString.of("content-type");
+  static final CharSequence CONTENT_LENGTH = NettyString.of("content-length");
+  static final CharSequence ZERO = NettyString.of("0");
+  static final CharSequence TEXT_PLAIN = NettyString.of("text/plain");
+  static final CharSequence DATE = NettyString.of("date");
+  static final CharSequence SERVER = NettyString.of("server");
 
   final byte[] bytes;
   private final String value;
+  private final int hashCode;
 
   public NettyString(String value) {
     this.value = value;
+    this.hashCode = value.hashCode();
     this.bytes = value.getBytes(StandardCharsets.US_ASCII);
   }
 
@@ -38,6 +47,19 @@ public char charAt(int index) {
     return value.subSequence(start, end);
   }
 
+  @Override
+  public boolean equals(Object obj) {
+    if (obj != null && obj.getClass() == NettyString.class) {
+      return value.equals(((NettyString) obj).value);
+    }
+    return false;
+  }
+
+  @Override
+  public int hashCode() {
+    return hashCode;
+  }
+
   @Override
   @NonNull public String toString() {
     return value;

tests/src/test/java/examples/Performance.java

@@ -9,6 +9,7 @@
 import static io.jooby.MediaType.JSON;
 
 import io.jooby.Jooby;
+import io.jooby.ServerOptions;
 import io.jooby.StatusCode;
 import io.jooby.netty.NettyServer;
 
@@ -38,9 +39,6 @@ public class Performance extends Jooby {
 
   public static void main(final String[] args) {
     System.setProperty("io.netty.disableHttpHeadersValidation", "true");
-    // runApp(args, new
-    // UndertowServer().setOutputFactory(OutputFactory.threadLocal(OutputFactory.create())),
-    // EVENT_LOOP, Performance::new);
-    runApp(args, new NettyServer(), EVENT_LOOP, Performance::new);
+    runApp(args, new NettyServer(new ServerOptions().setPort(3001)), EVENT_LOOP, Performance::new);
   }
 }