import org.globus.wsrf.ResourceException; //导入依赖的package包/类
public Resource find(ResourceKey key) throws ResourceException {
    if (key != null) {
        throw new NoSuchResourceException();
    }

    synchronized (this) {

        // if we do not already have a value, call findSingleton()
        // and then cache the result.
        if (this.singleResource == null) {
            // check to see if the resource is persisted
            this.singleResource = createSingleton();
        }
        if (this.singleResource == null) {
            throw new NoSuchResourceException();
        }

    }
    return this.singleResource;
}
 

import org.globus.wsrf.ResourceException; //导入依赖的package包/类
/**
 * @see org.globus.wsrf.jndi.Initializable#initialize()
 */
public void initialize(Object resourceBean,
                          QName resourceElementQName,
                          Object id) throws ResourceException {
                          
       // Call the super initialize on the ReflectionResource                  
    super.initialize(resourceBean,resourceElementQName,id);
	this.desc = null;

	// this loads the metadata from XML files if this is the main service
	populateResourceProperties();

	// register the service to the index service
	refreshRegistration(true);
	
}
 

import org.globus.wsrf.ResourceException; //导入依赖的package包/类
/**
 * This is the callback to destroy this resource. If anything needs to be cleaned up
 * when this resource is destroyed it should be done here.
 */
 	
public void remove() throws ResourceException {
	

	if(new File(this.getTempDir()).exists()){
		boolean success = deleteDir(new File(this.getTempDir()));
		if(!success){
			LOG.error("ERROR: Failed to delete the Temp directory created by the resource.");
		}
		else{
			LOG.info("Deleted the Temp directory created by the resource.");
			super.remove();
		}
	}
}
 

import org.globus.wsrf.ResourceException; //导入依赖的package包/类
/**
 * @see org.globus.wsrf.jndi.Initializable#initialize()
 */
public void initialize(Object resourceBean,
                          QName resourceElementQName,
                          Object id) throws ResourceException {
                          
       // Call the super initialize on the ReflectionResource                  
    super.initialize(resourceBean,resourceElementQName,id);

	// this loads the metadata from XML files if this is the main service
	populateResourceProperties();

	// register the service to the index service
	refreshRegistration(true);
	
}
 

import org.globus.wsrf.ResourceException; //导入依赖的package包/类
public synchronized void setTargetServiceConnectionStatusException(String serviceURL, Exception ex) throws InternalErrorFault, ResourceException {
    TargetServiceStatus status = getTargetServiceStatus(serviceURL);
    status.setConnectionStatus(ServiceConnectionStatus.Exception);
    FaultHelper helper = new FaultHelper(new FederatedQueryProcessingFault());
    helper.addDescription("Error parsing data service URL");
    helper.addDescription(ex.getMessage());
    helper.addFaultCause(ex);
    FederatedQueryProcessingFault fqpFault = (FederatedQueryProcessingFault) helper.getFault();
    status.setBaseFault(fqpFault);
    storeTargetServiceStatus(status);
}
 

import org.globus.wsrf.ResourceException; //导入依赖的package包/类
private void setStatusMessage(String message) {
    LOG.debug(message);
    this.statusMessage = message;
    try {
        resourcePropertyManager.setExecutionDetailMessage(message);
    } catch (ResourceException ex) {
        LOG.warn("Error setting execution detail message on resource property: "
            + ex.getMessage(), ex);
    }
}
 

import org.globus.wsrf.ResourceException; //导入依赖的package包/类
public void store() throws ResourceException {
   if(!beingLoaded){
     //store the resource properties
     resourcePropertyPersistenceHelper.store(this);
     
     FileOutputStream fos = null;
     File tmpFile = null;

     try {
         tmpFile = File.createTempFile(
             this.getClass().getName(), ".tmp",
             resourcePersistenceHelper.getStorageDirectory());
         fos = new FileOutputStream(tmpFile);
         ObjectOutputStream oos = new ObjectOutputStream(fos);
         SubscriptionPersistenceUtils.storeSubscriptionListeners(
             this.getTopicList(), oos);
storeResource(oos);
     } catch (Exception e) {
         if (tmpFile != null) {
             tmpFile.delete();
         }
         throw new ResourceException("Failed to store resource", e);
     } finally {
         if (fos != null) {
             try { fos.close();} catch (Exception ee) {}
         }
     }

     File file = resourcePersistenceHelper.getKeyAsFile(this.getClass(), getID());
     if (file.exists()) {
         file.delete();
     }
     if (!tmpFile.renameTo(file)) {
         tmpFile.delete();
         throw new ResourceException("Failed to store resource");
     }
     }
 }
 

import org.globus.wsrf.ResourceException; //导入依赖的package包/类
public void load(ResourceKey resourceKey) throws ResourceException, NoSuchResourceException, InvalidResourceKeyException {
beingLoaded = true;
    //first we will recover the resource properties and initialize the resource
 StockPortfolioManagerResourceProperties props = (StockPortfolioManagerResourceProperties)resourcePropertyPersistenceHelper.load(StockPortfolioManagerResourceProperties.class, resourceKey.getValue());
    this.initialize(props, StockPortfolioManagerConstants.RESOURCE_PROPERTY_SET, resourceKey.getValue());
    
     //next we will recover the resource itself
     File file = resourcePersistenceHelper.getKeyAsFile(this.getClass(), resourceKey.getValue());
     if (!file.exists()) {
         beingLoaded = false;
         throw new NoSuchResourceException();
     }
     FileInputStream fis = null;
     int value = 0;
     try {
         fis = new FileInputStream(file);
         ObjectInputStream ois = new ObjectInputStream(fis);
         SubscriptionPersistenceUtils.loadSubscriptionListeners(
             this.getTopicList(), ois);
loadResource(resourceKey,ois);
     } catch (Exception e) {
         beingLoaded = false;
         throw new ResourceException("Failed to load resource", e);
     } finally {
         if (fis != null) {
             try { fis.close(); } catch (Exception ee) {}
         }
     } 
    
    beingLoaded = false;
 }
 

import org.globus.wsrf.ResourceException; //导入依赖的package包/类
public void load(ResourceKey resourceKey) throws ResourceException, NoSuchResourceException, InvalidResourceKeyException {
beingLoaded = true;
    //first we will recover the resource properties and initialize the resource
 FederatedQueryResultsRetrievalResourceProperties props = (FederatedQueryResultsRetrievalResourceProperties)resourcePropertyPersistenceHelper.load(FederatedQueryResultsRetrievalResourceProperties.class, resourceKey.getValue());
    this.initialize(props, FederatedQueryResultsRetrievalConstants.RESOURCE_PROPERTY_SET, resourceKey.getValue());
    
     //next we will recover the resource itself
     File file = resourcePersistenceHelper.getKeyAsFile(this.getClass(), resourceKey.getValue());
     if (!file.exists()) {
         beingLoaded = false;
         throw new NoSuchResourceException();
     }
     FileInputStream fis = null;
     int value = 0;
     try {
         fis = new FileInputStream(file);
         ObjectInputStream ois = new ObjectInputStream(fis);
         SubscriptionPersistenceUtils.loadSubscriptionListeners(
             this.getTopicList(), ois);
loadResource(resourceKey,ois);
     } catch (Exception e) {
         beingLoaded = false;
         throw new ResourceException("Failed to load resource", e);
     } finally {
         if (fis != null) {
             try { fis.close(); } catch (Exception ee) {}
         }
     } 
    
    beingLoaded = false;
 }
 

import org.globus.wsrf.ResourceException; //导入依赖的package包/类
private FederatedQueryExecutionStatus getExecutionStatus() throws ResourceException {
    FederatedQueryExecutionStatus status = managedResource.getFederatedQueryExecutionStatus();
    if (status == null) {
        status = new FederatedQueryExecutionStatus();
        storeExecutionStatus(status);
    }
    return managedResource.getFederatedQueryExecutionStatus();
}
 

import org.globus.wsrf.ResourceException; //导入依赖的package包/类
private TavernaWorkflowServiceImplResource getWorkflowResource() throws ResourceException, ResourceContextException {
	ResourceContext resourceContext = ResourceContext.getResourceContext();
	ResourceHome resourceHome = resourceContext.getResourceHome();
	ResourceKey resourceKey = resourceContext.getResourceKey();
	TavernaWorkflowServiceImplResource resource = (TavernaWorkflowServiceImplResource) resourceHome.find(resourceKey);
	return resource;
}
 

import org.globus.wsrf.ResourceException; //导入依赖的package包/类
public void load(ResourceKey resourceKey) throws ResourceException, NoSuchResourceException, InvalidResourceKeyException {
beingLoaded = true;
    //first we will recover the resource properties and initialize the resource
 TavernaWorkflowServiceImplResourceProperties props = (TavernaWorkflowServiceImplResourceProperties)resourcePropertyPersistenceHelper.load(TavernaWorkflowServiceImplResourceProperties.class, resourceKey.getValue());
    this.initialize(props, TavernaWorkflowServiceImplConstants.RESOURCE_PROPERTY_SET, resourceKey.getValue());
    
     //next we will recover the resource itself
     File file = resourcePersistenceHelper.getKeyAsFile(this.getClass(), resourceKey.getValue());
     if (!file.exists()) {
         beingLoaded = false;
         throw new NoSuchResourceException();
     }
     FileInputStream fis = null;
     int value = 0;
     try {
         fis = new FileInputStream(file);
         ObjectInputStream ois = new ObjectInputStream(fis);
         SubscriptionPersistenceUtils.loadSubscriptionListeners(
             this.getTopicList(), ois);
loadResource(resourceKey,ois);
     } catch (Exception e) {
         beingLoaded = false;
         throw new ResourceException("Failed to load resource", e);
     } finally {
         if (fis != null) {
             try { fis.close(); } catch (Exception ee) {}
         }
     } 
    
    beingLoaded = false;
 }
 

import org.globus.wsrf.ResourceException; //导入依赖的package包/类
public void storeResource(ObjectOutputStream oos) throws ResourceException {
 	if(this.getWorkflowStatus().equals(WorkflowStatusType.Done)){
 		try {
	oos.writeObject(this.getOutputDoc());
	LOG.info("storeResource was called..");
} catch (IOException e) {
	// TODO Auto-generated catch block
	e.printStackTrace();
}
 	}

 }
 

import org.globus.wsrf.ResourceException; //导入依赖的package包/类
@Override
public void remove() throws ResourceException {
	super.remove();
	try {
		removeDataFile();
	} catch (Exception e) {
		e.printStackTrace();
	}
}
 

import org.globus.wsrf.ResourceException; //导入依赖的package包/类
public void setStatus(org.cagrid.transfer.descriptor.Status status)
		throws ResourceException {
	DataStorageDescriptor desc = getDataStorageDescriptor();
	desc.setStatus(status);
	setDataStorageDescriptor(desc);

	if (status.equals(Status.Staged)) {
		DataStagedCallback callback = getDataStagedCallback();
		if (callback == null) {
			// try to refresh
			try {
				hookupCallBack();
			} catch (Exception e) {
				e.printStackTrace();
			}
		}

		final DataStagedCallback fcallback = callback;
		Thread th = new Thread(new Runnable() {
			public void run() {

				if (fcallback != null) {
					fcallback
							.dataStaged(TransferServiceContextResource.this);
				}
			}
		});
		th.start();
	}
}
 

import org.globus.wsrf.ResourceException; //导入依赖的package包/类
public void load(ResourceKey resourceKey) throws ResourceException, NoSuchResourceException, InvalidResourceKeyException {
beingLoaded = true;
 this.setResourceKey(resourceKey);
    //first we will recover the resource properties and initialize the resource
 TransferServiceContextResourceProperties props = (TransferServiceContextResourceProperties)resourcePropertyPersistenceHelper.load(TransferServiceContextResourceProperties.class, resourceKey.getValue());
    this.initialize(props, TransferServiceContextConstants.RESOURCE_PROPERTY_SET, resourceKey.getValue());
    
     //next we will recover the resource itself
     File file = resourcePersistenceHelper.getKeyAsFile(this.getClass(), resourceKey.getValue());
     if (!file.exists()) {
         beingLoaded = false;
         throw new NoSuchResourceException();
     }
     FileInputStream fis = null;
     int value = 0;
     try {
         fis = new FileInputStream(file);
         ObjectInputStream ois = new ObjectInputStream(fis);
         SubscriptionPersistenceUtils.loadSubscriptionListeners(
             this.getTopicList(), ois);
loadResource(resourceKey,ois);
     } catch (Exception e) {
         beingLoaded = false;
         throw new ResourceException("Failed to load resource", e);
     } finally {
         if (fis != null) {
             try { fis.close(); } catch (Exception ee) {}
         }
     } 
    
    beingLoaded = false;
 }
 

import org.globus.wsrf.ResourceException; //导入依赖的package包/类
public void remove(ReflectionResource resource) throws ResourceException {
    Class resourceBean = resource.getResourceBean().getClass();
    if (!this.beanClass.isAssignableFrom(resourceBean)) {
        Object[] args = new Object[]{this.beanClass, resourceBean};
        throw new IllegalArgumentException("expectedType");
    }
    remove(resource.getClass(), resource.getID());
}
 

import org.globus.wsrf.ResourceException; //导入依赖的package包/类
/**
 * Additional implementation cancels the query execution task if it hasn't
 * already begun executing
 */
public void remove() throws ResourceException {
    LOG.debug("Removing resource");
    super.remove();
    if (queryFuture != null) {
        LOG.debug("Canceling query execution work");
        queryFuture.cancel(true);
    }
}
 

import org.globus.wsrf.ResourceException; //导入依赖的package包/类
public void setDomainModel(gov.nih.nci.cagrid.metadata.dataservice.DomainModel domainModel ) throws ResourceException {
       ResourceProperty prop = getResourcePropertySet().get(DmrConstants.DOMAINMODEL);
	prop.set(0, domainModel);
}
 

import org.globus.wsrf.ResourceException; //导入依赖的package包/类
public void setTrustedIdentityProviders(org.cagrid.gaards.dorian.federation.TrustedIdentityProviders trustedIdentityProviders ) throws ResourceException {
       ResourceProperty prop = getResourcePropertySet().get(DorianConstants.TRUSTEDIDENTITYPROVIDERS);
	prop.set(0, trustedIdentityProviders);
}