anchor.diff:                           end, [], DelBucketStateList))),
               case List of
                   [H|_] ->
  -                    Ret = dequeue_1(DelBucketStateList, H),
  +                    Ret = dequeue_1(State, DelBucketStateList, H),
                       {Ret, State};
                   [] ->
                       {ok, State}
  
positive.code:                     timestamp = leo_date:now()}),
      {noreply, State};
  
  handle_info({enqueuing, MQId, Type, Directory}, State) ->
      {ok, State_1} = run(Type, ?STATE_ENQUEUING, MQId, Directory, State),
      {noreply, State_1};
  
  handle_info({enqueued, MQId, Type, Directory}, State) ->
      {ok, State_1} = run(Type, ?STATE_MONITORING, MQId, Directory, State),
  
negative.code:     end.
  
  %% @private
  -spec(dequeue_1(State, DelBucketStateList, MQId) ->
               ok |
               not_found |
               {error, Cause} when State::#state{},
                                   DelBucketStateList::[],
                                   MQId::mq_id(),
                                   Cause::any()).
  dequeue_1(_,[],_) ->
      not_found;
  dequeue_1(State, [{_, DelBucketStateBin}|DelBucketStateList], MQId) ->
      case catch binary_to_term(DelBucketStateBin) of
          #del_dir_state{type = Type,
                         directory = Directory,
  