/*
|
* %CopyrightBegin%
|
*
|
* Copyright Ericsson AB 2000-2009. All Rights Reserved.
|
*
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
* you may not use this file except in compliance with the License.
|
* You may obtain a copy of the License at
|
*
|
* http://www.apache.org/licenses/LICENSE-2.0
|
*
|
* Unless required by applicable law or agreed to in writing, software
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
* See the License for the specific language governing permissions and
|
* limitations under the License.
|
*
|
* %CopyrightEnd%
|
*/
|
package com.ericsson.otp.erlang;
|
|
/**
|
* This class represents local node types. It is used to group the node types
|
* {@link OtpNode OtpNode} and {@link OtpSelf OtpSelf}.
|
*/
|
public class OtpLocalNode extends AbstractNode {
|
protected int port;
|
protected OtpTransport epmd;
|
private int serial = 0;
|
private int pidCount = 1;
|
private int portCount = 1;
|
private int refId[];
|
|
/**
|
* Create a node with the given name and the default cookie.
|
*/
|
protected OtpLocalNode(final String node) {
|
super(node);
|
init();
|
}
|
|
/**
|
* Create a node with the given name, transport factory and the default
|
* cookie.
|
*/
|
protected OtpLocalNode(final String node,
|
final OtpTransportFactory transportFactory) {
|
super(node, transportFactory);
|
init();
|
}
|
|
/**
|
* Create a node with the given name and cookie.
|
*/
|
protected OtpLocalNode(final String node, final String cookie) {
|
super(node, cookie);
|
init();
|
}
|
|
/**
|
* Create a node with the given name, cookie and transport factory.
|
*/
|
protected OtpLocalNode(final String node, final String cookie,
|
final OtpTransportFactory transportFactory) {
|
super(node, cookie, transportFactory);
|
init();
|
}
|
|
private void init() {
|
serial = 0;
|
pidCount = 1;
|
portCount = 1;
|
refId = new int[3];
|
refId[0] = 1;
|
refId[1] = 0;
|
refId[2] = 0;
|
}
|
|
/**
|
* Get the port number used by this node.
|
*
|
* @return the port number this server node is accepting connections on.
|
*/
|
public int port() {
|
return port;
|
}
|
|
/**
|
* Get the Epmd socket.
|
*
|
* @return The socket connecting this node to Epmd.
|
*/
|
protected OtpTransport getEpmd() {
|
return epmd;
|
}
|
|
/**
|
* Set the Epmd socket after publishing this nodes listen port to Epmd.
|
*
|
* @param s The socket connecting this node to Epmd.
|
*/
|
protected void setEpmd(final OtpTransport s) {
|
epmd = s;
|
}
|
|
/**
|
* Create an Erlang {@link OtpErlangPid pid}. Erlang pids are based upon
|
* some node specific information; this method creates a pid using the
|
* information in this node. Each call to this method produces a unique pid.
|
*
|
* @return an Erlang pid.
|
*/
|
public synchronized OtpErlangPid createPid() {
|
final OtpErlangPid p = new OtpErlangPid(node, pidCount, serial,
|
creation);
|
pidCount++;
|
if (pidCount > 0x7fff) {
|
pidCount = 0;
|
serial++;
|
if (serial > 0x1fff) { /* 13 bits */
|
serial = 0;
|
}
|
}
|
return p;
|
}
|
|
/**
|
* Create an Erlang {@link OtpErlangPort port}. Erlang ports are based upon
|
* some node specific information; this method creates a port using the
|
* information in this node. Each call to this method produces a unique
|
* port. It may not be meaningful to create a port in a non-Erlang
|
* environment, but this method is provided for completeness.
|
*
|
* @return an Erlang port.
|
*/
|
public synchronized OtpErlangPort createPort() {
|
final OtpErlangPort p = new OtpErlangPort(node, portCount, creation);
|
portCount++;
|
if (portCount > 0xfffffff) { /* 28 bits */
|
portCount = 0;
|
}
|
return p;
|
}
|
|
/**
|
* Create an Erlang {@link OtpErlangRef reference}. Erlang references are
|
* based upon some node specific information; this method creates a
|
* reference using the information in this node. Each call to this method
|
* produces a unique reference.
|
*
|
* @return an Erlang reference.
|
*/
|
public synchronized OtpErlangRef createRef() {
|
final OtpErlangRef r = new OtpErlangRef(node, refId, creation);
|
// increment ref ids (3 ints: 18 + 32 + 32 bits)
|
refId[0]++;
|
if (refId[0] > 0x3ffff) {
|
refId[0] = 0;
|
refId[1]++;
|
if (refId[1] == 0) {
|
refId[2]++;
|
}
|
}
|
return r;
|
}
|
}
|
