diff options
Diffstat (limited to 'java/src/IceGridGUI/Application/AdapterEditor.java')
| -rw-r--r-- | java/src/IceGridGUI/Application/AdapterEditor.java | 641 |
1 files changed, 641 insertions, 0 deletions
diff --git a/java/src/IceGridGUI/Application/AdapterEditor.java b/java/src/IceGridGUI/Application/AdapterEditor.java new file mode 100644 index 00000000000..f5f9c9fe8fe --- /dev/null +++ b/java/src/IceGridGUI/Application/AdapterEditor.java @@ -0,0 +1,641 @@ +// ********************************************************************** +// +// Copyright (c) 2003-2011 ZeroC, Inc. All rights reserved. +// +// This copy of Ice is licensed to you under the terms described in the +// ICE_LICENSE file included in this distribution. +// +// ********************************************************************** + +package IceGridGUI.Application; + +import java.awt.event.ActionEvent; +import java.awt.event.ItemEvent; +import java.awt.event.ItemListener; + +import javax.swing.AbstractAction; +import javax.swing.Action; +import javax.swing.DefaultComboBoxModel; +import javax.swing.JButton; +import javax.swing.JCheckBox; +import javax.swing.JComboBox; +import javax.swing.JComponent; +import javax.swing.JOptionPane; +import javax.swing.JScrollPane; +import javax.swing.JTextArea; +import javax.swing.JTextField; +import javax.swing.event.DocumentEvent; +import javax.swing.event.DocumentListener; + +import com.jgoodies.forms.builder.DefaultFormBuilder; +import com.jgoodies.forms.layout.CellConstraints; + +import IceGrid.*; +import IceGridGUI.*; + +class AdapterEditor extends CommunicatorChildEditor +{ + AdapterEditor() + { + _objects = new ArrayMapField(this, true, "Identity", "Type", "Property"); + _allocatables = new ArrayMapField(this, true, "Identity", "Type", "Property"); + + // + // Create buttons + // + + // + // _replicaGroupButton + // + Action gotoReplicaGroup = new AbstractAction("", Utils.getIcon("/icons/16x16/goto.png")) + { + public void actionPerformed(ActionEvent e) + { + Object obj = _replicaGroupId.getSelectedItem(); + Adapter adapter = getAdapter(); + + ReplicaGroup rg = null; + if(obj instanceof ReplicaGroup) + { + rg = (ReplicaGroup)obj; + } + else + { + String replicaGroupId = Utils.substitute(obj.toString(), adapter.getResolver()); + + rg = adapter.getRoot().findReplicaGroup(replicaGroupId); + } + + // + // The button is enabled therefore rg should be != null + // + if(rg != null) + { + adapter.getRoot().setSelectedNode(rg); + } + } + }; + gotoReplicaGroup.putValue(Action.SHORT_DESCRIPTION, "Goto the definition of this replica group"); + _replicaGroupButton = new JButton(gotoReplicaGroup); + + Action checkRegisterProcess = new AbstractAction("Register Process") + { + public void actionPerformed(ActionEvent e) + { + updated(); + } + }; + _registerProcess = new JCheckBox(checkRegisterProcess); + _registerProcess.setToolTipText( + "<html>This setting is ignored for servers running Ice<br>" + + "version 3.3 or greater.<br>" + + "During activation, create a Process object<br>" + + "in this adapter and register it with IceGrid<br>" + + "to enable clean shutdown; you should register<br>" + + "exactly one Process object per server.</html>"); + + Action checkServerLifetime = new AbstractAction("Server Lifetime") + { + public void actionPerformed(ActionEvent e) + { + updated(); + } + }; + _serverLifetime = new JCheckBox(checkServerLifetime); + _serverLifetime.setToolTipText( + "<html>Is the adapter lifetime the same as the server<br>" + + "lifetime? The server is considered to be active<br>" + + "only if all the adapters with this attribute set<br>" + + "to true are active.</html>"); + // + // Associate updateListener with various fields + // + _name.getDocument().addDocumentListener( + new DocumentListener() + { + public void changedUpdate(DocumentEvent e) + { + update(); + } + + public void insertUpdate(DocumentEvent e) + { + update(); + } + + public void removeUpdate(DocumentEvent e) + { + update(); + } + + private void update() + { + updated(); + // + // Recompute default id + // + _defaultAdapterId = getAdapter().getDefaultAdapterId(_name.getText().trim()); + refreshId(); + } + }); + + _name.setToolTipText("Identifies this object adapter within an Ice communicator"); + + _endpoints.getDocument().addDocumentListener(_updateListener); + _endpoints.setToolTipText( + "<html>The network interface(s) on which this object adapter receives requests;<br>" + + "for example:<br>" + + " tcp (listen on all local interfaces using a random port)<br>" + + " tcp -h venus.foo.com (listen on just one interface)<br>" + + " tcp -t 10000 (sets a timeout of 10,000 milliseconds)<br>" + + " ssl -h venus.foo.com (accepts SSL connections instead of plain TCP)" + + "</html>"); + + _description.getDocument().addDocumentListener(_updateListener); + _description.setToolTipText("An optional description for this object adapter"); + + JTextField idTextField = (JTextField)_id.getEditor().getEditorComponent(); + idTextField.getDocument().addDocumentListener(_updateListener); + _id.setToolTipText("Identities this object adapter within an IceGrid deployment"); + + JTextField replicaGroupIdTextField = (JTextField)_replicaGroupId.getEditor().getEditorComponent(); + replicaGroupIdTextField.getDocument().addDocumentListener(_updateListener); + _replicaGroupId.setToolTipText("Select a replica group"); + + _priority.getDocument().addDocumentListener(_updateListener); + _priority.setToolTipText("The priority of this adapter; see the Ordered load-balancing " + + "policy in Replica Groups"); + + JTextField publishedEndpointsTextField = (JTextField)_publishedEndpoints.getEditor().getEditorComponent(); + publishedEndpointsTextField.getDocument().addDocumentListener(_updateListener); + _publishedEndpoints.setToolTipText( + "Endpoints registered with the IceGrid Registry during the activation of this adapter."); + } + + // + // From CommunicatorChildEditor + // + + void writeDescriptor() + { + AdapterDescriptor descriptor = (AdapterDescriptor)getAdapter().getDescriptor(); + descriptor.name = _name.getText().trim(); + descriptor.description = _description.getText(); + descriptor.id = getIdAsString(); + descriptor.replicaGroupId = getReplicaGroupIdAsString(); + descriptor.priority = _priority.getText().trim(); + descriptor.registerProcess = _registerProcess.isSelected(); + descriptor.serverLifetime = _serverLifetime.isSelected(); + descriptor.objects = _objectList; + descriptor.allocatables = _allocatableList; + } + + boolean isSimpleUpdate() + { + AdapterDescriptor descriptor = (AdapterDescriptor)getAdapter().getDescriptor(); + + return descriptor.name.equals(_name.getText().trim()); + } + + Communicator.ChildList getChildList() + { + return ((Communicator)_target.getParent()).getAdapters(); + } + + protected void appendProperties(DefaultFormBuilder builder) + { + builder.append("Adapter Name" ); + builder.append(_name, 3); + builder.nextLine(); + + builder.append("Description"); + builder.nextLine(); + builder.append(""); + builder.nextRow(-2); + CellConstraints cc = new CellConstraints(); + JScrollPane scrollPane = new JScrollPane(_description); + builder.add(scrollPane, cc.xywh(builder.getColumn(), builder.getRow(), 3, 3)); + builder.nextRow(2); + builder.nextLine(); + + builder.append("Adapter ID"); + builder.append(_id, 3); + builder.nextLine(); + + builder.append("Replica Group", _replicaGroupId); + builder.append(_replicaGroupButton); + builder.nextLine(); + + builder.append("Priority"); + builder.append(_priority, 3); + builder.nextLine(); + + builder.append("Endpoints" ); + builder.append(_endpoints, 3); + builder.nextLine(); + + builder.append("Published Endpoints"); + builder.append(_publishedEndpoints, 3); + builder.nextLine(); + + builder.append("", _registerProcess); + builder.nextLine(); + builder.append("", _serverLifetime); + builder.nextLine(); + + builder.append("Well-known Objects"); + builder.nextLine(); + builder.append(""); + builder.nextLine(); + builder.append(""); + builder.nextLine(); + builder.append(""); + builder.nextRow(-6); + scrollPane = new JScrollPane(_objects); + builder.add(scrollPane, cc.xywh(builder.getColumn(), builder.getRow(), 3, 7)); + builder.nextRow(6); + builder.nextLine(); + + builder.append("Allocatable Objects"); + builder.nextLine(); + builder.append(""); + builder.nextLine(); + builder.append(""); + builder.nextLine(); + builder.append(""); + builder.nextRow(-6); + scrollPane = new JScrollPane(_allocatables); + builder.add(scrollPane, cc.xywh(builder.getColumn(), builder.getRow(), 3, 7)); + builder.nextRow(6); + builder.nextLine(); + } + + protected void buildPropertiesPanel() + { + super.buildPropertiesPanel(); + _propertiesPanel.setName("Adapter Properties"); + } + + void postUpdate() + { + // + // Change enclosing properties after successful update + // + String name = _name.getText().trim(); + Adapter adapter = getAdapter(); + if(!name.equals(_oldName)) + { + adapter.removeProperty(_oldName + ".Endpoints"); + adapter.removeProperty(_oldName + ".PublishedEndpoints"); + _oldName = name; + } + + adapter.setProperty(name + ".Endpoints", _endpoints.getText().trim()); + + Object published = _publishedEndpoints.getSelectedItem(); + if(published == PUBLISH_ACTUAL) + { + adapter.removeProperty(name + ".PublishedEndpoints"); + } + else + { + adapter.setProperty(name + ".PublishedEndpoints", published.toString().trim()); + } + + // + // Set all objects and allocatables properties + // + java.util.Map<String, String[]> map = _objects.get(); + for(java.util.Map.Entry<String, String[]> p : map.entrySet()) + { + String key = p.getKey(); + String[] value = p.getValue(); + if(!value[1].equals("")) + { + adapter.setProperty(value[1], key); + } + } + + map = _allocatables.get(); + for(java.util.Map.Entry<String, String[]> p : map.entrySet()) + { + String key = p.getKey(); + String[] value = p.getValue(); + if(!value[1].equals("")) + { + adapter.setProperty(value[1], key); + } + } + } + + private void setId(String id) + { + if(id.equals(_defaultAdapterId)) + { + _id.setSelectedItem(DEFAULT_ADAPTER_ID); + } + else + { + _id.setSelectedItem(id); + } + } + + private void refreshId() + { + Object id = _id.getSelectedItem(); + _id.setModel(new DefaultComboBoxModel(new Object[]{DEFAULT_ADAPTER_ID})); + _id.setSelectedItem(id); + } + + private String getIdAsString() + { + Object obj = _id.getSelectedItem(); + return obj.toString().trim(); + } + + private void setReplicaGroupId(String replicaGroupId) + { + if(replicaGroupId.equals("")) + { + _replicaGroupId.setSelectedItem(NOT_REPLICATED); + } + else + { + ReplicaGroups replicaGroups = + getAdapter().getRoot().getReplicaGroups(); + + ReplicaGroup replicaGroup = + (ReplicaGroup)replicaGroups.findChild(replicaGroupId); + + if(replicaGroup != null) + { + _replicaGroupId.setSelectedItem(replicaGroup); + } + else + { + _replicaGroupId.setSelectedItem(replicaGroupId); + } + } + } + + private String getReplicaGroupIdAsString() + { + Object obj = _replicaGroupId.getSelectedItem(); + if(obj == NOT_REPLICATED) + { + return ""; + } + else + { + return obj.toString().trim(); + } + } + + protected boolean validate() + { + // + // First validate stringified identities + // + _objectList = mapToObjectDescriptorSeq(_objects.get()); + + if(_objectList == null) + { + return false; + } + + _allocatableList = mapToObjectDescriptorSeq(_allocatables.get()); + + if(_allocatableList == null) + { + return false; + } + + return check(new String[]{ + "Adapter Name", _name.getText().trim(), + "Adapter ID", getIdAsString(), + "Endpoints", _endpoints.getText().trim() + }); + } + + void show(Adapter adapter) + { + detectUpdates(false); + _target = adapter; + + AdapterDescriptor descriptor = (AdapterDescriptor)adapter.getDescriptor(); + + final Utils.Resolver resolver = adapter.getCoordinator().substitute() ? adapter.getResolver() : null; + + boolean isEditable = resolver == null; + + _oldName = descriptor.name; + + _name.setText(Utils.substitute(descriptor.name, resolver)); + _name.setEditable(isEditable); + + String oaPrefix = descriptor.name + "."; + + _description.setText(Utils.substitute(descriptor.description, resolver)); + _description.setEditable(isEditable); + _description.setOpaque(isEditable); + + // + // Need to make control editable & enabled before changing it + // + _id.setEnabled(true); + _id.setEditable(true); + _defaultAdapterId = adapter.getDefaultAdapterId(); + refreshId(); + if(descriptor.id == null) + { + descriptor.id = _defaultAdapterId; + } + + setId(Utils.substitute(descriptor.id, resolver)); + _id.setEnabled(isEditable); + _id.setEditable(isEditable); + + _replicaGroupId.setEnabled(true); + _replicaGroupId.setEditable(true); + + final ReplicaGroups replicaGroups = adapter.getRoot().getReplicaGroups(); + _replicaGroupId.setModel(replicaGroups.createComboBoxModel(NOT_REPLICATED)); + + _replicaGroupId.addItemListener(new ItemListener() + { + public void itemStateChanged(ItemEvent e) + { + if(e.getStateChange() == ItemEvent.SELECTED) + { + Object item = e.getItem(); + boolean enabled = (item instanceof ReplicaGroup); + if(!enabled && item != NOT_REPLICATED) + { + if(resolver != null) + { + String replicaGroupId = resolver.substitute(item.toString().trim()); + enabled = (replicaGroups.findChild(replicaGroupId) != null); + } + } + _replicaGroupButton.setEnabled(enabled); + } + } + }); + + setReplicaGroupId(Utils.substitute(descriptor.replicaGroupId, resolver)); + + _replicaGroupId.setEnabled(isEditable); + _replicaGroupId.setEditable(isEditable); + + _priority.setText(Utils.substitute(descriptor.priority, resolver)); + _priority.setEditable(isEditable); + + String endpoints = Utils.substitute(adapter.getProperty(oaPrefix + "Endpoints"), resolver); + + if(adapter.isEphemeral() && (endpoints == null || endpoints.equals(""))) + { + _endpoints.setText("default"); + } + else + { + _endpoints.setText(endpoints); + } + _endpoints.setEditable(isEditable); + + _publishedEndpoints.setEnabled(true); + _publishedEndpoints.setEditable(true); + String published = Utils.substitute(adapter.getProperty(oaPrefix + "PublishedEndpoints"), resolver); + if(published == null || published.equals("")) + { + _publishedEndpoints.setSelectedItem(PUBLISH_ACTUAL); + } + else + { + _publishedEndpoints.setSelectedItem(published); + } + _publishedEndpoints.setEnabled(isEditable); + _publishedEndpoints.setEditable(isEditable); + + // + // Objects + // + _objects.set(objectDescriptorSeqToMap(descriptor.objects), resolver, isEditable); + _allocatables.set(objectDescriptorSeqToMap(descriptor.allocatables), resolver, isEditable); + + _registerProcess.setSelected(descriptor.registerProcess); + _registerProcess.setEnabled(isEditable); + + _serverLifetime.setSelected(descriptor.serverLifetime); + _serverLifetime.setEnabled(isEditable); + + _applyButton.setEnabled(adapter.isEphemeral()); + _discardButton.setEnabled(adapter.isEphemeral()); + detectUpdates(true); + + if(adapter.isEphemeral()) + { + updated(); + } + } + + Adapter getAdapter() + { + return (Adapter)_target; + } + + private java.util.Map<String, String[]> objectDescriptorSeqToMap(java.util.List<ObjectDescriptor> objects) + { + java.util.Map<String, String[]> result = new java.util.TreeMap<String, String[]>(); + for(ObjectDescriptor p : objects) + { + String k = Ice.Util.identityToString(p.id); + result.put(k, new String[]{p.type, getAdapter().lookupPropertyValue(k)}); + } + return result; + } + + private java.util.LinkedList<ObjectDescriptor> mapToObjectDescriptorSeq(java.util.Map<String, String[]> map) + { + String badIdentities = ""; + java.util.LinkedList<ObjectDescriptor> result = new java.util.LinkedList<ObjectDescriptor>(); + for(java.util.Map.Entry<String, String[]> p : map.entrySet()) + { + try + { + Ice.Identity id = Ice.Util.stringToIdentity(p.getKey()); + String[] val = p.getValue(); + result.add(new ObjectDescriptor(id, val[0])); + } + catch(Ice.IdentityParseException ex) + { + badIdentities += "- " + p.getKey() + "\n"; + } + } + + if(!badIdentities.equals("")) + { + JOptionPane.showMessageDialog( + _target.getCoordinator().getMainFrame(), + "The following identities could not be parsed properly:\n" + badIdentities, + "Validation failed", + JOptionPane.ERROR_MESSAGE); + + return null; + } + else + { + return result; + } + } + + private String _defaultAdapterId = ""; + + private final Object DEFAULT_ADAPTER_ID = new Object() + { + public String toString() + { + return _defaultAdapterId; + } + }; + + private String _oldName; + + private JTextField _name = new JTextField(20); + private JTextArea _description = new JTextArea(3, 20); + + private JComboBox _id = new JComboBox(new Object[] {DEFAULT_ADAPTER_ID}); + private JComboBox _replicaGroupId = new JComboBox(); + private JButton _replicaGroupButton; + + private JTextField _priority = new JTextField(20); + + private JTextField _endpoints = new JTextField(20); + private JComboBox _publishedEndpoints = new JComboBox(new Object[]{PUBLISH_ACTUAL}); + + private JTextField _currentStatus = new JTextField(20); + private JTextField _currentEndpoints = new JTextField(20); + + private JCheckBox _registerProcess; + private JCheckBox _serverLifetime; + + private ArrayMapField _objects; + private java.util.LinkedList<ObjectDescriptor> _objectList; + private ArrayMapField _allocatables; + private java.util.LinkedList<ObjectDescriptor> _allocatableList; + + static private final Object PUBLISH_ACTUAL = new Object() + { + public String toString() + { + return "Actual endpoints"; + } + }; + + static private final Object NOT_REPLICATED = new Object() + { + public String toString() + { + return "Does not belong to a replica group"; + } + }; +} |