examples/master_slave_kill/MsKill.java
examples/master_slave_kill/Slave.java
examples/master_slave_kill/FinalizeTask.java
+ examples/migration/Emigrant.java
+ examples/migration/Migration.java
+ examples/migration/Policeman.java
examples/mutualExclusion/centralized/MutexCentral.java
examples/mutualExclusion/centralized/GrantTask.java
examples/mutualExclusion/centralized/Coordinator.java
)
set(XML_FILES
- examples/commTime/commTimeDeployment.xml
- examples/mutualExclusion/ring3.xml
- examples/mutualExclusion/centralized/mutex_centralized_deployment.xml
examples/platform.xml
- examples/pingPong/pingPongDeployment.xml
- examples/masterslave/basicDeployment.xml
+ examples/async/asyncDeployment.xml
+ examples/bittorrent/bittorrent.xml
+ examples/commTime/commTimeDeployment.xml
+ examples/masterslave/masterslaveDeployment.xml
examples/masterslave/deploy.xml
examples/master_slave_bypass/platform.xml
examples/master_slave_kill/platform.xml
- examples/async/asyncDeployment.xml
- examples/bittorrent/bittorrent.xml
+ examples/mutualExclusion/ring3.xml
+ examples/mutualExclusion/centralized/mutex_centralized_deployment.xml
+ examples/pingPong/pingPongDeployment.xml
)
set(source_to_pack
COMMAND ${JAVA_COMPILE} -d ${CMAKE_HOME_DIRECTORY}/examples -cp ${CMAKE_HOME_DIRECTORY}/simgrid.jar ${CMAKE_HOME_DIRECTORY}/examples/masterslave/*.java
COMMAND ${JAVA_COMPILE} -d ${CMAKE_HOME_DIRECTORY}/examples -cp ${CMAKE_HOME_DIRECTORY}/simgrid.jar ${CMAKE_HOME_DIRECTORY}/examples/master_slave_bypass/*.java
COMMAND ${JAVA_COMPILE} -d ${CMAKE_HOME_DIRECTORY}/examples -cp ${CMAKE_HOME_DIRECTORY}/simgrid.jar ${CMAKE_HOME_DIRECTORY}/examples/master_slave_kill/*.java
+ COMMAND ${JAVA_COMPILE} -d ${CMAKE_HOME_DIRECTORY}/examples -cp ${CMAKE_HOME_DIRECTORY}/simgrid.jar ${CMAKE_HOME_DIRECTORY}/examples/migration/*.java
COMMAND ${JAVA_COMPILE} -d ${CMAKE_HOME_DIRECTORY}/examples -cp ${CMAKE_HOME_DIRECTORY}/simgrid.jar ${CMAKE_HOME_DIRECTORY}/examples/mutualExclusion/centralized/*.java
COMMAND ${JAVA_COMPILE} -d ${CMAKE_HOME_DIRECTORY}/examples -cp ${CMAKE_HOME_DIRECTORY}/simgrid.jar ${CMAKE_HOME_DIRECTORY}/examples/pingPong/*.java
COMMAND ${JAVA_COMPILE} -d ${CMAKE_HOME_DIRECTORY}/examples -cp ${CMAKE_HOME_DIRECTORY}/simgrid.jar ${CMAKE_HOME_DIRECTORY}/examples/priority/*.java
ADD_TEST(commTime ${TESH_BIN_PATH} ${TESH_OPTION} --setenv srcdir=${CMAKE_HOME_DIRECTORY} ${CMAKE_HOME_DIRECTORY}/examples/commTime/commtime.tesh)
ADD_TEST(chord ${TESH_BIN_PATH} ${TESH_OPTION} --setenv srcdir=${CMAKE_HOME_DIRECTORY} ${CMAKE_HOME_DIRECTORY}/examples/chord/chord.tesh)
ADD_TEST(kill ${TESH_BIN_PATH} ${TESH_OPTION} --setenv srcdir=${CMAKE_HOME_DIRECTORY} ${CMAKE_HOME_DIRECTORY}/examples/master_slave_kill/kill.tesh)
-ADD_TEST(masterslave ${TESH_BIN_PATH} ${TESH_OPTION} --setenv srcdir=${CMAKE_HOME_DIRECTORY} ${CMAKE_HOME_DIRECTORY}/examples/masterslave/masterslave.tesh)
+ADD_TEST(masterslave ${TESH_BIN_PATH} ${TESH_OPTION} --setenv srcdir=${CMAKE_HOME_DIRECTORY} ${CMAKE_HOME_DIRECTORY}/examples/masterslave/masterslave.tesh)
ADD_TEST(mutualExclusion ${TESH_BIN_PATH} ${TESH_OPTION} --setenv srcdir=${CMAKE_HOME_DIRECTORY} ${CMAKE_HOME_DIRECTORY}/examples/mutualExclusion/mutualexclusion.tesh)
ADD_TEST(pingPong ${TESH_BIN_PATH} ${TESH_OPTION} --setenv srcdir=${CMAKE_HOME_DIRECTORY} ${CMAKE_HOME_DIRECTORY}/examples/pingPong/pingpong.tesh)
ADD_TEST(priority ${TESH_BIN_PATH} ${TESH_OPTION} --setenv srcdir=${CMAKE_HOME_DIRECTORY} ${CMAKE_HOME_DIRECTORY}/examples/priority/priority.tesh)
<link_ctn id="3"/>
</route>
</AS>
-</platform>
\ No newline at end of file
+</platform>
--- /dev/null
+<?xml version='1.0'?>
+<!DOCTYPE platform SYSTEM "http://simgrid.gforge.inria.fr/simgrid.dtd">
+<platform version="3">
+ <process host="Jacquelin" function="masterslave.Master">
+ <argument value="5"/> <!-- Amount of tasks to dispatch -->
+ <argument value="50000"/> <!-- Computation size of each task -->
+ <argument value="10"/> <!-- Communication size of each one -->
+ <argument value="7"/> <!-- Amount of slaves waiting for orders -->
+ </process>
+
+ <process host="Jackson" function="masterslave.Forwarder">
+ <argument value="0"/> <!-- Input mailbox -->
+ <argument value="7"/> <!-- First output mailbox -->
+ <argument value="8"/> <!-- Last output mailbox -->
+ </process>
+ <process host="Casavant" function="masterslave.Forwarder">
+ <argument value="1"/> <!-- Input mailbox -->
+ <argument value="9"/> <!-- First output mailbox -->
+ <argument value="10"/> <!-- Last output mailbox -->
+ </process>
+
+ <process host="iRMX" function="masterslave.Slave">
+ <argument value="2"/> <!-- Input mailbox -->
+ </process>
+ <process host="Bousquet" function="masterslave.Slave">
+ <argument value="3"/> <!-- Input mailbox -->
+ </process>
+ <process host="Soucy" function="masterslave.Slave">
+ <argument value="4"/> <!-- Input mailbox -->
+ </process>
+ <process host="Kuenning" function="masterslave.Slave">
+ <argument value="5"/> <!-- Input mailbox -->
+ </process>
+ <process host="Browne" function="masterslave.Slave">
+ <argument value="6"/> <!-- Input mailbox -->
+ </process>
+ <process host="Stephen" function="masterslave.Slave">
+ <argument value="7"/> <!-- Input mailbox -->
+ </process>
+ <process host="Robert" function="masterslave.Slave">
+ <argument value="8"/> <!-- Input mailbox -->
+ </process>
+ <process host="Sirois" function="masterslave.Slave">
+ <argument value="9"/> <!-- Input mailbox -->
+ </process>
+ <process host="Monique" function="masterslave.Slave">
+ <argument value="10"/> <!-- Input mailbox -->
+ </process>
+</platform>
Msg.info("Let's wait a little bit...");
waitFor(10);
Msg.info("Let's wake the lazy guy up! >:) BOOOOOUUUHHH!!!!");
- lazyGuy.restart();
+ lazyGuy.resume();
Msg.info("OK, goodbye now.");
}
}
\ No newline at end of file
}
public void main(String[] args) throws MsgException {
Msg.info("Nobody's watching me ? Let's go to sleep.");
- pause();
+ suspend();
Msg.info("Uuuh ? Did somebody call me ?");
Msg.info("Mmmh, goodbye now.");
}
public class Mutex {
private long bind; // The C object -- don't touch it
- public Mutex(int capa) {
- init(capa);
+ public Mutex() {
+ init();
}
protected void finalize() {
exit();
}
private native void exit();
- private native void init(int capacity);
+ private native void init();
public native void acquire();
public native void release();
#include "jmsg_synchro.h"
#include "jxbt_utilities.h"
+XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(jmsg);
+
static jfieldID jsyncro_field_Mutex_bind;
JNIEXPORT void JNICALL