com.sybase.jdbc2.timedio
Class InStreamMgr

java.lang.Object
  |
  +--com.sybase.jdbc2.timedio.InStreamMgr
public class InStreamMgr
extends Object

Field Summary
 private int_cacheSize
           
 private boolean_cancelling
           
 private java.sql.SQLWarning_capSqw
           
 private boolean_closing
           
 private com.sybase.jdbc2.timedio.StreamContext_currentCtx
           
 private com.sybase.jdbc2.timedio.Dbio_dbio
           
 private com.sybase.jdbc2.timedio.StreamContext_eventCtx
           
 private com.sybase.jdbc2.timedio.OutStreamMgr_outMgr
           
 (package private) com.sybase.jdbc2.utils.BufferInterval_partialBI
           
 private com.sybase.jdbc2.utils.BufferPool_pool
           
 private boolean_readAhead
           
 private com.sybase.jdbc2.utils.SyncObj_readerThd
           
 private com.sybase.jdbc2.utils.SyncQueue_readList
           
 private boolean_serialize
           
 com.sybase.jdbc2.tds.Tds_tds
           
 boolean_tracing
           
 final static intERROR
           
 final static intEVENT
           
 final static intEVENT_DONE
           
 final static intPARTIAL_PACKET
           
 final static intRESPONSE_DONE
           
 final static intRESPONSE_MORE
           
 final static intRESPONSE_OPEN
           

Constructor Summary
InStreamMgr(java.lang.String , int , com.sybase.jdbc2.jdbc.SybProperty )
           

Method Summary
 protected voidcacheResponses(com.sybase.jdbc2.timedio.StreamContext )
           
 voidcancelling(boolean )
           
 voidclose()
           
 voidclosing()
           
 protected com.sybase.jdbc2.timedio.StreamContextcurrentContext()
           
 voiddoRead(com.sybase.jdbc2.timedio.StreamContext )
           
 protected com.sybase.jdbc2.utils.SyncObjdump()
           
 com.sybase.jdbc2.utils.BufferIntervalgetBI()
           
 com.sybase.jdbc2.jdbc.CapturegetCapture()
           
 java.sql.SQLWarninggetCaptureWarnings()
           
 private synchronized com.sybase.jdbc2.timedio.StreamContextgetCurrentContext()
           
 java.io.InputStreamgetInputStream()
           
 java.io.OutputStreamgetOutputStream()
           
 protected com.sybase.jdbc2.utils.SyncQueuegetReadQueue()
           
 java.lang.StringgetSessionID()
           
 voidmarkDead()
           
 protected voidmoreData(com.sybase.jdbc2.utils.BufferInterval , int )
           
 private voidpartialPacket(com.sybase.jdbc2.utils.BufferInterval )
           
 private voidreadIfOwner(int , com.sybase.jdbc2.timedio.StreamContext )
           
 voidreportError(java.lang.String )
           
 protected voidsetBuffer(long )
           
 synchronized voidsetCurrentContextNull()
           
 voidsetEventContext(com.sybase.jdbc2.timedio.StreamContext )
           
 voidsetNetBufSize(int )
           
 protected voidsetOutStreamMgr(com.sybase.jdbc2.timedio.OutStreamMgr )
           
 voidsetSerialize()
           
 booleanstartAsync()
           
 private inttakeIfNoReadAhead(com.sybase.jdbc2.timedio.StreamContext )
           

Methods inherited from class java.lang.Object
getClass, hashCode, equals, clone, toString, notify, notifyAll, wait, wait, wait, finalize

Field Detail

_cacheSize

private int _cacheSize

_cancelling

private boolean _cancelling

_capSqw

private java.sql.SQLWarning _capSqw

_closing

private boolean _closing

_currentCtx

private com.sybase.jdbc2.timedio.StreamContext _currentCtx

_dbio

private com.sybase.jdbc2.timedio.Dbio _dbio

_eventCtx

private com.sybase.jdbc2.timedio.StreamContext _eventCtx

_outMgr

private com.sybase.jdbc2.timedio.OutStreamMgr _outMgr

_partialBI

com.sybase.jdbc2.utils.BufferInterval _partialBI

_pool

private com.sybase.jdbc2.utils.BufferPool _pool

_readAhead

private boolean _readAhead

_readerThd

private com.sybase.jdbc2.utils.SyncObj _readerThd

_readList

private com.sybase.jdbc2.utils.SyncQueue _readList

_serialize

private boolean _serialize

_tds

public com.sybase.jdbc2.tds.Tds _tds

_tracing

public boolean _tracing

ERROR

public final static int ERROR

EVENT

public final static int EVENT

EVENT_DONE

public final static int EVENT_DONE

PARTIAL_PACKET

public final static int PARTIAL_PACKET

RESPONSE_DONE

public final static int RESPONSE_DONE

RESPONSE_MORE

public final static int RESPONSE_MORE

RESPONSE_OPEN

public final static int RESPONSE_OPEN
Constructor Detail

InStreamMgr

public InStreamMgr(java.lang.String , int , com.sybase.jdbc2.jdbc.SybProperty )
Method Detail

cacheResponses

protected void cacheResponses(com.sybase.jdbc2.timedio.StreamContext )

cancelling

public void cancelling(boolean )

close

public void close()

closing

public void closing()

currentContext

protected com.sybase.jdbc2.timedio.StreamContext currentContext()

doRead

public void doRead(com.sybase.jdbc2.timedio.StreamContext )

dump

protected com.sybase.jdbc2.utils.SyncObj dump()

getBI

public com.sybase.jdbc2.utils.BufferInterval getBI()

getCapture

public com.sybase.jdbc2.jdbc.Capture getCapture()

getCaptureWarnings

public java.sql.SQLWarning getCaptureWarnings()

getCurrentContext

private synchronized com.sybase.jdbc2.timedio.StreamContext getCurrentContext()

getInputStream

public java.io.InputStream getInputStream()

getOutputStream

public java.io.OutputStream getOutputStream()

getReadQueue

protected com.sybase.jdbc2.utils.SyncQueue getReadQueue()

getSessionID

public java.lang.String getSessionID()

markDead

public void markDead()

moreData

protected void moreData(com.sybase.jdbc2.utils.BufferInterval , int )

partialPacket

private void partialPacket(com.sybase.jdbc2.utils.BufferInterval )

readIfOwner

private void readIfOwner(int , com.sybase.jdbc2.timedio.StreamContext )

reportError

public void reportError(java.lang.String )

setBuffer

protected void setBuffer(long )

setCurrentContextNull

public synchronized void setCurrentContextNull()

setEventContext

public void setEventContext(com.sybase.jdbc2.timedio.StreamContext )

setNetBufSize

public void setNetBufSize(int )

setOutStreamMgr

protected void setOutStreamMgr(com.sybase.jdbc2.timedio.OutStreamMgr )

setSerialize

public void setSerialize()

startAsync

public boolean startAsync()

takeIfNoReadAhead

private int takeIfNoReadAhead(com.sybase.jdbc2.timedio.StreamContext )