4 #include <arc/Logger.h>
8 namespace DataStaging {
28 class ThreadArgument {
36 class BulkThreadArgument {
39 std::list<DTR_ptr> dtrs;
40 BulkThreadArgument(
Processor* proc_,
const std::list<DTR_ptr>& dtrs_):proc(proc_),dtrs(dtrs_) { };
50 std::list<DTR_ptr> bulk_list;
54 static void DTRCheckCache(
void* arg);
56 static void DTRResolve(
void* arg);
58 static void DTRBulkResolve(
void* arg);
60 static void DTRQueryReplica(
void* arg);
62 static void DTRBulkQueryReplica(
void* arg);
64 static void DTRPreClean(
void *arg);
66 static void DTRStagePrepare(
void* arg);
68 static void DTRReleaseRequest(
void* arg);
70 static void DTRRegisterReplica(
void* arg);
72 static void DTRProcessCache(
void* arg);