text:
<?php session_start();

$url =  'http://'.$_SERVER['HTTP_HOST'].dirname($_SERVER['PHP_SELF']).'/index.php';
if (!isset($_SESSION['userid'])){
    header('HTTP/1.1 303 See other');
    header('LOCATION:'.$url);
}

?>
<!doctype html>

<meta charset="utf-8">
<title>Dashboard</title>
<link rel="stylesheet" href="https://fonts.googleapis.com/icon?family=Material+Icons">
<link rel="stylesheet" href="https://code.getmdl.io/1.3.0/material.pink-blue.min.css" />
<link rel="stylesheet" href="less/material-modal.css"/>
<link rel="stylesheet" href="main.css"/>

<?php require_once('menu.php');
function countCategories($con){
		$sqlCount='SELECT COUNT(catID) AS categories FROM category WHERE user_ID=?';
		$stmt = $con->prepare($sqlCount);
		$stmt->bind_param('s', $_SESSION['userid']);
		$stmt->execute();
		$stmt->bind_result($catID);
		while($stmt->fetch()){
			echo ''.$catID.'';
		}
}
function countFlashcards($con){
	$sqlCount='SELECT COUNT(flashcards.flashcardID) AS flashcardsNo
				FROM flashcards, category
				WHERE flashcards.category_catID=category.catID
				AND category.user_ID=?';
	$stmt = $con->prepare($sqlCount);
	$stmt->bind_param('s', $_SESSION['userid']);
	$stmt->execute();
	$stmt->bind_result($catID);
	while($stmt->fetch()){
		echo ''.$catID.'';
	}
}
// unused for now
function deleteCat($con, $catID){
	$sqlUser='DELETE FROM flashcards WHERE flashcards.category_catID=?';
	$stmt = $con->prepare($sqlUser);
	$stmt->bind_param('i', $catID);
	$stmt->execute();
	echo 'were here';
	$sqlUser='DELETE FROM category WHERE catID=?';
	$stmt = $con->prepare($sqlUser);
	$stmt->bind_param('i', $catID);
	$stmt->execute();

}
?>

            <div class="mdl-card__title" style="background: url('<?=$_SESSION['avatar']?>') center / cover">

Welcome, <?=$_SESSION['person']?>

You have <?php countCategories($con);?> categories

				   and <?php countFlashcards($con); ?> flashcards in total

                    Get Started

                    Edit your profile

Categories

Here are all categories you have. If you miss something just add a new one!

						  add

               <?php
				    $sqlCatDisplay = 'SELECT c.catID, c.cat_name, l.lang_name
									FROM category c, language l
									WHERE c.language_langID2=l.langID
									AND user_ID=?';
					$stmt = $con->prepare($sqlCatDisplay);
					$stmt->bind_param('i', $_SESSION['userid']);
					$stmt->execute();
					$stmt->bind_result($catID, $catName, $outputLang);
					while($stmt->fetch()){ ?>

<?=$catName;?>

									Output language <?=$outputLang;?>

									  <a href="flashcards.php?catid=<?=$catID;?>&catname=<?=$catName;?>"class="mdl-button mdl-button--colored mdl-js-button mdl-js-ripple-effect">
										  See flashcards inside

								   <div id="deleteCat<?=$catID?>" class="modal modal__bg">

Are you sure?

										<form action="<?=$_SERVER['PHP_SELF']?>" method="post" enctype="multipart/form-data">

												Are you sure you want to delete category with all the flashcards that it containts? Once deleted it's gone forever...

											  <input type="hidden" name="categoryid" value="<?=$catID?>">
											  <input type="submit" name="catDelete" value="Yes, delete: <?=$catID?>" class="mdl-button mdl-button--colored mdl-js-button">
											  <button class="mdl-button mdl-js-button mdl-button--raised mdl-js-ripple-effect mdl-button--colored modal__close">
												NO! Take me back
											  </button>
											  <?php if (!empty(filter_input(INPUT_POST, 'catDelete'))) { deleteCat($con, $catID); } ?>

										</form>

				<?php
					 }
				?>

                <button class="mdl-button mdl-button--icon mdl-js-button mdl-js-ripple-effect">
                    share
                </button>

Get started with Flashcards reborn

              		Flashcards reborn is a part of a Fiszki Android app and it takes a next step in learning new vocab. Soon you'll be able to experience a new way of managing your flashcards via web. Please notice that this is not finished product, therefore it still doesn't support our native app, but we're working on it.

					If you find aby bugs or you want to share an idea, please open a new issue on our GitHub repository.

				  	Got it! Let's get started!

<?php require_once('footer.php'); ?>


text:
package com.gazbert.bxbot.repository;

import com.gazbert.bxbot.domain.exchange.ExchangeConfig;

/**
 * The Exchange configuration repository.
 *
 * @author gazbert
 */
public interface ExchangeConfigRepository {

  ExchangeConfig get();

  ExchangeConfig save(ExchangeConfig config);
}

redpajama_set_name: RedPajamaGithub


text:
from django.apps import AppConfig

class VersatileImageFieldConfig(AppConfig):
    """The Django app config for django-versatileimagefield."""
    name = 'versatileimagefield'
    verbose_name = "VersatileImageField"

    def ready(self):
        from .registry import autodiscover
        autodiscover()


text:
package android.app;

@com.francetelecom.rd.stubs.annotation.ClassDone(0)
public class AlarmManager
{
  // Fields

  public static final int RTC_WAKEUP = 0;

  public static final int RTC = 1;

  public static final int ELAPSED_REALTIME_WAKEUP = 2;

  public static final int ELAPSED_REALTIME = 3;

  public static final long INTERVAL_FIFTEEN_MINUTES = 900000l;

  public static final long INTERVAL_HALF_HOUR = 1800000l;

  public static final long INTERVAL_HOUR = 3600000l;

  public static final long INTERVAL_HALF_DAY = 43200000l;

  public static final long INTERVAL_DAY = 86400000l;

  // Constructors

  AlarmManager(IAlarmManager arg1){
  }
  // Methods

  @com.francetelecom.rd.stubs.annotation.ArgsRule(value = "AlarmManager.set", pos = {1, 2, 3}, report = "-")
  public void set(int arg1, long arg2, PendingIntent arg3){
  }
  @com.francetelecom.rd.stubs.annotation.ArgsRule(value = "AlarmManager.setTime", pos = 1, report = "-")
  public void setTime(long arg1){
  }
  @com.francetelecom.rd.stubs.annotation.ArgsRule(value = "AlarmManager.setTimeZone", pos = 1, report = "-")
  public void setTimeZone(java.lang.String arg1){
  }
  public void cancel(PendingIntent arg1){
  }
  @com.francetelecom.rd.stubs.annotation.ArgsRule(value = "AlarmManager.setRepeating", pos = {1, 2, 3, 4}, report = "-")
  public void setRepeating(int arg1, long arg2, long arg3, PendingIntent arg4){
  }
  @com.francetelecom.rd.stubs.annotation.ArgsRule(value = "AlarmManager.setInexactRepeating", pos = {1, 2, 3, 4}, report = "-")
  public void setInexactRepeating(int arg1, long arg2, long arg3, PendingIntent arg4){
  }
}


text:
/*
 * Created by SharpDevelop.
 * User: Familia
 * Date: 14/05/2016
 * Time: 22:03
 *
 * To change this template use Tools | Options | Coding | Edit Standard Headers.
 */
using System;
using App.Comparer;

namespace App.Register
{
	public delegate bool DelegateRegisterOpcionalCheck();

	/// <summary>
	/// This class allows converting a excel cell to a string
	/// There are some details related with every kind of register
	/// </summary>
	public class GenericRegister
	{
		private eRegisterId _Id = eRegisterId.ID_Undefined;
		private uint _length = 0;
		private uint _start = 0;
		private uint _end = 0;
		private IComparer _Comparer = null;

		private char _pad = ' ';
		private eRegisterFormat _format = eRegisterFormat.PadRight;

		private bool _opcional = false;
		private DelegateRegisterOpcionalCheck RegisterOpcionalCheck = null;

		public GenericRegister(eRegisterId id, uint lenght, uint start, uint end, eRegisterFormat format, char filler)
		{
			_Id = id;
			_length = lenght;
			_start = start;
			_end = end;
			_format = format;
			_pad = filler;

			_Comparer = ComparerFactory.CreateComparer(_Id);
		}

		public void SetRegisterOpcionalCheck(DelegateRegisterOpcionalCheck check)
		{
			if(check != null)
			{
				_opcional = true;
				RegisterOpcionalCheck = check;
			}
		}

		public string GetValue(string input)
		{
			string retval = string.Empty;

			if((_Id != eRegisterId.ID_Filler) && (_Comparer.IsMatch(input)))
			{
				retval = _Comparer.GetOutput();
			}
			else
			{
				// Comprobar si es opcional, y casos de error
			}

			// Recortar cadena
			if(retval.Length > _length)
			{
				retval = retval.Substring(0, (int)_length);
			}
			else
			{
				if(retval.Length < _length)
				{
					char aux_pad = (retval.Length < 1) ? ' ' : _pad;
					// Padding
					if(_format == eRegisterFormat.PadRight)
						retval = retval.PadRight((int)_length, aux_pad);
					else
						retval = retval.PadLeft((int)_length, aux_pad);
				}
			}

			return (retval);
		}
	}
}


text:
<?xml version="1.0" encoding="utf-8"?>
<labels>
	Портал
	Портал
	Портал
	Моји филтери
	Датум
	Купац
	Бр.
	Број
	Крајњи рок
	Кр
	Почни
	П
	Купац
	Цкочи
	Број задатка
	Задаци
	Повратне информације
	П
	Не постоји задатак у овом избору филтера
	Нема пројектa за траженu филтер селекцију
	Портал > Избор
	Портал > Задаци
	Портал > Повратне информације
	Портал > Термини
	Покажи у пројекту
	Није изабран ниједан филтер!
</labels>


text:
package com.qingdao81.resourceverifier.cli;

import com.qingdao81.resourceverifier.annotation.ResourceVerifier;
import org.immutables.value.Value;

/**
 * CLI parser properties, auto generated by immutable library
 *
 */
@Value.Immutable
public interface CLIProperties {

    String host();

    int port();

    ResourceVerifier.Type type();

    long timeout();

    String uri();

    boolean logDetails();
}


text: sudo apt-get -y install smtp-user-enum


text:
Ohm's Law
---

### Introduction to Ohm's Law

![](file:///android_asset/DOC_HTML/apps/images/schematics/ohms.svg@100%|auto)

* Make the Connections as shown in the figure.

* CH1 monitors the Voltage across the resistor.

* PCS sets a suitable current flow through the resistor .

* Calculate the voltage across the resistor for various different currents, and plot them.

* Do Not use high value resistors, because the current source will not be able adjust to such high levels to ensure the right amount of current flow. Up to 200 ohms is ideal

#### Screenshot

![](file:///android_asset/DOC_HTML/apps/images/screenshots/ohms_law.png@100%|auto)


text:
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>

  <groupId>io.vertx</groupId>
  <artifactId>maven-verticles-examples</artifactId>
  <version>4.3.1</version>

  <packaging>pom</packaging>

  <modules>
    <module>maven-verticle</module>
    <module>maven-verticle-groovy</module>
    <module>maven-verticle-groovy-compiled</module>
  </modules>

</project>


text:
package be.doji.productivity.trambuapp.utils;

public final class DisplayConstants {

    /**
     * Utility classes should not have a public or default constructor
     */
    private DisplayConstants() {
    }

    public static final String SEPARATOR_TAGS_PROJECTS = ",";

    public static final String TITLE_APPLICATION = "TraMBU - visual activity and time tracking";
    public static final String TITLE_ACTIVITY = "[Activities]";
    public static final String TITLE_TIMESHEET = "[Timesheet]";
    public static final String TITLE_OPTIONS = "[Options]";

    public static final String STYLE_GLYPH_DEFAULT = "-fx-fill: linear-gradient(#ffffff, #d2d2d2); -fx-effect: dropshadow( one-pass-box , rgba(0,0,0,0.8) , 4 , 0.0 , 1 , 1 );";
    public static final String STYLE_CLASS_ACTIVITY_DONE = "done";
    public static final String STYLE_CLASS_ACTIVITY_TODO = "todo";
    public static final String STYLE_CLASS_ACTIVITY_ALERT = "alert";
    public static final String STYLE_CLASS_DEFAULT = "default";

    public static final String STYLE_LABEL_SPECIAL = "separatorLabel";
    public static final String STYLE_ACTIVTY_OVERLAY = "-fx-background-color: #8598a6; -fx-border-width: 2px; -fx-border-color: #3a4351; -fx-border-radius: 8px; -fx-background-radius: 9px; -fx-opacity: 0.95;";

    public static final String BUTTON_TEXT_IS_NOT_DONE = "Not Done";
    public static final String BUTTON_TEXT_IS_DONE = "Done!";
    public static final String BUTTON_TEXT_SAVE = "Save";
    public static final String BUTTON_TEXT_EDIT = "Edit";
    public static final String BUTTON_TEXT_DELETE = "Delete";
    public static final String BUTTON_TEXT_TIMER_START = "Start timing";
    public static final String BUTTON_TEXT_TIMER_STOP = "Stop timing";

    public static final String LABEL_TEXT_FILTER_COMPLETED = "Filter completed activities";
    public static final String LABEL_TEXT_FILTER_NONE = "No active filter";

    public static final String TEXT_ACTIVITY_UNKNOWN = "Unknown activity";

    public static final String NAME_CONFIGURATION_FILE = "trambu.conf";
    public static final String NAME_PROPERTY_TODO_LOCATION = "todoFile";
    public static final String NAME_PROPERTY_TIME_LOCATION = "timeFile";
    public static final String NAME_PROPERTY_NOTES_LOCATION = "noteDirectory";

    public static final String ERROR_MESSAGE_ACTIVITY_SAVING = "Error while saving activity";
    public static final String ERROR_MESSAGE_INITIALIZATION = "Error while initializing application";

    public static final String ERROR_MESSAGE_WRITE_PROPERTIES = "Error while saving preferences";

    public static final double UI_DEFAULT_WINDOW_WIDTH = 750.0;
    public static final double UI_DEFAULT_WINDOW_HEIGHT = 850.0;

    public static final String REGEX_WARNING_PERIOD = "[0-9]*";
}


text:
var app = require('./app'),
    firebase = require('./firebase'),
    chalk = require('chalk');

module.exports = {
  showHelp: function(command) {
    switch (command) {

      // Top-level functionality

      case 'login':
        console.log('\n' +
                    '  firebase login\n' +
                    '    Logs the user into Firebase. All commands that require login will prompt\n' +
                    '    you if you\'re not currently logged in.\n' +
                    '\n' +
                    '    Optional command line parameters:\n' +
                    '\n' +
                    '      --email     The email address of the account\n' +
                    '      --password  The password of the account\n' +
                    '\n' +
                    '    Stores the email address and access token granted from Firebase in a\n' +
                    '    .firebaserc settings file in the user\'s home directory. Access tokens\n' +
                    '    are valid for up to 30 days.\n');
        break;
      case 'logout':
        console.log('\n' +
                    '  firebase logout\n' +
                    '    Logs the user out of Firebase.\n' +
                    '\n' +
                    '    Optional command line parameters:\n' +
                    '\n' +
                    '      -d  Flag to delete the .firebaserc settings file entirely\n' +
                    '\n' +
                    '    Invalidates and removes the access token from the .firebaserc settings file\n' +
                    '    in the user\'s home directory. Optionally deletes the entire settings file.\n');
        break;
      case 'ls':
      case 'list':
        console.log('\n' +
                    '  firebase list\n' +
                    '    Lists the Firebases available to the currently logged in user.\n' +
                    '\n' +
                    '    If the user is not currently logged in, they are prompted to do so - see\n' +
                    '    `firebase login --help` for more details.\n');
        break;

      // Submodules

      case 'init':
      case 'initialise':
      case 'initialize':
        console.log('\n' +
                    '  firebase init\n' +
                    '    Initializes an existing Firebase app in the current directory and prompts\n' +
                    '    you through configuring it for firebaseapp.com.\n' +
                    '\n' +
                    '    Optional command line parameters:\n' +
                    '\n' +
                    '      -f, --firebase  The Firebase to initalize the app with. The current user\n' +
                    '                      must have access to this Firebase. This is used for the\n' +
                    '                      subdomain of firebaseapp.com\n' +
                    '      -p, --public    A directory containing all of the app\'s static files that\n' +
                    '                      should uploaded when deploying. Defaults to the current\n' +
                    '                      directory.\n' +
                    '\n' +
                    '    Generates a firebase.json file in the current directory for all the settings\n' +
                    '    required for deploy. If the user is not currently logged in, they are\n' +
                    '    prompted to do so - see `firebase login --help` for more details.\n');
        break;
      case 'bootstrap':
        var helpOverview =
                    '\n' +
                    '  firebase bootstrap\n' +
                    '    Creates a new Firebase powered app from a prebuilt template to quickly\n' +
                    '    get a project up and running. This creates a new folder and prompts\n' +
                    '    you through all the required settings.\n' +
                    '\n' +
                    '    Optional command line parameters:\n' +
                    '\n' +
                    '      -f, --firebase  The Firebase to initalize the app with. The current user\n' +
                    '                      must have access to this Firebase. This is used for the\n' +
                    '                      subdomain of firebaseapp.com\n' +
                    '      -t, --template  The name of the template to bootstrap the app with.\n';

        var helpFooter = '\n' +
                    '    Downloads and unpacks the template into a folder named after the Firebase\n' +
                    '    with which it has been initialized. Creates a firebase.json file in the\n' +
                    '    directory with some pre-configured settings appropriate for the template.\n' +
                    '    If the user is not currently logged in, they are prompted to do so - see\n' +
                    '    `firebase login --help` for more details.\n';

        app.getTemplates()
          .done(function(templates) {
            var helpTemplates = '\n                      The currently available templates are:\n';
            var templateList = Object.keys(templates).sort();
            for (var i = 0; i < templateList.length; i++) {
              var key = templateList[i],
                  template = templates[key];
              helpTemplates += '\n                        ' + chalk.yellow(key);
              helpTemplates += (template.repository) ? ' - ' + template.repository + '\n' : '\n';
              if (template.description) {
                helpTemplates += '                          ' + template.description;
              }
              helpTemplates += '\n';
            }

            console.log(helpOverview + helpTemplates + helpFooter);
          }, function(error) {
            var errTemplates = '\n                      ';
            errTemplates += chalk.red('Error: ') + 'Could not retrieve available templates.\n';

            console.log(helpOverview + errTemplates + helpFooter);
          });
        break;
      case 'deploy':
        console.log('\n' +
                    '  firebase deploy\n' +
                    '    Deploys the current app to Firebase Hosting and creates your subdomain on\n' +
                    '    firebaseapp.com if it doesn\'t already exist.\n' +
                    '\n' +
                    '    Optional command line parameters:\n' +
                    '\n' +
                    '      -m, --message  An optional version message\n' +
                    '\n' +
                    '      -f, --firebase Overrides the Firebase setting in the firebase.json\n' +
                    '      -p, --public   Overrides the public directory setting in the\n' +
                    '                     firebase.json\n' +
                    '\n' +
                    '    Uploads the directory detailed in the firebase.json settings file and\n' +
                    '    updates the security rules of the Firebase if specified. The current user\n' +
                    '    must have access to the Firebase in firebase.json, and if the user is not\n' +
                    '    currently logged in, they are prompted to do so - see\n' +
                    '    `firebase login --help` for more details.\n');
        break;
      case 'delete-site':
        console.log('\n' +
                    '  firebase delete-site\n' +
                    '    Deletes the current app from Firebase Hosting and displays a \n' +
                    '    \'Site not Found\' page as if the site had never been deployed to.\n' +
                    '\n' +
                    '    Optional command line parameters:\n' +
                    '\n' +
                    '      -m, --message  An optional version message\n' +
                    '\n' +
                    '      -f, --firebase Overrides the Firebase setting in the firebase.json\n' +
                    '\n' +
                    '    Deletes the site associated with the Firebase detailed in the firebase.json\n' +
                    '    settings file. The current user must have access to the Firebase, and if\n' +
                    '    the user is not currently logged in, they are prompted to do so - see\n' +
                    '    `firebase login --help` for more details.\n');
        break;
      case 'open':
        console.log('\n' +
                    '  firebase open\n' +
                    '    Opens the current Firebase app\'s firebaseapp.com subdomain in a browser.\n' +
                    '\n' +
                    '    The current directory must have been initialized using firebase init or\n' +
                    '    firebase bootstrap\n');
        break;

      default:
        this.showVersion();
        console.log('Usage: firebase <command>\n' +
                    '\n' +
                    '  Available commands are:\n' +
                    '\n' +
                    '  bootstrap\n' +
                    '    Creates a new Firebase powered app from a prebuilt template to quickly\n' +
                    '    get a project up and running. This creates a new folder and prompts\n' +
                    '    you through all the required settings.\n' +
                    '\n' +
                    '  deploy\n' +
                    '    Deploys the current app to Firebase Hosting and creates your subdomain on\n' +
                    '    firebaseapp.com if it doesn\'t already exist.\n' +
                    '\n' +
                    '  init\n' +
                    '    Initializes an existing Firebase app in the current directory and prompts\n' +
                    '    you through configuring it for firebaseapp.com.\n' +
                    '\n' +
                    '  open\n' +
                    '    Opens the URL of the current Firebase app in a browser.\n' +
                    '\n' +
                    '  list\n' +
                    '    Lists the Firebases available to the currently logged in user.\n' +
                    '\n' +
                    '  delete-site\n' +
                    '    Deletes the current app from Firebase Hosting and displays a \n' +
                    '    \'Site not Found\' page as if the site had never been deployed to.\n' +
                    '\n' +
                    '  login\n' +
                    '    Logs you into Firebase. All commands that require login will prompt\n' +
                    '    you if you\'re not currently logged in.\n' +
                    '\n' +
                    '  logout\n' +
                    '    Logs you out of Firebase.\n' +
                    '\n' +
                    '  -h, --help\n' +
                    '    Shows this help screen. Use `firebase <command> --help` for more detailed\n' +
                    '    help instructions.\n' +
                    '\n' +
                    '  -v, --version\n' +
                    '    Displays the current version.\n' +
                    '\n' +
                    '  -s, --silent\n' +
                    '    Silent mode for scripting - commands will error with non-zero status code\n' +
                    '    instead of waiting for prompt if not enough information supplied.\n' +
                    '\n' +
                    'For a quick start guide, see https://www.firebase.com/docs/hosting.html\n');
    }
  },
  showVersion: function() {
    console.log('\n' +
                'Firebase Command Line Tools\n' +
                'Version ' + firebase.version + '\n' +
                'https://www.firebase.com\n');
  }
};


text:
<?xml version="1.0" encoding="utf-8" ?>
<!DOCTYPE erlref SYSTEM "erlref.dtd">

<erlref>

    <copyright>
      <year>1999</year><year>2020</year>
      <holder>Ericsson AB. All Rights Reserved.</holder>
    </copyright>
    <legalnotice>
      Licensed under the Apache License, Version 2.0 (the "License");
      you may not use this file except in compliance with the License.
      You may obtain a copy of the License at

          http://www.apache.org/licenses/LICENSE-2.0

      Unless required by applicable law or agreed to in writing, software
      distributed under the License is distributed on an "AS IS" BASIS,
      WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
      See the License for the specific language governing permissions and
      limitations under the License.

    </legalnotice>
    <title>ssl</title>
    <prepared></prepared>
    <docno></docno>
    <date></date>
    <rev></rev>
    <file>ssl_session_cache_api.xml</file>

  <module since="OTP R14B">ssl_session_cache_api</module>
  <modulesummary>TLS session cache API</modulesummary>

  <description>

      Defines the API for the TLS session cache so
      that the data storage scheme can be replaced by
      defining a new callback module implementing this API.

  </description>

  <datatypes>

      <datatype>
	<name name="session_cache_ref"/>
      </datatype>

      <datatype>
	<name name="session_cache_key"/>
	<desc>

A key to an entry in the session cache.

	</desc>
      </datatype>

        <datatype>
	  <name name="partial_key"/>
	<desc>

The opaque part of the key. Does not need to be handled
	  by the callback.

	</desc>
      </datatype>

       <datatype>
	<name name="session"/>
	<desc>

The session data that is stored for each session.

	</desc>
      </datatype>
  </datatypes>

  <funcs>

    <func>
      <name since="OTP R14B">delete(Cache, Key) -> _</name>
      <fsummary>Deletes a cache entry.</fsummary>
      <type>
	<v>Cache = <seetype marker="#session_cache_ref"> session_cache_ref() </seetype></v>
	<v>Key = <seetype marker="#session_cache_key">session_cache_key() </seetype> </v>
      </type>
      <desc>

Deletes a cache entry. Is only called from the cache
	handling process.

      </desc>
    </func>

    <func>
      <name since="OTP R14B">foldl(Fun, Acc0, Cache) -> Acc</name>
      <fsummary></fsummary>
      <type>
	<v>Fun = fun()</v>
	<v>Acc0 = Acc = term()</v>
	<v>Cache = <seetype marker="#session_cache_ref"> session_cache_ref() </seetype></v>
      </type>
      <desc>

Calls <c>Fun(Elem, AccIn)</c> on successive elements of the
	cache, starting with <c>AccIn == Acc0</c>. <c>Fun/2</c> must
	return a new accumulator, which is passed to the next call.
	The function returns the final value of the accumulator.
	<c>Acc0</c> is returned if the cache is empty.

      </desc>
    </func>

    <func>
      <name since="OTP 18.0">init(Args) -> Cache </name>
      <fsummary>Returns cache reference.</fsummary>
      <type>
	<v>Cache = <seetype marker="#session_cache_ref"> session_cache_ref() </seetype></v>
	<v>Args = <seetype marker="stdlib:proplists#proplist">proplists:proplist()</seetype></v>
      </type>
      <desc>

Includes property <c>{role, client | server}</c>.
	Currently this is the only predefined property,
	there can also be user-defined properties. See also
	application environment variable
	<seeapp marker="ssl_app">session_cb_init_args</seeapp>.

Performs possible initializations of the cache and returns
	a reference to it that is used as parameter to the other
	API functions. Is called by the cache handling processes
	<c>init</c> function, hence putting the same requirements on it
	as a normal process <c>init</c> function. This function is
	called twice when starting the SSL application, once with
	the role client and once with the role server, as the SSL
	application must be prepared to take on both roles.

      </desc>
    </func>

    <func>
      <name since="OTP R14B">lookup(Cache, Key) -> Entry</name>
      <fsummary>Looks up a cache entry.</fsummary>
      <type>
	<v>Cache = <seetype marker="#session_cache_ref"> session_cache_ref() </seetype></v>
	<v>Key = <seetype marker="#session_cache_key">session_cache_key()</seetype> </v>
	<v>Session = <seetype marker="#session">session()</seetype> | undefined</v>
      </type>
      <desc>

Looks up a cache entry. Is to be callable from any
         process.

      </desc>
    </func>

    <func>
      <name since="OTP R14B">select_session(Cache, PartialKey) -> [Session]</name>
      <fsummary>Selects sessions that can be reused.</fsummary>
      <type>
	<v>Cache = <seetype marker="#session_cache_ref"> session_cache_ref() </seetype></v>
	<v>PartialKey = <seetype marker="#partial_key"> partial_key() </seetype></v>
	<v>Session = <seetype marker="#session">session()</seetype></v>
      </type>
      <desc>

Selects sessions that can be reused. Is to be callable
	from any process.

      </desc>
    </func>

    <func>
      <name since="OTP 19.3">size(Cache) -> integer()</name>
      <fsummary>Returns the number of sessions in the cache.</fsummary>
      <type>
	<v>Cache = <seetype marker="#session_cache_ref"> session_cache_ref() </seetype></v>
      </type>
      <desc>

Returns the number of sessions in the cache. If size
	exceeds the maximum number of sessions, the current cache
	entries will be invalidated regardless of their remaining
	lifetime. Is to be callable from any process.

      </desc>
    </func>

    <func>
      <name since="OTP R14B">terminate(Cache) -> _</name>
      <fsummary>Called by the process that handles the cache when it
      is about to terminate.</fsummary>
      <type>
	<v>Cache = <seetype marker="#session_cache_ref"> session_cache_ref() </seetype></v>
	<d>As returned by init/0</d>
      </type>
      <desc>

Takes care of possible cleanup that is needed when the
	cache handling process terminates.

      </desc>
    </func>

    <func>
      <name since="OTP R14B">update(Cache, Key, Session) -> _</name>
      <fsummary>Caches a new session or updates an already cached one.</fsummary>
      <type>
	<v>Cache = <seetype marker="#session_cache_ref"> session_cache_ref() </seetype></v>
	<v>Key = <seetype marker="#session_cache_key">session_cache_key()</seetype> </v>
	<v>Session = <seetype marker="#session">session()</seetype></v>
      </type>
      <desc>

Caches a new session or updates an already cached one. Is
	only called from the cache handling process.

      </desc>
    </func>

  </funcs>

</erlref>


text:
var exec = require('child_process').exec;
var crypto = require('crypto');
var fs = require('fs');

exports.sha1File = function(path, cb) {
  var sha1 = crypto.createHash('sha1');

  var file = fs.createReadStream(path);
  file
    .on('data', function(d) {
      sha1.update(d);
    })
    .on('end', function() {
      cb(null, sha1.digest('hex'));
    });
}

exports.assertSha1 = function(result, fixture) {
  exports.sha1File(fixture, function(err, fixtureSha1) {
    exports.sha1File(result, function(err, resultSha1) {
      if (fixtureSha1 === resultSha1) {
        return;
      }

      var message =
        'Sha1 mismatch: ' + resultSha1 + ' !== ' + fixtureSha1 + ' when ' +
        'comparing ' + result + ' with ' + fixture;
      throw new Error(message);
    });
  });
};


text:
package redis.clients.jedis.tests;

import static org.junit.Assert.assertEquals;

import java.net.URI;
import java.net.URISyntaxException;
import org.junit.BeforeClass;
import org.junit.Test;

import redis.clients.jedis.DefaultJedisClientConfig;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisClientConfig;
import redis.clients.jedis.JedisShardInfo;
import redis.clients.jedis.Protocol;
import redis.clients.jedis.tests.commands.JedisCommandTestBase;
import redis.clients.jedis.tests.utils.RedisVersionUtil;

/**
 * This test class is a copy of {@link JedisTest}.
 * <p>
 * This test is only executed when the server/cluster is Redis 6. or more.
 */
public class JedisWithCompleteCredentialsTest extends JedisCommandTestBase {

  /**
   * Use to check if the ACL test should be ran. ACL are available only in 6.0 and later
   * @throws Exception
   */
  @BeforeClass
  public static void prepare() throws Exception {
    org.junit.Assume.assumeTrue("Not running ACL test on this version of Redis",
        RedisVersionUtil.checkRedisMajorVersionNumber(6));
  }

  @Test
  public void useWithoutConnecting() {
    try (Jedis j = new Jedis()) {
      assertEquals("OK", j.auth("acljedis", "fizzbuzz"));
      j.dbSize();
    }
  }

  @Test
  public void connectWithShardInfo() {
    JedisShardInfo shardInfo = new JedisShardInfo("localhost", Protocol.DEFAULT_PORT);
    shardInfo.setUser("acljedis");
    shardInfo.setPassword("fizzbuzz");
    try (Jedis jedis = new Jedis(shardInfo)) {
      jedis.get("foo");
    }
  }

  @Test
  public void connectWithConfig() {
    try (Jedis jedis = new Jedis(hnp, DefaultJedisClientConfig.builder().build())) {
      jedis.auth("acljedis", "fizzbuzz");
      assertEquals("PONG", jedis.ping());
    }
    try (Jedis jedis = new Jedis(hnp, DefaultJedisClientConfig.builder().user("acljedis")
        .password("fizzbuzz").build())) {
      assertEquals("PONG", jedis.ping());
    }
  }

  @Test
  public void connectWithConfigInterface() {
    try (Jedis jedis = new Jedis(hnp, new JedisClientConfig() {
    })) {
      jedis.auth("acljedis", "fizzbuzz");
      assertEquals("PONG", jedis.ping());
    }
    try (Jedis jedis = new Jedis(hnp, new JedisClientConfig() {
      @Override
      public String getUser() {
        return "acljedis";
      }

      @Override
      public String getPassword() {
        return "fizzbuzz";
      }
    })) {
      assertEquals("PONG", jedis.ping());
    }
  }

  @Test
  public void startWithUrl() {
    try (Jedis j = new Jedis("localhost", 6379)) {
      assertEquals("OK", j.auth("acljedis", "fizzbuzz"));
      assertEquals("OK", j.select(2));
      j.set("foo", "bar");
    }
    try (Jedis j2 = new Jedis("redis://acljedis:fizzbuzz@localhost:6379/2")) {
      assertEquals("PONG", j2.ping());
      assertEquals("bar", j2.get("foo"));
    }
  }

  @Test
  public void startWithUri() throws URISyntaxException {
    try (Jedis j = new Jedis("localhost", 6379)) {
      assertEquals("OK", j.auth("acljedis", "fizzbuzz"));
      assertEquals("OK", j.select(2));
      j.set("foo", "bar");
    }
    try (Jedis j2 = new Jedis(new URI("redis://acljedis:fizzbuzz@localhost:6379/2"))) {
      assertEquals("PONG", j2.ping());
      assertEquals("bar", j2.get("foo"));
    }
  }

  @Test
  public void connectWithURICredentials() throws URISyntaxException {
    jedis.set("foo", "bar");

    try (Jedis j1 = new Jedis(new URI("redis://default:foobared@localhost:6379"))) {
      assertEquals("PONG", j1.ping());
      assertEquals("bar", j1.get("foo"));
    }

    try (Jedis j2 = new Jedis(new URI("redis://acljedis:fizzbuzz@localhost:6379"))) {
      assertEquals("PONG", j2.ping());
      assertEquals("bar", j2.get("foo"));
    }
  }

  @Test
  public void allowUrlWithNoDBAndNoPassword() {
    try (Jedis j1 = new Jedis("redis://localhost:6379")) {
      assertEquals("OK", j1.auth("acljedis", "fizzbuzz"));
      assertEquals("localhost", j1.getClient().getHost());
      assertEquals(6379, j1.getClient().getPort());
      assertEquals(0, j1.getDB());
    }

    try (Jedis j2 = new Jedis("redis://localhost:6379/")) {
      assertEquals("OK", j2.auth("acljedis", "fizzbuzz"));
      assertEquals("localhost", j2.getClient().getHost());
      assertEquals(6379, j2.getClient().getPort());
      assertEquals(0, j2.getDB());
    }
  }

}


text:
/* ----------------------------------------------------------------------------
 * This file was automatically generated by SWIG (http://www.swig.org).
 * Version 3.0.12
 *
 * Do not make changes to this file unless you know what you are doing--modify
 * the SWIG interface file instead.
 * ----------------------------------------------------------------------------- */

package org.pjsip.pjsua2;

public class StreamInfo {
  private transient long swigCPtr;
  protected transient boolean swigCMemOwn;

  protected StreamInfo(long cPtr, boolean cMemoryOwn) {
    swigCMemOwn = cMemoryOwn;
    swigCPtr = cPtr;
  }

  protected static long getCPtr(StreamInfo obj) {
    return (obj == null) ? 0 : obj.swigCPtr;
  }

  protected void finalize() {
    delete();
  }

  public synchronized void delete() {
    if (swigCPtr != 0) {
      if (swigCMemOwn) {
        swigCMemOwn = false;
        pjsua2JNI.delete_StreamInfo(swigCPtr);
      }
      swigCPtr = 0;
    }
  }

  public void setType(pjmedia_type value) {
    pjsua2JNI.StreamInfo_type_set(swigCPtr, this, value.swigValue());
  }

  public pjmedia_type getType() {
    return pjmedia_type.swigToEnum(pjsua2JNI.StreamInfo_type_get(swigCPtr, this));
  }

  public void setProto(pjmedia_tp_proto value) {
    pjsua2JNI.StreamInfo_proto_set(swigCPtr, this, value.swigValue());
  }

  public pjmedia_tp_proto getProto() {
    return pjmedia_tp_proto.swigToEnum(pjsua2JNI.StreamInfo_proto_get(swigCPtr, this));
  }

  public void setDir(pjmedia_dir value) {
    pjsua2JNI.StreamInfo_dir_set(swigCPtr, this, value.swigValue());
  }

  public pjmedia_dir getDir() {
    return pjmedia_dir.swigToEnum(pjsua2JNI.StreamInfo_dir_get(swigCPtr, this));
  }

  public void setRemoteRtpAddress(String value) {
    pjsua2JNI.StreamInfo_remoteRtpAddress_set(swigCPtr, this, value);
  }

  public String getRemoteRtpAddress() {
    return pjsua2JNI.StreamInfo_remoteRtpAddress_get(swigCPtr, this);
  }

  public void setRemoteRtcpAddress(String value) {
    pjsua2JNI.StreamInfo_remoteRtcpAddress_set(swigCPtr, this, value);
  }

  public String getRemoteRtcpAddress() {
    return pjsua2JNI.StreamInfo_remoteRtcpAddress_get(swigCPtr, this);
  }

  public void setTxPt(long value) {
    pjsua2JNI.StreamInfo_txPt_set(swigCPtr, this, value);
  }

  public long getTxPt() {
    return pjsua2JNI.StreamInfo_txPt_get(swigCPtr, this);
  }

  public void setRxPt(long value) {
    pjsua2JNI.StreamInfo_rxPt_set(swigCPtr, this, value);
  }

  public long getRxPt() {
    return pjsua2JNI.StreamInfo_rxPt_get(swigCPtr, this);
  }

  public void setCodecName(String value) {
    pjsua2JNI.StreamInfo_codecName_set(swigCPtr, this, value);
  }

  public String getCodecName() {
    return pjsua2JNI.StreamInfo_codecName_get(swigCPtr, this);
  }

  public void setCodecClockRate(long value) {
    pjsua2JNI.StreamInfo_codecClockRate_set(swigCPtr, this, value);
  }

  public long getCodecClockRate() {
    return pjsua2JNI.StreamInfo_codecClockRate_get(swigCPtr, this);
  }

  public void setCodecParam(SWIGTYPE_p_void value) {
    pjsua2JNI.StreamInfo_codecParam_set(swigCPtr, this, SWIGTYPE_p_void.getCPtr(value));
  }

  public SWIGTYPE_p_void getCodecParam() {
    long cPtr = pjsua2JNI.StreamInfo_codecParam_get(swigCPtr, this);
    return (cPtr == 0) ? null : new SWIGTYPE_p_void(cPtr, false);
  }

  public StreamInfo() {
    this(pjsua2JNI.new_StreamInfo(), true);
  }

}


text:
package me.ellios.hedwig.rpc.server;

import me.ellios.hedwig.rpc.core.ServiceSchema;
import me.ellios.hedwig.rpc.core.ServiceType;

/**
 * RPC server factory to initiate the required {@link me.ellios.hedwig.rpc.server.RpcServer}.
 *
 * @author George Cao
 * @since 4/26/13 11:50 AM
 */
public interface RpcServerFactory {

    /**
     * Checks if the current factory to handle the required server.
     *
     * @param schema the required server schema
     * @param type   the required server type
     * @return true or false.
     */
    boolean accept(ServiceSchema schema, ServiceType type);

    /**
     * Creates a new {@link me.ellios.hedwig.rpc.server.RpcServer}.
     * This method is only invoked when
     * {@link #accept(me.ellios.hedwig.rpc.core.ServiceSchema, me.ellios.hedwig.rpc.core.ServiceType)}
     * returns true.
     *
     * @return new {@link me.ellios.hedwig.rpc.server.RpcServer} instance.
     * @see #accept(me.ellios.hedwig.rpc.core.ServiceSchema, me.ellios.hedwig.rpc.core.ServiceType)
     */
    RpcServer create();
}


text:
package com.jetbrains.python.psi.impl.stubs;

import com.intellij.psi.stubs.IStubElementType;
import com.intellij.psi.stubs.StubBase;
import com.intellij.psi.stubs.StubElement;
import com.jetbrains.python.psi.PyFunction;
import com.jetbrains.python.psi.stubs.PyFunctionStub;
import org.jetbrains.annotations.NotNull;
import org.jetbrains.annotations.Nullable;

public class PyFunctionStubImpl extends StubBase<PyFunction> implements PyFunctionStub {
  private final String myName;
  private final String myDocString;
  private final String myDeprecationMessage;
  private final boolean myAsync;
  private final boolean myGenerator;
  private final boolean myOnlyRaisesNotImplementedError;
  private final String myTypeComment;
  private final String myAnnotation;

  public PyFunctionStubImpl(@Nullable String name,
                            @Nullable String docString,
                            @Nullable String deprecationMessage,
                            boolean isAsync,
                            boolean isGenerator,
                            boolean onlyRaisesNotImplementedError,
                            @Nullable String typeCommentContent,
                            @Nullable String annotation,
                            final StubElement parent,
                            @NotNull IStubElementType stubElementType) {
    super(parent, stubElementType);
    myName = name;
    myDocString = docString;
    myDeprecationMessage = deprecationMessage;
    myAsync = isAsync;
    myGenerator = isGenerator;
    myOnlyRaisesNotImplementedError = onlyRaisesNotImplementedError;
    myTypeComment = typeCommentContent;
    myAnnotation = annotation;
  }

  @Nullable
  @Override
  public String getName() {
    return myName;
  }

  @Nullable
  @Override
  public String getDocString() {
    return myDocString;
  }

  @Nullable
  @Override
  public String getDeprecationMessage() {
    return myDeprecationMessage;
  }

  @Nullable
  @Override
  public String getTypeComment() {
    return myTypeComment;
  }

  @Nullable
  @Override
  public String getAnnotation() {
    return myAnnotation;
  }

  @Override
  public boolean isAsync() {
    return myAsync;
  }

  @Override
  public boolean isGenerator() {
    return myGenerator;
  }

  @Override
  public boolean onlyRaisesNotImplementedError() {
    return myOnlyRaisesNotImplementedError;
  }

  @Override
  public String toString() {
    return "PyFunctionStub(" + myName + ")";
  }
}


text:
namespace blink {

class PLATFORM_EXPORT BeginClipPathDisplayItem final : public PairedBeginDisplayItem {
public:
    BeginClipPathDisplayItem(const DisplayItemClient& client, const Path& clipPath)
        : PairedBeginDisplayItem(client, BeginClipPath, sizeof(*this))
        , m_clipPath(clipPath.getSkPath()) { }

    void replay(GraphicsContext&) const override;
    void appendToWebDisplayItemList(const IntRect&, WebDisplayItemList*) const override;

    void analyzeForGpuRasterization(SkPictureGpuAnalyzer&) const override;

private:
    const SkPath m_clipPath;
#ifndef NDEBUG
    void dumpPropertiesAsDebugString(WTF::StringBuilder&) const override;
#endif
#if ENABLE(ASSERT)
    bool equals(const DisplayItem& other) const final
    {
        return DisplayItem::equals(other)
            && m_clipPath == static_cast<const BeginClipPathDisplayItem&>(other).m_clipPath;
    }
#endif
};

class PLATFORM_EXPORT EndClipPathDisplayItem final : public PairedEndDisplayItem {
public:
    EndClipPathDisplayItem(const DisplayItemClient& client)
        : PairedEndDisplayItem(client, EndClipPath, sizeof(*this)) { }

    void replay(GraphicsContext&) const override;
    void appendToWebDisplayItemList(const IntRect&, WebDisplayItemList*) const override;

private:
#if ENABLE(ASSERT)
    bool isEndAndPairedWith(DisplayItem::Type otherType) const final { return otherType == BeginClipPath; }
#endif
};

} // namespace blink

#endif // ClipPathDisplayItem_h


text:
import re
import sys

from setuptools import setup

if sys.hexversion < 0x20700f0:
    print 'Mailman requires at least Python 2.7'
    sys.exit(1)

setup(
    name            = 'mailman-bundler-dev',
    version         = '1',
    description     = 'Mailman with its admin and archiving interfaces(development version)',
    long_description= """\
This is GNU Mailman, a mailing list management system distributed under the
terms of the GNU General Public License (GPL) version 3 or later.
This package installs GNU Mailman alongside its administration and archiving
interfaces, Postorius and HyperKitty.
""",
    author          = 'The Mailman Developers',
    author_email    = 'mailman-developers@python.org',
    license         = 'GPLv3',
    url             = 'http://www.list.org',
    keywords        = 'email',
    #packages        = ['mailman_bundler'],
    #include_package_data = True,
    install_requires = [
        "zc.buildout"
        ],
    entry_points = {
        "console_scripts": [
            "django-read-settings = mailman_bundler_dev.django_read_settings:main",
            ],
        },
    )


text:
  <button
    class="btn-large waves-effect"
    (click)="onLetterPressed(letter)"
    *ngFor="let letter of letters">
      {{ letter }}
  </button>


text:
using System.Windows;
using System.Windows.Forms;
using FilesToDatabaseImporter.ViewModels;

namespace FilesToDatabaseImporter.Views
{
    public partial class DirectorySelectorView
    {
        public DirectorySelectorViewModel ViewModel
        {
            get { return DataContext as DirectorySelectorViewModel; }
        }

        public DirectorySelectorView()
        {
            InitializeComponent();
        }

        private void DirectoryBrowseButtonClicked(object sender, RoutedEventArgs e)
        {
            var dialog = new FolderBrowserDialog();
            var result = dialog.ShowDialog();
            if (result == DialogResult.OK)
            {
                ViewModel.Directory = dialog.SelectedPath;
            }
        }
    }
}


text:
<?php

require 'default_rollback.php';


text:
import { ComponentFixture, TestBed, waitForAsync } from '@angular/core/testing';

import { ProviderCreationComponent } from './provider-creation.component';

describe('ProviderCreationComponent', () => {
  let component: ProviderCreationComponent;
  let fixture: ComponentFixture<ProviderCreationComponent>;

  beforeEach(waitForAsync(() => {
    TestBed.configureTestingModule({
      declarations: [ ProviderCreationComponent ]
    })
    .compileComponents();
  }));

  beforeEach(() => {
    fixture = TestBed.createComponent(ProviderCreationComponent);
    component = fixture.componentInstance;
    fixture.detectChanges();
  });

  it('should create', () => {
    expect(component).toBeTruthy();
  });
});


text:
package io.apiman.gateway.platforms.war.micro;

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

/**
 * A user.
 *
 * @author eric.wittmann@redhat.com
 */
public class User {

    private String id;
    private String password;
    private List<String> roles = new ArrayList<>();

    /**
     * Constructor.
     */
    public User() {
    }

    /**
     * @return the id
     */
    public String getId() {
        return id;
    }

    /**
     * @param id the id to set
     */
    public void setId(String id) {
        this.id = id;
    }

    /**
     * @return the password
     */
    public String getPassword() {
        return password;
    }

    /**
     * @param password the password to set
     */
    public void setPassword(String password) {
        this.password = password;
    }

    /**
     * @return the roles
     */
    public List<String> getRoles() {
        return roles;
    }

    /**
     * @param roles the roles to set
     */
    public void setRoles(List<String> roles) {
        this.roles = roles;
    }

    public String [] getRolesAsArray() {
        return roles.toArray(new String[roles.size()]);
    }

}


text:
namespace google {
namespace cloud {
namespace notebooks_internal {
GOOGLE_CLOUD_CPP_INLINE_NAMESPACE_BEGIN

namespace {
auto constexpr kBackoffScaling = 2.0;
}  // namespace

Options ManagedNotebookServiceDefaultOptions(Options options) {
  options = google::cloud::internal::PopulateCommonOptions(
      std::move(options), "GOOGLE_CLOUD_CPP_MANAGED_NOTEBOOK_SERVICE_ENDPOINT",
      "", "GOOGLE_CLOUD_CPP_MANAGED_NOTEBOOK_SERVICE_AUTHORITY",
      "notebooks.googleapis.com");
  options =
      google::cloud::internal::PopulateGrpcOptions(std::move(options), "");
  if (!options.has<notebooks::ManagedNotebookServiceRetryPolicyOption>()) {
    options.set<notebooks::ManagedNotebookServiceRetryPolicyOption>(
        notebooks::ManagedNotebookServiceLimitedTimeRetryPolicy(
            std::chrono::minutes(30))
            .clone());
  }
  if (!options.has<notebooks::ManagedNotebookServiceBackoffPolicyOption>()) {
    options.set<notebooks::ManagedNotebookServiceBackoffPolicyOption>(
        ExponentialBackoffPolicy(std::chrono::seconds(1),
                                 std::chrono::minutes(5), kBackoffScaling)
            .clone());
  }
  if (!options.has<notebooks::ManagedNotebookServicePollingPolicyOption>()) {
    options.set<notebooks::ManagedNotebookServicePollingPolicyOption>(
        GenericPollingPolicy<
            notebooks::ManagedNotebookServiceRetryPolicyOption::Type,
            notebooks::ManagedNotebookServiceBackoffPolicyOption::Type>(
            options.get<notebooks::ManagedNotebookServiceRetryPolicyOption>()
                ->clone(),
            options.get<notebooks::ManagedNotebookServiceBackoffPolicyOption>()
                ->clone())
            .clone());
  }
  if (!options.has<
          notebooks::
              ManagedNotebookServiceConnectionIdempotencyPolicyOption>()) {
    options.set<
        notebooks::ManagedNotebookServiceConnectionIdempotencyPolicyOption>(
        notebooks::
            MakeDefaultManagedNotebookServiceConnectionIdempotencyPolicy());
  }

  return options;
}

GOOGLE_CLOUD_CPP_INLINE_NAMESPACE_END
}  // namespace notebooks_internal
}  // namespace cloud
}  // namespace google


text:
import React from "react";

export default class Login extends React.Component {
  render() {
    return
Login
;
  }
}


text:
void CompareTPs( TString in1 = "./upgradeTP.root" , TString in2 = "./currentTP.root" ) {

  // User may change these variables to modify the behavior of the script
  // Not everything is printed out to screen..
  //---------------------------------------------------------------------------//
  const bool drawGraph  = true ; // Draw the graphs (must be on to save the graphs).
  const bool saveGraph1 = true ; // Save the graphs in a subdir with file extension defined below.
  const bool saveGraph2 = true ; // Save the graphs in a subdir with file extension defined below.
  const bool remZero    = true ; // Remove the xlow bin from graphs (i.e. the first bin) by setting it to zero.
  const bool logy       = true ; // Set y axis to log.
  const bool logx       = false; // Set x axis to log--not really used.
  const bool dobatch    = true ; // Set dummy TCanvas to batch mode.

  const int ngraph  =  3       ; // Number of plots to compare.
  const int nrebin  =  5       ; // Number of bins to merge--TH1::Rebin is used in the script. Set to 1 if not desired.
  const int verbose =  0       ; // Verbosity level for print statements: [0,1,2,3] 0->All,1->Info,2->Warning,3->Error

  string mod     = "_test"     ; // A string to modify file names of produced plots. This string must start with a '_' character if it is not null.
  string folder  = "./plots"   ; // Set which directory graphs are saved to. Note this dir must exist prior to running this script.
  string ifile   = ".png"      ; // Set file type (extension) of graphs for individual files.
  string gfile   = ".pdf"      ; // Set file type (extension) of graphs for a single continuous file.
  string gname   = "allPlots"  ; // Name of single continuous file

  string dumdum1 = "Upgrade"   ; // Legend entry
  string dumdum2 = "Current"   ; // Legend entry

  // Enter names of the plots within the root files. Also used as part of final string of file names.
  string names_1[ngraph] = {"tp_pt_emul","tp_pt_emul_hbhe","tp_pt_emul_hf"};
  string names_2[ngraph] = {"tp_pt_emul","tp_pt_emul_hbhe","tp_pt_emul_hf"};

  // In principle one can use arrays to help customize the plots to define titles, ranges, axis labels, etc.
  string names_titles[ngraph] = {"Upgrade vs Current TP - ALL HCAL","Upgrade vs Current TP - HBHE","Upgrade vs Current TP - HF"}; //titles

  //---------------------------------------------------------------------------//

  // Open the ROOT files containing the histograms.
  TFile myFile1(in1);
  TFile myFile2(in2);
  if ( myFile1.IsZombie() || myFile2.IsZombie() ) { if ( verbose <= 10 ) cout << "Files are zombies!" << endl; return; }

  // Get full name
  string outGname = gname + mod + gfile;

  // Set ROOT global error message level -- see TError.h
  if ( verbose == 0 ) gErrorIgnoreLevel =    0;
  if ( verbose == 1 ) gErrorIgnoreLevel = 1000;
  if ( verbose == 2 ) gErrorIgnoreLevel = 2000;
  if ( verbose == 3 ) gErrorIgnoreLevel = 3000;

  // Style options etc.
  gROOT->SetStyle("Plain");
  gStyle->SetOptStat(0);
  gStyle->SetPalette(1);

  if ( verbose <= 1 ) {
    cout << endl << "=============================================================" << endl;
    cout << endl << "Comparing TP histograms--Upgrade vs Current " << endl;
    cout << endl << "=============================================================" << endl;
    cout << endl << "User Settings: " << endl;
    cout << "-------------------------------------------------------------" << endl;
    printf( "Draw the plots                 : %s\n" , BOOL_STR(drawGraph)  );
    printf( "Save the plots (individual)    : %s\n" , BOOL_STR(saveGraph1) );
    printf( "Save the plots (continuous)    : %s\n" , BOOL_STR(saveGraph2) );
    printf( "Remove the zeroth bin          : %s\n" , BOOL_STR(remZero)    );
    printf( "Set x-axis to log scale        : %s\n" , BOOL_STR(logx)       );
    printf( "Set y-axis to log scale        : %s\n" , BOOL_STR(logy)       );
    printf( "Run script in batch mode       : %s\n" , BOOL_STR(dobatch)    );
    printf( "Number of plots to compare     : %i\n" , ngraph               );
    printf( "Number of bins to remerge      : %i\n" , nrebin               );
    printf( "Output print level             : %i\n" , verbose              );
    printf( "Save plots to folder           : %s\n" , folder.c_str()       );
    printf( "Save individual plots as       : %s\n" , ifile.c_str()        );
    printf( "Save continuous plots in       : %s\n" , outGname.c_str()     );
    cout << "-------------------------------------------------------------" << endl;
  }
  if ( verbose <= 2 ) cout << "Warning: Upgrade and Current TPs are assumed to be in " << in1 << " and " << in2 << " respectively. Switch order if needed." << endl;

  // Dummy variables
  TH1F * hist1;
  TH1F * hist2;
  TCanvas * dumc = 0;
  dumc = new TCanvas("dumc","",600,400);
  dumc->SetBatch(dobatch);

  // Compare everything
  for( int i = 0; i < ngraph; i++ ) {
    char  hist_name1[200], hist_name2[200];
    sprintf(hist_name1,"%s",names_1[i].c_str());
    sprintf(hist_name2,"%s",names_2[i].c_str());

    if ( verbose <= 1) cout << endl << "Now processing " << names_1[i] << " and " << names_2[i] << " ... "  << endl ;
    myFile1.cd("datacomp/");
    hist1 = (TH1F*) gDirectory->Get(hist_name1);
    myFile2.cd("datacomp/");
    hist2 = (TH1F*) gDirectory->Get(hist_name2);
    if ( hist1->IsZombie() && verbose <= 2 ) { cout << "There is something wrong with " << names_1[i] << "[1]. Please fix: skipping." << endl; continue; }
    if ( hist2->IsZombie() && verbose <= 2 ) { cout << "There is something wrong with " << names_2[i] << "[2]. Please fix: skipping." << endl; continue; }

    double xup1 = hist1->GetXaxis()->GetBinUpEdge(hist1->GetNbinsX()) ;
    double xup2 = hist2->GetXaxis()->GetBinUpEdge(hist2->GetNbinsX()) ;

    if ( xup1 != xup2 && verbose <= 2 ) { cout << "Warning: Graphs do not have the same bin structure!" << endl; }

    if ( drawGraph ) {
      if ( logy ) dumc->SetLogy(1);
      if ( logx ) dumc->SetLogx(1);
      if ( remZero ) { hist1->SetBinContent(1,0); hist2->SetBinContent(1,0); }
      hist1->SetLineColor(1);
      hist1->SetMarkerColor(1);
      hist1->SetMarkerStyle(1);
      hist2->SetLineColor(2);
      hist2->SetMarkerColor(2);
      hist2->SetMarkerStyle(1);
      if (nrebin!=1 && verbose<=1) cout << " FYI: Rebinning from " << xup1 / hist1->GetNbinsX() << " GeV steps to " << xup1 / hist1->GetNbinsX() * nrebin << " GeV." << endl;
      hist1->Rebin(nrebin);
      hist2->Rebin(nrebin);
      TLegend *duml = new TLegend(0.75, 0.81, 0.89, 0.89, "", "brNDC");
      duml->SetBorderSize(2);
      duml->SetFillStyle(2);
      duml->AddEntry(hist1, dumdum1.c_str(), "l");
      duml->AddEntry(hist2, dumdum2.c_str(), "l");
      char title[200];
      sprintf(title,"%s;Energy",names_titles[i].c_str());
      hist1->SetTitle(title);
      //hist1->SetMinimum(1e-3);
      //hist1->SetMaximum(1);
      hist1->Draw("hist1 ");
      hist2->Draw("hist1 same");
      duml->Draw();
      char dumlabel[200];
      if ( logy ) sprintf(dumlabel,"%s/%s_logY%s%s",folder.c_str(),hist_name1,mod.c_str(),ifile.c_str());
      else        sprintf(dumlabel,"%s/%s_linY%s%s",folder.c_str(),hist_name1,mod.c_str(),ifile.c_str());
      if ( saveGraph1 ) {
        dumc->SaveAs(dumlabel);
        if ( verbose <= 1 ) cout << "Saving this comparison in: " << dumlabel << endl;
      }
      if ( saveGraph2 ) {
        if ( i == 0 )               dumc->Print( (folder+"/"+outGname+"(").c_str() );
        else if ( (i+1) == ngraph ) dumc->Print( (folder+"/"+outGname+")").c_str() );
        else                        dumc->Print( (folder+"/"+outGname).c_str() );
        if ( verbose <= 1 ) cout << "Saving current plot to " << folder << "/" << outGname << endl;
      }
      dumc->Clear();
    }//drawGraph

  }//end for
  if ( verbose <= 1 ) cout << "=============================================================" << endl;

  myFile1.Close();
  myFile2.Close();
  dumc->Close();

  if ( verbose <= 1 ) cout << endl << " .. Done " << endl;
} // end of function


text:
package com.employment.presenter;

import android.app.Activity;
import android.app.DatePickerDialog;
import android.graphics.drawable.ColorDrawable;
import android.util.Log;
import android.view.Gravity;
import android.view.LayoutInflater;
import android.view.View;
import android.view.ViewGroup;
import android.view.WindowManager;
import android.widget.Button;
import android.widget.DatePicker;
import android.widget.EditText;
import android.widget.LinearLayout;
import android.widget.PopupWindow;
import android.widget.TextView;

import com.employment.R;
import com.employment.base.RxPresenter;
import com.employment.base.RxUtil;
import com.employment.db.RealmHelper;
import com.employment.http.RetrofitHelper;
import com.employment.http.bean.ResponseBean;
import com.employment.model.student.bean.Employment;
import com.employment.model.student.bean.StudentInfo;
import com.employment.model.student.bean.UnEmployment;
import com.employment.model.student.event.EmploymentEvent;
import com.employment.presenter.contract.PersonalContract;
import com.employment.utils.SystemUtils;

import java.util.Calendar;
import java.util.Date;
import java.util.HashMap;

import javax.inject.Inject;

import io.reactivex.annotations.NonNull;
import io.reactivex.disposables.Disposable;
import io.reactivex.functions.Consumer;

/**
 * Created by roy on 2017/4/9.
 */

public class PersonalPresenter extends RxPresenter<PersonalContract.View> implements PersonalContract.Presenter {

    private RetrofitHelper mRetrofitHelper;
    private RealmHelper realmHelper;
    private Activity mContext;
    private DatePickerDialog dialog;
    private PopupWindow popupWindow;

    @Inject
    public PersonalPresenter(Activity mContext, RetrofitHelper mRetrofitHelper, RealmHelper realmHelper) {
        this.mRetrofitHelper = mRetrofitHelper;
        this.realmHelper = realmHelper;
        this.mContext = mContext;
        registerEvent();
    }

    private void registerEvent() {
        addRxBusSubscribe(EmploymentEvent.class, new Consumer<EmploymentEvent>() {
            @Override
            public void accept(@NonNull EmploymentEvent employmentEvent) throws Exception {
                if (employmentEvent.getType().equals("0")) {
                    getStudentInfo();
                } else if (employmentEvent.getType().equals("1")) {
                    getEmployInfo();
                }
            }
        });
    }

    @Override
    public void getStudentInfo() {
        mView.showContent(realmHelper.getStudentInfoBean());
    }

    @Override
    public void getEmployInfo() {
        int state = realmHelper.getStudentInfoBean().getSstate();
        final HashMap<String, String> map = new HashMap<>();
        map.put("studentId", realmHelper.getStudentInfoBean().getSid() + "");
        map.put("state", state + "");
        Disposable disposable = null;
        if (state == 5) {
            disposable = mRetrofitHelper.getEmploymentInfo(map)
                    .compose(RxUtil.<Employment>rxSchedulerHelper())
                    .subscribe(new Consumer<Employment>() {
                                   @Override
                                   public void accept(@NonNull Employment employment) throws Exception {
                                       mView.showEmploymentInfo(employment);
                                   }
                               },
                            new Consumer<Throwable>() {
                                @Override
                                public void accept(@NonNull Throwable throwable) throws Exception {
                                    mView.showError(throwable.toString());
                                }
                            });
        } else if (state == 4) {
            disposable = mRetrofitHelper.getUnEmploymentInfo(map)
                    .compose(RxUtil.<UnEmployment>rxSchedulerHelper())
                    .subscribe(new Consumer<UnEmployment>() {
                                   @Override
                                   public void accept(@NonNull UnEmployment employment) throws Exception {
                                       mView.showUnEmploymentInfo(employment);
                                   }
                               },
                            new Consumer<Throwable>() {
                                @Override
                                public void accept(@NonNull Throwable throwable) throws Exception {
                                    mView.showError(throwable.toString());
                                }
                            });
        }
        addSubscribe(disposable);
    }

    @Override
    public void setBirthday(final Date date) {
        Calendar calendar = Calendar.getInstance();
        calendar.setTime(date);
        dialog = new DatePickerDialog(mContext, new DatePickerDialog.OnDateSetListener() {
            @Override
            public void onDateSet(DatePicker datePicker, int i, int i1, int i2) {
                Calendar instance = Calendar.getInstance();
                instance.set(i, i1, i2);
                Date newDate = instance.getTime();
                realmHelper.setBirthday(newDate);
                mView.showBirthday(SystemUtils.formatTime(newDate));
            }
        }, calendar.get(Calendar.YEAR), calendar.get(Calendar.MONTH), calendar.get(Calendar.DATE));
        dialog.show();
    }

    @Override
    public void setPhone(LinearLayout layout, final String phone) {
        View view = LayoutInflater.from(mContext).inflate(R.layout.popup_layout, null);
        final EditText content = (EditText) view.findViewById(R.id.input_text);
        TextView title = (TextView) view.findViewById(R.id.popup_title);
        Button cancel = (Button) view.findViewById(R.id.cancel);
        Button ok = (Button) view.findViewById(R.id.ok);
        popupWindow = new PopupWindow(view, ViewGroup.LayoutParams.WRAP_CONTENT, ViewGroup.LayoutParams.WRAP_CONTENT);
        cancel.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View view) {
                popupWindow.dismiss();
            }
        });
        ok.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View view) {
                String newPhone = content.getText().toString();
                if (!newPhone.equals(phone) && !newPhone.isEmpty()) {
                    mView.showNewPhone(newPhone);
                    realmHelper.setPhone(newPhone);
                    popupWindow.dismiss();
                }
            }
        });
        title.setText("更新电话号码");
        popupWindow.setBackgroundDrawable(new ColorDrawable(0X00ffffff));
        backgroundAlpha(0.5f);
        popupWindow.setOutsideTouchable(true);// 非popwindow区域可触摸
        popupWindow.setOnDismissListener(new PopDismissListener());
        popupWindow.setFocusable(true);//可获取焦点
        popupWindow.setTouchable(true);// 设置可触摸
        popupWindow.showAtLocation(layout, Gravity.CENTER, 0, 0);
    }

    @Override
    public void setEmail(LinearLayout layout, final String email) {
        View view = LayoutInflater.from(mContext).inflate(R.layout.popup_layout, null);
        final EditText textView = (EditText) view.findViewById(R.id.input_text);
        TextView title = (TextView) view.findViewById(R.id.popup_title);
        Button cancel = (Button) view.findViewById(R.id.cancel);
        Button ok = (Button) view.findViewById(R.id.ok);
        popupWindow = new PopupWindow(view, ViewGroup.LayoutParams.WRAP_CONTENT, ViewGroup.LayoutParams.WRAP_CONTENT);
        cancel.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View view) {
                popupWindow.dismiss();
            }
        });
        ok.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View view) {
                String newEmail = textView.getText().toString();
                if (!newEmail.equals(email) && !newEmail.isEmpty()) {
                    mView.showNewEmail(newEmail);
                    realmHelper.setEmail(newEmail);
                    popupWindow.dismiss();
                }
            }
        });
        title.setText("更新电子邮箱");
        popupWindow.setBackgroundDrawable(new ColorDrawable(0X00ffffff));
        backgroundAlpha(0.5f);
        popupWindow.setOutsideTouchable(true);// 非popwindow区域可触摸
        popupWindow.setOnDismissListener(new PopDismissListener());
        popupWindow.setFocusable(true);//可获取焦点
        popupWindow.setTouchable(true);// 设置可触摸
        popupWindow.showAtLocation(layout, Gravity.CENTER, 0, 0);
    }

    @Override
    public void commitStudentInfo() {
        HashMap<String, String> map = new HashMap<>();
        StudentInfo bean = realmHelper.getStudentInfoBean();
        map.put("studentId", bean.getSid() + "");
        map.put("sbirth", SystemUtils.formatTime(bean.getSbirth()));
        map.put("sphone", bean.getSphone() + "");
        map.put("semail", bean.getSemail() + "");
        map.put("sdetail", bean.getSdetail() + "");
        Disposable disposable = mRetrofitHelper.commitStudentInfo(map)
                .compose(RxUtil.<ResponseBean>rxSchedulerHelper())
                .subscribe(new Consumer<ResponseBean>() {
                    @Override
                    public void accept(@NonNull ResponseBean responseBean) throws Exception {
                        if (responseBean.getCode() == 200) {
                            Log.e("roy", "学生信息修改成功");
                            mView.studentInfoCommitSuccess();
                        }
                    }
                }, new Consumer<Throwable>() {
                    @Override
                    public void accept(@NonNull Throwable throwable) throws Exception {
                        Log.e("roy", "学生信息修改失败");
                    }
                });
        addSubscribe(disposable);
    }

    /**
     * 设置添加屏幕的背景透明度
     *
     * @param bgAlpha
     */
    public void backgroundAlpha(float bgAlpha) {
        WindowManager.LayoutParams lp = mContext.getWindow().getAttributes();
        lp.alpha = bgAlpha; //0.0-1.0
        mContext.getWindow().setAttributes(lp);
    }

    /**
     * 添加新笔记时弹出的popWin关闭的事件,主要是为了将背景透明度改回来
     */
    class PopDismissListener implements PopupWindow.OnDismissListener {

        @Override
        public void onDismiss() {
            backgroundAlpha(1f);
        }
    }

    @Override
    public void detachView() {
        super.detachView();
        if (dialog != null && dialog.isShowing()) {
            dialog.hide();
            dialog = null;
        }
        if (popupWindow != null && popupWindow.isShowing()) {
            popupWindow.dismiss();
            popupWindow = null;
        }
    }
}


text:
<!DOCTYPE html>

    <meta http-equiv="refresh" content="0;URL=../../openssl_sys/constant.NID_id_GostR3410_94.html">

Redirecting to ../../openssl_sys/constant.NID_id_GostR3410_94.html...


text:
Character::Character(int n, int x, int y, int w, int h){
     xposition = x;
     yposition = y;
     width = w;
     height = h;
     name = n;
     direction = 1;
}

int Character::getxposition(){
  return xposition;
}

bool Character::checkcolide(int x, int y, int w, int h) {
     if (x >= xposition  && y >= yposition &&
         x <= xposition + width &&
         y <= yposition  + height){
       return 1;}
     if (x + w >= xposition  && y >= yposition &&
         x + w <= xposition + width &&
         y <= yposition  + height){
       return 1;}
     if (x >= xposition  && y + h >= yposition &&
         x <= xposition + width &&
         y + h <= yposition  + height){
       return 1;}
     if (x + w >= xposition  && y + h >= yposition &&
         x + w <= xposition + width &&
         y + h <= yposition  + height){
       return 1;}
     else return 0;
}

void Character::draw(){
  drawTexture(name, xposition, yposition, width, height);
}


text:
#include <string>

#include "modsecurity/transaction.h"
#include "src/operators/operator.h"

#ifndef SRC_OPERATORS_NO_MATCH_H_
#define SRC_OPERATORS_NO_MATCH_H_

namespace modsecurity {
namespace operators {

class NoMatch : public Operator {
 public:
    /** @ingroup ModSecurity_Operator */
    NoMatch()
        : Operator("NoMatch") { }

    bool evaluate(Transaction *transaction, const std::string &str) override;
};

}  // namespace operators
}  // namespace modsecurity

#endif  // SRC_OPERATORS_NO_MATCH_H_


text:
package org.apache.beam.runners.dataflow.worker.util;

import java.util.ArrayList;
import java.util.List;
import org.apache.beam.runners.core.InMemoryTimerInternals;
import org.apache.beam.runners.core.NullSideInputReader;
import org.apache.beam.runners.core.OutputWindowedValue;
import org.apache.beam.runners.core.ReduceFnRunner;
import org.apache.beam.runners.core.SideInputReader;
import org.apache.beam.runners.core.StateInternals;
import org.apache.beam.runners.core.StateInternalsFactory;
import org.apache.beam.runners.core.StepContext;
import org.apache.beam.runners.core.SystemReduceFn;
import org.apache.beam.runners.core.TimerInternals.TimerData;
import org.apache.beam.runners.core.construction.TriggerTranslation;
import org.apache.beam.runners.core.triggers.ExecutableTriggerStateMachine;
import org.apache.beam.runners.core.triggers.TriggerStateMachines;
import org.apache.beam.sdk.options.PipelineOptions;
import org.apache.beam.sdk.transforms.windowing.BoundedWindow;
import org.apache.beam.sdk.util.WindowedValue;
import org.apache.beam.sdk.values.KV;
import org.apache.beam.sdk.values.WindowingStrategy;
import org.joda.time.Instant;

/**
 * The default batch {@link BatchGroupAlsoByWindowFn} implementation, if no specialized "fast path"
 * implementation is applicable.
 */
public class BatchGroupAlsoByWindowViaOutputBufferFn<K, InputT, OutputT, W extends BoundedWindow>
    extends BatchGroupAlsoByWindowFn<K, InputT, OutputT> {

  private final WindowingStrategy<?, W> strategy;
  private final StateInternalsFactory<K> stateInternalsFactory;
  private SystemReduceFn<K, InputT, ?, OutputT, W> reduceFn;

  public BatchGroupAlsoByWindowViaOutputBufferFn(
      WindowingStrategy<?, W> windowingStrategy,
      StateInternalsFactory<K> stateInternalsFactory,
      SystemReduceFn<K, InputT, ?, OutputT, W> reduceFn) {
    this.strategy = windowingStrategy;
    this.reduceFn = reduceFn;
    this.stateInternalsFactory = stateInternalsFactory;
  }

  @Override
  public void processElement(
      KV<K, Iterable<WindowedValue<InputT>>> element,
      PipelineOptions options,
      StepContext stepContext,
      SideInputReader sideInputReader,
      OutputWindowedValue<KV<K, OutputT>> output)
      throws Exception {
    K key = element.getKey();
    // Used with Batch, we know that all the data is available for this key. We can't use the
    // timer manager from the context because it doesn't exist. So we create one and emulate the
    // watermark, knowing that we have all data and it is in timestamp order.
    InMemoryTimerInternals timerInternals = new InMemoryTimerInternals();
    timerInternals.advanceProcessingTime(Instant.now());
    timerInternals.advanceSynchronizedProcessingTime(Instant.now());
    StateInternals stateInternals = stateInternalsFactory.stateInternalsForKey(key);

    ReduceFnRunner<K, InputT, OutputT, W> reduceFnRunner =
        new ReduceFnRunner<>(
            key,
            strategy,
            ExecutableTriggerStateMachine.create(
                TriggerStateMachines.stateMachineForTrigger(
                    TriggerTranslation.toProto(strategy.getTrigger()))),
            stateInternals,
            timerInternals,
            output,
            NullSideInputReader.empty(),
            reduceFn,
            options);

    // Process the elements.
    reduceFnRunner.processElements(element.getValue());

    // Finish any pending windows by advancing the input watermark to infinity.
    timerInternals.advanceInputWatermark(BoundedWindow.TIMESTAMP_MAX_VALUE);

    // Finally, advance the processing time to infinity to fire any timers.
    timerInternals.advanceProcessingTime(BoundedWindow.TIMESTAMP_MAX_VALUE);
    timerInternals.advanceSynchronizedProcessingTime(BoundedWindow.TIMESTAMP_MAX_VALUE);

    fireEligibleTimers(timerInternals, reduceFnRunner);

    reduceFnRunner.persist();
  }

  private void fireEligibleTimers(
      InMemoryTimerInternals timerInternals, ReduceFnRunner<K, InputT, OutputT, W> reduceFnRunner)
      throws Exception {
    List<TimerData> timers = new ArrayList<>();
    while (true) {
      TimerData timer;
      while ((timer = timerInternals.removeNextEventTimer()) != null) {
        timers.add(timer);
      }
      while ((timer = timerInternals.removeNextProcessingTimer()) != null) {
        timers.add(timer);
      }
      while ((timer = timerInternals.removeNextSynchronizedProcessingTimer()) != null) {
        timers.add(timer);
      }
      if (timers.isEmpty()) {
        break;
      }
      reduceFnRunner.onTimers(timers);
      timers.clear();
    }
  }
}


text:
package models

// This file was generated by the swagger tool.
// Editing this file might prove futile when you re-run the swagger generate command

import (
	strfmt "github.com/go-openapi/strfmt"

	"github.com/go-openapi/errors"
	"github.com/go-openapi/swag"
)

// OpenpitrixStopClustersResponse openpitrix stop clusters response
// swagger:model openpitrixStopClustersResponse
type OpenpitrixStopClustersResponse struct {

	// ids of clusters stopped
	ClusterID []string `json:"cluster_id"`

	// job ids
	JobID []string `json:"job_id"`
}

// Validate validates this openpitrix stop clusters response
func (m *OpenpitrixStopClustersResponse) Validate(formats strfmt.Registry) error {
	var res []error

	if err := m.validateClusterID(formats); err != nil {
		// prop
		res = append(res, err)
	}

	if err := m.validateJobID(formats); err != nil {
		// prop
		res = append(res, err)
	}

	if len(res) > 0 {
		return errors.CompositeValidationError(res...)
	}
	return nil
}

func (m *OpenpitrixStopClustersResponse) validateClusterID(formats strfmt.Registry) error {

	if swag.IsZero(m.ClusterID) { // not required
		return nil
	}

	return nil
}

func (m *OpenpitrixStopClustersResponse) validateJobID(formats strfmt.Registry) error {

	if swag.IsZero(m.JobID) { // not required
		return nil
	}

	return nil
}

// MarshalBinary interface implementation
func (m *OpenpitrixStopClustersResponse) MarshalBinary() ([]byte, error) {
	if m == nil {
		return nil, nil
	}
	return swag.WriteJSON(m)
}

// UnmarshalBinary interface implementation
func (m *OpenpitrixStopClustersResponse) UnmarshalBinary(b []byte) error {
	var res OpenpitrixStopClustersResponse
	if err := swag.ReadJSON(b, &res); err != nil {
		return err
	}
	*m = res
	return nil
}


text:
.class Landroid/widget/RemoteViews$SetOnClickFillInIntent$1;
.super Ljava/lang/Object;
.source "RemoteViews.java"

# interfaces
.implements Landroid/view/View$OnClickListener;

# annotations
.annotation system Ldalvik/annotation/EnclosingMethod;
    value = Landroid/widget/RemoteViews$SetOnClickFillInIntent;->apply(Landroid/view/View;Landroid/view/ViewGroup;)V
.end annotation

.annotation system Ldalvik/annotation/InnerClass;
    accessFlags = 0x0
    name = null
.end annotation

# instance fields
.field final synthetic this$1:Landroid/widget/RemoteViews$SetOnClickFillInIntent;

# direct methods
.method constructor <init>(Landroid/widget/RemoteViews$SetOnClickFillInIntent;)V
    .locals 0
    .parameter

    .prologue
    .line 229
    iput-object p1, p0, Landroid/widget/RemoteViews$SetOnClickFillInIntent$1;->this$1:Landroid/widget/RemoteViews$SetOnClickFillInIntent;

    invoke-direct/range {p0 .. p0}, Ljava/lang/Object;-><init>()V

    return-void
.end method

# virtual methods
.method public onClick(Landroid/view/View;)V
    .locals 9
    .parameter "v"

    .prologue
    const/4 v8, 0x1

    const/4 v6, 0x0

    const/high16 v7, 0x3f00

    .line 232
    invoke-virtual {p1}, Landroid/view/View;->getParent()Landroid/view/ViewParent;

    move-result-object v1

    check-cast v1, Landroid/view/View;

    .line 234
    .local v1, parent:Landroid/view/View;
    :goto_0
    instance-of v5, v1, Landroid/widget/AdapterView;

    if-nez v5, :cond_0

    instance-of v5, v1, Landroid/appwidget/AppWidgetHostView;

    if-nez v5, :cond_0

    .line 235
    invoke-virtual {v1}, Landroid/view/View;->getParent()Landroid/view/ViewParent;

    move-result-object v1

    .end local v1           #parent:Landroid/view/View;
    check-cast v1, Landroid/view/View;

    .restart local v1       #parent:Landroid/view/View;
    goto :goto_0

    .line 238
    :cond_0
    instance-of v5, v1, Landroid/appwidget/AppWidgetHostView;

    if-eqz v5, :cond_1

    .line 241
    const-string v5, "RemoteViews"

    const-string v6, "Collection item doesn\'t have AdapterView parent"

    invoke-static {v5, v6}, Landroid/util/Log;->e(Ljava/lang/String;Ljava/lang/String;)I

    .line 267
    :goto_1
    return-void

    .line 246
    :cond_1
    invoke-virtual {v1}, Landroid/view/View;->getTag()Ljava/lang/Object;

    move-result-object v5

    instance-of v5, v5, Landroid/app/PendingIntent;

    if-nez v5, :cond_2

    .line 247
    const-string v5, "RemoteViews"

    const-string v6, "Attempting setOnClickFillInIntent without calling setPendingIntentTemplate on parent."

    invoke-static {v5, v6}, Landroid/util/Log;->e(Ljava/lang/String;Ljava/lang/String;)I

    goto :goto_1

    .line 252
    :cond_2
    invoke-virtual {v1}, Landroid/view/View;->getTag()Ljava/lang/Object;

    move-result-object v2

    check-cast v2, Landroid/app/PendingIntent;

    .line 254
    .local v2, pendingIntent:Landroid/app/PendingIntent;
    invoke-virtual {p1}, Landroid/view/View;->getContext()Landroid/content/Context;

    move-result-object v5

    invoke-virtual {v5}, Landroid/content/Context;->getResources()Landroid/content/res/Resources;

    move-result-object v5

    invoke-virtual {v5}, Landroid/content/res/Resources;->getCompatibilityInfo()Landroid/content/res/CompatibilityInfo;

    move-result-object v5

    iget v0, v5, Landroid/content/res/CompatibilityInfo;->applicationScale:F

    .line 256
    .local v0, appScale:F
    const/4 v5, 0x2

    new-array v3, v5, [I

    .line 257
    .local v3, pos:[I
    invoke-virtual {p1, v3}, Landroid/view/View;->getLocationOnScreen([I)V

    .line 259
    new-instance v4, Landroid/graphics/Rect;

    invoke-direct {v4}, Landroid/graphics/Rect;-><init>()V

    .line 260
    .local v4, rect:Landroid/graphics/Rect;
    aget v5, v3, v6

    int-to-float v5, v5

    mul-float/2addr v5, v0

    add-float/2addr v5, v7

    float-to-int v5, v5

    iput v5, v4, Landroid/graphics/Rect;->left:I

    .line 261
    aget v5, v3, v8

    int-to-float v5, v5

    mul-float/2addr v5, v0

    add-float/2addr v5, v7

    float-to-int v5, v5

    iput v5, v4, Landroid/graphics/Rect;->top:I

    .line 262
    aget v5, v3, v6

    invoke-virtual {p1}, Landroid/view/View;->getWidth()I

    move-result v6

    add-int/2addr v5, v6

    int-to-float v5, v5

    mul-float/2addr v5, v0

    add-float/2addr v5, v7

    float-to-int v5, v5

    iput v5, v4, Landroid/graphics/Rect;->right:I

    .line 263
    aget v5, v3, v8

    invoke-virtual {p1}, Landroid/view/View;->getHeight()I

    move-result v6

    add-int/2addr v5, v6

    int-to-float v5, v5

    mul-float/2addr v5, v0

    add-float/2addr v5, v7

    float-to-int v5, v5

    iput v5, v4, Landroid/graphics/Rect;->bottom:I

    .line 265
    iget-object v5, p0, Landroid/widget/RemoteViews$SetOnClickFillInIntent$1;->this$1:Landroid/widget/RemoteViews$SetOnClickFillInIntent;

    iget-object v5, v5, Landroid/widget/RemoteViews$SetOnClickFillInIntent;->fillInIntent:Landroid/content/Intent;

    invoke-virtual {v5, v4}, Landroid/content/Intent;->setSourceBounds(Landroid/graphics/Rect;)V

    .line 266
    iget-object v5, p0, Landroid/widget/RemoteViews$SetOnClickFillInIntent$1;->this$1:Landroid/widget/RemoteViews$SetOnClickFillInIntent;

    invoke-virtual {p1}, Landroid/view/View;->getContext()Landroid/content/Context;

    move-result-object v6

    iget-object v7, p0, Landroid/widget/RemoteViews$SetOnClickFillInIntent$1;->this$1:Landroid/widget/RemoteViews$SetOnClickFillInIntent;

    iget-object v7, v7, Landroid/widget/RemoteViews$SetOnClickFillInIntent;->fillInIntent:Landroid/content/Intent;

    invoke-virtual {v5, v6, v2, v7}, Landroid/widget/RemoteViews$SetOnClickFillInIntent;->startIntentSafely(Landroid/content/Context;Landroid/app/PendingIntent;Landroid/content/Intent;)Z

    goto :goto_1
.end method


text:
import { exportProgressReducer } from './exportprogress';
import {
  exportCancelled,
  exportProgress,
  exportError,
  exportComplete,
  exportReset,
} from '../actions';
import {
  NOT_STARTED,
  IN_PROGRESS,
  COMPLETE_ERROR,
  COMPLETE_SUCCESS,
} from '../helpers/exportProgressStates';

describe('exportProgressReducer', () => {
  it('should initialize to a state of not started', () => {
    expect(exportProgressReducer(undefined, {})).toMatchSnapshot();
  });
  it('should reset when the export is cancelled', () => {
    expect(exportProgressReducer(undefined, exportCancelled())).toMatchSnapshot();
  });
  it('should reflect current status when there is progress', () => {
    expect(exportProgressReducer(undefined, exportProgress('working...'))).toMatchSnapshot();
  });
  it('should support an error state', () => {
    expect(exportProgressReducer(undefined, exportError('something went wrong'))).toMatchSnapshot();
  });
  it('should support complete state with path', () => {
    expect(exportProgressReducer(undefined, exportComplete('/dev/null'))).toMatchSnapshot();
  });
  it('should properly reset when needed', () => {
    const beginningState = {
      status: 'working...',
      state: IN_PROGRESS,
      exportedPath: null,
    };
    const expected = exportProgressReducer(undefined, {});
    expect(exportProgressReducer(beginningState, exportReset())).toEqual(expected);
  });
});


text:
namespace LinkedList.Tests
{
    using System;
    using LinkedList.Common;
    using Microsoft.VisualStudio.TestTools.UnitTesting;

    [TestClass]
    public class IndexOfOperationTests
    {
        [TestMethod]
        public void IndexOfElementInEmptyListTest()
        {
            LinkedList<int> list = new LinkedList<int>();

            int index = list.IndexOf(0);

            Assert.AreEqual(-1, index);
        }

        [TestMethod]
        public void IndexOfFirstAndOnlyElementTest()
        {
            LinkedList<int> list = new LinkedList<int>();
            list.Add(0);

            int index = list.IndexOf(0);

            Assert.AreEqual(0, index);
        }

        [TestMethod]
        public void IndexOfFirstElementOfMultipleTest()
        {
            LinkedList<int> list = new LinkedList<int>();
            list.Add(0);
            list.Add(15);
            list.Add(1);

            int index = list.IndexOf(0);

            Assert.AreEqual(0, index);
        }

        [TestMethod]
        public void IndexOfElementFromDuplicatesTest()
        {
            LinkedList<int> list = new LinkedList<int>();
            list.Add(15);
            list.Add(1);
            list.Add(0);
            list.Add(0);
            list.Add(1);
            list.Add(0);
            list.Add(144);

            int index = list.IndexOf(0);

            Assert.AreEqual(2, index);
        }

        [TestMethod]
        public void IndexOfLastElementOfMultipleTest()
        {
            LinkedList<int> list = new LinkedList<int>();
            list.Add(15);
            list.Add(1);
            list.Add(0);
            list.Add(0);
            list.Add(1);
            list.Add(0);
            list.Add(144);

            int index = list.IndexOf(144);

            Assert.AreEqual(6, index);
        }
    }
}


text:
var Soundcloud = require('./soundcloud-client.js');

module.exports = function (client_id) {
    return new Soundcloud(client_id);
};


text:
using BTDB.ODBLayer;
using System.Collections.Generic;
using System.Linq;
using Xunit;
using Xunit.Abstractions;

namespace BTDBTest
{
    public class MultipleEnumerationTest : ObjectDbTestBase
    {
        public MultipleEnumerationTest(ITestOutputHelper output) : base(output)
        {
        }

        public class Application
        {
            [PrimaryKey(1)]
            public ulong CompanyId { get; set; }
            [PrimaryKey(2)]
            public ulong ApplicationId { get; set; }
        }

        public interface IApplicationTable : IRelation<Application>
        {
            IEnumerable<Application> ListById(AdvancedEnumeratorParam<ulong> param);
            IEnumerable<Application> FindById(ulong companyId);
        }

        [Fact]
        public void CanEnumerateAdvancedEnumeratorMultipleTimes()
        {
            using var tr = _db.StartTransaction();
            var creator = tr.InitRelation<IApplicationTable>("ApplicationTable");
            var table = creator(tr);
            var application1 = new Application { CompanyId = 1, ApplicationId = 100 };
            var application2 = new Application { CompanyId = 1, ApplicationId = 101 };
            var application3 = new Application { CompanyId = 2, ApplicationId = 102 };

            table.Upsert(application2);
            table.Upsert(application1);
            table.Upsert(application3);

            var en = table.ListById(new AdvancedEnumeratorParam<ulong>(EnumerationOrder.Ascending,
                1, KeyProposition.Included, 2, KeyProposition.Included));

            Assert.Equal(3, en.Count());
            Assert.Equal(3, en.Count());
            Assert.Equal(en.Select(a => a.ApplicationId), new ulong[] { 100, 101, 102 });

            tr.Commit();
        }

        [Fact]
        public void CanEnumerateEnumeratorMultipleTimes()
        {
            using var tr = _db.StartTransaction();
            var creator = tr.InitRelation<IApplicationTable>("ApplicationTable");
            var table = creator(tr);
            table.Upsert(new Application { CompanyId = 1, ApplicationId = 100 });
            table.Upsert(new Application { CompanyId = 1, ApplicationId = 101 });
            table.Upsert(new Application { CompanyId = 2, ApplicationId = 102 });

            var en = table.FindById(1);

            Assert.Equal(2, en.Count());
            Assert.Equal(2, en.Count());
            Assert.Equal(en.Select(a => a.ApplicationId), new ulong[] { 100, 101 });
            tr.Commit();
        }

        [Fact]
        public void CanEnumerateRelationAdvancedEnumeratorAfterMoveNext()
        {
            using var tr = _db.StartTransaction();
            var creator = tr.InitRelation<IApplicationTable>("ApplicationTable");
            var table = creator(tr);

            table.Upsert(new Application { CompanyId = 1, ApplicationId = 101 });
            table.Upsert(new Application { CompanyId = 1, ApplicationId = 100 });
            table.Upsert(new Application { CompanyId = 2, ApplicationId = 102 });

            var result = table.ListById(new AdvancedEnumeratorParam<ulong>(EnumerationOrder.Ascending,
                1, KeyProposition.Included, 2, KeyProposition.Included));

            var resultEnumerator = result.GetEnumerator();
            Assert.True(resultEnumerator.MoveNext());

            var val1 = resultEnumerator.Current;
            Assert.Equal(100U, val1.ApplicationId);

            var values = result.ToList();
            Assert.Equal(3, values.Count());

            tr.Commit();
        }
    }
}


text:
package org.arquillian.smart.testing.report.model;

import javax.xml.bind.annotation.XmlElement;
import javax.xml.bind.annotation.XmlRootElement;
import javax.xml.bind.annotation.XmlType;

@XmlRootElement(name = "smart-testing-execution")
@XmlType(propOrder = {"module", "executionConfiguration", "selection"})
public class SmartTestingExecution {

    private String module;
    private ExecutionConfiguration executionConfiguration;
    private Selection selection;

    public SmartTestingExecution() {
    }

    private SmartTestingExecution(SmartTestingExecution.Builder builder) {
        this.module = builder.module;
        this.executionConfiguration = builder.executionConfiguration;
        this.selection = builder.selection;
    }

    @XmlElement
    public Selection getSelection() {
        return selection;
    }

    @XmlElement
    public ExecutionConfiguration getExecutionConfiguration() {
        return executionConfiguration;
    }

    @XmlElement
    public String getModule() {
        return module;
    }

    public static SmartTestingExecution.Builder builder() {
        return new Builder();
    }

    public static class Builder {
        private String module;
        private ExecutionConfiguration executionConfiguration;
        private Selection selection;

        public Builder() {
        }

        public Builder withModule(String name) {
            this.module = name;
            return this;
        }

        public ExecutionConfiguration.Builder addConfiguration() {
            return new ExecutionConfiguration.Builder(this);
        }

        public Builder setExecutionConfiguration(ExecutionConfiguration.Builder builder) {
            executionConfiguration = new ExecutionConfiguration(builder);
            return this;
        }

        public Builder setSelection(Selection.Builder builder) {
            this.selection = new Selection(builder);
            return this;
        }

        public Selection.Builder addSelection() {
            return new Selection.Builder(this);
        }

        public SmartTestingExecution build() {
            return new SmartTestingExecution(this);
        }
    }
}


text:
/**
 * Created on 16-okt-06
 * @author Tim Vermeiren
 */
package org.aikodi.chameleon.eclipse.presentation.hyperlink;

import org.aikodi.chameleon.core.element.Element;
import org.aikodi.chameleon.core.reference.CrossReference;
import org.aikodi.chameleon.eclipse.connector.EclipseEditorTag;
import org.aikodi.chameleon.eclipse.editors.EclipseDocument;
import org.eclipse.jface.text.IRegion;
import org.eclipse.jface.text.ITextViewer;
import org.eclipse.jface.text.Region;
import org.eclipse.jface.text.hyperlink.IHyperlink;
import org.eclipse.jface.text.hyperlink.IHyperlinkDetector;

/**
 * This class will check for Hyperlinks in the ChameleonEditor.
 *
 * @author Tim Vermeiren
 *
 */
public class ChameleonHyperlinkDetector implements IHyperlinkDetector {

	/**
	 * Returns the ChameleonHyperlinks detected in the specified region.
	 * Returns null if no hyperlinks found.
	 *
	 * @param	textViewer
	 * 			The textviewer wherein the hyperlinks are being searched
	 * @param 	region
	 * 			The region covered by the mousepointer. Normally the length of region is 0,
	 * 			only if a selection is covered this will be longer.
	 */
	@Override
   public IHyperlink[] detectHyperlinks(ITextViewer textViewer, IRegion region, boolean canShowMultipleHyperlinks) {
		// Get the ChameleonDocument:
		EclipseDocument document;
		try {
			document = (EclipseDocument) textViewer.getDocument();
		} catch (ClassCastException e) {
			e.printStackTrace();
			return null;
		}
		// print out the word covered by the mousepointer while holding CTRL:
		// System.out.println("Mouse-over word: " + document.findWord(region.getOffset()) ); // debugging
		// get the editorTag:
		EclipseEditorTag editorTag = document.getReferenceEditorTagAtRegion(region);
		if(editorTag == null) {
			return null;
		} else {
//			System.out.println("Found cross-reference taf at offset: "+editorTag.getOffset() +" length: "+editorTag.getLength());
			// get the element:
			Element element = editorTag.element();
			if (element instanceof CrossReference) {
				IRegion refRegion = new Region(editorTag.getOffset(), editorTag.getLength());
				ChameleonHyperlink hyperlink = new ChameleonHyperlink((CrossReference) element, refRegion, document);
				return new IHyperlink[] { hyperlink };
			} else {
				return null;
			}
		}
	}
}


text:
#if !defined(_STOREHANDLER_HPP_INCLUDED)
#define _STOREHANDLER_HPP_INCLUDED

#include "imaphandler.hpp"

ImapHandler *storeHandler(ImapSession *, INPUT_DATA_STRUCT &input);
ImapHandler *uidStoreHandler(ImapSession *, INPUT_DATA_STRUCT &input);

class StoreHandler : public ImapHandler {
private:
    ParseBuffer *m_parseBuffer;
    bool m_usingUid;

public:
    StoreHandler(ImapSession *session, ParseBuffer *parseBuffer, bool usingUid)  : ImapHandler(session), m_parseBuffer(parseBuffer), m_usingUid(usingUid)  {}
    virtual ~StoreHandler() {}
    virtual IMAP_RESULTS receiveData(INPUT_DATA_STRUCT &input);
};

#endif // !defined(_STOREHANDLER_HPP_INCLUDED)