Package org.opennars.main

Class NarNode

java.lang.Object

org.opennars.main.NarNode

All Implemented Interfaces:

EventEmitter.EventObserver

public class NarNode
extends Object
implements EventEmitter.EventObserver

Author:

Patrick Hammer

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	NarNode.EventReceivedTask
static class	NarNode.TargetNar

Field Summary

Fields

Modifier and Type	Field	Description
private int	listenPort
Nar	nar
private DatagramSocket	receiveSocket
private List<NarNode.TargetNar>	targets

Constructor Summary

Constructors

Constructor	Description
NarNode(int listenPort)	Create a Nar node that listens for received tasks from other NarNode instances
NarNode(Nar nar, int listenPort)

Method Summary

Modifier and Type	Method	Description
void	addRedirectionTo(String targetIP, int targetPort, float taskThreshold, Term mustContainTerm, boolean sendInput)	Add another target Nar node to redirect tasks to, and under which conditions.
void	addRedirectionTo(NarNode.TargetNar target)
void	event(Class event, Object[] args)	Input and derived tasks will be potentially sent
private Object	receiveObject()	NarNode's receiving a task or Narsese string
static void	sendNarsese(String input, String targetIP, int targetPort, float taskThreshold, Term mustContainTerm)
static void	sendNarsese(String input, NarNode.TargetNar target)	Send Narsese that contains the optional mustContainTerm
private void	sendTask(Task t)	Send tasks that are above priority threshold and contain the optional mustContainTerm

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

receiveSocket

private transient DatagramSocket receiveSocket

listenPort

private int listenPort

nar

public Nar nar

targets

private List<NarNode.TargetNar> targets

Constructor Detail

NarNode

public NarNode(int listenPort)
        throws SocketException,
               UnknownHostException,
               IOException,
               InstantiationException,
               InvocationTargetException,
               NoSuchMethodException,
               ParserConfigurationException,
               IllegalAccessException,
               SAXException,
               ClassNotFoundException,
               ParseException

Create a Nar node that listens for received tasks from other NarNode instances

Parameters:

listenPort -

Throws:

SocketException

UnknownHostException

IOException

InstantiationException

InvocationTargetException

NoSuchMethodException

ParserConfigurationException

IllegalAccessException

SAXException

ClassNotFoundException

ParseException

NarNode

public NarNode(Nar nar,
               int listenPort)
        throws SocketException,
               UnknownHostException,
               IOException,
               InstantiationException,
               InvocationTargetException,
               NoSuchMethodException,
               ParserConfigurationException,
               IllegalAccessException,
               SAXException,
               ClassNotFoundException,
               ParseException

Throws:

SocketException

UnknownHostException

IOException

InstantiationException

InvocationTargetException

NoSuchMethodException

ParserConfigurationException

IllegalAccessException

SAXException

ClassNotFoundException

ParseException

Method Detail

event

public void event(Class event,
                  Object[] args)

Input and derived tasks will be potentially sent

Specified by:

event in interface EventEmitter.EventObserver

Parameters:

event -

args -

sendTask

private void sendTask(Task t)
               throws IOException

Send tasks that are above priority threshold and contain the optional mustContainTerm

Parameters:

t -

Throws:

IOException

sendNarsese

public static void sendNarsese(String input,
                               NarNode.TargetNar target)
                        throws IOException

Send Narsese that contains the optional mustContainTerm

Parameters:

input -

target -

Throws:

IOException

sendNarsese

public static void sendNarsese(String input,
                               String targetIP,
                               int targetPort,
                               float taskThreshold,
                               Term mustContainTerm)
                        throws IOException

Throws:

IOException

addRedirectionTo

public void addRedirectionTo(String targetIP,
                             int targetPort,
                             float taskThreshold,
                             Term mustContainTerm,
                             boolean sendInput)
                      throws SocketException,
                             UnknownHostException

Add another target Nar node to redirect tasks to, and under which conditions.

Parameters:

targetIP - The target Nar node IP

targetPort - The target Nar node port

taskThreshold - The threshold the priority of the task has to have to redirect

mustContainTerm - The optional term that needs to be contained recursively in the task term

Throws:

SocketException

UnknownHostException

addRedirectionTo

public void addRedirectionTo(NarNode.TargetNar target)
                      throws SocketException,
                             UnknownHostException

Throws:

SocketException

UnknownHostException

receiveObject

private Object receiveObject()
                      throws IOException

NarNode's receiving a task or Narsese string

Returns:

the object received (Task, String)

Throws:

IOException - when can't receive packet