本文整理了Java中org.opendaylight.yangtools.yang.model.repo.api.YangTextSchemaSource类的一些代码示例，展示了YangTextSchemaSource类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。YangTextSchemaSource类的具体详情如下：
包路径：org.opendaylight.yangtools.yang.model.repo.api.YangTextSchemaSource
类名称：YangTextSchemaSource

YangTextSchemaSource介绍

[英]YANG text schema source representation. Exposes an RFC6020 or RFC7950 text representation as an InputStream.
[中]YANG文本模式源代码表示。将RFC6020或RFC7950文本表示形式公开为InputStream。

代码示例

代码示例来源：origin: org.opendaylight.mdsal/mdsal-binding-generator-impl

private static YangTextSchemaSource toYangTextSource(final SourceIdentifier identifier,
    final YangModuleInfo moduleInfo) {
  return YangTextSchemaSource.delegateForByteSource(identifier, moduleInfo.getYangTextByteSource());
}

代码示例来源：origin: opendaylight/controller

public YangTextSchemaSourceSerializationProxy(final YangTextSchemaSource source) throws IOException {
  this.revision = source.getIdentifier().getRevision().orElse(null);
  this.name = source.getIdentifier().getName();
  this.schemaSource = source.read();
}

代码示例来源：origin: org.opendaylight.yangtools/yang-parser-rfc7950

/**
 * Create a {@link YangStatementStreamSource} for a {@link YangTextSchemaSource}.
 *
 * @param source YangTextSchemaSource, must not be null
 * @return A new {@link YangStatementStreamSource}
 * @throws IOException When we fail to read the source
 * @throws YangSyntaxErrorException If the source fails basic parsing
 */
public static YangStatementStreamSource create(final YangTextSchemaSource source) throws IOException,
    YangSyntaxErrorException {
  final StatementContext context;
  try (InputStream stream = source.openStream()) {
    context = parseYangSource(source.getIdentifier(), stream);
  }
  return new YangStatementStreamSource(source.getIdentifier(), context, source.getSymbolicName().orElse(null));
}

代码示例来源：origin: org.opendaylight.yangtools/yang-model-util

@Override
@SuppressFBWarnings(value = "RCN_REDUNDANT_NULLCHECK_WOULD_HAVE_BEEN_A_NPE",
  justification = "https://github.com/spotbugs/spotbugs/issues/600")
protected void storeAsType(final File file, final YangTextSchemaSource cast) {
  try (InputStream castStream = cast.openStream()) {
    Files.copy(castStream, file.toPath(), StandardCopyOption.REPLACE_EXISTING);
  } catch (final IOException e) {
    throw new IllegalStateException("Cannot store schema source " + cast.getIdentifier() + " to " + file,
        e);
  }
}

代码示例来源：origin: opendaylight/controller

@Test
public void getExistingYangTextSchemaSource() throws IOException, SchemaSourceException {
  String source = "Test";
  YangTextSchemaSource schemaSource = YangTextSchemaSource.delegateForByteSource(
      ID, ByteSource.wrap(source.getBytes()));
  YangTextSchemaSourceSerializationProxy sourceProxy = new YangTextSchemaSourceSerializationProxy(schemaSource);
  Mockito.when(mockedRemoteSchemaRepository.getYangTextSchemaSource(ID))
    .thenReturn(Futures.successful(sourceProxy));
  YangTextSchemaSource providedSource = remoteSchemaProvider.getSource(ID).checkedGet();
  assertEquals(providedSource.getIdentifier(), ID);
  assertArrayEquals(providedSource.read(), schemaSource.read());
}

代码示例来源：origin: opendaylight/yangtools

final List<YangTextSchemaSource> sourcesInProject = new ArrayList<>(yangFilesInProject.size());
for (final File f : yangFilesInProject) {
  final YangTextSchemaSource textSource = YangTextSchemaSource.forFile(f);
  final ASTSchemaSource astSource = TextToASTTransformer.transformText(textSource);
  if (!astSource.getIdentifier().equals(textSource.getIdentifier())) {
    sourcesInProject.add(YangTextSchemaSource.delegateForByteSource(astSource.getIdentifier(),
      textSource));
  } else {

代码示例来源：origin: org.opendaylight.yangtools/yang-parser-impl

final SourceIdentifier providedId = source.getIdentifier();
final SourceIdentifier parsedId = ast.getIdentifier();
final YangTextSchemaSource text;
  text = YangTextSchemaSource.delegateForByteSource(parsedId, source);
} else {
  text = source;

代码示例来源：origin: org.opendaylight.yangtools/yang-parser-rfc7950

public static ASTSchemaSource transformText(final YangTextSchemaSource text) throws SchemaSourceException,
      IOException, YangSyntaxErrorException {
    final YangStatementStreamSource src = YangStatementStreamSource.create(text);
    final ParserRuleContext ctx = src.getYangAST();
    LOG.debug("Model {} parsed successfully", text);

    // TODO: missing validation (YangModelBasicValidationListener should be re-implemented to new parser)

    return ASTSchemaSource.create(text.getIdentifier(), text.getSymbolicName().orElse(null), ctx);
  }
}

代码示例来源：origin: opendaylight/yangtools

@Override
  void addYangsToMetaInf(final MavenProject project, final Collection<YangTextSchemaSource> modelsInProject)
      throws IOException {
    final File generatedYangDir = new GeneratedDirectories(project).getYangDir();
    LOG.debug("Generated dir {}", generatedYangDir);
    // copy project's src/main/yang/*.yang to ${project.builddir}/generated-sources/yang/META-INF/yang/
    // This honors setups like a Eclipse-profile derived one
    final File withMetaInf = new File(generatedYangDir, YangToSourcesProcessor.META_INF_YANG_STRING);
    for (YangTextSchemaSource source : modelsInProject) {
      final String fileName = source.getIdentifier().toYangFilename();
      final File file = new File(withMetaInf, fileName);
      Files.createParentDirs(file);
      source.copyTo(Files.asByteSink(file));
      LOG.debug("Created file {} for {}", file, source.getIdentifier());
    }
    setResource(generatedYangDir, project);
    LOG.debug("{} YANG files marked as resources: {}", YangToSourcesProcessor.LOG_PREFIX, generatedYangDir);
  }
}

代码示例来源：origin: opendaylight/controller

@Override
public void onSuccess(@Nonnull final YangTextSchemaSource result) {
  try {
    promise.success(new YangTextSchemaSourceSerializationProxy(result));
  } catch (IOException e) {
    LOG.warn("Unable to read schema source for {}", result.getIdentifier(), e);
    promise.failure(e);
  }
}

代码示例来源：origin: opendaylight/yangtools

/**
 * Create a new {@link YangTextSchemaSource} backed by a resource available in the ClassLoader where this
 * class resides.
 *
 * @param resourceName Resource name
 * @return A new instance.
 * @throws IllegalArgumentException if the resource does not exist or if the name has invalid format
 */
// FIXME: 3.0.0: YANGTOOLS-849: return YangTextSchemaSource
public static @NonNull ResourceYangTextSchemaSource forResource(final String resourceName) {
  return forResource(YangTextSchemaSource.class, resourceName);
}

代码示例来源：origin: opendaylight/yangtools

/**
 * Create a new YangTextSchemaSource backed by a {@link File} with {@link SourceIdentifier} derived from the file
 * name.
 *
 * @param file Backing File
 * @return A new YangTextSchemaSource
 * @throws IllegalArgumentException if the file name has invalid format or if the supplied File is not a file
 * @throws NullPointerException if file is null
 */
public static @NonNull YangTextSchemaSource forFile(final File file) {
  checkArgument(file.isFile(), "Supplied file %s is not a file", file);
  return new YangTextFileSchemaSource(identifierFromFilename(file.getName()), file);
}

代码示例来源：origin: org.opendaylight.controller/netconf-testtool

private Map<ModuleBuilder, String> toModuleBuilders(final Map<SourceIdentifier, Map.Entry<ASTSchemaSource, YangTextSchemaSource>> sources) {
  final Map<SourceIdentifier, ParserRuleContext> asts = Maps.transformValues(sources, new Function<Map.Entry<ASTSchemaSource, YangTextSchemaSource>, ParserRuleContext>() {
    @Override
    public ParserRuleContext apply(final Map.Entry<ASTSchemaSource, YangTextSchemaSource> input) {
      return input.getKey().getAST();
    }
  });
  final Map<String, NavigableMap<Date, URI>> namespaceContext = BuilderUtils.createYangNamespaceContext(
      asts.values(), Optional.<SchemaContext>absent());
  final ParseTreeWalker walker = new ParseTreeWalker();
  final Map<ModuleBuilder, String> sourceToBuilder = new HashMap<>();
  for (final Map.Entry<SourceIdentifier, ParserRuleContext> entry : asts.entrySet()) {
    final ModuleBuilder moduleBuilder = YangParserListenerImpl.create(namespaceContext, entry.getKey().getName(),
        walker, entry.getValue()).getModuleBuilder();
    try(InputStreamReader stream = new InputStreamReader(sources.get(entry.getKey()).getValue().openStream(), Charsets.UTF_8)) {
      sourceToBuilder.put(moduleBuilder, CharStreams.toString(stream));
    } catch (final IOException e) {
      throw new RuntimeException(e);
    }
  }
  return sourceToBuilder;
}

代码示例来源：origin: opendaylight/yangtools

@Override
  Collection<YangTextSchemaSource> sources() {
    return ImmutableList.of(YangTextSchemaSource.forFile(file()));
  }
}

代码示例来源：origin: opendaylight/controller

@Test
public void testGetExistingYangTextSchemaSource() throws Exception {
  String source = "Test source.";
  YangTextSchemaSource schemaSource = YangTextSchemaSource.delegateForByteSource(
      ID, ByteSource.wrap(source.getBytes()));
  Mockito.when(mockedLocalRepository.getSchemaSource(ID, YangTextSchemaSource.class)).thenReturn(
      Futures.immediateCheckedFuture(schemaSource));
  Future<YangTextSchemaSourceSerializationProxy> retrievedSourceFuture =
      remoteRepository.getYangTextSchemaSource(ID);
  assertTrue(retrievedSourceFuture.isCompleted());
  YangTextSchemaSource resultSchemaSource = Await.result(retrievedSourceFuture,
      FiniteDuration.Zero()).getRepresentation();
  assertEquals(resultSchemaSource.getIdentifier(), schemaSource.getIdentifier());
  assertArrayEquals(resultSchemaSource.read(), schemaSource.read());
}

代码示例来源：origin: opendaylight/yangtools

final SourceIdentifier providedId = source.getIdentifier();
final SourceIdentifier parsedId = ast.getIdentifier();
final YangTextSchemaSource text;
  text = YangTextSchemaSource.delegateForByteSource(parsedId, source);
} else {
  text = source;

代码示例来源：origin: opendaylight/yangtools

@Override
@SuppressFBWarnings(value = "RCN_REDUNDANT_NULLCHECK_WOULD_HAVE_BEEN_A_NPE",
  justification = "https://github.com/spotbugs/spotbugs/issues/600")
protected void storeAsType(final File file, final YangTextSchemaSource cast) {
  try (InputStream castStream = cast.openStream()) {
    Files.copy(castStream, file.toPath(), StandardCopyOption.REPLACE_EXISTING);
  } catch (final IOException e) {
    throw new IllegalStateException("Cannot store schema source " + cast.getIdentifier() + " to " + file,
        e);
  }
}

代码示例来源：origin: org.opendaylight.controller/sal-clustering-commons

@Override
public void onSuccess(YangTextSchemaSource result) {
  try {
    promise.success(new YangTextSchemaSourceSerializationProxy(result));
  } catch (IOException e) {
    LOG.warn("Unable to read schema source for {}", result.getIdentifier(), e);
    promise.failure(e);
  }
}

代码示例来源：origin: org.opendaylight.yangtools/yang-model-api

/**
 * Create a new {@link YangTextSchemaSource} backed by a resource available in the ClassLoader where this
 * class resides.
 *
 * @param resourceName Resource name
 * @return A new instance.
 * @throws IllegalArgumentException if the resource does not exist or if the name has invalid format
 */
// FIXME: 3.0.0: YANGTOOLS-849: return YangTextSchemaSource
public static @NonNull ResourceYangTextSchemaSource forResource(final String resourceName) {
  return forResource(YangTextSchemaSource.class, resourceName);
}

代码示例来源：origin: org.opendaylight.yangtools/yang-model-api

/**
 * Create a new YangTextSchemaSource backed by a {@link File} with {@link SourceIdentifier} derived from the file
 * name.
 *
 * @param file Backing File
 * @return A new YangTextSchemaSource
 * @throws IllegalArgumentException if the file name has invalid format or if the supplied File is not a file
 * @throws NullPointerException if file is null
 */
public static @NonNull YangTextSchemaSource forFile(final File file) {
  checkArgument(file.isFile(), "Supplied file %s is not a file", file);
  return new YangTextFileSchemaSource(identifierFromFilename(file.getName()), file);
}