Package net.sourceforge.jtds.jdbc

Class SharedLocalNamedPipe

java.lang.Object
net.sourceforge.jtds.jdbc.SharedSocket
net.sourceforge.jtds.jdbc.SharedLocalNamedPipe
public class SharedLocalNamedPipe extends SharedSocket
This class implements inter-process communication (IPC) to the database server using local named pipes (will only work on Windows).
Version:
$Id: SharedLocalNamedPipe.java,v 1.12 2007-07-08 21:38:13 bheineman Exp $
Author:
Adam Etheredge

  • Field Details

  • Constructor Details

    • SharedLocalNamedPipe

      public SharedLocalNamedPipe(JtdsConnection connection) throws IOException
      Creates a new instance of SharedLocalNamedPipe.
      Parameters:
      connection - the connection object
      Throws:
      IOException - if an I/O error occurs

  • Method Details

    • getMAC

      String getMAC()
      Overrides:
      getMAC in class SharedSocket

    • isConnected

      boolean isConnected()
      Get the connected status of this socket.
      Overrides:
      isConnected in class SharedSocket
      Returns:
      true if the underlying named pipe is connected

    • sendNetPacket

      byte[] sendNetPacket(SharedSocket.VirtualSocket vsock, byte[] buffer) throws IOException
      Send an network packet. If output for another virtual socket is in progress this packet will be sent later.
      Overrides:
      sendNetPacket in class SharedSocket
      Parameters:
      vsock - the SharedSocket.VirtualSocket used by the originating RequestStream
      buffer - the data to send
      Returns:
      the same buffer received if emptied or another buffer w/ the same size if the incoming buffer is cached (to avoid copying)
      Throws:
      IOException - if an I/O error occurs

    • close

      void close() throws IOException
      Close the named pipe and virtual sockets and release any resources.
      Overrides:
      close in class SharedSocket
      Throws:
      IOException - if the socket close fails

    • forceClose

      void forceClose()
      Force close the socket causing any pending reads/writes to fail.

      Used by the login timer to abort a login attempt.

      Overrides:
      forceClose in class SharedSocket

    • setTimeout

      protected void setTimeout(int timeout)
      Set the socket timeout.
      Overrides:
      setTimeout in class SharedSocket
      Parameters:
      timeout - the timeout value in milliseconds