Package aleph.comm

Examples of aleph.comm.CommunicationManager.send()

221
222
223
224
225
226
227
228
229
230
231
      // Fill in peers, using handshake with parent
      synchronized (lock) {  // only the paranoid survive
        thisPE.group = null;
        Integer id = new Integer(Aleph.getIntProperty("aleph.group", 0));
        cManager.send(thisPE.parent, new PEGroup.AskParent(thisPE, id, thisPE.index));
        while (thisPE.group == null) {
          try {lock.wait();} catch (InterruptedException e) {}
        }
       
        Logger.fetal("PE started...");
View Full Code Here
276
277
278
279
280
281
282
283
284
285
286
   * @exception SecurityException If caller is not allowed to kill this server.
   **/
  public boolean stop (int code) throws SecurityException {
    try {
      CommunicationManager cManager = CommunicationManager.getManager();
      cManager.send(address, new HaltMessage(code));
      cManager.flush(address);
      return true;
    } catch (IOException e) { // timed out
      return false;
    } catch (Exception e) {
View Full Code Here
161
162
163
164
165
166
167
168
169
170
171
   * @param message what to display
   **/
  public static void warning (String message) {
    try {
      CommunicationManager cManager = CommunicationManager.getManager();
      cManager.send(cManager.getConsoleAddress(),
                    new Warning(message));
    } catch (Exception e) {
      Aleph.panic(e);
    }
  }
View Full Code Here
183
184
185
186
187
188
189
190
191
192
193
   * @param message what to display
   **/
  public static void error (String message) {
    try {
      CommunicationManager cManager = CommunicationManager.getManager();
      cManager.send(cManager.getConsoleAddress(),
                    new Error(message));
    } catch (Exception e) {
      Aleph.panic(e);
    }
  }
View Full Code Here
205
206
207
208
209
210
211
212
213
214
215
   * @param message what to display
   **/
  public static void inform (String message) {
    try {
      CommunicationManager cManager = CommunicationManager.getManager();
      cManager.send(cManager.getConsoleAddress(),
                    new Inform(message));
    } catch (Exception e) {
      Aleph.panic(e);
    }
  }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.