Skip to content

Commit

Permalink
Revert "fix: login decoders and encoders go before idle state handler"
Browse files Browse the repository at this point in the history
This reverts commit cce9dff.
  • Loading branch information
Z-Kris committed Jan 17, 2025
1 parent b6f1815 commit e615878
Show file tree
Hide file tree
Showing 8 changed files with 16 additions and 16 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -24,15 +24,15 @@ public class LoginChannelInitializer<R>(
"Channel initialized: $ch"
}
ch.pipeline().addLast(
LoginMessageDecoder(networkService),
LoginMessageEncoder(networkService),
IdleStateHandler(
true,
NetworkService.INITIAL_TIMEOUT_SECONDS,
NetworkService.INITIAL_TIMEOUT_SECONDS,
NetworkService.INITIAL_TIMEOUT_SECONDS,
TimeUnit.SECONDS,
),
LoginMessageDecoder(networkService),
LoginMessageEncoder(networkService),
LoginChannelHandler(networkService),
)
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,15 +24,15 @@ public class LoginChannelInitializer<R>(
"Channel initialized: $ch"
}
ch.pipeline().addLast(
LoginMessageDecoder(networkService),
LoginMessageEncoder(networkService),
IdleStateHandler(
true,
NetworkService.INITIAL_TIMEOUT_SECONDS,
NetworkService.INITIAL_TIMEOUT_SECONDS,
NetworkService.INITIAL_TIMEOUT_SECONDS,
TimeUnit.SECONDS,
),
LoginMessageDecoder(networkService),
LoginMessageEncoder(networkService),
LoginChannelHandler(networkService),
)
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,15 +24,15 @@ public class LoginChannelInitializer<R>(
"Channel initialized: $ch"
}
ch.pipeline().addLast(
LoginMessageDecoder(networkService),
LoginMessageEncoder(networkService),
IdleStateHandler(
true,
NetworkService.INITIAL_TIMEOUT_SECONDS,
NetworkService.INITIAL_TIMEOUT_SECONDS,
NetworkService.INITIAL_TIMEOUT_SECONDS,
TimeUnit.SECONDS,
),
LoginMessageDecoder(networkService),
LoginMessageEncoder(networkService),
LoginChannelHandler(networkService),
)
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,15 +24,15 @@ public class LoginChannelInitializer<R>(
"Channel initialized: $ch"
}
ch.pipeline().addLast(
LoginMessageDecoder(networkService),
LoginMessageEncoder(networkService),
IdleStateHandler(
true,
NetworkService.INITIAL_TIMEOUT_SECONDS,
NetworkService.INITIAL_TIMEOUT_SECONDS,
NetworkService.INITIAL_TIMEOUT_SECONDS,
TimeUnit.SECONDS,
),
LoginMessageDecoder(networkService),
LoginMessageEncoder(networkService),
LoginChannelHandler(networkService),
)
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,15 +25,15 @@ public class LoginChannelInitializer<R>(
}
networkService.trafficMonitor.incrementConnections()
ch.pipeline().addLast(
LoginMessageDecoder(networkService),
LoginMessageEncoder(networkService),
IdleStateHandler(
true,
NetworkService.INITIAL_TIMEOUT_SECONDS,
NetworkService.INITIAL_TIMEOUT_SECONDS,
NetworkService.INITIAL_TIMEOUT_SECONDS,
TimeUnit.SECONDS,
),
LoginMessageDecoder(networkService),
LoginMessageEncoder(networkService),
LoginChannelHandler(networkService),
)
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,15 +25,15 @@ public class LoginChannelInitializer<R>(
}
networkService.trafficMonitor.incrementConnections()
ch.pipeline().addLast(
LoginMessageDecoder(networkService),
LoginMessageEncoder(networkService),
IdleStateHandler(
true,
NetworkService.INITIAL_TIMEOUT_SECONDS,
NetworkService.INITIAL_TIMEOUT_SECONDS,
NetworkService.INITIAL_TIMEOUT_SECONDS,
TimeUnit.SECONDS,
),
LoginMessageDecoder(networkService),
LoginMessageEncoder(networkService),
LoginChannelHandler(networkService),
)
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,15 +25,15 @@ public class LoginChannelInitializer<R>(
}
networkService.trafficMonitor.incrementConnections()
ch.pipeline().addLast(
LoginMessageDecoder(networkService),
LoginMessageEncoder(networkService),
IdleStateHandler(
true,
NetworkService.INITIAL_TIMEOUT_SECONDS,
NetworkService.INITIAL_TIMEOUT_SECONDS,
NetworkService.INITIAL_TIMEOUT_SECONDS,
TimeUnit.SECONDS,
),
LoginMessageDecoder(networkService),
LoginMessageEncoder(networkService),
LoginChannelHandler(networkService),
)
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,15 +25,15 @@ public class LoginChannelInitializer<R>(
}
networkService.trafficMonitor.incrementConnections()
ch.pipeline().addLast(
LoginMessageDecoder(networkService),
LoginMessageEncoder(networkService),
IdleStateHandler(
true,
NetworkService.INITIAL_TIMEOUT_SECONDS,
NetworkService.INITIAL_TIMEOUT_SECONDS,
NetworkService.INITIAL_TIMEOUT_SECONDS,
TimeUnit.SECONDS,
),
LoginMessageDecoder(networkService),
LoginMessageEncoder(networkService),
LoginChannelHandler(networkService),
)
}
Expand Down

0 comments on commit e615878

Please sign in to comment.