double the buffer size

Author: saviorand

client.py

@@ -10,8 +10,9 @@
 # response = requests.post(url, data=data)
 headers = {'Content-Type': 'application/octet-stream'}
 
-nbyte = 100
+nbyte = 128
 
+# for i in range(4):
 for i in range(4):
     nbyte = 10*nbyte
     data = bytes([0x0A] * nbyte)

external/gojo/bufio/bufio.mojo

@@ -5,7 +5,7 @@ from ..strings import StringBuilder
 
 alias MIN_READ_BUFFER_SIZE = 16
 alias MAX_CONSECUTIVE_EMPTY_READS = 100
-alias DEFAULT_BUF_SIZE = 4096
+alias DEFAULT_BUF_SIZE = 8200
 
 alias ERR_INVALID_UNREAD_BYTE = "bufio: invalid use of unread_byte"
 alias ERR_INVALID_UNREAD_RUNE = "bufio: invalid use of unread_rune"
@@ -93,7 +93,7 @@ struct Reader[R: io.Reader](Sized, io.Reader, io.ByteReader, io.ByteScanner):
             self.read_pos = 0
 
         # Compares to the length of the entire List[UInt8] object, including 0 initialized positions.
-        # IE. var b = List[UInt8](capacity=4096), then trying to write at b[4096] and onwards will fail.
+        # IE. var b = List[UInt8](capacity=8200), then trying to write at b[8200] and onwards will fail.
         if self.write_pos >= self.buf.capacity:
             panic("bufio.Reader: tried to fill full buffer")
 
@@ -444,7 +444,7 @@ struct Reader[R: io.Reader](Sized, io.Reader, io.ByteReader, io.ByteScanner):
         var err = Error()
         var full_buffers = List[List[UInt8]]()
         var total_len = 0
-        var frag = List[UInt8](capacity=4096)
+        var frag = List[UInt8](capacity=8200)
         while True:
             frag, err = self.read_slice(delim)
             if not err:

external/gojo/bufio/scan.mojo

@@ -311,7 +311,7 @@ alias ERR_FINAL_TOKEN = Error("final token")
 # The actual maximum token size may be smaller as the buffer
 # may need to include, for instance, a newline.
 alias MAX_SCAN_TOKEN_SIZE = 64 * 1024
-alias START_BUF_SIZE = 4096  # Size of initial allocation for buffer.
+alias START_BUF_SIZE = 8200  # Size of initial allocation for buffer.
 
 
 fn new_scanner[R: io.Reader](owned reader: R) -> Scanner[R]:

external/gojo/io/io.mojo

@@ -2,7 +2,7 @@ from collections.optional import Optional
 from ..builtins import cap, copy, Byte, panic
 from .traits import ERR_UNEXPECTED_EOF
 
-alias BUFFER_SIZE = 4096
+alias BUFFER_SIZE = 8200
 
 
 fn write_string[W: Writer](inout writer: W, string: String) -> (Int, Error):

external/gojo/net/net.mojo

@@ -4,7 +4,7 @@ from ..builtins import Byte
 from .socket import Socket
 from .address import Addr, TCPAddr
 
-alias DEFAULT_BUFFER_SIZE = 4096
+alias DEFAULT_BUFFER_SIZE = 8200
 
 
 trait Conn(io.Writer, io.Reader, io.Closer):

external/gojo/net/tcp.mojo

@@ -7,7 +7,7 @@ from .socket import Socket
 
 # Time in nanoseconds
 alias Duration = Int
-alias DEFAULT_BUFFER_SIZE = 4096
+alias DEFAULT_BUFFER_SIZE = 8200
 alias DEFAULT_TCP_KEEP_ALIVE = Duration(15 * 1000 * 1000 * 1000)  # 15 seconds
 
 

external/gojo/strings/builder.mojo

@@ -33,7 +33,7 @@ struct StringBuilder[growth_factor: Float32 = 2](Stringable, Sized, io.Writer, i
     var capacity: Int
 
     @always_inline
-    fn __init__(inout self, *, capacity: Int = 4096):
+    fn __init__(inout self, *, capacity: Int = 8200):
         constrained[growth_factor >= 1.25]()
         self.data = DTypePointer[DType.uint8]().alloc(capacity)
         self.size = 0

lightbug_http/http.mojo

@@ -357,6 +357,10 @@ fn encode(res: HTTPResponse) raises -> String:
         _ = builder.write_string(len(res.body_raw).__str__())
         _ = builder.write_string(rChar)
         _ = builder.write_string(nChar)
+    else:
+        _ = builder.write_string("Content-Length: 0")
+        _ = builder.write_string(rChar)
+        _ = builder.write_string(nChar)
 
     _ = builder.write_string("Connection: ")
     if res.connection_close():
@@ -369,11 +373,12 @@ fn encode(res: HTTPResponse) raises -> String:
     _ = builder.write_string("Date: ")
     _ = builder.write_string(current_time)
 
+    _ = builder.write_string(rChar)
+    _ = builder.write_string(nChar)
+    _ = builder.write_string(rChar)
+    _ = builder.write_string(nChar)
+    
     if len(res.body_raw) > 0:
-        _ = builder.write_string(rChar)
-        _ = builder.write_string(nChar)
-        _ = builder.write_string(rChar)
-        _ = builder.write_string(nChar)
         _ = builder.write(res.get_body_bytes())
 
     return StringSlice[False, ImmutableStaticLifetime](unsafe_from_utf8_ptr=builder.render().unsafe_ptr(), len=builder.size)

lightbug_http/net.mojo

@@ -14,7 +14,7 @@ from external.libc import (
     inet_ntop
 )
 
-alias default_buffer_size = 4096
+alias default_buffer_size = 8200
 alias default_tcp_keep_alive = Duration(15 * 1000 * 1000 * 1000)  # 15 seconds
 
 
@@ -270,6 +270,7 @@ fn get_peer_name(fd: Int32) raises -> HostPort:
     """Return the address of the peer connected to the socket."""
     var remote_address_ptr = UnsafePointer[sockaddr].alloc(1)
     var remote_address_ptr_size = socklen_t(sizeof[sockaddr]())
+
     var status = getpeername(
         fd,
         remote_address_ptr,

lightbug_http/sys/server.mojo

@@ -165,6 +165,9 @@ struct SysServer:
         """
         var b = Bytes()
         _ = conn.read(b)
+        if len(b) == 0:
+            conn.close()
+            return
 
         var buf = buffer.new_buffer(b)
         var reader = Reader(buf)
@@ -219,7 +222,6 @@ struct SysServer:
         except e:
             error = Error("Failed to read request body: " + e.__str__())
 
-        print(encode(request))
         var res = handler.func(request)
 
         # if not self.tcp_keep_alive: