RequestOptionCall<IndexRequestBuilder> entityCall) {
        return doBatchDelete(new BulkList<>(list, call, entityCall), null);
    }

    // #pending create, modify, remove

            RequestOptionCall<IndexRequestBuilder> entityCall) {
        return doBatchDelete(new BulkList<>(list, call, entityCall), null);
    }

    // #pending create, modify, remove

            RequestOptionCall<IndexRequestBuilder> entityCall) {
        return doBatchDelete(new BulkList<>(list, call, entityCall), null);
    }

    // #pending create, modify, remove

                    } else {
                        queryMap.put(fileType.toUpperCase(Locale.ROOT), value);
                    }
                }
            }
            queryMap.remove("labels.facet_filetype_others");
            queryMap.put("labels.facet_filetype_others", "filetype:others");
            if (logger.isDebugEnabled()) {
                logger.debug("Updated query map: queryMap={}", queryMap);

                WitnessUnregisterResponse response = rpcClient.unregister(request);
                
                if (response.isSuccess()) {
                    registrations.remove(registration.getRegistrationId());
                    listeners.remove(registration.getRegistrationId());
                    
                    log.info("Successfully unregistered witness: {}", 
                        registration.getRegistrationId());

toggle="buttons"] .btn')),e=0,n=t.length;e<n;e++){var i=t[e],o=i.querySelector(y);o.checked||o.hasAttribute("checked")?i.classList.add(_):i.classList.remove(_)}for(var a=0,s=(t=[].slice.call(document.querySelectorAll('[data-toggle="button"]'))).length;a<s;a++){var l=t[a];"true"===l.getAttribute("aria-pressed")?l.classList.add(_):l.classList.remove(_)}})),o.default.fn.button=E._jQueryInterface,o.default.fn.button.Constructor=E,o.default.fn.button.noConflict=function(){return o.default.fn.button=p...

                session.send(request, response);
            } catch (final SmbException se) {
                if (se.getNtStatus() == NtStatus.NT_STATUS_NETWORK_NAME_DELETED) {
                    /* Someone removed the share while we were
                     * connected. Bastards! Disconnect this tree
                     * so that it reconnects cleanly should the share
                     * reappear in this client's lifetime.

        int FLAG_A = 0x01;
        int FLAG_B = 0x02;
        assertFalse(m.isFlagSet(FLAG_A));
        m.setFlag(FLAG_A);
        assertTrue(m.isFlagSet(FLAG_A));
        // unset correctly removes the flag
        m.unsetFlag(FLAG_A);
        assertFalse(m.isFlagSet(FLAG_A));
        // Test another flag
        m.setFlag(FLAG_B);
        assertTrue(m.isFlagSet(FLAG_B));
        m.unsetFlag(FLAG_B);

                paramMap.put(HcHttpClient.PROXY_CREDENTIALS_PROPERTY, new UsernamePasswordCredentials(
                        paramMap.remove(Param.Client.PROXY_USERNAME).toString(), paramMap.remove(Param.Client.PROXY_PASSWORD).toString()));
            }
        } else {
            initializeDefaultHttpProxy(paramMap);
        }

        crawlerClientFactory = factory;

                
                // Schedule next retry or remove
                handleFailure(channel, e);
            }
        });
    }
    
    private void removeChannel(ChannelInfo channel) {
        log.info("Removing failed channel {} after max retries", channel.getChannelId());
        
        manager.removeChannel(channel);
        failoverStates.remove(channel.getChannelId());