本文整理汇总了Java中com.google.protobuf.TextFormat.ParseException类的典型用法代码示例。如果您正苦于以下问题：Java ParseException类的具体用法？Java ParseException怎么用？Java ParseException使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
ParseException类属于com.google.protobuf.TextFormat包，在下文中一共展示了ParseException类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: asyncGetCursorInfo
import com.google.protobuf.TextFormat.ParseException; //导入依赖的package包/类
@Override
public void asyncGetCursorInfo(String ledgerName, String consumerName,
final MetaStoreCallback<ManagedCursorInfo> callback) {
String path = prefix + ledgerName + "/" + consumerName;
if (log.isDebugEnabled()) {
log.debug("Reading from {}", path);
}
zk.getData(path, false, (rc, path1, ctx, data, stat) -> executor.submit(safeRun(() -> {
if (rc != Code.OK.intValue()) {
callback.operationFailed(new MetaStoreException(KeeperException.create(Code.get(rc))));
} else {
try {
ManagedCursorInfo info = parseManagedCursorInfo(data);
callback.operationComplete(info, new ZKStat(stat));
} catch (ParseException | InvalidProtocolBufferException e) {
callback.operationFailed(new MetaStoreException(e));
}
}
})), null);
if (log.isDebugEnabled()) {
log.debug("Reading from {} ok", path);
}
}
开发者ID:apache，项目名称:incubator-pulsar，代码行数:26，代码来源:MetaStoreImplZookeeper.java
示例2: applyToToolchain
import com.google.protobuf.TextFormat.ParseException; //导入依赖的package包/类
/** Applies the given function to the first toolchain that applies to the given cpu. */
public static String applyToToolchain(
String original,
String targetCpu,
Function<CToolchain.Builder, CToolchain.Builder> transformation)
throws ParseException {
CrosstoolConfig.CrosstoolRelease.Builder crosstoolBuilder =
CrosstoolConfig.CrosstoolRelease.newBuilder();
TextFormat.merge(original, crosstoolBuilder);
for (int i = 0; i < crosstoolBuilder.getToolchainCount(); i++) {
if (crosstoolBuilder.getToolchain(i).getTargetCpu().equals(targetCpu)) {
CToolchain.Builder toolchainBuilder =
CToolchain.newBuilder(crosstoolBuilder.getToolchain(i));
transformation.apply(toolchainBuilder);
crosstoolBuilder.removeToolchain(i);
crosstoolBuilder.addToolchain(toolchainBuilder.build());
break;
}
}
return TextFormat.printToString(crosstoolBuilder.build());
}
开发者ID:bazelbuild，项目名称:bazel，代码行数:23，代码来源:MockCcSupport.java
示例3: testUnknownEnumValuesInTextFormat
import com.google.protobuf.TextFormat.ParseException; //导入依赖的package包/类
public void testUnknownEnumValuesInTextFormat() {
TestAllTypes.Builder builder = TestAllTypes.newBuilder();
builder.setOptionalNestedEnumValue(4321);
builder.addRepeatedNestedEnumValue(5432);
builder.addPackedNestedEnumValue(6543);
TestAllTypes message = builder.build();
// We can print a message with unknown enum values.
String textData = TextFormat.printToString(message);
assertEquals(
"optional_nested_enum: UNKNOWN_ENUM_VALUE_NestedEnum_4321\n"
+ "repeated_nested_enum: UNKNOWN_ENUM_VALUE_NestedEnum_5432\n"
+ "packed_nested_enum: UNKNOWN_ENUM_VALUE_NestedEnum_6543\n", textData);
// Parsing unknown enum values will fail just like parsing other kinds of
// unknown fields.
try {
TextFormat.merge(textData, builder);
fail();
} catch (ParseException e) {
// expected.
}
}
开发者ID:bazelbuild，项目名称:bazel，代码行数:24，代码来源:UnknownEnumValueTest.java
示例4: parseManagedLedgerInfo
import com.google.protobuf.TextFormat.ParseException; //导入依赖的package包/类
private ManagedLedgerInfo parseManagedLedgerInfo(byte[] data)
throws ParseException, InvalidProtocolBufferException {
// First try binary format, then fallback to text
try {
return ManagedLedgerInfo.parseFrom(data);
} catch (InvalidProtocolBufferException e) {
// Fallback to parsing protobuf text format
ManagedLedgerInfo.Builder builder = ManagedLedgerInfo.newBuilder();
TextFormat.merge(new String(data, Encoding), builder);
return builder.build();
}
}
开发者ID:apache，项目名称:incubator-pulsar，代码行数:13，代码来源:MetaStoreImplZookeeper.java
示例5: parseManagedCursorInfo
import com.google.protobuf.TextFormat.ParseException; //导入依赖的package包/类
private ManagedCursorInfo parseManagedCursorInfo(byte[] data)
throws ParseException, InvalidProtocolBufferException {
// First try binary format, then fallback to text
try {
return ManagedCursorInfo.parseFrom(data);
} catch (InvalidProtocolBufferException e) {
// Fallback to parsing protobuf text format
ManagedCursorInfo.Builder builder = ManagedCursorInfo.newBuilder();
TextFormat.merge(new String(data, Encoding), builder);
return builder.build();
}
}
开发者ID:apache，项目名称:incubator-pulsar，代码行数:14，代码来源:MetaStoreImplZookeeper.java
示例6: getApiProtoConfig
import com.google.protobuf.TextFormat.ParseException; //导入依赖的package包/类
/** Parses the config file, in proto text format, and returns it. */
public Service getApiProtoConfig(String configFileName) throws ParseException {
String content = readTestData(configFileName);
Service.Builder builder = Service.newBuilder();
TextFormat.merge(content, builder);
return builder.build();
}
开发者ID:googleapis，项目名称:api-compiler，代码行数:8，代码来源:TestConfig.java
示例7: primitive
import com.google.protobuf.TextFormat.ParseException; //导入依赖的package包/类
public boolean primitive(Object value) throws ParseException, IOException
{
if (getMatchKeyList().contains(key)) {
found = true;
this.value = value;
keyValMap.put(key, value);
key = null;
keyCount++;
return false;
}
return true;
}
开发者ID:apache，项目名称:apex-malhar，代码行数:13，代码来源:JsonKeyFinder.java
示例8: handle
import com.google.protobuf.TextFormat.ParseException; //导入依赖的package包/类
/**
* Handle a request, customized by an user's protocol
*
* @param uid
* @param ip
* @param app
* @param apv
* @param os
* @param osv
* @param ch
* @param op
* @param nation
* @param province
* @param city
* @throws ParseException
* @throws InvalidProtocolBufferException
* @throws Exception
*/
public void handle(String uid, String ip, String app, String apv, String os, String osv,
String ch, String op, String nation, String province, String city)
throws ParseException, InvalidProtocolBufferException, Exception
{
InfoReqPack.Builder builder = InfoReqPack.newBuilder();
if (null != uid && !"".equals(uid))
builder.setUid(uid);
if (null != ip && !"".equals(ip))
builder.setIp(ip);
if (null != app && !"".equals(app))
builder.setApp(app);
if (null != apv && !"".equals(apv))
builder.setAppVer(apv);
if (null != os && !"".equals(os))
builder.setOs(os);
if (null != osv && !"".equals(osv))
builder.setOsVer(osv);
if (null != ch && !"".equals(ch))
builder.setChannel(ch);
if (null != op && !"".equals(op))
builder.setIsp(op);
if (null != nation && !"".equals(nation))
builder.setNation(nation);
if (null != province && !"".equals(province))
builder.setProvince(province);
if (null != city && !"".equals(city))
builder.setCity(city);
builder.setLocSwitch(true);
InfoReqPack pack = builder.build();
// if (ClientMgr.getInstance().send("ADAPTER", pack, this)) {
if (ClientMgr.getInstance().send("INFO", pack, this)) {
log.info("REQ succ:" + this.m_checkSum);
} else {
log.info("REQ failed:" + this.m_checkSum);
throw new Exception("send fail");
}
}
开发者ID:mornsun，项目名称:bdclient，代码行数:56，代码来源:InfoTalk.java
示例9: writeMultipleEvents
import com.google.protobuf.TextFormat.ParseException; //导入依赖的package包/类
public void writeMultipleEvents() throws Exception, ParseException {
final int TOTAL_WRITES = 100000;
final long startTime = System.currentTimeMillis();
successes = 0;
fails = 0;
for (int z = 0; z < TOTAL_WRITES; z++) {
es.appendToStream(STREAM_NAME, new ResponseReceiver() {
@Override
public void onResponseReturn(Message msg) {
// log.debug("Response returned="+i);
successes++;
if ((successes + fails) == (TOTAL_WRITES)) {
processing.release();
}
}
@Override
public void onErrorReturn(Exception ex) {
fails++;
if ((successes + fails) == TOTAL_WRITES) {
processing.release();
}
}
}, generateEvents());
}
processing.acquire();
long endTime = System.currentTimeMillis();
long duration = endTime - startTime;
log.debug("Writing finished. Number of writes={} ({} successful, {} failed), duration={}",
TOTAL_WRITES, successes, fails, duration);
}
开发者ID:valdasraps，项目名称:esj，代码行数:35，代码来源:Writer.java
示例10: writeMultipleEvents
import com.google.protobuf.TextFormat.ParseException; //导入依赖的package包/类
@Test
public void writeMultipleEvents() throws Exception, ParseException {
final int TOTAL_WRITES = 100000;
final long startTime = System.currentTimeMillis();
successes = 0;
fails = 0;
for (int z = 0; z < TOTAL_WRITES; z++) {
es.appendToStream(STREAM_NAME, new ResponseReceiver() {
@Override
public void onResponseReturn(Message msg) {
// log.debug("Response returned="+i);
successes++;
if ((successes + fails) == (TOTAL_WRITES)) {
processing.release();
}
}
@Override
public void onErrorReturn(Exception ex) {
fails++;
if ((successes + fails) == TOTAL_WRITES) {
processing.release();
}
}
}, generateEvents());
}
processing.acquire();
long endTime = System.currentTimeMillis();
long duration = endTime - startTime;
log.debug("Writing finished. Number of writes={} ({} successful, {} failed), duration={}",
TOTAL_WRITES, successes, fails, duration);
}
开发者ID:valdasraps，项目名称:esj，代码行数:36，代码来源:EventSendIT.java
示例11: canWriteAndReadString
import com.google.protobuf.TextFormat.ParseException; //导入依赖的package包/类
@Test
public void canWriteAndReadString() throws ParseException, InvalidProtocolBufferException
{
PSFProtos.PSF.Builder psfBuilder = PSFProtos.PSF.newBuilder();
PSFParameter.Builder psfParamBuilder = PSFProtos.PSFParameter.newBuilder();
psfBuilder.setPsfType(PSFType.TWO_AXIS_AND_THETA_GAUSSIAN_2D);
psfParamBuilder.setName("X\"SD");
psfParamBuilder.setUnit(PSFParameterUnit.DISTANCE);
psfParamBuilder.setValue(1.1);
psfBuilder.addParameters(psfParamBuilder);
psfParamBuilder.setName("Y SD");
psfParamBuilder.setUnit(PSFParameterUnit.DISTANCE);
psfParamBuilder.setValue(1.2);
psfBuilder.addParameters(psfParamBuilder);
psfParamBuilder.setName("'Angle");
psfParamBuilder.setUnit(PSFParameterUnit.ANGLE);
psfParamBuilder.clearValue();
psfBuilder.addParameters(psfParamBuilder);
// Standard string
String e = psfBuilder.toString();
PSFProtos.PSF psf = psfBuilder.build();
String o = psf.toString();
System.out.printf(o);
Assert.assertEquals(e, o);
psfBuilder.clear();
TextFormat.merge(o, psfBuilder);
Assert.assertTrue("Merge string", psf.equals(psfBuilder.build()));
// Short string
String o2 = TextFormat.shortDebugString(psf);
System.out.println(o2);
psfBuilder.clear();
TextFormat.merge(o2, psfBuilder);
Assert.assertTrue("Merge short string", psf.equals(psfBuilder.build()));
// JSON
Printer printer = JsonFormat.printer().omittingInsignificantWhitespace();
String json = printer.print(psf);
System.out.println(json);
json = JSONUtils.simplify(json);
System.out.println(json);
psfBuilder.clear();
JsonFormat.parser().merge(json, psfBuilder);
Assert.assertTrue("Merge JSON", psf.equals(psfBuilder.build()));
}
开发者ID:aherbert，项目名称:GDSC-SMLM，代码行数:50，代码来源:PSFProtosTest.java
示例12: getProcessor
import com.google.protobuf.TextFormat.ParseException; //导入依赖的package包/类
@Override
protected CompilerPass getProcessor(final Compiler compiler) {
ConformanceConfig.Builder builder = ConformanceConfig.newBuilder();
try {
TextFormat.merge(configuration, builder);
} catch (ParseException e) {
throw new RuntimeException(e);
}
return new CheckConformance(compiler, ImmutableList.of(builder.build()));
}
开发者ID:google，项目名称:closure-compiler，代码行数:11，代码来源:CheckConformanceTest.java
示例13: parseConfigProto
import com.google.protobuf.TextFormat.ParseException; //导入依赖的package包/类
private ValidatedConformanceConfig parseConfigProto(String textProto) {
ConformanceConfig.Builder builder = ConformanceConfig.newBuilder();
try {
TextFormat.merge(textProto, builder);
} catch (ParseException pe) {
throw new RuntimeException(pe);
}
return ValidatedConformanceConfig.create(builder.build());
}
开发者ID:google，项目名称:closure-templates，代码行数:10，代码来源:SoyConformanceTest.java
示例14: parsePlatform
import com.google.protobuf.TextFormat.ParseException; //导入依赖的package包/类
static Platform parsePlatform(Label platformLabel, @Nullable String platformDescription) {
Platform.Builder platformBuilder = Platform.newBuilder();
try {
if (platformDescription != null) {
TextFormat.getParser().merge(platformDescription, platformBuilder);
}
} catch (ParseException e) {
throw new IllegalArgumentException(
String.format(
"Failed to parse remote_execution_properties from platform %s", platformLabel),
e);
}
return platformBuilder.build();
}
开发者ID:bazelbuild，项目名称:bazel，代码行数:15，代码来源:RemoteSpawnRunner.java
示例15: mergeCrosstoolConfig
import com.google.protobuf.TextFormat.ParseException; //导入依赖的package包/类
public static String mergeCrosstoolConfig(String original, CToolchain toolchain)
throws TextFormat.ParseException {
CrosstoolConfig.CrosstoolRelease.Builder builder =
CrosstoolConfig.CrosstoolRelease.newBuilder();
TextFormat.merge(original, builder);
for (CToolchain.Builder toolchainBuilder : builder.getToolchainBuilderList()) {
toolchainBuilder.mergeFrom(toolchain);
}
return TextFormat.printToString(builder.build());
}
开发者ID:bazelbuild，项目名称:bazel，代码行数:11，代码来源:MockCcSupport.java
示例16: addLibcLabelToCrosstool
import com.google.protobuf.TextFormat.ParseException; //导入依赖的package包/类
public static String addLibcLabelToCrosstool(String original, String label)
throws TextFormat.ParseException {
CrosstoolConfig.CrosstoolRelease.Builder builder =
CrosstoolConfig.CrosstoolRelease.newBuilder();
TextFormat.merge(original, builder);
for (CrosstoolConfig.CToolchain.Builder toolchain : builder.getToolchainBuilderList()) {
toolchain.setDefaultGrteTop(label);
}
return TextFormat.printToString(builder.build());
}
开发者ID:bazelbuild，项目名称:bazel，代码行数:11，代码来源:MockCcSupport.java
示例17: startJSON
import com.google.protobuf.TextFormat.ParseException; //导入依赖的package包/类
public void startJSON() throws ParseException, IOException
{
found = false;
end = false;
}
开发者ID:apache，项目名称:apex-malhar，代码行数:6，代码来源:JsonKeyFinder.java
示例18: endJSON
import com.google.protobuf.TextFormat.ParseException; //导入依赖的package包/类
public void endJSON() throws ParseException, IOException
{
end = true;
}
开发者ID:apache，项目名称:apex-malhar，代码行数:5，代码来源:JsonKeyFinder.java
示例19: startArray
import com.google.protobuf.TextFormat.ParseException; //导入依赖的package包/类
public boolean startArray() throws ParseException, IOException
{
return true;
}
开发者ID:apache，项目名称:apex-malhar，代码行数:5，代码来源:JsonKeyFinder.java
示例20: startObject
import com.google.protobuf.TextFormat.ParseException; //导入依赖的package包/类
public boolean startObject() throws ParseException, IOException
{
return true;
}
开发者ID:apache，项目名称:apex-malhar，代码行数:5，代码来源:JsonKeyFinder.java
注：本文中的com.google.protobuf.TextFormat.ParseException类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论