Logo
Distributed Genetic Programming Framework
print print

File org.dgpf.gp.netvm.netimpl.GridNetworkImpl.java

Here you can find all the information about the file org.dgpf.gp.netvm.netimpl.GridNetworkImpl.java. You may explore it here or download it onto your local disk.
/*
 * Copyright (c) 2006 Thomas Weise
 * 
 * E-Mail           : tweise@gmx.de
 * Creation Date    : 2006-07-19 10:49:31
 * Original Filename: org.dgpf.gp.netvm.netimpl.GridNetworkImpl.java
 * Version          : 1.0.0
 * Last modification: 2006-07-19
 *                by: Thomas Weise
 * 
 * License          : GNU LESSER GENERAL PUBLIC LICENSE
 *                    Version 2.1, February 1999
 *                    You should have received a copy of this license along
 *                    with this library; if not, write to the Free Software
 *                    Foundation, Inc., 59 Temple Place, Suite 330, Boston,
 *                    MA 02111-1307, USA or download the license under
 *                    http://www.gnu.org/copyleft/lesser.html.
 *                    
 * Warranty         : This software is provided "as is" without any
 *                    warranty; without even the implied warranty of
 *                    merchantability or fitness for a particular purpose.
 *                    See the Gnu Lesser General Public License for more
 *                    details.
 */

 
package org.dgpf.gp.netvm.netimpl;

import java.util.Map;

import org.dgpf.gp.netvm.base.INetworkImplFactory;
import org.dgpf.gp.netvm.base.NetVM;
import org.dgpf.gp.netvm.base.NetVMContext;
import org.dgpf.gp.netvm.base.NetworkImpl;
import org.dgpf.gp.vm.base.VMMemory;
import org.sfc.collections.Arrays;
import org.sfc.collections.Collections;
import org.sfc.math.stochastic.Randomizer;

/**
 * A network implementation that models a network as a perfect grid.
 *
 * @author Thomas Weise
 */

public final  class GridNetworkImpl  extends  NetworkImpl
  {
/**
 * The factory class for this network implementation.
 */

  public  static  final INetworkImplFactory FACTORY =
    new INetworkImplFactory()
    {
    private static  final long  serialVersionUID = 1;
    
    public  final NetworkImpl create  (final NetVMContext p_context)
      {
      return new GridNetworkImpl(p_context);
      }
    
    private final Object writeReplace()
      {
      return FACTORY;
      }
    
    private final Object readResolve()
      {
      return FACTORY;
      }
    };
/**
 * The networked virtual machine grid which contains the locations of the
 * networked virtual machines.
 */

  private           NetVM[][]           m_grid  ;
/**
 * The maximum x coordinate of the grid.
 */

  private           int                 m_max_x ;
/**
 * The maximum y coordinate of the grid.
 */
  
  private           int                 m_max_y ;
/**
 * The internal mapping from coordinates to network vms.
 */

  private final     Map<NetVM, Coords>  m_coords  ;
  
/**
 * Create a new grid network implementation.
 * @param p_nvc The network vm context to be used.
 */

  public  GridNetworkImpl (final NetVMContext p_nvc)
    {
    super(p_nvc);                  
    this.m_coords = Collections.create_map(-1);
    }
/**
 * Deliver a message from a source to the destinations in reach.
 * @param p_source  The source node.
 * @param p_data    The message data.
 * @return  <code>true</code> if and only if the message was delivered to
 *          at least one node. 
 */

  @Override
  protected final boolean deliver (final NetVM         p_source,
                                         VMMemory      p_data)
    {
    Coords        l_c;
    int           l_x, l_i, l_j, l_mx, l_my, l_a, l_b;
    NetVM         l_t;
    NetVM[][]     l_g;
    Randomizer    l_r;
    
    l_c = this.m_coords.get(p_source);
    if(l_c == null) return false;
    
    l_x       = l_c.m_x;
    l_a       = l_c.m_y;
    l_mx      = this.m_max_x;
    l_my      = this.m_max_y;
    l_g       = this.m_grid;
    l_i       = (l_x+1);
    l_j       = (l_a+1);
    l_r       = this.get_context().get_randomizer();
    
    for(--l_a; l_a <= l_j; l_a++)
      {
      if((l_a >= 0) && (l_a < l_my))
        {
        for(l_b = (l_x-1); l_b <= l_i; l_b++)
          {
          if((l_b >= 0) && (l_b < l_mx))
            {
            l_t = l_g[l_a][l_b];
            if((l_t != null) && (l_t != p_source))
              {
              if(l_t.receive(p_data, 1+l_r.nextInt(20)))
                {
                p_data = this.copy_mem(p_data);    
                }    
              }
            }
          }
        }
      }
        
    this.dispose_mem(p_data);
    return true;
    }
  
/**
 * Set the count of virtual machines to be simulated.
 * @param p_vm_count  The new count of virtual machines to be simulated.
 */

  @Override
  protected final void set_vm_count(final int p_vm_count)
    {        
    this.m_grid = new NetVM[p_vm_count][p_vm_count];
    this.reset_caches();
    }
  
/**
 * Reset the internal caches used.
 */

  @Override
  protected final void  reset_caches()
    {
    Map<NetVM, Coords>  l_c;
    NetVMContext        l_cc;
    int                 l_i;
    
    l_c   = this.m_coords;
    l_cc  = this.get_context();
    
    l_c.clear();
    for(l_i = (l_cc.get_vm_count()-1); l_i >= 0; l_i--)
      {
      l_c.put(l_cc.get_vm(l_i), new Coords());
      }
    }
  
  
/**
 * This method is called right before a simulation starts to initialize the
 * virtual network.
 * The simulation-setup of the fitness functions will also be invoked here.
 * @param p_index   The index number of the current simulation. The first
 *                  simulation will have index 0, the second will have
 *                  index 1 and so on.
 */

  @Override
  protected void init_network (final int p_index)
    {
    NetVM[][]           l_g;
    NetVM               l_vv;
    int                 l_i, l_x, l_y, l_mx, l_my, l_q;
    Randomizer          l_r;
    Coords              l_cc;
    NetVMContext        l_ctx;
    Map<NetVM, Coords>  l_map;
    
    l_ctx = this.get_context();
    l_g   = this.m_grid;
    l_r   = l_ctx.get_randomizer();
    l_i   = l_ctx.get_vm_count();    
    l_map = this.m_coords;
    
    l_mx  = ((int)((p_index*14996831L) % l_i) + 1);
    l_my  = (l_i/l_mx);
    while( (l_mx*l_my) < l_i ) l_my++;
        
    this.m_max_x = l_mx;
    this.m_max_y = l_my;
    l_x          = 0;
    l_q          = 0;
    for(--l_i; l_i >= 0; l_i--)
      {
      l_vv = l_ctx.get_vm(l_i);
      
      do
        {
        l_y = l_r.nextInt(l_my);
        } while(l_g[l_y][l_x] != null);
      
      l_g[l_y][l_x] = l_vv;
    
      l_cc     = l_map.get(l_vv);
      l_cc.m_x = l_x;
      l_cc.m_y = l_y;
      
      if((++l_q) >= l_my)
        {
        l_x++;
        l_q = 0;
        }
      }    
    }
  
/**
 * This method is called right when a simulation has finished and cleans
 * up the network.
 * @param p_index   The index number of the current simulation. The first
 *                  simulation will have index 0, the second will have
 *                  index 1 and so on.
 */

  @Override
  protected void    end_network    (final int p_index)
    {
    int       l_i;
    NetVM[][] l_g;
    
    l_g = this.m_grid;
    for(l_i = (this.m_max_y-1); l_i >= 0; l_i--)
      {
      Arrays.fill(l_g[l_i], null, 0, this.m_max_x);
      }
    }
  
  
/**
 * Coordinates of a networked vm.
 *
 * @author Thomas Weise
 */

  private static  final class Coords
    {
/**
 * The x-coordinate.
 */

    int m_x ;
/**
 * The y-coordinate.
 */

    int m_y ;
    }
  }

File Information:

file name:GridNetworkImpl.java
package:org.dgpf.gp.netvm.netimpl
qualified name:org.dgpf.gp.netvm.netimpl.GridNetworkImpl.java
file type:Java Source File
download location:download http://dgpf.sourceforge.net/source/org/dgpf/gp/netvm/netimpl/GridNetworkImpl.java
size:7.376 KB (7554 B)
uploaded: 2015-07-22 04:10:56 GMT+0000
last update: 2006-08-04 12:46:19 GMT+0000
last access: 2017-11-17 19:08:03 GMT+0000

statistics online since 2006-01-02.   RSS Feed
Contact us by sending an email to tweise@gmx.de to receive further information, to report errors, or to join our project.
All content on this site (http://dgpf.sourceforge.net/) is LGPL-licensed.
http://dgpf.sourceforge.net/scripts/source/source.php last modified at 2015-07-22 04:10:53 GMT+0000 served at 2017-11-17 19:08:03 GMT+0000.
Valid CSS Valid XHTML 1.1
Valid RSS SourceForge.net Logo