Hola,
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);
> }
> /
>
> Thanks.
>
> WBR,
> Alexey.
Isn't it dangerous to just ignore the IOException? TCPConnector
finishConnect wraps socketChannel's finishConnect which (probably pretty
rarely but still) can throw exception leaving a socket in an unconnected
state. Even better, according to SocketChannel.finishConnect() 1.5 java doc:
"If a connection attempt fails, that is, if an invocation of this method
throws a checked exception, then the channel will be closed."
So we can end up with an unusable selectionKey (with underlaying channel
closed) being put in the Selector's set.
I haven't checked so it's just a theory :)
br,
pb
>
> 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
>
>