Hi Alexey,
Works great!!!!
thanks for this rocket-fast answer!
cheers,
Matthias
Am 25.02.2009 um 14:31 schrieb Oleksiy Stashok:
> Hi Matthias,
>
> please try to create SelectorHandler like this:
>
> TCPSelectorHandler tcpSelectorHandler = new TCPSelectorHandler() {
> @Override
> public boolean onAcceptInterest(SelectionKey key,
> Context ctx) throws IOException{
> SelectableChannel channel = acceptWithoutRegistration(key);
>
> if (channel != null) {
> configureChannel(channel);
> SelectionKey readKey =
> channel.register(selector, SelectionKey.OP_READ |
> SelectionKey.OP_WRITE);
> readKey.attach(System.currentTimeMillis());
> }
> return false;
> }
> }
>
> this way your Filter will be called, when accepted connection will
> be ready for writing - so you'll be able to send data.
>
> Pls. let me know if it works fine for you.
>
> Thanks.
>
> WBR,
> Alexey.
>
>
> On Feb 25, 2009, at 14:24 , Matthias Schmidt wrote:
>
>> Hi *,
>>
>> based on Jean-Francois Grizzly intro:
>>
>> http://weblogs.java.net/blog/jfarcand/archive/2008/02/writing_a_tcpud_1.html
>>
>> I wrote a small Daytime server ( cf RFC 867 ) just to get in touch
>> with grizzly.
>>
>> I used a ProtocolFilter to push the string to the client. (This
>> might be the first mistake here...)
>>
>> The DefaultSelectionKeyHandler only processes the ProtocolChain
>> when there is data to read.
>> Absolutely nothing happens on OP_CONNECT.
>>
>> Question: How can/should i code a server which reacts on an
>> incoming connection?
>> At the moment i have to hit the keyboard once after i issue:
>>
>> telnet localhost 1405
>>
>> Whereas the original unix daytime server just sends the string and
>> exits on an incoming connection.
>>
>> if played around with overloading onConnectOp, onConnectInterest
>> without success.
>>
>> cheers,
>>
>> Matthias
>>
>>
>>> public class Main {
>>>
>>> private static int PORT = 1405;
>>>
>>> public static void main(String[] args) {
>>> Controller controller = new Controller();
>>>
>>> TCPSelectorHandler tcpSelectorHandler = new
>>> TCPSelectorHandler();
>>>
>>> tcpSelectorHandler.setPort(PORT);
>>>
>>> controller.addSelectorHandler(tcpSelectorHandler);
>>>
>>> Pipeline mySharedPipeline = new DefaultPipeline();
>>> mySharedPipeline.setMaxThreads(5);
>>>
>>> controller.setPipeline(mySharedPipeline);
>>>
>>> ProtocolChainInstanceHandler pciHandler =
>>> new ProtocolChainInstanceHandler() {
>>>
>>> final private ProtocolChain protocolChain = new
>>> DefaultProtocolChain();
>>>
>>> public ProtocolChain poll() {
>>> return protocolChain;
>>> }
>>>
>>> public boolean offer(ProtocolChain instance) {
>>> return true;
>>> }
>>> };
>>>
>>> controller.setProtocolChainInstanceHandler(pciHandler);
>>>
>>> ProtocolChain protocolChain = pciHandler.poll();
>>> protocolChain.addFilter(new DaytimeWriterFilter());
>>>
>>> try {
>>> System.out.println("Starting Daytime server running on
>>> port " + PORT);
>>> controller.start();
>>> } catch (IOException ex) {
>>> Logger.getLogger(Main.class.getName()).log(Level.SEVERE,
>>> null, ex);
>>> }
>>>
>>> }
>>> }
>>>
>>> class DaytimeWriterFilter implements ProtocolFilter {
>>>
>>> public boolean execute(Context ctx) throws IOException {
>>> if (ctx.getProtocol() == Controller.Protocol.TCP) {
>>> SelectableChannel channel =
>>> ctx.getSelectionKey().channel();
>>>
>>> String now = "This is grizzly daytime server speaking.
>>> It's: " +
>>> (new Date()).toString() + "\n";
>>>
>>> ByteBuffer buffer = ByteBuffer.wrap(now.getBytes());
>>>
>>> OutputWriter.flushChannel(channel, buffer);
>>>
>>> channel.close();
>>> buffer.clear();
>>> }
>>>
>>> return false;
>>> }
>>>
>>> public boolean postExecute(Context arg0) throws IOException {
>>> return false; // game over
>>> }
>>>
>>> }
>>>
>>
>>
>>
>>
>> Matthias Schmidt Tel: (++49) 6227 356 236
>> Sun Microsystems GmbH Fax: (++49) 6227 356 222
>> Altrottstr. 31 Mobil: (++49) 171 5767209
>> D-69190 Walldorf ICQ: 435738815
>>
>>
>> ---------------------------------------------------------------------
>> To unsubscribe, e-mail: users-unsubscribe_at_grizzly.dev.java.net
>> For additional commands, e-mail: users-help_at_grizzly.dev.java.net
>>
>
>
> ---------------------------------------------------------------------
> To unsubscribe, e-mail: users-unsubscribe_at_grizzly.dev.java.net
> For additional commands, e-mail: users-help_at_grizzly.dev.java.net
>
Matthias Schmidt Tel: (++49) 6227 356 236
Sun Microsystems GmbH Fax: (++49) 6227 356 222
Altrottstr. 31 Mobil: (++49) 171 5767209
D-69190 Walldorf ICQ: 435738815