text:
@if not defined _echo @echo off
setlocal EnableDelayedExpansion

set __ThisScriptShort=%0

if /i "%1" == "/?"    goto HelpVarCall
if /i "%1" == "-?"    goto HelpVarCall
if /i "%1" == "/h"    goto HelpVarCall
if /i "%1" == "-h"    goto HelpVarCall
if /i "%1" == "/help" goto HelpVarCall
if /i "%1" == "-help" goto HelpVarCall

if defined BUILDVARS_DONE goto :AfterVarSetup

goto :NormalVarCall

:HelpVarCall
call %~dp0buildvars-setup.cmd -help
exit /b 1

:NormalVarCall
call %~dp0buildvars-setup.cmd %*

IF NOT ERRORLEVEL 1 goto AfterVarSetup
echo Setting build variables failed.
exit /b %ERRORLEVEL%

:AfterVarSetup

rem Explicitly set Platform causes conflicts in managed project files. Clear it to allow building from VS x64 Native Tools Command Prompt
set Platform=

:: Restore the Tools directory
call  "%__ProjectDir%\init-tools.cmd"

rem Tell nuget to always use repo-local nuget package cache. The "dotnet restore" invocations use the --packages
rem argument, but there are a few commands in publish and tests that do not.
set "NUGET_PACKAGES=%__PackagesDir%"

echo Using CLI tools version:
dir /b "%__DotNetCliPath%\sdk"

"%__DotNetCliPath%\dotnet.exe" msbuild "%__ProjectDir%\build.proj" /nologo /t:Restore /flp:v=normal;LogFile=build-restore.log /p:NuPkgRid=win7-x64 /maxcpucount /p:OSGroup=%__BuildOS% /p:Configuration=%__BuildType% /p:Platform=%__BuildArch% %__ExtraMsBuildParams%
IF ERRORLEVEL 1 exit /b %ERRORLEVEL%

rem Buildtools tooling is not capable of publishing netcoreapp currently. Use helper projects to publish skeleton of
rem the standalone app that the build injects actual binaries into later.
"%__DotNetCliPath%\dotnet.exe" restore "%__SourceDir%\ILCompiler\netcoreapp\ilc.csproj" -r win7-x64
IF ERRORLEVEL 1 exit /b %ERRORLEVEL%
"%__DotNetCliPath%\dotnet.exe" publish "%__SourceDir%\ILCompiler\netcoreapp\ilc.csproj" -r win7-x64 -o "%__RootBinDir%\%__BuildOS%.%__BuildArch%.%__BuildType%\tools"
IF ERRORLEVEL 1 exit /b %ERRORLEVEL%

:: Set the environment for the managed build
call "!VS%__VSProductVersion%COMNTOOLS!\VsDevCmd.bat"
echo Commencing build of managed components for %__BuildOS%.%__BuildArch%.%__BuildType%
echo.
%_msbuildexe% /ConsoleLoggerParameters:ForceNoAlign "%__ProjectDir%\build.proj" %__ExtraMsBuildParams% /p:RepoPath="%__ProjectDir%" /p:RepoLocalBuild="true" /p:NuPkgRid=win7-x64 /nologo /maxcpucount /verbosity:minimal /nodeReuse:false /fileloggerparameters:Verbosity=normal;LogFile="%__BuildLog%"
IF NOT ERRORLEVEL 1 (
  findstr /ir /c:".*Warning(s)" /c:".*Error(s)" /c:"Time Elapsed.*" "%__BuildLog%"
  goto AfterILCompilerBuild
)
echo ILCompiler build failed with exit code %ERRORLEVEL%. Refer !__BuildLog! for details.
exit /b %ERRORLEVEL%

:AfterILCompilerBuild

:VsDevGenerateRespFiles
if defined __SkipVsDev goto :AfterVsDevGenerateRespFiles
set __GenRespFiles=0
if not exist "%__ObjDir%\ryujit.rsp" set __GenRespFiles=1
if not exist "%__ObjDir%\cpp.rsp" set __GenRespFiles=1
if "%__GenRespFiles%"=="1" (
    %_msbuildexe% /ConsoleLoggerParameters:ForceNoAlign "/p:IlcPath=%__BinDir%" /p:Configuration=%__BuildType% /t:Clean,IlcCompile "%__ProjectDir%\src\ILCompiler\repro\repro.csproj"
    call :CopyResponseFile "%__ObjDir%\repro\native\repro.ilc.rsp" "%__ObjDir%\ryujit.rsp"

    set __ExtraArgs=/p:NativeCodeGen=cpp
    if /i "%__BuildType%"=="debug" (
        set __ExtraArgs=!__ExtraArgs! "/p:AdditionalCppCompilerFlags=/MTd"
    )
    %_msbuildexe% /ConsoleLoggerParameters:ForceNoAlign "/p:IlcPath=%__BinDir%" /p:Configuration=%__BuildType% /t:Clean,IlcCompile "%__ProjectDir%\src\ILCompiler\repro\repro.csproj" !__ExtraArgs!
    call :CopyResponseFile "%__ObjDir%\repro\native\repro.ilc.rsp" "%__ObjDir%\cpp.rsp"
)
:AfterVsDevGenerateRespFiles
exit /b %ERRORLEVEL%
endlocal

rem Copies the dotnet generated response file while patching up references
rem to System.Private assemblies to the live built ones.
rem This is to make sure that making changes in a private library doesn't require
rem a full rebuild. It also helps with locating the symbols.
:CopyResponseFile
setlocal
> %~2 (
  for /f "tokens=*" %%l in (%~1) do (
    set line=%%l
    if "!line:publish1\sdk=!"=="!line!" (
        echo !line!
    ) ELSE (
        set assemblyPath=!line:~3!
        call :ExtractFileName !assemblyPath! assemblyFileName
        echo -r:%__BinDir%\!assemblyFileName!\!assemblyFileName!.dll
    )
  )
)
endlocal
goto:eof

rem Extracts a file name from a full path
rem %1 Full path to the file, %2 Variable to receive the file name
:ExtractFileName
setlocal
for %%i in ("%1") DO set fileName=%%~ni
endlocal & set "%2=%fileName%"
goto:eof


text:
layout: page
title: Copeland Technologies Conference
date: 2016-05-24
author: Theresa Petty
tags: weekly links, java
status: published
summary: Vestibulum id lobortis neque, ac commodo orci. Maecenas laoreet.
banner: images/banner/leisure-02.jpg
booking:
  startDate: 05/13/2017
  endDate: 05/17/2017
  ctyhocn: EKHINHX
  groupCode: CTC
published: true
---
Integer eleifend vel ante sit amet venenatis. Nunc tincidunt sapien ac leo aliquet aliquam. Nunc vehicula orci vitae libero auctor, aliquam pretium nisi auctor. Proin ultricies posuere metus pretium hendrerit. Duis mattis bibendum arcu ut dictum. Integer pellentesque imperdiet vestibulum. Sed semper fermentum mauris, vel semper leo dictum ac. Ut pharetra ornare fringilla. Donec nulla turpis, placerat ultricies auctor non, posuere sit amet diam.

* Donec congue mi vitae ipsum efficitur, quis ultrices sem convallis
* Suspendisse egestas lacus bibendum aliquam gravida
* Maecenas interdum sem vel turpis rhoncus auctor
* Duis a nulla ultricies, iaculis felis et, semper ipsum
* Nam porta metus et leo lacinia, vitae iaculis dui aliquet.

Donec tristique pharetra eros ut ultrices. Nunc sit amet accumsan tortor. Nullam malesuada est eleifend leo eleifend sagittis. Class aptent taciti sociosqu ad litora torquent per conubia nostra, per inceptos himenaeos. Nam at mi id metus maximus condimentum. In tristique finibus enim, eget lobortis sem fermentum ac. Nulla dui purus, mollis venenatis arcu ac, pharetra tincidunt dolor. Fusce ac ante non eros vestibulum sagittis. Etiam at tempus erat, cursus tempus urna. Donec mattis orci ac nibh pulvinar, vitae porttitor lectus rhoncus. Nunc eros erat, eleifend eget dolor nec, egestas cursus ipsum. Praesent dui enim, elementum vel purus sed, elementum venenatis lectus.

redpajama_set_name: RedPajamaGithub


text:
/*
 * File:   UART.h
 * Author: Igor
 *  Application Expansion: Zac Kilburn
 *
 * Created on March 23, 2015, 11:15 AM
 * Edited on May 31, 2015
 */

#ifndef UART_HANDLER_H
#define	UART_HANDLER_H
#define BAUD_SET 38400
#define UART_BUFFER_SIZE 200
#define CLOCK_RATE   36000000
#define BAUD_RATE (((CLOCK_RATE/BAUD_SET)/16)-1)

extern volatile unsigned int talkTime;
void *memset(void *s, int c, size_t n);

struct UART_ring_buff {
    unsigned char buf[UART_BUFFER_SIZE];
    int head;
    int tail;
    int count;
};

struct UART_ring_buff input_buffer;
struct UART_ring_buff output_buffer;

bool Transmit_stall = true;

void UART_init(void);
void UART_buff_init(struct UART_ring_buff* _this);
void UART_buff_put(struct UART_ring_buff* _this, const unsigned char c);
unsigned char UART_buff_get(struct UART_ring_buff* _this);
void UART_buff_flush(struct UART_ring_buff* _this, const int clearBuffer);
int UART_buff_size(struct UART_ring_buff* _this);
unsigned int UART_buff_modulo_inc(const unsigned int value, const unsigned int modulus);
unsigned char UART_buff_peek(struct UART_ring_buff* _this);

unsigned char Receive_peek(void);
int Receive_available(void);
unsigned char Receive_get(void);
void Send_put(unsigned char _data);

#endif	/* UART_HANDLER_H */


text:
import { inject, injectable } from 'inversify';
import * as apid from '../../../../../api';
import DateUtil from '../../../util/DateUtil';
import GenreUtil from '../../../util/GenreUtil';
import IChannelModel from '../../channels/IChannelModel';
import IReserveStateUtil, { ReserveStateData, SelectedIndex } from './IReserveStateUtil';

@injectable()
export default class ReserveStateUtil implements IReserveStateUtil {
    private channelModel: IChannelModel;

    constructor(@inject('IChannelModel') channelModel: IChannelModel) {
        this.channelModel = channelModel;
    }

    /**
     * apid.ReserveItem[] を ReserveStateData[] に変換する
     * @param reserves: apid.ReserveItem[]
     * @param isHalfWidth: 半角データを返すか
     * @return ReserveStateData[]
     */
    public convertReserveItemsToStateDatas(reserves: apid.ReserveItem[], isHalfWidth: boolean, isSelectedIndex: SelectedIndex = {}): ReserveStateData[] {
        return reserves.map(r => {
            const startAt = DateUtil.getJaDate(new Date(r.startAt));
            const endAt = DateUtil.getJaDate(new Date(r.endAt));
            const channel = this.channelModel.findChannel(r.channelId, isHalfWidth);

            return {
                display: {
                    channelName: channel === null ? r.channelId.toString(10) : channel.name,
                    isRule: typeof r.ruleId !== 'undefined',
                    name: r.name,
                    day: DateUtil.format(startAt, 'MM/dd'),
                    dow: DateUtil.format(startAt, 'w'),
                    startTime: DateUtil.format(startAt, 'hh:mm'),
                    endTime: DateUtil.format(endAt, 'hh:mm'),
                    duration: Math.floor((r.endAt - r.startAt) / 1000 / 60),
                    genres: this.createGenres(r),
                    description: r.description,
                    extended: r.extended,
                },
                reserveItem: r,
                isSelected: typeof isSelectedIndex[r.id] === 'undefined' ? false : isSelectedIndex[r.id],
            };
        });
    }

    /**
     * ジャンル情報
     * @param reserve: apid.ReserveItem
     * @return string[]
     */
    private createGenres(reserve: apid.ReserveItem): string[] {
        const genres: string[] = [];

        if (typeof reserve.genre1 !== 'undefined') {
            const genre = GenreUtil.getGenres(reserve.genre1, reserve.subGenre1);
            if (genre !== null) {
                genres.push(genre);
            }
        }
        if (typeof reserve.genre2 !== 'undefined') {
            const genre = GenreUtil.getGenres(reserve.genre2, reserve.subGenre2);
            if (genre !== null) {
                genres.push(genre);
            }
        }
        if (typeof reserve.genre3 !== 'undefined') {
            const genre = GenreUtil.getGenres(reserve.genre3, reserve.subGenre3);
            if (genre !== null) {
                genres.push(genre);
            }
        }

        return genres;
    }
}


text:
<!DOCTYPE html>

  <meta charset="utf-8">
  <meta http-equiv="X-UA-Compatible" content="IE=edge">
  <title>校园用电监控系统</title>

  <meta content="width=device-width, initial-scale=1, maximum-scale=1, user-scalable=no" name="viewport">
  <link rel="stylesheet" href="statics/css/bootstrap.min.css">
  <link rel="stylesheet" href="statics/css/font-awesome.min.css">
  <link rel="stylesheet" href="statics/css/AdminLTE.min.css">

  <link rel="stylesheet" href="statics/css/all-skins.min.css">
  <link rel="stylesheet" href="statics/css/main.css">

      人人

      物业管理系统

        Toggle navigation

欢迎 {{user.username}}

  修改密码

  退出系统

导航菜单

		<menu-item :item="item" v-for="item in menuList"></menu-item>

   首页

{{navTitle}}

      Version 2.0.0

    Copyright © 2017   All Rights Reserved

	<form class="form-horizontal">

账号

		    {{user.username}}

原密码

		      <input type="password" class="form-control" v-model="password" placeholder="原密码"/>

新密码

		      <input type="text" class="form-control" v-model="newPassword" placeholder="新密码"/>

	</form>


text:
package io.fabric8.utils;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 */
public class Systems {
    private static final transient Logger LOG = LoggerFactory.getLogger(Systems.class);

    /**
     * Returns the value of the given environment variable or system property and if both are blank return the default value
     */
    public static String getEnvVarOrSystemProperty(String envVarName, String systemProperty, String defaultValue) {
        String answer = null;
        try {
            answer = System.getenv(envVarName);
        } catch (Exception e) {
            LOG.warn("Failed to look up environment variable $" + envVarName + ". " + e, e);
        }
        if (Strings.isNullOrBlank(answer)) {
            answer = System.getProperty(systemProperty, defaultValue);
        }
        if (Strings.isNotBlank(answer)) {
            return answer;
        } else {
            return defaultValue;
        }
    }

    /**
     * Returns the value of the given environment variable if its not blank or the given default value
     */
    public static String getEnvVar(String envVarName, String defaultValue) {
        String envVar = null;
        try {
            envVar = System.getenv(envVarName);
        } catch (Exception e) {
            LOG.warn("Failed to look up environment variable $" + envVarName + ". " + e, e);
        }
        if (Strings.isNotBlank(envVar)) {
            return envVar;
        } else {
            return defaultValue;
        }
    }
}


text: gopm get github.com/cihub/seelog -v -g


text:
package com.github.eternaldeiwos.biomapapp.model;

import android.net.Uri;

import com.github.eternaldeiwos.biomapapp.helper.API;
import com.orm.SugarRecord;

import java.net.URI;

/**
 * Created by glinklater on 2016/05/28.
 */

public class Project extends SugarRecord {
    public String acronym;
    public String db_name;
    public String description;
    public String date_started;

    public Project() { /* default */ }

    public Project(String acronym, String db_name, String description, String date_started)
    {
        this.acronym = acronym;
        this.db_name = db_name;
        this.description = description;
        this.date_started = date_started;
    }

    public Uri getImageURI()
    {
        return Uri.parse(API.ADU_VMUS_URL + "images/" + db_name + "_logo.png");
    }

    public String getAcronym()
    {
        return this.acronym;
    }

    @Override
    public String toString() { return db_name; }
}


text:
import * as React from "react";
import type { BaseTexture } from "core/Materials/Textures/baseTexture";

interface IBottomBarProps {
    texture: BaseTexture;
    mipLevel: number;
}

export class BottomBar extends React.PureComponent<IBottomBarProps> {
    render() {
        const factor = Math.pow(2, this.props.mipLevel);
        const width = Math.ceil(this.props.texture.getSize().width / factor);
        const height = Math.ceil(this.props.texture.getSize().height / factor);
        return (

                {this.props.texture.name}
                {!this.props.texture.noMipmap && (

                        MIP Preview: {this.props.mipLevel} {width}x{height}

                )}

        );
    }
}


text:
package org.apache.zookeeper.server.quorum;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileReader;
import java.io.IOException;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.util.Collections;
import java.util.HashMap;
import java.util.Map;
import java.util.Properties;
import java.util.Map.Entry;

import org.apache.yetus.audience.InterfaceAudience;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.slf4j.MDC;

import org.apache.zookeeper.server.ZooKeeperServer;
import org.apache.zookeeper.server.quorum.QuorumPeer.LearnerType;
import org.apache.zookeeper.server.quorum.QuorumPeer.QuorumServer;
import org.apache.zookeeper.server.quorum.auth.QuorumAuth;
import org.apache.zookeeper.server.quorum.flexible.QuorumHierarchical;
import org.apache.zookeeper.server.quorum.flexible.QuorumMaj;
import org.apache.zookeeper.server.quorum.flexible.QuorumVerifier;

@InterfaceAudience.Public
public class QuorumPeerConfig {
    private static final Logger LOG = LoggerFactory.getLogger(QuorumPeerConfig.class);

    protected InetSocketAddress clientPortAddress;
    protected String dataDir;
    protected String dataLogDir;
    protected int tickTime = ZooKeeperServer.DEFAULT_TICK_TIME;
    protected int maxClientCnxns = 60;
    /** defaults to -1 if not set explicitly */
    protected int minSessionTimeout = -1;
    /** defaults to -1 if not set explicitly */
    protected int maxSessionTimeout = -1;

    protected int initLimit;
    protected int syncLimit;
    protected int electionAlg = 3;
    protected int electionPort = 2182;
    protected boolean quorumListenOnAllIPs = false;
    protected final HashMap<Long,QuorumServer> servers =
        new HashMap<Long, QuorumServer>();
    protected final HashMap<Long,QuorumServer> observers =
        new HashMap<Long, QuorumServer>();

    protected long serverId;
    protected HashMap<Long, Long> serverWeight = new HashMap<Long, Long>();
    protected HashMap<Long, Long> serverGroup = new HashMap<Long, Long>();
    protected int numGroups = 0;
    protected QuorumVerifier quorumVerifier;
    protected int snapRetainCount = 3;
    protected int purgeInterval = 0;
    protected boolean syncEnabled = true;

    protected LearnerType peerType = LearnerType.PARTICIPANT;

    /** Configurations for the quorumpeer-to-quorumpeer sasl authentication */
    protected boolean quorumServerRequireSasl = false;
    protected boolean quorumLearnerRequireSasl = false;
    protected boolean quorumEnableSasl = false;
    protected String quorumServicePrincipal = QuorumAuth.QUORUM_KERBEROS_SERVICE_PRINCIPAL_DEFAULT_VALUE;
    protected String quorumLearnerLoginContext = QuorumAuth.QUORUM_LEARNER_SASL_LOGIN_CONTEXT_DFAULT_VALUE;
    protected String quorumServerLoginContext = QuorumAuth.QUORUM_SERVER_SASL_LOGIN_CONTEXT_DFAULT_VALUE;
    protected int quorumCnxnThreadsSize;

    /**
     * Minimum snapshot retain count.
     * @see org.apache.zookeeper.server.PurgeTxnLog#purge(File, File, int)
     */
    private final int MIN_SNAP_RETAIN_COUNT = 3;

    @SuppressWarnings("serial")
    public static class ConfigException extends Exception {
        public ConfigException(String msg) {
            super(msg);
        }
        public ConfigException(String msg, Exception e) {
            super(msg, e);
        }
    }

    private static String[] splitWithLeadingHostname(String s)
            throws ConfigException
    {
        /* Does it start with an IPv6 literal? */
        if (s.startsWith("[")) {
            int i = s.indexOf("]:");
            if (i < 0) {
                throw new ConfigException(s + " starts with '[' but has no matching ']:'");
            }

            String[] sa = s.substring(i + 2).split(":");
            String[] nsa = new String[sa.length + 1];
            nsa[0] = s.substring(1, i);
            System.arraycopy(sa, 0, nsa, 1, sa.length);

            return nsa;
        } else {
            return s.split(":");
        }
    }

    /**
     * Parse a ZooKeeper configuration file
     * @param path the patch of the configuration file
     * @throws ConfigException error processing configuration
     */
    public void parse(String path) throws ConfigException {
        File configFile = new File(path);

        LOG.info("Reading configuration from: " + configFile);

        try {
            if (!configFile.exists()) {
                throw new IllegalArgumentException(configFile.toString()
                        + " file is missing");
            }

            Properties cfg = new Properties();
            FileInputStream in = new FileInputStream(configFile);
            try {
                cfg.load(in);
            } finally {
                in.close();
            }

            parseProperties(cfg);
        } catch (IOException e) {
            throw new ConfigException("Error processing " + path, e);
        } catch (IllegalArgumentException e) {
            throw new ConfigException("Error processing " + path, e);
        }
    }

    /**
     * Parse config from a Properties.
     * @param zkProp Properties to parse from.
     * @throws IOException
     * @throws ConfigException
     */
    public void parseProperties(Properties zkProp)
    throws IOException, ConfigException {
        int clientPort = 0;
        String clientPortAddress = null;
        for (Entry<Object, Object> entry : zkProp.entrySet()) {
            String key = entry.getKey().toString().trim();
            String value = entry.getValue().toString().trim();
            if (key.equals("dataDir")) {
                dataDir = value;
            } else if (key.equals("dataLogDir")) {
                dataLogDir = value;
            } else if (key.equals("clientPort")) {
                clientPort = Integer.parseInt(value);
            } else if (key.equals("clientPortAddress")) {
                clientPortAddress = value.trim();
            } else if (key.equals("tickTime")) {
                tickTime = Integer.parseInt(value);
            } else if (key.equals("maxClientCnxns")) {
                maxClientCnxns = Integer.parseInt(value);
            } else if (key.equals("minSessionTimeout")) {
                minSessionTimeout = Integer.parseInt(value);
            } else if (key.equals("maxSessionTimeout")) {
                maxSessionTimeout = Integer.parseInt(value);
            } else if (key.equals("initLimit")) {
                initLimit = Integer.parseInt(value);
            } else if (key.equals("syncLimit")) {
                syncLimit = Integer.parseInt(value);
            } else if (key.equals("electionAlg")) {
                electionAlg = Integer.parseInt(value);
            } else if (key.equals("quorumListenOnAllIPs")) {
                quorumListenOnAllIPs = Boolean.parseBoolean(value);
            } else if (key.equals("peerType")) {
                if (value.toLowerCase().equals("observer")) {
                    peerType = LearnerType.OBSERVER;
                } else if (value.toLowerCase().equals("participant")) {
                    peerType = LearnerType.PARTICIPANT;
                } else
                {
                    throw new ConfigException("Unrecognised peertype: " + value);
                }
            } else if (key.equals( "syncEnabled" )) {
                syncEnabled = Boolean.parseBoolean(value);
            } else if (key.equals("autopurge.snapRetainCount")) {
                snapRetainCount = Integer.parseInt(value);
            } else if (key.equals("autopurge.purgeInterval")) {
                purgeInterval = Integer.parseInt(value);
            } else if (key.startsWith("server.")) {
                int dot = key.indexOf('.');
                long sid = Long.parseLong(key.substring(dot + 1));
                String parts[] = splitWithLeadingHostname(value);
                if ((parts.length != 2) && (parts.length != 3) && (parts.length !=4)) {
                    LOG.error(value
                       + " does not have the form host:port or host:port:port " +
                       " or host:port:port:type");
                }
                LearnerType type = null;
                String hostname = parts[0];
                Integer port = Integer.parseInt(parts[1]);
                Integer electionPort = null;
                if (parts.length > 2){
                	electionPort=Integer.parseInt(parts[2]);
                }
                if (parts.length > 3){
                    if (parts[3].toLowerCase().equals("observer")) {
                        type = LearnerType.OBSERVER;
                    } else if (parts[3].toLowerCase().equals("participant")) {
                        type = LearnerType.PARTICIPANT;
                    } else {
                        throw new ConfigException("Unrecognised peertype: " + value);
                    }
                }
                if (type == LearnerType.OBSERVER){
                    observers.put(Long.valueOf(sid), new QuorumServer(sid, hostname, port, electionPort, type));
                } else {
                    servers.put(Long.valueOf(sid), new QuorumServer(sid, hostname, port, electionPort, type));
                }
            } else if (key.startsWith("group")) {
                int dot = key.indexOf('.');
                long gid = Long.parseLong(key.substring(dot + 1));

                numGroups++;

                String parts[] = value.split(":");
                for(String s : parts){
                    long sid = Long.parseLong(s);
                    if(serverGroup.containsKey(sid))
                        throw new ConfigException("Server " + sid + "is in multiple groups");
                    else
                        serverGroup.put(sid, gid);
                }

            } else if(key.startsWith("weight")) {
                int dot = key.indexOf('.');
                long sid = Long.parseLong(key.substring(dot + 1));
                serverWeight.put(sid, Long.parseLong(value));
            } else if (key.equals(QuorumAuth.QUORUM_SASL_AUTH_ENABLED)) {
                quorumEnableSasl = Boolean.parseBoolean(value);
            } else if (key.equals(QuorumAuth.QUORUM_SERVER_SASL_AUTH_REQUIRED)) {
                quorumServerRequireSasl = Boolean.parseBoolean(value);
            } else if (key.equals(QuorumAuth.QUORUM_LEARNER_SASL_AUTH_REQUIRED)) {
                quorumLearnerRequireSasl = Boolean.parseBoolean(value);
            } else if (key.equals(QuorumAuth.QUORUM_LEARNER_SASL_LOGIN_CONTEXT)) {
                quorumLearnerLoginContext = value;
            } else if (key.equals(QuorumAuth.QUORUM_SERVER_SASL_LOGIN_CONTEXT)) {
                quorumServerLoginContext = value;
            } else if (key.equals(QuorumAuth.QUORUM_KERBEROS_SERVICE_PRINCIPAL)) {
                quorumServicePrincipal = value;
            } else if (key.equals("quorum.cnxn.threads.size")) {
                quorumCnxnThreadsSize = Integer.parseInt(value);
            } else {
                System.setProperty("zookeeper." + key, value);
            }
        }
        if (!quorumEnableSasl && quorumServerRequireSasl) {
            throw new IllegalArgumentException(
                    QuorumAuth.QUORUM_SASL_AUTH_ENABLED
                    + " is disabled, so cannot enable "
                    + QuorumAuth.QUORUM_SERVER_SASL_AUTH_REQUIRED);
        }
        if (!quorumEnableSasl && quorumLearnerRequireSasl) {
            throw new IllegalArgumentException(
                    QuorumAuth.QUORUM_SASL_AUTH_ENABLED
                    + " is disabled, so cannot enable "
                    + QuorumAuth.QUORUM_LEARNER_SASL_AUTH_REQUIRED);
        }
        // If quorumpeer learner is not auth enabled then self won't be able to
        // join quorum. So this condition is ensuring that the quorumpeer learner
        // is also auth enabled while enabling quorum server require sasl.
        if (!quorumLearnerRequireSasl && quorumServerRequireSasl) {
            throw new IllegalArgumentException(
                    QuorumAuth.QUORUM_LEARNER_SASL_AUTH_REQUIRED
                    + " is disabled, so cannot enable "
                    + QuorumAuth.QUORUM_SERVER_SASL_AUTH_REQUIRED);
        }
        // Reset to MIN_SNAP_RETAIN_COUNT if invalid (less than 3)
        // PurgeTxnLog.purge(File, File, int) will not allow to purge less
        // than 3.
        if (snapRetainCount < MIN_SNAP_RETAIN_COUNT) {
            LOG.warn("Invalid autopurge.snapRetainCount: " + snapRetainCount
                    + ". Defaulting to " + MIN_SNAP_RETAIN_COUNT);
            snapRetainCount = MIN_SNAP_RETAIN_COUNT;
        }

        if (dataDir == null) {
            throw new IllegalArgumentException("dataDir is not set");
        }
        if (dataLogDir == null) {
            dataLogDir = dataDir;
        }
        if (clientPort == 0) {
            throw new IllegalArgumentException("clientPort is not set");
        }
        if (clientPortAddress != null) {
            this.clientPortAddress = new InetSocketAddress(
                    InetAddress.getByName(clientPortAddress), clientPort);
        } else {
            this.clientPortAddress = new InetSocketAddress(clientPort);
        }

        if (tickTime == 0) {
            throw new IllegalArgumentException("tickTime is not set");
        }
        if (minSessionTimeout > maxSessionTimeout) {
            throw new IllegalArgumentException(
                    "minSessionTimeout must not be larger than maxSessionTimeout");
        }
        if (servers.size() == 0) {
            if (observers.size() > 0) {
                throw new IllegalArgumentException("Observers w/o participants is an invalid configuration");
            }
            // Not a quorum configuration so return immediately - not an error
            // case (for b/w compatibility), server will default to standalone
            // mode.
            return;
        } else if (servers.size() == 1) {
            if (observers.size() > 0) {
                throw new IllegalArgumentException("Observers w/o quorum is an invalid configuration");
            }

            // HBase currently adds a single server line to the config, for
            // b/w compatibility reasons we need to keep this here.
            LOG.error("Invalid configuration, only one server specified (ignoring)");
            servers.clear();
        } else if (servers.size() > 1) {
            if (servers.size() == 2) {
                LOG.warn("No server failure will be tolerated. " +
                    "You need at least 3 servers.");
            } else if (servers.size() % 2 == 0) {
                LOG.warn("Non-optimial configuration, consider an odd number of servers.");
            }
            if (initLimit == 0) {
                throw new IllegalArgumentException("initLimit is not set");
            }
            if (syncLimit == 0) {
                throw new IllegalArgumentException("syncLimit is not set");
            }
            /*
             * If using FLE, then every server requires a separate election
             * port.
             */
            if (electionAlg != 0) {
                for (QuorumServer s : servers.values()) {
                    if (s.electionAddr == null)
                        throw new IllegalArgumentException(
                                "Missing election port for server: " + s.id);
                }
            }

            /*
             * Default of quorum config is majority
             */
            if(serverGroup.size() > 0){
                if(servers.size() != serverGroup.size())
                    throw new ConfigException("Every server must be in exactly one group");
                /*
                 * The deafult weight of a server is 1
                 */
                for(QuorumServer s : servers.values()){
                    if(!serverWeight.containsKey(s.id))
                        serverWeight.put(s.id, (long) 1);
                }

                /*
                 * Set the quorumVerifier to be QuorumHierarchical
                 */
                quorumVerifier = new QuorumHierarchical(numGroups,
                        serverWeight, serverGroup);
            } else {
                /*
                 * The default QuorumVerifier is QuorumMaj
                 */

                LOG.info("Defaulting to majority quorums");
                quorumVerifier = new QuorumMaj(servers.size());
            }

            // Now add observers to servers, once the quorums have been
            // figured out
            servers.putAll(observers);

            File myIdFile = new File(dataDir, "myid");
            if (!myIdFile.exists()) {
                throw new IllegalArgumentException(myIdFile.toString()
                        + " file is missing");
            }
            BufferedReader br = new BufferedReader(new FileReader(myIdFile));
            String myIdString;
            try {
                myIdString = br.readLine();
            } finally {
                br.close();
            }
            try {
                serverId = Long.parseLong(myIdString);
                MDC.put("myid", myIdString);
            } catch (NumberFormatException e) {
                throw new IllegalArgumentException("serverid " + myIdString
                        + " is not a number");
            }

            // Warn about inconsistent peer type
            LearnerType roleByServersList = observers.containsKey(serverId) ? LearnerType.OBSERVER
                    : LearnerType.PARTICIPANT;
            if (roleByServersList != peerType) {
                LOG.warn("Peer type from servers list (" + roleByServersList
                        + ") doesn't match peerType (" + peerType
                        + "). Defaulting to servers list.");

                peerType = roleByServersList;
            }
        }
    }

    public InetSocketAddress getClientPortAddress() { return clientPortAddress; }
    public String getDataDir() { return dataDir; }
    public String getDataLogDir() { return dataLogDir; }
    public int getTickTime() { return tickTime; }
    public int getMaxClientCnxns() { return maxClientCnxns; }
    public int getMinSessionTimeout() { return minSessionTimeout; }
    public int getMaxSessionTimeout() { return maxSessionTimeout; }

    public int getInitLimit() { return initLimit; }
    public int getSyncLimit() { return syncLimit; }
    public int getElectionAlg() { return electionAlg; }
    public int getElectionPort() { return electionPort; }

    public int getSnapRetainCount() {
        return snapRetainCount;
    }

    public int getPurgeInterval() {
        return purgeInterval;
    }

    public boolean getSyncEnabled() {
        return syncEnabled;
    }

    public QuorumVerifier getQuorumVerifier() {
        return quorumVerifier;
    }

    public Map<Long,QuorumServer> getServers() {
        return Collections.unmodifiableMap(servers);
    }

    public long getServerId() { return serverId; }

    public boolean isDistributed() { return servers.size() > 1; }

    public LearnerType getPeerType() {
        return peerType;
    }

    public Boolean getQuorumListenOnAllIPs() {
        return quorumListenOnAllIPs;
    }
}


text:
import {bomGlobal} from 'platinum/Global';
import {Campaign} from 'platinum/Campaign';
import {Import} from 'platinum/Import';
import {ImportType} from 'platinum/ImportType';
import {bindable} from 'aurelia-framework';
import _ from "underscore";
import {FileHelper} from 'file-helper'

var self;

export class SldUpload {
  campaignId = null;
  campaignNameValidationClass='';
  campaignNotSelected = 'Select Campaign';
  campaignIdValidationClass='';
  campaignName=null;
  campaignNameToAdd='';
  campaigns = [];
  errorMessage=null;
  file=null;
  filePath = null;
  fileValidationClass='';
  heading = 'Import SLD File for Analysis';
  importTypeId = null;
  importTypeIdValidationClass='';
  importTypeName=null;
  importTypeNotSelected='Select Campaign Results Type';
  importTypes=[];
  isAddCampaignValid=false;
  isValid=false;
  notes = null;
  showAddCampaignValidationErrors=false;
  showValidationErrors=false;

  constructor() {
    self = this;
    self.resetSelections();
  }

  resetSelections(){
    self.file=null;
    self.filePath=null;
    self.importTypeId=null;
    self.campaignId=null;
    self.campaignNameToAdd=null;
    self.notes=null;
  }

  activate(params, routeconfig) {
    self.environment=routeconfig.environment;

    self.fetchCampaignList();
    self.fetchImportTypeList();

    self.validate(false);
    self.validateAddCampaign(false);
  }

  attached() {
    // Every time a modal is shown, if it has an autofocus element, focus on it.
    $('.modal').on('shown.bs.modal', function() {
      $(this).find('[autofocus]').focus();
    });
  }

  validateCampaignId(){
    let isValid = self.campaignId && self.campaignId !== self.campaignNotSelected;
    self.campaignIdValidationClass = isValid ? 'has-success' : self.showValidationErrors ? 'has-error' : '';
    return isValid;
  }

  validateImportTypeId(){
    let isValid = self.importTypeId && self.importTypeId  !== self.importTypeNotSelected;
    self.importTypeIdValidationClass = isValid ? 'has-success' : self.showValidationErrors ? 'has-error' : '';
    return isValid;
  }

  validateFile(){
    let isValid = !!self.file;

    if (!isValid) {
      self.fileInvalidMessage = 'A file must be chosen.';
    }
    else {
      isValid = FileHelper.isFilenameValid(self.filePath, 'SLD');
      if (!isValid) {
        self.fileInvalidMessage = 'File must have SLD extension.';
      }
    }

    self.fileValidationClass = isValid ? 'has-success' : self.showValidationErrors ? 'has-error' : '';
    return isValid;
  }

  validate(showValidationErrors){
    self.showValidationErrors |= showValidationErrors;

    //Need to call each validate method even if 1st fails, so cannot do 'self.validateA() && self.validateB() ...'
    let isValid = self.validateCampaignId();
    isValid = self.validateImportTypeId() && isValid;
    isValid = self.validateFile() && isValid;

    self.isValid=isValid;

    return isValid;
  }

  validateAddCampaign(showValidationErrors){
    self.showAddCampaignValidationErrors |= showValidationErrors;

    self.isAddCampaignValid=self.validateCampaignName();

    return self.isAddCampaignValid;
  }

  validateCampaignName(){
    let isValid = !!self.campaignNameToAdd && self.campaignNameToAdd.length > 0;
    self.campaignNameValidationClass = isValid ? 'has-success' : self.showAddCampaignValidationErrors ? 'has-error' : '';
    return isValid;
  }

  fetchImportTypeList() {
    let importType = new ImportType();

    importType.list(importTypeListSucceeded, importTypeListFailed);

    function importTypeListSucceeded(response) {
      console.log(response);
      bomGlobal.handlePlatinumResponse(response, importTypeListReallySucceeded, importTypeListFailed);
    }

    function importTypeListReallySucceeded(response) {
      //self.importTypes = response.Values;
      self.importTypes = _.filter(response.Values,function(importType){return importType.Name.indexOf("OPM") == -1;});
    }

    function importTypeListFailed(err) {
      self.handleError(`Error loading import types: ${err}`);
    }
  }

  fetchCampaignList(campaignNameToSelect) {
    let campaign = new Campaign();

    campaign.list(campaignListSucceeded, campaignListFailed);

    function campaignListSucceeded(response) {
      console.log(response);
      bomGlobal.handlePlatinumResponse(response, campaignListReallySucceeded, campaignListFailed);
    }

    function campaignListReallySucceeded(response){
      self.campaigns = response.Values;
      if(campaignNameToSelect){
        var campaignToSelect= _.find(self.campaigns,
          function(campaign){return campaign.Name === campaignNameToSelect;});
        if(campaignToSelect){
          self.campaignId = campaignToSelect.Id;
          self.validate();
        }
        self.campaignNameToAdd=null;
      }
    }

    function campaignListFailed(err) {
      self.handleError(`Error loading campaigns: ${err}`);
    }
  }

  handleError(err){
    self.errorMessage = err;
  }

  fileSelected() {
    self.filePath=null;
    self.file=null;

    if(self.$event.target.files && self.$event.target.files.length > 0) {
      self.file = self.$event.target.files[0];
      self.filePath = self.file.name;
      self.validate();
    }
  }

  createCampaign(){
    if(!self.validateAddCampaign(true)){
      return;
    }

    let campaign = new Campaign();
    campaign.Id = 0;
    campaign.Name = self.campaignNameToAdd;
    campaign.Description = self.campaignNameToAdd;

    campaign.create(campaign, createCampaignSucceeded, createCampaignFailed);

    function createCampaignSucceeded(response) {
      console.log(response);
      bomGlobal.handlePlatinumResponse(response, createCampaignReallySucceeded, createCampaignFailed);
    }

    function createCampaignReallySucceeded(response) {
      self.fetchCampaignList(self.campaignNameToAdd);
      $('#create-campaign-modal').modal('hide');
    }

    function createCampaignFailed(err) {
      self.handleError(`Error creating campaign: ${err}`);
    }
  }

  submit() {
    if (!self.validate(true)) {
      return;
    }

    self.campaignName = _.find(self.campaigns,function(campaign){return campaign.Id == self.campaignId;}).Name;
    self.importTypeName = _.find(self.importTypes,function(importType){return importType.Id == self.importTypeId;}).Name;

    $('#are-you-sure-modal').modal('show');
  }

  uploadSldFile() {
    var form = $('#sld-upload-form')[0];
    var formData = new FormData(form);

    var imp = new Import();
    imp.upload(formData,submitFileSucceeded,submitFileFailed);

    function submitFileSucceeded(response) {
      console.log(response);
      bomGlobal.handlePlatinumResponse(response, submitFileReallySucceeded, submitFileFailed);
    }

    function submitFileReallySucceeded(response) {
      $('#file-upload-succeeded-modal').modal('show');
      self.resetSelections();
    }

    function submitFileFailed(err) {
      self.handleError(`Error uploading file: ${err}`);
    }
  }
}


text:
<?php
declare(strict_types = 1);

namespace Domain\Specification\ResourceAuthor;

use Domain\Entity\ResourceAuthor as Entity;
use Innmind\Specification\Specification as ParentSpec;

interface Specification extends ParentSpec
{
    public function isSatisfiedBy(Entity $relation): bool;
}


text:
SEQAN_BEGIN_TESTSUITE(test_Search)
{
	// Call tests.
	SEQAN_CALL_TEST(test_GPostProcessMatches_dummy1);
	SEQAN_CALL_TEST(test_GPostProcessMatches_dummy2);
	SEQAN_CALL_TEST(test_GPostProcessMatches_short1);
	SEQAN_CALL_TEST(test_GPostProcessMatches_short2);
	SEQAN_CALL_TEST(test_GPostProcessMatches_alreadySorted);
	SEQAN_CALL_TEST(test_GPostProcessMatches_empty);
	SEQAN_CALL_TEST(test_GComputeMatch_dummy);
	SEQAN_CALL_TEST(test_GCheckClusterMaster_dummy);
	SEQAN_CALL_TEST(test_GCheckClusterMaster_halfMaster);
	SEQAN_CALL_TEST(test_GCheckClusterMaster_withoutMaster);
	SEQAN_CALL_TEST(test_GCheckClusterMaster_empty);
	SEQAN_CALL_TEST(test_GSearch_systemTest_emptyFiles_LAMode);
	SEQAN_CALL_TEST(test_GSearch_systemTest_emptyFiles_CQMode);
	SEQAN_CALL_TEST(test_GSearch_systemTest_emptyFiles_CQMode_unclustered);
	SEQAN_CALL_TEST(test_GSearch_systemTest_toyFiles_LAMode);
	SEQAN_CALL_TEST(test_GSearch_systemTest_toyFiles_CQMode);
	SEQAN_CALL_TEST(test_GSearch_systemTest_toyFiles_CQMode_unclustered);
	SEQAN_CALL_TEST(test_GSearch_systemTest_rfamFiles_LAMode);
	SEQAN_CALL_TEST(test_GSearch_systemTest_rfamFiles_LAMode_unclustered);
	SEQAN_CALL_TEST(test_GSearch_systemTest_rfamFiles_CQMode);
	SEQAN_CALL_TEST(test_GParseMasterID_dummy);
	SEQAN_CALL_TEST(test_GParseMasterID_noMaster);
	SEQAN_CALL_TEST(test_GSearch_systemTest_speicherzugriffsfehler_0517);

}
SEQAN_END_TESTSUITE


text:
using System;
using System.Collections.Generic;
using System.Drawing;
using System.Text;

namespace DevToolsX.Documents.Utils
{
    public static class ColorTranslator
    {
        public static string ToHtml(Color color)
        {
            return string.Format("#{0:X2}{1:X2}{2:X2}", color.R, color.G, color.B);
        }

        public static string ToLaTeX(Color color)
        {
            return string.Format("{0:F3},{1:F3},{2:F3}", color.R/255.0, color.G/255.0, color.B/255.0);
        }

        public static Color FromHtml(string color)
        {
            if (string.IsNullOrEmpty(color) || color.Length != 7) return Color.Empty;
            try
            {
                string rs = color.Substring(1, 2);
                string gs = color.Substring(3, 2);
                string bs = color.Substring(5, 2);
                int r = Convert.ToInt32(rs, 16);
                int g = Convert.ToInt32(gs, 16);
                int b = Convert.ToInt32(bs, 16);
                return Color.FromArgb(r, g, b);
            }
            catch
            {
                return Color.Empty;
            }
        }

    }
}


text:
#import <DevToolsCParsing/Transform.h>

@class MoveInstanceVarUpTransform;

@interface MoveCompoundTransform : Transform
{
    MoveInstanceVarUpTransform *_moveInstanceVarUpTransform;
}

- (BOOL)performFinal;
- (BOOL)performPerFile;
- (BOOL)performFirstFile;
- (BOOL)checkFinal;
- (void)cleanupTransformSpecificPerFile;
- (BOOL)checkPerFile;
- (BOOL)checkFirstFile;
- (BOOL)checkValidateInputs;
- (id)transformRelatedNames;
- (void)dealloc;

@end


text:
%{

 % Demo to try a second layer on an already trained model
 demoType = 'trainedX';
 dataOptions.prevModel = 'mats/demDecomposeSkel2.mat';
 latentDim = 8;
 initVardistIters = 500;
 itNo = [1000 2000];

 %%
 ca;clear;dataOptions={120,3,[]};indPoints=40;experimentNo=20;enableParallelism=1; demSkelMultvargplvm1
 % .mat save on folder demonstr
% TO load:
 ca;clear;dataOptions={120,3,[]};indPoints=40;experimentNo=20;trainModel=0; demSkelMultvargplvm1

%}

if ~exist('trainModel', 'var'), trainModel = true; end
if ~exist('demoType', 'var'), demoType = 'skelDecomposeAnkur'; end
if ~exist('dataOptions','var'), dataOptions = {}; end
if exist('diaryFile','var'),  diary(diaryFile);  end
if ~exist('saveModel','var'), saveModel = false; end
%if ~exist('experimentNo'), experimentNo = 404; end

% Fix seeds
randn('seed', 1e5);
rand('seed', 1e5);

%multvargplvm_init;
hsvargplvm_init;
globalOpt.dataSetName = 'skelDecompose';
globalOpt.demoType = demoType;
globalOpt.dataOptions = dataOptions;

%---- LOAD DATA
if ~exist('Y')
    [Y,lbls,padding,Z] = multvargplvmPrepareData(globalOpt.demoType, globalOpt.dataOptions);
end

for i=1:size(Y,2)
    Yall{i} = Y(:,i);
end

%-- Set up model
numberOfDatasets = length(Yall);
globalOpt.indPoints = min(globalOpt.indPoints, size(Yall{1},1));

%-- Load datasets
for i=1:numberOfDatasets
    Y = Yall{i};
    N{i} = size(Y,1);
    indTr = globalOpt.indTr;
    if indTr == -1
        indTr = 1:N{i};
    end
    if ~exist('Yts')
        indTs = setdiff(1:size(Y,1), indTr);
        Yts{i} = Y(indTs,:);
    end
    Ytr{i} = Y(indTr,:);

    t{i} = linspace(0, 2*pi, size(Y, 1)+1)'; t{i} = t{i}(1:end-1, 1);
    timeStampsTraining{i} = t{i}(indTr,1); %timeStampsTest = t(indTs,1);
end

for i=2:numberOfDatasets
    if N{i} ~= N{i-1}
        error('The number of observations in each dataset must be the same!');
    end
end

clear('Y','N')

%%

if trainModel
    options = svargplvmOptions(Ytr, globalOpt);

    if ~isempty(globalOpt.dynamicsConstrainType)
        for i=1:numberOfDatasets
            % Set up dynamcis (i.e. back-constraints) model
            optionsDyn{i}.type = 'vargpTime';
            optionsDyn{i}.inverseWidth=30;
            %   optionsDyn.vardistCovars = vardistCovarsMult;
            optionsDyn{i}.initX = globalOpt.initX;
            optionsDyn{i}.constrainType = globalOpt.dynamicsConstrainType;

            if exist('timeStampsTraining')
                optionsDyn{i}.t = timeStampsTraining;
            end
            if exist('labelsTrain') && ~isempty(labelsTrain)
                optionsDyn{i}.labels = labelsTrain;
            end
        end
    else
        optionsDyn= [];
    end

    model = multvargplvmCreate(Ytr, globalOpt, options, optionsDyn);
    if exist('diaryFile')
        model.diaryFile = diaryFile;
    end

    if globalOpt.enableParallelism % around 3x faster
        fprintf('# Parallel computations w.r.t the submodels!\n');
        model.parallel = 1;
        model = svargplvmPropagateField(model,'parallel', 1);
    end

    model.globalOpt = globalOpt;
    model.options = options;

    %%%% TEMP
    if exist('whiteVar')
        model.dynamics.kern.comp{2}.variance = whiteVar;
    end
    %%%%

    %model = svargplvmPropagateField(model, 'learnSigmaf',1);%%%%%
    % Force kernel computations
    params = svargplvmExtractParam(model);
    model = svargplvmExpandParam(model, params);

    if ~isfield(globalOpt, 'saveName') || isempty(globalOpt.saveName)
        globalOpt.saveName = vargplvmWriteResult([], 'multVargplvm', '', globalOpt.experimentNo);
    end
    model.saveName = globalOpt.saveName;

    %%
    %fprintf('# Median of vardist. covars: %d \n',median(median(model.vardist.covars)));
    %fprintf('# Min of vardist. covars: %d \n',min(min(model.vardist.covars)));
    %fprintf('# Max of vardist. covars: %d \n',max(max(model.vardist.covars)));
    tic
    if globalOpt.displayIters
        if strcmp(globalOpt.saveName, 'noSave')
            model = svargplvmOptimiseModel(model, true, false); % don't save the model
        else
            model = svargplvmOptimiseModel(model);
        end
    else
        if strcmp(globalOpt.saveName, 'noSave')
            model = svargplvmOptimiseModelNoDisplay(model,true,false); % don't save the model
        else
            model = svargplvmOptimiseModelNoDisplay(model);
        end
    end
    toc
    if saveModel
        prunedModel = svargplvmPruneModel(model);
        vargplvmWriteResult(prunedModel);
    end
else
    load(vargplvmWriteResult([], 'multVargplvm', '', globalOpt.experimentNo));
    model = svargplvmRestorePrunedModel(model, Ytr);
end

%%
allScales = svargplvmScales('get',model);
%  thresh = max(model.comp{obsMod}.kern.comp{1}.inputScales) * 0.001;
thresh = 0.005;
binaryScales = zeros(model.numModels, model.q);
allScalesMat = zeros(model.numModels, model.q);
for i=1:model.numModels
    % Normalise values between 0 and 1
    allScales{i} = allScales{i} / max(allScales{i});
    retainedScales{i} = find(allScales{i} > thresh);
    allScalesMat(i,:) = allScales{i};
    binaryScales(i,retainedScales{i}) = 1;
end
% sharedDims = intersect(retainedScales{obsMod}, retainedScales{infMod});
%imagesc(binaryScales')
%htree = linkage(pdist(allScalesMat),'single');
%clu = cluster(htree, 12);

if ~exist('showResults','var'), showResults = 0; end

if ~showResults
    return
end

%%
if strcmp(globalOpt.demoType, 'skelDecomposeAnkur')
    visPoint = Z(1,:);
    % Move some joints a bit further apart for clearer plots
    visPoint([16 19])=visPoint([16 19])-2.5; % Right Shoulders and arms (further from center)
    visPoint([25])=visPoint([25])+2; % right hand (closer to center)
    visPoint([28 31 34 37])=visPoint([28 31 34 37])+3; % Left shoulders and arms (further from center)
    visPoint([61])=visPoint([61])+7; % Left toe away from center
    visPoint([52])=visPoint([52])+2; % Left knee away from center
    visPoint([43])=visPoint([43])-2; % Right ankle away from center
    visPoint([55])=visPoint([55])+4; % Left ankle away from center
    visPoint([46])=visPoint([46])-1.5; % Right ankle away from center
    visPoint([58])=visPoint([58])-8; % Right toe away from center
    visPoint([59])=visPoint([59])-1.5; % Right toe a bit up
    visPoint([56 62])=visPoint([56 62])-1.5; % Left ankle toe a bit up
    visPoint([11 14])=visPoint([11 14])-[1 2.5]; % Neck/Head a bit up

    %%
    fprintf(1',['\n\n',...
        '#  Clustering each of the 57 dimensions separately. \n',...
        '   Each color represents if the dimension corresponds to moving along the (x,y,z) axis\n',...
        '   and each symbol corresponds to a cluster id\']);
    ca
    K = 5;
    randn('seed', 10); rand('seed', 10);

    distMeasure = 'cityblock'; % sqEuclidean, cityblock, cosine, correlation
    [clu,centroids] = kmeans_matlab(allScalesMat,K, 'EmptyAction', 'singleton','Start','sample','MaxIter',500,'Distance',distMeasure);

    %htree = linkage(pdist(allScalesMat),'single');
    %clu = cluster(htree, K);

    imagesc(clu')

    for cc = 1:length(unique(clu))
        fprintf('Cluster %d: ',cc);
        % Add + 6, because the first 6 points are all not included in tr.
        % set (since they have variance 0, and also this means they get
        % allocated to their own cluster)
        fprintf('%d ',find(clu==cc)+6)
        fprintf('\n');
    end
    fprintf('\n');
    allSymb = getSymbols(K+1);
    % Create the set of symbols to be for a "Default" cluster, that has the
    % lower spine points that in the dataset are centerd and therefore have
    % variance 0 (ie they 're all the same)
    symb = {allSymb{end},allSymb{end},allSymb{end},allSymb{end},allSymb{end},allSymb{end}};
    for i=1:57
        symb{end+1} = allSymb{clu(i)};
    end
    handle = xyzankurVisualise(visPoint,1);view([90,0])
    xyzankurDrawColor(xyzankur2joint(visPoint), handle,symb,visPoint);
    fprintf('# Press any key to continue');    pause
    %%
    fprintf(1','\n\n# As above but scales are binarized first (ie to 0-1)');
    K=5;
    randn('seed', 10); rand('seed', 10);
    clu = kmeans_matlab(binaryScales,K, 'EmptyAction', 'singleton','Start','sample','MaxIter',500, 'Distance', 'Hamming');
    imagesc(clu')

    for cc = 1:length(unique(clu))
        fprintf('Cluster %d: ',cc);
        fprintf('%d ',find(clu==cc)+6)
        fprintf('\n');
    end
    fprintf('\n');

    allSymb = getSymbols(K+1);
    symb = {allSymb{end},allSymb{end},allSymb{end},allSymb{end},allSymb{end},allSymb{end}};
    for i=1:57
        symb{end+1} = allSymb{clu(i)};
    end

    handle = xyzankurVisualise(visPoint,1);view([90,0])
    xyzankurDrawColor(xyzankur2joint(visPoint), handle,symb,visPoint);
    fprintf('# Press any key to continue');    pause

    %% Do the same, but "merge" scales for x-y-z locations, ie dimension
    %% k,k+1 and k+2 correspond to the xyz loc. of joing k
    fprintf(1',['\n\n',...
        '#  Clustering each SET of dimensions, 1:3, 4:6, etc, \n',...
        '   ie grouping them by joint for all degrees of freedom (x,y,z). \n',...
        '   Each cluster id is represented with a separate combination of color/symbol\n']);
    allScalesMat_xyz=[];
    for i=1:3:length(allScales)
        allScalesMat_xyz = [allScalesMat_xyz; [allScales{i} allScales{i+1} allScales{i+2}]];
    end
    %%
    for kk=2:9
        K = kk; % Check K=5, randSeed=10,distMeasure='correlation', start='sample'
        ca
        randn('seed', 10); rand('seed', 10);

        distMeasure = 'sqEuclidean'; % sqEuclidean, cityblock, cosine, correlation
        [clu,centroids] = kmeans_matlab(allScalesMat_xyz,K, 'EmptyAction', 'singleton','Start','sample','MaxIter',500,'Distance',distMeasure);
        %imagesc(clu')
        for cc = 1:length(unique(clu))
            fprintf('Cluster %d: ',cc);
            fprintf('%d ',find(clu==cc)+6)
            fprintf('\n');
        end
        fprintf('\n');
        allSymb = getSymbols(K+1);
        if length(allSymb) > 2, allSymb{3}(1)='k'; end
        if length(allSymb) > 5, allSymb{6}(1)='b'; end
        % Create the set of symbols to be for a "Default" cluster, that has the
        % lower spine points that in the dataset are centerd and therefore have
        % variance 0 (ie they 're all the same)
        symb = {allSymb{end},allSymb{end}};
        for i=1:size(clu,1)
            symb{end+1} = allSymb{clu(i)};
        end
        handle = xyzankurVisualise(visPoint,1);view([90,0]); axis off;
        xyzankurDrawColor(xyzankur2joint(visPoint), handle,symb,visPoint,true);
        pause
    end
    fprintf('# Press any key to continue');    pause
%%  In the outputs directly
    fprintf(1, ['\n\n# As above but cluster directly the outputs (after grouping by 3\n',...
                    '  i.e. [Y(:, 1:3), Y(:,4:6) ] etc.\n']);
    zz=[];
    for i=1:3:length(allScales)
        zz = [zz; [Z(:,i) Z(:,i+1) Z(:,i+2)]];
    end
    for kk=2:9
        K = kk; % Check K=5, randSeed=10,distMeasure='correlation', start='sample'
        ca
        randn('seed', 10); rand('seed', 10);

        distMeasure = 'correlation'; % sqEuclidean, cityblock, cosine, correlation
        [clu,centroids] = kmeans_matlab(allScalesMat_xyz,K, 'EmptyAction', 'singleton','Start','sample','MaxIter',500,'Distance',distMeasure);
        %imagesc(clu')
        for cc = 1:length(unique(clu))
            fprintf('Cluster %d: ',cc);
            fprintf('%d ',find(clu==cc)+6)
            fprintf('\n');
        end
        fprintf('\n');
        allSymb = getSymbols(K+1);
        if length(allSymb) > 2, allSymb{3}(1)='k'; end
        if length(allSymb) > 5, allSymb{6}(1)='b'; end
        % Create the set of symbols to be for a "Default" cluster, that has the
        % lower spine points that in the dataset are centerd and therefore have
        % variance 0 (ie they 're all the same)
        symb = {allSymb{end},allSymb{end}};
        for i=1:size(clu,1)
            symb{end+1} = allSymb{clu(i)};
        end
        handle = xyzankurVisualise(visPoint,1);view([90,0]); axis off;
        xyzankurDrawColor(xyzankur2joint(visPoint), handle,symb,visPoint,true);
        pause
    end
    %% What is each dim. doing? 1-6 are fixed (padding) - Only for globalOpt.demoType = skelDecomposeAnkur
    %{
mlt = ones(1,size(Z,2)).*1.4;
mlt(8)=8;
for dd=8:size(Z,2)
    pause
    dmin = min(Z(:,dd));
    dmax = max(Z(:,dd));
    r = abs(dmax-dmin);
    Ytmp = repmat(Z(102,:), 40,1);
    Ytmp(:,dd) = linspace(dmin-mlt(dd)*abs(r), dmax+mlt(dd)*abs(r), size(Ytmp,1))';
    clf
    grid on
    xyzankurAnim(Ytmp, 4,[' Dim: ' num2str(dd)]);
end
    %}
    %%
else
    hsvargplvmAnalyseResults;
end


text:
package jp.gr.java_conf.uzresk.aws.ope.runcommand;

import java.util.List;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;

import com.amazonaws.ClientConfiguration;
import com.amazonaws.auth.DefaultAWSCredentialsProviderChain;
import com.amazonaws.regions.RegionUtils;
import com.amazonaws.services.lambda.runtime.Context;
import com.amazonaws.services.lambda.runtime.LambdaLogger;
import com.amazonaws.services.simplesystemsmanagement.AWSSimpleSystemsManagementAsync;
import com.amazonaws.services.simplesystemsmanagement.AWSSimpleSystemsManagementAsyncClient;
import com.amazonaws.services.simplesystemsmanagement.model.CommandStatus;
import com.amazonaws.services.simplesystemsmanagement.model.NotificationConfig;
import com.amazonaws.services.simplesystemsmanagement.model.SendCommandRequest;
import com.amazonaws.services.simplesystemsmanagement.model.SendCommandResult;

import jp.gr.java_conf.uzresk.aws.lambda.LambdaLock;
import jp.gr.java_conf.uzresk.aws.ope.runcommand.model.RunScriptRequest;

public class RunScriptFunction {

	private ClientConfiguration cc;

	public void execute(RunScriptRequest rc, Context context) {

		LambdaLogger logger = context.getLogger();
		logger.log("Run Command Start. Run Configuration:[" + rc + "]");

		List<String> instanceIds = rc.getInstanceIds();
		boolean isLockAcquisition = new LambdaLock().lock(instanceIds.toString(), context);
		if (!isLockAcquisition) {
			logger.log("[ERROR][RunScript][" + instanceIds + "]You can not acquire a lock.");
			return;
		}

		String regionName = System.getenv("AWS_DEFAULT_REGION");

		AWSSimpleSystemsManagementAsync client = RegionUtils.getRegion(regionName).createClient(
				AWSSimpleSystemsManagementAsyncClient.class, new DefaultAWSCredentialsProviderChain(),
				getClientConfiguration());

		try {

			SendCommandRequest req = new SendCommandRequest();
			req.setInstanceIds(rc.getInstanceIds());
			req.setDocumentName(rc.getDocumentName());
			req.setParameters(rc.getParameters());

			req.setOutputS3BucketName(rc.getOutputS3BucketName());
			req.setOutputS3KeyPrefix(rc.getOutputS3KeyPrefix());

			// SNS settings
			if (isValidSNSSettings(rc, context)) {
				req.setServiceRoleArn(rc.getServiceRoleArn());
				NotificationConfig nc = new NotificationConfig();
				nc.setNotificationArn(rc.getNotificationArn());
				nc.setNotificationEvents(rc.getNotificationEvents());
				req.setNotificationConfig(nc);
			}

			Future<SendCommandResult> result = client.sendCommandAsync(req);

			SendCommandResult r;
			while (!result.isDone()) {
				Thread.sleep(100);
			}
			r = result.get();
			if (CommandStatus.Failed.name().equals(r.getCommand().getStatus())) {
				logger.log("[ERROR] execution failure. Commands[" + r.toString() + "]");
			} else {
				logger.log("[SUCCESS]Execution of RunCommand has completed successfully.[" + rc + "]");
			}
		} catch (InterruptedException | ExecutionException e) {
			logger.log("[ERROR] execution run commands." + e.getMessage());

		} finally {
			client.shutdown();
		}

	}

	void setClientConfiguration(ClientConfiguration cc) {
		this.cc = cc;
	}

	ClientConfiguration getClientConfiguration() {
		if (this.cc == null) {
			return new ClientConfiguration();
		}
		return this.cc;
	}

	private boolean isValidSNSSettings(RunScriptRequest rc, Context context) {

		LambdaLogger logger = context.getLogger();

		if (rc.getServiceRoleArn() != null && rc.getNotificationArn() != null && rc.getNotificationEvents() != null) {
			return true;
		} else {
			logger.log("Since the A setting of is missing, skip the SNS[" + rc + "]");
			return false;
		}
	}
}


text:
class LinkValidator < ActiveModel::Validator
  def validate(record)
    record.class::GOVSPEAK_FIELDS.each do |govspeak_field_name|
      govspeak_field_value = record.read_attribute(govspeak_field_name)
      next if govspeak_field_value.blank?

      messages = errors(govspeak_field_value)
      record.errors[govspeak_field_name] << messages unless messages.blank?
    end
  end

  def errors(string)
    link_regex = %r{
      \[.*?\]           # link text in literal square brackets
      \(                # literal opening parenthesis
         (\S*?)           # containing URL
         (\s+"[^"]+")?    # and optional space followed by title text in quotes
      \)                # literal close paren
      (\{:rel=["']external["']\})?  # optional :rel=external in literal curly brackets.
    }x

    errors = Set.new

    string.gsub(/("|")+/, '"').scan(link_regex) do |match|

      if match[0] !~ %r{^(?:https?://|mailto:|/)}
        errors << 'Internal links must start with a forward slash eg [link text](/link-destination). External links must start with http://, https://, or mailto: eg [external link text](https://www.google.co.uk).'
      end
      if match[1]
        errors << %q-Don't include hover text in links. Delete the text in quotation marks eg "This appears when you hover over the link."-
      end
      if match[2]
        errors << 'Delete {:rel="external"} in links.'
      end

    end
    errors.to_a
  end
end


text:
package com.dglogik.wear;

import android.app.ActivityManager;
import android.app.Service;
import android.content.Context;
import android.hardware.Sensor;
import android.hardware.SensorManager;
import android.support.annotation.NonNull;
import android.util.Log;

public class Utils {
    public static final String TAG = "DGMobile";

    public static void log(String message) {
        Log.i(TAG, message);
    }

    public static void printSensorList(SensorManager manager) {
        for (Sensor sensor : manager.getSensorList(Sensor.TYPE_ALL)) {
            log("Sensor: " + sensor.getName() + " by " + sensor.getVendor() + " (version: " + sensor.getVersion() + ", type: " + sensor.getStringType() + ")");
        }
    }
}


text:
if (!String.prototype.format) {
    String.prototype.format = function () {
        var args = arguments;
        return this.replace(/{(\d+)}/g, function (match, num) {
            if (typeof args[num] != 'undefined') {
                return args[num];
            }
            else {
                return match;
            }
        });
    };
}
var jThree;
(function (jThree) {
    var Base;
    (function (Base) {
        /**
         *
         */
        var JsHack = (function () {
            function JsHack() {
            }
            JsHack.getObjectName = function (obj) {
                var funcNameRegex = /function (.{1,})\(/;
                var result = (funcNameRegex).exec((obj).constructor.toString());
                return (result && result.length > 1) ? result[1] : "";
            };
            return JsHack;
        })();
        /**
         *This class indicate the class extends this class is added by jThree.
         */
        var jThreeObject = (function () {
            function jThreeObject() {
            }
            jThreeObject.prototype.toString = function () {
                return JsHack.getObjectName(this);
            };
            return jThreeObject;
        })();
        Base.jThreeObject = jThreeObject;
    })(Base = jThree.Base || (jThree.Base = {}));
})(jThree || (jThree = {}));
//# sourceMappingURL=Base.js.map


text:
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace FellSky.Game.Campaign.Commands
{
    class DockStrategicCommand
    {
    }
}


text:
package org.keycloak.protocol.oidc.mappers;

import org.keycloak.models.AuthenticatedClientSessionModel;
import org.keycloak.models.ClientSessionContext;
import org.keycloak.models.KeycloakSession;
import org.keycloak.models.ProtocolMapperModel;
import org.keycloak.models.UserSessionModel;
import org.keycloak.representations.IDToken;

/**
 * @author Bill Burke
 * @version $Revision: 1 $
 */
public interface OIDCIDTokenMapper {

    IDToken transformIDToken(IDToken token, ProtocolMapperModel mappingModel, KeycloakSession session,
                               UserSessionModel userSession, ClientSessionContext clientSession);
}


text:
package org.elasticsearch.client.watcher;

import org.elasticsearch.client.Validatable;

public class StartWatchServiceRequest implements Validatable {

}


text:
package org.wso2.maven.car.artifact;

import feign.Headers;
import feign.Param;
import feign.RequestLine;
import feign.Response;
import org.wso2.maven.car.artifact.exception.CAppMgtServiceStubException;

import java.io.File;

public interface CAppMgtServiceStub {

    @RequestLine("GET /management/login")
    @Headers("accept: application/json; charset=utf-8")
    Response doAuthenticate() throws CAppMgtServiceStubException;

    @RequestLine("POST /management/applications")
    @Headers("Content-Type: multipart/form-data; charset=utf-8")
    Response deployCApp(@Param("file") File capp) throws CAppMgtServiceStubException;

    @RequestLine("DELETE /management/applications/{name}")
    @Headers("Content-Type: application/json; charset=utf-8")
    Response unDeployCApp(@Param("name") String cAppName) throws CAppMgtServiceStubException;
}


text:
    <title></title>

Welcome to page1!

This page does not require login - anyone can see it


text:
<?php

use Illuminate\Support\Facades\Schema;
use Illuminate\Database\Schema\Blueprint;
use Illuminate\Database\Migrations\Migration;

class CreateUnitsTable extends Migration
{
    /**
     * Schema table name to migrate
     * @var string
     */
    public $set_schema_table = 'units';

    /**
     * Run the migrations.
     * @table units
     *
     * @return void
     */
    public function up()
    {
        if (Schema::hasTable($this->set_schema_table)) return;
        Schema::create($this->set_schema_table, function (Blueprint $table) {
            $table->engine = 'InnoDB';
            $table->increments('id');
            $table->string('title')->nullable();
            $table->string('description')->nullable();
            $table->integer('teachers_id')->unsigned();
            $table->integer('courses_id')->unsigned();

            $table->index(["teachers_id"], 'fk_units_teachers1_idx');
            $table->foreign('teachers_id', 'fk_units_teachers1_idx')
                ->references('id')
                ->on('teachers')
                ->onDelete('no action')
                ->onUpdate('no action');

            $table->index(["courses_id"], 'fk_units_courses1_idx');
            $table->foreign('courses_id', 'fk_units_courses1_idx')
                ->references('id')
                ->on('courses')
                ->onDelete('no action')
                ->onUpdate('no action');

            $table->nullableTimestamps();
        });
    }

    /**
     * Reverse the migrations.
     *
     * @return void
     */
     public function down()
     {
       Schema::dropIfExists($this->set_schema_table);
     }
}


text:
<?php
/**
 * @package Campsite
 */

/**
 * Includes
 */
require_once($GLOBALS['g_campsiteDir'].'/db_connect.php');
require_once($GLOBALS['g_campsiteDir'].'/classes/DatabaseObject.php');
require_once($GLOBALS['g_campsiteDir'].'/classes/DbObjectArray.php');

/**
 * @package Campsite
 */
class Alias extends DatabaseObject {
	var $m_dbTableName = 'Aliases';
	var $m_keyColumnNames = array('Id');
	var $m_keyIsAutoIncrement = true;
	var $m_columnNames = array('Id', 'Name', 'IdPublication');

	/**
	 * Constructor.
	 * @param int $p_id
	 */
	public function Alias($p_idOrName = null)
	{
		parent::DatabaseObject($this->m_columnNames);
		if (is_numeric($p_idOrName)) {
    		$this->m_data['Id'] = $p_idOrName;
			$this->fetch();
		} elseif (!empty($p_idOrName)) {
			$this->m_keyColumnNames = array('Name');
			$this->m_data['Name'] = $p_idOrName;
			$this->fetch();
			$this->m_keyColumnNames = array('Id');
		}
	} // constructor

	/**
	 * @return int
	 */
	public function getId()
	{
		return $this->m_data['Id'];
	} // fn getId

	/**
	 * @return string
	 */
	public function getName()
	{
		return $this->m_data['Name'];
	} // fn getName

	/**
	 * Wrapper around DatabaseObject::setProperty
	 *
	 * @see classes/DatabaseObject#setProperty($p_dbColumnName, $p_value, $p_commit, $p_isSql)
	 */
    public function setProperty($p_dbColumnName, $p_value, $p_commit = true, $p_isSql = false)
    {
        if ($p_dbColumnName == 'Name') {
            $this->m_keyColumnNames = array('Name');
            $this->resetCache();
            $this->m_keyColumnNames = array('Id');
        }
        return parent::setProperty($p_dbColumnName, $p_value);
    } // fn setProperty

	/**
	 *
	 */
	public function setName($p_name)
	{
	    return $this->setProperty('Name', $p_name);
	} // fn setName

	/**
	 * @return int
	 */
	public function getPublicationId()
	{
		return $this->m_data['IdPublication'];
	} // fn getPublicationId

	/**
	 * @param int $p_value
	 * @return boolean
	 */
	public function setPublicationId($p_value)
	{
		return $this->setProperty('IdPublication', $p_value);
	} // fn setPublicationId

	/**
	 * Get all the aliases that match the given criteria.
	 *
	 * @param int $p_id
	 * @param int $p_publicationId
	 * @param string $p_name
	 * @return array
	 */
	public static function GetAliases($p_id = null, $p_publicationId = null, $p_name = null)
	{
		$contraints = array();
		if (!is_null($p_publicationId)) {
			$contraints[] = array("IdPublication", $p_publicationId);
		}
		if (!is_null($p_name)) {
			$contraints[] = array("Name", $p_name);
		}
		if (!is_null($p_id)) {
			$contraints[] = array("Id", $p_id);
		}
		return DatabaseObject::Search('Alias', $contraints);
	} // fn GetAliases

} // class Alias

?>


text:
package formatter

import (
	"strconv"
	"strings"
	"time"

	"github.com/docker/docker/api/types/image"
	"github.com/docker/docker/pkg/stringid"
	units "github.com/docker/go-units"
)

const (
	defaultHistoryTableFormat  = "table {{.ID}}\t{{.CreatedSince}}\t{{.CreatedBy}}\t{{.Size}}\t{{.Comment}}"
	nonHumanHistoryTableFormat = "table {{.ID}}\t{{.CreatedAt}}\t{{.CreatedBy}}\t{{.Size}}\t{{.Comment}}"

	historyIDHeader = "IMAGE"
	createdByHeader = "CREATED BY"
	commentHeader   = "COMMENT"
)

// NewHistoryFormat returns a format for rendering an HistoryContext
func NewHistoryFormat(source string, quiet bool, human bool) Format {
	switch source {
	case TableFormatKey:
		switch {
		case quiet:
			return defaultQuietFormat
		case !human:
			return nonHumanHistoryTableFormat
		default:
			return defaultHistoryTableFormat
		}
	}

	return Format(source)
}

// HistoryWrite writes the context
func HistoryWrite(ctx Context, human bool, histories []image.HistoryResponseItem) error {
	render := func(format func(subContext subContext) error) error {
		for _, history := range histories {
			historyCtx := &historyContext{trunc: ctx.Trunc, h: history, human: human}
			if err := format(historyCtx); err != nil {
				return err
			}
		}
		return nil
	}
	historyCtx := &historyContext{}
	historyCtx.header = map[string]string{
		"ID":           historyIDHeader,
		"CreatedSince": createdSinceHeader,
		"CreatedAt":    createdAtHeader,
		"CreatedBy":    createdByHeader,
		"Size":         sizeHeader,
		"Comment":      commentHeader,
	}
	return ctx.Write(historyCtx, render)
}

type historyContext struct {
	HeaderContext
	trunc bool
	human bool
	h     image.HistoryResponseItem
}

func (c *historyContext) MarshalJSON() ([]byte, error) {
	return marshalJSON(c)
}

func (c *historyContext) ID() string {
	if c.trunc {
		return stringid.TruncateID(c.h.ID)
	}
	return c.h.ID
}

func (c *historyContext) CreatedAt() string {
	return time.Unix(c.h.Created, 0).Format(time.RFC3339)
}

func (c *historyContext) CreatedSince() string {
	if !c.human {
		return c.CreatedAt()
	}
	created := units.HumanDuration(time.Now().UTC().Sub(time.Unix(c.h.Created, 0)))
	return created + " ago"
}

func (c *historyContext) CreatedBy() string {
	createdBy := strings.Replace(c.h.CreatedBy, "\t", " ", -1)
	if c.trunc {
		return Ellipsis(createdBy, 45)
	}
	return createdBy
}

func (c *historyContext) Size() string {
	if c.human {
		return units.HumanSizeWithPrecision(float64(c.h.Size), 3)
	}
	return strconv.FormatInt(c.h.Size, 10)
}

func (c *historyContext) Comment() string {
	return c.h.Comment
}


text:
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Linq;
using System.Threading.Tasks;
using Windows.UI.Xaml.Navigation;
using Flashback.Model;
using FlashbackUwp.Services.FileServices;
using GalaSoft.MvvmLight.Messaging;

namespace FlashbackUwp.ViewModels
{
    public class ManageForumlistViewModel : FlashbackViewModelBase
    {
        private string _addPath = "";
        public string AddPath
        {
            get => _addPath;
            set => Set(ref _addPath, value);
        }

        private string _addName = "";
        public string AddName
        {
            get => _addName;
            set => Set(ref _addName, value);
        }

        private ObservableCollection<FbItem> _extraForums;
        public ObservableCollection<FbItem> ExtraForumList
        {
            get => _extraForums;
            set => Set(ref _extraForums, value);
        }

        private FileService _fileService;

        public ManageForumlistViewModel()
        {
            ExtraForumList = new ObservableCollection<FbItem>();

            if (Windows.ApplicationModel.DesignMode.DesignModeEnabled)
            {
                ExtraForumList = SampleData.SampleData.GetDefaultExtraForums();
            }
        }

        public async Task DeleteForum(FbItem item)
        {
            ExtraForumList.Remove(item);
            await _fileService.SaveExtraForums(ExtraForumList.ToList());
        }

        public async Task AddForum()
        {
            var forum = new FbItem
            {
                Id = AddPath,
                Name = AddName,
                Type = FbItemType.Forum,
                ShowForumColor = true
            };

            if (!ValidateAndFixPaths(forum))
            {
                Messenger.Default.Send("Ej kompletta uppgifter (fyll i namn, och sökvägen)", FlashbackConstants.MessengerShowWarning);
                return;
            }

            if (ExtraForumList.Any(x => x.Id == forum.Id))
            {
                AddName = "";
                AddPath = "";
                return;
            }

            ExtraForumList.Add(forum);
            AddName = "";
            AddPath = "";

            await _fileService.SaveExtraForums(ExtraForumList.ToList());
        }

        public async Task LoadViewModel()
        {
            _fileService = new FileService();
            var forums = await _fileService.GetExtraForums();

            ExtraForumList =  new ObservableCollection<FbItem>(forums);
        }

        private bool ValidateAndFixPaths(FbItem forum)
        {
            if (string.IsNullOrWhiteSpace(forum.Id) || string.IsNullOrWhiteSpace(forum.Name))
                return false;

            forum.Id = forum.Id.Replace("/", "");
            forum.Id = forum.Id.ToLower();

            return forum.Id.Contains("f");
        }

        public override async Task OnNavigatedToAsync(object parameter, NavigationMode mode, IDictionary<string, object> state)
        {
            await LoadViewModel();
        }
    }
}


text:
/**
 * Created by Eduardo on 24-Oct-14.
 */
(function () {
    angular.module('appControllers').controller('SaleFormController', ['SystemService', 'DataFactory', 'SaleFactory', 'toaster', 'UtilServices', function (SystemService, DataFactory, SaleFactory, toaster, UtilServices) {
        var that = this;
        this.init = function () {

            DataFactory.findAllSellers().success(function (data) {
                that.sellers = data;
                if (that.sale.seller) {
                    for (var i = 0; i < that.sellers.length; i++) {
                        if (that.sellers[i].name === that.sale.seller.name) {
                            that.sale.seller = that.sellers[i];
                        }
                    }
                }
            });

            DataFactory.findAllAdvertisers().success(function (data) {
                that.advertisers = data;
            });
            DataFactory.findAllFinancials().success(function (data) {
                that.financials = data;
            });

            that.editSale = false;
            that.showInputAdvertisement = false;
            that.shownInputAdvertisement = false;

            that.sale = {};
            that.sale.installmentsNumber = 1;
            that.sale.pendingIpvaNumber = 0;

            if (SystemService.sale) {
                that.convertDataToSale(SystemService.sale);
            }
        };

        this.convertSaleToData = function () {
            var data = angular.copy(that.sale);
            if (that.sale.deliveryDate && that.sale.deliveryTime) {
                var formattedDate = new Date();
                var partsOfDate = that.sale.deliveryDate.split('/');
                var partsOfTime = that.sale.deliveryTime.split(':');
                formattedDate.setDate(partsOfDate[0]);
                formattedDate.setMonth(partsOfDate[1] - 1);
                formattedDate.setYear(partsOfDate[2]);
                formattedDate.setHours(partsOfTime[0], partsOfTime[1]);
                data.deliveryDate = formattedDate.getTime();
            }
            data.price = UtilServices.formatNumber(that.sale.price);
            data.km = UtilServices.formatNumber(that.sale.km);
            data.deposit = UtilServices.formatCurrency(that.sale.deposit);
            data.transfer = UtilServices.formatCurrency(that.sale.transfer);
            data.downPayment = UtilServices.formatCurrency(that.sale.downPayment);
            data.installmentValue = UtilServices.formatCurrency(that.sale.installmentValue);
            data.pendingIpva = UtilServices.formatCurrency(that.sale.pendingIpva);
            if (SystemService.flow !== 'closeSale') {
                data.car = SystemService.car;
                data.customer = SystemService.customer;
            }
            return data;
        };

        this.convertDataToSale = function (data) {
            that.sale = data;
            that.sale.deposit = parseFloat(that.sale.deposit).toFixed(2);
            that.sale.transfer = parseFloat(that.sale.transfer).toFixed(2);
            if (that.sale.downPayment) {
                that.sale.downPayment = parseFloat(that.sale.downPayment).toFixed(2);
            }
            if (that.sale.installmentValue) {
                that.sale.installmentValue = parseFloat(that.sale.installmentValue).toFixed(2);
            }
            if (that.sale.pendingIpva) {
                that.sale.pendingIpva = parseFloat(that.sale.pendingIpva).toFixed(2);
            }
            if (data.deliveryDate) {
                var formattedDate = new Date(data.deliveryDate);
                that.sale.deliveryDate = ("0" + formattedDate.getDate()).slice(-2) + '/'
                    + ("0" + (formattedDate.getMonth() + 1)).slice(-2) + '/'
                    + formattedDate.getFullYear();
                that.sale.deliveryTime = formattedDate.toTimeString();
            }
        };

        this.submit = function () {
            var next = function () {
                SystemService.page = 10;
            };
            if(!SystemService.readOnly) {
                if (SystemService.flow === 'closeSale') {
                    SaleFactory.close(that.convertSaleToData()).success(function (data) {
                        SystemService.sale = data;
                        next();
                    });
                } else {
                    SaleFactory.sell(that.convertSaleToData()).success(function (data) {
                        SystemService.sale = data;
                        next();
                    });
                }
            } else {
                next();
            }
        };

    }]);
})();


text:
SYNONYM

#### According to
Index Fungorum

#### Published in
Mycologia 85(2): 277 (1993)

#### Original name
Cortinomyces Bougher & Castellano

### Remarks
null


text:
/* Test diagnostics for bad or doubtful casts.  Test with
   -pedantic-errors.  */
/* Origin: Joseph Myers <joseph@codesourcery.com> */
/* { dg-do compile } */
/* { dg-options "-std=gnu99 -pedantic-errors" } */

struct s { int a; } sv;
union u { int a; } uv;
int i;
long l;
char c;
void *p;
float fv;

void
f (void)
{
  (int []) p; /* { dg-error "error: cast specifies array type" } */
  (int ()) p; /* { dg-error "error: cast specifies function type" } */
  (struct s) sv; /* { dg-error "error: ISO C forbids casting nonscalar to the same type" } */
  (union u) uv; /* { dg-error "error: ISO C forbids casting nonscalar to the same type" } */
  (struct s) i; /* { dg-error "error: conversion to non-scalar type requested" } */
  (union u) i; /* { dg-error "error: ISO C forbids casts to union type" } */
  (union u) l; /* { dg-error "error: cast to union type from type not present in union" } */
  (int) sv; /* { dg-error "error: aggregate value used where an integer was expected" } */
  (int) uv; /* { dg-error "error: aggregate value used where an integer was expected" } */
  (float) sv; /* { dg-error "error: aggregate value used where a float was expected" } */
  (float) uv; /* { dg-error "error: aggregate value used where a float was expected" } */
  (_Complex double) sv; /* { dg-error "error: aggregate value used where a complex was expected" } */
  (_Complex double) uv; /* { dg-error "error: aggregate value used where a complex was expected" } */
  (void *) sv; /* { dg-error "error: cannot convert to a pointer type" } */
  (void *) uv; /* { dg-error "error: cannot convert to a pointer type" } */
  (_Bool) sv; /* { dg-error "error: used struct type value where scalar is required" } */
  (_Bool) uv; /* { dg-error "error: used union type value where scalar is required" } */
  (void) sv;
  (const void) uv;
  (void *) c; /* { dg-warning "warning: cast to pointer from integer of different size" } */
  (void *) (char) 1;
  (char) p; /* { dg-warning "warning: cast from pointer to integer of different size" } */
  (char) (void *) 1; /* { dg-warning "warning: cast from pointer to integer of different size" } */
}


text:
package org.apache.camel.component.xslt;

import javax.xml.transform.URIResolver;

import org.apache.camel.CamelContext;

/**
 * Can be used to create custom URI resolver for the XSLT endpoint. This
 * interface is useful, if the custom URI resolver depends on the resource URI
 * specified in the XSLT endpoint. The resource URI of the endpoint can be even
 * dynamic, like in the following example:
 *
 * <pre>
 * {@code <camel:recipientList>}
 * {@code      <camel:simple>xslt:${header.XSLT_FILE}?uriResolverFactory=#uriResolverFactory</camel:simple>}
 * {@code </camel:recipientList>}
 * </pre>
 *
 * The dynamic resource URI given in ${header.XSLT_FILE} will be past as
 * resourceUri parameter in the method
 * {@link #createUriResolver(CamelContext, String)}
 */
public interface XsltUriResolverFactory {

    /**
     * Method is called during the creation of a xslt endpoint.
     *
     * @param camelContext camel context
     * @param resourceUri resource URI specified in the endpoint URI
     * @return URI resolver
     */
    URIResolver createUriResolver(CamelContext camelContext, String resourceUri);

}


text:
[![Android Arsenal](https://img.shields.io/badge/Android%20Arsenal-DisqusSDK--Android-brightgreen.svg?style=flat)](http://android-arsenal.com/details/1/1855) [![Download](https://api.bintray.com/packages/jjhesk/maven/disqus/images/download.svg) ](https://bintray.com/jjhesk/maven/disqus/_latestVersion)

This is the simple library for https://disqus.com/ developed on Android.

## About
This library implements the Disqus API for use in Android applications. This librar is ongoing

### Gradle settings
```gradle
repositories {
   maven { url 'https://dl.bintray.com/jjhesk/maven' }
}
dependencies {
   compile 'DisqusSDK-Android:disqus:0.2.7'
}
```

## API RoadMap Support
- [x] Post comments
- [x] Post Comments more flexible
- [x] Updated authentication OAuth2.0 standard
- [x] Additional support for the CacheUrl mechanism
- [x] enable extending from fragment. PostCommentFragment
- [x] setup the activity for login
- [x] construct the configuration object

## Installation
 - [x] enable extending from fragment. PostCommentFragment
 - [x] setup the activity for login
 - [x] construct the configuration object

### Using AuthorizeActivity

1. Use `AuthorizeUtils.createIntent` to create a new `Intent` with your application settings.
2. Start the activity with `startActivityForResult`.
3. Implement 'onActivityResult' to get the access token object:
```java

    @Override
    protected void onActivityResult(int requestCode, int resultCode, Intent data) {
        // Check which request we're responding to
        if (requestCode == DisqusClient.authorization_intent_id) {
            // Make sure the request was successful
            if (resultCode == RESULT_CANCELED) {
                Toast.makeText(this, getResources().getString(com.hkm.disqus.R.string.failurelogin), Toast.LENGTH_LONG);
            }
            if (resultCode == RESULT_OK) {
                AccessToken token = (AccessToken) data.getExtras().getParcelable(AuthorizeActivity.EXTRA_ACCESS_TOKEN);
                addLine(token.accessToken);
                release_pending_content();
            }
        }
    }

    protect void release_pending_content(){
    if (appending_post_content != null) {
                        postPost(appending_post_content, post_post_id);
                        appending_post_content = null;
                    }
    }

```
4. ApiConfiguration Object Sample:
The ```forum name``` will be used as the following reference:

"https://disqus.com/api/3.0/threads/set.json?forum=\(forumShortName)&api_key=\(apiKey)&thread=ident:\(postID)%20\(domain)/?p=\(postID)"

```java
public class DqUtil {
    public static ApiConfig genConfig() {
        ApiConfig conf = new ApiConfig(
                BuildConfig.DISQUS_API_KEY,
                BuildConfig.DISQUS_DEFAULT_ACCESS,
                RestAdapter.LogLevel.BASIC);

        conf
         .setForumName("__forum_name__")
         .setApiSecret(BuildConfig.DISQUS_SECRET)
         .setRedirectUri(BuildConfig.DISQUS_REDIRECT_URI);

        return conf;
    }
}
```

#### Standard options
* API key - mandatory for all requests.
* Access token - required for requests that require authentication.
* Referrer - required for some requests that perform domain checks, should match a domain in your
Disqus app settings.
* Log level - set the Retrofit logging level, see [Square's docs](http://square.github.io/retrofit/javadoc/retrofit/RestAdapter.LogLevel.html) for details.

#### Other options

* API secret - intended for server to server requests as an alternative to the API key/access token
and provided for completeness. Can be used from a mobile app but this presents security risks and is
not recommended.

### Create client

As of version 0.9.0 the library is using [Retrofit](http://square.github.io/retrofit/) for requests.

The `ApiClient` can be used to create Disqus resource objects based on the Retrofit interfaces
defined in the `me.philio.disqus.api.resources` package. It works as a wrapper to the Retrofit
`RestAdapter` and configures the adapter and deserialisation options for Gson.
```java
    ApiClient apiClient = new ApiClient(apiConfig);
```
### Create resource and make requests
```java
    Applications applications = apiClient.createApplications();
    Response<Usage> usage = applications.listUsage("MyApp", 7);
```
All resources and requests match the naming conventions defined in the Disqus API documentation, but
often method signatures are kept as simple as possible.

### Advance Sample Code
```java
  setup.createThreads().listPostByIDAsync(comment_id, "hypebeast", cb);

    private void getPost() {
        try {
            base.getComments("1008680 http://hypebeast.com/?p=1008680", new Callback<com.hkm.disqus.api.model.Response<List<Post>>>() {
                @Override
                public void success(com.hkm.disqus.api.model.Response<List<Post>> posts, Response response) {

                    com.hkm.disqus.api.model.Response<List<Post>> d = posts;

                    Log.d(TAG, "now its working now");
                }

                @Override
                public void failure(RetrofitError error) {
                    Log.d(TAG, error.getMessage());
                }
            });
        } catch (ApiException e) {

        }
    }

```
In general:

* Named parameters are required and should not be null.

* Optional parameters can be provided as a `Map` where applicable, refer to the Disqus documentation
for details of optional parameters.

### Response format

All requests will return a `Response` object. Typical responses contain an error code (which will
always be 0 as errors throw exceptions), an optional cursor (which can be used for pagination) and
some data which is a generic type.

The data is usually an object or list of objects and for the majority of requests will be one of the
models defined in the API package. Some requests return empty structures so to avoid parsing issues
the data type is either `Object` or `List<Object>`, the response data for these requests can be
disregarded.

## Known issues

### Disqus issues

1. The cancel button for the authorisation page doesn't work.
2. Related param has no effect when used with `Blacklists.list()` method.
3. update after post thread doesnt work.


text:
package com.opengamma.integration.tool.portfolio;

import java.util.ArrayList;
import java.util.List;

import org.apache.commons.cli.Option;
import org.apache.commons.cli.Options;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.opengamma.component.tool.AbstractTool;
import com.opengamma.financial.tool.ToolContext;
import com.opengamma.id.ObjectId;
import com.opengamma.master.security.SecurityDocument;
import com.opengamma.master.security.SecurityMaster;
import com.opengamma.master.security.SecuritySearchRequest;
import com.opengamma.master.security.impl.SecuritySearchIterator;
import com.opengamma.scripts.Scriptable;

/**
 * The portfolio loader tool
 */
@Scriptable
public class SecurityDeleteTool extends AbstractTool<ToolContext> {

  /** Logger. */
  private static final Logger s_logger = LoggerFactory.getLogger(SecurityDeleteTool.class);

  /** Delete securities option flag */
  private static final String SECURITY_NAMES_OPT = "n";
  /** Delete security ids option flag */
  private static final String SECURITY_IDS_OPT = "i";
  /** External Id scheme wildcard search flag */
  private static final String EXTERNAL_ID_SCHEMES_OPT = "es";
  /** External Id value wildcard search flag */
  private static final String EXTERNAL_ID_VALUES_OPT = "ev";
  /** Write option flag */
  private static final String WRITE_OPT = "w";
  /** Verbose option flag */
  private static final String VERBOSE_OPT = "v";

  //-------------------------------------------------------------------------
  /**
   * Main method to run the tool.
   *
   * @param args  the standard tool arguments, not null
   */
  public static void main(String[] args) { //CSIGNORE
    new SecurityDeleteTool().invokeAndTerminate(args);
  }

  //-------------------------------------------------------------------------
  /**
   * Deletes securities from the specified sec master.
   */
  @Override
  protected void doRun() {
    SecuritySearchRequest securitySearchRequest = new SecuritySearchRequest();

    if (getCommandLine().hasOption(SECURITY_NAMES_OPT)) {
      securitySearchRequest.setName(
          getCommandLine().getOptionValue(SECURITY_NAMES_OPT));
    }
    if (getCommandLine().hasOption(SECURITY_IDS_OPT)) {
      List<ObjectId> ids = new ArrayList<ObjectId>();
      for (String s : getCommandLine().getOptionValues(SECURITY_IDS_OPT)) {
        ids.add(ObjectId.parse(s));
      }
      securitySearchRequest.setObjectIds(ids);
    }
    if (getCommandLine().hasOption(EXTERNAL_ID_SCHEMES_OPT)) {
      securitySearchRequest.setExternalIdScheme(
          getCommandLine().getOptionValue(EXTERNAL_ID_SCHEMES_OPT));
    }
    if (getCommandLine().hasOption(EXTERNAL_ID_VALUES_OPT)) {
      securitySearchRequest.setExternalIdValue(
          getCommandLine().getOptionValue(EXTERNAL_ID_VALUES_OPT));
    }

    SecurityMaster securityMaster = getToolContext().getSecurityMaster();
    for (SecurityDocument securityDocument : SecuritySearchIterator.iterable(securityMaster, securitySearchRequest)) {
      if (getCommandLine().hasOption(WRITE_OPT)) {
        securityMaster.remove(securityDocument.getUniqueId());
        s_logger.warn("Deleted " + securityDocument.getSecurity().getUniqueId() +
            " (" + securityDocument.getSecurity().getName() + ")");
      } else {
        s_logger.warn("Matched " + securityDocument.getSecurity().getUniqueId() +
            " (" + securityDocument.getSecurity().getName() + ")");
      }

    }
  }

  @Override
  protected Options createOptions(boolean contextProvided) {

    Options options = super.createOptions(contextProvided);

    Option securityNamesOption = new Option(
        SECURITY_NAMES_OPT, "name", true, "Regular expression to match security names");
    options.addOption(securityNamesOption);

    Option securityIdsOption = new Option(
        SECURITY_IDS_OPT, "securityid", true, "Security IDs to match");
    options.addOption(securityIdsOption);

//    OptionGroup group = new OptionGroup();
//    group.addOption(securityIdsOption);
//    group.addOption(securityNamesOption);
//    group.setRequired(true);
//    options.addOptionGroup(group);

    Option externalIdSchemesOption = new Option(
        EXTERNAL_ID_SCHEMES_OPT, "extscheme", true,
        "Regular expression to match external ID schemes");
    options.addOption(externalIdSchemesOption);

    Option externalIdValuesOption = new Option(
        EXTERNAL_ID_VALUES_OPT, "extvalue", true,
        "Regular expression to match external ID values");
    options.addOption(externalIdValuesOption);

    Option writeOption = new Option(
        WRITE_OPT, "write", false,
        "Actually persist the deletions");
    options.addOption(writeOption);

    Option verboseOption = new Option(
        VERBOSE_OPT, "verbose", false,
        "Displays progress messages on the terminal");
    options.addOption(verboseOption);

    return options;
  }

}


text:
* Fix the main client gem name listed in the readme and description ([#19118](https://github.com/googleapis/google-cloud-ruby/issues/19118))

### 0.1.0 (2022-07-29)

#### Features

* Initial generation of google-cloud-beyond_corp-app_gateways-v1 ([#18925](https://github.com/googleapis/google-cloud-ruby/issues/18925))


text:
<?xml version="1.0" encoding="iso-8859-1"?>
<!DOCTYPE html
     PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN"
     "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">

  <title>Module: Erubis::PrintEnabledEnhancer</title>
  <meta http-equiv="Content-Type" content="text/html; charset=iso-8859-1" />
  <meta http-equiv="Content-Script-Type" content="text/javascript" />
  <link rel="stylesheet" href="../.././rdoc-style.css" type="text/css" media="screen" />

          Module
          Erubis::PrintEnabledEnhancer

            In:

                erubis/enhancer.rb

enable print function

Notice: use Eruby#evaluate() and don‘t use Eruby#result() to be
enable print function.

this is only for Eruby.

Methods

      add_preamble
      evaluate
      print

Public Instance methods

          add_preamble(src)

[Source]

# File erubis/enhancer.rb, line 128
    def add_preamble(src)
      src << "@_buf = "
      super
    end

          evaluate(context=nil)

[Source]

# File erubis/enhancer.rb, line 139
    def evaluate(context=nil)
      _src = @src
      if context.is_a?(Hash)
        context.each do |key, val| instance_variable_set("@#{key}", val) end
      elsif context
        context.instance_variables.each do |name|
          instance_variable_set(name, context.instance_variable_get(name))
        end
      end
      return instance_eval(_src, (@filename || '(erubis)'))
    end

          print(*args)

[Source]

# File erubis/enhancer.rb, line 133
    def print(*args)
      args.each do |arg|
        @_buf << arg.to_s
      end
    end

[Validate]


text:
import proto  # type: ignore

__protobuf__ = proto.module(
    package="google.cloud.aiplatform.v1beta1.schema.trainingjob.definition",
    manifest={"AutoMlTextSentiment", "AutoMlTextSentimentInputs",},
)

class AutoMlTextSentiment(proto.Message):
    r"""A TrainingJob that trains and uploads an AutoML Text
    Sentiment Model.

    Attributes:
        inputs (google.cloud.aiplatform.v1beta1.schema.trainingjob.definition_v1beta1.types.AutoMlTextSentimentInputs):
            The input parameters of this TrainingJob.
    """

    inputs = proto.Field(proto.MESSAGE, number=1, message="AutoMlTextSentimentInputs",)

class AutoMlTextSentimentInputs(proto.Message):
    r"""
    Attributes:
        sentiment_max (int):
            A sentiment is expressed as an integer
            ordinal, where higher value means a more
            positive sentiment. The range of sentiments that
            will be used is between 0 and sentimentMax
            (inclusive on both ends), and all the values in
            the range must be represented in the dataset
            before a model can be created.
            Only the Annotations with this sentimentMax will
            be used for training. sentimentMax value must be
            between 1 and 10 (inclusive).
    """

    sentiment_max = proto.Field(proto.INT32, number=1,)

__all__ = tuple(sorted(__protobuf__.manifest))