text:
.class Lcom/sec/ims/ICentralMsgStoreService$Stub$Proxy;
.super Ljava/lang/Object;
.source "ICentralMsgStoreService.java"

# interfaces
.implements Lcom/sec/ims/ICentralMsgStoreService;

# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
    value = Lcom/sec/ims/ICentralMsgStoreService$Stub;
.end annotation

.annotation system Ldalvik/annotation/InnerClass;
    accessFlags = 0xa
    name = "Proxy"
.end annotation

# instance fields
.field private mRemote:Landroid/os/IBinder;

# direct methods
.method constructor <init>(Landroid/os/IBinder;)V
    .locals 0

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

    iput-object p1, p0, Lcom/sec/ims/ICentralMsgStoreService$Stub$Proxy;->mRemote:Landroid/os/IBinder;

    return-void
.end method

# virtual methods
.method public asBinder()Landroid/os/IBinder;
    .locals 1

    iget-object v0, p0, Lcom/sec/ims/ICentralMsgStoreService$Stub$Proxy;->mRemote:Landroid/os/IBinder;

    return-object v0
.end method

.method public createParticipant(Ljava/lang/String;Ljava/lang/String;)V
    .locals 5
    .annotation system Ldalvik/annotation/Throws;
        value = {
            Landroid/os/RemoteException;
        }
    .end annotation

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v0

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v1

    :try_start_0
    const-string/jumbo v2, "com.sec.ims.ICentralMsgStoreService"

    invoke-virtual {v0, v2}, Landroid/os/Parcel;->writeInterfaceToken(Ljava/lang/String;)V

    invoke-virtual {v0, p1}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    invoke-virtual {v0, p2}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    iget-object v2, p0, Lcom/sec/ims/ICentralMsgStoreService$Stub$Proxy;->mRemote:Landroid/os/IBinder;

    const/16 v3, 0x13

    const/4 v4, 0x0

    invoke-interface {v2, v3, v0, v1, v4}, Landroid/os/IBinder;->transact(ILandroid/os/Parcel;Landroid/os/Parcel;I)Z

    invoke-virtual {v1}, Landroid/os/Parcel;->readException()V
    :try_end_0
    .catchall {:try_start_0 .. :try_end_0} :catchall_0

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    return-void

    :catchall_0
    move-exception v2

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    throw v2
.end method

.method public createSession(Ljava/lang/String;Ljava/lang/String;)V
    .locals 5
    .annotation system Ldalvik/annotation/Throws;
        value = {
            Landroid/os/RemoteException;
        }
    .end annotation

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v0

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v1

    :try_start_0
    const-string/jumbo v2, "com.sec.ims.ICentralMsgStoreService"

    invoke-virtual {v0, v2}, Landroid/os/Parcel;->writeInterfaceToken(Ljava/lang/String;)V

    invoke-virtual {v0, p1}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    invoke-virtual {v0, p2}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    iget-object v2, p0, Lcom/sec/ims/ICentralMsgStoreService$Stub$Proxy;->mRemote:Landroid/os/IBinder;

    const/16 v3, 0x12

    const/4 v4, 0x0

    invoke-interface {v2, v3, v0, v1, v4}, Landroid/os/IBinder;->transact(ILandroid/os/Parcel;Landroid/os/Parcel;I)Z

    invoke-virtual {v1}, Landroid/os/Parcel;->readException()V
    :try_end_0
    .catchall {:try_start_0 .. :try_end_0} :catchall_0

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    return-void

    :catchall_0
    move-exception v2

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    throw v2
.end method

.method public deleteMessage(Ljava/lang/String;Ljava/lang/String;)V
    .locals 5
    .annotation system Ldalvik/annotation/Throws;
        value = {
            Landroid/os/RemoteException;
        }
    .end annotation

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v0

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v1

    :try_start_0
    const-string/jumbo v2, "com.sec.ims.ICentralMsgStoreService"

    invoke-virtual {v0, v2}, Landroid/os/Parcel;->writeInterfaceToken(Ljava/lang/String;)V

    invoke-virtual {v0, p1}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    invoke-virtual {v0, p2}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    iget-object v2, p0, Lcom/sec/ims/ICentralMsgStoreService$Stub$Proxy;->mRemote:Landroid/os/IBinder;

    const/4 v3, 0x5

    const/4 v4, 0x0

    invoke-interface {v2, v3, v0, v1, v4}, Landroid/os/IBinder;->transact(ILandroid/os/Parcel;Landroid/os/Parcel;I)Z

    invoke-virtual {v1}, Landroid/os/Parcel;->readException()V
    :try_end_0
    .catchall {:try_start_0 .. :try_end_0} :catchall_0

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    return-void

    :catchall_0
    move-exception v2

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    throw v2
.end method

.method public deleteOldLegacyMessage(Ljava/lang/String;Ljava/lang/String;)V
    .locals 5
    .annotation system Ldalvik/annotation/Throws;
        value = {
            Landroid/os/RemoteException;
        }
    .end annotation

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v0

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v1

    :try_start_0
    const-string/jumbo v2, "com.sec.ims.ICentralMsgStoreService"

    invoke-virtual {v0, v2}, Landroid/os/Parcel;->writeInterfaceToken(Ljava/lang/String;)V

    invoke-virtual {v0, p1}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    invoke-virtual {v0, p2}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    iget-object v2, p0, Lcom/sec/ims/ICentralMsgStoreService$Stub$Proxy;->mRemote:Landroid/os/IBinder;

    const/16 v3, 0x17

    const/4 v4, 0x0

    invoke-interface {v2, v3, v0, v1, v4}, Landroid/os/IBinder;->transact(ILandroid/os/Parcel;Landroid/os/Parcel;I)Z

    invoke-virtual {v1}, Landroid/os/Parcel;->readException()V
    :try_end_0
    .catchall {:try_start_0 .. :try_end_0} :catchall_0

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    return-void

    :catchall_0
    move-exception v2

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    throw v2
.end method

.method public deleteParticipant(Ljava/lang/String;Ljava/lang/String;)V
    .locals 5
    .annotation system Ldalvik/annotation/Throws;
        value = {
            Landroid/os/RemoteException;
        }
    .end annotation

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v0

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v1

    :try_start_0
    const-string/jumbo v2, "com.sec.ims.ICentralMsgStoreService"

    invoke-virtual {v0, v2}, Landroid/os/Parcel;->writeInterfaceToken(Ljava/lang/String;)V

    invoke-virtual {v0, p1}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    invoke-virtual {v0, p2}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    iget-object v2, p0, Lcom/sec/ims/ICentralMsgStoreService$Stub$Proxy;->mRemote:Landroid/os/IBinder;

    const/16 v3, 0x15

    const/4 v4, 0x0

    invoke-interface {v2, v3, v0, v1, v4}, Landroid/os/IBinder;->transact(ILandroid/os/Parcel;Landroid/os/Parcel;I)Z

    invoke-virtual {v1}, Landroid/os/Parcel;->readException()V
    :try_end_0
    .catchall {:try_start_0 .. :try_end_0} :catchall_0

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    return-void

    :catchall_0
    move-exception v2

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    throw v2
.end method

.method public deleteSession(Ljava/lang/String;Ljava/lang/String;)V
    .locals 5
    .annotation system Ldalvik/annotation/Throws;
        value = {
            Landroid/os/RemoteException;
        }
    .end annotation

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v0

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v1

    :try_start_0
    const-string/jumbo v2, "com.sec.ims.ICentralMsgStoreService"

    invoke-virtual {v0, v2}, Landroid/os/Parcel;->writeInterfaceToken(Ljava/lang/String;)V

    invoke-virtual {v0, p1}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    invoke-virtual {v0, p2}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    iget-object v2, p0, Lcom/sec/ims/ICentralMsgStoreService$Stub$Proxy;->mRemote:Landroid/os/IBinder;

    const/16 v3, 0x14

    const/4 v4, 0x0

    invoke-interface {v2, v3, v0, v1, v4}, Landroid/os/IBinder;->transact(ILandroid/os/Parcel;Landroid/os/Parcel;I)Z

    invoke-virtual {v1}, Landroid/os/Parcel;->readException()V
    :try_end_0
    .catchall {:try_start_0 .. :try_end_0} :catchall_0

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    return-void

    :catchall_0
    move-exception v2

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    throw v2
.end method

.method public disableAutoSync(Ljava/lang/String;Ljava/lang/String;)V
    .locals 5
    .annotation system Ldalvik/annotation/Throws;
        value = {
            Landroid/os/RemoteException;
        }
    .end annotation

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v0

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v1

    :try_start_0
    const-string/jumbo v2, "com.sec.ims.ICentralMsgStoreService"

    invoke-virtual {v0, v2}, Landroid/os/Parcel;->writeInterfaceToken(Ljava/lang/String;)V

    invoke-virtual {v0, p1}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    invoke-virtual {v0, p2}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    iget-object v2, p0, Lcom/sec/ims/ICentralMsgStoreService$Stub$Proxy;->mRemote:Landroid/os/IBinder;

    const/16 v3, 0x1d

    const/4 v4, 0x0

    invoke-interface {v2, v3, v0, v1, v4}, Landroid/os/IBinder;->transact(ILandroid/os/Parcel;Landroid/os/Parcel;I)Z

    invoke-virtual {v1}, Landroid/os/Parcel;->readException()V
    :try_end_0
    .catchall {:try_start_0 .. :try_end_0} :catchall_0

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    return-void

    :catchall_0
    move-exception v2

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    throw v2
.end method

.method public downloadMessage(Ljava/lang/String;Ljava/lang/String;)V
    .locals 5
    .annotation system Ldalvik/annotation/Throws;
        value = {
            Landroid/os/RemoteException;
        }
    .end annotation

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v0

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v1

    :try_start_0
    const-string/jumbo v2, "com.sec.ims.ICentralMsgStoreService"

    invoke-virtual {v0, v2}, Landroid/os/Parcel;->writeInterfaceToken(Ljava/lang/String;)V

    invoke-virtual {v0, p1}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    invoke-virtual {v0, p2}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    iget-object v2, p0, Lcom/sec/ims/ICentralMsgStoreService$Stub$Proxy;->mRemote:Landroid/os/IBinder;

    const/4 v3, 0x7

    const/4 v4, 0x0

    invoke-interface {v2, v3, v0, v1, v4}, Landroid/os/IBinder;->transact(ILandroid/os/Parcel;Landroid/os/Parcel;I)Z

    invoke-virtual {v1}, Landroid/os/Parcel;->readException()V
    :try_end_0
    .catchall {:try_start_0 .. :try_end_0} :catchall_0

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    return-void

    :catchall_0
    move-exception v2

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    throw v2
.end method

.method public enableAutoSync(Ljava/lang/String;Ljava/lang/String;)V
    .locals 5
    .annotation system Ldalvik/annotation/Throws;
        value = {
            Landroid/os/RemoteException;
        }
    .end annotation

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v0

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v1

    :try_start_0
    const-string/jumbo v2, "com.sec.ims.ICentralMsgStoreService"

    invoke-virtual {v0, v2}, Landroid/os/Parcel;->writeInterfaceToken(Ljava/lang/String;)V

    invoke-virtual {v0, p1}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    invoke-virtual {v0, p2}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    iget-object v2, p0, Lcom/sec/ims/ICentralMsgStoreService$Stub$Proxy;->mRemote:Landroid/os/IBinder;

    const/16 v3, 0x1c

    const/4 v4, 0x0

    invoke-interface {v2, v3, v0, v1, v4}, Landroid/os/IBinder;->transact(ILandroid/os/Parcel;Landroid/os/Parcel;I)Z

    invoke-virtual {v1}, Landroid/os/Parcel;->readException()V
    :try_end_0
    .catchall {:try_start_0 .. :try_end_0} :catchall_0

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    return-void

    :catchall_0
    move-exception v2

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    throw v2
.end method

.method public getInterfaceDescriptor()Ljava/lang/String;
    .locals 1

    const-string/jumbo v0, "com.sec.ims.ICentralMsgStoreService"

    return-object v0
.end method

.method public manualSync(Ljava/lang/String;Ljava/lang/String;)V
    .locals 5
    .annotation system Ldalvik/annotation/Throws;
        value = {
            Landroid/os/RemoteException;
        }
    .end annotation

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v0

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v1

    :try_start_0
    const-string/jumbo v2, "com.sec.ims.ICentralMsgStoreService"

    invoke-virtual {v0, v2}, Landroid/os/Parcel;->writeInterfaceToken(Ljava/lang/String;)V

    invoke-virtual {v0, p1}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    invoke-virtual {v0, p2}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    iget-object v2, p0, Lcom/sec/ims/ICentralMsgStoreService$Stub$Proxy;->mRemote:Landroid/os/IBinder;

    const/16 v3, 0x1b

    const/4 v4, 0x0

    invoke-interface {v2, v3, v0, v1, v4}, Landroid/os/IBinder;->transact(ILandroid/os/Parcel;Landroid/os/Parcel;I)Z

    invoke-virtual {v1}, Landroid/os/Parcel;->readException()V
    :try_end_0
    .catchall {:try_start_0 .. :try_end_0} :catchall_0

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    return-void

    :catchall_0
    move-exception v2

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    throw v2
.end method

.method public notifyCloudMessageUpdate(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V
    .locals 5
    .annotation system Ldalvik/annotation/Throws;
        value = {
            Landroid/os/RemoteException;
        }
    .end annotation

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v0

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v1

    :try_start_0
    const-string/jumbo v2, "com.sec.ims.ICentralMsgStoreService"

    invoke-virtual {v0, v2}, Landroid/os/Parcel;->writeInterfaceToken(Ljava/lang/String;)V

    invoke-virtual {v0, p1}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    invoke-virtual {v0, p2}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    invoke-virtual {v0, p3}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    iget-object v2, p0, Lcom/sec/ims/ICentralMsgStoreService$Stub$Proxy;->mRemote:Landroid/os/IBinder;

    const/16 v3, 0x11

    const/4 v4, 0x0

    invoke-interface {v2, v3, v0, v1, v4}, Landroid/os/IBinder;->transact(ILandroid/os/Parcel;Landroid/os/Parcel;I)Z

    invoke-virtual {v1}, Landroid/os/Parcel;->readException()V
    :try_end_0
    .catchall {:try_start_0 .. :try_end_0} :catchall_0

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    return-void

    :catchall_0
    move-exception v2

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    throw v2
.end method

.method public notifyUIScreen(Ljava/lang/String;ILjava/lang/String;I)V
    .locals 5
    .annotation system Ldalvik/annotation/Throws;
        value = {
            Landroid/os/RemoteException;
        }
    .end annotation

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v0

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v1

    :try_start_0
    const-string/jumbo v2, "com.sec.ims.ICentralMsgStoreService"

    invoke-virtual {v0, v2}, Landroid/os/Parcel;->writeInterfaceToken(Ljava/lang/String;)V

    invoke-virtual {v0, p1}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    invoke-virtual {v0, p2}, Landroid/os/Parcel;->writeInt(I)V

    invoke-virtual {v0, p3}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    invoke-virtual {v0, p4}, Landroid/os/Parcel;->writeInt(I)V

    iget-object v2, p0, Lcom/sec/ims/ICentralMsgStoreService$Stub$Proxy;->mRemote:Landroid/os/IBinder;

    const/16 v3, 0x1a

    const/4 v4, 0x0

    invoke-interface {v2, v3, v0, v1, v4}, Landroid/os/IBinder;->transact(ILandroid/os/Parcel;Landroid/os/Parcel;I)Z

    invoke-virtual {v1}, Landroid/os/Parcel;->readException()V
    :try_end_0
    .catchall {:try_start_0 .. :try_end_0} :catchall_0

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    return-void

    :catchall_0
    move-exception v2

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    throw v2
.end method

.method public onBufferDBReadResult(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;IZ)V
    .locals 5
    .annotation system Ldalvik/annotation/Throws;
        value = {
            Landroid/os/RemoteException;
        }
    .end annotation

    const/4 v2, 0x0

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v0

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v1

    :try_start_0
    const-string/jumbo v3, "com.sec.ims.ICentralMsgStoreService"

    invoke-virtual {v0, v3}, Landroid/os/Parcel;->writeInterfaceToken(Ljava/lang/String;)V

    invoke-virtual {v0, p1}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    invoke-virtual {v0, p2}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    invoke-virtual {v0, p3}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    invoke-virtual {v0, p4}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    invoke-virtual {v0, p5}, Landroid/os/Parcel;->writeInt(I)V

    if-eqz p6, :cond_0

    const/4 v2, 0x1

    :cond_0
    invoke-virtual {v0, v2}, Landroid/os/Parcel;->writeInt(I)V

    iget-object v2, p0, Lcom/sec/ims/ICentralMsgStoreService$Stub$Proxy;->mRemote:Landroid/os/IBinder;

    const/16 v3, 0xc

    const/4 v4, 0x0

    invoke-interface {v2, v3, v0, v1, v4}, Landroid/os/IBinder;->transact(ILandroid/os/Parcel;Landroid/os/Parcel;I)Z

    invoke-virtual {v1}, Landroid/os/Parcel;->readException()V
    :try_end_0
    .catchall {:try_start_0 .. :try_end_0} :catchall_0

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    return-void

    :catchall_0
    move-exception v2

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    throw v2
.end method

.method public onBufferDBReadResultBatch(Ljava/lang/String;Ljava/lang/String;)V
    .locals 5
    .annotation system Ldalvik/annotation/Throws;
        value = {
            Landroid/os/RemoteException;
        }
    .end annotation

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v0

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v1

    :try_start_0
    const-string/jumbo v2, "com.sec.ims.ICentralMsgStoreService"

    invoke-virtual {v0, v2}, Landroid/os/Parcel;->writeInterfaceToken(Ljava/lang/String;)V

    invoke-virtual {v0, p1}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    invoke-virtual {v0, p2}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    iget-object v2, p0, Lcom/sec/ims/ICentralMsgStoreService$Stub$Proxy;->mRemote:Landroid/os/IBinder;

    const/16 v3, 0xd

    const/4 v4, 0x0

    invoke-interface {v2, v3, v0, v1, v4}, Landroid/os/IBinder;->transact(ILandroid/os/Parcel;Landroid/os/Parcel;I)Z

    invoke-virtual {v1}, Landroid/os/Parcel;->readException()V
    :try_end_0
    .catchall {:try_start_0 .. :try_end_0} :catchall_0

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    return-void

    :catchall_0
    move-exception v2

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    throw v2
.end method

.method public onRCSDBReady(Ljava/lang/String;)V
    .locals 5
    .annotation system Ldalvik/annotation/Throws;
        value = {
            Landroid/os/RemoteException;
        }
    .end annotation

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v0

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v1

    :try_start_0
    const-string/jumbo v2, "com.sec.ims.ICentralMsgStoreService"

    invoke-virtual {v0, v2}, Landroid/os/Parcel;->writeInterfaceToken(Ljava/lang/String;)V

    invoke-virtual {v0, p1}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    iget-object v2, p0, Lcom/sec/ims/ICentralMsgStoreService$Stub$Proxy;->mRemote:Landroid/os/IBinder;

    const/16 v3, 0x16

    const/4 v4, 0x0

    invoke-interface {v2, v3, v0, v1, v4}, Landroid/os/IBinder;->transact(ILandroid/os/Parcel;Landroid/os/Parcel;I)Z

    invoke-virtual {v1}, Landroid/os/Parcel;->readException()V
    :try_end_0
    .catchall {:try_start_0 .. :try_end_0} :catchall_0

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    return-void

    :catchall_0
    move-exception v2

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    throw v2
.end method

.method public onUIButtonProceed(Ljava/lang/String;ILjava/lang/String;)Z
    .locals 6
    .annotation system Ldalvik/annotation/Throws;
        value = {
            Landroid/os/RemoteException;
        }
    .end annotation

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v0

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v1

    :try_start_0
    const-string/jumbo v3, "com.sec.ims.ICentralMsgStoreService"

    invoke-virtual {v0, v3}, Landroid/os/Parcel;->writeInterfaceToken(Ljava/lang/String;)V

    invoke-virtual {v0, p1}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    invoke-virtual {v0, p2}, Landroid/os/Parcel;->writeInt(I)V

    invoke-virtual {v0, p3}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    iget-object v3, p0, Lcom/sec/ims/ICentralMsgStoreService$Stub$Proxy;->mRemote:Landroid/os/IBinder;

    const/16 v4, 0xb

    const/4 v5, 0x0

    invoke-interface {v3, v4, v0, v1, v5}, Landroid/os/IBinder;->transact(ILandroid/os/Parcel;Landroid/os/Parcel;I)Z

    invoke-virtual {v1}, Landroid/os/Parcel;->readException()V

    invoke-virtual {v1}, Landroid/os/Parcel;->readInt()I
    :try_end_0
    .catchall {:try_start_0 .. :try_end_0} :catchall_0

    move-result v3

    if-eqz v3, :cond_0

    const/4 v2, 0x1

    :goto_0
    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    return v2

    :cond_0
    const/4 v2, 0x0

    goto :goto_0

    :catchall_0
    move-exception v3

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    throw v3
.end method

.method public onUserEnterApp(Ljava/lang/String;)V
    .locals 5
    .annotation system Ldalvik/annotation/Throws;
        value = {
            Landroid/os/RemoteException;
        }
    .end annotation

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v0

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v1

    :try_start_0
    const-string/jumbo v2, "com.sec.ims.ICentralMsgStoreService"

    invoke-virtual {v0, v2}, Landroid/os/Parcel;->writeInterfaceToken(Ljava/lang/String;)V

    invoke-virtual {v0, p1}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    iget-object v2, p0, Lcom/sec/ims/ICentralMsgStoreService$Stub$Proxy;->mRemote:Landroid/os/IBinder;

    const/16 v3, 0x9

    const/4 v4, 0x0

    invoke-interface {v2, v3, v0, v1, v4}, Landroid/os/IBinder;->transact(ILandroid/os/Parcel;Landroid/os/Parcel;I)Z

    invoke-virtual {v1}, Landroid/os/Parcel;->readException()V
    :try_end_0
    .catchall {:try_start_0 .. :try_end_0} :catchall_0

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    return-void

    :catchall_0
    move-exception v2

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    throw v2
.end method

.method public onUserLeaveApp(Ljava/lang/String;)V
    .locals 5
    .annotation system Ldalvik/annotation/Throws;
        value = {
            Landroid/os/RemoteException;
        }
    .end annotation

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v0

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v1

    :try_start_0
    const-string/jumbo v2, "com.sec.ims.ICentralMsgStoreService"

    invoke-virtual {v0, v2}, Landroid/os/Parcel;->writeInterfaceToken(Ljava/lang/String;)V

    invoke-virtual {v0, p1}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    iget-object v2, p0, Lcom/sec/ims/ICentralMsgStoreService$Stub$Proxy;->mRemote:Landroid/os/IBinder;

    const/16 v3, 0xa

    const/4 v4, 0x0

    invoke-interface {v2, v3, v0, v1, v4}, Landroid/os/IBinder;->transact(ILandroid/os/Parcel;Landroid/os/Parcel;I)Z

    invoke-virtual {v1}, Landroid/os/Parcel;->readException()V
    :try_end_0
    .catchall {:try_start_0 .. :try_end_0} :catchall_0

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    return-void

    :catchall_0
    move-exception v2

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    throw v2
.end method

.method public readMessage(Ljava/lang/String;Ljava/lang/String;)V
    .locals 5
    .annotation system Ldalvik/annotation/Throws;
        value = {
            Landroid/os/RemoteException;
        }
    .end annotation

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v0

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v1

    :try_start_0
    const-string/jumbo v2, "com.sec.ims.ICentralMsgStoreService"

    invoke-virtual {v0, v2}, Landroid/os/Parcel;->writeInterfaceToken(Ljava/lang/String;)V

    invoke-virtual {v0, p1}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    invoke-virtual {v0, p2}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    iget-object v2, p0, Lcom/sec/ims/ICentralMsgStoreService$Stub$Proxy;->mRemote:Landroid/os/IBinder;

    const/4 v3, 0x3

    const/4 v4, 0x0

    invoke-interface {v2, v3, v0, v1, v4}, Landroid/os/IBinder;->transact(ILandroid/os/Parcel;Landroid/os/Parcel;I)Z

    invoke-virtual {v1}, Landroid/os/Parcel;->readException()V
    :try_end_0
    .catchall {:try_start_0 .. :try_end_0} :catchall_0

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    return-void

    :catchall_0
    move-exception v2

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    throw v2
.end method

.method public receivedMessage(Ljava/lang/String;Ljava/lang/String;)V
    .locals 5
    .annotation system Ldalvik/annotation/Throws;
        value = {
            Landroid/os/RemoteException;
        }
    .end annotation

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v0

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v1

    :try_start_0
    const-string/jumbo v2, "com.sec.ims.ICentralMsgStoreService"

    invoke-virtual {v0, v2}, Landroid/os/Parcel;->writeInterfaceToken(Ljava/lang/String;)V

    invoke-virtual {v0, p1}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    invoke-virtual {v0, p2}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    iget-object v2, p0, Lcom/sec/ims/ICentralMsgStoreService$Stub$Proxy;->mRemote:Landroid/os/IBinder;

    const/4 v3, 0x1

    const/4 v4, 0x0

    invoke-interface {v2, v3, v0, v1, v4}, Landroid/os/IBinder;->transact(ILandroid/os/Parcel;Landroid/os/Parcel;I)Z

    invoke-virtual {v1}, Landroid/os/Parcel;->readException()V
    :try_end_0
    .catchall {:try_start_0 .. :try_end_0} :catchall_0

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    return-void

    :catchall_0
    move-exception v2

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    throw v2
.end method

.method public registerCallback(Ljava/lang/String;Lcom/sec/ims/ICentralMsgStoreService;)V
    .locals 5
    .annotation system Ldalvik/annotation/Throws;
        value = {
            Landroid/os/RemoteException;
        }
    .end annotation

    const/4 v2, 0x0

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v0

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v1

    :try_start_0
    const-string/jumbo v3, "com.sec.ims.ICentralMsgStoreService"

    invoke-virtual {v0, v3}, Landroid/os/Parcel;->writeInterfaceToken(Ljava/lang/String;)V

    invoke-virtual {v0, p1}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    if-eqz p2, :cond_0

    invoke-interface {p2}, Lcom/sec/ims/ICentralMsgStoreService;->asBinder()Landroid/os/IBinder;

    move-result-object v2

    :cond_0
    invoke-virtual {v0, v2}, Landroid/os/Parcel;->writeStrongBinder(Landroid/os/IBinder;)V

    iget-object v2, p0, Lcom/sec/ims/ICentralMsgStoreService$Stub$Proxy;->mRemote:Landroid/os/IBinder;

    const/16 v3, 0xe

    const/4 v4, 0x0

    invoke-interface {v2, v3, v0, v1, v4}, Landroid/os/IBinder;->transact(ILandroid/os/Parcel;Landroid/os/Parcel;I)Z

    invoke-virtual {v1}, Landroid/os/Parcel;->readException()V
    :try_end_0
    .catchall {:try_start_0 .. :try_end_0} :catchall_0

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    return-void

    :catchall_0
    move-exception v2

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    throw v2
.end method

.method public restartService(Ljava/lang/String;)V
    .locals 5
    .annotation system Ldalvik/annotation/Throws;
        value = {
            Landroid/os/RemoteException;
        }
    .end annotation

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v0

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v1

    :try_start_0
    const-string/jumbo v2, "com.sec.ims.ICentralMsgStoreService"

    invoke-virtual {v0, v2}, Landroid/os/Parcel;->writeInterfaceToken(Ljava/lang/String;)V

    invoke-virtual {v0, p1}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    iget-object v2, p0, Lcom/sec/ims/ICentralMsgStoreService$Stub$Proxy;->mRemote:Landroid/os/IBinder;

    const/16 v3, 0x19

    const/4 v4, 0x0

    invoke-interface {v2, v3, v0, v1, v4}, Landroid/os/IBinder;->transact(ILandroid/os/Parcel;Landroid/os/Parcel;I)Z

    invoke-virtual {v1}, Landroid/os/Parcel;->readException()V
    :try_end_0
    .catchall {:try_start_0 .. :try_end_0} :catchall_0

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    return-void

    :catchall_0
    move-exception v2

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    throw v2
.end method

.method public resumeSync(Ljava/lang/String;)V
    .locals 5
    .annotation system Ldalvik/annotation/Throws;
        value = {
            Landroid/os/RemoteException;
        }
    .end annotation

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v0

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v1

    :try_start_0
    const-string/jumbo v2, "com.sec.ims.ICentralMsgStoreService"

    invoke-virtual {v0, v2}, Landroid/os/Parcel;->writeInterfaceToken(Ljava/lang/String;)V

    invoke-virtual {v0, p1}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    iget-object v2, p0, Lcom/sec/ims/ICentralMsgStoreService$Stub$Proxy;->mRemote:Landroid/os/IBinder;

    const/16 v3, 0x18

    const/4 v4, 0x0

    invoke-interface {v2, v3, v0, v1, v4}, Landroid/os/IBinder;->transact(ILandroid/os/Parcel;Landroid/os/Parcel;I)Z

    invoke-virtual {v1}, Landroid/os/Parcel;->readException()V
    :try_end_0
    .catchall {:try_start_0 .. :try_end_0} :catchall_0

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    return-void

    :catchall_0
    move-exception v2

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    throw v2
.end method

.method public sentMessage(Ljava/lang/String;Ljava/lang/String;)V
    .locals 5
    .annotation system Ldalvik/annotation/Throws;
        value = {
            Landroid/os/RemoteException;
        }
    .end annotation

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v0

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v1

    :try_start_0
    const-string/jumbo v2, "com.sec.ims.ICentralMsgStoreService"

    invoke-virtual {v0, v2}, Landroid/os/Parcel;->writeInterfaceToken(Ljava/lang/String;)V

    invoke-virtual {v0, p1}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    invoke-virtual {v0, p2}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    iget-object v2, p0, Lcom/sec/ims/ICentralMsgStoreService$Stub$Proxy;->mRemote:Landroid/os/IBinder;

    const/4 v3, 0x2

    const/4 v4, 0x0

    invoke-interface {v2, v3, v0, v1, v4}, Landroid/os/IBinder;->transact(ILandroid/os/Parcel;Landroid/os/Parcel;I)Z

    invoke-virtual {v1}, Landroid/os/Parcel;->readException()V
    :try_end_0
    .catchall {:try_start_0 .. :try_end_0} :catchall_0

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    return-void

    :catchall_0
    move-exception v2

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    throw v2
.end method

.method public startFullSync(Ljava/lang/String;Ljava/lang/String;)V
    .locals 5
    .annotation system Ldalvik/annotation/Throws;
        value = {
            Landroid/os/RemoteException;
        }
    .end annotation

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v0

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v1

    :try_start_0
    const-string/jumbo v2, "com.sec.ims.ICentralMsgStoreService"

    invoke-virtual {v0, v2}, Landroid/os/Parcel;->writeInterfaceToken(Ljava/lang/String;)V

    invoke-virtual {v0, p1}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    invoke-virtual {v0, p2}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    iget-object v2, p0, Lcom/sec/ims/ICentralMsgStoreService$Stub$Proxy;->mRemote:Landroid/os/IBinder;

    const/16 v3, 0x10

    const/4 v4, 0x0

    invoke-interface {v2, v3, v0, v1, v4}, Landroid/os/IBinder;->transact(ILandroid/os/Parcel;Landroid/os/Parcel;I)Z

    invoke-virtual {v1}, Landroid/os/Parcel;->readException()V
    :try_end_0
    .catchall {:try_start_0 .. :try_end_0} :catchall_0

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    return-void

    :catchall_0
    move-exception v2

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    throw v2
.end method

.method public stopSync(Ljava/lang/String;Ljava/lang/String;)V
    .locals 5
    .annotation system Ldalvik/annotation/Throws;
        value = {
            Landroid/os/RemoteException;
        }
    .end annotation

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v0

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v1

    :try_start_0
    const-string/jumbo v2, "com.sec.ims.ICentralMsgStoreService"

    invoke-virtual {v0, v2}, Landroid/os/Parcel;->writeInterfaceToken(Ljava/lang/String;)V

    invoke-virtual {v0, p1}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    invoke-virtual {v0, p2}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    iget-object v2, p0, Lcom/sec/ims/ICentralMsgStoreService$Stub$Proxy;->mRemote:Landroid/os/IBinder;

    const/16 v3, 0xf

    const/4 v4, 0x0

    invoke-interface {v2, v3, v0, v1, v4}, Landroid/os/IBinder;->transact(ILandroid/os/Parcel;Landroid/os/Parcel;I)Z

    invoke-virtual {v1}, Landroid/os/Parcel;->readException()V
    :try_end_0
    .catchall {:try_start_0 .. :try_end_0} :catchall_0

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    return-void

    :catchall_0
    move-exception v2

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    throw v2
.end method

.method public unReadMessage(Ljava/lang/String;Ljava/lang/String;)V
    .locals 5
    .annotation system Ldalvik/annotation/Throws;
        value = {
            Landroid/os/RemoteException;
        }
    .end annotation

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v0

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v1

    :try_start_0
    const-string/jumbo v2, "com.sec.ims.ICentralMsgStoreService"

    invoke-virtual {v0, v2}, Landroid/os/Parcel;->writeInterfaceToken(Ljava/lang/String;)V

    invoke-virtual {v0, p1}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    invoke-virtual {v0, p2}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    iget-object v2, p0, Lcom/sec/ims/ICentralMsgStoreService$Stub$Proxy;->mRemote:Landroid/os/IBinder;

    const/4 v3, 0x4

    const/4 v4, 0x0

    invoke-interface {v2, v3, v0, v1, v4}, Landroid/os/IBinder;->transact(ILandroid/os/Parcel;Landroid/os/Parcel;I)Z

    invoke-virtual {v1}, Landroid/os/Parcel;->readException()V
    :try_end_0
    .catchall {:try_start_0 .. :try_end_0} :catchall_0

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    return-void

    :catchall_0
    move-exception v2

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    throw v2
.end method

.method public uploadMessage(Ljava/lang/String;Ljava/lang/String;)V
    .locals 5
    .annotation system Ldalvik/annotation/Throws;
        value = {
            Landroid/os/RemoteException;
        }
    .end annotation

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v0

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v1

    :try_start_0
    const-string/jumbo v2, "com.sec.ims.ICentralMsgStoreService"

    invoke-virtual {v0, v2}, Landroid/os/Parcel;->writeInterfaceToken(Ljava/lang/String;)V

    invoke-virtual {v0, p1}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    invoke-virtual {v0, p2}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    iget-object v2, p0, Lcom/sec/ims/ICentralMsgStoreService$Stub$Proxy;->mRemote:Landroid/os/IBinder;

    const/4 v3, 0x6

    const/4 v4, 0x0

    invoke-interface {v2, v3, v0, v1, v4}, Landroid/os/IBinder;->transact(ILandroid/os/Parcel;Landroid/os/Parcel;I)Z

    invoke-virtual {v1}, Landroid/os/Parcel;->readException()V
    :try_end_0
    .catchall {:try_start_0 .. :try_end_0} :catchall_0

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    return-void

    :catchall_0
    move-exception v2

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    throw v2
.end method

.method public wipeOutMessage(Ljava/lang/String;Ljava/lang/String;)V
    .locals 5
    .annotation system Ldalvik/annotation/Throws;
        value = {
            Landroid/os/RemoteException;
        }
    .end annotation

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v0

    invoke-static {}, Landroid/os/Parcel;->obtain()Landroid/os/Parcel;

    move-result-object v1

    :try_start_0
    const-string/jumbo v2, "com.sec.ims.ICentralMsgStoreService"

    invoke-virtual {v0, v2}, Landroid/os/Parcel;->writeInterfaceToken(Ljava/lang/String;)V

    invoke-virtual {v0, p1}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    invoke-virtual {v0, p2}, Landroid/os/Parcel;->writeString(Ljava/lang/String;)V

    iget-object v2, p0, Lcom/sec/ims/ICentralMsgStoreService$Stub$Proxy;->mRemote:Landroid/os/IBinder;

    const/16 v3, 0x8

    const/4 v4, 0x0

    invoke-interface {v2, v3, v0, v1, v4}, Landroid/os/IBinder;->transact(ILandroid/os/Parcel;Landroid/os/Parcel;I)Z

    invoke-virtual {v1}, Landroid/os/Parcel;->readException()V
    :try_end_0
    .catchall {:try_start_0 .. :try_end_0} :catchall_0

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    return-void

    :catchall_0
    move-exception v2

    invoke-virtual {v1}, Landroid/os/Parcel;->recycle()V

    invoke-virtual {v0}, Landroid/os/Parcel;->recycle()V

    throw v2
.end method


text:
package org.apache.ignite.spi.discovery.tcp;

import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;
import java.util.UUID;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.atomic.AtomicInteger;
import org.apache.ignite.Ignite;
import org.apache.ignite.IgniteCheckedException;
import org.apache.ignite.IgniteSystemProperties;
import org.apache.ignite.configuration.IgniteConfiguration;
import org.apache.ignite.events.DiscoveryEvent;
import org.apache.ignite.events.Event;
import org.apache.ignite.internal.util.typedef.G;
import org.apache.ignite.lang.IgniteBiPredicate;
import org.apache.ignite.lang.IgnitePredicate;
import org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryAbstractMessage;
import org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryClientReconnectMessage;
import org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryJoinRequestMessage;
import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
import org.junit.Test;

import static java.util.concurrent.TimeUnit.MILLISECONDS;
import static org.apache.ignite.events.EventType.EVT_CLIENT_NODE_DISCONNECTED;
import static org.apache.ignite.events.EventType.EVT_CLIENT_NODE_RECONNECTED;
import static org.apache.ignite.events.EventType.EVT_NODE_FAILED;
import static org.apache.ignite.events.EventType.EVT_NODE_JOINED;
import static org.apache.ignite.spi.discovery.tcp.TcpDiscoveryImpl.RES_WAIT;

/**
 * Test for {@link TcpDiscoverySpi#setReconnectDelay(int)}.
 */
public class TcpDiscoverySpiReconnectDelayTest extends GridCommonAbstractTest {
    /** Time to wait for events. */
    private static final int EVT_TIMEOUT = 120000;

    /** Timeout for socket operations. */
    private static final int SOCK_AND_ACK_TIMEOUT = 500;

    static {
        System.setProperty(IgniteSystemProperties.IGNITE_QUIET, "false");
    }

    //region Client joins after failNode()

    /** */
    @Test
    public void testClientJoinAfterFailureShortTimeout() throws Exception {
        checkClientJoinAfterNodeFailure(5, 500);
    }

    /** */
    @Test
    public void testClientJoinAfterFailureLongTimeout() throws Exception {
        checkClientJoinAfterNodeFailure(3, 5000);
    }

    /**
     * Check that client restores connection after the given time, with the expected number of messages sent
     * and expected time elapsed.
     *
     * @param numOfFailedRequests number of TcpDiscoveryJoinRequestMessage to be failed before succeed to connect.
     * @param reconnectDelay argument for {@link TcpDiscoverySpi#setReconnectDelay(int)}
     */
    private void checkClientJoinAfterNodeFailure(int numOfFailedRequests, int reconnectDelay) throws Exception {
        try (
            Ignite ignite1 = G.start(getConfiguration("server", false, reconnectDelay));
            Ignite ignite2 = G.start(getConfiguration("client", true, reconnectDelay))
        ) {
            // Check topology.
            assertEquals(1L, ignite1.cluster().localNode().order());
            assertEquals(2L, ignite2.cluster().localNode().order());
            assertEquals(2L, ignite2.cluster().topologyVersion());

            final CountDownLatch failLatch = new CountDownLatch(1);
            final CountDownLatch joinLatch = new CountDownLatch(1);
            final CountDownLatch reconnectLatch = new CountDownLatch(1);
            final CountDownLatch disconnectLatch = new CountDownLatch(1);

            ignite1.events().localListen(new IgnitePredicate<DiscoveryEvent>() {
                @Override public boolean apply(DiscoveryEvent evt) {
                    info("Node1 event: " + evt);

                    if (evt.type() == EVT_NODE_FAILED)
                        failLatch.countDown();
                    else if (evt.type() == EVT_NODE_JOINED)
                        joinLatch.countDown();

                    return true;
                }
            }, EVT_NODE_FAILED, EVT_NODE_JOINED);

            ignite2.events().localListen(new IgnitePredicate<Event>() {
                @Override public boolean apply(Event evt) {
                    info("Node2 event: " + evt);

                    if (evt.type() == EVT_CLIENT_NODE_DISCONNECTED)
                        disconnectLatch.countDown();
                    else if (evt.type() == EVT_CLIENT_NODE_RECONNECTED)
                        reconnectLatch.countDown();

                    return true;
                }
            }, EVT_CLIENT_NODE_DISCONNECTED, EVT_CLIENT_NODE_RECONNECTED);

            long startTime = System.currentTimeMillis();

            AtomicInteger failJoinReq = ((FailingTcpDiscoverySpi)ignite2.configuration().getDiscoverySpi()).failJoinReq;
            failJoinReq.set(numOfFailedRequests);
            ignite1.configuration().getDiscoverySpi().failNode(ignite2.cluster().localNode().id(), null);

            assertTrue(disconnectLatch.await(EVT_TIMEOUT, MILLISECONDS));
            assertTrue(failLatch.await(EVT_TIMEOUT, MILLISECONDS));
            assertTrue(reconnectLatch.await(EVT_TIMEOUT, MILLISECONDS));
            assertTrue(joinLatch.await(EVT_TIMEOUT, MILLISECONDS));

            long endTime = System.currentTimeMillis();

            // Check topology.
            assertEquals(1L, ignite1.cluster().localNode().order());
            assertEquals(4L, ignite2.cluster().localNode().order());
            assertEquals(4L, ignite2.cluster().topologyVersion());

            // Check connection time.
            // Total time should be at least the sum of all delays.
            long totalTime = endTime - startTime;
            long expTotalTime = numOfFailedRequests * reconnectDelay;
            assertTrue(totalTime >= expTotalTime);

            // Check number of messages.
            // If exactly numOfFailedRequests fail, counter will be at -1.
            // If unexpected additional requests are sent, counter will be <= -2.
            int cntr = failJoinReq.get();
            int numOfMessages = numOfFailedRequests - cntr;
            int expNumOfMessages = numOfFailedRequests + 1;
            assertEquals("Unexpected number of messages", expNumOfMessages, numOfMessages);
        }
    }

    //endregion

    //region Client joins after brakeConnection()

    /** */
    @Test
    public void testClientJoinAfterSocketClosedShortTimeout() throws Exception {
        checkClientJoinAfterSocketClosed(5, 500);
    }

    /** */
    @Test
    public void testClientJoinAfterSocketClosedLongTimeout() throws Exception {
        checkClientJoinAfterSocketClosed(3, 5000);
    }

    /**
     * Check that client restores connection after the given time, with the expected number of messages sent
     * and expected time elapsed.
     *
     * @param numOfFailedRequests number of TcpDiscoveryJoinRequestMessage to be failed before succeed to connect.
     * @param reconnectDelay argument for {@link TcpDiscoverySpi#setReconnectDelay(int)}
     */
    private void checkClientJoinAfterSocketClosed(int numOfFailedRequests, int reconnectDelay) throws Exception {
        try (
            Ignite ignite1 = G.start(getConfiguration("server", false, reconnectDelay));
            Ignite ignite2 = G.start(getConfiguration("client", true, reconnectDelay))
        ) {
            // Check topology.
            assertEquals(1L, ignite1.cluster().localNode().order());
            assertEquals(2L, ignite2.cluster().localNode().order());
            assertEquals(2L, ignite2.cluster().topologyVersion());

            long startTime = System.currentTimeMillis();

            AtomicInteger failCntr = ((FailingTcpDiscoverySpi)ignite2.configuration().getDiscoverySpi()).failReconReq;
            failCntr.set(numOfFailedRequests);
            ((TcpDiscoverySpi)ignite2.configuration().getDiscoverySpi()).brakeConnection();

            // Need to send a discovery message to a remote node to provoke reconnection.
            // remoteListen() is used because it is synchronous (e.g. send() is not).
            ignite2.message().remoteListen(null, new DummyListener());

            long endTime = System.currentTimeMillis();

            // Check topology.
            assertEquals(1L, ignite1.cluster().localNode().order());
            assertEquals(2L, ignite2.cluster().localNode().order());
            assertEquals(2L, ignite2.cluster().topologyVersion());

            // Check connection time.
            // Total time should be at least the sum of all delays.
            long totalTime = endTime - startTime;
            long expTotalTime = numOfFailedRequests * reconnectDelay;
            assertTrue(totalTime >= expTotalTime);

            // Check number of messages.
            // If exactly numOfFailedRequests fail, counter will be at -1.
            // If unexpected additional requests are sent, counter will be <= -2.
            int cntr = failCntr.get();
            int numOfMessages = numOfFailedRequests - cntr;
            int expNumOfMessages = numOfFailedRequests + 1;
            assertEquals("Unexpected number of messages", expNumOfMessages, numOfMessages);
        }
    }

    //endregion

    //region Client joins at start

    /** */
    @Test
    public void testClientJoinAtStartShortTimeout() throws Exception {
        checkClientJoinAtStart(5, 500);
    }

    /** */
    @Test
    public void testClientJoinAtStartLongTimeout() throws Exception {
        checkClientJoinAtStart(3, 5000);
    }

    /** */
    @Test
    public void testServerJoinAtStartShortTimeout() throws Exception {
        checkServerJoinAtStart(5, 500);
    }

    /** */
    @Test
    public void testServerJoinAtStartLongTimeout() throws Exception {
        checkServerJoinAtStart(3, 5000);
    }

    /**
     * Check that client restores connection after the given time, with the expected number of messages sent
     * and expected time elapsed.
     *  @param numOfFailedRequests number of TcpDiscoveryJoinRequestMessage to be failed before succeed to connect.
     * @param reconnectDelay argument for {@link TcpDiscoverySpi#setReconnectDelay(int)}
     */
    private void checkClientJoinAtStart(int numOfFailedRequests, int reconnectDelay) throws Exception {
        try (
            Ignite ignite1 = G.start(getConfiguration("server", false, reconnectDelay))
        ) {
            final CountDownLatch joinLatch = new CountDownLatch(1);

            ignite1.events().localListen(new IgnitePredicate<DiscoveryEvent>() {
                @Override public boolean apply(DiscoveryEvent evt) {
                    info("Node1 event: " + evt);

                    if (evt.type() == EVT_NODE_JOINED)
                        joinLatch.countDown();

                    return true;
                }
            }, EVT_NODE_JOINED);

            IgniteConfiguration ignite2Cfg = getConfiguration("client", true, reconnectDelay);
            final AtomicInteger failJoinReq = ((FailingTcpDiscoverySpi)ignite2Cfg.getDiscoverySpi()).failJoinReq;
            failJoinReq.set(numOfFailedRequests);

            final long startTime = System.currentTimeMillis();

            try (Ignite ignite2 = G.start(ignite2Cfg)) {
                assertTrue(joinLatch.await(EVT_TIMEOUT, MILLISECONDS));

                long endTime = System.currentTimeMillis();

                // Check topology.
                assertEquals(1L, ignite1.cluster().localNode().order());
                assertEquals(2L, ignite2.cluster().localNode().order());
                assertEquals(2L, ignite2.cluster().topologyVersion());

                // Check connection time.
                // Total time should be at least the sum of all delays.
                long totalTime = endTime - startTime;
                long expTotalTime = numOfFailedRequests * reconnectDelay;
                assertTrue(totalTime >= expTotalTime);

                // Check number of messages.
                // If exactly numOfFailedRequests fail, counter will be at -1.
                // If unexpected additional requests are sent, counter will be <= -2.
                int cntr = failJoinReq.get();
                int numOfMessages = numOfFailedRequests - cntr;
                int expNumOfMessages = numOfFailedRequests + 1;
                assertEquals("Unexpected number of messages", expNumOfMessages, numOfMessages);
            }
        }
    }

    /**
     * Check that client restores connection after the given time, with the expected number of messages sent
     * and expected time elapsed.
     *  @param numOfFailedRequests number of TcpDiscoveryJoinRequestMessage to be failed before succeed to connect.
     * @param reconnectDelay argument for {@link TcpDiscoverySpi#setReconnectDelay(int)}
     */
    private void checkServerJoinAtStart(int numOfFailedRequests, int reconnectDelay) throws Exception {
        try (
            Ignite ignite1 = G.start(getConfiguration("server", false, reconnectDelay))
        ) {
            final CountDownLatch joinLatch = new CountDownLatch(1);
            final AtomicInteger failJoinReqRes = ((FailingTcpDiscoverySpi)ignite1.configuration().getDiscoverySpi())
                .failJoinReqRes;
            failJoinReqRes.set(numOfFailedRequests);

            ignite1.events().localListen(new IgnitePredicate<DiscoveryEvent>() {
                @Override public boolean apply(DiscoveryEvent evt) {
                    info("Node1 event: " + evt);

                    if (evt.type() == EVT_NODE_JOINED)
                        joinLatch.countDown();

                    return true;
                }
            }, EVT_NODE_JOINED);

            final long startTime = System.currentTimeMillis();

            try (Ignite ignite2 = G.start(getConfiguration("server-2", false, reconnectDelay))) {
                assertTrue(joinLatch.await(EVT_TIMEOUT, MILLISECONDS));

                long endTime = System.currentTimeMillis();

                // Check topology.
                assertEquals(1L, ignite1.cluster().localNode().order());
                assertEquals(2L, ignite2.cluster().localNode().order());
                assertEquals(2L, ignite2.cluster().topologyVersion());

                // Check connection time.
                // Total time should be at least the sum of all delays.
                long totalTime = endTime - startTime;
                long expTotalTime = numOfFailedRequests * reconnectDelay;
                assertTrue(totalTime >= expTotalTime);

                // Check number of messages.
                // If exactly numOfFailedRequests fail, counter will be at -1.
                // If unexpected additional requests are sent, counter will be <= -2.
                int cntr = failJoinReqRes.get();
                int numOfMessages = numOfFailedRequests - cntr;
                int expNumOfMessages = numOfFailedRequests + 1;
                assertEquals("Unexpected number of messages", expNumOfMessages, numOfMessages);
            }
        }
    }

    //endregion

    //region Helpers

    /** */
    private IgniteConfiguration getConfiguration(String name, boolean isClient, int reconnectDelay) {
        IgniteConfiguration cfg = new IgniteConfiguration()
            .setIgniteInstanceName(name)
            .setDiscoverySpi(new FailingTcpDiscoverySpi()
                .setIpFinder(LOCAL_IP_FINDER)
                .setReconnectDelay(reconnectDelay)
                // Allow reconnection to take long.
                .setNetworkTimeout(EVT_TIMEOUT)
                // Make sure reconnection attempts are short enough.
                // Each reconnection attempt is
                // 500ms for write (socketTimeout) + 500ms for read (ackTimeout)
                // tried only once.
                .setSocketTimeout(SOCK_AND_ACK_TIMEOUT)
                .setAckTimeout(SOCK_AND_ACK_TIMEOUT)
                .setReconnectCount(1))
            // Make sure that server doesn't kick reconnecting client out.
            .setClientFailureDetectionTimeout(EVT_TIMEOUT);

        if (isClient)
            cfg.setClientMode(true);
        return cfg;
    }

    /** Custom Discovery SPI allowing to fail sending of certain messages. */
    private static class FailingTcpDiscoverySpi extends TcpDiscoverySpi {
        /** */
        private final AtomicInteger failJoinReq = new AtomicInteger();

        /** */
        private final AtomicInteger failJoinReqRes = new AtomicInteger();

        /** */
        private final AtomicInteger failReconReq = new AtomicInteger();

        /** {@inheritDoc} */
        @Override protected void writeToSocket(Socket sock, OutputStream out, TcpDiscoveryAbstractMessage msg,
            long timeout) throws IOException, IgniteCheckedException {

            if (!onMessage(sock, msg))
                return;

            super.writeToSocket(sock, out, msg, timeout);
        }

        /** {@inheritDoc} */
        @Override protected void writeToSocket(TcpDiscoveryAbstractMessage msg, Socket sock, int res,
            long timeout) throws IOException {

            if (msg instanceof TcpDiscoveryJoinRequestMessage && failJoinReqRes.getAndDecrement() > 0)
                res = RES_WAIT;

            super.writeToSocket(msg, sock, res, timeout);
        }

        /**
         * @param sock Socket.
         * @param msg Message.
         * @return {@code False} if should not further process message.
         * @throws IOException If failed.
         */
        private boolean onMessage(Socket sock, TcpDiscoveryAbstractMessage msg) throws IOException {
            boolean fail = false;

            if (msg instanceof TcpDiscoveryJoinRequestMessage)
                fail = failJoinReq.getAndDecrement() > 0;
            if (msg instanceof TcpDiscoveryClientReconnectMessage)
                fail = failReconReq.getAndDecrement() > 0;

            if (fail) {
                log.info("Close socket on message write [msg=" + msg + "]");

                sock.close();
            }

            return true;
        }
    }

    /** */
    private static class DummyListener implements IgniteBiPredicate<UUID, Object> {
        /** {@inheritDoc} */
        @Override public boolean apply(UUID uuid, Object msg) {
            return true;
        }
    }

    //endregion
}

redpajama_set_name: RedPajamaGithub


text:
package org.swtk.common.dict.beans;

import java.util.Set;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Lazy;
import org.springframework.core.io.Resource;
import org.springframework.stereotype.Component;
import org.swtk.common.dict.DictionaryBase;

import com.trimc.blogger.commons.LogManager;

@Lazy
@Component("nounPhrasesDictionary")
public class NounPhrasesDictionary extends DictionaryBase {

	public static LogManager	logger	= new LogManager(NounPhrasesDictionary.class);

	@Autowired
	@Value("${properties.nounPhrases.path}")
	private Resource			resource;

	@Override
	public Set<String> entries() {
		return set(resource);
	}
}


text:
using System;
using System.Collections.Generic;
using System.ComponentModel.DataAnnotations;
using System.Linq;
using System.Web;

namespace AuxidyCinema.Models
{
    public class Movie
    {
        [Required]
        public int movieId { get; set; }
        [Required]
        [StringLength(255)]
        [Display(Name = "Name")]
        public string name { get; set; }
        [Required]
        [Display(Name = "Release Date")]
        public DateTime? releaseDate { get; set; }
        public Genre Genre { get; set; }
        [Required]
        [Display(Name = "Genre")]
        public int GenreId { get; set;}
    }
}


text:
var _ = require('lodash')
var React = require('react')
var TriangleDown = require('./SVGCollection').TriangleDown
var TriangleUp = require('./SVGCollection').TriangleUp
var color = require('../../js/color')

var OpenMenu = React.createClass({

    propTypes: {
        options: React.PropTypes.array,
        style: React.PropTypes.object,
        selected: React.PropTypes.string
    },

    getInitialState: function() {
        return {
            isExpanded: false
        }
    },

    onClick: function() {
        this.setState({
            isExpanded: !this.state.isExpanded
        })
    },

    onMouseLeave: function(e) {
        if (!e.currentTarget.getAttribute('data-openmenu')) {
            this.setState({
                isExpanded: false
            })
        }
    },

    render: function() {
        var that = this
        var text = 'bug'
        var cls = this.state.isExpanded ? '' : 'invisible'
        options = _.map(this.props.options, function(opt, i) {
            var className = 'dropupoption noselect'
            if (opt.key === that.props.selected) {
                text = opt.label
                className += ' selectedbutton'
            }
            var style = (i === that.props.options.length - 1) ? {borderBottom: '1px solid #dcdcdc'} : {}
            return (

                    {opt.label.toUpperCase().replace(/EXAC/, 'ExAC')}

            )
        })

        return (

                {options}

{text.toUpperCase()}
                <TriangleUp data-openmenu='true' className='dropuptriangle' />

        )
    }
})

module.exports = OpenMenu


text:
<?php
/**
 * @group
 */
class Kwf_Component_Cache_ProcessInput_Test extends Kwc_TestAbstract
{
    public function setUp()
    {
        parent::setUp('Kwf_Component_Cache_ProcessInput_Root');
    }

    public function testEmpty()
    {
        $c = $this->_root->getcomponentById('1');
        $pi = Kwf_Component_Abstract_ContentSender_Default::__getProcessInputComponents($c);
        $this->assertEquals(0, count($pi));
    }

    public function testDirectProcessInput()
    {
        $c = $this->_root->getcomponentById('2');
        $pi = Kwf_Component_Abstract_ContentSender_Default::__getProcessInputComponents($c);
        $this->assertEquals(1, count($pi));
        $pi = array_values($pi);
        $this->assertEquals('2', $pi[0]->componentId);
    }

    public function testContainsProcessInput()
    {
        $c = $this->_root->getcomponentById('3');
        $pi = Kwf_Component_Abstract_ContentSender_Default::__getProcessInputComponents($c);
        $this->assertEquals(1, count($pi));
        $pi = array_values($pi);
        $this->assertEquals('3-withProcessInput', $pi[0]->componentId);
    }

    public function testParagraphsDirectProcessInput()
    {
        $c = $this->_root->getcomponentById('4');
        $pi = Kwf_Component_Abstract_ContentSender_Default::__getProcessInputComponents($c);
        $this->assertEquals(2, count($pi));
        $pi = array_values($pi);
        $this->assertEquals('4-1', $pi[0]->componentId);
        $this->assertEquals('4-2-withProcessInput', $pi[1]->componentId);
    }

    public function testAddDirectProcessInput()
    {
        $c = $this->_root->getComponentById('5');
        $pi = Kwf_Component_Abstract_ContentSender_Default::__getProcessInputComponents($c);
        $this->assertEquals(0, count($pi));

        $m = Kwf_Model_Abstract::getInstance('Kwf_Component_Cache_ProcessInput_Paragraphs_TestModel');
        $row = $m->createRow();
        $row->component_id = '5';
        $row->visible = true;
        $row->pos = 1;
        $row->component = 'withProcessInput';
        $row->save();
        $this->_process();

        $c = $this->_root->getComponentById('5');
        $pi = Kwf_Component_Abstract_ContentSender_Default::__getProcessInputComponents($c);
        $this->assertEquals(1, count($pi));
        $pi = array_values($pi);
        $this->assertEquals('5-3', $pi[0]->componentId);
    }

    public function testAddContainsProcessInput()
    {
        $c = $this->_root->getcomponentById('5');
        $pi = Kwf_Component_Abstract_ContentSender_Default::__getProcessInputComponents($c);
        $this->assertEquals(0, count($pi));

        $m = Kwf_Model_Abstract::getInstance('Kwf_Component_Cache_ProcessInput_Paragraphs_TestModel');
        $row = $m->createRow();
        $row->component_id = '5';
        $row->visible = true;
        $row->pos = 1;
        $row->component = 'containsWithProcessInput';
        $row->save();
        $this->_process();

        $c = $this->_root->getComponentById('5');
        $pi = Kwf_Component_Abstract_ContentSender_Default::__getProcessInputComponents($c);
        $this->assertEquals(1, count($pi));
        $pi = array_values($pi);
        $this->assertEquals('5-3-withProcessInput', $pi[0]->componentId);
    }

    public function testRemoveDirectProcessInput()
    {
        $c = $this->_root->getComponentById('4');
        $pi = Kwf_Component_Abstract_ContentSender_Default::__getProcessInputComponents($c);
        $this->assertEquals(2, count($pi));

        $m = Kwf_Model_Abstract::getInstance('Kwf_Component_Cache_ProcessInput_Paragraphs_TestModel');
        $row = $m->getRow(1);
        $row->visible = false;
        $row->save();
        $this->_process();

        $c = $this->_root->getComponentById('4');
        $pi = Kwf_Component_Abstract_ContentSender_Default::__getProcessInputComponents($c);
        $this->assertEquals(1, count($pi));
        $pi = array_values($pi);
        $this->assertEquals('4-2-withProcessInput', $pi[0]->componentId);
    }

    public function testRemoveContainsProcessInput()
    {
        $c = $this->_root->getComponentById('4');
        $pi = Kwf_Component_Abstract_ContentSender_Default::__getProcessInputComponents($c);
        $this->assertEquals(2, count($pi));

        $m = Kwf_Model_Abstract::getInstance('Kwf_Component_Cache_ProcessInput_Paragraphs_TestModel');
        $row = $m->getRow(2);
        $row->delete();
        $this->_process();

        $c = $this->_root->getComponentById('4');
        $pi = Kwf_Component_Abstract_ContentSender_Default::__getProcessInputComponents($c);
        $this->assertEquals(1, count($pi));
        $pi = array_values($pi);
        $this->assertEquals('4-1', $pi[0]->componentId);
    }
}


text:
class C

println(/* resolved: false */ C.getClass)
println(classOf[/* file: this, offset: 6, type: org.jetbrains.plugins.scala.lang.psi.api.toplevel.typedef.ScClass */ C])


text:
<!DOCTYPE html>

    <title>Ralph Whitbeck's Twilio Resume</title>
    <meta name="viewport" content="width=device-width, initial-scale=1">
    <link rel="stylesheet" href="//maxcdn.bootstrapcdn.com/bootstrap/3.2.0/css/bootstrap.min.css">
    <link rel="stylesheet" href="//maxcdn.bootstrapcdn.com/bootstrap/3.2.0/css/bootstrap-theme.min.css">

Ralph Whitbeck's Twilio Resume

Enter your name and phone number and receive an automated call.

                <form class="form-inline" id="makecall" action="makecall.php" method="post" role="form">

                      Phone
                      <input class="form-control input-lg" type="tel" placeholder="Enter Phone" id="Phone" name="Phone" required>

                  <button type="submit" class="btn btn-primary btn-lg">Call</button>
                </form>


text:
require('user_modules/script_runner').isTestApplicable({ { extendedPolicy = { "EXTERNAL_PROPRIETARY" } } })

--[[ Required Shared libraries ]]
local commonFunctions = require("user_modules/shared_testcases/commonFunctions")
local commonSteps = require("user_modules/shared_testcases/commonSteps")
local testCasesForPolicyTable = require("user_modules/shared_testcases/testCasesForPolicyTable")
local utils = require ('user_modules/utils')

--[[ General Precondition before ATF start ]]
commonSteps:DeleteLogsFileAndPolicyTable()

--[[ Local variables ]]
local pre_dataconsent = "129372391"
local base4 = "686787169"

--[[ General Settings for configuration ]]
Test = require("connecttest")
require("user_modules/AppTypes")

--[[ Precondition ]]
function Test:Precondition_ActivateRegisteredApp()
  testCasesForPolicyTable:trigger_getting_device_consent(self, config.application1.registerAppInterfaceParams.appName, utils.getDeviceMAC())
end

function Test:Precondition_Check_App_assigned_BASE4()
  local group_app_id_table = commonFunctions:get_data_policy_sql(config.pathToSDL.."/storage/policy.sqlite", "SELECT functional_group_id FROM app_group where application_id = '0000001'")

  local group_app_id
  for _, value in pairs(group_app_id_table) do
    group_app_id = value
  end
  if(group_app_id ~= base4) then
    self:FailTestCase("Application is not assigned to Base-4. Group: "..group_app_id)
  end
end

function Test:Precondition_Disallow_device()
  self.hmiConnection:SendNotification("SDL.OnAllowSDLFunctionality",
    {allowed = false, source = "GUI", device = {id = utils.getDeviceMAC() , name = utils.getDeviceName()}})
  EXPECT_NOTIFICATION("OnPermissionsChange")
end

--[[ Test ]]
commonFunctions:newTestCasesGroup("Test")

function Test:TestStep1_Check_App_assigned_PreDataConsent()
  local group_app_id_table = commonFunctions:get_data_policy_sql(config.pathToSDL.."/storage/policy.sqlite", "SELECT functional_group_id FROM app_group where application_id = '0000001'")

  local group_app_id
  for _, value in pairs(group_app_id_table) do
    group_app_id = value
  end
  if(group_app_id ~= pre_dataconsent) then
    self:FailTestCase("Application is not assigned to BaseBeforeDataConsent. Group: "..group_app_id)
  end
end

function Test:TestStep1_Send_RPC_from_default_disallowed()
  --AddCommand belongs to default permissions, so should be disallowed
  local RequestIDAddCommand = self.mobileSession:SendRPC("AddCommand", { cmdID = 111, menuParams = { position = 1, menuName ="Command111" } })
  EXPECT_HMICALL("UI.AddCommand",{})
  :Times(0)
  EXPECT_RESPONSE(RequestIDAddCommand, { success = false, resultCode = "DISALLOWED" })
  EXPECT_NOTIFICATION("OnHashChange")
  :Times(0)
end

function Test:ActivateApp()
  local requestId1 = self.hmiConnection:SendRequest("SDL.ActivateApp", { appID = self.applications[config.application1.registerAppInterfaceParams.appName] })
  EXPECT_HMIRESPONSE(requestId1)
  :Do(function(_, data1)
      if data1.result.isSDLAllowed ~= true then
        local requestId2 = self.hmiConnection:SendRequest("SDL.GetUserFriendlyMessage", { language = "EN-US", messageCodes = { "DataConsent" } })
        EXPECT_HMIRESPONSE(requestId2)
        :Do(function(_, _)
            self.hmiConnection:SendNotification("SDL.OnAllowSDLFunctionality", { allowed = true, source = "GUI", device = { id = utils.getDeviceMAC(), name = utils.getDeviceName() } })
            EXPECT_HMICALL("BasicCommunication.ActivateApp")
            :Do(function(_, data2)
                self.hmiConnection:SendResponse(data2.id,"BasicCommunication.ActivateApp", "SUCCESS", { })
              end)
            :Times(1)
          end)
      end
    end)
end

function Test:TestStep3_Send_RPC_from_default_again()
  local RequestIDAddCommand = self.mobileSession:SendRPC("AddCommand", { cmdID = 111, menuParams = { position = 1, menuName ="Command111" } })
  EXPECT_HMICALL("UI.AddCommand",{})
  :Do(function(_,data)
      self.hmiConnection:SendResponse(data.id, data.method, "SUCCESS", {})
    end)
  EXPECT_RESPONSE(RequestIDAddCommand, { success = true, resultCode = "SUCCESS" })
  EXPECT_NOTIFICATION("OnHashChange")
end

function Test:Precondition_Check_App_assigned_BASE4()
  local group_app_id_table = commonFunctions:get_data_policy_sql(config.pathToSDL.."/storage/policy.sqlite", "SELECT functional_group_id FROM app_group where application_id = '0000001'")

  local group_app_id
  for _, value in pairs(group_app_id_table) do
    group_app_id = value
  end
  if(group_app_id ~= base4) then
    self:FailTestCase("Application is not assigned to Base-4. Group: "..group_app_id)
  end
end

--[[ Postconditions ]]
commonFunctions:newTestCasesGroup("Postconditions")

function Test.Postcondition_Stop()
  StopSDL()
end

return Test


text:
package au.com.dius.pact.consumer.junit.v3;

import au.com.dius.pact.consumer.junit.MatcherTestUtils;
import au.com.dius.pact.consumer.MessagePactBuilder;
import au.com.dius.pact.consumer.junit.MessagePactProviderRule;
import au.com.dius.pact.core.model.annotations.Pact;
import au.com.dius.pact.consumer.junit.PactVerification;
import au.com.dius.pact.consumer.dsl.PactDslJsonBody;
import au.com.dius.pact.core.model.messaging.MessagePact;
import org.junit.Assert;
import org.junit.Rule;
import org.junit.Test;

import java.util.HashMap;
import java.util.Map;

public class ExampleMessageConsumerWithV2MatchersTest {

    @Rule
    public MessagePactProviderRule mockProvider = new MessagePactProviderRule(this);
    private byte[] currentMessage;

    @Pact(provider = "test_provider_v3", consumer = "test_consumer_v3")
    public MessagePact createPact(MessagePactBuilder builder) {
        PactDslJsonBody body = new PactDslJsonBody()
          .uuid("workflowId")
          .stringType("domain")
          .eachLike("values")
            .stringType("key")
            .stringType("value")
            .closeObject()
          .closeArray()
          .asBody();

        Map<String, String> metaData = new HashMap<>();
        metaData.put("contentType", "application/json");

      MessagePact messagePact = builder.given("executing a workflow with rabbitmq")
        .expectsToReceive("execution payload")
        .withContent(body)
        .withMetadata(metaData)
        .toPact();

      MatcherTestUtils.assertMessageMatcherKeysEqualTo(messagePact, "body",
        "$.workflowId",
        "$.domain",
        "$.values",
        "$.values",
        "$.values[*].key",
        "$.values[*].value"
      );

      return messagePact;
    }

    @Test
    @PactVerification("test_provider_v3")
    public void test() throws Exception {
        Assert.assertNotNull(new String(currentMessage));
    }

    public void setMessage(byte[] messageContents) {
        currentMessage = messageContents;
    }
}


text:
package org.hoteia.qalingo.core.solr.bean;

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

import org.apache.solr.client.solrj.beans.Field;

public class ProductMarketingSolr {

	@Field
	private Long id;

	@Field
	private String description;

	private Boolean isDefault;

	@Field
	private String code;

	@Field
	private String name;

	@Field
	private String defaultCategoryCode;

	@Field
	private String defaultProductSkuCode;

	@Field
	private Float price;

    @Field
    private List<String> catalogCode = new ArrayList<String>();

    @Field
    private List<String> catalogCategories = new ArrayList<String>();

    @Field
    private List<String> tags = new ArrayList<String>();

	@Field("datecreate")
	private Date dateCreate;

	@Field("dateupdate")
	private Date dateUpdate;

	public String getName() {
        return name;
    }

	public void setName(String name) {
        this.name = name;
    }

	public Long getId() {
		return id;
	}

	public void setId(Long id) {
		this.id = id;
	}

	public String getDescription() {
		return description;
	}

	public void setDescription(String description) {
		this.description = description;
	}

	public Boolean getIsDefault() {
		return isDefault;
	}

	public void setIsDefault(Boolean isDefault) {
		this.isDefault = isDefault;
	}

	public String getCode() {
		return code;
	}

	public void setCode(String code) {
		this.code = code;
	}

	public String getDefaultCategoryCode() {
		return defaultCategoryCode;
	}

	public void setDefaultCategoryCode(String defaultCategoryCode) {
		this.defaultCategoryCode = defaultCategoryCode;
	}

	public String getDefaultProductSkuCode() {
		return defaultProductSkuCode;
	}

	public void setDefaultProductSkuCode(String defaultProductSkuCode) {
		this.defaultProductSkuCode = defaultProductSkuCode;
	}

    public Float getPrice() {
        return price;
    }

    public void setPrice(Float price) {
        this.price = price;
    }

	public List<String> getCatalogCode() {
        return catalogCode;
    }

	public void setCatalogCode(List<String> catalogCode) {
        this.catalogCode = catalogCode;
    }

    public void addCatalogCode(String catalogCode){
        if(this.catalogCode == null){
            this.catalogCode = new ArrayList<String>();
        }
        if(!this.catalogCode.contains(catalogCode)){
            this.catalogCode.add(catalogCode);
        }
    }

    public List<String> getCatalogCategories() {
        return catalogCategories;
    }

    public void setCatalogCategories(List<String> catalogCategories) {
        this.catalogCategories = catalogCategories;
    }

    public void addCatalogCategories(String catalogCategoryCode){
        if(this.catalogCategories == null){
            this.catalogCategories = new ArrayList<String>();
        }
        if(!this.catalogCategories.contains(catalogCategoryCode)){
            this.catalogCategories.add(catalogCategoryCode);
        }
    }

    public List<String> getTags() {
        return tags;
    }

    public void setTags(List<String> tags) {
        this.tags = tags;
    }

    public void addTags(String tag){
        if(this.tags == null){
            this.tags = new ArrayList<String>();
        }
        if(!this.tags.contains(tag)){
            this.tags.add(tag);
        }
    }

	public Date getDateCreate() {
		return dateCreate;
	}

	public void setDateCreate(Date dateCreate) {
		this.dateCreate = dateCreate;
	}

	public Date getDateUpdate() {
		return dateUpdate;
	}

	public void setDateUpdate(Date dateUpdate) {
		this.dateUpdate = dateUpdate;
	}

    @Override
    public int hashCode() {
        final int prime = 31;
        int result = 1;
        result = prime * result + ((code == null) ? 0 : code.hashCode());
        result = prime * result + ((id == null) ? 0 : id.hashCode());
        return result;
    }

    @Override
    public boolean equals(Object obj) {
        if (this == obj)
            return true;
        if (obj == null)
            return false;
        if (getClass() != obj.getClass())
            return false;
        ProductMarketingSolr other = (ProductMarketingSolr) obj;
        if (code == null) {
            if (other.code != null)
                return false;
        } else if (!code.equals(other.code))
            return false;
        if (id == null) {
            if (other.id != null)
                return false;
        } else if (!id.equals(other.id))
            return false;
        return true;
    }

    @Override
    public String toString() {
        return "ProductMarketingSolr [id=" + id + ", description=" + description + ", isDefault=" + isDefault + ", code=" + code + ", name=" + name + ", defaultCategoryCode=" + defaultCategoryCode
                + ", defaultProductSkuCode=" + defaultProductSkuCode + ", catalogCode=" + catalogCode + ", price=" + price + ", dateCreate=" + dateCreate + ", dateUpdate=" + dateUpdate
                + ", catalogCategories=" + catalogCategories + "]";
    }

}


text: python3 convert.py -st caffe -dt tf -sm example/caffe/lenet.prototxt -dm model/lenet.meta


text:
package com.ip_b1.fii.admission.Controllers;

import com.ip_b1.fii.admission.DTO.*;
import com.ip_b1.fii.admission.ServerProperties;
import com.ip_b1.fii.admission.Utils.AuthUtils;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpMethod;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

@RestController
@RequestMapping("/controller/add_classroom")
public class AddClassroom {

    @RequestMapping(method = RequestMethod.POST)
    public ResponseEntity<ClassroomsEntity> setResult(@RequestBody ClassroomsEntity classroom) {
        ClassroomsEntity classroomToAdd = new ClassroomsEntity();
        classroomToAdd.setId(classroom.getId());
        classroomToAdd.setLocatie(classroom.getLocatie());
        classroomToAdd.setNrLocuri(classroom.getNrLocuri());

        RestTemplate template = new RestTemplate();

        template.put(
                ServerProperties.modelUrl + "/sali",
                classroomToAdd);

        return new ResponseEntity<ClassroomsEntity>(
                //response,
                HttpStatus.OK
        );
    }
}


text:
struct cb_link_to_compressed {
    struct cb_link_to_compressed_data *data;
    struct cb_link_to_compressed *next;
};

struct cb_link_to_compressed *
cb_link_to_compressed_init(int32_t org_seq_id, int16_t coarse_start,
                           int16_t coarse_end, uint64_t original_start,
                           uint64_t original_end, bool dir);

void cb_link_to_compressed_free(struct cb_link_to_compressed *link);

struct cb_link_to_compressed_data {
    bool dir;
    int32_t org_seq_id;
    int16_t coarse_start;
    int16_t coarse_end;
    uint64_t original_start;
    uint64_t original_end;
};

struct cb_link_to_compressed_data *
cb_link_to_compressed_data_init(int32_t org_seq_id, int16_t coarse_start,
                                int16_t coarse_end, uint64_t original_start,
                                uint64_t original_end, bool dir);

#endif


text:
<!DOCTYPE html>

    <title>Focusbook</title>
    <link rel="stylesheet" href="css/popup.css">
    <link rel="stylesheet" href="http://code.ionicframework.com/ionicons/2.0.1/css/ionicons.min.css">

        Settings


text:
constexpr IncognitoModePrefs::Availability
    IncognitoModePrefs::kDefaultAvailability;

// static
bool IncognitoModePrefs::IntToAvailability(int in_value,
                                           Availability* out_value) {
  if (in_value < 0 || in_value >= static_cast<int>(Availability::kNumTypes)) {
    *out_value = kDefaultAvailability;
    return false;
  }
  *out_value = static_cast<Availability>(in_value);
  return true;
}

// static
IncognitoModePrefs::Availability IncognitoModePrefs::GetAvailability(
    const PrefService* pref_service) {
  return GetAvailabilityInternal(pref_service, CHECK_PARENTAL_CONTROLS);
}

// static
void IncognitoModePrefs::SetAvailability(PrefService* prefs,
                                         const Availability availability) {
  prefs->SetInteger(prefs::kIncognitoModeAvailability,
                    static_cast<int>(availability));
}

// static
void IncognitoModePrefs::RegisterProfilePrefs(
    user_prefs::PrefRegistrySyncable* registry) {
  registry->RegisterIntegerPref(prefs::kIncognitoModeAvailability,
                                static_cast<int>(kDefaultAvailability));
#if defined(OS_ANDROID)
  registry->RegisterBooleanPref(prefs::kIncognitoReauthenticationForAndroid,
                                false);
#endif
}

// static
bool IncognitoModePrefs::ShouldLaunchIncognito(
    const base::CommandLine& command_line,
    const PrefService* prefs) {
  // Note: This code only checks parental controls if the user requested
  // to launch in incognito mode or if it was forced via prefs. This way,
  // the parental controls check (which can be quite slow) can be avoided
  // most of the time.
  bool should_use_incognito =
      command_line.HasSwitch(switches::kIncognito) ||
      GetAvailabilityInternal(prefs, DONT_CHECK_PARENTAL_CONTROLS) ==
          IncognitoModePrefs::Availability::kForced;
#if BUILDFLAG(IS_CHROMEOS_LACROS)
  auto* init_params = chromeos::LacrosService::Get()->init_params();
  // TODO(https://crbug.com/1194304): Remove in M93.
  should_use_incognito |= init_params->is_incognito_deprecated;
  should_use_incognito |=
      init_params->initial_browser_action ==
      crosapi::mojom::InitialBrowserAction::kOpenIncognitoWindow;
#endif
  return should_use_incognito &&
         GetAvailabilityInternal(prefs, CHECK_PARENTAL_CONTROLS) !=
             IncognitoModePrefs::Availability::kDisabled;
}

// static
bool IncognitoModePrefs::CanOpenBrowser(Profile* profile) {
  switch (GetAvailability(profile->GetPrefs())) {
    case IncognitoModePrefs::Availability::kEnabled:
      return true;

    case IncognitoModePrefs::Availability::kDisabled:
      return !profile->IsIncognitoProfile();

    case IncognitoModePrefs::Availability::kForced:
      return profile->IsIncognitoProfile();

    default:
      NOTREACHED();
      return false;
  }
}

// static
bool IncognitoModePrefs::ArePlatformParentalControlsEnabled() {
#if defined(OS_WIN)
  return GetWinParentalControls().logging_required;
#elif defined(OS_ANDROID)
  return chrome::android::PartnerBrowserCustomizations::IsIncognitoDisabled();
#else
  return false;
#endif
}

// static
IncognitoModePrefs::Availability IncognitoModePrefs::GetAvailabilityInternal(
    const PrefService* pref_service,
    GetAvailabilityMode mode) {
  DCHECK(pref_service);
  int pref_value = pref_service->GetInteger(prefs::kIncognitoModeAvailability);
  Availability result = kDefaultAvailability;
  bool valid = IntToAvailability(pref_value, &result);
  DCHECK(valid);
  if (result != IncognitoModePrefs::Availability::kDisabled &&
      mode == CHECK_PARENTAL_CONTROLS && ArePlatformParentalControlsEnabled()) {
    if (result == IncognitoModePrefs::Availability::kForced)
      LOG(ERROR) << "Ignoring FORCED incognito. Parental control logging on";
    return IncognitoModePrefs::Availability::kDisabled;
  }
  return result;
}


text:
package com.twitter.finagle.buoyant.h2
package netty4

import com.twitter.logging.Logger
import io.netty.buffer.ByteBuf
import io.netty.channel._
import io.netty.handler.codec.http.{HttpServerCodec, HttpServerUpgradeHandler}
import io.netty.handler.codec.http2._
import io.netty.util.AsciiString

object ServerUpgradeHandler {
  private val log = Logger.get("h2")

  private val PrefaceBuf = Http2CodecUtil.connectionPrefaceBuf
  private val PrefaceLen = PrefaceBuf.readableBytes
  private def isPreface(bb: ByteBuf) =
    (bb.readableBytes >= PrefaceLen &&
      bb.slice(0, PrefaceLen).equals(PrefaceBuf))

  private def isH2C(proto: CharSequence): Boolean =
    AsciiString.contentEquals(Http2CodecUtil.HTTP_UPGRADE_PROTOCOL_NAME, proto)
}

/**
 * Accept either H2C requests (beginning with a Connection preface)
 * or HTTP requests with h2c protocol upgrading.
 */
class ServerUpgradeHandler(h2Framer: H2FrameCodec) extends ChannelDuplexHandler {
  import ServerUpgradeHandler._

  // Parses HTTP/1 objects.
  private[this] val h1Codec = new HttpServerCodec

  // Intercepts HTTP/1 requests with the HTTP2-Settings headers and
  // initiate protocol upgrade.
  private[this] val upgrader =
    new HttpServerUpgradeHandler(h1Codec, new HttpServerUpgradeHandler.UpgradeCodecFactory {
      override def newUpgradeCodec(proto: CharSequence): HttpServerUpgradeHandler.UpgradeCodec =
        if (isH2C(proto)) new Http2FrameCodecServerUpgrader(h2Framer)
        else null
    })

  /**
   * Detect the HTTP2 connection preface to support Prior Knowledge
   * HTTP2 (i.e. gRPC). If that doesn't exist try to upgrade from HTTP/1.
   */
  override def channelRead(ctx: ChannelHandlerContext, obj: Any): Unit = {
    obj match {
      case bb: ByteBuf if isPreface(bb) =>
        // If the connection starts with the magical prior-knowledge
        // preface, just assume we're speaking plain h2c.
        ctx.pipeline.addAfter(ctx.name, "h2 framer", h2Framer)

      case bb: ByteBuf =>
        // Otherwise, Upgrade from h1 to h2
        ctx.pipeline.addAfter(ctx.name, "h1 codec", h1Codec)
        ctx.pipeline.addAfter("h1 codec", "h1 upgrade h2", upgrader)
      // TODO silently translate native h1 to h2

      case _ => // Fall through and pass on the read.
    }

    // Stop trying to upgrade the protocol.
    ctx.pipeline.remove(this)
    log.debug(s"h2 server pipeline: installing framer: ${ctx.pipeline}")

    // Pass it on.
    ctx.fireChannelRead(obj); ()
  }
}


text:
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN"
   "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd">

	<title>LuaJava - A Script Tool for Java</title>
    <link rel="stylesheet" href="http://www.keplerproject.org/doc.css" type="text/css"/>
	<meta http-equiv="Content-Type" content="text/html; charset=UTF-8"/>

<big>LuaJava</big>

A Script Tool for Java

LuaJava

Home

Overview

Status

Dependencies

Download

Credits

Contact us

Manual

Compiling

Installing

Java Console

Lua Reference

Java Reference

Examples

History

Project

Bug Tracker

CVS

License

History

1.2 [24/May/2007]

Java object fields can be set in Lua. eg: javaObj.intField=1 ;

Java arrays can be read and set in Lua;

Corrected bug of missing function pushinteger in C;

Corrected possible memory leak when a Java object proxy metatable could not be set;

Static fields and java.lang.Class fields are accessible.

1.1 [24/Jan/2007]

changes to comply with Lua 5.1 API;

included LUA_MULTRET as a LuaState constant;

corrected bug on LuaObject.call on the order of the results.

1.0 [22/Jun/2005]

improved error handling;

dropped JDK 1.3 compatibility;

windows binaries compatible with LuaBinaries 5.0.2 Release 2;

new documentation format.

1.0 Beta 4 [21/Jan/2005]

package renamed to "org.keplerproject.luajava";

LuaObject.getLuaState is now public;

new function LuaObject.type();

JavaFunction.foo() renamed to JavaFunction.execute();

method called by javaLoadLib now can return an int.

1.0 Beta 3 [21/Sep/2004]

new function in lua luajava.loadLib, that opens libraries for Lua written in Java;

function LuaState.setGlobal now receives String, to work like Lua setglobal;

JavaFunction.foo() throws LuaException;

new function LuaState.pushString(byte[]);

Bugs linking some lua functions to Java;

minor bug fixes.

1.0 Beta 2 [07/Jul/2004]

now supports multi-threading;

new function LuaState.close() that should be called to close the state;

LuaState was missing some functions;

many bug fixes.

1.0 Beta 1 [28/Jun/2004]

$Id: history.html,v 1.19 2007-09-17 19:28:40 thiago Exp $


text:
module SimpleScheduler
  # Active Job class that wraps the scheduled job and determines if the job
  # should still be run based on the scheduled time and when the job expires.
  class FutureJob < ActiveJob::Base
    # An error class that is raised if a job does not run because the run time is
    # too late when compared to the scheduled run time.
    # @!attribute run_time
    #   @return [Time] The actual run time
    # @!attribute scheduled_time
    #   @return [Time] The scheduled run time
    # @!attribute task
    #   @return [SimpleScheduler::Task] The expired task
    class Expired < StandardError
      attr_accessor :run_time, :scheduled_time, :task
    end

    rescue_from Expired, with: :handle_expired_task

    # Perform the future job as defined by the task.
    # @param task_params [Hash] The params from the scheduled task
    # @param scheduled_time [Integer] The epoch time for when the job was scheduled to be run
    def perform(task_params, scheduled_time)
      @task = Task.new(task_params)
      @scheduled_time = Time.at(scheduled_time).in_time_zone(@task.time_zone)
      raise Expired if expired?
      queue_task
    end

    # Delete all future jobs created by Simple Scheduler from the `Sidekiq::ScheduledSet`.
    def self.delete_all
      Task.scheduled_set.each do |job|
        job.delete if job.display_class == "SimpleScheduler::FutureJob"
      end
    end

    private

    # The duration between the scheduled run time and actual run time that
    # will cause the job to expire. Expired jobs will not be executed.
    # @return [ActiveSupport::Duration]
    def expire_duration
      split_duration = @task.expires_after.split(".")
      duration = split_duration[0].to_i
      duration_units = split_duration[1]
      duration.send(duration_units)
    end

    # Returns whether or not the job has expired based on the time
    # between the scheduled run time and the current time.
    # @return [Boolean]
    def expired?
      return false if @task.expires_after.blank?
      expire_duration.from_now(@scheduled_time) < Time.now.in_time_zone(@task.time_zone)
    end

    # Handle the expired task by passing the task and run time information
    # to a block that can be creating in a Rails initializer file.
    def handle_expired_task(exception)
      exception.run_time = Time.now.in_time_zone(@task.time_zone)
      exception.scheduled_time = @scheduled_time
      exception.task = @task

      SimpleScheduler.expired_task_blocks.each do |block|
        block.call(exception)
      end
    end

    # The name of the method used to queue the task's job or worker.
    # @return [Symbol]
    def perform_method
      if @task.job_class.included_modules.include?(Sidekiq::Worker)
        :perform_async
      else
        :perform_later
      end
    end

    # Queue the task with the scheduled time if the job allows.
    def queue_task
      if @task.job_class.instance_method(:perform).arity.zero?
        @task.job_class.send(perform_method)
      else
        @task.job_class.send(perform_method, @scheduled_time.to_i)
      end
    end
  end
end


text:
![](art/logo.png)

What's it?
=========

A simple paging ListView that's allow parallax and fading.

Sample:
=========
```xml
<RelativeLayout xmlns:android="http://schemas.android.com/apk/res/android"
  xmlns:tools="http://schemas.android.com/tools"
  android:layout_width="match_parent"
  android:layout_height="match_parent">

  <com.ppamorim.library.PagerListView
    android:id="@+id/pager_list_view"
    android:layout_width="match_parent"
    android:layout_height="match_parent"
    android:background="#000000"
    android:layout_below="@+id/toolbar"/>

</RelativeLayout>

```

Gradle:
=========
```groovy
dependencies {
  not uploaded yet :(
}
```

Licence:
==========
```
Copyright 2015 Pedro Paulo de Amorim

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.
```


text:
https://www.codewars.com/kata/547274e24481cfc469000416/

According to the creation myths of the Abrahamic religions, Adam and Eve were the first Humans to wander the Earth.

You have to do God's job. The creation method must return an array of length 2 containing objects (representing Adam and Eve). The first object in the array should be an instance of the class `Man`. The second should be an instance of the class `Woman`. Both objects have to be subclasses of `Human`.

Your job is to implement the `Human`, `Man` and `Woman` classes.