text:
/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
/* ***** BEGIN LICENSE BLOCK *****
 * Version: MPL 1.1/GPL 2.0/LGPL 2.1
 *
 * The contents of this file are subject to the Mozilla Public License Version
 * 1.1 (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.mozilla.org/MPL/
 *
 * Software distributed under the License is distributed on an "AS IS" basis,
 * WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License
 * for the specific language governing rights and limitations under the
 * License.
 *
 * The Original Code is the Netscape Portable Runtime (NSPR).
 *
 * The Initial Developer of the Original Code is
 * Netscape Communications Corporation.
 * Portions created by the Initial Developer are Copyright (C) 1998-2000
 * the Initial Developer. All Rights Reserved.
 *
 * Contributor(s):
 *
 * Alternatively, the contents of this file may be used under the terms of
 * either the GNU General Public License Version 2 or later (the "GPL"), or
 * the GNU Lesser General Public License Version 2.1 or later (the "LGPL"),
 * in which case the provisions of the GPL or the LGPL are applicable instead
 * of those above. If you wish to allow use of your version of this file only
 * under the terms of either the GPL or the LGPL, and not to allow others to
 * use your version of this file under the terms of the MPL, indicate your
 * decision by deleting the provisions above and replace them with the notice
 * and other provisions required by the GPL or the LGPL. If you do not delete
 * the provisions above, a recipient may use your version of this file under
 * the terms of any one of the MPL, the GPL or the LGPL.
 *
 * ***** END LICENSE BLOCK ***** */

#include "prlog.h"
#include "prthread.h"
#include "private/pprthred.h"
#include "primpl.h"

PR_IMPLEMENT(PRWord *)
PR_GetGCRegisters(PRThread *t, int isCurrent, int *np)
{
    return _MD_HomeGCRegisters(t, isCurrent, np);
}

PR_IMPLEMENT(PRStatus)
PR_ThreadScanStackPointers(PRThread* t,
                           PRScanStackFun scanFun, void* scanClosure)
{
    PRThread* current = PR_GetCurrentThread();
    PRWord *sp, *esp, *p0;
    int n;
    void **ptd;
    PRStatus status;
    PRUint32 index;
    int stack_end;

    /*
    ** Store the thread's registers in the thread structure so the GC
    ** can scan them. Then scan them.
    */
    p0 = _MD_HomeGCRegisters(t, t == current, &n);
    status = scanFun(t, (void**)p0, n, scanClosure);
    if (status != PR_SUCCESS)
        return status;

    /* Scan the C stack for pointers into the GC heap */
#if defined(XP_PC) && defined(WIN16)
    /*
    ** Under WIN16, the stack of the current thread is always mapped into
    ** the "task stack" (at SS:xxxx).  So, if t is the current thread, scan
    ** the "task stack".  Otherwise, scan the "cached stack" of the inactive
    ** thread...
    */
    if (t == current) {
        sp  = (PRWord*) &stack_end;
        esp = (PRWord*) _pr_top_of_task_stack;

        PR_ASSERT(sp <= esp);
    } else {
        sp  = (PRWord*) PR_GetSP(t);
        esp = (PRWord*) t->stack->stackTop;

        PR_ASSERT((t->stack->stackSize == 0) ||
                  ((sp >  (PRWord*)t->stack->stackBottom) &&
                   (sp <= (PRWord*)t->stack->stackTop)));
    }
#else   /* ! WIN16 */
#ifdef HAVE_STACK_GROWING_UP
    if (t == current) {
        esp = (PRWord*) &stack_end;
    } else {
        esp = (PRWord*) PR_GetSP(t);
    }
    sp = (PRWord*) t->stack->stackTop;
    if (t->stack->stackSize) {
        PR_ASSERT((esp > (PRWord*)t->stack->stackTop) &&
                  (esp < (PRWord*)t->stack->stackBottom));
    }
#else   /* ! HAVE_STACK_GROWING_UP */
    if (t == current) {
        sp = (PRWord*) &stack_end;
    } else {
        sp = (PRWord*) PR_GetSP(t);
    }
    esp = (PRWord*) t->stack->stackTop;
    if (t->stack->stackSize) {
        PR_ASSERT((sp > (PRWord*)t->stack->stackBottom) &&
                  (sp < (PRWord*)t->stack->stackTop));
    }
#endif  /* ! HAVE_STACK_GROWING_UP */
#endif  /* ! WIN16 */

#if defined(WIN16)
    {
        prword_t scan;
        prword_t limit;

        scan = (prword_t) sp;
        limit = (prword_t) esp;
        while (scan < limit) {
            prword_t *test;

            test = *((prword_t **)scan);
            status = scanFun(t, (void**)&test, 1, scanClosure);
            if (status != PR_SUCCESS)
                return status;
            scan += sizeof(char);
        }
    }
#else
    if (sp < esp) {
        status = scanFun(t, (void**)sp, esp - sp, scanClosure);
        if (status != PR_SUCCESS)
            return status;
    }
#endif

    /*
    ** Mark all of the per-thread-data items attached to this thread
    **
    ** The execution environment better be accounted for otherwise it
    ** will be collected
    */
    status = scanFun(t, (void**)&t->environment, 1, scanClosure);
    if (status != PR_SUCCESS)
        return status;

    /* if thread is not allocated on stack, this is redundant. */
    ptd = t->privateData;
    for (index = 0; index < t->tpdLength; index++, ptd++) {
        status = scanFun(t, (void**)ptd, 1, scanClosure);
        if (status != PR_SUCCESS)
            return status;
    }

    return PR_SUCCESS;
}

/* transducer for PR_EnumerateThreads */
typedef struct PRScanStackData {
    PRScanStackFun      scanFun;
    void*               scanClosure;
} PRScanStackData;

static PRStatus PR_CALLBACK
pr_ScanStack(PRThread* t, int i, void* arg)
{
    PRScanStackData* data = (PRScanStackData*)arg;
    return PR_ThreadScanStackPointers(t, data->scanFun, data->scanClosure);
}

PR_IMPLEMENT(PRStatus)
PR_ScanStackPointers(PRScanStackFun scanFun, void* scanClosure)
{
    PRScanStackData data;
    data.scanFun = scanFun;
    data.scanClosure = scanClosure;
    return PR_EnumerateThreads(pr_ScanStack, &data);
}

PR_IMPLEMENT(PRUword)
PR_GetStackSpaceLeft(PRThread* t)
{
    PRThread *current = PR_GetCurrentThread();
    PRWord *sp, *esp;
    int stack_end;

#if defined(WIN16)
    /*
    ** Under WIN16, the stack of the current thread is always mapped into
    ** the "task stack" (at SS:xxxx).  So, if t is the current thread, scan
    ** the "task stack".  Otherwise, scan the "cached stack" of the inactive
    ** thread...
    */
    if (t == current) {
        sp  = (PRWord*) &stack_end;
        esp = (PRWord*) _pr_top_of_task_stack;

        PR_ASSERT(sp <= esp);
    } else {
        sp  = (PRWord*) PR_GetSP(t);
        esp = (PRWord*) t->stack->stackTop;

	PR_ASSERT((t->stack->stackSize == 0) ||
                 ((sp >  (PRWord*)t->stack->stackBottom) &&
		  (sp <= (PRWord*)t->stack->stackTop)));
    }
#else   /* ! WIN16 */
#ifdef HAVE_STACK_GROWING_UP
    if (t == current) {
        esp = (PRWord*) &stack_end;
    } else {
        esp = (PRWord*) PR_GetSP(t);
    }
    sp = (PRWord*) t->stack->stackTop;
    if (t->stack->stackSize) {
        PR_ASSERT((esp > (PRWord*)t->stack->stackTop) &&
                  (esp < (PRWord*)t->stack->stackBottom));
    }
#else   /* ! HAVE_STACK_GROWING_UP */
    if (t == current) {
        sp = (PRWord*) &stack_end;
    } else {
        sp = (PRWord*) PR_GetSP(t);
    }
    esp = (PRWord*) t->stack->stackTop;
    if (t->stack->stackSize) {
	PR_ASSERT((sp > (PRWord*)t->stack->stackBottom) &&
		  (sp < (PRWord*)t->stack->stackTop));
    }
#endif  /* ! HAVE_STACK_GROWING_UP */
#endif  /* ! WIN16 */
    return (PRUword)t->stack->stackSize - ((PRWord)esp - (PRWord)sp);
}


text:
<?php

/*
 * php compressor.php [overwrite]
 */

/*
 * Reads a file as a string, compresses it and outputs the result.
 */

$currentDirectoryName = 'FilesToCompress';

$compressor = new Compressor();
$compressor->scanRecursively($currentDirectoryName, $argv);

class Compressor {

    public function scanRecursively($currentDirectoryName, $argv = []) {

        $result = scandir($currentDirectoryName);
        $noDotsArray = array_slice($result, 2);
        if (in_array(".DS_Store", $noDotsArray)) {
            unset($noDotsArray[0]);
        }

        foreach ($noDotsArray as $individualLine) {

            if (is_dir($currentDirectoryName . '/' . $individualLine) == true) {
                $readableDirectory = $this->amendDirectoryName($currentDirectoryName, $individualLine);
                $this->scanRecursively($readableDirectory, $argv);
            } else {
                if (!array_key_exists(1, $argv)) {
                    $this->readFile($individualLine, $currentDirectoryName);
                } else {
                    $this->readFile($individualLine, $currentDirectoryName, $argv[1]);
                }
            }
        }
    }

    public function amendDirectoryName ($currentDirectoryName, $directoryAddition) {
        $newDirectoryName = $currentDirectoryName . '/' . $directoryAddition;
        return $newDirectoryName;
    }

    public function scanDirectory ($directoryName) {
        $directoryContents = scandir($directoryName);
        return $directoryContents;
    }

    public function readFile($fileName, $currentDirectoryName, $argument = null) {

        $fileOutputName = $fileName . '.gz';
        $fileToReadContents = $this->readFileContent($fileName, $currentDirectoryName);

        if (file_exists('CompressedFiles/' . $fileOutputName) == true) {
            if ($argument == 'overwrite') {
                $this->createAndWriteFile($fileToReadContents, $fileOutputName, $currentDirectoryName);
            } else {
                print_r(PHP_EOL . "\033[31m" . 'File: ' . $fileOutputName .  ' already exists.'. PHP_EOL . "\033[0m");
                print_r("\033[34m" . 'Please run "php batchCompressor.php overwrite" to overwrite.' . PHP_EOL . PHP_EOL . "\033[0m");
            }
        } else {
            $this->createAndWriteFile($fileToReadContents, $fileOutputName);
        }

    }

    public function readFileContent($fileToRead, $currentDirectoryName) {
        $fileContents = file_get_contents($currentDirectoryName . '/' . $fileToRead, 'r');
        return $fileContents;
    }

    public function createAndWriteFile($data, $fileOutputName) {
        $gzData = gzencode($data, 9);
        $filePath = fopen('CompressedFiles/' . $fileOutputName, "w");
        $this->writeFile($filePath, $gzData);
    }

    public function writeFile ($filePath, $gzData) {
        fwrite($filePath, $gzData);
        fclose($filePath);
    }
}

redpajama_set_name: RedPajamaGithub


text:
package gov.va.hmp.access;

/**
 * A matcher over acceptable values for use in {@link ITarget} evaluation.
 *

 * Inspired by hamcrest matchers.
 *

 * For easy access to common Matcher implementations, use the static factory
 * methods in {@link Targets}.
 *

 * Well designed matchers should be immutable.
 *
 * @see ITarget
 */
public interface Matcher<T> {
    /**
     * Evaluates the matcher for argument <var>item</var>.
     *

     * This method matches against Object, instead of the generic type T. This is
     * because the caller of the Matcher does not know at runtime what the type is
     * (because of type erasure with Java generics). It is down to the implementations
     * to check the correct type.
     *
     * @param item the object against which the matcher is evaluated.
     * @return true if <var>item</var> matches, otherwise false.
     */
    boolean matches(Object item) throws MissingAttributeException;
}


text:
Finsta Deck is a "Top Trumps" inspired card game for mobile, based on finance data of the Canton Bern.
You can play the current version on your mobile at http://quartett.herokuapp.com

# Setup

* install rvm http://rvm.io
* bundle install
* spring rake db:setup
* spring rake import geo:import

# Credits

Puzzle ITC http://www.puzzle.ch

* Pierre Fritsch
* Roland Studer
* Philipp Gassmann
* Anselm Strauss
* Andreas Maierhofer


text:
package com.jeequan.jeepay.core.entity;

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;

import java.io.Serializable;
import java.util.Date;

/**
 * <p>
 * 分账账号组
 * </p>
 *
 * @author [mybatis plus generator]
 * @since 2021-08-23
 */
@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
@TableName("t_mch_division_receiver_group")
public class MchDivisionReceiverGroup implements Serializable {

    //gw
    public static final LambdaQueryWrapper<MchDivisionReceiverGroup> gw(){
        return new LambdaQueryWrapper<>();
    }

    private static final long serialVersionUID=1L;

    /**
     * 组ID
     */
    @TableId(value = "receiver_group_id", type = IdType.AUTO)
    private Long receiverGroupId;

    /**
     * 组名称
     */
    private String receiverGroupName;

    /**
     * 商户号
     */
    private String mchNo;

    /**
     * 自动分账组(当订单分账模式为自动分账,改组将完成分账逻辑) 0-否 1-是
     */
    private Byte autoDivisionFlag;

    /**
     * 创建者用户ID
     */
    private Long createdUid;

    /**
     * 创建者姓名
     */
    private String createdBy;

    /**
     * 创建时间
     */
    private Date createdAt;

    /**
     * 更新时间
     */
    private Date updatedAt;

}


text:
<!DOCTYPE html>

	<meta charset="utf-8">
	<title>letzERP Desk</title>
	<meta name="author" content="">
	<meta name="viewport" content="width=device-width, initial-scale=1.0,
		maximum-scale=1.0, minimum-scale=1.0, user-scalable=no, minimal-ui">
	<meta name="apple-mobile-web-app-capable" content="yes">
	<meta name="apple-mobile-web-app-status-bar-style" content="white">
	<meta name="mobile-web-app-capable" content="yes">
	<link rel="shortcut icon"
		href="{{ favicon or "/assets/frappe/images/favicon.ico" }}" type="image/x-icon">
	<link rel="icon"
		href="{{ favicon or "/assets/frappe/images/favicon.ico" }}" type="image/x-icon">
	{% for include in include_css -%}
	<link type="text/css" rel="stylesheet" href="{{ include }}">
	{%- endfor -%}

	{% for include in include_js -%}

	{%- endfor -%}


text:
HexWarfare
=====

Warfare game based on hexes

Some images are from the Battle for Wesnoth project and are licensed under GPLv2.
https://github.com/wesnoth/wesnoth

Building Instructions

You need to have the dependencies already built and installed. At this time we are dependent on SDL2 (base+image+mixer+ttf), google protobufs, enet, boost. Boost is mostly required since certain C++11 things like regex are broken in some compilers still.

If using ubuntu (or derivative) these can be downloaded with the command:
sudo apt-get install libsdl2-dev libsdl2-image-dev libsdl2-mixer-dev libsdl2-ttf-dev libprotobuf-dev libenet-dev libboost-1.55-all-dev
This assumes you have a development environment set up already.

Clone the repository with git clone https://github.com/sweetkristas/HexWarfare
Update the submodules.
The first time: git submodule init && git submodule update
Change into the HexWarfare directory and type make


text:
#ifndef _PVRSCOPE_H_
#define _PVRSCOPE_H_

#ifdef __cplusplus
extern "C" {
#endif

/*
	SGSPerfServer and PVRTune communications
*/

/*!
 @addtogroup ScopeComms PVRScopeComms
 @brief      The PVRScopeComms functionality of PVRScope allows an application to send user defined information to
             PVRTune via PVRPerfServer, both as counters and marks, or as editable data that can be
             passed back to the application.
 @details    PVRScopeComms has the following limitations:
             \li PVRPerfServer must be running on the host device if a @ref ScopeComms enabled
                 application wishes to send custom counters or marks to PVRTune. If the application in
                 question also wishes to communicate with PVRScopeServices without experiencing any
                 undesired behaviour PVRPerfServer should be run with the '--disable-hwperf' flag.
             \li The following types may be sent: Boolean, Enumerator, Float, Integer, String.
 @{
*/

/****************************************************************************
** Enums
****************************************************************************/

/*!**************************************************************************
 @enum          ESPSCommsLibType
 @brief         Each editable library item has a data type associated with it
****************************************************************************/
///
enum ESPSCommsLibType
{
	eSPSCommsLibTypeString,		///< data is string (NOT NULL-terminated, use length parameter)
	eSPSCommsLibTypeFloat,		///< data is SSPSCommsLibraryTypeFloat
	eSPSCommsLibTypeInt,		///< data is SSPSCommsLibraryTypeInt
	eSPSCommsLibTypeEnum,		///< data is string (NOT NULL-terminated, use length parameter). First line is selection number, subsequent lines are available options.
	eSPSCommsLibTypeBool		///< data is SSPSCommsLibraryTypeBool
};

/****************************************************************************
** Structures
****************************************************************************/

// Internal implementation data
struct SSPSCommsData;

/*!**************************************************************************
 @struct        SSPSCommsLibraryItem
 @brief         Definition of one editable library item
****************************************************************************/
struct SSPSCommsLibraryItem
{

	const char			*pszName;       ///< Item name. If dots are used, PVRTune could show these as a foldable tree view.
	unsigned int		nNameLength;	///< Item name length

	ESPSCommsLibType	eType;			///< Item type

	const char			*pData;         ///< Item data
	unsigned int		nDataLength;	///< Item data length
};

/*!**************************************************************************
 @struct        SSPSCommsLibraryTypeFloat
 @brief         Current, minimum and maximum values for an editable library item of type float
****************************************************************************/
struct SSPSCommsLibraryTypeFloat
{
	float fCurrent;						///< Current value
	float fMin;							///< Minimal value
	float fMax;							///< Maximum value
};

/*!**************************************************************************
 @struct        SSPSCommsLibraryTypeInt
 @brief         Current, minimum and maximum values for an editable library item of type int
****************************************************************************/
struct SSPSCommsLibraryTypeInt
{
	int nCurrent;						///< Current value
	int nMin;    						///< Minimal value
	int nMax;    						///< Maximum value
};

/*!**************************************************************************
 @struct        SSPSCommsLibraryTypeBool
 @brief         Current value for an editable library item of type bool
****************************************************************************/
struct SSPSCommsLibraryTypeBool
{
	bool bValue;                            ///< Boolean value
};

/*!**************************************************************************
 @struct        SSPSCommsCounterDef
 @brief         Definition of one custom counter
****************************************************************************/
struct SSPSCommsCounterDef
{
	const char			*pszName;		    ///< Custom counter name
	unsigned int		nNameLength;	    ///< Custom counter name length
};

/****************************************************************************
** Declarations
****************************************************************************/

/*!**************************************************************************
 @brief         Initialise @ref ScopeComms
 @return        @ref ScopeComms data.
****************************************************************************/
SSPSCommsData *pplInitialise(
	const char			* const pszName,	///< String to describe the application
	const unsigned int	nNameLen			///< String length
);

/*!**************************************************************************
 @brief         Shutdown or de-initialise the remote control section of PVRScope.
****************************************************************************/
void pplShutdown(
    SSPSCommsData *psData			        ///< Context data
);

/*!**************************************************************************
 @brief         Query for the time. Units are microseconds, resolution is undefined.
****************************************************************************/
unsigned int pplGetTimeUS(
	SSPSCommsData		&sData	        ///< Context data
);

/*!**************************************************************************
 @brief         Send a time-stamped string marker to be displayed in PVRTune.
 @details       Examples might be:
                \li switching to outdoor renderer
                \li starting benchmark test N
****************************************************************************/
bool pplSendMark(
	SSPSCommsData		&sData,				///< Context data
	const char			* const pszString,	///< Time-stamped string
	const unsigned int	nLen				///< String length
);

/*!**************************************************************************
 @brief         Send a time-stamped begin marker to PVRTune.
 @details       Every begin must be followed by an end; they cannot be interleaved or
                nested. PVRTune will show these as an activity timeline.
****************************************************************************/
bool pplSendProcessingBegin(
	SSPSCommsData		&sData,				///< Context data
	const char			* const	pszString,	///< Name of the processing block
	const unsigned int	nLen,				///< String length
	const unsigned int	nFrame=0			///< Iteration (or frame) number, by which processes can be grouped.
);

/*!**************************************************************************
 @brief         Send a time-stamped end marker to PVRTune.
 @details       Every end must be preceeded by a begin; they cannot be interleaved or
                nested. PVRTune will show these as an activity timeline.
****************************************************************************/
bool pplSendProcessingEnd(
	SSPSCommsData		&sData      ///< Context data
);

/*!**************************************************************************
 @brief         Create a library of remotely editable items
****************************************************************************/
bool pplLibraryCreate(
	SSPSCommsData				&sData,			///< Context data
	const SSPSCommsLibraryItem	* const pItems,	///< Editable items
	const unsigned int			nItemCount		///< Number of items
);

/*!**************************************************************************
 @brief	        Query to see whether a library item has been edited, and also retrieve the new data.
****************************************************************************/
bool pplLibraryDirtyGetFirst(
	SSPSCommsData		&sData,	                ///< Context data
	unsigned int		&nItem,	                ///< Item number
	unsigned int		&nNewDataLen,           ///< New data length
	const char			**ppData        	    ///< New data
);

/*!**************************************************************************
 @brief         Specify the number of custom counters and their definitions
****************************************************************************/
bool pplCountersCreate(
	SSPSCommsData				&sData,	                ///< Context data
	const SSPSCommsCounterDef	* const psCounterDefs,  ///< Counter definitions
	const unsigned int			nCount    	            ///< Number of counters
);

/*!**************************************************************************
 @brief 	    Send an update for all the custom counters. The psCounterReadings array must be
                nCount long.
****************************************************************************/
bool pplCountersUpdate(
	SSPSCommsData				&sData,	                    ///< Context data
	const unsigned int			* const psCounterReadings	///< Counter readings array
);

/*!**************************************************************************
 @brief	        Force a cache flush.
 @details       Some implementations store data sends in the cache. If the data rate is low, the real
                send of data can be significantly delayed.
                If it is necessary to flush the cache, the best results are likely to be
                achieved by calling this function with a frequency between once per second up to once per
                frame. If data is sent extremely infrequently, this function could be
                called once at the end of each bout of data send.
****************************************************************************/
bool pplSendFlush(
	SSPSCommsData				&sData	    ///< Context data
);

/*! @} */

#ifdef __cplusplus
}
#endif

#endif /* _PVRSCOPE_H_ */

/*****************************************************************************
 End of file (PVRScopeComms.h)
*****************************************************************************/


text:
package org.finra.jtaf.core.parsing;

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

import org.finra.jtaf.core.AutomationEngine;
import org.finra.jtaf.core.model.exceptions.NameCollisionException;
import org.finra.jtaf.core.model.test.TestComponent;
import org.finra.jtaf.core.model.test.TestScript;
import org.finra.jtaf.core.model.test.TestSuite;
import org.finra.jtaf.core.model.test.digraph.DiNode;
import org.finra.jtaf.core.model.test.digraph.TestDigraph;
import org.finra.jtaf.core.parsing.exceptions.ParsingException;
import org.finra.jtaf.core.plugins.parsing.IPostParseTestPlugin;
import org.finra.jtaf.core.plugins.parsing.ParserPluginException;
import org.finra.jtaf.core.plugins.parsing.PostTestParserPluginContext;
import org.finra.jtaf.core.utilities.logging.MessageCollector;
import org.w3c.dom.Element;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;

/**
 * Parser plugin meant to handle the loop element in the script that determines
 * the number of times a test script needs to be run.
 *
 */
public class LoopPlugin implements IPostParseTestPlugin
{
    protected TestDigraph testDigraph;

    @Override
    public String getTagName()
    {
        return "loop";
    }

    public LoopPlugin(AutomationEngine automationEngine)
    {
        this.testDigraph = automationEngine.getTestDigraph();
    }

    @Override
    public void execute(PostTestParserPluginContext ctx)
        throws ParserPluginException
    {
        int iterationCount = getIterationCount(ctx.getRootNodeTest());
        if (iterationCount != 1)
        {
            TestScript oldTestScript = getOldTestScript(ctx.getTestSuite());
            List<TestScript> iteratedScripts = createIteratedTestScripts(ctx,
                    oldTestScript, iterationCount);
            removeOldTestScript(ctx.getTestSuite());
            addIteratedTestScripts(ctx.getTestSuite(), iteratedScripts);
        }
    }

    private static int getIterationCount(Node rootNodeTest)
    {
        int result = 1;
        NodeList children = rootNodeTest.getChildNodes();
        for (int i = 0; i < children.getLength(); i++)
        {
            if (children.item(i).getNodeName().equalsIgnoreCase("loop"))
            {
                result = Integer.parseInt(children.item(i).getAttributes()
                        .getNamedItem("iterations").getNodeValue());
            }
        }
        return result;
    }

    private static TestScript getOldTestScript(TestSuite testSuite)
    {
        List<TestComponent> testComponents = testSuite.getComponentList();
        return (TestScript) testComponents.get(testComponents.size() - 1);
    }

    List<TestScript> createIteratedTestScripts(PostTestParserPluginContext ctx,
        TestScript oldTestScript, int iterationCount)
        throws ParserPluginException
    {
        List<TestScript> result = new ArrayList<TestScript>();
        for (int currentIteration = 1; currentIteration <= iterationCount; currentIteration++)
        {
            TestScript newTestScript;
            ScriptParser sp = AutomationEngine.getInstance().getScriptParser();
            try
            {
                newTestScript = sp
                        .processTestScript((Element) ctx.getRootNodeTest(),
                                new MessageCollector());
            }
            catch (ParsingException parsingException)
            {
                throw new ParserPluginException("Problem re-parsing test",
                        parsingException);
            }
            newTestScript.setName(newTestScript.getName() + " [iteration "
                    + currentIteration + " of " + iterationCount + "]");
            result.add(newTestScript);
        }
        return result;
    }

    private static void removeOldTestScript(TestSuite testSuite)
    {
        List<TestComponent> testComponents = testSuite.getComponentList();
        testComponents.remove(testComponents.size() - 1);
    }

    private void addIteratedTestScripts(TestSuite testSuite,
        List<TestScript> iteratedScripts) throws ParserPluginException
    {
        try
        {
            for (TestScript iteratedScript : iteratedScripts)
            {
                testSuite.add(iteratedScript);
                // DigraphPlugin dependenciesPlugin =
                // DigraphPlugin.getInstance();
                // TestDigraph testDigraph =
                // dependenciesPlugin.getTestDigraph();
                testDigraph.addVertex(new DiNode(iteratedScript));
            }
        }
        catch (NameCollisionException nameCollisionException)
        {
            throw new ParserPluginException("Duplicate test name: ",
                    nameCollisionException);
        }
    }
}


text:
package org.webrtc;

import android.support.test.InstrumentationRegistry;
import android.support.test.filters.SmallTest;
import android.support.test.runner.AndroidJUnit4;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.webrtc.PeerConnectionFactory;

// This test is intended to run on ARM and catch LoadLibrary errors when we load the WebRTC
// JNI. It can't really be setting up calls since ARM emulators are too slow, but instantiating
// a peer connection isn't timing-sensitive, so we can at least do that.
@RunWith(AndroidJUnit4.class)
public class WebRtcJniBootTest {
  @Test
  @SmallTest
  public void testJniLoadsWithoutError() throws InterruptedException {
    PeerConnectionFactory.initializeAndroidGlobals(InstrumentationRegistry.getTargetContext(),
        false /* videoCodecHwAcceleration */);

    PeerConnectionFactory.Options options = new PeerConnectionFactory.Options();
    new PeerConnectionFactory(options);
  }
}


text:
// Copyright 2011 Google Inc. All Rights Reserved.
//
// 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.

/**
 * @fileoverview Common functions for interacting with pages.
 *
 */

goog.provide('bots.dashboard.Common');

goog.require('bots.dashboard.Constants');
goog.require('bots.dashboard.UrlManager');
goog.require('goog.dom');
goog.require('goog.net.XhrIo');

/**
 * Constructor for the common methods class.
 * @constructor
 * @export
 */
bots.dashboard.Common = function() {
};

/**
 * Submits the url from a specified input box to the server.
 * @param {string} id The id of the input box to use.
 * @param {bots.dashboard.UrlManager} urlManager The urlManager being used.
 * @param {?Function} opt_callback Callback to use when the submit is
 *   successful.
 * @export
 */
bots.dashboard.Common.submitInputUrl = function(id, urlManager, opt_callback) {
  var urlInput = goog.dom.getElement(id);
  urlManager.addUrl(urlInput.value, false, opt_callback);
};

/**
 * Loads the urls from the server for the current user and sends them to the
 * handlers in UrlManager instance.
 * @param {bots.dashboard.UrlManager} urlManager The urlManager being used.
 * @export
 */
bots.dashboard.Common.loadUrlManagerUrls = function(urlManager) {
  // Chaining the load url requests through callbacks, this provides users
  // with a better experience where they see the submitted + interested urls
  // added, followed by any scores.
  // #TODO(user): Merge the get url requests into a single request, and
  // do the interested/submitted sorting client side.
  var getScores = goog.bind(urlManager.getAndDisplayScores, urlManager);
  var getInterestedUrls = goog.bind(goog.net.XhrIo.send, undefined,
      bots.dashboard.Constants.GETURLS_URL + '?' +
      bots.dashboard.Constants.GETURLS_URL_INTERESTED_PARAM + '=true',
      goog.bind(urlManager.interestedUrlHandler, urlManager, getScores),
      'GET');

  goog.net.XhrIo.send(
      bots.dashboard.Constants.GETURLS_URL + '?' +
      bots.dashboard.Constants.GETURLS_URL_SUBMITTED_PARAM + '=true',
      goog.bind(urlManager.submittedUrlHandler,
                urlManager, getInterestedUrls), 'GET');
};


text:
package main

import (
	"fmt"

	"github.com/hyperledger/fabric-chaincode-go/shim"
	pb "github.com/hyperledger/fabric-protos-go/peer"
)

// PassthruChaincode passes thru invoke and query to another chaincode where
//     called ChaincodeID = args[0]
//     called chaincode's function = args[1]
//     called chaincode's args = args[2:len-2]
//     called ChannelID = args[len-1]
type PassthruChaincode struct {
}

func toChaincodeArgs(args ...string) [][]byte {
	bargs := make([][]byte, len(args))
	for i, arg := range args {
		bargs[i] = []byte(arg)
	}
	return bargs
}

func (p *PassthruChaincode) Init(stub shim.ChaincodeStubInterface) pb.Response {
	fmt.Println("passthru Init")
	function, _ := stub.GetFunctionAndParameters()
	return shim.Success([]byte(function))
}

// helper
func (p *PassthruChaincode) iq(stub shim.ChaincodeStubInterface, chaincode string, args []string, channel string) pb.Response {
	return stub.InvokeChaincode(chaincode, toChaincodeArgs(args...), channel)
}

// Invoke passes through the invoke call
// The chaincode ID to call MUST be specified as first argument
// The channel ID to call the chaincode on MUST be specified as the last argument
func (p *PassthruChaincode) Invoke(stub shim.ChaincodeStubInterface) pb.Response {
	args := stub.GetStringArgs()
	fmt.Println("passthru Invoke ", args)

	if len(args) < 2 {
		return shim.Error("Channel to call on not provided")
	}
	channelToCallOn := args[len(args)-1]
	if len(args) < 1 {
		return shim.Error("Chaincode to call not provided")
	}
	chaincodeToCall := args[0]

	response := p.iq(stub, chaincodeToCall, args[1:len(args)-1], channelToCallOn)
	if response.Status != shim.OK {
		msg := response.Message
		if response.Payload != nil {
			msg = string(response.Payload)
		}
		errStr := fmt.Sprintf("Failed to invoke chaincode. Got error: %s", msg)
		fmt.Printf(errStr)
		return shim.Error(errStr)
	}
	return response
}

func main() {
	err := shim.Start(new(PassthruChaincode))
	if err != nil {
		fmt.Printf("Error starting Passthru chaincode: %s", err)
	}
}


text:
/*
Youtube, soundcloud and pastebin link embeding
 */

// TODO: DRY this shit

let main = require('../main'),
	{$, etc} = main;

// >80 char rule
const youtube_url_re = exports.youtube_url_re = /(?:>>>*?)?(?:https?:\/\/)?(?:www\.|m.)?youtube\.com\/watch\/?\?((?:[^\s#&=]+=[^\s#&]*&)*)?v=([\w-]{11})((?:&[^\s#&=]+=[^\s#&]*)*)&?(#t=[\dhms]{1,9})?/,
	youtube_short_re = exports.youtube_short_re = /(?:>>>*?)?(?:https?:\/\/)?(?:www\.|m.)?youtu.be\/([\w-]{11})\??(t=[\dhms]{1,9})?/,
	youtube_time_re = exports.youtube_time_re = /^#t=(?:(\d\d?)h)?(?:(\d{1,3})m)?(?:(\d{1,3})s)?$/,
	youtube_short_time_re = exports.youtube_short_time_re = /^t=(?:(\d\d?)h)?(?:(\d{1,3})m)?(?:(\d{1,3})s)?$/;

function make_video(id, params, start) {
	if (!params)
		params = {allowFullScreen: 'true'};
	params.allowScriptAccess = 'always';
	var query = {
		autohide: 1,
		fs: 1,
		modestbranding: 1,
		origin: document.location.origin,
		rel: 0,
		showinfo: 0
	};
	if (start)
		query.start = start;
	if (params.autoplay)
		query.autoplay = params.autoplay;
	if (params.loop) {
		query.loop = '1';
		query.playlist = id;
	}

	return $('', {
		type: 'text/html',
		src: encodeURI('https://www.youtube.com/embed/' + id) + '?'
			+ $.param(query),
		frameborder: '0',
		attr: video_dims(),
		class: 'youtube-player'
	});
}

function video_dims() {
	if (window.screen && screen.width <= 320)
		return {width: 250, height: 150};
	else
		return {width: 560, height: 340};
}

main.$threads.on('click', '.watch', function(e) {
	if (e.which > 1 || e.metaKey || e.ctrlKey || e.altKey || e.shiftKey)
		return;
	var $target = $(e.target);

	// maybe squash that double-play bug? ugh, really
	if (!$target.is('a'))
		return;

	var $video = $target.find('iframe');
	if ($video.length) {
		$video.siblings('br').andSelf().remove();
		$target.css('width', 'auto');
		return false;
	}
	if ($target.data('noembed'))
		return;
	//check if longURL, if that fails, check if shortURL
	var m = $target.attr('href').match(youtube_url_re);
	if (!m) {
		m = $target.attr('href').match(youtube_short_re);
		if (!m)
		// Shouldn't happen, but degrade to normal click action
			return;
		timeCall(m[1],m[2],youtube_short_time_re);
	}
	timeCall(m[2],m[4],youtube_time_re);
	function timeCall(url, time, timeRex){
		var start = 0;
		if (time){
			var t = time.match(timeRex);
			if (t) {
				if (t[1])
					start += parseInt(t[1], 10) * 3600;
				if (t[2])
					start += parseInt(t[2], 10) * 60;
				if (t[3])
					start += parseInt(t[3], 10);
			}
		}
		$target
			.css('width', video_dims().width)
			.append('
', make_video(url, null, start))
	}
	return false;
});

main.$threads.on('mouseenter', '.watch', function (event) {
	var $target = $(event.target);
	if ($target.data('requestedTitle'))
		return;
	$target.data('requestedTitle', true);
	// Edit textNode in place so that we don't mess with the embed
	var node = $target.contents().filter(function () {
		return this.nodeType === 3;
	})[0];
	if (!node)
		return;
	const orig = node.textContent;
	node.textContent = orig + '...';
	var m = $target.attr('href').match(youtube_url_re);
	if (!m){
		m = $target.attr('href').match(youtube_short_re);
		if(!m)
			return;
		$.ajax({
			url: '//gdata.youtube.com/feeds/api/videos/' + m[1],
			data: {v: '2', alt: 'jsonc'},
			dataType: 'json',
			success: gotInfo,
			error() {
				node.textContent = orig + '???';
			}
		});
	}

	$.ajax({
		url: '//gdata.youtube.com/feeds/api/videos/' + m[2],
		data: {v: '2', alt: 'jsonc'},
		dataType: 'json',
		success: gotInfo,
		error() {
			node.textContent = orig + '???';
		}
	});
	// Creates the Titles upon hover
	// NOTE: Condense gotInfos into single function
	function gotInfo(data) {
		var title = data && data.data && data.data.title;
		if (title) {
			node.textContent = orig + ': ' + title;
			$target.css({color: 'black'});
		}
		else
			node.textContent = orig + ' (gone?)';

		if (data
			&& data.data
			&& data.data.accessControl
			&& data.data.accessControl.embed === 'denied'
		) {
			node.textContent += ' (EMBEDDING DISABLED)';
			$target.data('noembed', true);
		}
	}
});

function make_embed(uri, params, dims) {
	var $obj = $('<object/>', {attr: dims});
	for (var name in params) {
		$('<param/>', {
			attr: {
				name: name,
				value: params[name]
			}
		}).appendTo($obj);
	}
	$('<embed/>', {
		src: uri,
		type: 'application/x-shockwave-flash'
	})
		.attr(dims)
		.attr(params)
		.appendTo($obj);
	return $obj;
}

/* SOUNDCLOUD */

const soundcloud_url_re = exports.soundcloud_url_re = /(?:>>>*?)?(?:https?:\/\/)?(?:www\.)?soundcloud\.com\/([\w-]{1,40}\/[\w-]{1,80})\/?/;

function fetchSoundcloud(target, width, cb) {
	const url = 'https://soundcloud.com/oembed?url='
		+ encodeURIComponent(target.getAttribute('href'))
		+ `&maxwidth=${width}&maxheight=166&auto_play=true&format=json`
		+ '&show_comments=false';
	const xhr = new XMLHttpRequest();
	xhr.open('GET', url);
	xhr.responseType = 'json';
	xhr.onload = function () {
		if (this.status !== 200)
			return cb(this.status);
		cb(null, this.response);
	};
	xhr.send();
}

main.$threads.on('click', '.soundcloud', function (e) {
	if (e.which > 1 || e.ctrlKey || e.altKey || e.shiftKey || e.metaKey)
		return;
	const {target} = e,
		iframe = target.query('iframe');
	e.preventDefault();
	if (iframe) {
		iframe.previousElementSibling.remove();
		iframe.remove();
		return;
	}

	const width = Math.round(window.innerWidth * 0.75);
	fetchSoundcloud(target, width, (err, json) => {
		if (err)
			return alert(err);
		target.append(document.createElement('br'));
		target.append(etc.parseDOM(json.html)[0]);
		target.style.width = width + 'px';
	});
});

main.$threads.on('mouseenter', '.soundcloud:not(.fetched)', function (event) {
	const {target} = event,
		node = target.firstChild,
		text = node.textContent;
	node.textContent = text + ' ...';

	// We should not be doing 2 separate fetches on mouseover and click, but
	// what if the user manages to click without mouseenter somehow?
	fetchSoundcloud(target, 1000, (err, json) => {
		if (err)
			return node.textContent = `${text}: Error: ${err}`;
		node.textContent = `${text}: ${json.title}`;
		target.style.color = 'black';
		target.classList.add('fetched');
	});
});

// PASTEBIN
const pastebin_re = exports.pastebin_re = /(?:>>>*?)?(?:https?:\/\/)?(?:www\.|m.)?pastebin\.com\/(.*)/;
//Pastebin's API seems built for MAKING pastebins but not sharing them

$(document).on('click', '.pastebin', function(event){
	if (event.which > 1 || event.ctrlKey || event.altKey || event.shiftKey || event.metaKey)
		return;
	var $target = $(event.target);

	var $obj = $target.find('iframe');
	if ($obj.length) {
		$obj.siblings('br').andSelf().remove();
		$target.css({
			width: 'auto',
			height: 'auto'
		});
		return false;
	}

	var m = $target.attr('href').match(pastebin_re);
	if (!m)
		return;
	var $window = $(window),
		width = Math.round($window.innerWidth() * 0.65),
		height = Math.round($window.innerHeight() * 0.65);
	$target
		.css({
			width: width,
			height: height
		})
		.append('
', $('', {
			type: 'text/html',
			src: 'https://pastebin.com/embed_iframe.php?i='+ m[1],
			frameborder: '0',
			width: width,
			height: height
		}))
	return false;
});


text:
<TITLE>Review for Traffic (2000)</TITLE>
<LINK REL="STYLESHEET" TYPE="text/css" HREF="/ramr.css">

Traffic (2000)

reviewed by
Louis Proyect

After Stephen Soderbergh transformed an environmentalist struggle into a
sexploitative star vehicle for Julia Roberts, it should not surprise us
that he would Hollywood-ize the hard-hitting television miniseries
"Traffik". Made for Channel 4 in Great Britain in 1989, "Traffik" also
appeared on public television in the United States one year later.

In "Traffic" Soderbergh has appropriated (or misappropriated) some core
elements of the original, while leaving out others that would get in the
way of his commercial goals. The resultant mess helps us understand how
liberal taste-makers frame the "war on drugs" in the face of an impending
war in Colombia. Considering that Soderbergh's first film was titled "Sex,
Lies and Videotape", an appropriate subtitle for "Traffic" might be "Drugs,
Lies and Hollywood".

In "Traffik", we are afforded a multi-tiered view of Great Britain's war on
the heroin trade. The central figure is a British Home Office minister
named Jack Lithgow (Bill Paterson) who has been assigned to oversee that
war. The irony, and one of the key dramatic elements of the tale, is that
his daughter is a drug addict. While relentlessly pursuing the source of
the "traffik" in Pakistan, he is constantly being pulled into his
daughter's own maelstrom.

"Traffik" derives its German title from the fact that one of the
politician's main antagonists is a German who uses a construction business
as a front for a much more lucrative heroin import business. After he is
arrested in the course of a major drug interdiction effort, his wife takes
over--even though she has been innocent of his activities up to that point.
Her easy slide into criminality serves to illustrate the point that nobody
is immune from the enormous temptations of a quick profit. Not only does
she assume control without missing a beat, she seems even more savvy than
her jailed husband. She announces, ''I'm going to be strong about this. I'm
not going to let go of everything we fought for'', as if the family
business was commercial real estate.

In Soderbergh's film the terrain and the commodity have shifted. We are now
dealing with the cocaine trade and its source is Mexico. The main character
is an American drug czar Robert Wakefield, played by the ubiquitous Michael
Douglas. His daughter Caroline (Erika Christensen) is a cocaine free-baser
who turns to prostitution to pay for her habit. In a search for his
daughter, which has all the hyped-up intensity of a Charles Bronson revenge
melodrama, Wakefield descends into the Black community, which takes on the
character of the Casbah. Blacks on the street appear menacing to Wakefield
(and the largely white audience I saw the film with), as if each had a
knife in one pocket and a drug stash in the other.

Another significant difference between the two films is how each drug czar
relates to the rogue third world country where the drugs originate. In
"Traffik", Lithgow is directing a campaign to wean Pakistani farmers away
from growing opium toward legal cash crops. His idealistic hopes are
eventually crushed when he realizes that there is no incentive for peasants
to stop growing opium. Unfortunately nothing grows in the arid Pakistani
soil as well as the poppy. "It doesn't need much water," Lithgow is told.
"It doesn't need much in the way of nutrients. They are just weeds -- the
richest weeds in the world." He learns that farmers must grow and harvest
10 acres of sugar cane to reap the profit from just three acres of poppies.

Perhaps the heroin and cocaine trade is driven by the same brute economic
facts that drive the tobacco industry, a legal but much more toxic
industry. According to the book "Barbarians at the Gate," investor Warren
Buffett told Salomon Chairman John Gutfreund in 1987: "I'll tell you why I
like the cigarette business. It costs a penny to make. Sell it for a
dollar. It's addictive. And there's fantastic brand loyalty.''

While "Traffik" is mostly about character development--particularly
Lithgow's disillusionment--"Traffic" is mostly a lurid 'policier', a sort
of big budget version of the old TV show "Miami Vice", in which law
enforcement becomes paramount, despite the film's lip-service to the
obvious truth that the war on drugs is unwinnable.

In Soderbergh's film, the major point of view in Mexico belongs to Javier
Rodriguez Rodriguez (Benicio Del Toro), an honest cop out to bust the
corrupt Army general and the drug lords he protects. This Mexico is even
more wicked than the Black community, at least in cinematographic terms.
Soderbergh, who handled the camera itself for the Mexico location, uses a
sulfur-yellow filter to make sure that the audience understands that this
is a hellish place.

While "Traffik" takes place largely in Pakistan, where the opium is grown,
there is no interest in finding out what conditions spawn the growth of
coca. For that to take place, the film would have to include Colombia as a
venue. If you restrict your terrain to Mexico, you are dealing solely with
the finished product. And who else handles the finished product but
case-hardened businessmen rather than people at the bottom, who rely on the
soil to make a living.

This is where "Traffik" excels. The film begins with Fazal (Jamal Shah), an
impoverished Pakistani farmer who grows opium poppies on his farm and ekes
out barely enough money to support his wife and two children. Lithgow
eventually meets Fazal and asks, "Do you know that people in the West are
dying from the heroin you make?" "Sir, I grow opium, not heroin," Fazal
replies. "You deal with the heroin problem."

Soderbergh is quite open about his desire to flatter law enforcement
agencies in the USA, while simultaneously maintaining a hip "war on drugs
can not succeed" 'tude. In a profile that appears in the Jan. 3-9 Village
Voice, Soderbergh states:

"I didn't want to come off like we had answers. The idea that some silly
filmmaker after two years could sort it out would be outrageous. But there
seems to be a huge vacuum in the public debate and I guess this is one of
the few times I felt a movie could actually help. The funny thing is,
everybody who sees it thinks it puts their point of view across, and I was
expecting exactly the opposite. We had a screening in Washington for
Customs, DEA, and the Department of Justice and they all came out saying
they really liked it. The following night, there was some hardcore leftie
NPR/PBS [!!!!] screening in L.A. and some guy stands up and goes, 'Thank
you for making the first pro-legalization movie.' Then the other night,
Commissioner Safir came to a screening and said he thought it was the most
accurate representation of law enforcement he'd seen in a long time. And I
have, you know, stoner friends who are going, like, 'Dude, yeah, great . .
. '"

Nobody could possibly accuse Soderbergh of coming off like he had answers.
But one might have hoped that he would have had a more open-eyed view of
the cops in the United States, who appear in the film to be the Mexican
police's only reliable ally.

Since Soderbergh is based in Los Angeles, one can only conclude that he has
not been reading a newspaper for the past few years. Otherwise, he would
have felt the need to introduce a little bit of reality into his script,
based on the gargantuan Ramparts Division scandal.

It turns out that over the past decade or so, the LAPD anti-drug division
has been deeply involved in the cocaine trade itself. Ex-cop, now serving a
long prison sentence, Rafael Perez was accused of murdering, dealers during
a botched drug deal in the mid-1990s. His ex-girl friend claims that the
bodies of those victims and that of another woman allegedly killed by
Perez's partner David Mack were buried in Mexico in hopes that, if they
were discovered, they would be presumed to be victims of the region's drug
wars. While some investigators claim that this accusation was false, there
is no doubt that Perez and other officers have been found guilty of
stealing drugs from the evidence room of their department and re-selling
them on the street. In 1999 Perez pleaded guilty to stealing eight pounds
of cocaine in exchange for a lighter prison sentence. He also agreed to
identify other allegedly corrupt officers. Now this would have made for a
more interesting film, since it is a far more accurate representation of
how urban police departments behave--or misbehave.

Furthermore, if Soderbergh had been more informed about the relationship
between the USA and Mexico, he would have not been so eager to put white
hats on all the American officials, especially in light of the revelations
made by Thomas A. Constantine, the top drug-enforcement official who
resigned last year.

In an interview with the NY Times on November 26, 1999, Constantine states
regarding the Mexican drug trade: "I watched that situation for five and a
half years, and every year it became worse. We were not adequately
protecting the citizens of the United States from these organized-crime
figures."

Why not?

"Every time we had a major case involving a criminal organization from
Mexico operating in the United States, there was a significant allegation
of corruption involving the Mexican Attorney General's office, a Mexican
state police force, the highway police," he said.

However, the Clinton administration chose not to confront the Mexican
government, since American concerns about Mexico's corruption and
drug-trafficking problems were secondary to trade and other economic
interests.

"The idea was, if you said those things publicly, if you release documents,
you will just aggravate the situation," he said. "My concern was that we
had kids in this country dropping like flies. Maybe that was parochial, but
I felt like I was the only person there who felt like that."

Even after Constantine's counterpart in Mexico was found in 1997 to have
been colluding with the country's biggest cocaine trafficker, serious
discussion of the issue within the Clinton administration was minimal, even
negligible, he said. The exception was the annual debate over whether to
certify the anti-drug efforts of Mexico and other nations that produce or
ship illegal drugs.

Constantine told the NY Times, "Everyone would say, 'Your facts are
correct, but there are bigger policy issues involved.' "

Louis Proyect
Marxism mailing list: http://www.marxmail.org

The review above was posted to the
rec.arts.movies.reviews newsgroup (de.rec.film.kritiken for German reviews).

The Internet Movie Database accepts no responsibility for the contents of the
review and has no editorial control. Unless stated otherwise, the copyright
belongs to the author.

Please direct comments/criticisms of the review to relevant newsgroups.

Broken URLs inthe reviews are the responsibility of the author.

The formatting of the review is likely to differ from the original due
to ASCII to HTML conversion.

Related links: index of all rec.arts.movies.reviews reviews


text:
using System;

namespace C0DEC0RE
{
	/// <summary>
	/// Base for custom factories used to create default event loggers specific to individual blocks.
	/// These default event loggers are used when events need to be logged from static classes and methods
	/// that cannot participate in the normal instrumentation attachment process.
	/// </summary>
	public abstract class DefaultEventLoggerCustomFactoryBase : ICustomFactory
	{
		/// <summary>
		/// This method supports the Enterprise Library infrastructure and is not intended to be used directly from your code.
		/// </summary>
		/// <param name="context">Represents the context in which a build-up or tear-down runs.</param>
		/// <param name="name">Unused parameter</param>
		/// <param name="configurationSource">Represents a source for getting configuration</param>
		/// <param name="reflectionCache">Unused parameter.</param>
		/// <returns>Fully initialized instance of a default event logging object</returns>
		public object CreateObject(IBuilderContext context, string name, IConfigurationSource configurationSource, ConfigurationReflectionCache reflectionCache)
		{
			InstrumentationConfigurationSection objectConfiguration	= GetConfiguration(configurationSource);

			object createdObject = DoCreateObject((objectConfiguration));

			return createdObject;
		}

		/// <summary>
		/// This method supports the Enterprise Library infrastructure and is not intended to be used directly from your code.
		/// Builds an initialized default event logging object.
		/// </summary>
		/// <param name="instrumentationConfigurationSection">The instrumentation section that is used as configuration.</param>
		/// <returns>A fully initialized instance of a default event logging object.</returns>
		protected abstract object DoCreateObject(InstrumentationConfigurationSection instrumentationConfigurationSection);

		private InstrumentationConfigurationSection GetConfiguration(IConfigurationSource configurationSource)
		{
			InstrumentationConfigurationSection configurationSection
				= (InstrumentationConfigurationSection)configurationSource.GetSection(InstrumentationConfigurationSection.SectionName);
			if (configurationSection == null) configurationSection
				= new InstrumentationConfigurationSection(false, false, false);

			return configurationSection;
		}
	}
}


text:
<?php esc_html_e( "Navigate", "twentysixteen" ); ?>

            <?php wp_nav_menu( array( 'sort_column' => 'menu_order', 'container_class' => 'nav', 'theme_location' => 'primary_menu' ) ); ?>

    <?php if ( ! function_exists( 'dynamic_sidebar' ) || ! dynamic_sidebar( 'Slideout Widgets' ) ) : ?>
		<?php // widgets load here ?>
	<?php endif; ?>

	<?php
        $modules = get_option( 'reza_modules' );
        if ( $modules['tweets'] ) : get_template_part('inc/twitter'); endif;
    ?>


text:
..
 This work is licensed under a Creative Commons Attribution 3.0 Unported
 License.

 http://creativecommons.org/licenses/by/3.0/legalcode

==========================================
refactor-datasource-driver-framework
==========================================

https://blueprints.launchpad.net/congress/+spec/refactor-datasource-driver-framework

Currently the congress datasource driver is still pretty complex. This
blueprint aims to simplify it.

Problem description
===================

A detailed description of the problem:

* current there is a lot of logic in the convert_obj() method which is
  used to load the data into the data source driver. The majority of this
  logic is to validate that the table schema is valid. We should only need
  to do this one though on load of the data source driver.

* currently if you list the tables of a data source driver they aren't always
  populated in via __init__ self.state[table_name] = set(). I want to add a
  method to the DatasourceDriver base class that load_translator() which
  will allow one to pass in translators via the __init__ of a
  datasource driver. This will validate the schema there.

Proposed change
===============

Add load_translator() to datasource driver base class as descripted as able.
In addition to other refactoring that comes up as this work is being done.

Alternatives
------------

N/A

Policy
------

N/A

Using the Congress datalog syntax, write out an example policy using
https://wiki.openstack.org/wiki/Congress#Policy_Language

Example:

error(vm) :-
    nova:virtual_machine(vm),
    ids:ip_packet(src_ip, dst_ip),
    neutron:port(vm, src_ip), //finds out the port that has the VM's IP
    ids:ip_blacklist(dst_ip).

Policy Actions
--------------

N/A
Describe the policy activities in terms of monitoring, reactive, proactive,
and other ways to explain how the policy will implement it's desired state.

Data Sources
------------

N/A
Describe which projects and/or services the data is coming from

Data model impact
-----------------

N/A
Changes which require modifications to the data model often have a wider impact
on the system.  The community often has strong opinions on how the data model
should be evolved, from both a functional and performance perspective. It is
therefore important to capture and gain agreement as early as possible on any
proposed changes to the data model.

Questions which need to be addressed by this section include:

* What new data objects and/or database schema changes is this going to
  require?

* What database migrations will accompany this change.

* How will the initial set of new data objects be generated, for example if you
  need to take into account existing instances, or modify other existing data
  describe how that will work.

REST API impact
---------------

N/A

Security impact
---------------

N/A

Notifications impact
--------------------

N/A

Other end user impact
---------------------

N/A

Performance Impact
------------------

N/A

Other Deployer Impacts
----------------------

N/A

Developer Impact
----------------

N/A

Implementation
==============

Assignee(s)
-----------

Primary assignee:
    arosen

Work Items
----------

Push code to do this.

Dependencies
============

N/A

Testing
=======

Unit tests and tempest tests will be present to confirm this works as desired.

Documentation Impact
====================

Will update docs for how this now works.

References
==========

N/A


text:
<!DOCTYPE html>
<meta charset="utf-8">
<link rel="author" title="Julien Chaffraix" href="mailto:jchaffraix@webkit.org">
<link rel="help" href="https://bugs.webkit.org/show_bug.cgi?id=73272">
<link href="/css/support/width-keyword-classes.css" rel="stylesheet">
<link href="/css/support/grid.css" rel="stylesheet">
<link href="/css/support/alignment.css" rel="stylesheet">
<link rel="stylesheet" type="text/css" href="/fonts/ahem.css">
<link rel="help" href="https://drafts.csswg.org/css-grid/#track-sizing">
<meta name="assert" content="Test that setting and getting multiple grid-template-columns and grid-template-rows works as expected">


text:
from eeglib.helpers import CSVHelper

helper= CSVHelper("fake_EEG_signal.csv", windowSize=256)

for eeg in helper:
    print(eeg.PFD())


text:
<annotation>
<folder>calculator</folder>
<filename>calculator_2_view_1_pose_12_lit_1_gray.jpg</filename>
<source>
<database>photorealistic	rendering</database>
</source>
<size>
<width>640</width>
<height>480</height>
<depth>3</depth>
</size>
<segmented>0</segmented>
<object>
<name>calculator</name>
<pose>Unspecified</pose>
<truncated>0</truncated>
<difficult>0</difficult>
<bndbox>
<xmin>249</xmin>
<ymin>185</ymin>
<xmax>416</xmax>
<ymax>312</ymax>
</bndbox>
</object>
</annotation>


text:
from django.db import models

class Product(models.Model):
    category = models.ForeignKey('Category')
    name = models.CharField(max_length=128, unique=True)
    base_price = models.DecimalField(max_digits=5, decimal_places=2)
    quantity = models.IntegerField(default=0)
    def __str__(self):
        return self.name

class Category(models.Model):
    class Meta:
        verbose_name_plural = "Categories"
    name = models.CharField(max_length=128, unique=True)
    def __str__(self):
        return self.name


text:
using System;

namespace OpenViewer.Framework
{
    public class Constants
    {
        public const string Version = "0.1";
    }
}


text:
package com.github.ibole.infrastructure.persistence.db.mybatis;

import com.github.ibole.infrastructure.persistence.db.exception.DataBaseAccessException;
import com.github.ibole.infrastructure.persistence.pagination.model.PageList;
import com.github.ibole.infrastructure.persistence.pagination.model.Pager;
import com.sun.rowset.CachedRowSetImpl;

import org.apache.ibatis.session.RowBounds;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.support.SqlSessionDaoSupport;
import org.springframework.beans.factory.annotation.Autowired;

import java.io.Serializable;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.Types;
import java.util.List;
import java.util.Map;

import javax.sql.RowSet;

/*********************************************************************************************.
 *
 *
 *
Copyright 2016, iBole Inc. All rights reserved.
 *
 *

 *********************************************************************************************/

/**
 * MyBatis的Dao代理类.
 * @author bwang
 *
 */
public class BaseDao<T> extends SqlSessionDaoSupport {

  @Autowired
  public void setSqlSessionFactory(SqlSessionFactory sqlSessionFactory){

      super.setSqlSessionFactory(sqlSessionFactory);
  }

  private static final String COUNT = "_Count";

  public int save(String key, T entity) throws DataBaseAccessException {
      try {
          return getSqlSession().insert(key, entity);
      } catch (Exception e) {
          throw new DataBaseAccessException(getClass().getName() + " save exception:", e);
      }
  }

  public int saveObject(String key, Object entity) throws DataBaseAccessException {
      try {
          return getSqlSession().insert(key, entity);
      } catch (Exception e) {
          throw new DataBaseAccessException(getClass().getName() + " save exception:", e);
      }
  }

  public int save(String key, List<T> entity) throws DataBaseAccessException {
      try {

          return getSqlSession().insert(key, entity);
      } catch (Exception e) {
          throw new DataBaseAccessException(getClass().getName() + " save exception:", e);
      }
  }

  public int update(String key, Object entity) throws DataBaseAccessException {
      try {
          return getSqlSession().update(key, entity);
      } catch (Exception e) {
          throw new DataBaseAccessException(getClass().getName() + " update exception:", e);
      }
  }

  public int update(String key, Map<Object, Object> entity) throws DataBaseAccessException {
      try {

          return getSqlSession().update(key, entity);
      } catch (Exception e) {
          throw new DataBaseAccessException(getClass().getName() + " update exception:", e);
      }
  }

  public int delete(String key, Serializable id) throws DataBaseAccessException {
      try {
          return getSqlSession().delete(key, id);
      } catch (Exception e) {
          throw new DataBaseAccessException(getClass().getName() + " delete exception:", e);
      }
  }

  public int delete(String key, Object entity) throws DataBaseAccessException {
      try {
          return getSqlSession().delete(key, entity);
      } catch (Exception e) {
          throw new DataBaseAccessException(getClass().getName() + " delete exception:", e);
      }
  }

  public List<T> getAll(String key) {
      try {
          SqlSession session = getSqlSession();
          return session.selectList(key);
      } catch (Exception e) {
          logger.error(getClass().getName() + " getAll exception and key is" + key, e);
          return null;
      }
  }

  @SuppressWarnings("unchecked")
  public T get(String key, Object params) {
      try {
          return (T) getSqlSession().selectOne(key, params);
      } catch (Exception e) {
          logger.error(getClass().getName() + " get exception and key is" + key, e);
          return null;
      }
  }

  public <K, V> Map<K, V> getMap(String statement, Object parameter, String mapKey) {
    return getSqlSession().selectMap(statement, parameter, mapKey);
  }

  public Object getObject(String key, Object params) {
      try {
          return getSqlSession().selectOne(key, params);
      } catch (Exception e) {
          logger.error(getClass().getName() + " get exception and key is" + key, e);
          return null;
      }
  }

  public List<T> getList(String key, Object params) {
      try {
          return getSqlSession().selectList(key, params);
      } catch (Exception e) {
          logger.error(getClass().getName() + " getList exception and key is" + key, e);
          return null;
      }
  }

  @SuppressWarnings("rawtypes")
  public List getObjectList(String key, Object params) {
      try {
          return getSqlSession().selectList(key, params);
      } catch (Exception e) {
          logger.error(getClass().getName() + " getList exception and key is" + key, e);
          return null;
      }
  }

  public List<String> getStringList(String key, Object params) {
      try {
          return getSqlSession().selectList(key, params);
      } catch (Exception e) {
          logger.error(getClass().getName() + " getList exception and key is" + key, e);
          return null;
      }
  }

  //Notes: page.getOffset() only used for mysql
  @SuppressWarnings({"rawtypes", "unchecked"})
  public PageList<T> getList(String key, Object params, Pager page) {
    PageList pages = new PageList(page);
      try {
          Integer totalCounts = count(key + COUNT, params);
          // add 最大页数判断
          int pageM = maxPage(totalCounts, page.getPageSize(), page.getPageNumber());
          if (pageM > 0) {
            pages.getPager().setPageNumber(pageM);
          } // end
          if (totalCounts != null && totalCounts.longValue() > 0) {
              List<T> list = getSqlSession().selectList(key, params,
                      new RowBounds(page.getOffset(), page.getPageSize()));
              pages.addAll(list);
              pages.getPager().setTotalCount(totalCounts.longValue());
          }
          return pages;
      } catch (Exception e) {
          logger.error(getClass().getName() + " getList exception and key is" + key, e);
          return null;
      }
  }

  /**
   * 判断是否超出最大页数
   *
   * @param tcount
   *            总条数
   * @param pageS
   *            每页条数
   * @param pNo
   *            当前页
   * @return int 大于0表示超出最大页数,返回最大页数
   */
  private int maxPage(Integer tcount, Integer pageS, Integer pNo) {
      if(tcount==null)
          return -1;
      int maxPage = tcount % pageS == 0 ? tcount / pageS : tcount / pageS + 1;// 最大页数
      if (maxPage < pNo)
          return maxPage;
      else
          return -1;
  }

  public Integer count(String key, Object params) {
      try {
          return (Integer) getSqlSession().selectOne(key, params);
      } catch (Exception e) {
          logger.error(getClass().getName() + " count exception and key is" + key, e);
          return Integer.valueOf(0);
      }
  }

  public Connection getConnection() {
      try {
          Connection conn = getSqlSession().getConfiguration().getEnvironment().getDataSource().getConnection();
          conn.setAutoCommit(false);
          return conn;
      } catch (SQLException e) {
          return null;
      }

  }

  /**
   * 执行sql语句
   *
   * @param sql
   * @param params
   *            执行sql时的参数
   * @throws DaoException
   */
  public PreparedStatement execute(String sql, Object[] params, Connection conn) throws Exception {

      PreparedStatement stmt = null;
      stmt = conn.prepareStatement(sql);
      fillParams(stmt, params);
      stmt.execute();

      return stmt;
  }

  /**
   * 执行sql语句
   *
   * @param sql
   * @param params
   *            执行sql时的参数
   * @throws DaoException
   */
  public PreparedStatement execute(String sql, Connection conn) throws Exception {

      PreparedStatement stmt = null;
      stmt = conn.prepareStatement(sql);
      stmt.execute();

      return stmt;
  }

  /**
   * 执行sql语句
   *
   * @param sql
   * @param params
   *            执行sql时的参数
   * @throws DaoException
   */
  public RowSet queryset(String sql, Object[] params) throws DataBaseAccessException {

      Connection conn = null;
      PreparedStatement stmt = null;
      ResultSet rs = null;
      CachedRowSetImpl crs = null;
      try {
          conn = getConnection();
          stmt = conn.prepareStatement(sql);
          fillParams(stmt, params);
          rs = stmt.executeQuery();
          //CachedRowSetImpl:
          //1. CachedRowSet 对象是可序列化的
          //2. 保存在其中的数据不会随着数据库和ResultSet的连接的关闭而丢失,可以传递.
          crs = new CachedRowSetImpl();
          //crs.populate(new ResultSetWrapper(rs));
          crs.populate(rs);
      } catch (Exception e) {
          logger.error(sql, e);
          throw new DataBaseAccessException("query error", e);
      } finally {
          releaseConnection(rs, stmt, conn);
      }
      return crs;
  }

  /**
   * 数据库批量处理.
   *
   * @param sql The sql to be executed
   * @param params The parameters for PreparedStatement
   * @return  an array of update counts containing one element for each
   * command in the batch.
   * @throws DataBaseAccessException
   */
  public int[] executeBatch(String sql, Object[][] params) throws DataBaseAccessException {
      Connection connection = null;
      PreparedStatement ps = null;
      try {
          connection = getConnection();
          ps = connection.prepareStatement(sql);
          for (int i = 0; i < params.length; i++) {
              fillParams(ps, params[i]);
              ps.addBatch();
          }
          return ps.executeBatch();
      } catch (Exception e) {
          logger.error(getClass().getName(), e);
          throw new DataBaseAccessException("batch error", e);
      } finally {
          try {
              if (connection != null) {
                  connection.commit();
                  connection.setAutoCommit(true);
              }
          } catch (Exception e) {
              logger.error(getClass().getName(), e);
              throw new DataBaseAccessException("batch error", e);
          }
          releaseConnection(null, ps, connection);
      }
  }

  /**
   * 数据库批量处理
   *
   * @param sql
   * @param params
   * @return
   * @throws DataBaseAccessException
   */
  public PreparedStatement executeBatch(String sql, Object[][] params, Connection conn) throws Exception {
      PreparedStatement ps = null;

      conn = getConnection();
      ps = conn.prepareStatement(sql);
      for (int i = 0; i < params.length; i++) {
          fillParams(ps, params[i]);
          ps.addBatch();
      }
      ps.executeBatch();

      return ps;

  }

  public void fillParams(PreparedStatement ps, Object[] params) throws DataBaseAccessException {
      if (params != null && params.length != 0) {
          for (int i = 0; i < params.length; i++) {
              try {
                  if (params[i] == null) {
                      ps.setNull(i + 1, Types.VARCHAR);
                  } else {
                      ps.setObject(i + 1, params[i]);
                  }
              } catch (Exception e) {
                  logger.error(getClass().getName(), e);
                  throw new DataBaseAccessException("params error", e);
              }
          }
      }
  }

  public void releaseConnection(ResultSet rs, Statement stmt, Connection connection) throws DataBaseAccessException {
      try {
          if (rs != null) {
              rs.close();
          }
          if (stmt != null) {
              stmt.close();
          }
          if (connection != null) {
              connection.close();
          }
      } catch (Exception e) {
          logger.error(getClass().getName(), e);
          throw new DataBaseAccessException("conncention close error", e);
      }
  }

  public void releaseConnection(ResultSet rs, Statement[] stmt, Connection connection)
          throws DataBaseAccessException {
      try {

          if (rs != null) {
              rs.close();
          }
          if (stmt != null) {
              for (int i = 0; i < stmt.length; i++) {
                  if (stmt[i] != null)
                      stmt[i].close();
              }
          }
          if (connection != null) {
              connection.close();
          }
      } catch (Exception e) {
          logger.error(getClass().getName(), e);
          throw new DataBaseAccessException("conncention close error", e);
      }
  }

  public void rollback(Connection conn) throws DataBaseAccessException
  {
      try {
          if(conn!=null)
          conn.rollback();
      } catch (SQLException e) {
          logger.error(getClass().getName(), e);
          throw new DataBaseAccessException("rollback error", e);
      }
  }

  public void commit(Connection conn, Statement[] stmt) throws DataBaseAccessException {
      try {
          if (conn != null) {
              conn.commit();
              conn.setAutoCommit(true);
          }
      } catch (Exception e) {
          logger.error(getClass().getName(), e);
          throw new DataBaseAccessException("commit error", e);
      }
      releaseConnection(null, stmt,conn);
  }
}


text:
// Copyright 2016 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

/**
 * @fileoverview certificate-subentry represents an SSL certificate sub-entry.
 */

import '../../cr_elements/cr_action_menu/cr_action_menu.js';
import '../../cr_elements/cr_icon_button/cr_icon_button.m.js';
import '../../cr_elements/cr_lazy_render/cr_lazy_render.m.js';
import '../../cr_elements/policy/cr_policy_indicator.m.js';
import '../../cr_elements/icons.m.js';
import './certificate_shared_css.js';

import {html, PolymerElement} from 'chrome://resources/polymer/v3_0/polymer/polymer_bundled.min.js';

import {CrActionMenuElement} from '../../cr_elements/cr_action_menu/cr_action_menu.js';
import {CrLazyRenderElement} from '../../cr_elements/cr_lazy_render/cr_lazy_render.m.js';
import {CrPolicyIndicatorType} from '../../cr_elements/policy/cr_policy_indicator_behavior.m.js';
import {I18nMixin} from '../../js/i18n_mixin.js';

import {CertificateAction, CertificateActionEvent, CertificateActionEventDetail} from './certificate_manager_types.js';
import {CertificatesBrowserProxy, CertificatesBrowserProxyImpl, CertificatesError, CertificateSubnode, CertificateType} from './certificates_browser_proxy.js';

export interface CertificateSubentryElement {
  $: {
    menu: CrLazyRenderElement<CrActionMenuElement>,
    dots: HTMLElement,
  };
}

const CertificateSubentryElementBase = I18nMixin(PolymerElement);

export class CertificateSubentryElement extends CertificateSubentryElementBase {
  static get is() {
    return 'certificate-subentry';
  }

  static get template() {
    return html`{__html_template__}`;
  }

  static get properties() {
    return {
      model: Object,
      certificateType: String,
    };
  }

  model: CertificateSubnode;
  certificateType: CertificateType;
  private browserProxy_: CertificatesBrowserProxy =
      CertificatesBrowserProxyImpl.getInstance();

  /**
   * Dispatches an event indicating which certificate action was tapped. It is
   * used by the parent of this element to display a modal dialog accordingly.
   */
  private dispatchCertificateActionEvent_(action: CertificateAction) {
    this.dispatchEvent(new CustomEvent(CertificateActionEvent, {
      bubbles: true,
      composed: true,
      detail: {
        action: action,
        subnode: this.model,
        certificateType: this.certificateType,
        anchor: this.$.dots,
      },
    }));
  }

  /**
   * Handles the case where a call to the browser resulted in a rejected
   * promise.
   */
  private onRejected_(error: CertificatesError|null) {
    if (error === null) {
      // Nothing to do here. Null indicates that the user clicked "cancel" on
      // the native file chooser dialog.
      return;
    }

    // Otherwise propagate the error to the parents, such that a dialog
    // displaying the error will be shown.
    this.dispatchEvent(new CustomEvent('certificates-error', {
      bubbles: true,
      composed: true,
      detail: {error, anchor: null},
    }));
  }

  private onViewClick_() {
    this.closePopupMenu_();
    this.browserProxy_.viewCertificate(this.model.id);
  }

  private onEditClick_() {
    this.closePopupMenu_();
    this.dispatchCertificateActionEvent_(CertificateAction.EDIT);
  }

  private onDeleteClick_() {
    this.closePopupMenu_();
    this.dispatchCertificateActionEvent_(CertificateAction.DELETE);
  }

  private onExportClick_() {
    this.closePopupMenu_();
    if (this.certificateType === CertificateType.PERSONAL) {
      this.browserProxy_.exportPersonalCertificate(this.model.id).then(() => {
        this.dispatchCertificateActionEvent_(CertificateAction.EXPORT_PERSONAL);
      }, this.onRejected_.bind(this));
    } else {
      this.browserProxy_.exportCertificate(this.model.id);
    }
  }

  /**
   * @return Whether the certificate can be edited.
   */
  private canEdit_(model: CertificateSubnode): boolean {
    return model.canBeEdited;
  }

  /**
   * @return Whether the certificate can be exported.
   */
  private canExport_(
      certificateType: CertificateType, model: CertificateSubnode): boolean {
    if (certificateType === CertificateType.PERSONAL) {
      return model.extractable;
    }
    return true;
  }

  /**
   * @return Whether the certificate can be deleted.
   */
  private canDelete_(model: CertificateSubnode): boolean {
    return model.canBeDeleted;
  }

  private closePopupMenu_() {
    this.shadowRoot!.querySelector('cr-action-menu')!.close();
  }

  private onDotsClick_() {
    this.$.menu.get().showAt(this.$.dots);
  }

  private getPolicyIndicatorType_(model: CertificateSubnode):
      CrPolicyIndicatorType {
    return model.policy ? CrPolicyIndicatorType.USER_POLICY :
                          CrPolicyIndicatorType.NONE;
  }
}

customElements.define(
    CertificateSubentryElement.is, CertificateSubentryElement);


text:
package org.apache.pulsar.functions.instance;

import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.Getter;
import lombok.Setter;
import lombok.ToString;
import org.apache.pulsar.functions.proto.Function.FunctionConfig;

/**
 * This is the config passed to the Java Instance. Contains all the information
 * passed to run functions
 */
@Data
@Getter
@Setter
@EqualsAndHashCode
@ToString
public class InstanceConfig {
    private String instanceId;
    private String functionId;
    private String functionVersion;
    private FunctionConfig functionConfig;
    private int maxBufferedTuples;
}


text:
/**
 * The Scene Systems Start Event.
 *
 * This event is dispatched by a Scene during the Scene Systems start process. Primarily used by Scene Plugins.
 *
 * Listen to it from a Scene using `this.events.on('start', listener)`.
 *
 * @event Phaser.Scenes.Events#START
 * @type {string}
 * @since 3.0.0
 *
 * @param {Phaser.Scenes.Systems} sys - A reference to the Scene Systems class of the Scene that emitted this event.
 */
module.exports = 'start';