diff options
| author | Paul Buetow (centauri) <puppet@mx.buetow.org> | 2015-05-23 21:59:43 +0100 |
|---|---|---|
| committer | Paul Buetow (centauri) <puppet@mx.buetow.org> | 2015-05-23 21:59:43 +0100 |
| commit | 9fc2fc3ccdedf1b7e48f8dfb618ca6cb6a2a662e (patch) | |
| tree | 0fa92fe4e75cb53ffbf7eb56b5455eb9457bb06c /sources/events/internal | |
| parent | f7873669a43421331e14b8921ebdaa8af4393bd5 (diff) | |
| parent | 32749241efc1f5f70056d74a90237388f57ea350 (diff) | |
Merge remote-tracking branch 'remotes/github/packages' into packagespackages
Diffstat (limited to 'sources/events/internal')
| -rw-r--r-- | sources/events/internal/VSAbstractInternalEvent.java | 84 | ||||
| -rw-r--r-- | sources/events/internal/VSMessageReceiveEvent.java | 112 | ||||
| -rw-r--r-- | sources/events/internal/VSProtocolEvent.java | 199 | ||||
| -rw-r--r-- | sources/events/internal/VSProtocolScheduleEvent.java | 151 |
4 files changed, 0 insertions, 546 deletions
diff --git a/sources/events/internal/VSAbstractInternalEvent.java b/sources/events/internal/VSAbstractInternalEvent.java deleted file mode 100644 index ae0e2b8..0000000 --- a/sources/events/internal/VSAbstractInternalEvent.java +++ /dev/null @@ -1,84 +0,0 @@ -/* - * VS-Simulator (http://vs-sim.buetow.org) - * Copyright (c) 2008 - 2009 by Dipl.-Inform. (FH) Paul C. Buetow - * - * This program is free software; you can redistribute it and/or - * modify it under the terms of the GNU General Public License - * as published by the Free Software Foundation; either version 2 - * of the License, or (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with this program; if not, write to the Free Software - * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. - * - * All icons of the icons/ folder are under a Creative Commons - * Attribution-Noncommercial-Share Alike License a CC-by-nc-sa. - * - * The icon's homepage is http://code.google.com/p/ultimate-gnome/ - */ - -package events.internal; - -import java.io.*; - -import events.VSAbstractEvent; -import serialize.VSSerialize; - -/** - * The class VSAbstractInternalEvent, this class if for destinguishing between - * internal and non-internal events. Internal usage only. - * - * @author Paul C. Buetow - */ -abstract public class VSAbstractInternalEvent extends VSAbstractEvent { - /** The serial version uid */ - private static final long serialVersionUID = 1L; - - /* (non-Javadoc) - * @see events.VSAbstractEvent#createShortname()() - */ - protected String createShortname(String savedShortname) { - return savedShortname; - } - - /* (non-Javadoc) - * @see serialize.VSSerializable#serialize(serialize.VSSerialize, - * java.io.ObjectOutputStream) - */ - public synchronized void serialize(VSSerialize serialize, - ObjectOutputStream objectOutputStream) - throws IOException { - super.serialize(serialize, objectOutputStream); - - /** For later backwards compatibility, to add more stuff */ - objectOutputStream.writeObject(new Boolean(false)); - - /** For later backwards compatibility, to add more stuff */ - objectOutputStream.writeObject(new Boolean(false)); - } - - /* (non-Javadoc) - * @see serialize.VSSerializable#deserialize(serialize.VSSerialize, - * java.io.ObjectInputStream) - */ - @SuppressWarnings("unchecked") - public synchronized void deserialize(VSSerialize serialize, - ObjectInputStream objectInputStream) - throws IOException, ClassNotFoundException { - super.deserialize(serialize, objectInputStream); - - if (VSSerialize.DEBUG) - System.out.println("Deserializing: VSAbstractInternalEvent"); - - /** For later backwards compatibility, to add more stuff */ - objectInputStream.readObject(); - - /** For later backwards compatibility, to add more stuff */ - objectInputStream.readObject(); - } -} diff --git a/sources/events/internal/VSMessageReceiveEvent.java b/sources/events/internal/VSMessageReceiveEvent.java deleted file mode 100644 index ab8c929..0000000 --- a/sources/events/internal/VSMessageReceiveEvent.java +++ /dev/null @@ -1,112 +0,0 @@ -/* - * Copyright (c) 2008 Paul C. Buetow, vs@dev.buetow.org - * - * This program is free software; you can redistribute it and/or - * modify it under the terms of the GNU General Public License - * as published by the Free Software Foundation; either version 2 - * of the License, or (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with this program; if not, write to the Free Software - * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. - * - * All icons of the icons/ folder are under a Creative Commons - * Attribution-Noncommercial-Share Alike License a CC-by-nc-sa. - * - * The icon's homepage is http://code.google.com/p/ultimate-gnome/ - */ - -package events.internal; - -//import java.io.*; - -import core.VSMessage; -import protocols.VSAbstractProtocol; -import serialize.VSNotSerializable; - -/** - * The class VSMessageReceiveEvent, this event is used if a process receives - * a message. - * - * @author Paul C. Buetow - */ -public class VSMessageReceiveEvent extends VSAbstractInternalEvent - implements VSNotSerializable { - /** The serioal version uid */ - private static final long serialVersionUID = 1L; - - /** The message. */ - private VSMessage message; - - /** - * Instantiates a new message receive event. - * - * @param message the message - */ - public VSMessageReceiveEvent(VSMessage message) { - this.message = message; - } - - /* (non-Javadoc) - * @see events.VSAbstractEvent#onInit() - */ - public void onInit() { - setClassname(getClass().toString()); - } - - /* (non-Javadoc) - * @see events.VSAbstractEvent#onStart() - */ - public void onStart() { - boolean onlyRelevantMessages = process.getPrefs().getBoolean( - "sim.messages.relevant"); - - //String eventName = message.getName(); - String protocolClassname = message.getProtocolClassname(); - - if (onlyRelevantMessages && !isRelevantMessage()) - return; - - Object protocolObj = null; - - if (process.objectExists(protocolClassname)) - protocolObj = process.getObject(protocolClassname); - - process.updateLamportTime(message.getLamportTime()+1); - process.updateVectorTime(message.getVectorTime()); - - StringBuffer buffer = new StringBuffer(); - buffer.append(prefs.getString("lang.en.message.recv")); - buffer.append("; "); - buffer.append(message);; - log(buffer.toString()); - - if (protocolObj != null) - ((VSAbstractProtocol) protocolObj).onMessageRecvStart(message); - } - - /** - * Checks if the message delivering is relevant. - * - * @return true, if relevant - */ - public boolean isRelevantMessage() { - String protocolClassname = message.getProtocolClassname(); - Object protocolObj = null; - - if (process.objectExists(protocolClassname)) - protocolObj = process.getObject(protocolClassname); - else - return false; - - if (!((VSAbstractProtocol) protocolObj).isRelevantMessage(message)) - return false; - - return true; - } -} diff --git a/sources/events/internal/VSProtocolEvent.java b/sources/events/internal/VSProtocolEvent.java deleted file mode 100644 index 92af81e..0000000 --- a/sources/events/internal/VSProtocolEvent.java +++ /dev/null @@ -1,199 +0,0 @@ -/* - * VS-Simulator (http://vs-sim.buetow.org) - * Copyright (c) 2008 - 2009 by Dipl.-Inform. (FH) Paul C. Buetow - * - * This program is free software; you can redistribute it and/or - * modify it under the terms of the GNU General Public License - * as published by the Free Software Foundation; either version 2 - * of the License, or (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with this program; if not, write to the Free Software - * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. - * - * All icons of the icons/ folder are under a Creative Commons - * Attribution-Noncommercial-Share Alike License a CC-by-nc-sa. - * - * The icon's homepage is http://code.google.com/p/ultimate-gnome/ - */ - -package events.internal; - -import java.io.*; - -import core.VSInternalProcess; -import events.*; -import protocols.VSAbstractProtocol; -import serialize.VSSerialize; - -/** - * The class VSProtocolEvent, this event is used if a protocol (server or - * client part) of a process gets enabled or disabled, an object of this class - * can be for 4 different purporses! Activation of the client protocol, - * deactivation of the client protocol, activation of the server protocol, - * deactivation of the server protocol. - * - * @author Paul C. Buetow - */ -public class VSProtocolEvent extends VSAbstractInternalEvent - implements VSCopyableEvent { - /** The serial version uid */ - private static final long serialVersionUID = 1L; - - /** The protocol classname. */ - private String protocolClassname; - - /** The event is a client protocol if true. Else it is a server protocol */ - private boolean isClientProtocol; - - /** The event is a protocol activation if true. Else it is a deactivation */ - private boolean isProtocolActivation; - - /* (non-Javadoc) - * @see events.VSCopyableEvent#initCopy(events.VSAbstractEvent) - */ - public void initCopy(VSAbstractEvent copy) { - VSProtocolEvent protocolEventCopy = (VSProtocolEvent) copy; - protocolEventCopy.isClientProtocol(isClientProtocol); - protocolEventCopy.isProtocolActivation(isProtocolActivation); - protocolEventCopy.setProtocolClassname(protocolClassname); - } - - /* (non-Javadoc) - * @see events.VSAbstractEvent#onInit() - */ - public void onInit() { - setClassname(getClass().toString()); - } - - /** - * Sets if it is a client protocol activation/deactivation. - * - * @param isClientProtocol the event is client protocol if true. the event - * is a server protocol if false. - */ - public void isClientProtocol(boolean isClientProtocol) { - this.isClientProtocol = isClientProtocol; - } - - /** - * Checks if it is a client protocol activation/deactivation. - * - * @return the event is client protocol if true. the event - * is a server protocol if false. - */ - public boolean isClientProtocol() { - return isClientProtocol; - } - - /** - * Sets if it is protocol activation. - * - * @param isProtocolActivation true, if it is a protocol activation. false, - * if it is a protocol deactivation. - */ - public void isProtocolActivation(boolean isProtocolActivation) { - this.isProtocolActivation = isProtocolActivation; - } - - /** - * Checks if it is protocol activation. - * - * @return true, if it is a protocol activation. false, if it is a protocol - * deactivation. - */ - public boolean isProtocolActivation() { - return isProtocolActivation; - } - - /** - * Sets the protocol classname. - * - * @param protocolClassname the new protocol classname - */ - public void setProtocolClassname(String protocolClassname) { - this.protocolClassname = protocolClassname; - } - - /* (non-Javadoc) - * @see events.VSAbstractEvent#onStart() - */ - public void onStart() { - VSInternalProcess internalProcess = (VSInternalProcess) process; - VSAbstractProtocol protocol = - internalProcess.getProtocolObject(protocolClassname); - - if (isClientProtocol) - protocol.isClient(isProtocolActivation); - else - protocol.isServer(isProtocolActivation); - - StringBuffer buffer = new StringBuffer(); - buffer.append(VSRegisteredEvents.getShortnameByClassname( - protocolClassname)); - - buffer.append(" "); - buffer.append(isClientProtocol - ? prefs.getString("lang.en.client") - : prefs.getString("lang.en.server")); - - buffer.append(" "); - buffer.append(isProtocolActivation - ? prefs.getString("lang.en.activated") - : prefs.getString("lang.en.deactivated")); - - log(buffer.toString()); - } - - /* (non-Javadoc) - * @see serialize.VSSerializable#serialize(serialize.VSSerialize, - * java.io.ObjectOutputStream) - */ - public synchronized void serialize(VSSerialize serialize, - ObjectOutputStream objectOutputStream) - throws IOException { - super.serialize(serialize, objectOutputStream); - - /** For later backwards compatibility, to add more stuff */ - objectOutputStream.writeObject(new Boolean(false)); - - objectOutputStream.writeObject(protocolClassname); - objectOutputStream.writeObject(new Boolean(isClientProtocol)); - objectOutputStream.writeObject(new Boolean(isProtocolActivation)); - - /** For later backwards compatibility, to add more stuff */ - objectOutputStream.writeObject(new Boolean(false)); - } - - /* (non-Javadoc) - * @see serialize.VSSerializable#deserialize(serialize.VSSerialize, - * java.io.ObjectInputStream) - */ - @SuppressWarnings("unchecked") - public synchronized void deserialize(VSSerialize serialize, - ObjectInputStream objectInputStream) - throws IOException, ClassNotFoundException { - super.deserialize(serialize, objectInputStream); - - if (VSSerialize.DEBUG) - System.out.println("Deserializing: VSProtocolEvent"); - - /** For later backwards compatibility, to add more stuff */ - objectInputStream.readObject(); - - protocolClassname = (String) objectInputStream.readObject(); - - isClientProtocol = ((Boolean) - objectInputStream.readObject()).booleanValue();; - isProtocolActivation = ((Boolean) - objectInputStream.readObject()).booleanValue();; - - /** For later backwards compatibility, to add more stuff */ - objectInputStream.readObject(); - } -} diff --git a/sources/events/internal/VSProtocolScheduleEvent.java b/sources/events/internal/VSProtocolScheduleEvent.java deleted file mode 100644 index 83b5505..0000000 --- a/sources/events/internal/VSProtocolScheduleEvent.java +++ /dev/null @@ -1,151 +0,0 @@ -/* - * Copyright (c) 2008 Paul C. Buetow, vs@dev.buetow.org - * - * This program is free software; you can redistribute it and/or - * modify it under the terms of the GNU General Public License - * as published by the Free Software Foundation; either version 2 - * of the License, or (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with this program; if not, write to the Free Software - * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. - * - * All icons of the icons/ folder are under a Creative Commons - * Attribution-Noncommercial-Share Alike License a CC-by-nc-sa. - * - * The icon's homepage is http://code.google.com/p/ultimate-gnome/ - */ - -package events.internal; - -import java.io.*; - -//import events.*; -import protocols.VSAbstractProtocol; -import serialize.*; - -/** - * The class VSProtocolScheduleEvent, this event is used if a protocol (which - * is a subclass of VSAbstractProtocol) reschedules itself to run again on a - * specific time. - * - * @author Paul C. Buetow - */ -public class VSProtocolScheduleEvent extends VSAbstractInternalEvent - implements VSNotSerializable { - /** The serial version uid */ - private static final long serialVersionUID = 1L; - - /** The event is a server protocol schedule. */ - private boolean isServerSchedule; /* true = server, false = client */ - - /** The reference to the protocol object to schedule. */ - private VSAbstractProtocol protocol; - - /** - * Create a VSProtocolScheduleEvent object - * - * @param protocol the protocol - * @param isServerSchedule the event is a client protocol schedule if - * false, else server schedule - */ - public VSProtocolScheduleEvent(VSAbstractProtocol protocol, - boolean isServerSchedule) { - this.protocol = protocol; - this.isServerSchedule = isServerSchedule; - } - - /* (non-Javadoc) - * @see events.VSAbstractEvent#onInit() - */ - public void onInit() { - setClassname(getClass().toString()); - } - - /** - * Sets if it is client protocol schedule. - * - * @param isServerSchedule false, if the event is a client protocol - * schedule. true, if server. - */ - public void isServerSchedule(boolean isServerSchedule) { - this.isServerSchedule = isServerSchedule; - } - - /** - * Sets if it is client protocol schedule. - * - * @return false, if the event is a client protocol schedule. true, if - * server. - */ - public boolean isServerSchedule() { - return isServerSchedule; - } - - /** - * Sets the protocol. - * - * @param protocol the protocol - */ - public void setProtocol(VSAbstractProtocol protocol) { - this.protocol = protocol; - } - - /** - * Gets the protocol. - * - * @return the protocol - */ - public VSAbstractProtocol getProtocol() { - return protocol; - } - - /* (non-Javadoc) - * @see events.VSAbstractEvent#onStart() - */ - public void onStart() { - if (isServerSchedule) - protocol.onServerScheduleStart(); - else - protocol.onClientScheduleStart(); - } - - /* (non-Javadoc) - * @see serialize.VSSerializable#serialize(serialize.VSSerialize, - * java.io.ObjectOutputStream) - */ - public synchronized void serialize(VSSerialize serialize, - ObjectOutputStream objectOutputStream) - throws IOException { - super.serialize(serialize, objectOutputStream); - - /** For later backwards compatibility, to add more stuff */ - objectOutputStream.writeObject(new Boolean(false)); - - /** For later backwards compatibility, to add more stuff */ - objectOutputStream.writeObject(new Boolean(false)); - } - - /* (non-Javadoc) - * @see serialize.VSSerializable#deserialize(serialize.VSSerialize, - * java.io.ObjectInputStream) - */ - @SuppressWarnings("unchecked") - public synchronized void deserialize(VSSerialize serialize, - ObjectInputStream objectInputStream) - throws IOException, ClassNotFoundException { - super.deserialize(serialize, objectInputStream); - - if (VSSerialize.DEBUG) - System.out.println("Deserializing: VSProtocolEvent"); - - /** For later backwards compatibility, to add more stuff */ - objectInputStream.readObject(); - - } -} |
