A
lgorithmique
N
umérique
D
istribuée
Public GIT Repository
projects
/
simgrid.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Add isend in Task
[simgrid.git]
/
org
/
simgrid
/
msg
/
Task.java
diff --git
a/org/simgrid/msg/Task.java
b/org/simgrid/msg/Task.java
index
830805e
..
a680e64
100644
(file)
--- a/
org/simgrid/msg/Task.java
+++ b/
org/simgrid/msg/Task.java
@@
-94,7
+94,7
@@
public class Task {
}
/**
* This method sets the priority of the computation of the task.
}
/**
* This method sets the priority of the computation of the task.
- * The priority doesn't affect the transfer
t
rate. For example a
+ * The priority doesn't affect the transfer rate. For example a
* priority of 2 will make the task receive two times more cpu than
* the other ones.
*
* priority of 2 will make the task receive two times more cpu than
* the other ones.
*
@@
-137,6
+137,15
@@
public class Task {
MsgNative.taskDestroy(this);
}
MsgNative.taskDestroy(this);
}
+
+ /** Send the task asynchronously on the mailbox identified by the specified name,
+ * with no way to retrieve whether the communication succeeded or not
+ *
+ */
+ public void dsend(String mailbox) {
+ MsgNative.taskDSend(mailbox, this);
+ }
+
/**
* Sends the task on the mailbox identified by the specified name
*
/**
* Sends the task on the mailbox identified by the specified name
*
@@
-175,7
+184,17
@@
public class Task {
public void sendBounded(String alias, double maxrate) throws TransferFailureException, HostFailureException, TimeoutException {
MsgNative.taskSendBounded(alias, this, maxrate);
}
public void sendBounded(String alias, double maxrate) throws TransferFailureException, HostFailureException, TimeoutException {
MsgNative.taskSendBounded(alias, this, maxrate);
}
-
+ /**
+ * Sends the task on the mailbox asynchronously
+ */
+ public native Comm isend(String mailbox);
+
+ /**
+ * Starts listening for receiving a task from an asynchronous communication
+ * @param mailbox
+ * @return
+ */
+ public static native Comm irecv(String mailbox);
/**
* Retrieves next task from the mailbox identified by the specified name
*
/**
* Retrieves next task from the mailbox identified by the specified name
*