projectswg/pswgcommon
1
0
Fork 0
mirror of https://github.com/ProjectSWGCore/pswgcommon.git synced 2026-01-15 23:04:19 -05:00
Code Issues Projects Releases Wiki Activity

Upgraded Manager

Browse Source
This commit is contained in:
Obique PSWG
2018-02-04 10:27:52 -06:00
parent 8d6dc159b0
commit 5f1ce51e0a
1 changed files with 141 additions and 96 deletions
Download Patch File Download Diff File Expand all files Collapse all files

237
src/com/projectswg/common/control/Manager.java
View File

@@ -1,129 +1,152 @@
/***********************************************************************************
* Copyright (c) 2015 /// Project SWG /// www.projectswg.com *
* *
* ProjectSWG is the first NGE emulator for Star Wars Galaxies founded on *
* July 7th, 2011 after SOE announced the official shutdown of Star Wars Galaxies. *
* Our goal is to create an emulator which will provide a server for players to *
* continue playing a game similar to the one they used to play. We are basing *
* it on the final publish of the game prior to end-game events. *
* *
* This file is part of Holocore. *
* *
* -------------------------------------------------------------------------------- *
* *
* Holocore is free software: you can redistribute it and/or modify *
* it under the terms of the GNU Affero General Public License as *
* published by the Free Software Foundation, either version 3 of the *
* License, or (at your option) any later version. *
* *
* Holocore 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 Affero General Public License for more details. *
* *
* You should have received a copy of the GNU Affero General Public License *
* along with Holocore. If not, see <http://www.gnu.org/licenses/>. *
* *
***********************************************************************************/
* Copyright (c) 2015 /// Project SWG /// www.projectswg.com *
* *
* ProjectSWG is the first NGE emulator for Star Wars Galaxies founded on *
* July 7th, 2011 after SOE announced the official shutdown of Star Wars Galaxies. *
* Our goal is to create an emulator which will provide a server for players to *
* continue playing a game similar to the one they used to play. We are basing *
* it on the final publish of the game prior to end-game events. *
* *
* This file is part of Holocore. *
* *
* -------------------------------------------------------------------------------- *
* *
* Holocore is free software: you can redistribute it and/or modify *
* it under the terms of the GNU Affero General Public License as *
* published by the Free Software Foundation, either version 3 of the *
* License, or (at your option) any later version. *
* *
* Holocore 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 Affero General Public License for more details. *
* *
* You should have received a copy of the GNU Affero General Public License *
* along with Holocore. If not, see <http://www.gnu.org/licenses/>. *
* *
***********************************************************************************/
package com.projectswg.common.control;
import com.projectswg.common.concurrency.Delay;
import com.projectswg.common.debug.Log;
import java.util.ArrayList;
import java.util.List;
import com.projectswg.common.debug.Log;
import java.util.Objects;
import java.util.concurrent.CopyOnWriteArrayList;
/**
* A Manager is a class that will manage services, and generally controls the
* program as a whole
* A Manager is a class that will manage services, and generally controls the program as a whole
*/
public abstract class Manager extends Service {
private List <Service> children;
private final List<Service> initialized;
private final List<Service> started;
private final List<Service> children;
public Manager() {
children = new ArrayList<Service>();
initialized = new CopyOnWriteArrayList<>();
started = new CopyOnWriteArrayList<>();
children = new CopyOnWriteArrayList<>();
}
/**
* Initializes this manager. If the manager returns false on this method
* then the initialization failed and may not work as intended. This will
* Initializes this manager. If the manager returns false on this method then the initialization failed and may not work as intended. This will
* initialize all children automatically.
*
* @return TRUE if initialization was successful, FALSE otherwise
*/
@Override
public boolean initialize() {
boolean success = super.initialize();
synchronized (children) {
for (Service child : children) {
for (Service child : children) {
try {
if (!child.initialize()) {
Log.e(child.getClass().getSimpleName() + " failed to initialize!");
Log.e("%s failed to initialize!", child.getClass().getSimpleName());
success = false;
break;
}
initialized.add(child);
} catch (Throwable t) {
Log.e("%s failed to initialize!", child.getClass().getSimpleName());
Log.e(t);
success = false;
break;
}
}
return success;
}
/**
* Starts this manager. If the manager returns false on this method then
* the manger failed to start and may not work as intended. This will start
* Starts this manager. If the manager returns false on this method then the manger failed to start and may not work as intended. This will start
* all children automatically.
*
* @return TRUE if starting was successful, FALSE otherwise
*/
@Override
public boolean start() {
boolean success = super.start();
synchronized (children) {
for (Service child : children) {
for (Service child : children) {
try {
if (!child.start()) {
Log.e(child.getClass().getSimpleName() + " failed to start!");
Log.e("%s failed to start!", child.getClass().getSimpleName());
success = false;
break;
}
started.add(child);
} catch (Throwable t) {
Log.e("%s failed to start!", child.getClass().getSimpleName());
Log.e(t);
success = false;
break;
}
}
return success;
}
/**
* Stops this manager. If the manager returns false on this method then
* the manger failed to stop and may not have fully locked down. This will
* Stops this manager. If the manager returns false on this method then the manger failed to stop and may not have fully locked down. This will
* start all children automatically.
*
* @return TRUE if stopping was successful, FALSE otherwise
*/
@Override
public boolean stop() {
boolean success = super.stop(), cSuccess = true;
synchronized (children) {
for (Service child : children) {
if (!success)
break;
cSuccess = child.stop();
if (!cSuccess) {
Log.e(child.getClass().getSimpleName() + " failed to stop!");
boolean success = super.stop();
for (Service child : started) {
try {
if (!child.stop()) {
Log.e("%s failed to stop!", child.getClass().getSimpleName());
success = false;
}
} catch (Throwable t) {
Log.e("%s failed to stop!", child.getClass().getSimpleName());
Log.e(t);
success = false;
}
}
return success;
}
/**
* Terminates this manager. If the manager returns false on this method
* then the manager failed to shut down and resources may not have been
* Terminates this manager. If the manager returns false on this method then the manager failed to shut down and resources may not have been
* cleaned up. This will terminate all children automatically.
*
* @return TRUE if termination was successful, FALSE otherwise
*/
@Override
public boolean terminate() {
boolean success = super.terminate();
synchronized (children) {
for (Service child : children) {
if (!child.terminate())
for (Service child : initialized) {
try {
if (!child.terminate()) {
Log.e("%s failed to terminate!", child.getClass().getSimpleName());
success = false;
}
} catch (Throwable t) {
Log.e("%s failed to terminate!", child.getClass().getSimpleName());
Log.e(t);
success = false;
}
}
return success;
@@ -131,71 +154,93 @@ public abstract class Manager extends Service {
/**
* Determines whether or not this manager is operational
*
* @return TRUE if this manager is operational, FALSE otherwise
*/
@Override
public boolean isOperational() {
boolean success = true;
synchronized (children) {
for (Service child : children) {
if (!child.isOperational())
success = false;
}
for (Service child : children) {
if (!child.isOperational())
return false;
}
return success;
return true;
}
/**
* Adds a child to the manager's list of children. This creates a tree of
* managers that allows information to propogate freely through the network
* Adds a child to the manager's list of children. This creates a tree of managers that allows information to propogate freely through the network
* in an easy way.
* @param m the manager to add as a child.
*
* @param service the service to add as a child.
*/
public void addChildService(Service s) {
if (s == null)
throw new NullPointerException("Child service cannot be null!");
synchronized (children) {
for (Service child : children) {
if (s == child || s.equals(child))
return;
}
children.add(s);
IntentManager manager = getIntentManager();
if (manager != null)
s.setIntentManager(manager);
}
public void addChildService(Service service) {
Objects.requireNonNull(service, "service");
if (children.contains(service))
return;
children.add(service);
IntentManager manager = getIntentManager();
if (manager != null)
service.setIntentManager(manager);
}
/**
* Removes the sub-manager from the list of children
* @param m the sub-manager to remove
*
* @param service the service to remove
*/
public void removeChildService(Service s) {
if (s == null)
return;
synchronized (children) {
children.remove(s);
}
public void removeChildService(Service service) {
Objects.requireNonNull(service, "service");
children.remove(service);
}
/**
* Returns a copied ArrayList of the children of this manager
*
* @return a copied ArrayList of the children of this manager
*/
public List<Service> getManagerChildren() {
synchronized (children) {
return new ArrayList<Service>(children);
}
return new ArrayList<>(children);
}
@Override
public void setIntentManager(IntentManager intentManager) {
super.setIntentManager(intentManager);
synchronized (children) {
for (Service s : children) {
s.setIntentManager(intentManager);
}
for (Service s : children) {
s.setIntentManager(intentManager);
}
}
public static void startManager(Manager manager) {
Log.i("Initializing...");
if (!manager.initialize()) {
Log.e("Failed to initialize!");
terminateManager(manager);
return;
}
Log.i("Initialized.");
if (!manager.start()) {
Log.e("Failed to start!");
stopManager(manager);
return;
}
Log.i("Started.");
while (manager.isOperational()) {
if (Delay.sleepMilli(50))
break;
}
stopManager(manager);
}
private static void stopManager(Manager manager) {
Log.i("Stopping...");
manager.stop();
Log.i("Stopped.");
terminateManager(manager);
}
private static void terminateManager(Manager manager) {
Log.i("Terminating...");
manager.terminate();
Log.i("Terminated.");
}
}