Skip to content

Commit

Permalink
removed debug log statements.
Browse files Browse the repository at this point in the history
  • Loading branch information
gciuloaica committed May 19, 2022
1 parent f202e8e commit 62e9bf0
Show file tree
Hide file tree
Showing 3 changed files with 1 addition and 6 deletions.
4 changes: 1 addition & 3 deletions zio-http/src/main/scala/zhttp/service/Handler.scala
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@ import io.netty.channel.{ChannelHandlerContext, SimpleChannelInboundHandler}
import io.netty.handler.codec.http._
import zhttp.http._
import zhttp.logging.Logger
import zhttp.service.Handler.log
import zhttp.service.server.WebSocketUpgrade
import zio.{UIO, ZIO}

Expand All @@ -19,7 +18,6 @@ private[zhttp] final case class Handler[R](
with WebSocketUpgrade[R] { self =>

override def channelRead0(ctx: Ctx, msg: HttpObject): Unit = {
log.debug(s"Message: ${msg.getClass.getSimpleName}")
implicit val iCtx: ChannelHandlerContext = ctx
msg match {
case jReq: FullHttpRequest =>
Expand Down Expand Up @@ -50,7 +48,7 @@ private[zhttp] final case class Handler[R](
}
case jReq: HttpRequest =>
val hasBody = canHaveBody(jReq)
log.debug(s"HasBody: ${hasBody}")
// log.debug(s"HasBody: ${hasBody}")
if (hasBody) ctx.channel().config().setAutoRead(false): Unit
try
unsafeRun(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@ import io.netty.channel.{ChannelHandlerContext, DefaultFileRegion}
import io.netty.handler.codec.http._
import zhttp.http._
import zhttp.logging.Logger
import zhttp.service.ServerResponseWriter.log
import zhttp.service.server.ServerTime
import zio.stream.ZStream
import zio.{UIO, ZIO}
Expand Down Expand Up @@ -87,7 +86,6 @@ private[zhttp] final class ServerResponseWriter[R](
* Writes data on the channel
*/
private def writeData(data: HttpData, jReq: HttpRequest)(implicit ctx: Ctx): Unit = {
log.debug(s"WriteData: ${data.getClass.getSimpleName}")
data match {

case _: HttpData.FromAsciiString => flushReleaseAndRead(jReq)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,6 @@ final case class ServerChannelInitializer[R](
// Order of handlers are critical to make this work
val pipeline = channel.pipeline()

log.debug(s"Connection initialized: ${channel.remoteAddress()}")
// SSL
// Add SSL Handler if CTX is available
val sslctx = if (cfg.sslOption == null) null else cfg.sslOption.sslContext
Expand Down

1 comment on commit 62e9bf0

@github-actions
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

🚀 Performance Benchmark:

Concurrency: 256
Requests/sec: 959473.84

Please sign in to comment.