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

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

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

Qos.isDynamic介绍

[英]If true, Qos is dynamic. Used to describe the changeability of the quality of service, typically over the life of a data stream.
[中]如果为true,则Qos是动态的。用于描述服务质量的可变性,通常在数据流的生命周期内。

代码示例

代码示例来源: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

chnlInfo.symbolListHandler.qos().dynamic(qos.isDynamic());
chnlInfo.symbolListHandler.qos().rate(qos.rate());
chnlInfo.symbolListHandler.qos().timeliness(qos.timeliness());

代码示例来源:origin: Refinitiv/Elektron-SDK

symbolListHandler.qos().dynamic(qos.isDynamic());
symbolListHandler.qos().rate(qos.rate());
symbolListHandler.qos().timeliness(qos.timeliness());

代码示例来源:origin: Refinitiv/Elektron-SDK

matchedQos.dynamic(qos.isDynamic());

代码示例来源:origin: Refinitiv/Elektron-SDK

static int encodeQos(EncodeIteratorImpl iter, Qos data)
{
  assert (iter != null);
  assert (data != null);
  int dataLength = 1;
  int Qos;
  if (data.timeliness() == QosTimeliness.UNSPECIFIED || data.rate() == QosRates.UNSPECIFIED)
    return CodecReturnCodes.INVALID_DATA;
  dataLength += (data.timeliness() > QosTimeliness.DELAYED_UNKNOWN) ? 2 : 0;
  dataLength += (data.rate() > QosRates.JIT_CONFLATED) ? 2 : 0;
  if (iter.isIteratorOverrun(dataLength))
    return CodecReturnCodes.BUFFER_TOO_SMALL;
  Qos = (data.timeliness() << 5);
  Qos |= (data.rate() << 1);
  Qos |= (data.isDynamic() ? 1 : 0);
  iter._writer.writeByte(Qos);
  if (data.timeliness() > QosTimeliness.DELAYED_UNKNOWN)
  {
    iter._writer.writeShort(data.timeInfo());
  }
  if (data.rate() > QosRates.JIT_CONFLATED)
  {
    iter._writer.writeShort(data.rateInfo());
  }
  iter._curBufPos = iter._writer.position();
  return CodecReturnCodes.SUCCESS;
}

代码示例来源:origin: Refinitiv/Elektron-SDK

static int encodeQosWithLength(EncodeIteratorImpl iter, Qos data)
{
  assert (iter != null);
  assert (data != null);
  int dataLength = 1;
  int Qos;
  if (data.timeliness() == QosTimeliness.UNSPECIFIED || data.rate() == QosRates.UNSPECIFIED)
    return CodecReturnCodes.INVALID_DATA;
  dataLength += (data.timeliness() > QosTimeliness.DELAYED_UNKNOWN) ? 2 : 0;
  dataLength += (data.rate() > QosRates.JIT_CONFLATED) ? 2 : 0;
  if (iter.isIteratorOverrun(dataLength + 1))
    return CodecReturnCodes.BUFFER_TOO_SMALL;
  iter._writer.writeByte(dataLength);
  Qos = (data.timeliness() << 5);
  Qos |= (data.rate() << 1);
  Qos |= (data.isDynamic() ? 1 : 0);
  iter._writer.writeByte(Qos);
  if (data.timeliness() > QosTimeliness.DELAYED_UNKNOWN)
  {
    iter._writer.writeShort(data.timeInfo());
  }
  if (data.rate() > QosRates.JIT_CONFLATED)
  {
    iter._writer.writeShort(data.rateInfo());
  }
  iter._curBufPos = iter._writer.position();
  return CodecReturnCodes.SUCCESS;
}

代码示例来源:origin: Refinitiv/Elektron-SDK

Qos qosDec = rdmServiceInfoDec.qosList().get(0);
assertEquals(qos.rate(), qosDec.rate());
assertEquals(qos.isDynamic(), qosDec.isDynamic());
assertEquals(qos.timeliness(), qosDec.timeliness());
assertEquals(qos.timeInfo(), qosDec.timeInfo());

代码示例来源:origin: Refinitiv/Elektron-SDK

symbolListRequest.serviceId(serviceId());
symbolListRequest.applyHasServiceId();
symbolListRequest.qos().dynamic(qos.isDynamic());
symbolListRequest.qos().rate(qos.rate());
symbolListRequest.qos().timeliness(qos.timeliness());

代码示例来源:origin: Refinitiv/Elektron-SDK

private void qosED(QosImpl qos)
{
  _encIter.clear();
  _buffer.data(ByteBuffer.allocate(15));
  _encIter.setBufferAndRWFVersion(_buffer, Codec.majorVersion(), Codec.minorVersion());
  qos.encode(_encIter);
  _decIter.clear();
  _decIter.setBufferAndRWFVersion(_buffer, Codec.majorVersion(), Codec.minorVersion());
  Qos qos1 = CodecFactory.createQos();
  qos1.decode(_decIter);
  assertEquals(qos.rate(), qos1.rate());
  assertEquals(qos.rateInfo(), qos1.rateInfo());
  assertEquals(qos.timeInfo(), qos1.timeInfo());
  assertEquals(qos.timeliness(), qos1.timeliness());
  assertEquals(qos.isDynamic(), qos1.isDynamic());
}

代码示例来源:origin: Refinitiv/Elektron-SDK

requestMsg.qos().dynamic(qos.isDynamic());
requestMsg.qos().rate(qos.rate());
requestMsg.qos().timeliness(qos.timeliness());
requestMsg.worstQos().dynamic(worstQos.isDynamic());
requestMsg.worstQos().rate(worstQos.rate());
requestMsg.worstQos().timeliness(worstQos.timeliness());

代码示例来源:origin: Refinitiv/Elektron-SDK

symbolListRequest.serviceId(serviceId());
symbolListRequest.applyHasServiceId();
symbolListRequest.qos().dynamic(qos.isDynamic());
symbolListRequest.qos().rate(qos.rate());
symbolListRequest.qos().timeliness(qos.timeliness());

代码示例来源:origin: Refinitiv/Elektron-SDK

_requestMsg.qos().dynamic(qos.isDynamic());
_requestMsg.qos().rate(qos.rate());
_requestMsg.qos().rateInfo(qos.rateInfo());

代码示例来源:origin: Refinitiv/Elektron-SDK

requestMsg.qos().dynamic(qos.isDynamic());
requestMsg.qos().rate(qos.rate());
requestMsg.qos().timeliness(qos.timeliness());

代码示例来源:origin: Refinitiv/Elektron-SDK

msg.qos().timeliness(qos().timeliness());
msg.qos().timeInfo(qos().timeInfo());
msg.qos().dynamic(qos().isDynamic());
msg.applyHasQos();
msg.worstQos().timeliness(worstQos().timeliness());
msg.worstQos().timeInfo(worstQos().timeInfo());
msg.worstQos().dynamic(worstQos().isDynamic());
msg.applyHasWorstQos();

代码示例来源:origin: Refinitiv/Elektron-SDK

assertEquals(testQoss[i].timeliness(), tmpQos.timeliness());
assertEquals(testQoss[i].timeInfo(), tmpQos.timeInfo());
assertEquals(testQoss[i].isDynamic(), tmpQos.isDynamic());

代码示例来源:origin: Refinitiv/Elektron-SDK

requestMsg.qos().dynamic(qos().isDynamic());
requestMsg.qos().rate(qos().rate());
requestMsg.qos().rateInfo(qos().rateInfo());

代码示例来源:origin: Refinitiv/Elektron-SDK

refreshMsg.qos().dynamic(qos().isDynamic());
refreshMsg.qos().rate(qos().rate());
refreshMsg.qos().timeliness(qos().timeliness());

代码示例来源:origin: Refinitiv/Elektron-SDK

refreshMsg.qos().dynamic(qos().isDynamic());
refreshMsg.qos().rate(qos().rate());
refreshMsg.qos().timeliness(qos().timeliness());

代码示例来源:origin: Refinitiv/Elektron-SDK

refreshMsg.qos().dynamic(qos().isDynamic());
refreshMsg.qos().rate(qos().rate());
refreshMsg.qos().timeliness(qos().timeliness());

代码示例来源:origin: Refinitiv/Elektron-SDK

msg.qos().timeliness(qos().timeliness());
msg.qos().timeInfo(qos().timeInfo());
msg.qos().dynamic(qos().isDynamic());
msg.applyHasQos();

相关文章