import net.jini.core.lookup.ServiceID; //导入依赖的package包/类
public IJSpace getSpaceDirect(ServiceID serviceID) throws RemoteException {
    if (puDetails == null) {
        throw new RemoteException("processing unit shutdown");
    }
    for (Object serviceDetails : puDetails.getDetails()) {
        if (isSpaceServiceDetails(serviceDetails)) {
            try {
                if (containsEmbeddedSpace(serviceDetails)) {
                    Method spaceServiceId = serviceDetails.getClass().getMethod("getServiceID");
                    if (spaceServiceId.invoke(serviceDetails).equals(serviceID)) {
                        Field spaceDetails = serviceDetails.getClass().getDeclaredField("directSpace");
                        spaceDetails.setAccessible(true);
                        return (IJSpace) spaceDetails.get(serviceDetails);
                    }
                }
            } catch (Exception e) {
                throw new RemoteException("Failed to get space", e);
            }
        }
    }
    return null;
}
 

import net.jini.core.lookup.ServiceID; //导入依赖的package包/类
public RuntimeHolder getSpaceRuntimeHolder(ServiceID serviceID) throws RemoteException {
    if (puDetails == null) {
        throw new RemoteException("processing unit shutdown");
    }
    for (Object serviceDetails : puDetails.getDetails()) {
        if (isSpaceServiceDetails(serviceDetails)) {
            try {
                if (containsEmbeddedSpace(serviceDetails)) {
                    Method spaceServiceId = serviceDetails.getClass().getMethod("getServiceID");
                    if (spaceServiceId.invoke(serviceDetails).equals(serviceID)) {
                        Field spaceDetails = serviceDetails.getClass().getDeclaredField("directSpaceAdmin");
                        spaceDetails.setAccessible(true);
                        IInternalRemoteJSpaceAdmin spaceAdmin = (IInternalRemoteJSpaceAdmin) spaceDetails.get(serviceDetails);
                        return spaceAdmin.getRuntimeHolder();
                    }
                }
            } catch (Exception e) {
                throw new RemoteException("Failed to get runtime holder", e);
            }
        }
    }
    return null;
}
 

import net.jini.core.lookup.ServiceID; //导入依赖的package包/类
public StatisticsHolder getSpaceStatisticsHolder(ServiceID serviceID) throws RemoteException {
    if (puDetails == null) {
        throw new RemoteException("processing unit shutdown");
    }
    for (Object serviceDetails : puDetails.getDetails()) {
        if (isSpaceServiceDetails(serviceDetails)) {
            try {
                if (containsEmbeddedSpace(serviceDetails)) {
                    Method spaceServiceId = serviceDetails.getClass().getMethod("getServiceID");
                    if (spaceServiceId.invoke(serviceDetails).equals(serviceID)) {
                        Field spaceDetails = serviceDetails.getClass().getDeclaredField("directSpaceAdmin");
                        spaceDetails.setAccessible(true);
                        IInternalRemoteJSpaceAdmin spaceAdmin = (IInternalRemoteJSpaceAdmin) spaceDetails.get(serviceDetails);
                        return ((StatisticsAdmin) spaceAdmin).getHolder();
                    }
                }
            } catch (Exception e) {
                throw new RemoteException("Failed to get statistics holder", e);
            }
        }
    }
    return null;
}
 

import net.jini.core.lookup.ServiceID; //导入依赖的package包/类
public ServiceItem getServiceItem(ServiceID serviceID) {
	Collection<List<ServiceItem>> c = interfaceListMap.values();
	if (c == null)
		return null;
	List<ServiceItem> sItems;
	ServiceItem sItem;
	for (Iterator<List<ServiceItem>> it = c.iterator(); it.hasNext();) {
		sItems = it.next();
		for (int i = 0; i < sItems.size(); i++) {
			if (serviceID.equals((sItems.get(i)).serviceID)) {
				sItem = sItems.remove(i);
				sItems.add(sItem);
				return sItem;
			}
		}
	}
	return null;
}
 

import net.jini.core.lookup.ServiceID; //导入依赖的package包/类
private void removeFromTree(ServiceID sid) {
	int nServices = _root.getChildCount();
	// System.out.println("removeFromTree() checking "+nServices+"
	// services");

	for (int i = 0; i < nServices; i++) {
		// System.out.println("Checking "+i);

		DefaultMutableTreeNode service = (DefaultMutableTreeNode) _root
				.getChildAt(i);
		ServiceNode sNode = (ServiceNode) service.getUserObject();
		// System.out.println("Checking "+sNode);
		if (sNode.sameServiceID(sid)) {
			DefaultTreeModel model = (DefaultTreeModel) _tree.getModel();
			model.removeNodeFromParent(service);
			return;
		}

	}
}
 

import net.jini.core.lookup.ServiceID; //导入依赖的package包/类
MethodAnalytics create(ServiceID serviceID, String hostName) {
    String activeOps = "";
    synchronized (stopWatch) {
        if (stopWatch.size() > 0) {
            StringBuilder b = new StringBuilder();
            for (Integer i : stopWatch.keySet()) {
                if (b.length() > 0)
                    b.append(", ");
                b.append(Integer.toString(i));
            }
            activeOps = b.toString();
        }
    }
    return new MethodAnalytics(activeOps,
                               averageExecTime,
                               completed.get(),
                               failed.get(),
                               hostName,
                               methodName,
                               numActiveOperations.get(),
                               serviceID,
                               totalCallTime.get(),
                               totalOperationCalls.get());
}
 

import net.jini.core.lookup.ServiceID; //导入依赖的package包/类
public void unProvision(ServiceID serviceId) throws ProvisioningException {
    ServiceItem[] serviceItems = Accessor.get().getServiceItems(new ServiceTemplate(serviceId, null, null), null);
    OperationalStringEntry opStringEntry = null;
    if(serviceItems.length>0)
        opStringEntry = AttributesUtil.getFirstByType(serviceItems[0].attributeSets, OperationalStringEntry.class);
    if (opStringEntry == null)
        throw new IllegalArgumentException("Service was not provisioned");
    ServiceItem[] provisionMonitors = Accessor.get().getServiceItems(new ServiceTemplate(null, new Class[]{ProvisionMonitor.class}, null),
                                                                     null);
    for (ServiceItem monitor : provisionMonitors) {
        try {
            ((DeployAdmin) ((ProvisionMonitor) monitor.service).getAdmin()).undeploy(opStringEntry.name);
            return;
        } catch (OperationalStringException ignored) {
            //deploy admin does not know our service, try another one
        } catch (RemoteException e) {
        }
    }
    throw new ProvisioningException("No DeployAdmin is able to undeploy service " + serviceId);
}
 

import net.jini.core.lookup.ServiceID; //导入依赖的package包/类
public MethodAnalytics(String activeOperations,
                       double averageExecTime,
                       int completed,
                       int failed,
                       String hostName,
                       String methodName,
                       int numActiveOperations,
                       ServiceID serviceID,
                       long totalCallTime,
                       int totalOperationCalls) {
    this.activeOperations = activeOperations;
    this.averageExecTime = averageExecTime;
    this.completed = completed;
    this.failed = failed;
    this.hostName = hostName;
    this.methodName = methodName;
    this.numActiveOperations = numActiveOperations;
    this.serviceID = serviceID;
    this.totalCallTime = totalCallTime;
    this.totalOperationCalls = totalOperationCalls;
}
 

import net.jini.core.lookup.ServiceID; //导入依赖的package包/类
private void processEventsFromGsm(List<Events> eventsFromGSMs) {
    //go over events after orphaned processing unit instances have been added
    for (Events events : eventsFromGSMs) {
        for (Event event : events.getEvents()) {
            if (event instanceof ServiceFaultDetectionEvent) {
                ServiceFaultDetectionEvent serviceFaultDetectionEvent = (ServiceFaultDetectionEvent)event;
                ServiceID serviceID = serviceFaultDetectionEvent.getServiceID();
                String serviceIdAsString = serviceID.toString();
                ProcessingUnitInstance puInstanceByUID = processingUnitInstances.getInstanceByUID(serviceIdAsString);
                if (puInstanceByUID != null) {
                    //will raise a member alive indicator event (no need to flush)
                    ((InternalProcessingUnitInstance)puInstanceByUID).setMemberAliveIndicatorStatus(serviceFaultDetectionEvent);
                } else {
                    assertStateChangesPermitted();
                    synchronized (DefaultAdmin.this) {
                        Iterator<ProcessingUnitInstance> iterator = removedProcessingUnitInstances.iterator();
                        while (iterator.hasNext()) {
                            ProcessingUnitInstance removedInstance = iterator.next();
                            if (removedInstance.getUid().equals(serviceIdAsString)) {
                                ((InternalProcessingUnitInstance)removedInstance).setMemberAliveIndicatorStatus(serviceFaultDetectionEvent);
                                if (serviceFaultDetectionEvent.isDetectedFailure()) {
                                    iterator.remove();
                                }
                            }
                        }
                    }
                }
            } else if (event instanceof ProvisionLifeCycleEvent) {
                ProvisionLifeCycleEvent provEvent = (ProvisionLifeCycleEvent)event;
                String processingUnitName = provEvent.getProcessingUnitName();
                ProcessingUnit processingUnit = processingUnits.getProcessingUnit(processingUnitName);
                if (processingUnit != null) {
                    ((InternalProcessingUnit)processingUnit).processProvisionEvent(provEvent);
                }
            }
        }
    }
}
 

import net.jini.core.lookup.ServiceID; //导入依赖的package包/类
public DefaultGridServiceManager(ServiceID serviceID, GSM gsm, InternalAdmin admin, int agentId, String agentUid, JVMDetails jvmDetails)
        throws RemoteException {
    super(admin, agentId, agentUid, jvmDetails);
    this.serviceID = serviceID;
    this.gsm = gsm;
    this.gsmAdmin = (ProvisionMonitorAdmin) gsm.getAdmin();
}
 

import net.jini.core.lookup.ServiceID; //导入依赖的package包/类
public DefaultElasticServiceManager(ServiceID serviceID, ESM esm, InternalAdmin admin, int agentId, String agentUid, JVMDetails jvmDetails)
throws RemoteException {
    super(admin, agentId, agentUid, jvmDetails);
    this.serviceID = serviceID;
    this.esm = esm;
    this.esmScaleIsInProgressPerProcessingUnit = new ConcurrentHashMap<String, Boolean>();
}
 

import net.jini.core.lookup.ServiceID; //导入依赖的package包/类
public ServiceID getServiceID() {
    return this.serviceID;
}
 

import net.jini.core.lookup.ServiceID; //导入依赖的package包/类
public DefaultGridServiceAgent(ServiceID serviceID, GSA gsa, InternalAdmin admin, AgentProcessesDetails processesDetails, JVMDetails jvmDetails) {
    super(admin, jvmDetails);
    this.serviceID = serviceID;
    this.gsa = gsa;
    this.processesDetails = processesDetails;
    this.gridServiceContainers = new DefaultGridServiceContainers(admin);
    this.gridServiceManagers = new DefaultGridServiceManagers(admin);
    this.lookupServices = new DefaultLookupServices(admin);
    this.elasticServiceManagers = new DefaultElasticServiceManagers(admin);
}
 

import net.jini.core.lookup.ServiceID; //导入依赖的package包/类
@Override
public DirectSpaceProxyFactory getSpaceDirectFactory(ServiceID serviceID) throws RemoteException {
    final IJSpace space = getSpaceDirect(serviceID);
    if (space == null)
        return null;
    DirectSpaceProxyFactoryImpl result = (DirectSpaceProxyFactoryImpl) space.getDirectProxy().getFactory();
    result = result.createCopyWithoutClusterPolicyIfNeeded();
    return result;
}
 

import net.jini.core.lookup.ServiceID; //导入依赖的package包/类
public PUDetails(ServiceID gscServiceID, ClusterInfo clusterInfo, BeanLevelProperties beanLevelProperties, Object[] details) {
    this.gscServiceID = gscServiceID;
    this.clusterInfo = clusterInfo;
    this.beanLevelProperties = beanLevelProperties;
    this.details = details;
    if (details == null) {
        this.details = new ServiceDetails[0];
    }
}
 

import net.jini.core.lookup.ServiceID; //导入依赖的package包/类
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException {
    gscServiceID = (ServiceID) in.readObject();
    clusterInfo = (ClusterInfo) in.readObject();
    int size = in.readInt();
    this.details = new ServiceDetails[size];
    for (int i = 0; i < size; i++) {
        details[i] = in.readObject();
    }
}
 

import net.jini.core.lookup.ServiceID; //导入依赖的package包/类
public void discarded(DiscoveryEvent e) {
    final ServiceRegistrar[] regs = e.getRegistrars();
    SwingUtilities.invokeLater(wrap(new Runnable() {
        public void run() {
            for (int i = 0; i < regs.length; i++) {
                ServiceID id = regs[i].getServiceID();
                if (lookup != null
                        && id.equals(lookup.getServiceID())) {
                    lookup = null;
                    seqNo = Long.MAX_VALUE;
                }
                for (int j = 0;
                        j < registrars.getMenuComponentCount();
                        j++) {
                    JMenuItem item =
                            (JMenuItem) registrars.getMenuComponent(j);
                    if (item instanceof RegistrarMenuItem
                            && id.equals(((RegistrarMenuItem) item).id)) {
                        item.setSelected(false);
                        registrars.remove(item);
                        if (registrars.getMenuComponentCount() == 0) {
                            addNone(registrars);
                        }
                        break;
                    }
                }
            }
            if (lookup == null) {
                resetTmpl();
            }
        }
    }));
}
 

import net.jini.core.lookup.ServiceID; //导入依赖的package包/类
/**
 * Returns a SORCER service provider identified by its service ID.
 * 
 * @param sid
 *            - provider's ID
 * @return a SORCER service provider
 * @throws RemoteException
 */
@Override
public Provider lookup(ServiceID sid) throws RemoteException {
	if (sid == null)
		return null;
	ServiceItem sItem = cinfo.getServiceItem(sid);
	return (sItem != null && sItem.service instanceof Provider) ? (Provider) sItem.service
			: null;
}
 

import net.jini.core.lookup.ServiceID; //导入依赖的package包/类
public void serviceDiscarded(ServiceID serviceID) {
	synchronized (_tabs) {
		int nt = _tabs.size();
		for (int i = 0; i < nt; i++) {
			((SSBrowserTab) _tabs.get(i)).serviceDiscarded(serviceID);
		}
	}
}
 

import net.jini.core.lookup.ServiceID; //导入依赖的package包/类
public void serviceModified(ServiceID serviceID) {
	synchronized (_tabs) {
		int nt = _tabs.size();
		for (int i = 0; i < nt; i++) {
			((SSBrowserTab) _tabs.get(i)).serviceModified(serviceID);
		}
	}
}