Home
last modified time | relevance | path

Searched refs:Xaction (Results 1 – 25 of 46) sorted by relevance

12

/dports/converters/osm2pgrouting/osm2pgrouting-2.3.8/src/database/
H A DExport2DB.cpp100 Xaction.commit(); in install_postGIS()
156 Xaction.commit(); in createTables()
185 Xaction.commit(); in createTables()
214 Xaction.commit(); in dropTables()
232 Xaction.commit(); in dropTables()
314 Xaction.commit(); in export_osm()
360 Xaction.exec(sql1); in fill_source_target()
367 Xaction.exec(sql2); in fill_source_target()
381 Xaction.exec(sql3); in fill_source_target()
539 Xaction.commit(); in get_val()
[all …]
/dports/www/squid/squid-4.15/src/adaptation/icap/
H A DXaction.cc78 Adaptation::Icap::Xaction::Xaction(const char *aTypeName, Adaptation::Icap::ServiceRep::Pointer &aS… in Xaction() function in Adaptation::Icap::Xaction
110 Adaptation::Icap::Xaction::~Xaction() in ~Xaction()
118 Adaptation::Icap::Xaction::masterLogEntry() in masterLogEntry()
125 Adaptation::Icap::Xaction::service() in service()
145 void Adaptation::Icap::Xaction::start() in start()
153 Adaptation::Icap::Xaction *xa = static_cast<Adaptation::Icap::Xaction *>(data); in icapLookupDnsResults()
159 Adaptation::Icap::Xaction::openConnection() in openConnection()
176 CbcPointer<Xaction> self(this); in openConnection()
208 CbcPointer<Xaction> self(this); in dnsLookupDone()
243 Adaptation::Icap::Xaction *x = (Adaptation::Icap::Xaction*)data;
[all …]
H A DOptXact.cc28 Adaptation::Icap::Xaction("Adaptation::Icap::OptXact", aService), in OptXact()
35 Adaptation::Icap::Xaction::start(); in start()
121 Adaptation::Icap::Xaction::swanSong(); in swanSong()
132 Adaptation::Icap::Xaction::finalizeLogInfo(); in finalizeLogInfo()
143 Adaptation::Icap::Xaction *Adaptation::Icap::OptXactLauncher::createXaction() in createXaction()
H A DXaction.h37 class Xaction: public Adaptation::Initiate
41 Xaction(const char *aTypeName, ServiceRep::Pointer &aService);
42 virtual ~Xaction();
H A DMakefile.am29 Xaction.cc \
30 Xaction.h \
H A DOptXact.h25 class OptXact: public Xaction
62 virtual Xaction *createXaction();
H A DLauncher.h41 class Xaction; variable
71 virtual Xaction *createXaction() = 0;
/dports/benchmarks/polygraph/polygraph-4.13.0/src/runtime/
H A DXaction.cc36 int Xaction::TheSampleDebt = 0;
37 Counter Xaction::TheCount = 0;
40 void Xaction::reset() { in reset()
79 void Xaction::finish(Error err) { in finish()
137 void Xaction::countSuccess() { in countSuccess()
141 void Xaction::countFailure() { in countFailure()
147 void Xaction::newState(State aState) { in newState()
152 bool Xaction::abortBeforeIo() const { in abortBeforeIo()
197 void Xaction::abortNow() { in abortNow()
211 void Xaction::logStats() { in logStats()
[all …]
H A DBcastRcver.h15 class Xaction; variable
33 inline void noteEvent(BcastChannel *ch, const Xaction *x);
49 virtual void noteXactEvent(BcastChannel *ch, const Xaction *x);
81 void BcastRcver::noteEvent(BcastChannel *ch, const Xaction *x) { in noteEvent()
H A DXaction.h29 class Xaction: public AlarmUser, public FileScanUser {
91 QueuePlace<Xaction> theLiveXacts;
161 typedef Queue<Xaction, &Xaction::theLiveXacts> XactLiveQueue;
H A DStatsSampleMgr.cc101 if (Xaction::TheSampleDebt > 0) { in startSample()
103 << Xaction::TheSampleDebt << " entries still uncollected" in startSample()
107 Xaction::TheSampleDebt += cfg.capacity; in startSample()
H A DStatIntvl.h15 class Xaction; variable
31 virtual void noteXactEvent(BcastChannel *ch, const Xaction *x);
H A DMakefile.am121 Xaction.h \
122 Xaction.cc \
H A DRptmstat.h30 virtual void noteXactEvent(BcastChannel *, const Xaction *);
/dports/www/squid/squid-4.15/src/
H A Dhelper.h36 class Xaction {
37 MEMPROXY_CLASS(Helper::Xaction);
39 Xaction(HLPCB *c, void *d, const char *b): request(c, d, b) {} in Xaction() function
82 Helper::Xaction *nextRequest();
89 void submitRequest(Helper::Xaction *r);
100 std::queue<Helper::Xaction *> queue;
196 typedef std::list<Helper::Xaction *> Requests;
228 Helper::Xaction *replyXaction;
241 Helper::Xaction *popRequest(int requestId);
H A Dhelper.cc47 static void Enqueue(helper * hlp, Helper::Xaction *);
373 helper::submitRequest(Helper::Xaction *r) in submitRequest()
486 Helper::Xaction *r = new Helper::Xaction(callback, data, buf); in submit()
512 Helper::Xaction *r = new Helper::Xaction(callback, data, buf); in submit()
860 Helper::Xaction *
863 Helper::Xaction *r = nullptr; in popRequest()
1172 Enqueue(helper * hlp, Helper::Xaction * r) in Enqueue()
1229 Helper::Xaction *
1440 Helper::Xaction *r; in helperKickQueue()
1450 Helper::Xaction *r; in helperStatefulKickQueue()
[all …]
/dports/converters/osm2pgrouting/osm2pgrouting-2.3.8/include/database/
H A DExport2DB.h121 void process_section(const std::string &ways_columns, pqxx::work &Xaction) const;
126 pqxx::work &Xaction) const;
131 pqxx::work &Xaction) const;
/dports/www/libecap/libecap-1.0.1/src/libecap/common/
H A Dforward.h28 class Xaction; variable
33 class Xaction; variable
/dports/www/libecap/libecap-1.0.1/src/libecap/adapter/
H A Dxaction.h15 class Xaction: public Options {
17 virtual ~Xaction() {} in ~Xaction()
H A Dservice.h40 typedef shared_ptr<Xaction> MadeXactionPointer;
41 virtual MadeXactionPointer makeXaction(host::Xaction *hostx) = 0;
H A Dxaction.cc5 void libecap::adapter::Xaction::resume() { in resume()
/dports/www/libecap/libecap-1.0.1/src/libecap/host/
H A Dxaction.h15 class Xaction: public Options {
17 virtual ~Xaction() {} in ~Xaction()
/dports/benchmarks/polygraph/polygraph-4.13.0/src/server/
H A DSrvXact.cc26 Xaction::reset(); in reset()
100 Xaction::wakeUp(a); in wakeUp()
120 Xaction::finish(err); in finish()
125 Xaction::logStats(ol); in logStats()
/dports/benchmarks/polygraph/polygraph-4.13.0/src/client/
H A DCltXact.cc37 Xaction::reset(); in reset()
117 Xaction::finish(err); in finish()
294 Xaction::logStats(ol); in logStats()
398 Xaction::wakeUp(a); in wakeUp()
/dports/www/squid/squid-4.15/src/adaptation/ecap/
H A DXactionRep.h32 class XactionRep : public Adaptation::Initiate, public libecap::host::Xaction,
41 typedef libecap::shared_ptr<libecap::adapter::Xaction> AdapterXaction;

12