From bc47850bbe36ec6a75ff2a08ae75b6d321cb1b82 Mon Sep 17 00:00:00 2001
From: Norman Maurer <norman@apache.org>
Date: Tue, 6 Mar 2012 19:26:32 +0100
Subject: [PATCH] Allow to obtain the Worker that was used to serve the IO of a
 Channel

---
 .../netty/channel/socket/nio/AbstractNioChannel.java   | 10 ++++++++++
 .../netty/channel/socket/nio/NioDatagramChannel.java   |  5 +++++
 .../io/netty/channel/socket/nio/NioSocketChannel.java  |  5 +++++
 3 files changed, 20 insertions(+)

diff --git a/transport/src/main/java/io/netty/channel/socket/nio/AbstractNioChannel.java b/transport/src/main/java/io/netty/channel/socket/nio/AbstractNioChannel.java
index 27fe0a8e44..df5334f39c 100644
--- a/transport/src/main/java/io/netty/channel/socket/nio/AbstractNioChannel.java
+++ b/transport/src/main/java/io/netty/channel/socket/nio/AbstractNioChannel.java
@@ -115,6 +115,16 @@ abstract class AbstractNioChannel<C extends SelectableChannel & WritableByteChan
         this.channel = ch;
     }
 
+    /**
+     * Return the {@link AbstractNioWorker} that handle the IO of the {@link AbstractNioChannel}
+     * 
+     * @return worker
+     */
+    public AbstractNioWorker getWorker() {
+        return worker;
+    }
+    
+    
     @Override
     public InetSocketAddress getLocalAddress() {
         InetSocketAddress localAddress = this.localAddress;
diff --git a/transport/src/main/java/io/netty/channel/socket/nio/NioDatagramChannel.java b/transport/src/main/java/io/netty/channel/socket/nio/NioDatagramChannel.java
index c8dcc77813..f620154176 100644
--- a/transport/src/main/java/io/netty/channel/socket/nio/NioDatagramChannel.java
+++ b/transport/src/main/java/io/netty/channel/socket/nio/NioDatagramChannel.java
@@ -66,6 +66,11 @@ final class NioDatagramChannel extends AbstractNioChannel<DatagramChannel>
     }
 
 
+    @Override
+    public NioDatagramWorker getWorker() {
+        return (NioDatagramWorker) super.getWorker();
+    }
+
     @Override
     public boolean isBound() {
         return isOpen() && channel.socket().isBound();
diff --git a/transport/src/main/java/io/netty/channel/socket/nio/NioSocketChannel.java b/transport/src/main/java/io/netty/channel/socket/nio/NioSocketChannel.java
index 37f4e669ff..5d36fdc65b 100644
--- a/transport/src/main/java/io/netty/channel/socket/nio/NioSocketChannel.java
+++ b/transport/src/main/java/io/netty/channel/socket/nio/NioSocketChannel.java
@@ -43,6 +43,11 @@ class NioSocketChannel extends AbstractNioChannel<SocketChannel>
         config = new DefaultNioSocketChannelConfig(socket.socket());
     }
 
+    @Override
+    public NioWorker getWorker() {
+        return (NioWorker) super.getWorker();
+    }
+
     @Override
     public NioSocketChannelConfig getConfig() {
         return config;