本文整理了Java中com.thomsonreuters.upa.codec.Qos.clear
方法的一些代码示例,展示了Qos.clear
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Qos.clear
方法的具体详情如下:
包路径:com.thomsonreuters.upa.codec.Qos
类名称:Qos
方法名:clear
[英]Clears Qos. Useful for object reuse.
[中]清除Qos。对对象重用很有用。
代码示例来源:origin: Refinitiv/Elektron-SDK
void clear()
{
_dataCode = DataCode.NO_CODE;
_rsslQos.clear();
}
}
代码示例来源:origin: Refinitiv/Elektron-SDK
/**
* Clears the current contents of this object and prepares it for re-use.
*/
public void clear()
{
flags = 0;
qos.clear();
worstQos.clear();
itemNames.clear();
priorityClass = 1;
priorityCount = 1;
identifier = -1;
isSymbolListData = false;
if (viewFieldList != null ) viewFieldList.clear();
if (viewElementNameList != null ) viewElementNameList.clear();
}
代码示例来源:origin: Refinitiv/Elektron-SDK
/**
* Clears the current contents of this object and prepares it for re-use.
*/
public void clear()
{
super.clear();
qos.clear();
priorityClass = 0;
priorityCount = 0;
flags = 0;
}
代码示例来源:origin: Refinitiv/Elektron-SDK
/**
* Clears the current contents of this object and prepares it for re-use.
*/
public void clear()
{
super.clear();
flags = 0;
qos.clear();
itemNames.clear();
priorityClass = 1;
priorityCount = 1;
}
代码示例来源:origin: Refinitiv/Elektron-SDK
void clear()
{
_msgKey.clear();
_msgKeyReference = null;
_domainType = 0;
_qos.clear();
_qosReference = null;
}
}
代码示例来源:origin: Refinitiv/Elektron-SDK
@Override
void decode(com.thomsonreuters.upa.codec.Buffer rsslBuffer, com.thomsonreuters.upa.codec.DecodeIterator dIter)
{
_rsslBuffer = rsslBuffer;
if (com.thomsonreuters.upa.codec.CodecReturnCodes.SUCCESS == _rsslQos.decode(dIter))
_dataCode = DataCode.NO_CODE;
else
{
_dataCode = DataCode.BLANK;
_rsslQos.clear();
}
}
代码示例来源:origin: Refinitiv/Elektron-SDK
/**
* Clears the current contents of this object and prepares it for re-use.
*/
public void clear()
{
super.clear();
flags = 0;
qos.clear();
itemNames.clear();
priorityClass = 1;
priorityCount = 1;
identifier = -1;
viewFieldList.clear();
}
代码示例来源:origin: Refinitiv/Elektron-SDK
/**
* Clears the current contents of this object and prepares it for re-use.
*/
public void clear()
{
super.clear();
state.clear();
qos.clear();
flags = 0;
}
代码示例来源:origin: Refinitiv/Elektron-SDK
/**
* Clears the current contents of this object and prepares it for re-use.
*/
public void clear()
{
super.clear();
state.clear();
qos.clear();
flags = 0;
}
代码示例来源:origin: Refinitiv/Elektron-SDK
/**
* Clears the current contents of this object and prepares it for re-use.
*/
public void clear()
{
super.clear();
state.clear();
qos.clear();
flags = 0;
}
代码示例来源:origin: Refinitiv/Elektron-SDK
void clear()
{
assert (_state == State.RETURN_TO_POOL);
_requestMsg.clear();
_requestMsg.msgClass(MsgClasses.REQUEST);
_handler = null;
_stream = null;
_streamInfo.clear();
_state = State.PENDING_REQUEST;
_hasStaticQos = false;
_matchedQos.clear();
_hasBehaviour = false;
_providerDriven = false;
_serviceId = 0;
_hasServiceId = false;
_initialResponseReceived = false;
_symbolListFlags = 0;
_tableKey = null;
_viewElemCount = 0;
_viewType = 0;
}
代码示例来源:origin: Refinitiv/Elektron-SDK
WlItemHandler(Watchlist watchlist)
{
_watchlist = watchlist;
_defaultQos.clear();
_defaultQos.timeliness(QosTimeliness.REALTIME);
_defaultQos.rate(QosRates.TICK_BY_TICK);
_statusMsg.msgClass(MsgClasses.STATUS);
_wlViewHandler = new WlViewHandler(watchlist);
_itemAggregationKeytoWlStreamTable = new HashMap<WlItemAggregationKey,WlStream>(_watchlist.role().watchlistOptions().itemCountHint() + 10, 1);
}
代码示例来源:origin: Refinitiv/Elektron-SDK
qos.clear();
代码示例来源:origin: Refinitiv/Elektron-SDK
void decode(com.thomsonreuters.upa.codec.Qos rsslQos)
{
if (rsslQos != null)
{
_dataCode = DataCode.NO_CODE;
_rsslQos.rate(rsslQos.rate());
_rsslQos.timeliness(rsslQos.timeliness());
_rsslQos.dynamic(rsslQos.isDynamic());
_rsslQos.timeInfo(rsslQos.timeInfo());
_rsslQos.rateInfo(rsslQos.rateInfo());
}
else
{
_dataCode = DataCode.BLANK;
_rsslQos.clear();
}
}
代码示例来源:origin: Refinitiv/Elektron-SDK
providerQos.clear();
providerQos.dynamic(false); /* @brief If _TRUE, Qos is dynamic (used to describe the changeability of the quality of service, typically over the life of a data stream) */
providerQos.rate(QosRates.TICK_BY_TICK);/* Rate is Tick By Tick, indicates every change to information is conveyed */
代码示例来源:origin: Refinitiv/Elektron-SDK
qos1.rate(QosRates.TICK_BY_TICK);
assertFalse(qos1.equals(qos2));
qos1.clear();
assertTrue(qos1.equals(qos2));
qos1.rate(QosRates.JIT_CONFLATED);
assertFalse(qos1.equals(qos2));
qos1.clear();
assertTrue(qos1.equals(qos2));
qos1.rate(QosRates.TIME_CONFLATED);
assertFalse(qos1.equals(qos2));
qos1.clear();
assertTrue(qos1.equals(qos2));
qos1.timeliness(QosTimeliness.REALTIME);
assertFalse(qos1.equals(qos2));
qos1.clear();
assertTrue(qos1.equals(qos2));
qos1.timeliness(QosTimeliness.DELAYED_UNKNOWN);
assertFalse(qos1.equals(qos2));
qos1.clear();
assertTrue(qos1.equals(qos2));
qos1.timeliness(QosTimeliness.DELAYED);
assertFalse(qos1.equals(qos2));
qos1.clear();
assertTrue(qos1.equals(qos2));
qos1.rateInfo(1000);
assertFalse(qos1.equals(qos2));
qos1.clear();
assertTrue(qos1.equals(qos2));
qos1.timeInfo(2000);
代码示例来源:origin: Refinitiv/Elektron-SDK
qos1.rate(QosRates.TICK_BY_TICK);
assertTrue(qos1.isBetter(qos2));
qos1.clear();
assertFalse(qos1.isBetter(qos2));
qos1.rate(QosRates.JIT_CONFLATED);
assertTrue(qos1.isBetter(qos2));
qos1.clear();
assertFalse(qos1.isBetter(qos2));
qos1.rate(QosRates.TIME_CONFLATED);
assertTrue(qos1.isBetter(qos2));
qos1.clear();
assertFalse(qos1.isBetter(qos2));
qos1.timeliness(QosTimeliness.REALTIME);
assertTrue(qos1.isBetter(qos2));
qos1.clear();
assertFalse(qos1.isBetter(qos2));
qos1.timeliness(QosTimeliness.DELAYED_UNKNOWN);
assertTrue(qos1.isBetter(qos2));
qos1.clear();
assertFalse(qos1.isBetter(qos2));
qos1.timeliness(QosTimeliness.DELAYED);
assertTrue(qos1.isBetter(qos2));
qos1.clear();
assertFalse(qos1.isBetter(qos2));
qos1.rate(QosRates.TIME_CONFLATED);
qos1.rateInfo(1000);
assertTrue(qos1.isBetter(qos2));
qos1.clear();
assertFalse(qos1.isBetter(qos2));
代码示例来源:origin: Refinitiv/Elektron-SDK
((QosImpl)qos)._timeInfo = 65536;
assertFalse(qos.isInRange(bestQos, worstQos));
qos.clear();
assertFalse(qos.isInRange(bestQos, worstQos));
((QosImpl)qos)._rate = QosRates.TIME_CONFLATED;
((QosImpl)qos)._timeInfo = 65533;
assertTrue(qos.isInRange(bestQos, worstQos));
qos.clear();
assertFalse(qos.isInRange(bestQos, worstQos));
((QosImpl)qos)._rate = QosRates.TIME_CONFLATED;
((QosImpl)qos)._timeInfo = 65534;
assertTrue(qos.isInRange(bestQos, worstQos));
qos.clear();
assertFalse(qos.isInRange(bestQos, worstQos));
((QosImpl)qos)._rate = QosRates.TIME_CONFLATED;
代码示例来源:origin: Refinitiv/Elektron-SDK
rsslQos.clear();
((com.thomsonreuters.upa.codec.RequestMsg)_rsslMsg).applyHasWorstQos();
Qos rsslWQos = ((com.thomsonreuters.upa.codec.RequestMsg)_rsslMsg).worstQos();
rsslWQos.clear();
代码示例来源:origin: Refinitiv/Elektron-SDK
return ret;
_tempMatchedQos.clear();
内容来源于网络,如有侵权,请联系作者删除!