Examples of SyncInfoValue

org.apache.directory.api.ldap.extras.controls.SyncInfoValue

A syncInfoValue object, as defined in RFC 4533 ;

 2.5.  Sync Info Message The Sync Info Message is an LDAP Intermediate Response Message [RFC4511] where responseName is the object identifier 1.3.6.1.4.1.4203.1.9.1.4 and responseValue contains a BER-encoded syncInfoValue.  The criticality is FALSE (and hence absent). syncInfoValue ::= CHOICE { newcookie      [0] syncCookie, refreshDelete  [1] SEQUENCE { cookie         syncCookie OPTIONAL, refreshDone    BOOLEAN DEFAULT TRUE }, refreshPresent [2] SEQUENCE { cookie         syncCookie OPTIONAL, refreshDone    BOOLEAN DEFAULT TRUE }, syncIdSet      [3] SEQUENCE { cookie         syncCookie OPTIONAL, refreshDeletes BOOLEAN DEFAULT FALSE, syncUUIDs      SET OF syncUUID } }

@author Apache Directory Project

org.apache.directory.api.ldap.extras.controls.syncrepl.syncInfoValue.SyncInfoValue

A syncInfoValue object, as defined in RFC 4533 ;

 2.5.  Sync Info Message The Sync Info Message is an LDAP Intermediate Response Message [RFC4511] where responseName is the object identifier 1.3.6.1.4.1.4203.1.9.1.4 and responseValue contains a BER-encoded syncInfoValue.  The criticality is FALSE (and hence absent). syncInfoValue ::= CHOICE { newcookie      [0] syncCookie, refreshDelete  [1] SEQUENCE { cookie         syncCookie OPTIONAL, refreshDone    BOOLEAN DEFAULT TRUE }, refreshPresent [2] SEQUENCE { cookie         syncCookie OPTIONAL, refreshDone    BOOLEAN DEFAULT TRUE }, syncIdSet      [3] SEQUENCE { cookie         syncCookie OPTIONAL, refreshDeletes BOOLEAN DEFAULT FALSE, syncUUIDs      SET OF syncUUID } }

@author Apache Directory Project

org.apache.directory.shared.ldap.extras.controls.SyncInfoValue

A syncInfoValue object, as defined in RFC 4533 ;

 2.5.  Sync Info Message The Sync Info Message is an LDAP Intermediate Response Message [RFC4511] where responseName is the object identifier 1.3.6.1.4.1.4203.1.9.1.4 and responseValue contains a BER-encoded syncInfoValue.  The criticality is FALSE (and hence absent). syncInfoValue ::= CHOICE { newcookie      [0] syncCookie, refreshDelete  [1] SEQUENCE { cookie         syncCookie OPTIONAL, refreshDone    BOOLEAN DEFAULT TRUE }, refreshPresent [2] SEQUENCE { cookie         syncCookie OPTIONAL, refreshDone    BOOLEAN DEFAULT TRUE }, syncIdSet      [3] SEQUENCE { cookie         syncCookie OPTIONAL, refreshDeletes BOOLEAN DEFAULT FALSE, syncUUIDs      SET OF syncUUID } }

@author Apache Directory Project

Examples of org.apache.directory.shared.ldap.extras.controls.SyncInfoValue

                  0x01, 0x01, 0x01, 0x01, 0x01, 0x01, 0x01, 0x01, 
                  0x01
            } );
        bb.flip();


        SyncInfoValue decorator = new SyncInfoValueDecorator( codec );
        decorator.setType( SynchronizationInfoEnum.SYNC_ID_SET );


        try
        {
            ((SyncInfoValueDecorator)decorator).decode( bb.array() );
            fail( "Should not be there" );

View Full Code Here

Examples of org.apache.directory.shared.ldap.extras.controls.SyncInfoValue

                                    SyncInfoValueTags.NEW_COOKIE_TAG.getValue(), 
                new GrammarAction<SyncInfoValueContainer>( "NewCookie choice for SyncInfoValueControl" )
            {
                public void action( SyncInfoValueContainer container )
                {
                    SyncInfoValue control = container.getSyncInfoValueControl();


                    Value value = container.getCurrentTLV().getValue();


                    byte[] newCookie = value.getData();


                    if ( IS_DEBUG )
                    {
                        LOG.debug( "newcookie = " + Strings.dumpBytes(newCookie) );
                    }


                    control.setCookie( newCookie );


                    // We can have an END transition
                    container.setGrammarEndAllowed( true );
                    
                    container.setSyncInfoValueControl( control );
                }
            } );




        /** 
         * Transition from initial state to SyncInfoValue refreshDelete choice
         * SyncInfoValue ::= CHOICE {
         *     ...
         *     refreshDelete [1] SEQUENCE {
         *     ...
         *     
         * Initialize the syncInfoValue object
         */
        super.transitions[SyncInfoValueStatesEnum.START_STATE.ordinal()][SyncInfoValueTags.REFRESH_DELETE_TAG.getValue()] = 
            new GrammarTransition( SyncInfoValueStatesEnum.START_STATE, 
                                    SyncInfoValueStatesEnum.REFRESH_DELETE_STATE, 
                                    SyncInfoValueTags.REFRESH_DELETE_TAG.getValue(), 
                new GrammarAction<SyncInfoValueContainer>( "RefreshDelete choice for SyncInfoValueControl" )
            {
                public void action( SyncInfoValueContainer container )
                {
                    SyncInfoValue control = container.getSyncInfoValueControl();
                    
                    container.setSyncInfoValueControl( control );


                    // We can have an END transition
                    container.setGrammarEndAllowed( true );
                }
            } );




        /** 
         * Transition from refreshDelete state to cookie
         *     refreshDelete [1] SEQUENCE {
         *         cookie syncCookie OPTIONAL,
         *     ...
         *     
         * Load the cookie object
         */
        super.transitions[SyncInfoValueStatesEnum.REFRESH_DELETE_STATE.ordinal()][UniversalTag.OCTET_STRING.getValue()] = 
            new GrammarTransition( SyncInfoValueStatesEnum.REFRESH_DELETE_STATE, 
                                    SyncInfoValueStatesEnum.REFRESH_DELETE_COOKIE_STATE, 
                                    UniversalTag.OCTET_STRING.getValue(), 
                new GrammarAction<SyncInfoValueContainer>( "RefreshDelete cookie" )
            {
                public void action( SyncInfoValueContainer container )
                {
                    SyncInfoValue control = container.getSyncInfoValueControl();
                    
                    Value value = container.getCurrentTLV().getValue();


                    byte[] cookie = value.getData();


                    if ( IS_DEBUG )
                    {
                        LOG.debug( "cookie = " + Strings.dumpBytes(cookie) );
                    }


                    container.getSyncInfoValueControl().setCookie( cookie );
                    container.setSyncInfoValueControl( control );


                    // We can have an END transition
                    container.setGrammarEndAllowed( true );
                }
            } );




        /** 
         * Transition from refreshDelete cookie state to refreshDone
         *     refreshDelete [1] SEQUENCE {
         *         ....
         *         refreshDone BOOLEAN DEFAULT TRUE
         *     }
         *     
         * Load the refreshDone flag
         */
        super.transitions[SyncInfoValueStatesEnum.REFRESH_DELETE_COOKIE_STATE.ordinal()][UniversalTag.BOOLEAN.getValue()] = 
            new GrammarTransition( SyncInfoValueStatesEnum.REFRESH_DELETE_COOKIE_STATE, 
                                    SyncInfoValueStatesEnum.LAST_SYNC_INFO_VALUE_STATE, 
                                    UniversalTag.BOOLEAN.getValue(), 
                new GrammarAction<SyncInfoValueContainer>( "RefreshDelete refreshDone flag" )
            {
                public void action( SyncInfoValueContainer container ) throws DecoderException
                {
                    SyncInfoValue control = container.getSyncInfoValueControl();
                    
                    Value value = container.getCurrentTLV().getValue();


                    try
                    {
                        boolean refreshDone = BooleanDecoder.parse( value );


                        if ( IS_DEBUG )
                        {
                            LOG.debug( "refreshDone = {}", refreshDone );
                        }


                        control.setRefreshDone( refreshDone );


                        container.setSyncInfoValueControl( control );


                        // the END transition for grammar
                        container.setGrammarEndAllowed( true );
                    }
                    catch ( BooleanDecoderException be )
                    {
                        String msg = I18n.err( I18n.ERR_04025 );
                        LOG.error( msg, be );
                        throw new DecoderException( msg );
                    }




                    // We can have an END transition
                    container.setGrammarEndAllowed( true );
                }
            } );




        /** 
         * Transition from refreshDelete choice state to refreshDone
         *     refreshDelete [1] SEQUENCE {
         *         ....
         *         refreshDone BOOLEAN DEFAULT TRUE
         *     }
         *     
         * Load the refreshDone flag
         */
        super.transitions[SyncInfoValueStatesEnum.REFRESH_DELETE_STATE.ordinal()][UniversalTag.BOOLEAN.getValue()] = 
            new GrammarTransition( SyncInfoValueStatesEnum.REFRESH_DELETE_STATE, 
                                    SyncInfoValueStatesEnum.LAST_SYNC_INFO_VALUE_STATE, 
                                    UniversalTag.BOOLEAN.getValue(), 
                new GrammarAction<SyncInfoValueContainer>( "RefreshDelete refreshDone flag" )
            {
                public void action( SyncInfoValueContainer container ) throws DecoderException
                {
                    SyncInfoValue control = container.getSyncInfoValueControl();
                    
                    Value value = container.getCurrentTLV().getValue();


                    try
                    {
                        boolean refreshDone = BooleanDecoder.parse( value );


                        if ( IS_DEBUG )
                        {
                            LOG.debug( "refreshDone = {}", refreshDone );
                        }


                        control.setRefreshDone( refreshDone );


                        container.setSyncInfoValueControl( control );


                        // the END transition for grammar
                        container.setGrammarEndAllowed( true );
                    }
                    catch ( BooleanDecoderException be )
                    {
                        String msg = I18n.err( I18n.ERR_04025 );
                        LOG.error( msg, be );
                        throw new DecoderException( msg );
                    }




                    // We can have an END transition
                    container.setGrammarEndAllowed( true );
                }
            } );
        
        
        /** 
         * Transition from initial state to SyncInfoValue refreshPresent choice
         * SyncInfoValue ::= CHOICE {
         *     ...
         *     refreshPresent [2] SEQUENCE {
         *     ...
         *     
         * Initialize the syncInfoValue object
         */
        super.transitions[SyncInfoValueStatesEnum.START_STATE.ordinal()][SyncInfoValueTags.REFRESH_PRESENT_TAG.getValue()] = 
            new GrammarTransition( SyncInfoValueStatesEnum.START_STATE, 
                                    SyncInfoValueStatesEnum.REFRESH_PRESENT_STATE, 
                                    SyncInfoValueTags.REFRESH_PRESENT_TAG.getValue(), 
                new GrammarAction<SyncInfoValueContainer>( "RefreshDelete choice for SyncInfoValueControl" )
            {
                public void action( SyncInfoValueContainer container )
                {
                    SyncInfoValue control = container.getSyncInfoValueControl();
                    
                    container.setSyncInfoValueControl( control );


                    // We can have an END transition
                    container.setGrammarEndAllowed( true );
                }
            } );


    
        /** 
         * Transition from refreshPresent state to cookie
         *     refreshPresent [2] SEQUENCE {
         *         cookie syncCookie OPTIONAL,
         *     ...
         *     
         * Load the cookie object
         */
        super.transitions[SyncInfoValueStatesEnum.REFRESH_PRESENT_STATE.ordinal()][UniversalTag.OCTET_STRING.getValue()] = 
            new GrammarTransition( SyncInfoValueStatesEnum.REFRESH_PRESENT_STATE, 
                                    SyncInfoValueStatesEnum.REFRESH_PRESENT_COOKIE_STATE, 
                                    UniversalTag.OCTET_STRING.getValue(), 
                new GrammarAction<SyncInfoValueContainer>( "RefreshPresent cookie" )
            {
                public void action( SyncInfoValueContainer container )
                {
                    SyncInfoValue control = container.getSyncInfoValueControl();
                    
                    Value value = container.getCurrentTLV().getValue();


                    byte[] cookie = value.getData();


                    if ( IS_DEBUG )
                    {
                        LOG.debug( "cookie = " + Strings.dumpBytes(cookie) );
                    }


                    container.getSyncInfoValueControl().setCookie( cookie );
                    container.setSyncInfoValueControl( control );


                    // We can have an END transition
                    container.setGrammarEndAllowed( true );
                }
            } );
        
        




        /** 
         * Transition from refreshPresent cookie state to refreshDone
         *     refreshPresent [2] SEQUENCE {
         *         ....
         *         refreshDone BOOLEAN DEFAULT TRUE
         *     }
         *     
         * Load the refreshDone flag
         */
        super.transitions[SyncInfoValueStatesEnum.REFRESH_PRESENT_COOKIE_STATE.ordinal()][UniversalTag.BOOLEAN.getValue()] = 
            new GrammarTransition( SyncInfoValueStatesEnum.REFRESH_PRESENT_COOKIE_STATE, 
                                    SyncInfoValueStatesEnum.LAST_SYNC_INFO_VALUE_STATE, 
                                    UniversalTag.BOOLEAN.getValue(), 
                new GrammarAction<SyncInfoValueContainer>( "RefreshPresent refreshDone flag" )
            {
                public void action( SyncInfoValueContainer container ) throws DecoderException
                {
                    SyncInfoValue control = container.getSyncInfoValueControl();
                    
                    Value value = container.getCurrentTLV().getValue();


                    try
                    {
                        boolean refreshDone = BooleanDecoder.parse( value );


                        if ( IS_DEBUG )
                        {
                            LOG.debug( "refreshDone = {}", refreshDone );
                        }


                        control.setRefreshDone( refreshDone );


                        container.setSyncInfoValueControl( control );


                        // the END transition for grammar
                        container.setGrammarEndAllowed( true );
                    }
                    catch ( BooleanDecoderException be )
                    {
                        String msg = I18n.err( I18n.ERR_04025 );
                        LOG.error( msg, be );
                        throw new DecoderException( msg );
                    }




                    // We can have an END transition
                    container.setGrammarEndAllowed( true );
                }
            } );




        /** 
         * Transition from refreshPresent choice state to refreshDone
         *     refreshPresent [1] SEQUENCE {
         *         ....
         *         refreshDone BOOLEAN DEFAULT TRUE
         *     }
         *     
         * Load the refreshDone flag
         */
        super.transitions[SyncInfoValueStatesEnum.REFRESH_PRESENT_STATE.ordinal()][UniversalTag.BOOLEAN.getValue()] = 
            new GrammarTransition( SyncInfoValueStatesEnum.REFRESH_PRESENT_STATE, 
                                    SyncInfoValueStatesEnum.LAST_SYNC_INFO_VALUE_STATE, 
                                    UniversalTag.BOOLEAN.getValue(), 
                new GrammarAction<SyncInfoValueContainer>( "RefreshPresent refreshDone flag" )
            {
                public void action( SyncInfoValueContainer container ) throws DecoderException
                {
                    SyncInfoValue control = container.getSyncInfoValueControl();
                    
                    Value value = container.getCurrentTLV().getValue();


                    try
                    {
                        boolean refreshDone = BooleanDecoder.parse( value );


                        if ( IS_DEBUG )
                        {
                            LOG.debug( "refreshDone = {}", refreshDone );
                        }


                        control.setRefreshDone( refreshDone );


                        container.setSyncInfoValueControl( control );


                        // the END transition for grammar
                        container.setGrammarEndAllowed( true );
                    }
                    catch ( BooleanDecoderException be )
                    {
                        String msg = I18n.err( I18n.ERR_04025 );
                        LOG.error( msg, be );
                        throw new DecoderException( msg );
                    }


                    // We can have an END transition
                    container.setGrammarEndAllowed( true );
                }
            } );
        
        
        /** 
         * Transition from initial state to SyncInfoValue syncIdSet choice
         * SyncInfoValue ::= CHOICE {
         *     ...
         *     syncIdSet [3] SEQUENCE {
         *     ...
         *     
         * Initialize the syncInfoValue object
         */
        super.transitions[SyncInfoValueStatesEnum.START_STATE.ordinal()][SyncInfoValueTags.SYNC_ID_SET_TAG.getValue()] = 
            new GrammarTransition( SyncInfoValueStatesEnum.START_STATE, 
                                    SyncInfoValueStatesEnum.SYNC_ID_SET_STATE, 
                                    SyncInfoValueTags.SYNC_ID_SET_TAG.getValue(), 
                new GrammarAction<SyncInfoValueContainer>( "SyncIdSet choice for SyncInfoValueControl" )
            {
                public void action( SyncInfoValueContainer container )
                {
                    SyncInfoValue control = container.getSyncInfoValueControl();
                    
                    container.setSyncInfoValueControl( control );
                }
            } );
        
        
        /** 
         * Transition from syncIdSet state to cookie
         *     syncIdSet [3] SEQUENCE {
         *         cookie syncCookie OPTIONAL,
         *     ...
         *     
         * Load the cookie object
         */
        super.transitions[SyncInfoValueStatesEnum.SYNC_ID_SET_STATE.ordinal()][UniversalTag.OCTET_STRING.getValue()] = 
            new GrammarTransition( SyncInfoValueStatesEnum.SYNC_ID_SET_STATE, 
                                    SyncInfoValueStatesEnum.SYNC_ID_SET_COOKIE_STATE, 
                                    UniversalTag.OCTET_STRING.getValue(), 
                new GrammarAction<SyncInfoValueContainer>( "SyncIdSet cookie" )
            {
                public void action( SyncInfoValueContainer container )
                {
                    SyncInfoValue control = container.getSyncInfoValueControl();
                    
                    Value value = container.getCurrentTLV().getValue();


                    byte[] cookie = value.getData();


                    if ( IS_DEBUG )
                    {
                        LOG.debug( "cookie = " + Strings.dumpBytes(cookie) );
                    }


                    container.getSyncInfoValueControl().setCookie( cookie );
                    container.setSyncInfoValueControl( control );
                }
            } );
        
        
        /** 
         * Transition from syncIdSet state to refreshDeletes
         *     syncIdSet [3] SEQUENCE {
         *         ...
         *         refreshDeletes BOOLEAN DEFAULT FALSE,
         *     ...
         *     
         * Load the refreshDeletes flag
         */
        super.transitions[SyncInfoValueStatesEnum.SYNC_ID_SET_STATE.ordinal()][UniversalTag.BOOLEAN.getValue()] = 
            new GrammarTransition( SyncInfoValueStatesEnum.SYNC_ID_SET_STATE, 
                                    SyncInfoValueStatesEnum.SYNC_ID_SET_REFRESH_DELETES_STATE, 
                                    UniversalTag.BOOLEAN.getValue(), 
                new GrammarAction<SyncInfoValueContainer>( "SyncIdSet refreshDeletes" )
            {
                public void action( SyncInfoValueContainer container ) throws DecoderException
                {
                    SyncInfoValue control = container.getSyncInfoValueControl();
                    
                    Value value = container.getCurrentTLV().getValue();


                    try
                    {
                        boolean refreshDeletes = BooleanDecoder.parse( value );


                        if ( IS_DEBUG )
                        {
                            LOG.debug( "refreshDeletes = {}", refreshDeletes );
                        }


                        control.setRefreshDeletes( refreshDeletes );


                        container.setSyncInfoValueControl( control );
                    }
                    catch ( BooleanDecoderException be )
                    {
                        String msg = I18n.err( I18n.ERR_04026 );
                        LOG.error( msg, be );
                        throw new DecoderException( msg );
                    }
                }
            } );
        
        
        /** 
         * Transition from syncIdSet cookie state to refreshDeletes
         *     syncIdSet [3] SEQUENCE {
         *         ...
         *         refreshDeletes BOOLEAN DEFAULT FALSE,
         *     ...
         *     
         * Load the refreshDeletes flag
         */
        super.transitions[SyncInfoValueStatesEnum.SYNC_ID_SET_COOKIE_STATE.ordinal()][UniversalTag.BOOLEAN.getValue()] = 
            new GrammarTransition( SyncInfoValueStatesEnum.SYNC_ID_SET_COOKIE_STATE, 
                                    SyncInfoValueStatesEnum.SYNC_ID_SET_REFRESH_DELETES_STATE, 
                                    UniversalTag.BOOLEAN.getValue(), 
                new GrammarAction<SyncInfoValueContainer>( "SyncIdSet refreshDeletes" )
            {
                public void action( SyncInfoValueContainer container ) throws DecoderException
                {
                    SyncInfoValue control = container.getSyncInfoValueControl();
                    
                    Value value = container.getCurrentTLV().getValue();


                    try
                    {
                        boolean refreshDeletes = BooleanDecoder.parse( value );


                        if ( IS_DEBUG )
                        {
                            LOG.debug( "refreshDeletes = {}", refreshDeletes );
                        }


                        control.setRefreshDeletes( refreshDeletes );


                        container.setSyncInfoValueControl( control );
                    }
                    catch ( BooleanDecoderException be )
                    {
                        String msg = I18n.err( I18n.ERR_04024 );
                        LOG.error( msg, be );
                        throw new DecoderException( msg );
                    }
                }
            } );
        
        
        /** 
         * Transition from syncIdSet state to syncUUIDs
         *     syncIdSet [3] SEQUENCE {
         *         ...
         *         syncUUIDs      *SET OF* syncUUID
         *     }
         *     
         * Initialize the UUID set : no action associated, except allowing a grammar end
         */
        super.transitions[SyncInfoValueStatesEnum.SYNC_ID_SET_STATE.ordinal()][UniversalTag.SET.getValue()] = 
            new GrammarTransition( SyncInfoValueStatesEnum.SYNC_ID_SET_STATE, 
                                    SyncInfoValueStatesEnum.SYNC_ID_SET_SET_OF_UUIDS_STATE, 
                                    UniversalTag.SET.getValue(), 
                new GrammarAction<SyncInfoValueContainer>( "SyncIdSet syncUUIDs" )
            {
                public void action( SyncInfoValueContainer container ) throws DecoderException
                {
                    // We can have an END transition
                    container.setGrammarEndAllowed( true );
                }
            } );
        
        
        /** 
         * Transition from syncIdSet cookie state to syncUUIDs
         *     syncIdSet [3] SEQUENCE {
         *         ...
         *         syncUUIDs      *SET OF* syncUUID
         *     }
         *     
         * Initialize the UUID set : no action associated
         */
        super.transitions[SyncInfoValueStatesEnum.SYNC_ID_SET_COOKIE_STATE.ordinal()][UniversalTag.SET.getValue()] = 
            new GrammarTransition( SyncInfoValueStatesEnum.SYNC_ID_SET_COOKIE_STATE, 
                                    SyncInfoValueStatesEnum.SYNC_ID_SET_SET_OF_UUIDS_STATE, 
                                    UniversalTag.SET.getValue(),
                new GrammarAction<SyncInfoValueContainer>( "SyncIdSet syncUUIDs" )
            {
                public void action( SyncInfoValueContainer container ) throws DecoderException
                {
                    // We can have an END transition
                    container.setGrammarEndAllowed( true );
                }
            } );
          
        
        /** 
         * Transition from syncIdSet refreshDeletes state to syncUUIDs
         *     syncIdSet [3] SEQUENCE {
         *         ...
         *         syncUUIDs      *SET OF* syncUUID
         *     }
         *     
         * Initialize the UUID set : no action associated
         */
        super.transitions[SyncInfoValueStatesEnum.SYNC_ID_SET_REFRESH_DELETES_STATE.ordinal()][UniversalTag.SET.getValue()] = 
            new GrammarTransition( SyncInfoValueStatesEnum.SYNC_ID_SET_REFRESH_DELETES_STATE, 
                                    SyncInfoValueStatesEnum.SYNC_ID_SET_SET_OF_UUIDS_STATE, 
                                    UniversalTag.SET.getValue(), 
                new GrammarAction<SyncInfoValueContainer>( "SyncIdSet syncUUIDs" )
            {
                public void action( SyncInfoValueContainer container ) throws DecoderException
                {
                    // We can have an END transition
                    container.setGrammarEndAllowed( true );
                }
            } );
        
        
        /** 
         * Transition from syncIdSet syncUUIDs to syncUUID
         *     syncIdSet [3] SEQUENCE {
         *         ...
         *         syncUUIDs      SET OF *syncUUID*
         *     }
         *     
         * Add the first UUID in the UUIDs list
         */
        super.transitions[SyncInfoValueStatesEnum.SYNC_ID_SET_SET_OF_UUIDS_STATE.ordinal()][UniversalTag.OCTET_STRING.getValue()] = 
            new GrammarTransition( SyncInfoValueStatesEnum.SYNC_ID_SET_SET_OF_UUIDS_STATE, 
                                    SyncInfoValueStatesEnum.SYNC_ID_SET_UUID_STATE, 
                                    UniversalTag.OCTET_STRING.getValue(), 
                new GrammarAction<SyncInfoValueContainer>( "SyncIdSet first UUID" )
            {
                public void action( SyncInfoValueContainer container ) throws DecoderException
                {
                    SyncInfoValue control = container.getSyncInfoValueControl();
                    
                    Value value = container.getCurrentTLV().getValue();


                    byte[] uuid = value.getData();
                    
                    // UUID must be exactly 16 bytes long
                    if ( ( uuid == null ) || ( uuid.length != 16 ) )
                    {
                        String msg = I18n.err( I18n.ERR_04027 );
                        LOG.error( msg );
                        throw new DecoderException( msg );
                    }


                    if ( IS_DEBUG )
                    {
                        LOG.debug( "UUID = " + Strings.dumpBytes(uuid) );
                    }


                    // Store the UUID in the UUIDs list
                    control.addSyncUUID( uuid );
                    
                    // We can have an END transition
                    container.setGrammarEndAllowed( true );
                }
            } );
        
        
        /** 
         * Transition from syncIdSet syncUUID to syncUUID
         *     syncIdSet [3] SEQUENCE {
         *         ...
         *         syncUUIDs      SET OF *syncUUID*
         *     }
         *     
         * Add a new UUID in the UUIDs list
         */
        super.transitions[SyncInfoValueStatesEnum.SYNC_ID_SET_UUID_STATE.ordinal()][UniversalTag.OCTET_STRING.getValue()] = 
            new GrammarTransition( SyncInfoValueStatesEnum.SYNC_ID_SET_UUID_STATE, 
                                    SyncInfoValueStatesEnum.SYNC_ID_SET_UUID_STATE, 
                                    UniversalTag.OCTET_STRING.getValue(), 
                new GrammarAction<SyncInfoValueContainer>( "SyncIdSet UUID" )
            {
                public void action( SyncInfoValueContainer container ) throws DecoderException
                {
                    SyncInfoValue control = container.getSyncInfoValueControl();
                    
                    Value value = container.getCurrentTLV().getValue();


                    byte[] uuid = value.getData();
                    
                    // UUID must be exactly 16 bytes long
                    if ( ( uuid == null ) || ( uuid.length != 16 ) )
                    {
                        String msg = I18n.err( I18n.ERR_04027 );
                        LOG.error( msg );
                        throw new DecoderException( msg );
                    }


                    if ( IS_DEBUG )
                    {
                        LOG.debug( "UUID = " + Strings.dumpBytes(uuid) );
                    }


                    // Store the UUID in the UUIDs list
                    control.getSyncUUIDs().add( uuid );
                    
                    // We can have an END transition
                    container.setGrammarEndAllowed( true );
                }
            } );

View Full Code Here

Examples of org.apache.directory.shared.ldap.extras.controls.SyncInfoValue

            (byte)0x80, 0x03,               // syncInfoValue ::= CHOICE {
              'a', 'b', 'c'                 //     newCookie [0] syncCookie
            } );
        bb.flip();


        SyncInfoValue decorator = new SyncInfoValueDecorator( codec );
        decorator.setType( SynchronizationInfoEnum.NEW_COOKIE );


        SyncInfoValue syncInfoValue = (SyncInfoValue)((SyncInfoValueDecorator)decorator).decode( bb.array() );


        assertEquals( SynchronizationInfoEnum.NEW_COOKIE, syncInfoValue.getType() );
        assertEquals( "abc", Strings.utf8ToString(syncInfoValue.getCookie()) );
        
        // Check the encoding
        try
        {
            ByteBuffer encoded = ((SyncInfoValueDecorator)syncInfoValue).encode( ByteBuffer.allocate( ((SyncInfoValueDecorator)syncInfoValue).computeLength() ) );

View Full Code Here

Examples of org.apache.directory.shared.ldap.extras.controls.SyncInfoValue

            (byte)0x80, 0x00,               // syncInfoValue ::= CHOICE {
                                            //     newCookie [0] syncCookie
            } );
        bb.flip();


        SyncInfoValue decorator = new SyncInfoValueDecorator( codec );
        decorator.setType( SynchronizationInfoEnum.NEW_COOKIE );


        SyncInfoValue syncInfoValue = (SyncInfoValue)((SyncInfoValueDecorator)decorator).decode( bb.array() );


        assertEquals( SynchronizationInfoEnum.NEW_COOKIE, syncInfoValue.getType() );
        assertEquals( "", Strings.utf8ToString(syncInfoValue.getCookie()) );
        
        // Check the encoding
        try
        {
            ByteBuffer encoded = ((SyncInfoValueDecorator)syncInfoValue).encode( ByteBuffer.allocate( ((SyncInfoValueDecorator)syncInfoValue).computeLength() ) );

View Full Code Here

Examples of org.apache.directory.shared.ldap.extras.controls.SyncInfoValue

              0x04, 0x03, 'a', 'b', 'c',    //         cookie       syncCookie OPTIONAL,
              0x01, 0x01, (byte)0xFF        //         refreshDone  BOOLEAN DEFAULT TRUE
            } );
        bb.flip();


        SyncInfoValue decorator = new SyncInfoValueDecorator( codec );
        
        decorator.setType( SynchronizationInfoEnum.REFRESH_DELETE );


        SyncInfoValue syncInfoValue = (SyncInfoValue)((SyncInfoValueDecorator)decorator).decode( bb.array() );


        assertEquals( SynchronizationInfoEnum.REFRESH_DELETE, syncInfoValue.getType() );
        assertEquals( "abc", Strings.utf8ToString(syncInfoValue.getCookie()) );
        assertTrue( syncInfoValue.isRefreshDone() );
        
        // Check the encoding
        try
        {
            ByteBuffer buffer = ByteBuffer.allocate( 0x07 );

View Full Code Here

Examples of org.apache.directory.shared.ldap.extras.controls.SyncInfoValue

              0x04, 0x03, 'a', 'b', 'c',    //         cookie       syncCookie OPTIONAL,
              0x01, 0x01, (byte)0x00        //         refreshDone  BOOLEAN DEFAULT TRUE
            } );
        bb.flip();


        SyncInfoValue decorator = new SyncInfoValueDecorator( codec );
        
        decorator.setType( SynchronizationInfoEnum.REFRESH_DELETE );


        SyncInfoValue syncInfoValue = (SyncInfoValue)((SyncInfoValueDecorator)decorator).decode( bb.array() );


        assertEquals( SynchronizationInfoEnum.REFRESH_DELETE, syncInfoValue.getType() );
        assertEquals( "abc", Strings.utf8ToString(syncInfoValue.getCookie()) );
        assertFalse( syncInfoValue.isRefreshDone() );
        
        // Check the encoding
        try
        {
            ByteBuffer encoded = ((SyncInfoValueDecorator)syncInfoValue).encode( ByteBuffer.allocate( ((SyncInfoValueDecorator)syncInfoValue).computeLength() ) );

View Full Code Here

Examples of org.apache.directory.shared.ldap.extras.controls.SyncInfoValue

                                            //     refreshDelete [1] SEQUENCE {
              0x04, 0x03, 'a', 'b', 'c'     //         cookie       syncCookie OPTIONAL,
            } );
        bb.flip();


        SyncInfoValue decorator = new SyncInfoValueDecorator( codec );
        
        decorator.setType( SynchronizationInfoEnum.REFRESH_DELETE );


        SyncInfoValue syncInfoValue = (SyncInfoValue)((SyncInfoValueDecorator)decorator).decode( bb.array() );


        assertEquals( SynchronizationInfoEnum.REFRESH_DELETE, syncInfoValue.getType() );
        assertEquals( "abc", Strings.utf8ToString(syncInfoValue.getCookie()) );
        assertTrue( syncInfoValue.isRefreshDone() );
        
        // Check the encoding
        try
        {
            ByteBuffer encoded = ((SyncInfoValueDecorator)syncInfoValue).encode( ByteBuffer.allocate( ((SyncInfoValueDecorator)syncInfoValue).computeLength() ) );

View Full Code Here

Examples of org.apache.directory.shared.ldap.extras.controls.SyncInfoValue

                                            //     refreshDelete [1] SEQUENCE {
              0x01, 0x01, 0x00              //        refreshDone  BOOLEAN DEFAULT TRUE
            } );
        bb.flip();


        SyncInfoValue decorator = new SyncInfoValueDecorator( codec );
        
        decorator.setType( SynchronizationInfoEnum.REFRESH_DELETE );


        SyncInfoValue syncInfoValue = (SyncInfoValue)((SyncInfoValueDecorator)decorator).decode( bb.array() );


        assertEquals( SynchronizationInfoEnum.REFRESH_DELETE, syncInfoValue.getType() );
        assertEquals( "", Strings.utf8ToString(syncInfoValue.getCookie()) );
        assertFalse( syncInfoValue.isRefreshDone() );
        
        // Check the encoding
        try
        {
            ByteBuffer encoded = ((SyncInfoValueDecorator)syncInfoValue).encode( ByteBuffer.allocate( ((SyncInfoValueDecorator)syncInfoValue).computeLength() ) );

View Full Code Here

Examples of org.apache.directory.shared.ldap.extras.controls.SyncInfoValue

            { 
            (byte)0xA1, 0x00                // syncInfoValue ::= CHOICE {
            } );
        bb.flip();


        SyncInfoValue decorator = new SyncInfoValueDecorator( codec );
        
        decorator.setType( SynchronizationInfoEnum.REFRESH_DELETE );


        SyncInfoValue syncInfoValue = (SyncInfoValue)((SyncInfoValueDecorator)decorator).decode( bb.array() );


        assertEquals( SynchronizationInfoEnum.REFRESH_DELETE, syncInfoValue.getType() );
        assertEquals( "", Strings.utf8ToString(syncInfoValue.getCookie()) );
        assertTrue( syncInfoValue.isRefreshDone() );
        
        // Check the encoding
        try
        {
            ByteBuffer encoded = ((SyncInfoValueDecorator)syncInfoValue).encode( ByteBuffer.allocate( ((SyncInfoValueDecorator)syncInfoValue).computeLength() ) );

View Full Code Here

Examples of org.apache.directory.shared.ldap.extras.controls.SyncInfoValue

              0x04, 0x03, 'a', 'b', 'c',    //         cookie       syncCookie OPTIONAL,
              0x01, 0x01, (byte)0xFF        //         refreshDone  BOOLEAN DEFAULT TRUE
            } );
        bb.flip();


        SyncInfoValue decorator = new SyncInfoValueDecorator( codec );
        
        decorator.setType( SynchronizationInfoEnum.REFRESH_PRESENT );


        SyncInfoValue syncInfoValue = (SyncInfoValue)((SyncInfoValueDecorator)decorator).decode( bb.array() );


        assertEquals( SynchronizationInfoEnum.REFRESH_PRESENT, syncInfoValue.getType() );
        assertEquals( "abc", Strings.utf8ToString(syncInfoValue.getCookie()) );
        assertTrue( syncInfoValue.isRefreshDone() );
        
        // Check the encoding
        try
        {
            ByteBuffer buffer = ByteBuffer.allocate( 0x07 );

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.