ShutdownServer.java
资源名称:src.rar [点击查看]
上传用户:gwt600
上传日期:2021-06-03
资源大小:704k
文件大小:3k
源码类别:
游戏
开发平台:
Java
- /*
- This file is part of the OdinMS Maple Story Server
- Copyright (C) 2008 Patrick Huy <patrick.huy@frz.cc>
- Matthias Butz <matze@odinms.de>
- Jan Christian Meyer <vimes@odinms.de>
- This program is free software: you can redistribute it and/or modify
- it under the terms of the GNU Affero General Public License version 3
- as published by the Free Software Foundation. You may not use, modify
- or distribute this program under any other version of the
- GNU Affero General Public License.
- 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 Affero General Public License for more details.
- You should have received a copy of the GNU Affero General Public License
- along with this program. If not, see <http://www.gnu.org/licenses/>.
- */
- /* * To change this template, choose Tools | Templates * and open the template in the editor. */ package net.sf.odinms.server; import java.rmi.RemoteException; import java.sql.SQLException; import net.sf.odinms.database.DatabaseConnection; import net.sf.odinms.net.channel.ChannelServer; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * * @author Frz */ public class ShutdownServer implements Runnable { private static Logger log = LoggerFactory.getLogger(ShutdownServer.class); private int myChannel; public ShutdownServer(int channel) { myChannel = channel; } @Override public void run() { try { ChannelServer.getInstance(myChannel).shutdown(); } catch (Throwable t) { log.error("SHUTDOWN ERROR", t); } int c = 200; while (ChannelServer.getInstance(myChannel).getConnectedClients() > 0 && c > 0) { try { Thread.sleep(100); } catch (InterruptedException e) { log.error("ERROR", e); } c--; } try { ChannelServer.getWorldRegistry().deregisterChannelServer(myChannel); } catch (RemoteException e) { // we are shutting down } try { ChannelServer.getInstance(myChannel).unbind(); } catch (Throwable t) { log.error("SHUTDOWN ERROR", t); } boolean allShutdownFinished = true; for (ChannelServer cserv : ChannelServer.getAllInstances()){ if (!cserv.hasFinishedShutdown()) { allShutdownFinished = false; } } if (allShutdownFinished) { TimerManager.getInstance().stop(); try { DatabaseConnection.closeAll(); } catch (SQLException e) { log.error("THROW", e); } System.exit(0); // still can't exit without system.exit ;_; } } }
English
