_dli2feintfstub.java

数字图书馆的互操作接口

                              org.omg.CORBA.IntHolder expectedTotal, 
                              org.omg.CORBA.IntHolder stateTimeout) throws  dli2fe.CORBA.DLI2FEException {

    while (true) {
      if (!_is_local()) {
        org.omg.CORBA.portable.OutputStream _output = null;
        org.omg.CORBA.portable.InputStream  _input  = null;
        try {
          _output = this._request("getSessionInfo", true);
          _output.write_long((int)serverSID);
          _input = this._invoke(_output);
          expectedTotal.value = _input.read_long();
          stateTimeout.value = _input.read_long();
                  }
        catch (org.omg.CORBA.portable.ApplicationException _exception) {
          final org.omg.CORBA.portable.InputStream in = _exception.getInputStream();
          java.lang.String _exception_id = _exception.getId();
          if (_exception_id.equals(dli2fe.CORBA.DLI2FEExceptionHelper.id())) {
            throw             dli2fe.CORBA.DLI2FEExceptionHelper.read(_exception.getInputStream());
          }
          throw new org.omg.CORBA.UNKNOWN("Unexpected User Exception: " + _exception_id);
        }
        catch (org.omg.CORBA.portable.RemarshalException _exception) {
          continue;
        }
        finally {
          this._releaseReply(_input);
        }
      } else {
        final org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke("getSessionInfo", _opsClass);
        if (_so == null) {
          continue;
        }
        final dli2fe.CORBA.DLI2FEIntfOperations _self = (dli2fe.CORBA.DLI2FEIntfOperations)_so.servant;
        try {
          _self.getSessionInfo(serverSID, expectedTotal, stateTimeout);
        }
        finally {
          _servant_postinvoke(_so);
        }
      }
      break;
    }
  }

  /**
     * <pre>
   *   void getDocs (in long serverSID, in long reqID,
                in dli2fe.CORBA.XMLObject docPropList, in string docsToGet,
                out dli2fe.CORBA.XMLObject res)
    raises (dli2fe.CORBA.DLI2FEException);
   * </pre>
   */
  public void getDocs (int serverSID, 
                       int reqID, 
                       java.lang.String docPropList, 
                       java.lang.String docsToGet, 
                       org.omg.CORBA.StringHolder res) throws  dli2fe.CORBA.DLI2FEException {

    while (true) {
      if (!_is_local()) {
        org.omg.CORBA.portable.OutputStream _output = null;
        org.omg.CORBA.portable.InputStream  _input  = null;
        try {
          _output = this._request("getDocs", true);
          _output.write_long((int)serverSID);
          _output.write_long((int)reqID);
          _output.write_wstring((java.lang.String)docPropList);
          _output.write_string((java.lang.String)docsToGet);
          _input = this._invoke(_output);
          res.value = _input.read_wstring();
                  }
        catch (org.omg.CORBA.portable.ApplicationException _exception) {
          final org.omg.CORBA.portable.InputStream in = _exception.getInputStream();
          java.lang.String _exception_id = _exception.getId();
          if (_exception_id.equals(dli2fe.CORBA.DLI2FEExceptionHelper.id())) {
            throw             dli2fe.CORBA.DLI2FEExceptionHelper.read(_exception.getInputStream());
          }
          throw new org.omg.CORBA.UNKNOWN("Unexpected User Exception: " + _exception_id);
        }
        catch (org.omg.CORBA.portable.RemarshalException _exception) {
          continue;
        }
        finally {
          this._releaseReply(_input);
        }
      } else {
        final org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke("getDocs", _opsClass);
        if (_so == null) {
          continue;
        }
        final dli2fe.CORBA.DLI2FEIntfOperations _self = (dli2fe.CORBA.DLI2FEIntfOperations)_so.servant;
        try {
          _self.getDocs(serverSID, reqID, docPropList, docsToGet, res);
        }
        finally {
          _servant_postinvoke(_so);
        }
      }
      break;
    }
  }

  /**
     * <pre>
   *   void extendStateTimeout (in long serverSID, in long secondsToExtend)
    raises (dli2fe.CORBA.DLI2FEException);
   * </pre>
   */
  public void extendStateTimeout (int serverSID, 
                                  int secondsToExtend) throws  dli2fe.CORBA.DLI2FEException {

    while (true) {
      if (!_is_local()) {
        org.omg.CORBA.portable.OutputStream _output = null;
        org.omg.CORBA.portable.InputStream  _input  = null;
        try {
          _output = this._request("extendStateTimeout", true);
          _output.write_long((int)serverSID);
          _output.write_long((int)secondsToExtend);
          _input = this._invoke(_output);
                  }
        catch (org.omg.CORBA.portable.ApplicationException _exception) {
          final org.omg.CORBA.portable.InputStream in = _exception.getInputStream();
          java.lang.String _exception_id = _exception.getId();
          if (_exception_id.equals(dli2fe.CORBA.DLI2FEExceptionHelper.id())) {
            throw             dli2fe.CORBA.DLI2FEExceptionHelper.read(_exception.getInputStream());
          }
          throw new org.omg.CORBA.UNKNOWN("Unexpected User Exception: " + _exception_id);
        }
        catch (org.omg.CORBA.portable.RemarshalException _exception) {
          continue;
        }
        finally {
          this._releaseReply(_input);
        }
      } else {
        final org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke("extendStateTimeout", _opsClass);
        if (_so == null) {
          continue;
        }
        final dli2fe.CORBA.DLI2FEIntfOperations _self = (dli2fe.CORBA.DLI2FEIntfOperations)_so.servant;
        try {
          _self.extendStateTimeout(serverSID, secondsToExtend);
        }
        finally {
          _servant_postinvoke(_so);
        }
      }
      break;
    }
  }

  /**
     * <pre>
   *   void cancelRequest (in long serverSID, in long reqID)
    raises (dli2fe.CORBA.DLI2FEException);
   * </pre>
   */
  public void cancelRequest (int serverSID, 
                             int reqID) throws  dli2fe.CORBA.DLI2FEException {

    while (true) {
      if (!_is_local()) {
        org.omg.CORBA.portable.OutputStream _output = null;
        org.omg.CORBA.portable.InputStream  _input  = null;
        try {
          _output = this._request("cancelRequest", true);
          _output.write_long((int)serverSID);
          _output.write_long((int)reqID);
          _input = this._invoke(_output);
                  }
        catch (org.omg.CORBA.portable.ApplicationException _exception) {
          final org.omg.CORBA.portable.InputStream in = _exception.getInputStream();
          java.lang.String _exception_id = _exception.getId();
          if (_exception_id.equals(dli2fe.CORBA.DLI2FEExceptionHelper.id())) {
            throw             dli2fe.CORBA.DLI2FEExceptionHelper.read(_exception.getInputStream());
          }
          throw new org.omg.CORBA.UNKNOWN("Unexpected User Exception: " + _exception_id);
        }
        catch (org.omg.CORBA.portable.RemarshalException _exception) {
          continue;
        }
        finally {
          this._releaseReply(_input);
        }
      } else {
        final org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke("cancelRequest", _opsClass);
        if (_so == null) {
          continue;
        }
        final dli2fe.CORBA.DLI2FEIntfOperations _self = (dli2fe.CORBA.DLI2FEIntfOperations)_so.servant;
        try {
          _self.cancelRequest(serverSID, reqID);
        }
        finally {
          _servant_postinvoke(_so);
        }
      }
      break;
    }
  }

}