JGroupManager.java
| Index Score | ||
|---|---|---|
 |
 |
net.sf.ehcache.distribution.jgroups |
 |
 |
ehcache |
View: Reasons, Metrics, Source Code
These are the metrics that contribute to the Enerjy Score for this file, ranked by impact. So the metrics listed at the top influence the score to a greater extent that the metrics listed at the bottom.
| Metric | Description | |
|---|---|---|
/**
* Copyright 2003-2008 Luck Consulting Pty Ltd
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package net.sf.ehcache.distribution.jgroups;
import net.sf.ehcache.Cache;
import net.sf.ehcache.CacheException;
import net.sf.ehcache.CacheManager;
import net.sf.ehcache.Ehcache;
import net.sf.ehcache.Element;
import net.sf.ehcache.Status;
import net.sf.ehcache.distribution.CacheManagerPeerProvider;
import net.sf.ehcache.distribution.CachePeer;
import org.jgroups.Address;
import org.jgroups.Channel;
import org.jgroups.blocks.NotificationBus;
import java.io.Serializable;
import java.rmi.RemoteException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.logging.Logger;
import java.util.logging.Level;
/**
* The main Jgroup class for replication via JGroup. Starts up the Jgroup
* communication bus and listen for message in the bus. Because of Ehcache
* design we have to register this as a CachePeer. In reality this class listen
* for change on the bus and tells the cachemanager to update.
*
* @author Pierre Monestie (pmonestie__REMOVE__THIS__@gmail.com)
* @author <a href="mailto:gluck@gregluck.com">Greg Luck</a>
* @version $Id: JGroupManager.java 744 2008-08-16 20:10:49Z gregluck $
*/
public class JGroupManager implements NotificationBus.Consumer, CachePeer, CacheManagerPeerProvider {
private static String hostname = "localhost";
private static final Logger LOG = Logger.getLogger(JGroupManager.class.getName());
private static HashMap properties = new HashMap();
private NotificationBus bus;
private CacheManager cacheManager;
/**
* Construc a new JGroupManager with a specific Jgroups connection String
*
* @param m
* the cache manager
* @param connect
* the connection String
*/
public JGroupManager(CacheManager m, String connect) {
try {
this.cacheManager = m;
this.bus = new NotificationBus("EH_CACHE", connect);
// manager.bus = new NotificationBus(busName,
// DEFAULT_CHANNEL_PROPERTIES_POST);
this.bus.start();
this.bus.getChannel().setOpt(Channel.LOCAL, Boolean.FALSE);
this.bus.setConsumer(this);
LOG.info("GMS started. address is " + this.bus.getLocalAddress());
} catch (Exception e) {
LOG.log(Level.SEVERE, e.getMessage(), e);
}
}
/**
* {@inheritDoc}
*/
public Serializable getCache() {
return null;
}
private void handleJGroupNotification(JGroupSerializable e) {
// LOG.fine("got notified:"+e.getSerializableKey());
Cache c = cacheManager.getCache(e.getCacheName());
if (c != null) {
if (e.getEvent() == e.REMOVE && c.getQuiet(e.getKey()) != null) {
c.remove(e.getKey(), true);
} else if (e.getEvent() == e.PUT) {
c.put(new Element(e.getKey(), e.getValue()), true);
} else if (e.getEvent() == e.REMOVE_ALL) {
// c.removeAll(true);
LOG.fine("remove all");
c.removeAll(true);
}
}
}
/**
* Handles notification: Looks at type of message and unwrap if the argument
* is a list
*/
public void handleNotification(Serializable arg0) {
if (arg0 instanceof JGroupSerializable) {
handleJGroupNotification((JGroupSerializable) arg0);
} else if (arg0 instanceof List) {
List l = (List) arg0;
for (int i = 0; i < l.size(); i++) {
Object obj = l.get(i);
if (obj instanceof JGroupSerializable) {
handleJGroupNotification((JGroupSerializable) obj);
}
}
}
}
/**
* {@inheritDoc}
*/
public void memberJoined(Address arg0) {
LOG.finest("joined:" + arg0);
}
/**
* {@inheritDoc}
*/
public void memberLeft(Address arg0) {
LOG.finest("left:" + arg0);
}
/**
* {@inheritDoc}
*/
public List getElements(List keys) throws RemoteException {
return null;
}
/**
* {@inheritDoc}
*/
public String getGuid() throws RemoteException {
return null;
}
/**
* {@inheritDoc}
*/
public List getKeys() throws RemoteException {
return null;
}
/**
* {@inheritDoc}
*/
public String getName() throws RemoteException {
return null;
}
/**
* {@inheritDoc}
*/
public Element getQuiet(Serializable key) throws RemoteException {
return null;
}
/**
* {@inheritDoc}
*/
public String getUrl() throws RemoteException {
return null;
}
/**
* {@inheritDoc}
*/
public String getUrlBase() throws RemoteException {
return null;
}
/**
* {@inheritDoc}
*/
public void put(Element element) throws IllegalArgumentException, IllegalStateException, RemoteException {
}
/**
* {@inheritDoc}
*/
public boolean remove(Serializable key) throws IllegalStateException, RemoteException {
return false;
}
/**
* {@inheritDoc}
*/
public void removeAll() throws RemoteException, IllegalStateException {
}
private JGroupSerializable wrapMessage(JGroupEventMessage msg) {
Object value = (msg.getElement() == null ? null : msg.getElement().getValue());
return new JGroupSerializable(msg.getEvent(), msg.getSerializableKey(), value, msg.getCacheName());
}
/**
* {@inheritDoc}
*/
public void send(List eventMessages) throws RemoteException {
if (eventMessages.size() == 1) {
bus.sendNotification(wrapMessage((JGroupEventMessage) eventMessages.get(0)));
return;
}
ArrayList msg = new ArrayList();
for (Iterator iter = eventMessages.iterator(); iter.hasNext();) {
JGroupEventMessage m = (JGroupEventMessage) iter.next();
msg.add(wrapMessage(m));
}
try {
bus.sendNotification(msg);
} catch (Throwable t) {
throw new RemoteException(t.getMessage());
}
}
/**
* @return the {@link Status} of the manager
*/
public Status getStatus() {
if (bus == null) {
return Status.STATUS_UNINITIALISED;
}
if (bus.getChannel() == null) {
return Status.STATUS_SHUTDOWN;
}
return Status.STATUS_ALIVE;
}
/**
* {@inheritDoc}
*/
public void dispose() throws CacheException {
if (bus != null) {
try {
bus.stop();
} catch (Exception e) {
LOG.log(Level.SEVERE, "Error occured while closing Manager:", e);
}
}
}
/**
* {@inheritDoc}
*/
public long getTimeForClusterToForm() {
return 0;
}
/**
* {@inheritDoc}
*/
public void init() {
}
/**
* {@inheritDoc}
*/
public List listRemoteCachePeers(Ehcache cache) throws CacheException {
ArrayList a = new ArrayList();
a.add(this);
return a;
}
/**
* {@inheritDoc}
*/
public void registerPeer(String rmiUrl) {
}
/**
* {@inheritDoc}
*/
public void unregisterPeer(String rmiUrl) {
}
}
The table below shows all metrics for JGroupManager.java.
| Metric | Value | Description | |
|---|---|---|---|