text:
//
// This file was generated by the JavaTM Architecture for XML Binding(JAXB) Reference Implementation, v2.0.5-b02-fcs
// See http://java.sun.com/xml/jaxb
// Any modifications to this file will be lost upon recompilation of the source schema.
// Generated on: 2008.06.17 at 03:33:40 PM PDT
//

package com.acl.ax.datasource.mapsdk.xml.binding;

import javax.xml.bind.annotation.XmlAccessType;
import javax.xml.bind.annotation.XmlAccessorType;
import javax.xml.bind.annotation.XmlAttribute;
import javax.xml.bind.annotation.XmlElement;
import javax.xml.bind.annotation.XmlRootElement;
import javax.xml.bind.annotation.XmlType;
import javax.xml.bind.annotation.adapters.CollapsedStringAdapter;
import javax.xml.bind.annotation.adapters.XmlJavaTypeAdapter;

/**
 *
 */
@XmlAccessorType(XmlAccessType.FIELD)
@XmlType(name = "", propOrder = {
    "recurring",
    "custom"
})
@XmlRootElement(name = "SCHEDULEOPTIONS")
public class SCHEDULEOPTIONS {

    @XmlAttribute(name = "SCHEDULETYPE", required = true)
    @XmlJavaTypeAdapter(CollapsedStringAdapter.class)
    protected String scheduletype;
    @XmlElement(name = "RECURRING")
    protected RECURRING recurring;
    @XmlElement(name = "CUSTOM")
    protected CUSTOM custom;

    /**
     * Gets the value of the scheduletype property.
     *
     * @return
     *     possible object is
     *     {@link String }
     *
     */
    public String getSCHEDULETYPE() {
        return scheduletype;
    }

    /**
     * Sets the value of the scheduletype property.
     *
     * @param value
     *     allowed object is
     *     {@link String }
     *
     */
    public void setSCHEDULETYPE(String value) {
        this.scheduletype = value;
    }

    /**
     * Gets the value of the recurring property.
     *
     * @return
     *     possible object is
     *     {@link RECURRING }
     *
     */
    public RECURRING getRECURRING() {
        return recurring;
    }

    /**
     * Sets the value of the recurring property.
     *
     * @param value
     *     allowed object is
     *     {@link RECURRING }
     *
     */
    public void setRECURRING(RECURRING value) {
        this.recurring = value;
    }

    /**
     * Gets the value of the custom property.
     *
     * @return
     *     possible object is
     *     {@link CUSTOM }
     *
     */
    public CUSTOM getCUSTOM() {
        return custom;
    }

    /**
     * Sets the value of the custom property.
     *
     * @param value
     *     allowed object is
     *     {@link CUSTOM }
     *
     */
    public void setCUSTOM(CUSTOM value) {
        this.custom = value;
    }

}


text:
package org.lightadmin.core.test;

import org.lightadmin.core.util.LightAdminConfigurationUtils;
import org.springframework.context.support.GenericApplicationContext;
import org.springframework.mock.env.MockPropertySource;
import org.springframework.test.context.support.AnnotationConfigContextLoader;

public class LightAdminConfigurationContextLoader extends AnnotationConfigContextLoader {

	private static final String CONFIGURATIONS_BASE_PACKAGE = "org.lightadmin.core.test.config";

	@Override
	protected void customizeContext( final GenericApplicationContext context ) {
		MockPropertySource mockPropertySource = new MockPropertySource();
		mockPropertySource.setProperty( LightAdminConfigurationUtils.LIGHT_ADMINISTRATION_BASE_PACKAGE, CONFIGURATIONS_BASE_PACKAGE );
		context.getEnvironment().getPropertySources().addFirst( mockPropertySource );
	}
}

redpajama_set_name: RedPajamaGithub


text:
from PyQt5 import QtCore, QtGui, QtWidgets

class Ui_WdgAppMainView(object):
    def setupUi(self, WdgAppMainView):
        WdgAppMainView.setObjectName("WdgAppMainView")
        WdgAppMainView.resize(840, 460)
        self.verticalLayout_6 = QtWidgets.QVBoxLayout(WdgAppMainView)
        self.verticalLayout_6.setContentsMargins(0, 0, 0, 0)
        self.verticalLayout_6.setSpacing(6)
        self.verticalLayout_6.setObjectName("verticalLayout_6")
        self.pnlNavigation = QtWidgets.QFrame(WdgAppMainView)
        self.pnlNavigation.setStyleSheet("QLabel#lblNavigation1, QLabel#lblNavigation2, QLabel#lblNavigation3 {\n"
"  padding: 2px;\n"
"  border: 1px solid lightgray;\n"
"  border-radius: 2px;\n"
"  background-color: lightgray;\n"
"}")
        self.pnlNavigation.setFrameShape(QtWidgets.QFrame.NoFrame)
        self.pnlNavigation.setFrameShadow(QtWidgets.QFrame.Raised)
        self.pnlNavigation.setObjectName("pnlNavigation")
        self.horizontalLayout = QtWidgets.QHBoxLayout(self.pnlNavigation)
        self.horizontalLayout.setContentsMargins(0, 0, 0, 0)
        self.horizontalLayout.setSpacing(4)
        self.horizontalLayout.setObjectName("horizontalLayout")
        self.lblNavigation1 = QtWidgets.QLabel(self.pnlNavigation)
        self.lblNavigation1.setStyleSheet("")
        self.lblNavigation1.setText("")
        self.lblNavigation1.setOpenExternalLinks(False)
        self.lblNavigation1.setObjectName("lblNavigation1")
        self.horizontalLayout.addWidget(self.lblNavigation1)
        self.lblNavigation2 = QtWidgets.QLabel(self.pnlNavigation)
        self.lblNavigation2.setStyleSheet("")
        self.lblNavigation2.setText("")
        self.lblNavigation2.setOpenExternalLinks(False)
        self.lblNavigation2.setObjectName("lblNavigation2")
        self.horizontalLayout.addWidget(self.lblNavigation2)
        self.lblNavigation3 = QtWidgets.QLabel(self.pnlNavigation)
        self.lblNavigation3.setStyleSheet("")
        self.lblNavigation3.setText("")
        self.lblNavigation3.setObjectName("lblNavigation3")
        self.horizontalLayout.addWidget(self.lblNavigation3)
        spacerItem = QtWidgets.QSpacerItem(20, 20, QtWidgets.QSizePolicy.Fixed, QtWidgets.QSizePolicy.Minimum)
        self.horizontalLayout.addItem(spacerItem)
        self.btnRefreshMnStatus = QtWidgets.QPushButton(self.pnlNavigation)
        self.btnRefreshMnStatus.setObjectName("btnRefreshMnStatus")
        self.horizontalLayout.addWidget(self.btnRefreshMnStatus)
        self.btnMnActions = QtWidgets.QPushButton(self.pnlNavigation)
        self.btnMnActions.setObjectName("btnMnActions")
        self.horizontalLayout.addWidget(self.btnMnActions)
        self.btnMnListColumns = QtWidgets.QPushButton(self.pnlNavigation)
        self.btnMnListColumns.setObjectName("btnMnListColumns")
        self.horizontalLayout.addWidget(self.btnMnListColumns)
        self.btnMoveMnUp = QtWidgets.QPushButton(self.pnlNavigation)
        self.btnMoveMnUp.setMaximumSize(QtCore.QSize(40, 16777215))
        self.btnMoveMnUp.setText("")
        self.btnMoveMnUp.setObjectName("btnMoveMnUp")
        self.horizontalLayout.addWidget(self.btnMoveMnUp)
        self.btnMoveMnDown = QtWidgets.QPushButton(self.pnlNavigation)
        self.btnMoveMnDown.setMaximumSize(QtCore.QSize(40, 16777215))
        self.btnMoveMnDown.setText("")
        self.btnMoveMnDown.setObjectName("btnMoveMnDown")
        self.horizontalLayout.addWidget(self.btnMoveMnDown)
        self.lblMnListMessage = QtWidgets.QLabel(self.pnlNavigation)
        self.lblMnListMessage.setText("")
        self.lblMnListMessage.setObjectName("lblMnListMessage")
        self.horizontalLayout.addWidget(self.lblMnListMessage)
        spacerItem1 = QtWidgets.QSpacerItem(40, 20, QtWidgets.QSizePolicy.Expanding, QtWidgets.QSizePolicy.Minimum)
        self.horizontalLayout.addItem(spacerItem1)
        self.verticalLayout_6.addWidget(self.pnlNavigation)
        self.frmMain = QtWidgets.QFrame(WdgAppMainView)
        self.frmMain.setFrameShape(QtWidgets.QFrame.StyledPanel)
        self.frmMain.setFrameShadow(QtWidgets.QFrame.Raised)
        self.frmMain.setObjectName("frmMain")
        self.verticalLayout = QtWidgets.QVBoxLayout(self.frmMain)
        self.verticalLayout.setContentsMargins(6, 6, 6, 6)
        self.verticalLayout.setSpacing(6)
        self.verticalLayout.setObjectName("verticalLayout")
        self.stackedWidget = QtWidgets.QStackedWidget(self.frmMain)
        self.stackedWidget.setObjectName("stackedWidget")
        self.pageNetworkInfo = QtWidgets.QWidget()
        self.pageNetworkInfo.setObjectName("pageNetworkInfo")
        self.verticalLayout_5 = QtWidgets.QVBoxLayout(self.pageNetworkInfo)
        self.verticalLayout_5.setContentsMargins(0, 0, 0, 0)
        self.verticalLayout_5.setSpacing(6)
        self.verticalLayout_5.setObjectName("verticalLayout_5")
        self.lblNetworkInfo = QtWidgets.QLabel(self.pageNetworkInfo)
        self.lblNetworkInfo.setText("")
        self.lblNetworkInfo.setTextInteractionFlags(QtCore.Qt.LinksAccessibleByMouse|QtCore.Qt.TextSelectableByMouse)
        self.lblNetworkInfo.setObjectName("lblNetworkInfo")
        self.verticalLayout_5.addWidget(self.lblNetworkInfo)
        spacerItem2 = QtWidgets.QSpacerItem(20, 40, QtWidgets.QSizePolicy.Minimum, QtWidgets.QSizePolicy.Expanding)
        self.verticalLayout_5.addItem(spacerItem2)
        self.stackedWidget.addWidget(self.pageNetworkInfo)
        self.pageMasternodeList = QtWidgets.QWidget()
        self.pageMasternodeList.setObjectName("pageMasternodeList")
        self.verticalLayout_4 = QtWidgets.QVBoxLayout(self.pageMasternodeList)
        self.verticalLayout_4.setContentsMargins(0, 0, 0, 0)
        self.verticalLayout_4.setSpacing(6)
        self.verticalLayout_4.setObjectName("verticalLayout_4")
        self.viewMasternodes = QtWidgets.QTableView(self.pageMasternodeList)
        self.viewMasternodes.setEditTriggers(QtWidgets.QAbstractItemView.AnyKeyPressed|QtWidgets.QAbstractItemView.EditKeyPressed)
        self.viewMasternodes.setProperty("showDropIndicator", False)
        self.viewMasternodes.setSelectionMode(QtWidgets.QAbstractItemView.SingleSelection)
        self.viewMasternodes.setSelectionBehavior(QtWidgets.QAbstractItemView.SelectRows)
        self.viewMasternodes.setShowGrid(False)
        self.viewMasternodes.setObjectName("viewMasternodes")
        self.viewMasternodes.verticalHeader().setVisible(False)
        self.viewMasternodes.verticalHeader().setSortIndicatorShown(False)
        self.verticalLayout_4.addWidget(self.viewMasternodes)
        self.lblNoMasternodeMessage = QtWidgets.QLabel(self.pageMasternodeList)
        self.lblNoMasternodeMessage.setStyleSheet("QLabel{\n"
"  margin-top: 10px;\n"
"}")
        self.lblNoMasternodeMessage.setText("")
        self.lblNoMasternodeMessage.setAlignment(QtCore.Qt.AlignLeading|QtCore.Qt.AlignLeft|QtCore.Qt.AlignTop)
        self.lblNoMasternodeMessage.setObjectName("lblNoMasternodeMessage")
        self.verticalLayout_4.addWidget(self.lblNoMasternodeMessage)
        self.stackedWidget.addWidget(self.pageMasternodeList)
        self.pageSingleMasternode = QtWidgets.QWidget()
        self.pageSingleMasternode.setObjectName("pageSingleMasternode")
        self.verticalLayout_3 = QtWidgets.QVBoxLayout(self.pageSingleMasternode)
        self.verticalLayout_3.setContentsMargins(0, 0, 0, 0)
        self.verticalLayout_3.setSpacing(6)
        self.verticalLayout_3.setObjectName("verticalLayout_3")
        self.frmMasternodeDetails = QtWidgets.QFrame(self.pageSingleMasternode)
        self.frmMasternodeDetails.setFrameShape(QtWidgets.QFrame.NoFrame)
        self.frmMasternodeDetails.setFrameShadow(QtWidgets.QFrame.Plain)
        self.frmMasternodeDetails.setObjectName("frmMasternodeDetails")
        self.verticalLayout_2 = QtWidgets.QVBoxLayout(self.frmMasternodeDetails)
        self.verticalLayout_2.setContentsMargins(0, 0, 0, 0)
        self.verticalLayout_2.setSpacing(6)
        self.verticalLayout_2.setObjectName("verticalLayout_2")
        self.layMasternodesControl = QtWidgets.QHBoxLayout()
        self.layMasternodesControl.setContentsMargins(0, 0, 0, 0)
        self.layMasternodesControl.setSpacing(3)
        self.layMasternodesControl.setObjectName("layMasternodesControl")
        self.btnEditMn = QtWidgets.QPushButton(self.frmMasternodeDetails)
        sizePolicy = QtWidgets.QSizePolicy(QtWidgets.QSizePolicy.Minimum, QtWidgets.QSizePolicy.Fixed)
        sizePolicy.setHorizontalStretch(0)
        sizePolicy.setVerticalStretch(0)
        sizePolicy.setHeightForWidth(self.btnEditMn.sizePolicy().hasHeightForWidth())
        self.btnEditMn.setSizePolicy(sizePolicy)
        self.btnEditMn.setMaximumSize(QtCore.QSize(16777215, 16777215))
        self.btnEditMn.setFocusPolicy(QtCore.Qt.NoFocus)
        self.btnEditMn.setObjectName("btnEditMn")
        self.layMasternodesControl.addWidget(self.btnEditMn)
        self.btnCancelEditingMn = QtWidgets.QPushButton(self.frmMasternodeDetails)
        self.btnCancelEditingMn.setFocusPolicy(QtCore.Qt.NoFocus)
        self.btnCancelEditingMn.setObjectName("btnCancelEditingMn")
        self.layMasternodesControl.addWidget(self.btnCancelEditingMn)
        self.btnApplyMnChanges = QtWidgets.QPushButton(self.frmMasternodeDetails)
        self.btnApplyMnChanges.setFocusPolicy(QtCore.Qt.NoFocus)
        self.btnApplyMnChanges.setObjectName("btnApplyMnChanges")
        self.layMasternodesControl.addWidget(self.btnApplyMnChanges)
        spacerItem3 = QtWidgets.QSpacerItem(40, 20, QtWidgets.QSizePolicy.Expanding, QtWidgets.QSizePolicy.Minimum)
        self.layMasternodesControl.addItem(spacerItem3)
        self.verticalLayout_2.addLayout(self.layMasternodesControl)
        spacerItem4 = QtWidgets.QSpacerItem(20, 353, QtWidgets.QSizePolicy.Minimum, QtWidgets.QSizePolicy.Expanding)
        self.verticalLayout_2.addItem(spacerItem4)
        self.verticalLayout_3.addWidget(self.frmMasternodeDetails)
        self.stackedWidget.addWidget(self.pageSingleMasternode)
        self.verticalLayout.addWidget(self.stackedWidget)
        self.verticalLayout_6.addWidget(self.frmMain)
        self.lblMnStatusLabel = QtWidgets.QLabel(WdgAppMainView)
        self.lblMnStatusLabel.setObjectName("lblMnStatusLabel")
        self.verticalLayout_6.addWidget(self.lblMnStatusLabel)
        self.lblMnStatus = QtWidgets.QLabel(WdgAppMainView)
        self.lblMnStatus.setStyleSheet("")
        self.lblMnStatus.setFrameShape(QtWidgets.QFrame.StyledPanel)
        self.lblMnStatus.setFrameShadow(QtWidgets.QFrame.Sunken)
        self.lblMnStatus.setText("")
        self.lblMnStatus.setWordWrap(False)
        self.lblMnStatus.setOpenExternalLinks(False)
        self.lblMnStatus.setTextInteractionFlags(QtCore.Qt.LinksAccessibleByMouse|QtCore.Qt.TextSelectableByMouse)
        self.lblMnStatus.setObjectName("lblMnStatus")
        self.verticalLayout_6.addWidget(self.lblMnStatus)

        self.retranslateUi(WdgAppMainView)
        self.stackedWidget.setCurrentIndex(1)
        QtCore.QMetaObject.connectSlotsByName(WdgAppMainView)

    def retranslateUi(self, WdgAppMainView):
        _translate = QtCore.QCoreApplication.translate
        WdgAppMainView.setWindowTitle(_translate("WdgAppMainView", "Form"))
        self.btnRefreshMnStatus.setText(_translate("WdgAppMainView", "Refresh status"))
        self.btnMnActions.setText(_translate("WdgAppMainView", "MN actions"))
        self.btnMnListColumns.setText(_translate("WdgAppMainView", "Columns..."))
        self.btnMoveMnUp.setToolTip(_translate("WdgAppMainView", "Move up the selected masternode entry"))
        self.btnMoveMnDown.setToolTip(_translate("WdgAppMainView", "Move down the selected masternode entry"))
        self.btnEditMn.setToolTip(_translate("WdgAppMainView", "Edit masternode details"))
        self.btnEditMn.setText(_translate("WdgAppMainView", "Edit"))
        self.btnCancelEditingMn.setText(_translate("WdgAppMainView", "Cancel changes"))
        self.btnApplyMnChanges.setText(_translate("WdgAppMainView", "Apply changes"))
        self.lblMnStatusLabel.setText(_translate("WdgAppMainView", "Status details:"))


text:
.class public final Lcom/google/android/gms/ads/internal/client/AdRequestParcel;
.super Ljava/lang/Object;

# interfaces
.implements Lcom/google/android/gms/common/internal/safeparcel/SafeParcelable;

# annotations
.annotation runtime Lcom/google/android/gms/internal/zzgr;
.end annotation

# static fields
.field public static final CREATOR:Lcom/google/android/gms/ads/internal/client/zzg;

# instance fields
.field public final extras:Landroid/os/Bundle;

.field public final versionCode:I

.field public final zzsB:J

.field public final zzsC:I

.field public final zzsD:Ljava/util/List;
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "Ljava/util/List",
            "<",
            "Ljava/lang/String;",
            ">;"
        }
    .end annotation
.end field

.field public final zzsE:Z

.field public final zzsF:I

.field public final zzsG:Z

.field public final zzsH:Ljava/lang/String;

.field public final zzsI:Lcom/google/android/gms/ads/internal/client/SearchAdRequestParcel;

.field public final zzsJ:Landroid/location/Location;

.field public final zzsK:Ljava/lang/String;

.field public final zzsL:Landroid/os/Bundle;

.field public final zzsM:Landroid/os/Bundle;

.field public final zzsN:Ljava/util/List;
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "Ljava/util/List",
            "<",
            "Ljava/lang/String;",
            ">;"
        }
    .end annotation
.end field

.field public final zzsO:Ljava/lang/String;

.field public final zzsP:Ljava/lang/String;

# direct methods
.method static constructor <clinit>()V
    .registers 1

    new-instance v0, Lcom/google/android/gms/ads/internal/client/zzg;

    invoke-direct {v0}, Lcom/google/android/gms/ads/internal/client/zzg;-><init>()V

    sput-object v0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->CREATOR:Lcom/google/android/gms/ads/internal/client/zzg;

    return-void
.end method

.method public constructor <init>(IJLandroid/os/Bundle;ILjava/util/List;ZIZLjava/lang/String;Lcom/google/android/gms/ads/internal/client/SearchAdRequestParcel;Landroid/location/Location;Ljava/lang/String;Landroid/os/Bundle;Landroid/os/Bundle;Ljava/util/List;Ljava/lang/String;Ljava/lang/String;)V
    .registers 21
    .param p1, "versionCode"    # I
    .param p2, "birthday"    # J
    .param p4, "extras"    # Landroid/os/Bundle;
    .param p5, "gender"    # I
    .param p7, "isTestDevice"    # Z
    .param p8, "tagForChildDirectedTreatment"    # I
    .param p9, "manualImpressionsEnabled"    # Z
    .param p10, "publisherProvidedId"    # Ljava/lang/String;
    .param p11, "searchAdRequestParcel"    # Lcom/google/android/gms/ads/internal/client/SearchAdRequestParcel;
    .param p12, "location"    # Landroid/location/Location;
    .param p13, "contentUrl"    # Ljava/lang/String;
    .param p14, "networkExtras"    # Landroid/os/Bundle;
    .param p15, "customTargeting"    # Landroid/os/Bundle;
    .param p17, "requestAgent"    # Ljava/lang/String;
    .param p18, "requestPackage"    # Ljava/lang/String;
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(IJ",
            "Landroid/os/Bundle;",
            "I",
            "Ljava/util/List",
            "<",
            "Ljava/lang/String;",
            ">;ZIZ",
            "Ljava/lang/String;",
            "Lcom/google/android/gms/ads/internal/client/SearchAdRequestParcel;",
            "Landroid/location/Location;",
            "Ljava/lang/String;",
            "Landroid/os/Bundle;",
            "Landroid/os/Bundle;",
            "Ljava/util/List",
            "<",
            "Ljava/lang/String;",
            ">;",
            "Ljava/lang/String;",
            "Ljava/lang/String;",
            ")V"
        }
    .end annotation

    .prologue
    .local p6, "keywords":Ljava/util/List;, "Ljava/util/List<Ljava/lang/String;>;"
    .local p16, "categoryExclusions":Ljava/util/List;, "Ljava/util/List<Ljava/lang/String;>;"
    invoke-direct {p0}, Ljava/lang/Object;-><init>()V

    iput p1, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->versionCode:I

    iput-wide p2, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsB:J

    if-nez p4, :cond_e

    new-instance p4, Landroid/os/Bundle;

    .end local p4    # "extras":Landroid/os/Bundle;
    invoke-direct {p4}, Landroid/os/Bundle;-><init>()V

    :cond_e
    iput-object p4, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->extras:Landroid/os/Bundle;

    iput p5, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsC:I

    iput-object p6, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsD:Ljava/util/List;

    iput-boolean p7, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsE:Z

    iput p8, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsF:I

    iput-boolean p9, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsG:Z

    iput-object p10, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsH:Ljava/lang/String;

    iput-object p11, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsI:Lcom/google/android/gms/ads/internal/client/SearchAdRequestParcel;

    iput-object p12, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsJ:Landroid/location/Location;

    iput-object p13, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsK:Ljava/lang/String;

    move-object/from16 v0, p14

    iput-object v0, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsL:Landroid/os/Bundle;

    move-object/from16 v0, p15

    iput-object v0, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsM:Landroid/os/Bundle;

    move-object/from16 v0, p16

    iput-object v0, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsN:Ljava/util/List;

    move-object/from16 v0, p17

    iput-object v0, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsO:Ljava/lang/String;

    move-object/from16 v0, p18

    iput-object v0, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsP:Ljava/lang/String;

    return-void
.end method

# virtual methods
.method public describeContents()I
    .registers 2

    const/4 v0, 0x0

    return v0
.end method

.method public equals(Ljava/lang/Object;)Z
    .registers 8
    .param p1, "other"    # Ljava/lang/Object;

    .prologue
    const/4 v0, 0x0

    instance-of v1, p1, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;

    if-nez v1, :cond_6

    .end local p1    # "other":Ljava/lang/Object;
    :cond_5
    :goto_5
    return v0

    .restart local p1    # "other":Ljava/lang/Object;
    :cond_6
    check-cast p1, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;

    .end local p1    # "other":Ljava/lang/Object;
    iget v1, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->versionCode:I

    iget v2, p1, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->versionCode:I

    if-ne v1, v2, :cond_5

    iget-wide v2, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsB:J

    iget-wide v4, p1, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsB:J

    cmp-long v1, v2, v4

    if-nez v1, :cond_5

    iget-object v1, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->extras:Landroid/os/Bundle;

    iget-object v2, p1, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->extras:Landroid/os/Bundle;

    invoke-static {v1, v2}, Lcom/google/android/gms/common/internal/zzw;->equal(Ljava/lang/Object;Ljava/lang/Object;)Z

    move-result v1

    if-eqz v1, :cond_5

    iget v1, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsC:I

    iget v2, p1, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsC:I

    if-ne v1, v2, :cond_5

    iget-object v1, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsD:Ljava/util/List;

    iget-object v2, p1, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsD:Ljava/util/List;

    invoke-static {v1, v2}, Lcom/google/android/gms/common/internal/zzw;->equal(Ljava/lang/Object;Ljava/lang/Object;)Z

    move-result v1

    if-eqz v1, :cond_5

    iget-boolean v1, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsE:Z

    iget-boolean v2, p1, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsE:Z

    if-ne v1, v2, :cond_5

    iget v1, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsF:I

    iget v2, p1, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsF:I

    if-ne v1, v2, :cond_5

    iget-boolean v1, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsG:Z

    iget-boolean v2, p1, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsG:Z

    if-ne v1, v2, :cond_5

    iget-object v1, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsH:Ljava/lang/String;

    iget-object v2, p1, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsH:Ljava/lang/String;

    invoke-static {v1, v2}, Lcom/google/android/gms/common/internal/zzw;->equal(Ljava/lang/Object;Ljava/lang/Object;)Z

    move-result v1

    if-eqz v1, :cond_5

    iget-object v1, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsI:Lcom/google/android/gms/ads/internal/client/SearchAdRequestParcel;

    iget-object v2, p1, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsI:Lcom/google/android/gms/ads/internal/client/SearchAdRequestParcel;

    invoke-static {v1, v2}, Lcom/google/android/gms/common/internal/zzw;->equal(Ljava/lang/Object;Ljava/lang/Object;)Z

    move-result v1

    if-eqz v1, :cond_5

    iget-object v1, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsJ:Landroid/location/Location;

    iget-object v2, p1, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsJ:Landroid/location/Location;

    invoke-static {v1, v2}, Lcom/google/android/gms/common/internal/zzw;->equal(Ljava/lang/Object;Ljava/lang/Object;)Z

    move-result v1

    if-eqz v1, :cond_5

    iget-object v1, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsK:Ljava/lang/String;

    iget-object v2, p1, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsK:Ljava/lang/String;

    invoke-static {v1, v2}, Lcom/google/android/gms/common/internal/zzw;->equal(Ljava/lang/Object;Ljava/lang/Object;)Z

    move-result v1

    if-eqz v1, :cond_5

    iget-object v1, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsL:Landroid/os/Bundle;

    iget-object v2, p1, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsL:Landroid/os/Bundle;

    invoke-static {v1, v2}, Lcom/google/android/gms/common/internal/zzw;->equal(Ljava/lang/Object;Ljava/lang/Object;)Z

    move-result v1

    if-eqz v1, :cond_5

    iget-object v1, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsM:Landroid/os/Bundle;

    iget-object v2, p1, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsM:Landroid/os/Bundle;

    invoke-static {v1, v2}, Lcom/google/android/gms/common/internal/zzw;->equal(Ljava/lang/Object;Ljava/lang/Object;)Z

    move-result v1

    if-eqz v1, :cond_5

    iget-object v1, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsN:Ljava/util/List;

    iget-object v2, p1, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsN:Ljava/util/List;

    invoke-static {v1, v2}, Lcom/google/android/gms/common/internal/zzw;->equal(Ljava/lang/Object;Ljava/lang/Object;)Z

    move-result v1

    if-eqz v1, :cond_5

    iget-object v1, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsO:Ljava/lang/String;

    iget-object v2, p1, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsO:Ljava/lang/String;

    invoke-static {v1, v2}, Lcom/google/android/gms/common/internal/zzw;->equal(Ljava/lang/Object;Ljava/lang/Object;)Z

    move-result v1

    if-eqz v1, :cond_5

    iget-object v1, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsP:Ljava/lang/String;

    iget-object v2, p1, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsP:Ljava/lang/String;

    invoke-static {v1, v2}, Lcom/google/android/gms/common/internal/zzw;->equal(Ljava/lang/Object;Ljava/lang/Object;)Z

    move-result v1

    if-eqz v1, :cond_5

    const/4 v0, 0x1

    goto/16 :goto_5
.end method

.method public hashCode()I
    .registers 5

    const/16 v0, 0x11

    new-array v0, v0, [Ljava/lang/Object;

    const/4 v1, 0x0

    iget v2, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->versionCode:I

    invoke-static {v2}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;

    move-result-object v2

    aput-object v2, v0, v1

    const/4 v1, 0x1

    iget-wide v2, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsB:J

    invoke-static {v2, v3}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long;

    move-result-object v2

    aput-object v2, v0, v1

    const/4 v1, 0x2

    iget-object v2, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->extras:Landroid/os/Bundle;

    aput-object v2, v0, v1

    const/4 v1, 0x3

    iget v2, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsC:I

    invoke-static {v2}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;

    move-result-object v2

    aput-object v2, v0, v1

    const/4 v1, 0x4

    iget-object v2, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsD:Ljava/util/List;

    aput-object v2, v0, v1

    const/4 v1, 0x5

    iget-boolean v2, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsE:Z

    invoke-static {v2}, Ljava/lang/Boolean;->valueOf(Z)Ljava/lang/Boolean;

    move-result-object v2

    aput-object v2, v0, v1

    const/4 v1, 0x6

    iget v2, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsF:I

    invoke-static {v2}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;

    move-result-object v2

    aput-object v2, v0, v1

    const/4 v1, 0x7

    iget-boolean v2, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsG:Z

    invoke-static {v2}, Ljava/lang/Boolean;->valueOf(Z)Ljava/lang/Boolean;

    move-result-object v2

    aput-object v2, v0, v1

    const/16 v1, 0x8

    iget-object v2, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsH:Ljava/lang/String;

    aput-object v2, v0, v1

    const/16 v1, 0x9

    iget-object v2, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsI:Lcom/google/android/gms/ads/internal/client/SearchAdRequestParcel;

    aput-object v2, v0, v1

    const/16 v1, 0xa

    iget-object v2, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsJ:Landroid/location/Location;

    aput-object v2, v0, v1

    const/16 v1, 0xb

    iget-object v2, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsK:Ljava/lang/String;

    aput-object v2, v0, v1

    const/16 v1, 0xc

    iget-object v2, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsL:Landroid/os/Bundle;

    aput-object v2, v0, v1

    const/16 v1, 0xd

    iget-object v2, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsM:Landroid/os/Bundle;

    aput-object v2, v0, v1

    const/16 v1, 0xe

    iget-object v2, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsN:Ljava/util/List;

    aput-object v2, v0, v1

    const/16 v1, 0xf

    iget-object v2, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsO:Ljava/lang/String;

    aput-object v2, v0, v1

    const/16 v1, 0x10

    iget-object v2, p0, Lcom/google/android/gms/ads/internal/client/AdRequestParcel;->zzsP:Ljava/lang/String;

    aput-object v2, v0, v1

    invoke-static {v0}, Lcom/google/android/gms/common/internal/zzw;->hashCode([Ljava/lang/Object;)I

    move-result v0

    return v0
.end method

.method public writeToParcel(Landroid/os/Parcel;I)V
    .registers 3
    .param p1, "out"    # Landroid/os/Parcel;
    .param p2, "flags"    # I

    .prologue
    invoke-static {p0, p1, p2}, Lcom/google/android/gms/ads/internal/client/zzg;->zza(Lcom/google/android/gms/ads/internal/client/AdRequestParcel;Landroid/os/Parcel;I)V

    return-void
.end method


text:
package com.navercorp.pinpoint.rpc.client;

import java.net.InetSocketAddress;
import java.net.SocketAddress;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;

import org.jboss.netty.bootstrap.ClientBootstrap;
import org.jboss.netty.channel.Channel;
import org.jboss.netty.channel.ChannelFuture;
import org.jboss.netty.channel.ChannelFutureListener;
import org.jboss.netty.channel.ChannelPipeline;
import org.jboss.netty.channel.ChannelPipelineException;
import org.jboss.netty.channel.socket.nio.NioClientBossPool;
import org.jboss.netty.channel.socket.nio.NioClientSocketChannelFactory;
import org.jboss.netty.channel.socket.nio.NioWorkerPool;
import org.jboss.netty.util.HashedWheelTimer;
import org.jboss.netty.util.ThreadNameDeterminer;
import org.jboss.netty.util.Timeout;
import org.jboss.netty.util.Timer;
import org.jboss.netty.util.TimerTask;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.navercorp.pinpoint.common.util.PinpointThreadFactory;
import com.navercorp.pinpoint.rpc.MessageListener;
import com.navercorp.pinpoint.rpc.PinpointSocketException;
import com.navercorp.pinpoint.rpc.StateChangeEventListener;
import com.navercorp.pinpoint.rpc.cluster.ClusterOption;
import com.navercorp.pinpoint.rpc.cluster.Role;
import com.navercorp.pinpoint.rpc.stream.DisabledServerStreamChannelMessageListener;
import com.navercorp.pinpoint.rpc.stream.ServerStreamChannelMessageListener;
import com.navercorp.pinpoint.rpc.util.AssertUtils;
import com.navercorp.pinpoint.rpc.util.LoggerFactorySetup;
import com.navercorp.pinpoint.rpc.util.TimerFactory;

/**
 * @author emeroad
 * @author koo.taejin
 */
public class PinpointClientFactory {

    private final Logger logger = LoggerFactory.getLogger(this.getClass());

    public static final String CONNECT_TIMEOUT_MILLIS = "connectTimeoutMillis";
    private static final int DEFAULT_CONNECT_TIMEOUT = 5000;
    private static final long DEFAULT_TIMEOUTMILLIS = 3 * 1000;
    private static final long DEFAULT_PING_DELAY = 60 * 1000 * 5;
    private static final long DEFAULT_ENABLE_WORKER_PACKET_DELAY = 60 * 1000 * 1;

    private final AtomicInteger socketId = new AtomicInteger(1);

    private volatile boolean released;
    private ClientBootstrap bootstrap;
    private Map<String, Object> properties = Collections.emptyMap();

    private long reconnectDelay = 3 * 1000;
    private final Timer timer;

    // it's better to be a long value. even though keeping ping period from client to server short,
    // disconnection between them dose not be detected quickly.
    // rather keeping it from server to client short help detect disconnection as soon as possible.
    private long pingDelay = DEFAULT_PING_DELAY;
    private long enableWorkerPacketDelay = DEFAULT_ENABLE_WORKER_PACKET_DELAY;
    private long timeoutMillis = DEFAULT_TIMEOUTMILLIS;

    private ClusterOption clusterOption = ClusterOption.DISABLE_CLUSTER_OPTION;

    private MessageListener messageListener = SimpleMessageListener.INSTANCE;
    private List<StateChangeEventListener> stateChangeEventListeners = new ArrayList<StateChangeEventListener>();
    private ServerStreamChannelMessageListener serverStreamChannelMessageListener = DisabledServerStreamChannelMessageListener.INSTANCE;

    static {
        LoggerFactorySetup.setupSlf4jLoggerFactory();
    }

    public PinpointClientFactory() {
        this(1, 1);
    }

    public PinpointClientFactory(int bossCount, int workerCount) {
        if (bossCount < 1) {
            throw new IllegalArgumentException("bossCount is negative: " + bossCount);
        }

        // create a timer earlier because it is used for connectTimeout
        Timer timer = createTimer();
        ClientBootstrap bootstrap = createBootStrap(bossCount, workerCount, timer);
        setOptions(bootstrap);
        addPipeline(bootstrap);

        this.bootstrap = bootstrap;
        this.timer = timer;
    }

    private Timer createTimer() {
        HashedWheelTimer timer = TimerFactory.createHashedWheelTimer("Pinpoint-SocketFactory-Timer", 100, TimeUnit.MILLISECONDS, 512);
        timer.start();
        return timer;
    }

    private void addPipeline(ClientBootstrap bootstrap) {
        PinpointClientPipelineFactory pinpointClientPipelineFactory = new PinpointClientPipelineFactory(this);
        bootstrap.setPipelineFactory(pinpointClientPipelineFactory);
    }

    private void setOptions(ClientBootstrap bootstrap) {
        // connectTimeout
        bootstrap.setOption(CONNECT_TIMEOUT_MILLIS, DEFAULT_CONNECT_TIMEOUT);
        // read write timeout needed?  isn't it needed because of nio?

        // tcp setting
        bootstrap.setOption("tcpNoDelay", true);
        bootstrap.setOption("keepAlive", true);
        // buffer setting
        bootstrap.setOption("sendBufferSize", 1024 * 64);
        bootstrap.setOption("receiveBufferSize", 1024 * 64);

    }

    public void setConnectTimeout(int connectTimeout) {
        if (connectTimeout < 0) {
            throw new IllegalArgumentException("connectTimeout cannot be a negative number");
        }
        bootstrap.setOption(CONNECT_TIMEOUT_MILLIS, connectTimeout);
    }

    public int getConnectTimeout() {
        return (Integer) bootstrap.getOption(CONNECT_TIMEOUT_MILLIS);
    }

    public long getReconnectDelay() {
        return reconnectDelay;
    }

    public void setReconnectDelay(long reconnectDelay) {
        if (reconnectDelay < 0) {
            throw new IllegalArgumentException("reconnectDelay cannot be a negative number");
        }
        this.reconnectDelay = reconnectDelay;
    }

    public long getPingDelay() {
        return pingDelay;
    }

    public void setPingDelay(long pingDelay) {
        if (pingDelay < 0) {
            throw new IllegalArgumentException("pingDelay cannot be a negative number");
        }
        this.pingDelay = pingDelay;
    }

    public long getEnableWorkerPacketDelay() {
        return enableWorkerPacketDelay;
    }

    public void setEnableWorkerPacketDelay(long enableWorkerPacketDelay) {
        if (enableWorkerPacketDelay < 0) {
            throw new IllegalArgumentException("EnableWorkerPacketDelay cannot be a negative number");
        }
         this.enableWorkerPacketDelay = enableWorkerPacketDelay;
    }

    public long getTimeoutMillis() {
        return timeoutMillis;
    }

    public void setTimeoutMillis(long timeoutMillis) {
        if (timeoutMillis < 0) {
            throw new IllegalArgumentException("timeoutMillis cannot be a negative number");
        }
        this.timeoutMillis = timeoutMillis;
    }

    private ClientBootstrap createBootStrap(int bossCount, int workerCount, Timer timer) {
        // profiler, collector,
        logger.debug("createBootStrap boss:{}, worker:{}", bossCount, workerCount);
        NioClientSocketChannelFactory nioClientSocketChannelFactory = createChannelFactory(bossCount, workerCount, timer);
        return new ClientBootstrap(nioClientSocketChannelFactory);
    }

    private NioClientSocketChannelFactory createChannelFactory(int bossCount, int workerCount, Timer timer) {
        ExecutorService boss = Executors.newCachedThreadPool(new PinpointThreadFactory("Pinpoint-Client-Boss", true));
        NioClientBossPool bossPool = new NioClientBossPool(boss, bossCount, timer, ThreadNameDeterminer.CURRENT);

        ExecutorService worker = Executors.newCachedThreadPool(new PinpointThreadFactory("Pinpoint-Client-Worker", true));
        NioWorkerPool workerPool = new NioWorkerPool(worker, workerCount, ThreadNameDeterminer.CURRENT);
        return new NioClientSocketChannelFactory(bossPool, workerPool);
    }

    public PinpointClient connect(String host, int port) throws PinpointSocketException {
        InetSocketAddress connectAddress = new InetSocketAddress(host, port);
        return connect(connectAddress);
    }

    public PinpointClient connect(InetSocketAddress connectAddress) throws PinpointSocketException {
        ChannelFuture connectFuture = bootstrap.connect(connectAddress);
        PinpointClientHandler pinpointClientHandler = getSocketHandler(connectFuture, connectAddress);

        PinpointClient pinpointClient = new PinpointClient(pinpointClientHandler);
        traceSocket(pinpointClient);
        return pinpointClient;
    }

    public PinpointClient reconnect(String host, int port) throws PinpointSocketException {
        SocketAddress address = new InetSocketAddress(host, port);
        ChannelFuture connectFuture = bootstrap.connect(address);
        PinpointClientHandler pinpointClientHandler = getSocketHandler(connectFuture, address);

        PinpointClient pinpointClient = new PinpointClient(pinpointClientHandler);
        traceSocket(pinpointClient);
        return pinpointClient;
    }

    /*
        trace mechanism is needed in case of calling close without closing socket
        it is okay to make that later because this is a exceptional case.
     */
    private void traceSocket(PinpointClient pinpointClient) {

    }

    public PinpointClient scheduledConnect(String host, int port) {
        InetSocketAddress connectAddress = new InetSocketAddress(host, port);
        return scheduledConnect(connectAddress);
    }

    public PinpointClient scheduledConnect(InetSocketAddress connectAddress) {
        PinpointClient pinpointClient = new PinpointClient(new ReconnectStateClientHandler());
        reconnect(pinpointClient, connectAddress);
        return pinpointClient;
    }

    PinpointClientHandler getSocketHandler(ChannelFuture channelConnectFuture, SocketAddress address) {
        if (address == null) {
            throw new NullPointerException("address");
        }

        PinpointClientHandler pinpointClientHandler = getSocketHandler(channelConnectFuture.getChannel());
        pinpointClientHandler.setConnectSocketAddress(address);

        ConnectFuture handlerConnectFuture = pinpointClientHandler.getConnectFuture();
        handlerConnectFuture.awaitUninterruptibly();

        if (ConnectFuture.Result.FAIL == handlerConnectFuture.getResult()) {
            throw new PinpointSocketException("connect fail to " + address + ".", channelConnectFuture.getCause());
        }

        return pinpointClientHandler;
    }

    public ChannelFuture reconnect(final SocketAddress remoteAddress) {
        if (remoteAddress == null) {
            throw new NullPointerException("remoteAddress");
        }

        ChannelPipeline pipeline;
        final ClientBootstrap bootstrap = this.bootstrap;
        try {
            pipeline = bootstrap.getPipelineFactory().getPipeline();
        } catch (Exception e) {
            throw new ChannelPipelineException("Failed to initialize a pipeline.", e);
        }
        PinpointClientHandler pinpointClientHandler = (DefaultPinpointClientHandler) pipeline.getLast();
        pinpointClientHandler.initReconnect();

        // Set the options.
        Channel ch = bootstrap.getFactory().newChannel(pipeline);
        boolean success = false;
        try {
            ch.getConfig().setOptions(bootstrap.getOptions());
            success = true;
        } finally {
            if (!success) {
                ch.close();
            }
        }

        // Connect.
        return ch.connect(remoteAddress);
    }

    public Timeout newTimeout(TimerTask task, long delay, TimeUnit unit) {
        return this.timer.newTimeout(task, delay, unit);
    }

    private PinpointClientHandler getSocketHandler(Channel channel) {
        return (PinpointClientHandler) channel.getPipeline().getLast();
    }

    void reconnect(final PinpointClient pinpointClient, final SocketAddress socketAddress) {
        ConnectEvent connectEvent = new ConnectEvent(pinpointClient, socketAddress);
        timer.newTimeout(connectEvent, reconnectDelay, TimeUnit.MILLISECONDS);
    }

    private class ConnectEvent implements TimerTask {

        private final Logger logger = LoggerFactory.getLogger(getClass());
        private final PinpointClient pinpointClient;
        private final SocketAddress socketAddress;

        private ConnectEvent(PinpointClient pinpointClient, SocketAddress socketAddress) {
            if (pinpointClient == null) {
                throw new NullPointerException("pinpointClient must not be null");
            }
            if (socketAddress == null) {
                throw new NullPointerException("socketAddress must not be null");
            }

            this.pinpointClient = pinpointClient;
            this.socketAddress = socketAddress;
        }

        @Override
        public void run(Timeout timeout) {
            if (timeout.isCancelled()) {
                return;
            }

            // Just return not to try reconnection when event has been fired but pinpointClient already closed.
            if (pinpointClient.isClosed()) {
                logger.debug("pinpointClient is already closed.");
                return;
            }

            logger.warn("try reconnect. connectAddress:{}", socketAddress);
            final ChannelFuture channelFuture = reconnect(socketAddress);
            Channel channel = channelFuture.getChannel();
            final PinpointClientHandler pinpointClientHandler = getSocketHandler(channel);
            pinpointClientHandler.setConnectSocketAddress(socketAddress);
            pinpointClientHandler.setPinpointClient(pinpointClient);

            channelFuture.addListener(new ChannelFutureListener() {
                @Override
                public void operationComplete(ChannelFuture future) throws Exception {
                    if (future.isSuccess()) {
                        Channel channel = future.getChannel();
                        logger.info("reconnect success {}, {}", socketAddress, channel);
                        pinpointClient.reconnectSocketHandler(pinpointClientHandler);
                    } else {
                         if (!pinpointClient.isClosed()) {

                         /*
                            // comment out because exception message can be taken at exceptionCaught
                            if (logger.isWarnEnabled()) {
                                Throwable cause = future.getCause();
                                logger.warn("reconnect fail. {} Caused:{}", socketAddress, cause.getMessage());
                            }
                          */
                            reconnect(pinpointClient, socketAddress);
                        } else {
                            logger.info("pinpointClient is closed. stop reconnect.");
                        }
                    }
                }
            });
        }
    }

    public void release() {
        synchronized (this) {
            if (released) {
                return;
            }
            released = true;
        }

        if (bootstrap != null) {
            bootstrap.releaseExternalResources();
        }
        Set<Timeout> stop = this.timer.stop();
        if (!stop.isEmpty()) {
            logger.info("stop Timeout:{}", stop.size());
        }

        // stop, cancel something?
    }

    Map<String, Object> getProperties() {
        return properties;
    }

    public void setProperties(Map<String, Object> agentProperties) {
        AssertUtils.assertNotNull(properties, "agentProperties must not be null");

        this.properties = Collections.unmodifiableMap(agentProperties);
    }

    public ClusterOption getClusterOption() {
        return clusterOption;
    }

    public void setClusterOption(String id, List<Role> roles) {
        this.clusterOption = new ClusterOption(true, id, roles);
    }

    public void setClusterOption(ClusterOption clusterOption) {
        this.clusterOption = clusterOption;
    }

    public MessageListener getMessageListener() {
        return messageListener;
    }

    public MessageListener getMessageListener(MessageListener defaultMessageListener) {
        if (messageListener == null) {
            return defaultMessageListener;
        }

        return messageListener;
    }

    public void setMessageListener(MessageListener messageListener) {
        AssertUtils.assertNotNull(messageListener, "messageListener must not be null");

        this.messageListener = messageListener;
    }

    public ServerStreamChannelMessageListener getServerStreamChannelMessageListener() {
        return serverStreamChannelMessageListener;
    }

    public ServerStreamChannelMessageListener getServerStreamChannelMessageListener(ServerStreamChannelMessageListener defaultStreamMessageListener) {
        if (serverStreamChannelMessageListener == null) {
            return defaultStreamMessageListener;
        }

        return serverStreamChannelMessageListener;
    }

    public void setServerStreamChannelMessageListener(ServerStreamChannelMessageListener serverStreamChannelMessageListener) {
        AssertUtils.assertNotNull(messageListener, "messageListener must not be null");

        this.serverStreamChannelMessageListener = serverStreamChannelMessageListener;
    }

    public List<StateChangeEventListener> getStateChangeEventListeners() {
        return new ArrayList<StateChangeEventListener>(stateChangeEventListeners);
    }

    public void addStateChangeEventListener(StateChangeEventListener stateChangeEventListener) {
        this.stateChangeEventListeners.add(stateChangeEventListener);
    }

    boolean isReleased() {
        return released;
    }

    int issueNewSocketId() {
        return socketId.getAndIncrement();
    }

}


text:
<?xml version="1.0" encoding="UTF-8"?>

<beans:beans
    xmlns="http://www.springframework.org/schema/security"
    xmlns:beans="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

    xsi:schemaLocation="http://www.springframework.org/schema/beans
			http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
			http://www.springframework.org/schema/security
			http://www.springframework.org/schema/security/spring-security-3.0.xsd">

	<beans:description>
		This is the security configuration for the application.
	</beans:description>

	<http auto-config="true">
		<anonymous />
		<intercept-url
			pattern="/use**"
			access="ROLE_USER,ROLE_ADMIN" />
		<intercept-url
			pattern="/search**"
			access="ROLE_USER,ROLE_ADMIN" />
		<!--The login page, this goes to the login controller then to the login view/page(login.jsp).-->
		<form-login
			always-use-default-target="false"
			default-target-url="/"
			login-page="/login.html"
			authentication-failure-url="/login.html"
			login-processing-url="/login" />
		<!--The logout page that will be displayed.-->
		<logout
			invalidate-session="true"
			logout-success-url="/login.html"
			logout-url="/logout" />
	</http>

	<!--
		This is the authentication manager that will block access to the user interface
		if the user is not logged in.
	 -->
	<authentication-manager alias="authenticationManager">
		<!-- Local authentication provider. -->
		<authentication-provider user-service-ref="userService"  />
	</authentication-manager>

  	<!-- This bean enables the authorization. -->
	<beans:bean
		id="defaultWebSecurityExpressionHandler"
		class="org.springframework.security.web.access.expression.DefaultWebSecurityExpressionHandler" />

</beans:beans>


text:
<?php

defined('_JEXEC') or die;

/**
 * Model for component configuration
 *
 * @since  3.2
 */
class ConfigModelComponent extends ConfigModelForm
{
	/**
	 * Method to auto-populate the model state.
	 *
	 * Note. Calling getState in this method will result in recursion.
	 *
	 * @return	void
	 *
	 * @since	3.2
	 */
	protected function populateState()
	{
		$input = JFactory::getApplication()->input;

		// Set the component (option) we are dealing with.
		$component = $input->get('component');
		$state = $this->loadState();
		$state->set('component.option', $component);

		// Set an alternative path for the configuration file.
		if ($path = $input->getString('path'))
		{
			$path = JPath::clean(JPATH_SITE . '/' . $path);
			JPath::check($path);
			$state->set('component.path', $path);
		}

		$this->setState($state);
	}

	/**
	 * Method to get a form object.
	 *
	 * @param   array    $data      Data for the form.
	 * @param   boolean  $loadData  True if the form is to load its own data (default case), false if not.
	 *
	 * @return  mixed  A JForm object on success, false on failure
	 *
	 * @since	3.2
	 */
	public function getForm($data = array(), $loadData = true)
	{
		$state = $this->getState();

		if ($path = $state->get('component.path'))
		{
			// Add the search path for the admin component config.xml file.
			JForm::addFormPath($path);
		}
		else
		{
			// Add the search path for the admin component config.xml file.
			JForm::addFormPath(JPATH_ADMINISTRATOR . '/components/' . $state->get('component.option'));
		}

		// Get the form.
		$form = $this->loadForm(
			'com_config.component',
			'config',
			array('control' => 'jform', 'load_data' => $loadData),
			false,
			'/config'
		);

		if (empty($form))
		{
			return false;
		}

		return $form;
	}

	/**
	 * Get the component information.
	 *
	 * @return	object
	 *
	 * @since	3.2
	 */
	public function getComponent()
	{
		$state = $this->getState();
		$option = $state->get('component.option');

		// Load common and local language files.
		$lang = JFactory::getLanguage();
		$lang->load($option, JPATH_BASE, null, false, true)
		|| $lang->load($option, JPATH_BASE . "/components/$option", null, false, true);

		$result = JComponentHelper::getComponent($option);

		return $result;
	}

	/**
	 * Method to save the configuration data.
	 *
	 * @param   array  $data  An array containing all global config data.
	 *
	 * @return  boolean  True on success, false on failure.
	 *
	 * @since	3.2
	 * @throws  RuntimeException
	 */
	public function save($data)
	{
		$table      = JTable::getInstance('extension');
		$dispatcher = JEventDispatcher::getInstance();
		$context    = $this->option . '.' . $this->name;
		JPluginHelper::importPlugin('extension');

		// Save the rules.
		if (isset($data['params']) && isset($data['params']['rules']))
		{
			$rules = new JAccessRules($data['params']['rules']);
			$asset = JTable::getInstance('asset');

			if (!$asset->loadByName($data['option']))
			{
				$root = JTable::getInstance('asset');
				$root->loadByName('root.1');
				$asset->name = $data['option'];
				$asset->title = $data['option'];
				$asset->setLocation($root->id, 'last-child');
			}

			$asset->rules = (string) $rules;

			if (!$asset->check() || !$asset->store())
			{
				throw new RuntimeException($table->getError());
			}

			// We don't need this anymore
			unset($data['option']);
			unset($data['params']['rules']);
		}

		// Load the previous Data
		if (!$table->load($data['id']))
		{
			throw new RuntimeException($table->getError());
		}

		unset($data['id']);

		// Bind the data.
		if (!$table->bind($data))
		{
			throw new RuntimeException($table->getError());
		}

		// Check the data.
		if (!$table->check())
		{
			throw new RuntimeException($table->getError());
		}

		$result = $dispatcher->trigger('onExtensionBeforeSave', array($context, &$table, false));

			// Store the data.
		if (in_array(false, $result, true) || !$table->store())
		{
			throw new RuntimeException($table->getError());
		}

		// Trigger the after save event.
		$dispatcher->trigger('onExtensionAfterSave', array($context, &$table, false));

		// Clean the component cache.
		$this->cleanCache('_system', 0);
		$this->cleanCache('_system', 1);

		return true;
	}
}


text:
using System;
using System.Net;
using Independentsoft.Exchange;

namespace Sample
{
    class Program
    {
        static void Main(string[] args)
        {
            NetworkCredential credential = new NetworkCredential("username", "password");
            Service service = new Service("https://myserver/ews/Exchange.asmx", credential);

            try
            {
                Note note = new Note();
                note.Subject = "My test note";
                note.Body = new Body("My test note");
                note.Color = NoteColor.Green;
                note.IconColor = NoteColor.Green;
                note.Height = 200;
                note.Width = 300;
                note.Left = 400;
                note.Top = 200;

                ItemId itemId = service.CreateItem(note, StandardFolder.Notes);
            }
            catch (ServiceRequestException ex)
            {
                Console.WriteLine("Error: " + ex.Message);
                Console.WriteLine("Error: " + ex.XmlMessage);
                Console.Read();
            }
            catch (WebException ex)
            {
                Console.WriteLine("Error: " + ex.Message);
                Console.Read();
            }
        }
    }
}


text:
cask 'fontbase' do
  version '2.6.3'
  sha256 '20f256f8e1ebdffd2bff9dcc219345e33360df73b469eef33fa651afe784ffd1'

  url "https://releases.fontba.se/mac/FontBase-#{version}.dmg"
  name 'FontBase'
  homepage 'https://fontba.se/'

  app 'FontBase.app'

  zap trash: [
               '~/Library/Preferences/com.dominiklevitsky.fontbase.helper.plist',
               '~/Library/Preferences/com.dominiklevitsky.fontbase.plist',
               '~/Library/Application Support/FontBase',
               '~/Library/Saved Application State/com.dominiklevitsky.fontbase.savedState',
             ]
end


text:
import { shouldUpdate } from '../../../src/queue/update';

describe('should replace', () => {
  it('should properly tell if two different types need to be updated', () => {
    const previous = {};
    const next = '';

    expect(shouldUpdate(previous, next)).toEqual(false);
  });

  it('should tell if two objects need to be updated', () => {
    const previous = { type: 'div' };
    const next = { type: 'main' };

    expect(shouldUpdate(previous, next)).toEqual(true);
  });
});


text:
package org.apache.nutch.protocol.ftp;

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

import org.apache.commons.net.ftp.FTPFileEntryParser;

import org.apache.nutch.crawl.CrawlDatum;
import org.apache.hadoop.io.Text;
import org.apache.nutch.net.protocols.Response;

import org.apache.hadoop.conf.Configuration;

import org.apache.nutch.protocol.Content;
import org.apache.nutch.metadata.Nutch;
import org.apache.nutch.protocol.Protocol;
import org.apache.nutch.protocol.ProtocolOutput;
import org.apache.nutch.protocol.ProtocolStatus;
import crawlercommons.robots.BaseRobotRules;

import java.lang.invoke.MethodHandles;
import java.net.URL;
import java.util.List;
import java.io.IOException;

/**
 * This class is a protocol plugin used for ftp: scheme. It creates
 * {@link FtpResponse} object and gets the content of the url from it.
 * Configurable parameters are {@code ftp.username}, {@code ftp.password},
 * {@code ftp.content.limit}, {@code ftp.timeout}, {@code ftp.server.timeout},
 * {@code ftp.password}, {@code ftp.keep.connection} and {@code ftp.follow.talk}
 * . For details see "FTP properties" section in {@code nutch-default.xml}.
 */
public class Ftp implements Protocol {

  protected static final Logger LOG = LoggerFactory
      .getLogger(MethodHandles.lookup().lookupClass());

  private static final int BUFFER_SIZE = 16384; // 16*1024 = 16384

  static final int MAX_REDIRECTS = 5;

  int timeout;

  int maxContentLength;

  String userName;
  String passWord;

  // typical/default server timeout is 120*1000 millisec.
  // better be conservative here
  int serverTimeout;

  // when to have client start anew
  long renewalTime = -1;

  boolean keepConnection;

  boolean followTalk;

  // ftp client
  Client client = null;
  // ftp dir list entry parser
  FTPFileEntryParser parser = null;

  private Configuration conf;

  private FtpRobotRulesParser robots = null;

  // constructor
  public Ftp() {
    robots = new FtpRobotRulesParser();
  }

  /** Set the timeout. */
  public void setTimeout(int to) {
    timeout = to;
  }

  /** Set the point at which content is truncated. */
  public void setMaxContentLength(int length) {
    maxContentLength = length;
  }

  /** Set followTalk */
  public void setFollowTalk(boolean followTalk) {
    this.followTalk = followTalk;
  }

  /** Set keepConnection */
  public void setKeepConnection(boolean keepConnection) {
    this.keepConnection = keepConnection;
  }

  /**
   * Creates a {@link FtpResponse} object corresponding to the url and returns a
   * {@link ProtocolOutput} object as per the content received
   *
   * @param url
   *          Text containing the ftp url
   * @param datum
   *          The CrawlDatum object corresponding to the url
   *
   * @return {@link ProtocolOutput} object for the url
   */
  public ProtocolOutput getProtocolOutput(Text url, CrawlDatum datum) {
    String urlString = url.toString();
    try {
      URL u = new URL(urlString);

      int redirects = 0;

      while (true) {
        FtpResponse response;
        response = new FtpResponse(u, datum, this, getConf()); // make a request

        int code = response.getCode();
        datum.getMetaData().put(Nutch.PROTOCOL_STATUS_CODE_KEY,
          new Text(Integer.toString(code)));

        if (code == 200) { // got a good response
          return new ProtocolOutput(response.toContent()); // return it

        } else if (code >= 300 && code < 400) { // handle redirect
          if (redirects == MAX_REDIRECTS)
            throw new FtpException("Too many redirects: " + url);
          u = new URL(response.getHeader("Location"));
          redirects++;
          if (LOG.isTraceEnabled()) {
            LOG.trace("redirect to " + u);
          }
        } else { // convert to exception
          throw new FtpError(code);
        }
      }
    } catch (Exception e) {
      return new ProtocolOutput(null, new ProtocolStatus(e));
    }
  }

  protected void finalize() {
    try {
      if (this.client != null && this.client.isConnected()) {
        this.client.logout();
        this.client.disconnect();
      }
    } catch (IOException e) {
      // do nothing
    }
  }

  /** For debugging. */
  public static void main(String[] args) throws Exception {
    int timeout = Integer.MIN_VALUE;
    int maxContentLength = Integer.MIN_VALUE;
    String logLevel = "info";
    boolean followTalk = false;
    boolean keepConnection = false;
    boolean dumpContent = false;
    String urlString = null;

    String usage = "Usage: Ftp [-logLevel level] [-followTalk] [-keepConnection] [-timeout N] [-maxContentLength L] [-dumpContent] url";

    if (args.length == 0) {
      System.err.println(usage);
      System.exit(-1);
    }

    for (int i = 0; i < args.length; i++) {
      if (args[i].equals("-logLevel")) {
        logLevel = args[++i];
      } else if (args[i].equals("-followTalk")) {
        followTalk = true;
      } else if (args[i].equals("-keepConnection")) {
        keepConnection = true;
      } else if (args[i].equals("-timeout")) {
        timeout = Integer.parseInt(args[++i]) * 1000;
      } else if (args[i].equals("-maxContentLength")) {
        maxContentLength = Integer.parseInt(args[++i]);
      } else if (args[i].equals("-dumpContent")) {
        dumpContent = true;
      } else if (i != args.length - 1) {
        System.err.println(usage);
        System.exit(-1);
      } else {
        urlString = args[i];
      }
    }

    Ftp ftp = new Ftp();

    ftp.setFollowTalk(followTalk);
    ftp.setKeepConnection(keepConnection);

    if (timeout != Integer.MIN_VALUE) // set timeout
      ftp.setTimeout(timeout);

    if (maxContentLength != Integer.MIN_VALUE) // set maxContentLength
      ftp.setMaxContentLength(maxContentLength);

    // set log level
    // LOG.setLevel(Level.parse((new String(logLevel)).toUpperCase()));

    Content content = ftp.getProtocolOutput(new Text(urlString),
        new CrawlDatum()).getContent();

    System.err.println("Content-Type: " + content.getContentType());
    System.err.println("Content-Length: "
        + content.getMetadata().get(Response.CONTENT_LENGTH));
    System.err.println("Last-Modified: "
        + content.getMetadata().get(Response.LAST_MODIFIED));
    if (dumpContent) {
      System.out.print(new String(content.getContent()));
    }

    ftp = null;
  }

  /**
   * Set the {@link Configuration} object
   */
  public void setConf(Configuration conf) {
    this.conf = conf;
    this.maxContentLength = conf.getInt("ftp.content.limit", 64 * 1024);
    this.timeout = conf.getInt("ftp.timeout", 10000);
    this.userName = conf.get("ftp.username", "anonymous");
    this.passWord = conf.get("ftp.password", "anonymous@example.com");
    this.serverTimeout = conf.getInt("ftp.server.timeout", 60 * 1000);
    this.keepConnection = conf.getBoolean("ftp.keep.connection", false);
    this.followTalk = conf.getBoolean("ftp.follow.talk", false);
    this.robots.setConf(conf);
  }

  /**
   * Get the {@link Configuration} object
   */
  public Configuration getConf() {
    return this.conf;
  }

  /**
   * Get the robots rules for a given url
   */
  @Override
  public BaseRobotRules getRobotRules(Text url, CrawlDatum datum,
      List<Content> robotsTxtContent) {
    return robots.getRobotRulesSet(this, url, robotsTxtContent);
  }

  public int getBufferSize() {
    return BUFFER_SIZE;
  }

}


text:
package limelight.ui.events.panel;

import java.awt.*;

public class MouseReleasedEvent extends MouseEvent
{
  public MouseReleasedEvent(int modifiers, Point location, int clickCount)
  {
    super(modifiers, location, clickCount);
  }
}


text:
wpshop(document).ready(function(){
/*	Start custom display management	*/
	jQuery("#wpshop_product_attribute_display_choice").click(function() {
		if ( jQuery(this).is(":checked") ) {
			jQuery("#wpshop_product_attribute_frontend_display_container").hide();
		}
		else {
			jQuery("#wpshop_product_attribute_frontend_display_container").show();
		}
	});

/*	Start variation management	*/
	jQuery(".wpshop_admin_use_attribute_for_single_variation_checkbox").live("change", function(){
		var current_attribute_id = jQuery(this).attr("id").replace("wpshop_admin_use_attribute_for_single_variation_checkbox_", "");
		if ( jQuery(this).is(":checked") ) {
			jQuery(".wpshop_attribute_input_for_variation_" + current_attribute_id).show();
		}
		else {
			jQuery(".wpshop_attribute_input_for_variation_" + current_attribute_id).hide();
		}
	});

	/*	Create a dialog box for new variation creation	*/
	jQuery(".wpshop_admin_variation_single_dialog").dialog({
		modal: true,
		dialogClass: "wpshop_uidialog_box",
		autoOpen:false,
		show: "blind",
		width: 500,
		resizable: false,
		buttons:{
			 "create-single" : {
				text: WPSHOP_ADD_TEXT,
				click: function(){
					var box_checked = false;
					jQuery(".wpshop_admin_use_attribute_for_single_variation_checkbox").each(function(){
						if ( jQuery(this).is(":checked") ) {
							if (( jQuery(".wpshop_product_attribute_" + jQuery(this).attr("id").replace("wpshop_admin_use_attribute_for_single_variation_checkbox_", "")).val() != "" ) && ( jQuery(".wpshop_product_attribute_" + jQuery(this).attr("id").replace("wpshop_admin_use_attribute_for_single_variation_checkbox_", "")).val() != "0" )) {
								box_checked = true;
							}
						}
					});

					if ( box_checked ) {
						jQuery("#wpshop_admin_variation_definition").submit();
					}
					else {
						alert( wpshopConvertAccentTojs( WPSHOP_NO_ATTRIBUTES_SELECT_FOR_VARIATION ) );
					};

				},
				class: "button-primary",
			 }
		},
		close: function(){
			jQuery(".wpshop_admin_variation_single_dialog").html("");
		},
	});
	jQuery("#wpshop_new_variation_single_button").live('click', function(){
		jQuery(".wpshop_admin_variation_single_dialog").html(jQuery(".wpshop_loading_").html());
		var data = {
			action: "new_single_variation_definition",
			wpshop_ajax_nonce: jQuery("#wpshop_variation_management").val(),
			current_post_id: jQuery("#post_ID").val(),
		};
		jQuery.post(ajaxurl, data, function(response) {
			jQuery(".wpshop_admin_variation_single_dialog").html(response);
		});
		jQuery(".wpshop_admin_variation_single_dialog").dialog("open");
	});

	/*	Create a dialog box for new variation creation	*/
	jQuery(".wpshop_admin_variation_combined_dialog").dialog({
		modal: true,
		dialogClass: "wpshop_uidialog_box",
		autoOpen:false,
		show: "blind",
		resizable: false,
		width: 500,
		height: 250,
		buttons:{
			 "create-combined" : {
				text: WPSHOP_CREATE_TEXT,
				click: function(){
		        	animate_container('.wpshop_admin_variation_combined_dialog', jQuery(".wpshop_admin_variation_combined_dialog"));
					wpshop_create_variation("add_new_variation_list");
					desanimate_container(jQuery(".wpshop_admin_variation_combined_dialog"));
				},
				class: "button-primary",
			 }
		},
		close: function(){
			jQuery(".wpshop_admin_variation_combined_dialog").html("");
		},
	});
	/*	Action when user click on the new variation button	*/
	jQuery("#wpshop_new_variation_list_button").live('click', function() {
		jQuery(".wpshop_admin_variation_combined_dialog").html(jQuery(".wpshop_loading_").html());
		var data = {
			action: "new_combined_variation_list_definition",
			wpshop_ajax_nonce: jQuery("#wpshop_variation_management").val(),
			current_post_id: jQuery("#post_ID").val(),
		};
		jQuery.post(ajaxurl, data, function(response) {
			jQuery(".wpshop_admin_variation_combined_dialog").html(response);
		});
		jQuery(".wpshop_admin_variation_combined_dialog").dialog("open");
	});

	/*	Action when user ask to delete a variation	*/
	jQuery(".wpshop_variation_button_delete").live('click', function() {
		if( confirm(wpshopConvertAccentTojs("<?php echo __('Are you sure you want to delete this variation?', 'wpshop'); ?>")) ) {
			var variation_to_delete = new Array();
			variation_to_delete.push( jQuery(this).attr("id").replace('wpshop_variation_delete_', '') );
			wpshop_variation_delete ( variation_to_delete );
			return false;
		}
	});
	jQuery("#wpshop_admin_variation_mass_delete_button").live('click', function(){
		if( confirm(wpshopConvertAccentTojs("<?php echo __('Are you sure you want to delete all selected variation?', 'wpshop'); ?>")) ) {
			var variation_to_delete = new Array();
			jQuery(".wpshop_variation_mass_select_input").each(function() {
				if ( jQuery(this).is(":checked") ) {
					variation_to_delete.push( jQuery(this).val() );
				}
			});
			wpshop_variation_delete ( variation_to_delete );
			return false;
		}
	});

	/*	Create a dialog box for new variation creation	*/
	jQuery(".wpshop_admin_variation_parameter_dialog").dialog({
		modal: true,
		dialogClass: "wpshop_uidialog_box",
		autoOpen:false,
		show: "blind",
		resizable: false,
		width: 600,
		buttons:{
			"option-save" : {
				text: WPSHOP_SAVE_PRODUCT_OPTIONS_PARAMS,
				click: function(){
					jQuery("#wpshop_variation_parameter_form").submit();
				},
				class: "button-primary",
			}
		},
		close: function(){
			jQuery(".wpshop_admin_variation_parameter_dialog").html("");
		},
	});
	jQuery("#wpshop_variation_parameters_button").live('click', function(){
		jQuery(".wpshop_variation_parameters_button").html(jQuery(".wpshop_loading_").html());
		var data = {
			action: "admin_variation_parameters",
			wpshop_ajax_nonce: jQuery("#wpshop_variation_management").val(),
			current_post_id: jQuery("#post_ID").val(),
		};
		jQuery.post(ajaxurl, data, function(response) {
			jQuery(".wpshop_admin_variation_parameter_dialog").html(response);
		});
		jQuery(".wpshop_admin_variation_parameter_dialog").dialog("open");
	});

	/*	Allows variation order by drag and drop	*/
	//	jQuery(".variation_existing_main_container").sortable();

	/*	Variation details viewing	*/
	jQuery(".wpshop_variation_metabox .wpshop_variation_metabox_row").live('click', function() {
		var current_variation_id = jQuery(this).parent().attr("id").replace("wpshop_variation_metabox_", "");
		jQuery(".wpshop_variation_def_details").stop(true).slideUp(200);
		jQuery(".wpshop_variation_metabox").removeClass('wpshop_current_variation');
		jQuery("#wpshop_variation_def_details_" + current_variation_id).stop(true).slideToggle(200);
		setTimeout(function(){
			if ( jQuery("#wpshop_variation_def_details_" + current_variation_id).is(":visible") ) {
				jQuery("#wpshop_variation_def_details_" + current_variation_id).parent().addClass('wpshop_current_variation');
			}
		}, 500);
	});

	/* Select / Deselect all existing variation	*/
	jQuery("#wpshop_variation_list_selection_controller").live("click", function(){
		var state = true;
		if (jQuery(this).is(":checked")) {
			state = true;
			jQuery(".wpshop_variation_metabox_col_close").addClass('wpshop_variation_metabox_col_close_current');
		}
		else {
			state = false;
			jQuery(".wpshop_variation_metabox_col_close").removeClass('wpshop_variation_metabox_col_close_current');
		}
		jQuery(".wpshop_variation_mass_select_input").each(function() {
			jQuery(this).prop("checked", state);
		});
	});
	jQuery(".wpshop_variation_mass_select_input").live("click", function(){
		if (jQuery(this).is(":checked")) {
			jQuery(".wpshop_variation_metabox_col_close").addClass('wpshop_variation_metabox_col_close_current');
		}
		else{
			jQuery("#wpshop_variation_list_selection_controller").prop("checked", false);
			var no_checked = false;
			jQuery(".wpshop_variation_mass_select_input").each(function() {
				if (jQuery(this).is(":checked")) {
					no_checked = true;
				}
			});
			if (!no_checked) {
				jQuery(".wpshop_variation_metabox_col_close").removeClass('wpshop_variation_metabox_col_close_current');
			}
		}
	});
/*	End variation management	*/

	/*	Action for product duplication	*/
	jQuery(".wpshop_product_duplication_button").click(function() {
		var product_id = jQuery(this).attr("id").replace("wpshop_product_id_", "");

		/*	Display loading picture	*/
		//jQuery("#wpshop_loading_duplicate_pdt_" + product_id).removeClass('success error');
		//jQuery("#wpshop_loading_duplicate_pdt_" + product_id).show();
		jQuery( this ).addClass( 'wps-bton-loading');

		/*	Launch ajax request	*/
		var data = {
			action: "duplicate_product",
			current_post_id: product_id,
			wpshop_ajax_nonce: '<?php echo wp_create_nonce("wpshop_product_duplication"); ?>'
		};
		jQuery.post(ajaxurl, data, function(response){
			if ( response[0] ) {

				jQuery("#wpshop_loading_duplicate_pdt_" + product_id).html( response[1] );
				jQuery("#wpshop_loading_duplicate_pdt_" + product_id).prepend('');
				jQuery( '#wpshop_product_id_' + product_id ).removeClass( 'wps-bton-loading');
			}
			else {
				jQuery("#wpshop_loading_duplicate_pdt_" + product_id).addClass('error');
				jQuery( '#wpshop_product_id_' + product_id ).removeClass( 'wps-bton-loading');
			}
		}, 'json');

		return false;
	});

/*	Start product attachment management	*/
	/*	Delete an attachment	*/
	jQuery(".delete_post_thumbnail").live('click',function(e){
		e.preventDefault();
		if (confirm(WPSHOP_MSG_CONFIRM_THUMBNAIL_DELETION)) {
			var data = {
				action: "delete_product_thumbnail",
				wpshop_ajax_nonce: '<?php echo wp_create_nonce("wpshop_delete_product_thumbnail"); ?>',
				attachement_id: jQuery(this).attr('id').replace('thumbnail_', '')
			};
			jQuery.post(ajaxurl, data, function(response){
				if (response[0]) {
					jQuery("#thumbnail_" + response[1]).parent('li').fadeOut('slow');
				}
				else {
					alert(wpshopConvertAccentTojs("<?php _e('An error occured while deleting attachement', 'wpshop'); ?>"));
				}
			}, 'json');
		}
	});
	/*	Reload the attachment container 	*/
	jQuery(".reload_box_attachment img").live('click', function(){
		jQuery(this).attr("src", "<?php echo WPSHOP_LOADING_ICON; ?>");
		var data = {
			action: "reload_product_attachment",
			part_to_reload: jQuery(this).attr("id"),
			current_post_id: jQuery("#post_ID").val(),
			wpshop_ajax_nonce: '<?php echo wp_create_nonce("wpshop_reload_product_attachment_part"); ?>'
		};
		jQuery.post(ajaxurl, data, function(response){
			jQuery(".product_attachment_list_" + response[1].replace('reload_', '')).html(response[0]);
			jQuery("#" + response[1]).attr("src", "<?php echo WPSHOP_MEDIAS_ICON_URL . 'reload_vs.png'; ?>");
		}, 'json');
	});

/*	Manage options for a file input	*/
	jQuery('.wpshop_form_input_element select').change(function() {
		var myclass = jQuery(this).attr('name').split('[');
		myclass = myclass[2].slice(0,-1);

		/*	Check if value is realy set to "yes/true"	*/
		if(jQuery('option:selected',this).val() && (jQuery('option:selected',this).val().toLowerCase() == 'yes')) {
			jQuery('.attribute_option_'+myclass).show();
		} else jQuery('.attribute_option_'+myclass).hide();
	});

/*	Update product information from bulk edition	*/
	jQuery( '#bulk_edit' ).live('click', function() {
	   var $bulk_row = jQuery( '#bulk-edit' );

	   /*	Read the post id list 	*/
	   var $post_ids = new Array();
	   $bulk_row.find( '#bulk-titles' ).children().each( function() {
		   $post_ids.push( jQuery( this ).attr( 'id' ).replace( /^(ttle)/i, '' ) );
	   });

	   /*	Read the different field to save 	*/
	   var data_to_save = new Array();
	   $bulk_row.find( '.wpshop_bulk_and_quick_edit_input' ).each( function() {
		   data_to_save.push( jQuery(this).attr( 'name' ) + '_-val-_' + jQuery(this).val() );
	   });

	   /*	Read the different post	*/
		var data = {
			action: "product_bulk_edit_save",
			post_ids: $post_ids,
			attribute: data_to_save,
			wpshop_ajax_nonce: '<?php echo wp_create_nonce("product_bulk_edit_save"); ?>'
		};
		jQuery.ajax({
			url: ajaxurl,
			type: 'POST',
			async: false,
			cache: false,
			data: data
		});
	});
});


text:
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
<html xmlns="http://www.w3.org/1999/xhtml">
<head>
<meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
<title>Untitled Document</title>
</head>

<body>
<form action="#" method="post">
<input type="text" name="user"  />
<br />
<input type="password" name="pass" />
<input type="submit" name="submit" value="login" />
</form>
</body>
</html>
<?php if(isset($_REQUEST['submit'])){
$name=$_REQUEST['user'];
$pass=$_REQUEST['pass'];
$query="select * from sp where `name`='$user' ";
$res=mysql_query($query);
$result=mysql_num_rows($res);
	if($result=='1'){
		while($row=mysql_fetch_assoc($res)){
			$id=$row['sp_id'];
			header("location:bids.php?sp=$id");
		}
	}

}


text:
**NOTE: THIS DOC IS A WORK IN PROGRESS**

This document captures concensus on the identity and content of milestones.

## Legos-1

Tentative target date: Feb 1, 2017

1.  `servicecatalog/v1alpha1` API complete and functional:
  1.  `ServiceBroker`, `ServiceClass`, `ServiceInstance`, `ServiceInstanceCredential`
  2.  Integrators should be able to program against this REST API
2.  API server serves `servicecatalog/v1alpha1`
  1.  It should be possible to use stock `kubectl` for raw CRUD operations
      against the API server
3.  Golang client for API in (1) is auto-generated

## MVP-1

Tentative target date: March 1, 2017

The MVP1 milestone is the barest skeleton of an MVP that has the right
architecture.

High-level functional requirements:

1.  `servicecatalog/v1alpha1` API complete and functional:
  1.  `ServiceBroker`, `ServiceClass`, `ServiceInstance`, `ServiceInstanceCredential`
  2.  Integrators should be able to program against this REST API
  3.  Status subresources for `ServiceBroker`, `ServiceInstance`, and `ServiceInstanceCredential`
2.  Golang client for API in (1) is auto-generated
3.  Native-k8s-style CLI experience
  1.  Formatted list
  2.  Formatted describe
4.  Integration with Open Service Broker API:
  1.  Add broker
  2.  Provision service instance
  3.  Bind to service instance
  4.  Unbind from service instance
  5.  Deprovision service instance
  6.  Remove broker
  7.  Update broker
  8.  Delete broker
5.  ServiceInstanceCredentials manifest as a Secret in the the k8s core; users will be expected
    to explicitly reference this secret in their Pod specs

High-level architectural requirements:

1.  We are moved off TPR and fully onto `servicecatalog/v1alpha1` API
2.  Code generators for API are in place:
  1.  Deep copy
  2.  Defaults
  3.  Conversions
  4.  YAML parser
  5.  API client
3.  Controller(s) use k8s controller infrastructure
4.  CLI interface:
  1.  Vendor in `kubectl` guts
  2.  listers and describers for `servicecatalog/v1alpha1` API resources


text:
require "execjs/runtime"

module ExecJS
  class DisabledRuntime < Runtime
    def name
      "Disabled"
    end

    def exec(source, options = {})
      raise Error, "ExecJS disabled"
    end

    def eval(source, options = {})
      raise Error, "ExecJS disabled"
    end

    def compile(source, options = {})
      raise Error, "ExecJS disabled"
    end

    def deprecated?
      true
    end

    def available?
      true
    end
  end
end


text:
package org.lwjgl.vulkan;

import javax.annotation.*;

import java.nio.*;

import org.lwjgl.system.*;

import static org.lwjgl.system.Checks.*;
import static org.lwjgl.system.JNI.*;
import static org.lwjgl.system.MemoryUtil.*;

import org.lwjgl.system.linux.*;

/**
 * The {@code VK_KHR_xlib_surface} extension is an instance extension. It provides a mechanism to create a {@code VkSurfaceKHR} object (defined by the {@link KHRSurface VK_KHR_surface} extension) that refers to an X11 {@code Window}, using the Xlib client-side library, as well as a query to determine support for rendering via Xlib.
 *
 *
VK_KHR_xlib_surface

 *
 *

 *
Name String

 *
{@code VK_KHR_xlib_surface}

 *
Extension Type

 *
Instance extension

 *
Registered Extension Number

 *
5

 *
Revision

 *
6

 *
Extension and Version Dependencies

 *

 *
Requires support for Vulkan 1.0

 *
Requires {@link KHRSurface VK_KHR_surface} to be enabled

 *

 *
Contact

 *

 *
Jesse Hall critsec

 *
Ian Elliott ianelliottus

 *

 *

 *
 *
Other Extension Metadata

 *
 *

 *
Last Modified Date

 *
2015-11-28

 *
IP Status

 *
No known IP claims.

 *
Contributors

 *

 *
Patrick Doane, Blizzard

 *
Jason Ekstrand, Intel

 *
Ian Elliott, LunarG

 *
Courtney Goeltzenleuchter, LunarG

 *
Jesse Hall, Google

 *
James Jones, NVIDIA

 *
Antoine Labour, Google

 *
Jon Leech, Khronos

 *
David Mao, AMD

 *
Norbert Nopper, Freescale

 *
Alon Or-bach, Samsung

 *
Daniel Rakos, AMD

 *
Graham Sellers, AMD

 *
Ray Smith, ARM

 *
Jeff Vigil, Qualcomm

 *
Chia-I Wu, LunarG

 *

 *

 */
public class KHRXlibSurface {

    /** The extension specification version. */
    public static final int VK_KHR_XLIB_SURFACE_SPEC_VERSION = 6;

    /** The extension name. */
    public static final String VK_KHR_XLIB_SURFACE_EXTENSION_NAME = "VK_KHR_xlib_surface";

    /** Extends {@code VkStructureType}. */
    public static final int VK_STRUCTURE_TYPE_XLIB_SURFACE_CREATE_INFO_KHR = 1000004000;

    protected KHRXlibSurface() {
        throw new UnsupportedOperationException();
    }

    // --- [ vkCreateXlibSurfaceKHR ] ---

    /** Unsafe version of: {@link #vkCreateXlibSurfaceKHR CreateXlibSurfaceKHR} */
    public static int nvkCreateXlibSurfaceKHR(VkInstance instance, long pCreateInfo, long pAllocator, long pSurface) {
        long __functionAddress = instance.getCapabilities().vkCreateXlibSurfaceKHR;
        if (CHECKS) {
            check(__functionAddress);
        }
        return callPPPPI(instance.address(), pCreateInfo, pAllocator, pSurface, __functionAddress);
    }

    /**
     * Create a {@code VkSurfaceKHR} object for an X11 window, using the Xlib client-side library.
     *
     *
C Specification

     *
     *
To create a {@code VkSurfaceKHR} object for an X11 window, using the Xlib client-side library, call:

     *
     *

     * VkResult vkCreateXlibSurfaceKHR(
     *     VkInstance                                  instance,
     *     const VkXlibSurfaceCreateInfoKHR*           pCreateInfo,
     *     const VkAllocationCallbacks*                pAllocator,
     *     VkSurfaceKHR*                               pSurface);

     *
     *
Valid Usage (Implicit)

     *
     *

     *
{@code instance} must be a valid {@code VkInstance} handle

     *
{@code pCreateInfo} must be a valid pointer to a valid {@link VkXlibSurfaceCreateInfoKHR} structure

     *
If {@code pAllocator} is not {@code NULL}, {@code pAllocator} must be a valid pointer to a valid {@link VkAllocationCallbacks} structure

     *
{@code pSurface} must be a valid pointer to a {@code VkSurfaceKHR} handle

     *

     *
     *
Return Codes

     *
     *

     *
On success, this command returns

     *

     *
{@link VK10#VK_SUCCESS SUCCESS}

     *

     *
On failure, this command returns

     *

     *
{@link VK10#VK_ERROR_OUT_OF_HOST_MEMORY ERROR_OUT_OF_HOST_MEMORY}

     *
{@link VK10#VK_ERROR_OUT_OF_DEVICE_MEMORY ERROR_OUT_OF_DEVICE_MEMORY}

     *

     *

     *
     *
See Also

     *
     *
{@link VkAllocationCallbacks}, {@link VkXlibSurfaceCreateInfoKHR}

     *
     * @param instance    the instance to associate the surface with.
     * @param pCreateInfo a pointer to a {@link VkXlibSurfaceCreateInfoKHR} structure containing the parameters affecting the creation of the surface object.
     * @param pAllocator  the allocator used for host memory allocated for the surface object when there is no more specific allocator available (see Memory Allocation).
     * @param pSurface    a pointer to a {@code VkSurfaceKHR} handle in which the created surface object is returned.
     */
    @NativeType("VkResult")
    public static int vkCreateXlibSurfaceKHR(VkInstance instance, @NativeType("VkXlibSurfaceCreateInfoKHR const *") VkXlibSurfaceCreateInfoKHR pCreateInfo, @Nullable @NativeType("VkAllocationCallbacks const *") VkAllocationCallbacks pAllocator, @NativeType("VkSurfaceKHR *") LongBuffer pSurface) {
        if (CHECKS) {
            check(pSurface, 1);
        }
        return nvkCreateXlibSurfaceKHR(instance, pCreateInfo.address(), memAddressSafe(pAllocator), memAddress(pSurface));
    }

    // --- [ vkGetPhysicalDeviceXlibPresentationSupportKHR ] ---

    /**
     * Query physical device for presentation to X11 server using Xlib.
     *
     *
C Specification

     *
     *
To determine whether a queue family of a physical device supports presentation to an X11 server, using the Xlib client-side library, call:

     *
     *

     * VkBool32 vkGetPhysicalDeviceXlibPresentationSupportKHR(
     *     VkPhysicalDevice                            physicalDevice,
     *     uint32_t                                    queueFamilyIndex,
     *     Display*                                    dpy,
     *     VisualID                                    visualID);

     *
     *
Description

     *
     *
This platform-specific function can be called prior to creating a surface.

     *
     *
Valid Usage

     *
     *

     *
{@code queueFamilyIndex} must be less than {@code pQueueFamilyPropertyCount} returned by {@code vkGetPhysicalDeviceQueueFamilyProperties} for the given {@code physicalDevice}

     *

     *
     *
Valid Usage (Implicit)

     *
     *

     *
{@code physicalDevice} must be a valid {@code VkPhysicalDevice} handle

     *
{@code dpy} must be a valid pointer to a {@code Display} value

     *

     *
     * @param physicalDevice   the physical device.
     * @param queueFamilyIndex the queue family index.
     * @param dpy              a pointer to an Xlib {@code Display} connection to the server.
     */
    @NativeType("VkBool32")
    public static boolean vkGetPhysicalDeviceXlibPresentationSupportKHR(VkPhysicalDevice physicalDevice, @NativeType("uint32_t") int queueFamilyIndex, @NativeType("Display *") long dpy, @NativeType("VisualID") long visualID) {
        long __functionAddress = physicalDevice.getCapabilities().vkGetPhysicalDeviceXlibPresentationSupportKHR;
        if (CHECKS) {
            check(__functionAddress);
            check(dpy);
        }
        return callPPNI(physicalDevice.address(), queueFamilyIndex, dpy, visualID, __functionAddress) != 0;
    }

    /** Array version of: {@link #vkCreateXlibSurfaceKHR CreateXlibSurfaceKHR} */
    @NativeType("VkResult")
    public static int vkCreateXlibSurfaceKHR(VkInstance instance, @NativeType("VkXlibSurfaceCreateInfoKHR const *") VkXlibSurfaceCreateInfoKHR pCreateInfo, @Nullable @NativeType("VkAllocationCallbacks const *") VkAllocationCallbacks pAllocator, @NativeType("VkSurfaceKHR *") long[] pSurface) {
        long __functionAddress = instance.getCapabilities().vkCreateXlibSurfaceKHR;
        if (CHECKS) {
            check(__functionAddress);
            check(pSurface, 1);
        }
        return callPPPPI(instance.address(), pCreateInfo.address(), memAddressSafe(pAllocator), pSurface, __functionAddress);
    }

}