Hi Erick
Erik Svensson wrote:
> Howdy all,
>
> On 1/22/08 5:10 PM, "Jeanfrancois Arcand" <Jeanfrancois.Arcand_at_Sun.COM>
> wrote:
>
>> Hi,
>>
>> Oleksiy Stashok wrote:
>>> Hello,
>>>
>>> if you're registering callbackHandler with ConnectorHandler, it's
>>> required to call finishConnect on onConnect event. For example:
>>>
>>> / public void onConnect(IOEvent<Context> ioEvent) {
>>> SelectionKey key = ioEvent.attachment().getSelectionKey();
>>> try{
>>> tcpConnector.finishConnect(key);
>>> } catch (IOException ex){
>>> // log
>>> }
>>> ioEvent.attachment().getSelectorHandler().register(key,
>>> SelectionKey.OP_READ);
>>> }
>>> /
>>>
>> OK I will work on documenting this as this is the second email today
>> talking about this undocumented operation :-)
>
> With Oleksiys help my example worked.
> I've modified TCPConnectorHandler:connect(SocketAddress remoteAddres,
> SocketAddress localAddress) to check for a callbackHandler and if one isn't
> installed it creates one (identical to the one created if controller ==
> null). This makes TCPConnectorHandler a bit easier to use for the the most
> common case.
Agree. Can you send the diff -u :-) We gonna add it to the trunk.
Thanks!
-- Jeanfrancois
>
>
> cheers
>
> Erik Svensson, SIX AB
>
>> A+
>>
>> -- Jeanfrancois
>>
>>
>>> Thanks.
>>>
>>> WBR,
>>> Alexey.
>>>
>>> Erik Svensson wrote:
>>>> Hwody all!
>>>>
>>>> We're newcomers to grizzly, looking to use grizzly as a comm backbone
>>>> for a
>>>> near-realtime information flow system for the financial industry.
>>>> I've created a simple server without a problem and now I'm looking at
>>>> writing a client using grizzly and here I run into some snags.
>>>> I've been looking at
>>>> http://blogs.sun.com/oleksiys/resource/ssl-client/GrizzlySSLNIOClient.java
>>>>
>>>> as an exampel but I can't get it to work.
>>>> The code:
>>>>
>>>> <snip>
>>>> private TCPConnectorHandler connector_handler;
>>>> private Controller controller;
>>>> private TCPSelectorHandler tcp_selector_handler;
>>>>
>>>> private ByteBuffer buf = ByteBuffer.allocate(100);
>>>>
>>>> controller = new Controller();
>>>> tcp_selector_handler = new TCPSelectorHandler(true); // true to get
>>>> client
>>>> controller.addSelectorHandler(tcp_selector_handler);
>>>>
>>>> controller.addStateListener(new ControllerStateListenerAdapter() {
>>>>
>>>> public void onReady() {
>>>> System.out.println("Ready!");
>>>> }
>>>>
>>>> public void onStarted() {
>>>> System.out.println("Controller started!");
>>>> }
>>>>
>>>> });
>>>>
>>>> new Thread(controller).start();
>>>> synchronized(this) {
>>>> try {
>>>> wait(30000);
>>>> } catch(Exception e) {
>>>> System.out.println("Timeout in wait"+e.getMessage());
>>>> }
>>>> }
>>>>
>>>> connector_handler =(TCPConnectorHandler)
>>>> controller.acquireConnectorHandler(Controller.Protocol.TCP);
>>>> connector_handler.setController(controller);
>>>>
>>>> System.out.println("Thread is started.? "+(controller.isStarted() ?
>>>> "Yes" : "No"));
>>>> try {
>>>> byte[] filler = new byte[92];
>>>>
>>>> for (int i = 0; i< filler.length; i++) {
>>>> filler[i] = 2;
>>>> }
>>>>
>>>> connector_handler.connect(new InetSocketAddress(host,port),
>>>> new
>>>> CallbackHandler() {
>>>> public void onConnect(IOEvent e) {
>>>> System.out.println("Callbackhandler: OnConnect...");
>>>> }
>>>>
>>>> public void onRead(IOEvent e) {
>>>> System.out.println("Callbackhandler: OnRead...");
>>>> }
>>>>
>>>> public void onWrite(IOEvent e) {
>>>> System.out.println("Callbackhandler: OnWrite...");
>>>> }
>>>>
>>>> });
>>>> int ctr = 0;
>>>> while (ctr < repeats) {
>>>> buf.putLong(System.nanoTime());
>>>> buf.put(filler);
>>>> buf.flip();
>>>> connector_handler.write(buf,false);
>>>> buf.clear();
>>>> connector_handler.read(buf,true);
>>>> buf.flip();
>>>> elapsed += System.nanoTime() - buf.getLong();
>>>> buf.clear();
>>>> ctr++;
>>>> }
>>>> System.out.println(""+repeats+" run at a total of "+elapsed+"
>>>> nanoseconds. Per packet it comes down to "+elapsed/repeats+
>>>> " nanoseconds per roundtrip.");
>>>> } catch(Exception e) {
>>>> System.out.println("Exception in execute..."+e);
>>>> e.printStackTrace(System.out);
>>>> }
>>>> }
>>>>
>>>> WHen I try to run it I get an java.nio.channels.NotYetConnectedException.
>>>> I've checked that I can connect to the host. What am I doing wrong?
>>>>
>>>> cheers
>>>>
>>>> Erik Svensson, SIX AB
>>>>
>>>>
>>>> ---------------------------------------------------------------------
>>>> 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
>>>
>> ---------------------------------------------------------------------
>> 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
>