cx.ath.matthew.unix.USInputStream クラス

cx.ath.matthew.unix.USInputStream の継承関係図

cx.ath.matthew.unix.USInputStream 連携図

公開メンバ関数
	USInputStream (int sock, UnixSocket us)
void	close () throws IOException
boolean	markSupported ()
int	read () throws IOException
int	read (byte[] b, int off, int len) throws IOException
boolean	isClosed ()
UnixSocket	getSocket ()
void	setBlocking (boolean enable)
void	setSoTimeout (int timeout)

静的公開変数類
static final int	MSG_DONTWAIT = 0x40

変数
boolean	closed = false

非公開メンバ関数
native int	native_recv (int sock, byte[] b, int off, int len, int flags, int timeout) throws IOException

非公開変数類
int	sock
byte []	onebuf = new byte[1]
UnixSocket	us
boolean	blocking = true
int	flags = 0
int	timeout = 0

詳解

構築子と解体子

USInputStream()

cx.ath.matthew.unix.USInputStream.USInputStream ( int  sock, UnixSocket  us  )

inline

                                                  {
        this.sock = sock;
        this.us = us;
    }

関数詳解

close()

void cx.ath.matthew.unix.USInputStream.close ( ) throws IOException

inline

                                           {
        closed = true;
        us.close();
    }

getSocket()

UnixSocket cx.ath.matthew.unix.USInputStream.getSocket ( )

inline

                                  {
        return us;
    }

isClosed()

boolean cx.ath.matthew.unix.USInputStream.isClosed ( )

inline

                              {
        return closed;
    }

markSupported()

boolean cx.ath.matthew.unix.USInputStream.markSupported ( )

inline

                                   {
        return false;
    }

native_recv()

native int cx.ath.matthew.unix.USInputStream.native_recv ( int  sock, byte []  b, int  off, int  len, int  flags, int  timeout  ) throws IOException

private

read() [1/2]

int cx.ath.matthew.unix.USInputStream.read ( ) throws IOException

inline

                                         {
        int rv = 0;
        while (0 >= rv) rv = read(onebuf);
        if (-1 == rv) return -1;
        return 0 > onebuf[0] ? -onebuf[0] : onebuf[0];
    }

read() [2/2]

int cx.ath.matthew.unix.USInputStream.read ( byte []  b, int  off, int  len  ) throws IOException

inline

                                                                   {
        if (closed) throw new NotConnectedException();
        int count = native_recv(sock, b, off, len, flags, timeout);
      /* Yes, I really want to do this. Recv returns 0 for 'connection shut down'.
       * read() returns -1 for 'end of stream.
       * Recv returns -1 for 'EAGAIN' (all other errors cause an exception to be raised)
       * whereas read() returns 0 for '0 bytes read', so yes, I really want to swap them here.
       */
        if (0 == count) return -1;
        else if (-1 == count) return 0;
        else return count;
    }

setBlocking()

void cx.ath.matthew.unix.USInputStream.setBlocking ( boolean  enable )

inline

                                            {
        flags = enable ? 0 : MSG_DONTWAIT;
    }

setSoTimeout()

void cx.ath.matthew.unix.USInputStream.setSoTimeout ( int  timeout )

inline

                                          {
        this.timeout = timeout;
    }

メンバ詳解

blocking

boolean cx.ath.matthew.unix.USInputStream.blocking = true

private

closed

boolean cx.ath.matthew.unix.USInputStream.closed = false

package

flags

int cx.ath.matthew.unix.USInputStream.flags = 0

private

MSG_DONTWAIT

final int cx.ath.matthew.unix.USInputStream.MSG_DONTWAIT = 0x40

static

onebuf

byte [] cx.ath.matthew.unix.USInputStream.onebuf = new byte[1]

private

sock

int cx.ath.matthew.unix.USInputStream.sock

private

timeout

int cx.ath.matthew.unix.USInputStream.timeout = 0

private

us

UnixSocket cx.ath.matthew.unix.USInputStream.us

private

---

このクラス詳解は次のファイルから抽出されました:

• D:/AppData/doxygen/keycloak/federation/src/federation/sssd/src/main/java/cx/ath/matthew/unix/USInputStream.java