Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
 package org.infinispan.client.hotrod.impl.transport.tcp;
 
 

Author(s):
Mircea.Markus@jboss.com
Since:
4.1
   private static final Log log = LogFactory.getLog(TransportObjectFactory.class);
   protected final TcpTransportFactory tcpTransportFactory;
   protected final AtomicInteger defaultCacheTopologyId;
   protected final boolean pingOnStartup;
   protected volatile boolean firstPingExecuted = false;
   protected final Codec codec;
   public TransportObjectFactory(Codec codecTcpTransportFactory tcpTransportFactory,
         AtomicInteger defaultCacheTopologyIdboolean pingOnStartup) {
      this. = tcpTransportFactory;
      this. = defaultCacheTopologyId;
      this. = pingOnStartup;
      this. = codec;
   }
   @Override
   public TcpTransport makeObject(SocketAddress addressthrows Exception {
      TcpTransport tcpTransport = new TcpTransport(address);
      if (.isTraceEnabled()) {
         .tracef("Created tcp transport: %s"tcpTransport);
      }
      if ( && !) {
         .trace("Executing first ping!");
          = true;
         // Don't ignore exceptions from ping() command, since
         // they indicate that the transport instance is invalid.
         ping(tcpTransport);
      }
      return tcpTransport;
   }
   protected PingOperation.PingResult ping(TcpTransport tcpTransportAtomicInteger topologyId) {
      PingOperation po = new PingOperation(topologyIdtcpTransport);
      return po.execute();
   }

   
This will be called by the test thread when testWhileIdle==true.
   @Override
   public boolean validateObject(SocketAddress addressTcpTransport transport) {
      try {
         boolean valid = ping(transport) == ..;
         .tracef("Is connection %s valid? %s"transportvalid);
         return valid;
      } catch (Throwable e) {
         .tracef(e"Error validating the connection %s. Marking it as invalid."transport);
         return false;
      }
   }
   @Override
   public void destroyObject(SocketAddress addressTcpTransport transportthrows Exception {
      if (.isTraceEnabled()) {
         .tracef("About to destroy tcp transport: %s"transport);
      }
      transport.destroy();
   }
   @Override
   public void activateObject(SocketAddress addressTcpTransport transportthrows Exception {
      super.activateObject(addresstransport);
      if (.isTraceEnabled()) {
         .tracef("Fetching from pool: %s"transport);
      }
   }
   @Override
   public void passivateObject(SocketAddress addressTcpTransport transportthrows Exception {
      super.passivateObject(addresstransport);
      if (.isTraceEnabled()) {
         .tracef("Returning to pool: %s"transport);
      }
   }
New to GrepCode? Check out our FAQ X