public ActivationGroupID registerGroup(ActivationGroupDesc desc) throws ActivationException, RemoteException { Thread.dumpStack(); checkShutdown(); // RegistryImpl.checkAccess() is done in the SameHostOnlyServerRef // during unmarshallCustomData and is not applicable to local access. checkArgs(desc, null); ActivationGroupID id = new ActivationGroupID(systemStub); GroupEntry entry = new GroupEntry(id, desc); // table insertion must take place before log update groupTable.put(id, entry); addLogRecord(new LogRegisterGroup(id, desc)); return id; }
public ActivationGroupID registerGroup(ActivationGroupDesc agdesc) throws ActivationException { waitStartup(); ActivationGroupID agid = new ActivationGroupID(this); ActivationGroupInfo agi = new ActivationGroupInfo(agid, agdesc); if (groupInfoByGroupId.containsKey(agid)) { // rmi.2E=This group is already registered. throw new ActivationException(Messages.getString("rmi.2E")); //$NON-NLS-1$ } groupInfoByGroupId.put(agid, agi); if (!restoreLock) { writeDelta(Delta.PUT, "group", agid, agdesc); //$NON-NLS-1$ // rmi.log.45=Delta was saved: rLog.log(persistenceDebugLevel, Messages.getString("rmi.log.45") //$NON-NLS-1$ + Delta.PUT + "," + "group" + ", " + agid + ", " //$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$ //$NON-NLS-4$ + agdesc); } return agid; }
/** * Main program to start a VM for an activation group. */ public static void main(String args[]) { try { if (System.getSecurityManager() == null) { System.setSecurityManager(new SecurityManager()); } // read group id, descriptor, and incarnation number from stdin MarshalInputStream in = new MarshalInputStream(System.in); ActivationGroupID id = (ActivationGroupID)in.readObject(); ActivationGroupDesc desc = (ActivationGroupDesc)in.readObject(); long incarnation = in.readLong(); // create and set group for the VM ActivationGroup.createGroup(id, desc, incarnation); } catch (Exception e) { System.err.println("Exception in starting ActivationGroupInit:"); e.printStackTrace(); } finally { try { System.in.close(); // note: system out/err shouldn't be closed // since the parent may want to read them. } catch (Exception ex) { // ignore exceptions } } }
public ActivationGroupID registerGroup(ActivationGroupDesc desc) throws ActivationException, RemoteException { checkShutdown(); RegistryImpl.checkAccess("ActivationSystem.registerGroup"); checkArgs(desc, null); ActivationGroupID id = new ActivationGroupID(systemStub); GroupEntry entry = new GroupEntry(id, desc); // table insertion must take place before log update groupTable.put(id, entry); addLogRecord(new LogRegisterGroup(id, desc)); return id; }
public ActivationGroupDesc setActivationGroupDesc(ActivationGroupID id, ActivationGroupDesc desc) throws ActivationException, UnknownGroupException, RemoteException { checkShutdown(); RegistryImpl.checkAccess( "ActivationSystem.setActivationGroupDesc"); checkArgs(desc, null); return getGroupEntry(id).setActivationGroupDesc(id, desc, true); }
public ActivationGroupDesc getActivationGroupDesc(ActivationGroupID id) throws ActivationException, UnknownGroupException, RemoteException { checkShutdown(); RegistryImpl.checkAccess ("ActivationSystem.getActivationGroupDesc"); return getGroupEntry(id).desc; }
synchronized ActivationGroupDesc setActivationGroupDesc( ActivationGroupID id, ActivationGroupDesc desc, boolean addRecord) throws UnknownGroupException, ActivationException { checkRemoved(); ActivationGroupDesc oldDesc = this.desc; this.desc = desc; // state update should occur before log update if (addRecord) { addLogRecord(new LogUpdateGroupDesc(id, desc)); } return oldDesc; }
public ActivationGroupID registerGroup(ActivationGroupDesc desc) throws ActivationException, RemoteException { checkShutdown(); // RegistryImpl.checkAccess() is done in the SameHostOnlyServerRef // during unmarshallCustomData and is not applicable to local access. checkArgs(desc, null); ActivationGroupID id = new ActivationGroupID(systemStub); GroupEntry entry = new GroupEntry(id, desc); // table insertion must take place before log update groupTable.put(id, entry); addLogRecord(new LogRegisterGroup(id, desc)); return id; }
public ActivationGroupDesc setActivationGroupDesc(ActivationGroupID id, ActivationGroupDesc desc) throws ActivationException, UnknownGroupException, RemoteException { checkShutdown(); // RegistryImpl.checkAccess() is done in the SameHostOnlyServerRef // during unmarshallCustomData and is not applicable to local access. checkArgs(desc, null); return getGroupEntry(id).setActivationGroupDesc(id, desc, true); }
public ActivationGroupDesc getActivationGroupDesc(ActivationGroupID id) throws ActivationException, UnknownGroupException, RemoteException { checkShutdown(); // RegistryImpl.checkAccess() is done in the SameHostOnlyServerRef // during unmarshallCustomData and is not applicable to local access. return getGroupEntry(id).desc; }
/** @inheritDoc */ public ActivationGroupDesc setActivationGroupDesc( ActivationGroupID groupId, ActivationGroupDesc groupDesc) throws ActivationException, UnknownGroupException, RemoteException { return super.setActivationGroupDesc(groupId, groupDesc); }
/** * Get the descriptor of the given activation group. * * @return the activation group descriptor, never null. * @throws UnknownGroupException if such group is unknown */ public ActivationGroupDesc getActivationGroupDesc(ActivationGroupID groupId) throws ActivationException, UnknownGroupException, RemoteException { ActivationGroupDesc desc = (ActivationGroupDesc) groupDescs.get(groupId); if (desc == null) throw new UnknownGroupException(groupId == null ? "null" : groupId.toString()); return desc; }
/** * Replace the activation group descriptor, return the previous descriptor. */ public ActivationGroupDesc setActivationGroupDesc( ActivationGroupID groupId, ActivationGroupDesc groupDesc) throws ActivationException, UnknownGroupException, RemoteException { ActivationGroupDesc prev = getActivationGroupDesc(groupId); groupDescs.put(groupId, groupDesc); return prev; }
