类com.sun.corba.se.impl.protocol.giopmsgheaders.CancelRequestMessage源码实例Demo

下面列出了怎么用com.sun.corba.se.impl.protocol.giopmsgheaders.CancelRequestMessage的API类实例代码及写法,或者点击链接到github查看源代码。

public void handleInput(CancelRequestMessage header) throws IOException
{
    try {
        try {
            messageHeader = header;
            setInputObject();

            // REVISIT: Move these two to subcontract.
            inputObject.unmarshalHeader();

            if (transportDebug()) dprint(".CANCEL->: id/"
                                         + header.getRequestId() + ": "
                                         + header.getGIOPVersion() + ": "
                                         + header);

            processCancelRequest(header.getRequestId());
            releaseByteBufferToPool();
        } finally {
            setWorkThenReadOrResumeSelect(header);
        }
    } catch (Throwable t) {
        if (transportDebug()) dprint(".CANCEL: id/"
                                     + header.getRequestId()
                                     + ": !!ERROR!!: "
                                     + header, t);
        // Mask the exception from thread.;
    } finally {
        if (transportDebug()) dprint(".CANCEL<-: id/"
                                     + header.getRequestId() + ": "
                                     + header.getGIOPVersion() + ": "
                                     + header);
    }
}
 
源代码2 项目: TencentKona-8   文件: CorbaMessageMediatorImpl.java
public void handleInput(CancelRequestMessage header) throws IOException
{
    try {
        try {
            messageHeader = header;
            setInputObject();

            // REVISIT: Move these two to subcontract.
            inputObject.unmarshalHeader();

            if (transportDebug()) dprint(".CANCEL->: id/"
                                         + header.getRequestId() + ": "
                                         + header.getGIOPVersion() + ": "
                                         + header);

            processCancelRequest(header.getRequestId());
            releaseByteBufferToPool();
        } finally {
            setWorkThenReadOrResumeSelect(header);
        }
    } catch (Throwable t) {
        if (transportDebug()) dprint(".CANCEL: id/"
                                     + header.getRequestId()
                                     + ": !!ERROR!!: "
                                     + header, t);
        // Mask the exception from thread.;
    } finally {
        if (transportDebug()) dprint(".CANCEL<-: id/"
                                     + header.getRequestId() + ": "
                                     + header.getGIOPVersion() + ": "
                                     + header);
    }
}
 
源代码3 项目: jdk8u60   文件: CorbaMessageMediatorImpl.java
public void handleInput(CancelRequestMessage header) throws IOException
{
    try {
        try {
            messageHeader = header;
            setInputObject();

            // REVISIT: Move these two to subcontract.
            inputObject.unmarshalHeader();

            if (transportDebug()) dprint(".CANCEL->: id/"
                                         + header.getRequestId() + ": "
                                         + header.getGIOPVersion() + ": "
                                         + header);

            processCancelRequest(header.getRequestId());
            releaseByteBufferToPool();
        } finally {
            setWorkThenReadOrResumeSelect(header);
        }
    } catch (Throwable t) {
        if (transportDebug()) dprint(".CANCEL: id/"
                                     + header.getRequestId()
                                     + ": !!ERROR!!: "
                                     + header, t);
        // Mask the exception from thread.;
    } finally {
        if (transportDebug()) dprint(".CANCEL<-: id/"
                                     + header.getRequestId() + ": "
                                     + header.getGIOPVersion() + ": "
                                     + header);
    }
}
 
public void handleInput(CancelRequestMessage header) throws IOException
{
    try {
        try {
            messageHeader = header;
            setInputObject();

            // REVISIT: Move these two to subcontract.
            inputObject.unmarshalHeader();

            if (transportDebug()) dprint(".CANCEL->: id/"
                                         + header.getRequestId() + ": "
                                         + header.getGIOPVersion() + ": "
                                         + header);

            processCancelRequest(header.getRequestId());
            releaseByteBufferToPool();
        } finally {
            setWorkThenReadOrResumeSelect(header);
        }
    } catch (Throwable t) {
        if (transportDebug()) dprint(".CANCEL: id/"
                                     + header.getRequestId()
                                     + ": !!ERROR!!: "
                                     + header, t);
        // Mask the exception from thread.;
    } finally {
        if (transportDebug()) dprint(".CANCEL<-: id/"
                                     + header.getRequestId() + ": "
                                     + header.getGIOPVersion() + ": "
                                     + header);
    }
}
 
源代码5 项目: openjdk-jdk8u   文件: CorbaMessageMediatorImpl.java
public void handleInput(CancelRequestMessage header) throws IOException
{
    try {
        try {
            messageHeader = header;
            setInputObject();

            // REVISIT: Move these two to subcontract.
            inputObject.unmarshalHeader();

            if (transportDebug()) dprint(".CANCEL->: id/"
                                         + header.getRequestId() + ": "
                                         + header.getGIOPVersion() + ": "
                                         + header);

            processCancelRequest(header.getRequestId());
            releaseByteBufferToPool();
        } finally {
            setWorkThenReadOrResumeSelect(header);
        }
    } catch (Throwable t) {
        if (transportDebug()) dprint(".CANCEL: id/"
                                     + header.getRequestId()
                                     + ": !!ERROR!!: "
                                     + header, t);
        // Mask the exception from thread.;
    } finally {
        if (transportDebug()) dprint(".CANCEL<-: id/"
                                     + header.getRequestId() + ": "
                                     + header.getGIOPVersion() + ": "
                                     + header);
    }
}
 
public void handleInput(CancelRequestMessage header) throws IOException
{
    try {
        try {
            messageHeader = header;
            setInputObject();

            // REVISIT: Move these two to subcontract.
            inputObject.unmarshalHeader();

            if (transportDebug()) dprint(".CANCEL->: id/"
                                         + header.getRequestId() + ": "
                                         + header.getGIOPVersion() + ": "
                                         + header);

            processCancelRequest(header.getRequestId());
            releaseByteBufferToPool();
        } finally {
            setWorkThenReadOrResumeSelect(header);
        }
    } catch (Throwable t) {
        if (transportDebug()) dprint(".CANCEL: id/"
                                     + header.getRequestId()
                                     + ": !!ERROR!!: "
                                     + header, t);
        // Mask the exception from thread.;
    } finally {
        if (transportDebug()) dprint(".CANCEL<-: id/"
                                     + header.getRequestId() + ": "
                                     + header.getGIOPVersion() + ": "
                                     + header);
    }
}
 
源代码7 项目: openjdk-jdk9   文件: CorbaMessageMediatorImpl.java
public void handleInput(CancelRequestMessage header) throws IOException
{
    try {
        try {
            messageHeader = header;
            setInputObject();

            // REVISIT: Move these two to subcontract.
            inputObject.unmarshalHeader();

            if (transportDebug()) dprint(".CANCEL->: id/"
                                         + header.getRequestId() + ": "
                                         + header.getGIOPVersion() + ": "
                                         + header);

            processCancelRequest(header.getRequestId());
            releaseByteBufferToPool();
        } finally {
            setWorkThenReadOrResumeSelect(header);
        }
    } catch (Throwable t) {
        if (transportDebug()) dprint(".CANCEL: id/"
                                     + header.getRequestId()
                                     + ": !!ERROR!!: "
                                     + header, t);
        // Mask the exception from thread.;
    } finally {
        if (transportDebug()) dprint(".CANCEL<-: id/"
                                     + header.getRequestId() + ": "
                                     + header.getGIOPVersion() + ": "
                                     + header);
    }
}
 
源代码8 项目: hottub   文件: CorbaMessageMediatorImpl.java
public void handleInput(CancelRequestMessage header) throws IOException
{
    try {
        try {
            messageHeader = header;
            setInputObject();

            // REVISIT: Move these two to subcontract.
            inputObject.unmarshalHeader();

            if (transportDebug()) dprint(".CANCEL->: id/"
                                         + header.getRequestId() + ": "
                                         + header.getGIOPVersion() + ": "
                                         + header);

            processCancelRequest(header.getRequestId());
            releaseByteBufferToPool();
        } finally {
            setWorkThenReadOrResumeSelect(header);
        }
    } catch (Throwable t) {
        if (transportDebug()) dprint(".CANCEL: id/"
                                     + header.getRequestId()
                                     + ": !!ERROR!!: "
                                     + header, t);
        // Mask the exception from thread.;
    } finally {
        if (transportDebug()) dprint(".CANCEL<-: id/"
                                     + header.getRequestId() + ": "
                                     + header.getGIOPVersion() + ": "
                                     + header);
    }
}
 
public void handleInput(CancelRequestMessage header) throws IOException
{
    try {
        try {
            messageHeader = header;
            setInputObject();

            // REVISIT: Move these two to subcontract.
            inputObject.unmarshalHeader();

            if (transportDebug()) dprint(".CANCEL->: id/"
                                         + header.getRequestId() + ": "
                                         + header.getGIOPVersion() + ": "
                                         + header);

            processCancelRequest(header.getRequestId());
            releaseByteBufferToPool();
        } finally {
            setWorkThenReadOrResumeSelect(header);
        }
    } catch (Throwable t) {
        if (transportDebug()) dprint(".CANCEL: id/"
                                     + header.getRequestId()
                                     + ": !!ERROR!!: "
                                     + header, t);
        // Mask the exception from thread.;
    } finally {
        if (transportDebug()) dprint(".CANCEL<-: id/"
                                     + header.getRequestId() + ": "
                                     + header.getGIOPVersion() + ": "
                                     + header);
    }
}
 
源代码10 项目: openjdk-8   文件: CorbaMessageMediatorImpl.java
public void handleInput(CancelRequestMessage header) throws IOException
{
    try {
        try {
            messageHeader = header;
            setInputObject();

            // REVISIT: Move these two to subcontract.
            inputObject.unmarshalHeader();

            if (transportDebug()) dprint(".CANCEL->: id/"
                                         + header.getRequestId() + ": "
                                         + header.getGIOPVersion() + ": "
                                         + header);

            processCancelRequest(header.getRequestId());
            releaseByteBufferToPool();
        } finally {
            setWorkThenReadOrResumeSelect(header);
        }
    } catch (Throwable t) {
        if (transportDebug()) dprint(".CANCEL: id/"
                                     + header.getRequestId()
                                     + ": !!ERROR!!: "
                                     + header, t);
        // Mask the exception from thread.;
    } finally {
        if (transportDebug()) dprint(".CANCEL<-: id/"
                                     + header.getRequestId() + ": "
                                     + header.getGIOPVersion() + ": "
                                     + header);
    }
}
 
 类方法
 同包方法