Py4JGetawayServer.java

Go to the documentation of this file.

/*
 *   DENOPTIM
 *   Copyright (C) 2022 Marco Foscato <marco.foscato@uib.no>
 * 
 *   This program 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.
 *
 *   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/>.
 */
 
package denoptim.integration.python;
import java.net.BindException;
 
import denoptim.exception.DENOPTIMException;
import denoptim.io.DenoptimIO;
import py4j.GatewayServer;
import py4j.Py4JNetworkException;
 
public class Py4JGetawayServer
{
    private GatewayServer server;
    
    private String pathname = null;
 
    private Object data = null;
  
//------------------------------------------------------------------------------
    
    public static void launch() throws DENOPTIMException
    {
        Py4JGetawayServer launcher = new Py4JGetawayServer();
        GatewayServer gatewayServer = new GatewayServer(launcher);
        try
        {
            gatewayServer.start();
        } catch (Py4JNetworkException e)
        {
            if (e.getCause() instanceof BindException
                    && e.getCause().getMessage().contains("already in use"))
                throw new DENOPTIMException("DENOPTIM Py4J server already "
                        + "running!",e);
        }
        launcher.setServer(gatewayServer);
    }
    
//------------------------------------------------------------------------------
    
    public Object loadData(String pathname) throws Exception
    {
        this.pathname = pathname;
        data = DenoptimIO.readDENOPTIMData(pathname);
        return data;
    }
    
//------------------------------------------------------------------------------
    
    public Object getData()
    {
        return data;
    }
 
//------------------------------------------------------------------------------
    
    public String getSourcePathName()
    {
        return pathname;
    }
    
//------------------------------------------------------------------------------  
 
    public void shutdown()
    {
        if (server != null)
            server.shutdown();
    }
    
//------------------------------------------------------------------------------
    
    private void setServer(GatewayServer server)
    {
        this.server = server;
    }
    
//------------------------------------------------------------------------------  
 
}