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

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

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

Qos.decode介绍

[英]Decode Qos.
[中]解码Qos。

代码示例

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

ret = fidQosValue.decode(dIter);
if (ret == CodecReturnCodes.SUCCESS)

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

ret = fidQosValue.decode(dIter);
if (ret == CodecReturnCodes.SUCCESS)

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

ret = fidQosValue.decode(dIter);
if (ret == CodecReturnCodes.SUCCESS)

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

ret = fidQosValue.decode(dIter);
if (ret == CodecReturnCodes.SUCCESS)

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

ret = fidQosValue.decode(dIter);
if (ret == CodecReturnCodes.SUCCESS)

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

if ((retVal = qos.decode(decIter)) < CodecReturnCodes.SUCCESS)

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

retval = qoS.decode(dIter);
if (retval != CodecReturnCodes.SUCCESS && retval != CodecReturnCodes.BLANK_DATA)

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

retval = qoS.decode(dIter);
if (retval != CodecReturnCodes.SUCCESS && retval != CodecReturnCodes.BLANK_DATA)

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

retval =qoS.decode(dIter);
if (retval != CodecReturnCodes.SUCCESS && retval != CodecReturnCodes.BLANK_DATA)

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

break;
case DataTypes.QOS:
  if ((ret = _fidQosValue.decode(iter)) < CodecReturnCodes.SUCCESS)
    return ret;
  break;

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

break;
case DataTypes.QOS:
  if ((ret = _fidQosValue.decode(iter)) < CodecReturnCodes.SUCCESS)
    return ret;
  break;

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

ret = qos.decode(dIter);
qosList().add(qos);
if (ret != CodecReturnCodes.SUCCESS

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

ret = tmpQos.decode(_decIter);
if (ret == CodecReturnCodes.SUCCESS)

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

assertEquals(28, fieldEntry.fieldId());
assertEquals(DataTypes.QOS, fieldEntry.dataType());
assertEquals(CodecReturnCodes.SUCCESS, qosVal.decode(dIter));
assertEquals(QosTimeliness.DELAYED, qosVal.timeliness());
assertEquals(3000, qosVal.timeInfo());
assertEquals(28, fieldEntry.fieldId());
assertEquals(DataTypes.UNKNOWN, fieldEntry.dataType());
assertEquals(CodecReturnCodes.SUCCESS, qosVal.decode(dIter));
assertEquals(QosTimeliness.DELAYED, qosVal.timeliness());
assertEquals(3000, qosVal.timeInfo());
assertTrue(elementEntry.name().toString().equals("28"));
assertEquals(DataTypes.QOS, elementEntry.dataType());
assertEquals(CodecReturnCodes.SUCCESS, qosVal.decode(dIter));
assertEquals(QosTimeliness.DELAYED, qosVal.timeliness());
assertEquals(3000, qosVal.timeInfo());
assertTrue(elementEntry.name().toString().equals("28"));
assertEquals(DataTypes.QOS, elementEntry.dataType());
assertEquals(CodecReturnCodes.SUCCESS, qosVal.decode(dIter));
assertEquals(QosTimeliness.DELAYED, qosVal.timeliness());
assertEquals(3000, qosVal.timeInfo());

相关文章