1 | /** |
2 | * |
3 | */ |
4 | package org.apache.mina.protocol.io; |
5 | |
6 | import java.net.SocketAddress; |
7 | import java.util.Set; |
8 | |
9 | import org.apache.mina.common.IdleStatus; |
10 | import org.apache.mina.common.SessionConfig; |
11 | import org.apache.mina.common.TransportType; |
12 | import org.apache.mina.io.IoSession; |
13 | import org.apache.mina.protocol.ProtocolDecoder; |
14 | import org.apache.mina.protocol.ProtocolEncoder; |
15 | import org.apache.mina.protocol.ProtocolHandler; |
16 | import org.apache.mina.protocol.ProtocolFilterChain; |
17 | import org.apache.mina.protocol.ProtocolSession; |
18 | import org.apache.mina.protocol.ProtocolSessionFilterChain; |
19 | import org.apache.mina.protocol.ProtocolSessionManagerFilterChain; |
20 | import org.apache.mina.protocol.SimpleProtocolDecoderOutput; |
21 | import org.apache.mina.protocol.SimpleProtocolEncoderOutput; |
22 | import org.apache.mina.protocol.io.IoAdapter.SessionHandlerAdapter; |
23 | import org.apache.mina.util.Queue; |
24 | |
25 | /** |
26 | * A {@link ProtocolSession} that is backed by {@link IoSession}. |
27 | * |
28 | * @author The Apache Directory Project (dev@directory.apache.org) |
29 | * @version $Rev: 327113 $, $Date: 2005-10-21 15:59:15 +0900 $ |
30 | */ |
31 | public class IoProtocolSession implements ProtocolSession |
32 | { |
33 | private final ProtocolSessionFilterChain filterChain; |
34 | |
35 | final IoSession session; |
36 | |
37 | final SessionHandlerAdapter shAdapter; |
38 | |
39 | final Queue writeQueue = new Queue(); |
40 | |
41 | final ProtocolEncoder encoder; |
42 | |
43 | final ProtocolDecoder decoder; |
44 | |
45 | final SimpleProtocolEncoderOutput encOut; |
46 | |
47 | final SimpleProtocolDecoderOutput decOut; |
48 | |
49 | IoProtocolSession( ProtocolSessionManagerFilterChain managerFilterChain, |
50 | IoSession session, SessionHandlerAdapter shAdapter ) |
51 | { |
52 | this.filterChain = new ProtocolSessionFilterChain( managerFilterChain ); |
53 | this.session = session; |
54 | this.shAdapter = shAdapter; |
55 | this.encoder = shAdapter.codecFactory.newEncoder(); |
56 | this.decoder = shAdapter.codecFactory.newDecoder(); |
57 | this.encOut = new SimpleProtocolEncoderOutput(); |
58 | this.decOut = new SimpleProtocolDecoderOutput(); |
59 | } |
60 | |
61 | /** |
62 | * Returns the {@link IoSession} this session is backed by. |
63 | */ |
64 | public IoSession getIoSession() |
65 | { |
66 | return session; |
67 | } |
68 | |
69 | public ProtocolFilterChain getFilterChain() |
70 | { |
71 | return filterChain; |
72 | } |
73 | |
74 | public ProtocolHandler getHandler() |
75 | { |
76 | return shAdapter.handler; |
77 | } |
78 | |
79 | public ProtocolEncoder getEncoder() |
80 | { |
81 | return encoder; |
82 | } |
83 | |
84 | public ProtocolDecoder getDecoder() |
85 | { |
86 | return decoder; |
87 | } |
88 | |
89 | public void close() |
90 | { |
91 | session.close(); |
92 | } |
93 | |
94 | public void close( boolean wait ) |
95 | { |
96 | session.close( wait ); |
97 | } |
98 | |
99 | public Object getAttachment() |
100 | { |
101 | return session.getAttachment(); |
102 | } |
103 | |
104 | public Object setAttachment( Object attachment ) |
105 | { |
106 | return session.setAttachment( attachment ); |
107 | } |
108 | |
109 | public Object getAttribute( String key ) |
110 | { |
111 | return session.getAttribute( key ); |
112 | } |
113 | |
114 | public Object setAttribute( String key, Object value ) |
115 | { |
116 | return session.setAttribute( key, value ); |
117 | } |
118 | |
119 | public Object removeAttribute( String key ) |
120 | { |
121 | return session.removeAttribute( key ); |
122 | } |
123 | |
124 | public Set getAttributeKeys() |
125 | { |
126 | return session.getAttributeKeys(); |
127 | } |
128 | |
129 | public void write( Object message ) |
130 | { |
131 | filterChain.filterWrite( this, message ); |
132 | } |
133 | |
134 | public long getWrittenWriteRequests() |
135 | { |
136 | return session.getWrittenWriteRequests(); |
137 | } |
138 | |
139 | public int getScheduledWriteRequests() |
140 | { |
141 | return session.getScheduledWriteRequests(); |
142 | } |
143 | |
144 | public TransportType getTransportType() |
145 | { |
146 | return session.getTransportType(); |
147 | } |
148 | |
149 | public boolean isConnected() |
150 | { |
151 | return session.isConnected(); |
152 | } |
153 | |
154 | public SessionConfig getConfig() |
155 | { |
156 | return session.getConfig(); |
157 | } |
158 | |
159 | public SocketAddress getRemoteAddress() |
160 | { |
161 | return session.getRemoteAddress(); |
162 | } |
163 | |
164 | public SocketAddress getLocalAddress() |
165 | { |
166 | return session.getLocalAddress(); |
167 | } |
168 | |
169 | public long getReadBytes() |
170 | { |
171 | return session.getReadBytes(); |
172 | } |
173 | |
174 | public long getWrittenBytes() |
175 | { |
176 | return session.getWrittenBytes(); |
177 | } |
178 | |
179 | public long getCreationTime() |
180 | { |
181 | return session.getCreationTime(); |
182 | } |
183 | |
184 | public long getLastIoTime() |
185 | { |
186 | return session.getLastIoTime(); |
187 | } |
188 | |
189 | public long getLastReadTime() |
190 | { |
191 | return session.getLastReadTime(); |
192 | } |
193 | |
194 | public long getLastWriteTime() |
195 | { |
196 | return session.getLastWriteTime(); |
197 | } |
198 | |
199 | public boolean isIdle( IdleStatus status ) |
200 | { |
201 | return session.isIdle( status ); |
202 | } |
203 | |
204 | public int getIdleCount( IdleStatus status ) |
205 | { |
206 | return session.getIdleCount( status ); |
207 | } |
208 | |
209 | public long getLastIdleTime( IdleStatus status ) |
210 | { |
211 | return session.getLastIdleTime( status ); |
212 | } |
213 | } |