---

GIOPConnectionFactory.java

Go to the documentation of this file.

/***
 * Jonathan: an Open Distributed Processing Environment 
 * Copyright (C) 1999-2000 France Telecom R&D
 * 
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2 of the License, or (at your option) any later version.
 * 
 * This library is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Lesser General Public License for more details.
 * 
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 * 
 * Release: 3.0
 *
 * Contact: jonathan@objectweb.org
 *
 * Author: Bruno Dumant
 * 
 */


package org.objectweb.david.libs.resources.giop;

import org.objectweb.jonathan.apis.kernel.Context;
import org.objectweb.jonathan.apis.kernel.JonathanException;
import org.objectweb.jonathan.apis.kernel.InternalException;
import org.objectweb.jonathan.apis.protocols.ip.IpSession;
import org.objectweb.jonathan.apis.protocols.ip.TcpIpConnectionMgr;
import org.objectweb.jonathan.apis.protocols.ip.IpConnection;
import org.objectweb.jonathan.apis.protocols.ip.TcpIpSrvConnectionFactory;
import org.objectweb.jonathan.apis.resources.Chunk;

import org.omg.GIOP.MsgType_1_0;

import java.io.IOException;

public class GIOPConnectionFactory implements TcpIpConnectionMgr {
   
   // the delegate connection factory.
   TcpIpConnectionMgr mgr;   

   GIOPConnectionFactory(Context c,Object[] used_components) {
      mgr = (TcpIpConnectionMgr) used_components[0];
   }
   
   public String getCanonicalHostName(String hostname) {
      return mgr.getCanonicalHostName(hostname);
   }

   public IpConnection newCltConnection(String host, int port,
                                        IpSession session)
      throws JonathanException {
      return mgr.newCltConnection(host,port,session);
   }

   public TcpIpSrvConnectionFactory newSrvConnectionFactory(int port)
      throws JonathanException {
      return new SrvConnectionFactory(mgr.newSrvConnectionFactory(port));
   }
}


class SrvConnectionFactory implements TcpIpSrvConnectionFactory {
   TcpIpSrvConnectionFactory delegate;
   
   SrvConnectionFactory(TcpIpSrvConnectionFactory delegate) {
      this.delegate = delegate;
   }
   
   //public TcpIpConnection newSrvConnection(TcpIpSession session)
   public IpConnection newSrvConnection(IpSession session)
      throws JonathanException {
      return new GIOPSrvConnection(delegate.newSrvConnection(session));
   }

   //public short getPort() 
   public int getPort() {
      return delegate.getPort();
   }

   public String getHostName() {
      return delegate.getHostName();
   }
   
   public void close() {
      delegate.close();
   }
}

//class GIOPSrvConnection implements TcpIpConnection 
class GIOPSrvConnection implements IpConnection {

   static byte[] header_bytes = {
      71, 73, 79, 80,
      1, 0, // version
      0,   // byte order: don't care
      (byte) MsgType_1_0._CloseConnection,
      0, 0, 0, 0
   };   

   static Chunk header = new Chunk(header_bytes,0,12);

   //TcpIpConnection delegate;
   IpConnection delegate;
   
   GIOPSrvConnection(IpConnection delegate)
      throws JonathanException {
      this.delegate = delegate;
   }
   
   public IpSession getSession() {
      return delegate.getSession();
   }

   public void setSession(IpSession session) {
      delegate.setSession(session);
   }

   public void receive(Chunk chunk,int to_read) throws IOException {
      delegate.receive(chunk,to_read);
   }
   public void emit(Chunk chunk) throws IOException {
      delegate.emit(chunk);
   }
   public int available() throws IOException {
      return delegate.available();
   }
   
   public int getPort() {
      return delegate.getPort();
   }
   public String getHostName() {
      return delegate.getHostName();
   }
   public void release() {
      delegate.release();
   }

   public void delete() {
      try {
         delegate.emit(header);
      } catch (IOException ignored) {}
      delegate.delete();
   }
}   

---