com.thomsonreuters.upa.codec.Qos.clear()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(6.4k)|赞(0)|评价(0)|浏览(131)

本文整理了Java中com.thomsonreuters.upa.codec.Qos.clear方法的一些代码示例,展示了Qos.clear的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Qos.clear方法的具体详情如下:
包路径:com.thomsonreuters.upa.codec.Qos
类名称:Qos
方法名:clear

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();

相关文章