#include "config.h"
-#include <string>
+#include "globaltask.h"
-#include "tasks.h"
+#include <string>
// Forward declaration.
class EPStats;
#include <string>
+#include "globaltask.h"
#include "kv_bucket_iface.h"
-#include "tasks.h"
#define DEFAULT_BACKFILL_SNOOZE_TIME 1.0
#include "executorthread.h"
#include "kv_bucket.h"
#include "kvshard.h"
+#include "tasks.h"
const double BgFetcher::sleepInterval = MIN_SLEEP_TIME;
#include "config.h"
-#include "stats.h"
-#include "tasks.h"
-
-#include <set>
-#include <string>
+#include "globaltask.h"
+class EPStats;
class EventuallyPersistentEngine;
/**
#include "logger.h"
#include "item.h"
#include "kvstore.h"
-#include "tasks.h"
#include "atomicqueue.h"
#define COUCHSTORE_NO_OPTIONS 0
#include "config.h"
+#include "globaltask.h"
#include "kv_bucket_iface.h"
-#include "tasks.h"
class EPStats;
class DefragmentVisitor;
#include "failover-table.h"
#include "kvshard.h"
#include "stored_value_factories.h"
+#include "tasks.h"
#include "vbucketdeletiontask.h"
EPVBucket::EPVBucket(id_type i,
void EPVBucket::scheduleDeferredDeletion(EventuallyPersistentEngine& engine) {
ExTask task = new VBucketMemoryAndDiskDeletionTask(engine, *shard, this);
ExecutorPool::get()->schedule(task);
-}
\ No newline at end of file
+}
#include "config.h"
-#include "tasks.h"
+#include "syncobject.h"
#include "task_type.h"
#include "taskable.h"
#include "config.h"
+#include "globaltask.h"
#include "objectregistry.h"
-#include "tasks.h"
#include "task_type.h"
#include "tasklogentry.h"
#include "flusher.h"
#include "common.h"
+#include "tasks.h"
#include <stdlib.h>
#include <platform/processclock.h>
#include <queue>
-#include "tasks.h"
+#include "globaltask.h"
template <class C = std::deque<ExTask>,
class Compare = CompareByDueDate>
#pragma once
-#include <array>
-#include <platform/processclock.h>
-#include <platform/sized_buffer.h>
-
#include "atomic.h"
#include "config.h"
#include "task_type.h"
+#include <platform/processclock.h>
+#include <platform/sized_buffer.h>
+#include <array>
+
enum task_state_t {
TASK_RUNNING,
TASK_SNOOZED,
#include "config.h"
-#include "tasks.h"
+#include "globaltask.h"
#include <string>
#include "config.h"
-#include "tasks.h"
+#include "globaltask.h"
typedef std::pair<int64_t, int64_t> row_range_t;
// Forward declaration.
+class EPStats;
class EventuallyPersistentEngine;
/**
#include "access_scanner.h"
#include "checkpoint_remover.h"
#include "conflict_resolution.h"
+#include "connmap.h"
#include "dcp/dcpconnmap.h"
#include "defragmenter.h"
-#include "kv_bucket.h"
#include "ep_engine.h"
#include "ext_meta_parser.h"
#include "failover-table.h"
#include "flusher.h"
#include "htresizer.h"
+#include "kv_bucket.h"
#include "kvshard.h"
#include "kvstore.h"
#include "locks.h"
#include "mutation_log.h"
-#include "warmup.h"
-#include "connmap.h"
#include "replicationthrottle.h"
#include "statwriter.h"
#include "tapconnmap.h"
-#include "vbucketdeletiontask.h"
+#include "tasks.h"
#include "vb_count_visitor.h"
+#include "vbucketdeletiontask.h"
+#include "warmup.h"
class StatsValueChangeListener : public ValueChangedListener {
public:
#include <platform/processclock.h>
+#include "globaltask.h"
#include "workload.h"
-#include "tasks.h"
/*
A type for identifying all tasks belonging to a task owner.
#include "config.h"
-#include <queue>
-#include <platform/processclock.h>
-
#include "futurequeue.h"
+#include "syncobject.h"
#include "task_type.h"
-#include "tasks.h"
+
+#include <platform/processclock.h>
+
+#include <list>
+#include <queue>
+
class ExecutorPool;
class ExecutorThread;
#include "hash_table.h"
#include "hlc.h"
#include "item_pager.h"
+#include "kvstore.h"
#include "monotonic.h"
#include <platform/non_negative_counter.h>
#include "stats_test.h"
#include "evp_store_single_threaded_test.h"
+#include "tasks.h"
#include "test_helpers.h"
#include <gmock/gmock.h>
#include "callbacks.h"
#include "checkpoint.h"
-#include "item_pager.h"
+#include "configuration.h"
#include "hash_table.h"
+#include "item_pager.h"
#include <gtest/gtest.h>
+class BgFetcher;
class VBucket;
+class VBucketBGFetchItem;
/**
* Dummy callback to replace the flusher callback.