The following document contains the results of PMD's CPD 3.7.
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\msg\command\TextLexer.java | 430 |
| org\fosstrak\reader\rprm\core\msg\reply\TextLexer.java | 144 |
else {throw new NoViableAltForCharException((char)LA(1), getFilename(), getLine(), getColumn());}
}
if ( _returnToken==null ) continue tryAgain; // found SKIP token
_ttype = _returnToken.getType();
_ttype = testLiteralsTable(_ttype);
_returnToken.setType(_ttype);
return _returnToken;
}
catch (RecognitionException e) {
throw new TokenStreamRecognitionException(e);
}
}
catch (CharStreamException cse) {
if ( cse instanceof CharStreamIOException ) {
throw new TokenStreamIOException(((CharStreamIOException)cse).io);
}
else {
throw new TokenStreamException(cse.getMessage());
}
}
}
}
public final void mWS(boolean _createToken) throws RecognitionException, CharStreamException, TokenStreamException {
int _ttype; Token _token=null; int _begin=text.length();
_ttype = WS;
int _saveIndex;
{
switch ( LA(1)) {
case ' ':
{
match(' ');
break;
}
case '\t':
{
match('\t');
break;
}
default:
{
throw new NoViableAltForCharException((char)LA(1), getFilename(), getLine(), getColumn());
}
}
}
_ttype = Token.SKIP;
if ( _createToken && _token==null && _ttype!=Token.SKIP ) {
_token = makeToken(_ttype);
_token.setText(new String(text.getBuffer(), _begin, text.length()-_begin));
}
_returnToken = _token;
}
public final void mLF(boolean _createToken) throws RecognitionException, CharStreamException, TokenStreamException {
int _ttype; Token _token=null; int _begin=text.length();
_ttype = LF;
int _saveIndex;
{
if ((LA(1)=='\r') && (LA(2)=='\n')) {
match("\r\n");
}
else if ((LA(1)=='\r') && (true)) {
match('\r');
}
else if ((LA(1)=='\n')) {
match('\n');
}
else {
throw new NoViableAltForCharException((char)LA(1), getFilename(), getLine(), getColumn());
}
}
newline();
if ( _createToken && _token==null && _ttype!=Token.SKIP ) {
_token = makeToken(_ttype);
_token.setText(new String(text.getBuffer(), _begin, text.length()-_begin));
}
_returnToken = _token;
}
public final void mSHARP(boolean _createToken) throws RecognitionException, CharStreamException, TokenStreamException {
int _ttype; Token _token=null; int _begin=text.length();
_ttype = SHARP;
int _saveIndex;
match("#");
if ( _createToken && _token==null && _ttype!=Token.SKIP ) {
_token = makeToken(_ttype);
_token.setText(new String(text.getBuffer(), _begin, text.length()-_begin));
}
_returnToken = _token;
}
public final void mDOT(boolean _createToken) throws RecognitionException, CharStreamException, TokenStreamException {
int _ttype; Token _token=null; int _begin=text.length();
_ttype = DOT;
int _saveIndex;
match(".");
if ( _createToken && _token==null && _ttype!=Token.SKIP ) {
_token = makeToken(_ttype);
_token.setText(new String(text.getBuffer(), _begin, text.length()-_begin));
}
_returnToken = _token;
}
public final void mEXCLAMATION(boolean _createToken) throws RecognitionException, CharStreamException, TokenStreamException {
int _ttype; Token _token=null; int _begin=text.length();
_ttype = EXCLAMATION;
int _saveIndex;
match("!");
if ( _createToken && _token==null && _ttype!=Token.SKIP ) {
_token = makeToken(_ttype);
_token.setText(new String(text.getBuffer(), _begin, text.length()-_begin));
}
_returnToken = _token;
}
public final void mCOMMA(boolean _createToken) throws RecognitionException, CharStreamException, TokenStreamException {
int _ttype; Token _token=null; int _begin=text.length();
_ttype = COMMA;
int _saveIndex;
match(","); | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\NotificationChannel.java | 502 |
| org\fosstrak\reader\rprm\core\Source.java | 816 |
if (readTriggers.containsKey(cur.getName())) {
if (cur.getType().equals(TriggerType.CONTINUOUS)) {
// continuous trigger
continuousThread.stop();
continuousThread = null;
} else if (cur.getType().equals(TriggerType.TIMER)) {
// timer trigger
if (timerThreads.containsKey(cur.getName())) {
Timer t = (Timer) timerThreads.get(cur.getName());
t.cancel();
timerThreads.remove(cur.getName());
}
} else if (cur.getType().equals(TriggerType.IO_EDGE)) {
// io edge trigger
// get port
final int num = 6;
String port = cur.getValue().substring(
cur.getValue().indexOf(';') + num,
cur.getValue().lastIndexOf(';'));
if (readerDevice.getEdgeTriggers().containsKey(port)) {
IOEdgeTriggerPortManager manager =
(IOEdgeTriggerPortManager) readerDevice
.getEdgeTriggers().get(port);
manager.removeListener(cur, this.getName());
if (manager.getNumberOfTriggers() <= 0) {
manager.stop();
}
}
} else if (cur.getType().equals(TriggerType.IO_VALUE)) {
// io value trigger
// get port
final int num = 5;
String port = cur.getValue().substring(num,
cur.getValue().indexOf(';'));
if (readerDevice.getValueTriggers().containsKey(port)) {
IOValueTriggerPortManager manager =
(IOValueTriggerPortManager) readerDevice
.getValueTriggers().get(port);
manager.removeListener(cur, this.getName());
if (manager.getNumberOfTriggers() <= 0) {
manager.stop();
}
}
}
this.readTriggers.remove(cur.getName()); | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\msg\command\TextLexer.java | 647 |
| org\fosstrak\reader\rprm\core\msg\reply\TextLexer.java | 521 |
matchRange(' ','~');
}
if ( _createToken && _token==null && _ttype!=Token.SKIP ) {
_token = makeToken(_ttype);
_token.setText(new String(text.getBuffer(), _begin, text.length()-_begin));
}
_returnToken = _token;
}
public final void mIDENT(boolean _createToken) throws RecognitionException, CharStreamException, TokenStreamException {
int _ttype; Token _token=null; int _begin=text.length();
_ttype = IDENT;
int _saveIndex;
{
switch ( LA(1)) {
case 'A': case 'B': case 'C': case 'D':
case 'E': case 'F': case 'G': case 'H':
case 'I': case 'J': case 'K': case 'L':
case 'M': case 'N': case 'O': case 'P':
case 'Q': case 'R': case 'S': case 'T':
case 'U': case 'V': case 'W': case 'X':
case 'Y': case 'Z':
{
matchRange('A','Z');
break;
}
case 'a': case 'b': case 'c': case 'd':
case 'e': case 'f': case 'g': case 'h':
case 'i': case 'j': case 'k': case 'l':
case 'm': case 'n': case 'o': case 'p':
case 'q': case 'r': case 's': case 't':
case 'u': case 'v': case 'w': case 'x':
case 'y': case 'z':
{
matchRange('a','z');
break;
}
default:
{
throw new NoViableAltForCharException((char)LA(1), getFilename(), getLine(), getColumn());
}
}
}
{ | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\NotificationChannel.java | 433 |
| org\fosstrak\reader\rprm\core\Source.java | 748 |
timerThread.schedule(new TimerReadThread(this, cur), 0,
Integer.parseInt(cur.getValue().substring(num)));
}
} else if (cur.getType().equals(TriggerType.IO_EDGE)) {
// io edge trigger
if (continuousThread == null) {
// get port
final int num = 6;
String port = cur.getValue().substring(
cur.getValue().indexOf(';') + num,
cur.getValue().lastIndexOf(';'));
if (readerDevice.getEdgeTriggers().containsKey(port)) {
IOEdgeTriggerPortManager manager =
(IOEdgeTriggerPortManager) readerDevice
.getEdgeTriggers().get(port);
manager.addListener(cur, this.getName());
if (manager.getNumberOfTriggers() == 1) {
manager.start();
}
} else {
throw new ReaderProtocolException(
"no trigger manager available",
MessagingConstants.ERROR_UNKNOWN);
}
}
} else if (cur.getType().equals(TriggerType.IO_VALUE)) {
// io value trigger
if (continuousThread == null) {
// get port
final int num = 5;
String port = cur.getValue().substring(num,
cur.getValue().indexOf(';'));
if (readerDevice.getValueTriggers().containsKey(port)) {
IOValueTriggerPortManager manager =
(IOValueTriggerPortManager) readerDevice
.getValueTriggers().get(port);
manager.addListener(cur, this.getName());
if (manager.getNumberOfTriggers() == 1) {
manager.start();
}
} else {
throw new ReaderProtocolException(
"no trigger manager available",
MessagingConstants.ERROR_UNKNOWN);
}
}
}
}
}
}
/**
* Remove a list of read triggers.
* @param triggerList
* The list of read triggers
*/
public void removeReadTriggers(final Trigger[] triggerList) { | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\mgmt\agent\snmp\mib\IfMib.java | 841 |
| org\fosstrak\reader\rprm\core\mgmt\agent\snmp\mib\IfMib.java | 874 |
public void linkUp(NotificationOriginator notificationOriginator,
OctetString context, VariableBinding[] vbs) {
if (vbs.length < 3) {
throw new IllegalArgumentException("Too few notification objects: "+
vbs.length+"<3");
}
if (!(vbs[0].getOid().startsWith(oidTrapVarIfIndex))) {
throw new IllegalArgumentException("Variable 0 has wrong OID: "+vbs[0].getOid()+
" does not start with "+oidTrapVarIfIndex);
}
if (!ifEntryIndex.isValidIndex(ifEntry.getIndexPart(vbs[0].getOid()))) {
throw new IllegalArgumentException("Illegal index for variable 0 specified: "+
ifEntry.getIndexPart(vbs[0].getOid()));
}
if (!(vbs[1].getOid().startsWith(oidTrapVarIfAdminStatus))) {
throw new IllegalArgumentException("Variable 1 has wrong OID: "+vbs[1].getOid()+
" does not start with "+oidTrapVarIfAdminStatus);
}
if (!ifEntryIndex.isValidIndex(ifEntry.getIndexPart(vbs[1].getOid()))) {
throw new IllegalArgumentException("Illegal index for variable 1 specified: "+
ifEntry.getIndexPart(vbs[1].getOid()));
}
if (!(vbs[2].getOid().startsWith(oidTrapVarIfOperStatus))) {
throw new IllegalArgumentException("Variable 2 has wrong OID: "+vbs[2].getOid()+
" does not start with "+oidTrapVarIfOperStatus);
}
if (!ifEntryIndex.isValidIndex(ifEntry.getIndexPart(vbs[2].getOid()))) {
throw new IllegalArgumentException("Illegal index for variable 2 specified: "+
ifEntry.getIndexPart(vbs[2].getOid()));
}
notificationOriginator.notify(context, oidLinkUp, vbs); | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\msg\command\TagType.java | 74 |
| org\fosstrak\reader\rprm\core\msg\reply\TagType.java | 74 |
@XmlAccessorType(XmlAccessType.FIELD)
@XmlType(name = "TagType", propOrder = {
"tagID",
"tagIDAsPureURI",
"tagIDAsTagURI",
"tagType",
"tagEvent",
"tagFields",
"any"
})
public class TagType {
@XmlElement(type = String.class)
@XmlJavaTypeAdapter(HexBinaryAdapter.class)
protected byte[] tagID;
protected String tagIDAsPureURI;
protected String tagIDAsTagURI;
protected String tagType;
protected List<TagEventType> tagEvent;
protected List<TagFieldValueParamType> tagFields;
@XmlAnyElement(lax = true)
protected List<Object> any;
/**
* Gets the value of the tagID property.
*
* @return
* possible object is
* {@link String }
*
*/
public byte[] getTagID() {
return tagID;
}
/**
* Sets the value of the tagID property.
*
* @param value
* allowed object is
* {@link String }
*
*/
public void setTagID(byte[] value) {
this.tagID = ((byte[]) value);
}
/**
* Gets the value of the tagIDAsPureURI property.
*
* @return
* possible object is
* {@link String }
*
*/
public String getTagIDAsPureURI() {
return tagIDAsPureURI;
}
/**
* Sets the value of the tagIDAsPureURI property.
*
* @param value
* allowed object is
* {@link String }
*
*/
public void setTagIDAsPureURI(String value) {
this.tagIDAsPureURI = value;
}
/**
* Gets the value of the tagIDAsTagURI property.
*
* @return
* possible object is
* {@link String }
*
*/
public String getTagIDAsTagURI() {
return tagIDAsTagURI;
}
/**
* Sets the value of the tagIDAsTagURI property.
*
* @param value
* allowed object is
* {@link String }
*
*/
public void setTagIDAsTagURI(String value) {
this.tagIDAsTagURI = value;
}
/**
* Gets the value of the tagType property.
*
* @return
* possible object is
* {@link String }
*
*/
public String getTagType() {
return tagType;
}
/**
* Sets the value of the tagType property.
*
* @param value
* allowed object is
* {@link String }
*
*/
public void setTagType(String value) {
this.tagType = value;
}
/**
* Gets the value of the tagEvent property.
*
* <p>
* This accessor method returns a reference to the live list,
* not a snapshot. Therefore any modification you make to the
* returned list will be present inside the JAXB object.
* This is why there is not a <CODE>set</CODE> method for the tagEvent property.
*
* <p>
* For example, to add a new item, do as follows:
* <pre>
* getTagEvent().add(newItem);
* </pre>
*
*
* <p>
* Objects of the following type(s) are allowed in the list
* {@link TagEventType }
*
*
*/
public List<TagEventType> getTagEvent() {
if (tagEvent == null) {
tagEvent = new ArrayList<TagEventType>();
}
return this.tagEvent;
}
/**
* Gets the value of the tagFields property.
*
* <p>
* This accessor method returns a reference to the live list,
* not a snapshot. Therefore any modification you make to the
* returned list will be present inside the JAXB object.
* This is why there is not a <CODE>set</CODE> method for the tagFields property.
*
* <p>
* For example, to add a new item, do as follows:
* <pre>
* getTagFields().add(newItem);
* </pre>
*
*
* <p>
* Objects of the following type(s) are allowed in the list
* {@link TagFieldValueParamType }
*
*
*/
public List<TagFieldValueParamType> getTagFields() {
if (tagFields == null) {
tagFields = new ArrayList<TagFieldValueParamType>();
}
return this.tagFields;
}
/**
* Gets the value of the any property.
*
* <p>
* This accessor method returns a reference to the live list,
* not a snapshot. Therefore any modification you make to the
* returned list will be present inside the JAXB object.
* This is why there is not a <CODE>set</CODE> method for the any property.
*
* <p>
* For example, to add a new item, do as follows:
* <pre>
* getAny().add(newItem);
* </pre>
*
*
* <p>
* Objects of the following type(s) are allowed in the list
* {@link Element }
* {@link Object }
*
*
*/
public List<Object> getAny() {
if (any == null) {
any = new ArrayList<Object>();
}
return this.any;
}
} | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\msg\command\ReadReportType.java | 85 |
| org\fosstrak\reader\rprm\core\msg\notification\ReadReportType.java | 85 |
@XmlAccessorType(XmlAccessType.FIELD)
@XmlType(name = "ReadReportType", propOrder = {
"tag",
"sourceReport",
"any"
})
public class ReadReportType {
protected List<TagType> tag;
protected List<SourceReport> sourceReport;
@XmlAnyElement(lax = true)
protected List<Object> any;
/**
* Gets the value of the tag property.
*
* <p>
* This accessor method returns a reference to the live list,
* not a snapshot. Therefore any modification you make to the
* returned list will be present inside the JAXB object.
* This is why there is not a <CODE>set</CODE> method for the tag property.
*
* <p>
* For example, to add a new item, do as follows:
* <pre>
* getTag().add(newItem);
* </pre>
*
*
* <p>
* Objects of the following type(s) are allowed in the list
* {@link TagType }
*
*
*/
public List<TagType> getTag() {
if (tag == null) {
tag = new ArrayList<TagType>();
}
return this.tag;
}
/**
* Gets the value of the sourceReport property.
*
* <p>
* This accessor method returns a reference to the live list,
* not a snapshot. Therefore any modification you make to the
* returned list will be present inside the JAXB object.
* This is why there is not a <CODE>set</CODE> method for the sourceReport property.
*
* <p>
* For example, to add a new item, do as follows:
* <pre>
* getSourceReport().add(newItem);
* </pre>
*
*
* <p>
* Objects of the following type(s) are allowed in the list
* {@link SourceReport }
*
*
*/
public List<SourceReport> getSourceReport() {
if (sourceReport == null) {
sourceReport = new ArrayList<SourceReport>();
}
return this.sourceReport;
}
/**
* Gets the value of the any property.
*
* <p>
* This accessor method returns a reference to the live list,
* not a snapshot. Therefore any modification you make to the
* returned list will be present inside the JAXB object.
* This is why there is not a <CODE>set</CODE> method for the any property.
*
* <p>
* For example, to add a new item, do as follows:
* <pre>
* getAny().add(newItem);
* </pre>
*
*
* <p>
* Objects of the following type(s) are allowed in the list
* {@link Element }
* {@link Object }
*
*
*/
public List<Object> getAny() {
if (any == null) {
any = new ArrayList<Object>();
}
return this.any;
}
/**
* <p>Java class for anonymous complex type.
*
* <p>The following schema fragment specifies the expected content contained within this class.
*
* <pre>
* <complexType>
* <complexContent>
* <restriction base="{http://www.w3.org/2001/XMLSchema}anyType">
* <sequence>
* <element name="sourceInfo" type="{urn:epcglobal:rp:xsd:1}SourceInfoType"/>
* <element name="tag" type="{urn:epcglobal:rp:xsd:1}TagType" maxOccurs="unbounded" minOccurs="0"/>
* <any/>
* </sequence>
* </restriction>
* </complexContent>
* </complexType>
* </pre>
*
*
*/
@XmlAccessorType(XmlAccessType.FIELD)
@XmlType(name = "", propOrder = {
"sourceInfo",
"tag",
"any"
})
public static class SourceReport {
protected SourceInfoType sourceInfo;
protected List<TagType> tag;
@XmlAnyElement(lax = true)
protected List<Object> any;
/**
* Gets the value of the sourceInfo property.
*
* @return
* possible object is
* {@link SourceInfoType }
*
*/
public SourceInfoType getSourceInfo() {
return sourceInfo;
}
/**
* Sets the value of the sourceInfo property.
*
* @param value
* allowed object is
* {@link SourceInfoType }
*
*/
public void setSourceInfo(SourceInfoType value) {
this.sourceInfo = value;
}
/**
* Gets the value of the tag property.
*
* <p>
* This accessor method returns a reference to the live list,
* not a snapshot. Therefore any modification you make to the
* returned list will be present inside the JAXB object.
* This is why there is not a <CODE>set</CODE> method for the tag property.
*
* <p>
* For example, to add a new item, do as follows:
* <pre>
* getTag().add(newItem);
* </pre>
*
*
* <p>
* Objects of the following type(s) are allowed in the list
* {@link TagType }
*
*
*/
public List<TagType> getTag() {
if (tag == null) {
tag = new ArrayList<TagType>();
}
return this.tag;
}
/**
* Gets the value of the any property.
*
* <p>
* This accessor method returns a reference to the live list,
* not a snapshot. Therefore any modification you make to the
* returned list will be present inside the JAXB object.
* This is why there is not a <CODE>set</CODE> method for the any property.
*
* <p>
* For example, to add a new item, do as follows:
* <pre>
* getAny().add(newItem);
* </pre>
*
*
* <p>
* Objects of the following type(s) are allowed in the list
* {@link Element }
* {@link Object }
*
*
*/
public List<Object> getAny() {
if (any == null) {
any = new ArrayList<Object>();
}
return this.any;
}
}
} | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\msg\command\TextLexer.java | 692 |
| org\fosstrak\reader\rprm\core\msg\reply\TextLexer.java | 566 |
_loop876:
do {
switch ( LA(1)) {
case 'A': case 'B': case 'C': case 'D':
case 'E': case 'F': case 'G': case 'H':
case 'I': case 'J': case 'K': case 'L':
case 'M': case 'N': case 'O': case 'P':
case 'Q': case 'R': case 'S': case 'T':
case 'U': case 'V': case 'W': case 'X':
case 'Y': case 'Z':
{
matchRange('A','Z');
break;
}
case 'a': case 'b': case 'c': case 'd':
case 'e': case 'f': case 'g': case 'h':
case 'i': case 'j': case 'k': case 'l':
case 'm': case 'n': case 'o': case 'p':
case 'q': case 'r': case 's': case 't':
case 'u': case 'v': case 'w': case 'x':
case 'y': case 'z':
{
matchRange('a','z');
break;
}
case '0': case '1': case '2': case '3':
case '4': case '5': case '6': case '7':
case '8': case '9':
{
matchRange('0','9');
break;
}
default:
{
break _loop876; | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\msg\command\TextLexer.java | 661 |
| org\fosstrak\reader\rprm\core\msg\command\TextLexer.java | 693 |
do {
switch ( LA(1)) {
case 'A': case 'B': case 'C': case 'D':
case 'E': case 'F': case 'G': case 'H':
case 'I': case 'J': case 'K': case 'L':
case 'M': case 'N': case 'O': case 'P':
case 'Q': case 'R': case 'S': case 'T':
case 'U': case 'V': case 'W': case 'X':
case 'Y': case 'Z':
{
matchRange('A','Z');
break;
}
case 'a': case 'b': case 'c': case 'd':
case 'e': case 'f': case 'g': case 'h':
case 'i': case 'j': case 'k': case 'l':
case 'm': case 'n': case 'o': case 'p':
case 'q': case 'r': case 's': case 't':
case 'u': case 'v': case 'w': case 'x':
case 'y': case 'z':
{
matchRange('a','z');
break;
} | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\msg\command\TextLexer.java | 608 |
| org\fosstrak\reader\rprm\core\msg\reply\TextLexer.java | 340 |
match(">");
if ( _createToken && _token==null && _ttype!=Token.SKIP ) {
_token = makeToken(_ttype);
_token.setText(new String(text.getBuffer(), _begin, text.length()-_begin));
}
_returnToken = _token;
}
protected final void mDIGIT(boolean _createToken) throws RecognitionException, CharStreamException, TokenStreamException {
int _ttype; Token _token=null; int _begin=text.length();
_ttype = DIGIT;
int _saveIndex;
matchRange('0','9');
if ( _createToken && _token==null && _ttype!=Token.SKIP ) {
_token = makeToken(_ttype);
_token.setText(new String(text.getBuffer(), _begin, text.length()-_begin));
}
_returnToken = _token;
}
public final void mINT(boolean _createToken) throws RecognitionException, CharStreamException, TokenStreamException {
int _ttype; Token _token=null; int _begin=text.length();
_ttype = INT;
int _saveIndex;
{ | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\msg\command\TagEventType.java | 75 |
| org\fosstrak\reader\rprm\core\msg\notification\TagEventType.java | 75 |
@XmlAccessorType(XmlAccessType.FIELD)
@XmlType(name = "TagEventType", propOrder = {
"eventType",
"eventTriggers",
"time"
})
public class TagEventType {
protected String eventType;
protected EventTriggers eventTriggers;
protected EventTimeType time;
/**
* Gets the value of the eventType property.
*
* @return
* possible object is
* {@link String }
*
*/
public String getEventType() {
return eventType;
}
/**
* Sets the value of the eventType property.
*
* @param value
* allowed object is
* {@link String }
*
*/
public void setEventType(String value) {
this.eventType = value;
}
/**
* Gets the value of the eventTriggers property.
*
* @return
* possible object is
* {@link EventTriggers }
*
*/
public EventTriggers getEventTriggers() {
return eventTriggers;
}
/**
* Sets the value of the eventTriggers property.
*
* @param value
* allowed object is
* {@link EventTriggers }
*
*/
public void setEventTriggers(EventTriggers value) {
this.eventTriggers = value;
}
/**
* Gets the value of the time property.
*
* @return
* possible object is
* {@link EventTimeType }
*
*/
public EventTimeType getTime() {
return time;
}
/**
* Sets the value of the time property.
*
* @param value
* allowed object is
* {@link EventTimeType }
*
*/
public void setTime(EventTimeType value) {
this.time = value;
}
/**
* <p>Java class for anonymous complex type.
*
* <p>The following schema fragment specifies the expected content contained within this class.
*
* <pre>
* <complexType>
* <complexContent>
* <restriction base="{http://www.w3.org/2001/XMLSchema}anyType">
* <sequence>
* <element name="trigger" type="{urn:epcglobal:rp:xsd:1}TriggerParamType" maxOccurs="unbounded"/>
* </sequence>
* </restriction>
* </complexContent>
* </complexType>
* </pre>
*
*
*/
@XmlAccessorType(XmlAccessType.FIELD)
@XmlType(name = "", propOrder = {
"trigger"
})
public static class EventTriggers {
protected List<String> trigger;
/**
* Gets the value of the trigger property.
*
* <p>
* This accessor method returns a reference to the live list,
* not a snapshot. Therefore any modification you make to the
* returned list will be present inside the JAXB object.
* This is why there is not a <CODE>set</CODE> method for the trigger property.
*
* <p>
* For example, to add a new item, do as follows:
* <pre>
* getTrigger().add(newItem);
* </pre>
*
*
* <p>
* Objects of the following type(s) are allowed in the list
* {@link String }
*
*
*/
public List<String> getTrigger() {
if (trigger == null) {
trigger = new ArrayList<String>();
}
return this.trigger;
}
}
} | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\msg\command\SourceInfoType.java | 65 |
| org\fosstrak\reader\rprm\core\msg\notification\SourceInfoType.java | 65 |
@XmlAccessorType(XmlAccessType.FIELD)
@XmlType(name = "SourceInfoType", propOrder = {
"sourceName",
"sourceFrequency",
"sourceProtocol",
"any"
})
public class SourceInfoType {
protected String sourceName;
protected String sourceFrequency;
protected String sourceProtocol;
@XmlAnyElement(lax = true)
protected List<Object> any;
/**
* Gets the value of the sourceName property.
*
* @return
* possible object is
* {@link String }
*
*/
public String getSourceName() {
return sourceName;
}
/**
* Sets the value of the sourceName property.
*
* @param value
* allowed object is
* {@link String }
*
*/
public void setSourceName(String value) {
this.sourceName = value;
}
/**
* Gets the value of the sourceFrequency property.
*
* @return
* possible object is
* {@link String }
*
*/
public String getSourceFrequency() {
return sourceFrequency;
}
/**
* Sets the value of the sourceFrequency property.
*
* @param value
* allowed object is
* {@link String }
*
*/
public void setSourceFrequency(String value) {
this.sourceFrequency = value;
}
/**
* Gets the value of the sourceProtocol property.
*
* @return
* possible object is
* {@link String }
*
*/
public String getSourceProtocol() {
return sourceProtocol;
}
/**
* Sets the value of the sourceProtocol property.
*
* @param value
* allowed object is
* {@link String }
*
*/
public void setSourceProtocol(String value) {
this.sourceProtocol = value;
}
/**
* Gets the value of the any property.
*
* <p>
* This accessor method returns a reference to the live list,
* not a snapshot. Therefore any modification you make to the
* returned list will be present inside the JAXB object.
* This is why there is not a <CODE>set</CODE> method for the any property.
*
* <p>
* For example, to add a new item, do as follows:
* <pre>
* getAny().add(newItem);
* </pre>
*
*
* <p>
* Objects of the following type(s) are allowed in the list
* {@link Object }
*
*
*/
public List<Object> getAny() {
if (any == null) {
any = new ArrayList<Object>();
}
return this.any;
}
} | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\msg\transport\HttpServerConnection.java | 67 |
| org\fosstrak\reader\rprm\core\msg\transport\TCPServerConnection.java | 71 |
public TCPServerConnection(final IncomingMessageListener listener) {
this.listener = listener;
connections = new Vector();
log = Logger.getLogger(getClass().getName());
}
/** Creates a separate client thread which processes client messages. */
protected void createServerThread() {
serverThread = new Thread(this);
serverThread.start();
}
/**
*
* @see org.fosstrak.reader.rprm.core.msg.transport.Connection#open()
*/
public void open(int port) {
isOpen = true;
try {
log.debug("Trying to open port " + port);
serverSocket = new ServerSocket(port);
this.port = port;
} catch (IOException e) {
log.error("Could not listen on port: " + port + ".");
log.error(e.getMessage());
}
createServerThread();
}
public void run() {
while (isOpen) {
log.debug("Listening to port " + port);
try {
//
// The accept method waits until a client starts up and
// requests a connection on the host and port of this server.
// When a connection is requested and successfully established,
// the accept method returns a new Socket object which is bound
// to a new port.
//
Socket clientSocket = serverSocket.accept();
Connection clientConnection = new TCPConnection(clientSocket); | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\mgmt\agent\snmp\mib\EpcglobalReaderMib.java | 3299 |
| org\fosstrak\reader\rprm\core\mgmt\agent\snmp\mib\EpcglobalReaderMib.java | 3492 |
EpcgRdrDevMemStateSuppressInterval(OID oid, MOAccess access) {
super(oid, access, new UnsignedInteger32());
//--AgentGen BEGIN=epcgRdrDevMemStateSuppressInterval
//--AgentGen END
}
public int isValueOK(SubRequest request) {
Variable newValue =
request.getVariableBinding().getVariable();
int valueOK = super.isValueOK(request);
if (valueOK != SnmpConstants.SNMP_ERROR_SUCCESS) {
return valueOK;
}
long v = ((UnsignedInteger32)newValue).getValue();
if (!(((v >= 0L) && (v <= 0L)) ||
((v >= 1L) && (v <= 3600L)))) {
valueOK = SnmpConstants.SNMP_ERROR_WRONG_VALUE;
}
//--AgentGen BEGIN=epcgRdrDevMemStateSuppressInterval::isValueOK
//--AgentGen END
return valueOK;
}
public Variable getValue() {
//--AgentGen BEGIN=epcgRdrDevMemStateSuppressInterval::getValue
//--AgentGen END
return super.getValue();
}
public int setValue(Variable newValue) {
//--AgentGen BEGIN=epcgRdrDevMemStateSuppressInterval::setValue
//--AgentGen END
return super.setValue(newValue);
}
//--AgentGen BEGIN=epcgRdrDevMemStateSuppressInterval::_METHODS
//--AgentGen END
} | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\msg\TextMessageSerializer.java | 410 |
| org\fosstrak\reader\rprm\core\msg\TextMessageSerializer.java | 522 |
org.fosstrak.reader.rprm.core.msg.notification.TagEventType tagEvent = (org.fosstrak.reader.rprm.core.msg.notification.TagEventType) tagEventIt
.next();
if (tagEvent.getEventType() != null) {
reportAttributes.add(tagEvent.getEventType());
}
if (tagEvent.getTime() != null
&& tagEvent.getTime().getEventTimeTick() != null) {
reportAttributes.add(tagEvent.getTime()
.getEventTimeTick());
} else if (tagEvent.getTime() != null
&& tagEvent.getTime().getEventTimeUTC() != null) {
reportAttributes.add(toISO8601(xmlGregorianCalendarToCalendar(tagEvent.getTime().getEventTimeUTC())));
}
// TODO: Should we really report the event triggers???
// if (tagEvent.getEventTriggers() != null &&
// tagEvent.getEventTriggers().getTrigger() != null) {
// //add all the trigger names
// org.fosstrak.reader.msg.notification.EventTriggersType
// eventTrigger = tagEvent.getEventTriggers();
// Iterator eventTriggerIt =
// eventTrigger.getTrigger().iterator();
// while(eventTriggerIt.hasNext()) {
// String triggerName = (String)eventTriggerIt.next();
// reportAttributes.add(triggerName);
// }
// }
}
}
// --- Add the tag fields ---
if (tag.getTagFields() != null) {
Iterator tagFieldIt = tag.getTagFields().iterator();
while (tagFieldIt.hasNext()) { | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\Source.java | 1116 |
| org\fosstrak\reader\rprm\core\Source.java | 1361 |
tempObservations = rd.identify(arpaa);
for (int i = 0; i < tempObservations.length; i++) {
Observation observation = tempObservations[i];
if (observation.successful) {
allObservations.add(tempObservations[i]);
} else {
ReadPoint readPoint = (ReadPoint) readPoints.get(observation.getReadPointName());
if (readPoint instanceof AntennaReadPoint) {
((AntennaReadPoint) readPoint).increaseFailedIdentificationCount();
}
}
}
} catch (HardwareException he) {
log.error(he.getMessage());
}
}
// event part !
// observed tags
Enumeration observationIterator = allObservations.elements();
Observation curObservation;
while (observationIterator.hasMoreElements()) {
curObservation = (Observation) observationIterator.nextElement();
// tags
for (int i = 0; i < curObservation.getIds().length; i++) { | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\mgmt\agent\snmp\mib\EpcglobalReaderMib.java | 2696 |
| org\fosstrak\reader\rprm\core\mgmt\agent\snmp\mib\EpcglobalReaderMib.java | 2892 |
" does not start with "+oidTrapVarEpcgAntRdPntLockFailuresNotifLevel);
}
if (!epcgAntReadPointEntryIndex.isValidIndex(epcgAntReadPointEntry.getIndexPart(vbs[2].getOid()))) {
throw new IllegalArgumentException("Illegal index for variable 2 specified: "+
epcgAntReadPointEntry.getIndexPart(vbs[2].getOid()));
}
if (!(vbs[3].getOid().startsWith(oidTrapVarEpcgReadPointName))) {
throw new IllegalArgumentException("Variable 3 has wrong OID: "+vbs[3].getOid()+
" does not start with "+oidTrapVarEpcgReadPointName);
}
if (!epcgReadPointEntryIndex.isValidIndex(epcgReadPointEntry.getIndexPart(vbs[3].getOid()))) {
throw new IllegalArgumentException("Illegal index for variable 3 specified: "+
epcgReadPointEntry.getIndexPart(vbs[3].getOid()));
}
if (!(vbs[4].getOid().startsWith(oidTrapVarEpcgAntRdPntLockFailures))) { | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\mgmt\agent\snmp\table\EpcgIoPortTableRow.java | 77 |
| org\fosstrak\reader\rprm\core\mgmt\agent\snmp\table\EpcgTriggerTableRow.java | 84 |
SnmpTable table = (SnmpTable)SnmpUtil.getSnmpTable(TableTypeEnum.EPCG_TRIGGER_TABLE);
Vector<OID> indices = table.getSortedIndices();
Enumeration<OID> elements = indices.elements();
while (elements.hasMoreElements()) {
OID tempIndex = elements.nextElement().nextPeer();
if (!indices.contains(tempIndex)) return tempIndex;
}
return new OID("1");
}
/**
* Gets the value at the specified column index.
*
* @param column
* The (zero-based) column index
* @return The value at the specified index
*/
@Override
public Variable getValue(int column) {
boolean refresh = ((System.currentTimeMillis() - lastRefreshTimes[column]) > refreshTimeInMs);
if (refresh) {
log.debug("refreshing row " + index.toString());
lastRefreshTimes[column] = System.currentTimeMillis();
} else {
log.debug("no need to refresh row " + index.toString());
}
switch (column) {
case EpcglobalReaderMib.idxEpcgTrigName: | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\Source.java | 1110 |
| org\fosstrak\reader\rprm\core\Source.java | 1206 |
Enumeration closureIterator = closure.elements();
ReaderAndReadPoints curClosure;
while (closureIterator.hasMoreElements()) {
curClosure = (ReaderAndReadPoints) closureIterator.nextElement();
try {
tempObservations = curClosure.getReader().identify(curClosure.getAllReadPointsAsArray());
for (int i = 0; i < tempObservations.length; i++) {
Observation observation = tempObservations[i];
if (observation.successful) {
allObservations.add(tempObservations[i]);
} else {
ReadPoint readPoint = (ReadPoint) readPoints.get(observation.getReadPointName());
if (readPoint instanceof AntennaReadPoint) {
((AntennaReadPoint) readPoint).increaseFailedIdentificationCount();
}
}
}
} catch (HardwareException he) {
log.error(he.getMessage());
}
} | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\msg\command\TextLexer.java | 595 |
| org\fosstrak\reader\rprm\core\msg\reply\TextLexer.java | 314 |
match("=");
if ( _createToken && _token==null && _ttype!=Token.SKIP ) {
_token = makeToken(_ttype);
_token.setText(new String(text.getBuffer(), _begin, text.length()-_begin));
}
_returnToken = _token;
}
public final void mESCAPE(boolean _createToken) throws RecognitionException, CharStreamException, TokenStreamException {
int _ttype; Token _token=null; int _begin=text.length();
_ttype = ESCAPE;
int _saveIndex;
match("\\");
if ( _createToken && _token==null && _ttype!=Token.SKIP ) {
_token = makeToken(_ttype);
_token.setText(new String(text.getBuffer(), _begin, text.length()-_begin));
}
_returnToken = _token;
} | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\mgmt\agent\snmp\mib\EpcglobalReaderMib.java | 2712 |
| org\fosstrak\reader\rprm\core\mgmt\agent\snmp\mib\EpcglobalReaderMib.java | 2761 |
" does not start with "+oidTrapVarEpcgAntRdPntLockFailures);
}
if (!epcgAntReadPointEntryIndex.isValidIndex(epcgAntReadPointEntry.getIndexPart(vbs[4].getOid()))) {
throw new IllegalArgumentException("Illegal index for variable 4 specified: "+
epcgAntReadPointEntry.getIndexPart(vbs[4].getOid()));
}
if (!(vbs[5].getOid().startsWith(oidTrapVarEpcgAntRdPntNoiseLevel))) {
throw new IllegalArgumentException("Variable 5 has wrong OID: "+vbs[5].getOid()+
" does not start with "+oidTrapVarEpcgAntRdPntNoiseLevel);
}
if (!epcgAntReadPointEntryIndex.isValidIndex(epcgAntReadPointEntry.getIndexPart(vbs[5].getOid()))) {
throw new IllegalArgumentException("Illegal index for variable 5 specified: "+
epcgAntReadPointEntry.getIndexPart(vbs[5].getOid()));
}
notificationOriginator.notify(context, oidEpcgReaderAntennaLockFailure, vbs); | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\mgmt\agent\snmp\mib\EpcglobalReaderMib.java | 3412 |
| org\fosstrak\reader\rprm\core\mgmt\agent\snmp\mib\EpcglobalReaderMib.java | 3452 |
EpcgRdrDevFreeMemoryAbateThreshold(OID oid, MOAccess access) {
super(oid, access, new UnsignedInteger32());
//--AgentGen BEGIN=epcgRdrDevFreeMemoryAbateThreshold
//--AgentGen END
}
public int isValueOK(SubRequest request) {
Variable newValue =
request.getVariableBinding().getVariable();
int valueOK = super.isValueOK(request);
if (valueOK != SnmpConstants.SNMP_ERROR_SUCCESS) {
return valueOK;
}
long v = ((UnsignedInteger32)newValue).getValue();
if (!(((v >= 0L) && (v <= 4294967295L)))) {
valueOK = SnmpConstants.SNMP_ERROR_WRONG_VALUE;
}
//--AgentGen BEGIN=epcgRdrDevFreeMemoryAbateThreshold::isValueOK
//--AgentGen END
return valueOK;
}
public Variable getValue() {
//--AgentGen BEGIN=epcgRdrDevFreeMemoryAbateThreshold::getValue
//--AgentGen END
return super.getValue();
}
public int setValue(Variable newValue) {
//--AgentGen BEGIN=epcgRdrDevFreeMemoryAbateThreshold::setValue
//--AgentGen END
return super.setValue(newValue);
}
//--AgentGen BEGIN=epcgRdrDevFreeMemoryAbateThreshold::_METHODS
//--AgentGen END
}
public class EpcgRdrDevMemStateSuppressInterval extends MOScalar { | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\mgmt\agent\snmp\mib\EpcglobalReaderMib.java | 2631 |
| org\fosstrak\reader\rprm\core\mgmt\agent\snmp\mib\EpcglobalReaderMib.java | 2729 |
public void epcgReaderNotificationChanOperState(NotificationOriginator notificationOriginator,
OctetString context, VariableBinding[] vbs) {
if (vbs.length < 6) {
throw new IllegalArgumentException("Too few notification objects: "+
vbs.length+"<6");
}
if (!(vbs[0].getOid().startsWith(oidTrapVarSysName))) {
throw new IllegalArgumentException("Variable 0 has wrong OID: "+vbs[0].getOid()+
" does not start with "+oidTrapVarSysName);
}
if (!(vbs[1].getOid().startsWith(oidTrapVarEpcgRdrDevTimeUtc))) {
throw new IllegalArgumentException("Variable 1 has wrong OID: "+vbs[1].getOid()+
" does not start with "+oidTrapVarEpcgRdrDevTimeUtc);
}
if (!(vbs[2].getOid().startsWith(oidTrapVarEpcgNotifChanOperNotifLevel))) { | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\msg\MessageLayerConfiguration.java | 104 |
| org\fosstrak\reader\rprm\core\Source.java | 578 |
return getProperties(sourcePropFile, sourceDefaultPropFile);
}
/**
* Singleton implementation of properties file accessor.
*
* @return properties instance
*/
private static XMLConfiguration getProperties(final String propFile,
final String defaultPropFile) {
if (configuration == null) {
// properties
configuration = new XMLConfiguration();
try {
// load resource from where this class is located
Exception ex = new Exception();
StackTraceElement[] sTrace = ex.getStackTrace();
String className = sTrace[0].getClassName();
Class c = Class.forName(className);
URL fileurl = ResourceLocator.getURL(propFile, defaultPropFile, c);
configuration.load(fileurl);
} catch (ConfigurationException e) {
log.error("Could not find properties file: " + propFile);
} catch (ClassNotFoundException cnfe) {
log.error("Could not find properties file: " + propFile);
}
}
return configuration;
}
/**
* Returns the name of the source.
* @return The name of the source
*/
public String getName() { | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\msg\transport\HttpServerConnection.java | 109 |
| org\fosstrak\reader\rprm\core\msg\transport\TCPServerConnection.java | 112 |
Connection clientConnection = new TCPConnection(clientSocket);
clientConnection.addIncomingMessageListener(listener);
connections.add(clientConnection);
log.debug("Connection requested by client!");
clientConnection.handleClient();
} catch (IOException e) {
log.error("Accept failed: " + e.getMessage()
+ e.getStackTrace());
this.reset();
}
}
}
/**
* @see org.fosstrak.reader.rprm.core.msg.transport.Connection#close()
*/
public void close() {
isOpen = false;
for (int i = 0; i < connections.size(); i++) {
((Connection) connections.get(i)).close();
}
}
/**
* Resets the current connection.
*
*/
protected void reset() {
log.debug("the connection is resetting!");
this.close();
}
} | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\mgmt\agent\snmp\mib\EpcglobalReaderMib.java | 3183 |
| org\fosstrak\reader\rprm\core\mgmt\agent\snmp\mib\EpcglobalReaderMib.java | 3223 |
EpcgRdrDevOperNotifToState(OID oid, MOAccess access) {
super(oid, access, new OctetString());
//--AgentGen BEGIN=epcgRdrDevOperNotifToState
//--AgentGen END
}
public int isValueOK(SubRequest request) {
Variable newValue =
request.getVariableBinding().getVariable();
int valueOK = super.isValueOK(request);
if (valueOK != SnmpConstants.SNMP_ERROR_SUCCESS) {
return valueOK;
}
OctetString os = (OctetString)newValue;
if (os.length() != 1) {
valueOK = SnmpConstants.SNMP_ERROR_WRONG_LENGTH;
}
//--AgentGen BEGIN=epcgRdrDevOperNotifToState::isValueOK
//--AgentGen END
return valueOK;
}
public Variable getValue() {
//--AgentGen BEGIN=epcgRdrDevOperNotifToState::getValue
//--AgentGen END
return super.getValue();
}
public int setValue(Variable newValue) {
//--AgentGen BEGIN=epcgRdrDevOperNotifToState::setValue
//--AgentGen END
return super.setValue(newValue);
}
//--AgentGen BEGIN=epcgRdrDevOperNotifToState::_METHODS
//--AgentGen END
}
public class EpcgRdrDevOperNotifStateLevel extends MOScalar { | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\msg\command\HexStringListType.java | 98 |
| org\fosstrak\reader\rprm\core\msg\notification\HexStringListType.java | 98 |
public void setList(org.fosstrak.reader.rprm.core.msg.reply.HexStringListType.List value) {
this.list = value;
}
/**
* <p>Java class for anonymous complex type.
*
* <p>The following schema fragment specifies the expected content contained within this class.
*
* <pre>
* <complexType>
* <complexContent>
* <restriction base="{http://www.w3.org/2001/XMLSchema}anyType">
* <sequence>
* <element name="value" type="{http://www.w3.org/2001/XMLSchema}hexBinary" maxOccurs="unbounded"/>
* </sequence>
* </restriction>
* </complexContent>
* </complexType>
* </pre>
*
*
*/
@XmlAccessorType(XmlAccessType.FIELD)
@XmlType(name = "", propOrder = {
"value"
})
public static class List {
@XmlElementRef(name = "value", type = JAXBElement.class)
protected java.util.List<JAXBElement<byte[]>> value;
/**
* Gets the value of the value property.
*
* <p>
* This accessor method returns a reference to the live list,
* not a snapshot. Therefore any modification you make to the
* returned list will be present inside the JAXB object.
* This is why there is not a <CODE>set</CODE> method for the value property.
*
* <p>
* For example, to add a new item, do as follows:
* <pre>
* getValue().add(newItem);
* </pre>
*
*
* <p>
* Objects of the following type(s) are allowed in the list
* {@link JAXBElement }{@code <}{@link byte[]}{@code >}
*
*
*/
public java.util.List<JAXBElement<byte[]>> getValue() {
if (value == null) {
value = new ArrayList<JAXBElement<byte[]>>();
}
return this.value;
}
}
} | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\mgmt\agent\snmp\mib\EpcglobalReaderMib.java | 2651 |
| org\fosstrak\reader\rprm\core\mgmt\agent\snmp\mib\EpcglobalReaderMib.java | 2700 |
epcgAntReadPointEntry.getIndexPart(vbs[2].getOid()));
}
if (!(vbs[3].getOid().startsWith(oidTrapVarEpcgReadPointName))) {
throw new IllegalArgumentException("Variable 3 has wrong OID: "+vbs[3].getOid()+
" does not start with "+oidTrapVarEpcgReadPointName);
}
if (!epcgReadPointEntryIndex.isValidIndex(epcgReadPointEntry.getIndexPart(vbs[3].getOid()))) {
throw new IllegalArgumentException("Illegal index for variable 3 specified: "+
epcgReadPointEntry.getIndexPart(vbs[3].getOid()));
}
if (!(vbs[4].getOid().startsWith(oidTrapVarEpcgAntRdPntMemoryReadFailures))) { | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\msg\command\TextCommandParserHelper.java | 936 |
| org\fosstrak\reader\rprm\core\msg\command\TextCommandParserHelper.java | 967 |
w.setData(tfListType);
//Set Selectors if optional parameter is available
if (hasParameters()) {
TagSelectorListParamType.List list = cmdFactory.createTagSelectorListParamTypeList();
TagSelectorListParamType listType = cmdFactory.createTagSelectorListParamType();
list.getValue().addAll(readListParameter().toStringList());
listType.setList(list);
w.setSelectors(listType);
}
//Set passwords if optional parameter available
if (hasParameters()) {
HexStringListType.List list = cmdFactory.createHexStringListTypeList();
HexStringListType listType = cmdFactory.createHexStringListType();
list.getValue().addAll(readListParameter().toHexStringListType());
listType.setList(list);
w.setPasswords(listType);
}
srcCommand.setWrite(w); | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\mgmt\agent\snmp\table\EpcgNotifTrigTableRowStatusListener.java | 92 |
| org\fosstrak\reader\rprm\core\mgmt\agent\snmp\table\EpcgReadTrigTableRowStatusListener.java | 92 |
source.removeReadTriggers(new Trigger[] { trigger });
}
} else {
lastEvent = event;
}
}
/**
* Compares to <code>RowStatusEvent</code> objects for equality.
*
* @param event1
* First <code>RowStatusEvent</code> object
* @param event2
* Second <code>RowStatusEvent</code> object
* @return <code>true</code> if the events are equal, <code>false</code>
* otherwise
*/
private boolean areRowStatusEventsEqual(RowStatusEvent event1, RowStatusEvent event2) {
if ((event1 == null) || (event2 == null)) return false;
return (event1.getSource().equals(event2.getSource()))
&& (event1.getRow().getIndex().toString().equals(event2
.getRow().getIndex().toString()))
&& (event1.getNewStatus() == event2.getNewStatus());
}
} | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\msg\command\TagFieldValueParamType.java | 63 |
| org\fosstrak\reader\rprm\core\msg\reply\TagFieldValueParamType.java | 63 |
@XmlAccessorType(XmlAccessType.FIELD)
@XmlType(name = "TagFieldValueParamType", propOrder = {
"tagFieldName",
"tagFieldValue"
})
public class TagFieldValueParamType {
protected String tagFieldName;
@XmlElement(type = String.class)
@XmlJavaTypeAdapter(HexBinaryAdapter.class)
protected byte[] tagFieldValue;
/**
* Gets the value of the tagFieldName property.
*
* @return
* possible object is
* {@link String }
*
*/
public String getTagFieldName() {
return tagFieldName;
}
/**
* Sets the value of the tagFieldName property.
*
* @param value
* allowed object is
* {@link String }
*
*/
public void setTagFieldName(String value) {
this.tagFieldName = value;
}
/**
* Gets the value of the tagFieldValue property.
*
* @return
* possible object is
* {@link String }
*
*/
public byte[] getTagFieldValue() {
return tagFieldValue;
}
/**
* Sets the value of the tagFieldValue property.
*
* @param value
* allowed object is
* {@link String }
*
*/
public void setTagFieldValue(byte[] value) {
this.tagFieldValue = ((byte[]) value);
}
} | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\mgmt\agent\snmp\table\EpcgNotifTrigTableRowStatusListener.java | 92 |
| org\fosstrak\reader\rprm\core\mgmt\agent\snmp\table\EpcgRdPntSrcTableRowStatusListener.java | 87 |
source.removeReadPoints(new ReadPoint[] { readPoint });
}
} else {
lastEvent = event;
}
}
/**
* Compares to <code>RowStatusEvent</code> objects for equality.
*
* @param event1
* First <code>RowStatusEvent</code> object
* @param event2
* Second <code>RowStatusEvent</code> object
* @return <code>true</code> if the events are equal, <code>false</code>
* otherwise
*/
private boolean areRowStatusEventsEqual(RowStatusEvent event1, RowStatusEvent event2) {
if ((event1 == null) || (event2 == null)) return false;
return (event1.getSource().equals(event2.getSource()))
&& (event1.getRow().getIndex().toString().equals(event2
.getRow().getIndex().toString()))
&& (event1.getNewStatus() == event2.getNewStatus());
}
} | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\msg\command\ReaderDeviceCommand.java | 1634 |
| org\fosstrak\reader\rprm\core\msg\command\SourceCommand.java | 1640 |
public static class Create {
protected String name;
/**
* Gets the value of the name property.
*
* @return
* possible object is
* {@link String }
*
*/
public String getName() {
return name;
}
/**
* Sets the value of the name property.
*
* @param value
* allowed object is
* {@link String }
*
*/
public void setName(String value) {
this.name = value;
}
}
/**
* <p>Java class for anonymous complex type.
*
* <p>The following schema fragment specifies the expected content contained within this class.
*
* <pre>
* <complexType>
* <complexContent>
* <restriction base="{http://www.w3.org/2001/XMLSchema}anyType">
* <sequence>
* <element name="name" type="{http://www.w3.org/2001/XMLSchema}string"/>
* </sequence>
* </restriction>
* </complexContent>
* </complexType>
* </pre>
*
*
*/
@XmlAccessorType(XmlAccessType.FIELD)
@XmlType(name = "", propOrder = {
"name"
})
public static class GetReadPoint {
protected String name;
/**
* Gets the value of the name property.
*
* @return
* possible object is
* {@link String }
*
*/
public String getName() {
return name;
}
/**
* Sets the value of the name property.
*
* @param value
* allowed object is
* {@link String }
*
*/
public void setName(String value) {
this.name = value;
}
}
/**
* <p>Java class for anonymous complex type.
*
* <p>The following schema fragment specifies the expected content contained within this class.
*
* <pre>
* <complexType>
* <complexContent>
* <restriction base="{http://www.w3.org/2001/XMLSchema}anyType">
* <sequence>
* <element name="name" type="{http://www.w3.org/2001/XMLSchema}string"/>
* </sequence>
* </restriction>
* </complexContent>
* </complexType>
* </pre>
*
*
*/
@XmlAccessorType(XmlAccessType.FIELD)
@XmlType(name = "", propOrder = {
"name"
})
public static class GetReadTrigger { | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\mgmt\agent\snmp\table\EpcgNotifChanSrcTableRowStatusListener.java | 87 |
| org\fosstrak\reader\rprm\core\mgmt\agent\snmp\table\EpcgNotifTrigTableRowStatusListener.java | 92 |
notifChan.removeNotificationTriggers(new Trigger[] { trigger });
}
} else {
lastEvent = event;
}
}
/**
* Compares to <code>RowStatusEvent</code> objects for equality.
*
* @param event1
* First <code>RowStatusEvent</code> object
* @param event2
* Second <code>RowStatusEvent</code> object
* @return <code>true</code> if the events are equal, <code>false</code>
* otherwise
*/
private boolean areRowStatusEventsEqual(RowStatusEvent event1, RowStatusEvent event2) {
if ((event1 == null) || (event2 == null)) return false;
return (event1.getSource().equals(event2.getSource()))
&& (event1.getRow().getIndex().toString().equals(event2
.getRow().getIndex().toString()))
&& (event1.getNewStatus() == event2.getNewStatus());
}
} | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\msg\TextMessageSerializer.java | 394 |
| org\fosstrak\reader\rprm\core\msg\TextMessageSerializer.java | 506 |
reportAttributes.add(new String(tag.getTagID()));
}
if (tag.getTagIDAsPureURI() != null) {
reportAttributes.add(tag.getTagIDAsPureURI());
}
if (tag.getTagIDAsTagURI() != null) {
reportAttributes.add(tag.getTagIDAsTagURI());
}
if (tag.getTagType() != null) {
reportAttributes.add(tag.getTagType());
}
// --- Add the tag events ---
if (tag.getTagEvent() != null) {
Iterator tagEventIt = tag.getTagEvent().iterator();
while (tagEventIt.hasNext()) { | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\msg\command\ReaderDeviceCommand.java | 326 |
| org\fosstrak\reader\rprm\core\msg\reply\ReaderDeviceReply.java | 125 |
@XmlType(name = "ReaderDeviceReply", propOrder = {
"getEPC",
"getManufacturer",
"getModel",
"getHandle",
"setHandle",
"getName",
"setName",
"getRole",
"setRole",
"getTimeTicks",
"getTimeUTC",
"setTimeUTC",
"getManufacturerDescription",
"getCurrentSource",
"setCurrentSource",
"getCurrentDataSelector",
"setCurrentDataSelector",
"removeSources",
"removeAllSources",
"getSource",
"getAllSources",
"removeDataSelectors",
"removeAllDataSelectors",
"getDataSelector",
"getAllDataSelectors",
"removeNotificationChannels",
"removeAllNotificationChannels",
"getNotificationChannel",
"getAllNotificationChannels",
"removeTriggers",
"removeAllTriggers",
"getTrigger",
"getAllTriggers",
"removeTagSelectors",
"removeAllTagSelectors",
"getTagSelector",
"getAllTagSelectors",
"removeTagFields",
"removeAllTagFields",
"getTagField",
"getAllTagFields",
"resetToDefaultSettings",
"reboot",
"goodbye",
"getReadPoint",
"getAllReadPoints",
"any"
})
public class ReaderDeviceReply { | |
| File | Line |
|---|---|
| org\fosstrak\reader\rprm\core\EventType.java | 135 |
| org\fosstrak\reader\rprm\core\FieldName.java | 211 |
Class c = FieldName.class;
Field[] fields = c.getFields();
String fieldName;
Field tempField;
String tempString;
for (int i = 0; i < fields.length; i++) {
try {
fieldName = fields[i].getName();
tempField = c.getField(fieldName);
tempString = (String) tempField.get(c);
if (tempString.toUpperCase().equals(type.toUpperCase())) {
return true;
}
} catch (Exception e) {
return false;
}
}
return false;
}
} | |