return this.name;
}
/** The arguments of the method function of the process. */
public Vector<String> args;
/* process synchronization tools */
return this.name;
}
/** The arguments of the method function of the process. */
public Vector<String> args;
/* process synchronization tools */
* @param args The arguments of the main function of the process.
*
* @exception HostNotFoundException if no host with this name exists.
* @param args The arguments of the main function of the process.
*
* @exception HostNotFoundException if no host with this name exists.
*
*/
public Process(String hostname, String name, String args[]) throws HostNotFoundException, NativeException {
*
*/
public Process(String hostname, String name, String args[]) throws HostNotFoundException, NativeException {
/**
* This method adds an argument in the list of the arguments of the main function
* of the process.
*
* @param arg The argument to add.
/**
* This method adds an argument in the list of the arguments of the main function
* of the process.
*
* @param arg The argument to add.
- public void migrate(Host host) {
- MsgNative.processChangeHost(this, host);
+ public static void migrate(Process process, Host host) {
+ MsgNative.processMigrate(process, host);
public static void waitFor(double seconds) throws HostFailureException {
MsgNative.processWaitFor(seconds);
}
public static void waitFor(double seconds) throws HostFailureException {
MsgNative.processWaitFor(seconds);
}
Msg.info("[" + this.name + "/" + this.getHost().getName() + "] argc=" +
this.args.size());
for (int i = 0; i < this.args.size(); i++)
Msg.info("[" + this.name + "/" + this.getHost().getName() + "] argc=" +
this.args.size());
for (int i = 0; i < this.args.size(); i++)
* @throws HostFailureException
* @throws TransferFailureException */
public void taskSend(String mailbox, Task task, double timeout) throws TransferFailureException, HostFailureException, TimeoutException {
* @throws HostFailureException
* @throws TransferFailureException */
public void taskSend(String mailbox, Task task, double timeout) throws TransferFailureException, HostFailureException, TimeoutException {
* @throws HostFailureException
* @throws TransferFailureException */
public void taskSend(String mailbox, Task task) throws TransferFailureException, HostFailureException, TimeoutException {
MsgNative.taskSend(mailbox, task, -1);
}
* @throws HostFailureException
* @throws TransferFailureException */
public void taskSend(String mailbox, Task task) throws TransferFailureException, HostFailureException, TimeoutException {
MsgNative.taskSend(mailbox, task, -1);
}
- /** Receive a task on mailbox associated with the specified mailbox */
+ /** Receive a task on mailbox associated with the specified mailbox
+ * @param mailbox
+ * @return
+ * @throws TransferFailureException
+ * @throws HostFailureException
+ * @throws TimeoutException
+ */
public Task taskReceive(String mailbox) throws TransferFailureException, HostFailureException, TimeoutException {
return MsgNative.taskReceive(mailbox, -1.0, null);
}
public Task taskReceive(String mailbox) throws TransferFailureException, HostFailureException, TimeoutException {
return MsgNative.taskReceive(mailbox, -1.0, null);
}
- /** Receive a task on mailbox associated with the specified alias (waiting at most given time) */
+ /** Receive a task on mailbox associated with the specified alias (waiting at most given time)
+ * @param mailbox
+ * @param timeout
+ * @return
+ * @throws TransferFailureException
+ * @throws HostFailureException
+ * @throws TimeoutException
+ */
public Task taskReceive(String mailbox, double timeout) throws TransferFailureException, HostFailureException, TimeoutException {
return MsgNative.taskReceive(mailbox, timeout, null);
}
public Task taskReceive(String mailbox, double timeout) throws TransferFailureException, HostFailureException, TimeoutException {
return MsgNative.taskReceive(mailbox, timeout, null);
}
- /** Receive a task on mailbox associated with the specified alias from given sender */
+ /** Receive a task on mailbox associated with the specified alias from given sender
+ * @param mailbox
+ * @param host
+ * @param timeout
+ * @return
+ * @throws TransferFailureException
+ * @throws HostFailureException
+ * @throws TimeoutException
+ */
public Task taskReceive(String mailbox, double timeout, Host host) throws TransferFailureException, HostFailureException, TimeoutException {
return MsgNative.taskReceive(mailbox, timeout, host);
}
public Task taskReceive(String mailbox, double timeout, Host host) throws TransferFailureException, HostFailureException, TimeoutException {
return MsgNative.taskReceive(mailbox, timeout, host);
}
- /** Receive a task on mailbox associated with the specified alias from given sender*/
+ /** Receive a task on mailbox associated with the specified alias from given sender
+ * @param mailbox
+ * @param host
+ * @return
+ * @throws TransferFailureException
+ * @throws HostFailureException
+ * @throws TimeoutException
+ */
public Task taskReceive(String mailbox, Host host) throws TransferFailureException, HostFailureException, TimeoutException {
return MsgNative.taskReceive(mailbox, -1.0, host);
}
public Task taskReceive(String mailbox, Host host) throws TransferFailureException, HostFailureException, TimeoutException {
return MsgNative.taskReceive(mailbox, -1.0, host);
}