本文整理了Java中com.thomsonreuters.upa.codec.Qos.isDynamic
方法的一些代码示例,展示了Qos.isDynamic
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Qos.isDynamic
方法的具体详情如下:
包路径:com.thomsonreuters.upa.codec.Qos
类名称: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();
内容来源于网络,如有侵权,请联系作者删除!