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; } } |