Mercurial Hosting > luan
comparison src/org/eclipse/jetty/io/nio/SelectChannelEndPoint.java @ 945:89fe80dfab2c
remove asyncDispatch()
author | Franklin Schmidt <fschmidt@gmail.com> |
---|---|
date | Tue, 11 Oct 2016 20:53:06 -0600 |
parents | b77d631b9e28 |
children | 901dcfa05c32 |
comparison
equal
deleted
inserted
replaced
944:1d24b6e422fa | 945:89fe80dfab2c |
---|---|
115 { | 115 { |
116 return _key; | 116 return _key; |
117 } | 117 } |
118 } | 118 } |
119 | 119 |
120 /* ------------------------------------------------------------ */ | |
121 public SelectorManager getSelectManager() | 120 public SelectorManager getSelectManager() |
122 { | 121 { |
123 return _manager; | 122 return _manager; |
124 } | 123 } |
125 | 124 |
126 /* ------------------------------------------------------------ */ | |
127 public Connection getConnection() | 125 public Connection getConnection() |
128 { | 126 { |
129 return _connection; | 127 return _connection; |
130 } | 128 } |
131 | 129 |
132 /* ------------------------------------------------------------ */ | |
133 public void setConnection(Connection connection) | 130 public void setConnection(Connection connection) |
134 { | 131 { |
135 _connection=(AsyncConnection)connection; | 132 _connection=(AsyncConnection)connection; |
136 } | |
137 | |
138 /* ------------------------------------------------------------ */ | |
139 public long getIdleTimestamp() | |
140 { | |
141 return _idleTimestamp; | |
142 } | 133 } |
143 | 134 |
144 /* ------------------------------------------------------------ */ | 135 /* ------------------------------------------------------------ */ |
145 /** Called by selectSet to schedule handling | 136 /** Called by selectSet to schedule handling |
146 * | 137 * |
191 _key.interestOps(0); | 182 _key.interestOps(0); |
192 else | 183 else |
193 { | 184 { |
194 // other wise do the dispatch | 185 // other wise do the dispatch |
195 dispatch(); | 186 dispatch(); |
196 } | |
197 } | |
198 } | |
199 | |
200 /* ------------------------------------------------------------ */ | |
201 public void asyncDispatch() | |
202 { | |
203 synchronized(this) | |
204 { | |
205 switch(_state) | |
206 { | |
207 case STATE_NEEDS_DISPATCH: | |
208 case STATE_UNDISPATCHED: | |
209 dispatch(); | |
210 break; | |
211 | |
212 case STATE_DISPATCHED: | |
213 case STATE_ASYNC: | |
214 _state=STATE_ASYNC; | |
215 break; | |
216 } | 187 } |
217 } | 188 } |
218 } | 189 } |
219 | 190 |
220 /* ------------------------------------------------------------ */ | 191 /* ------------------------------------------------------------ */ |