How to handle OP_CONNECT ?

View: Old framed views

3 Messages — Rating Filter: Alert me

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@...
For additional commands, e-mail: users-help@...

Oleksiy Stashok

Re: How to handle OP_CONNECT ?

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@...
> For additional commands, e-mail: users-help@...
>

---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@...
For additional commands, e-mail: users-help@...

Matthias Schmidt-13

Re: How to handle OP_CONNECT ?

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@...
>> For additional commands, e-mail: users-help@...
>>
>
>
> ---------------------------------------------------------------------
> To unsubscribe, e-mail: users-unsubscribe@...
> For additional commands, e-mail: users-help@...
>