net.sourceforge.jtds.jdbc

Class 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

Nested Class Summary

Nested classes/interfaces inherited from class net.sourceforge.jtds.jdbc.SharedSocket

SharedSocket.VirtualSocket

Field Summary

(package private) RandomAccessFile
pipe
The named pipe as a file.

Fields inherited from class net.sourceforge.jtds.jdbc.SharedSocket

TDS_DONE_LEN, TDS_DONE_TOKEN, TDS_HDR_LEN, bufferDir, cancelMonitor, cancelPending, charsetInfo, doneBuffer, globalMemUsage, hdrBuf, host, in, maxBufSize, memoryBudget, minMemPkts, out, packetCount, peakMemUsage, port, responseOwner, securityViolation, serverType, socket, socketTable, sslSocket, tdsVersion

Constructor Summary

SharedLocalNamedPipe(ConnectionJDBC2 connection)
Creates a new instance of SharedLocalNamedPipe.

Method Summary

(package private) void
close()
Close the named pipe and virtual sockets and release any resources.
(package private) void
forceClose()
Force close the socket causing any pending reads/writes to fail.
(package private) boolean
isConnected()
Get the connected status of this socket.
(package private) byte[]
sendNetPacket(int streamId, buffer[] )
Send an network packet.
protected void
setTimeout(int timeout)
Set the socket timeout.

Methods inherited from class net.sourceforge.jtds.jdbc.SharedSocket

cancel, close, closeStream, createSocketForJDBC3, dequeueInput, disableEncryption, enableEncryption, enqueueInput, forceClose, getCharset, getCharsetInfo, getHost, getIn, getMemoryBudget, getMinMemPkts, getNetPacket, getOut, getPktLen, getPort, getRequestStream, getResponseStream, getTdsVersion, isConnected, lookup, readPacket, sendNetPacket, setCharsetInfo, setIn, setMemoryBudget, setMinMemPkts, setOut, setTdsVersion, setTimeout

Field Details

pipe

(package private)  RandomAccessFile pipe
The named pipe as a file.

Constructor Details

SharedLocalNamedPipe

public SharedLocalNamedPipe(ConnectionJDBC2 connection)
            throws IOException
Creates a new instance of SharedLocalNamedPipe.
Parameters:
connection - the connection object

Method Details

close

(package private)  void close()
            throws IOException
Close the named pipe and virtual sockets and release any resources.
Overrides:
close in interface SharedSocket

forceClose

(package private)  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 interface SharedSocket

isConnected

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

sendNetPacket

(package private)  byte[] sendNetPacket(int streamId,
                                        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 interface SharedSocket
Parameters:
streamId - the originating RequestStream object

setTimeout

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

Generated on September 18 2009