mirror of
https://github.com/HDT3213/godis.git
synced 2025-10-05 08:46:56 +08:00
fix typo
This commit is contained in:
@@ -103,7 +103,7 @@ func (h *Handler) Handle(ctx context.Context, conn net.Conn) {
|
|||||||
|
|
||||||
// Close stops handler
|
// Close stops handler
|
||||||
func (h *Handler) Close() error {
|
func (h *Handler) Close() error {
|
||||||
logger.Info("handler shuting down...")
|
logger.Info("handler shutting down...")
|
||||||
h.closing.Set(true)
|
h.closing.Set(true)
|
||||||
// TODO: concurrent wait
|
// TODO: concurrent wait
|
||||||
h.activeConn.Range(func(key interface{}, val interface{}) bool {
|
h.activeConn.Range(func(key interface{}, val interface{}) bool {
|
||||||
|
@@ -76,7 +76,7 @@ func (h *EchoHandler) Handle(ctx context.Context, conn net.Conn) {
|
|||||||
|
|
||||||
// Close stops echo handler
|
// Close stops echo handler
|
||||||
func (h *EchoHandler) Close() error {
|
func (h *EchoHandler) Close() error {
|
||||||
logger.Info("handler shuting down...")
|
logger.Info("handler shutting down...")
|
||||||
h.closing.Set(true)
|
h.closing.Set(true)
|
||||||
// TODO: concurrent wait
|
// TODO: concurrent wait
|
||||||
h.activeConn.Range(func(key interface{}, val interface{}) bool {
|
h.activeConn.Range(func(key interface{}, val interface{}) bool {
|
||||||
|
Reference in New Issue
Block a user