本文整理汇总了C++中Timestamp类的典型用法代码示例。如果您正苦于以下问题:C++ Timestamp类的具体用法?C++ Timestamp怎么用?C++ Timestamp使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
在下文中一共展示了Timestamp类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的C++代码示例。
示例1: PrintWaitEvent
vector<TimerEvent*> Timer::GetExpiredTimerEvent(const Timestamp& now_ts)
{
LOG_VERBOSE << "us:" << now_ts.GetTimeUs() << endl;
vector<TimerEvent*> expired_events;
PrintWaitEvent();
auto iter = wait_event_.lower_bound(now_ts.GetTimeUs());
auto it = wait_event_.begin();
while (it != iter)
{
auto timer_it = id_timer_map_.find(it->second);
if (timer_it != id_timer_map_.end())
{
expired_events.push_back(timer_it->second.get());
}
else
{
LOG_VERBOSE << "timer id:" << it->second << " has been canceled" << endl;
}
it = wait_event_.erase(it);
LOG_VERBOSE << "some timer event happend" << endl;
}
return expired_events;
}
开发者ID:xzh3836598,项目名称:Zee,代码行数:28,代码来源:Timer.cpp
示例2:
DateTime::DateTime()
{
Timestamp now;
_utcTime = now.utcTime();
computeGregorian(julianDay());
computeDaytime();
}
开发者ID:RangelReale,项目名称:sandbox,代码行数:7,代码来源:DateTime.cpp
示例3: testScheduleInterval
void TimerTest::testScheduleInterval()
{
Timer timer;
Timestamp time;
TimerTask::Ptr pTask = new TimerTaskAdapter<TimerTest>(*this, &TimerTest::onTimer);
assert (pTask->lastExecution() == 0);
timer.schedule(pTask, 500, 500);
_event.wait();
assert (time.elapsed() >= 590000);
assert (pTask->lastExecution().elapsed() < 130000);
_event.wait();
assert (time.elapsed() >= 1190000);
assert (pTask->lastExecution().elapsed() < 130000);
_event.wait();
assert (time.elapsed() >= 1790000);
assert (pTask->lastExecution().elapsed() < 130000);
pTask->cancel();
assert (pTask->isCancelled());
}
开发者ID:12307,项目名称:poco,代码行数:27,代码来源:TimerTest.cpp
示例4: newImageCallback
void LiveSLAMWrapper::newImageCallback(const cv::Mat& img, Timestamp imgTime)
{
++ imageSeqNumber;
// Convert image to grayscale, if necessary
cv::Mat grayImg;
if (img.channels() == 1)
grayImg = img;
else
cvtColor(img, grayImg, CV_RGB2GRAY);
// Assert that we work with 8 bit images
assert(grayImg.elemSize() == 1);
assert(fx != 0 || fy != 0);
// need to initialize
if(!isInitialized)
{
monoOdometry->randomInit(grayImg.data, img.data, imgTime.toSec(), 1);
isInitialized = true;
}
else if(isInitialized && monoOdometry != nullptr)
{
monoOdometry->trackFrame(grayImg.data, img.data, imageSeqNumber,false,imgTime.toSec());
}
}
开发者ID:IceFish99,项目名称:lsd_slam,代码行数:28,代码来源:LiveSLAMWrapper.cpp
示例5: Status
StatusWith<OplogFetcher::DocumentsInfo> OplogFetcher::validateDocuments(
const Fetcher::Documents& documents, bool first, Timestamp lastTS) {
if (first && documents.empty()) {
return Status(ErrorCodes::OplogStartMissing,
str::stream() << "The first batch of oplog entries is empty, but expected at "
"least 1 document matching ts: "
<< lastTS.toString());
}
DocumentsInfo info;
// The count of the bytes of the documents read off the network.
info.networkDocumentBytes = 0;
info.networkDocumentCount = 0;
for (auto&& doc : documents) {
info.networkDocumentBytes += doc.objsize();
++info.networkDocumentCount;
// If this is the first response (to the $gte query) then we already applied the first doc.
if (first && info.networkDocumentCount == 1U) {
continue;
}
// Check to see if the oplog entry goes back in time for this document.
const auto docOpTime = OpTime::parseFromOplogEntry(doc);
// entries must have a "ts" field.
if (!docOpTime.isOK()) {
return docOpTime.getStatus();
}
info.lastDocument = {doc["h"].numberLong(), docOpTime.getValue()};
const auto docTS = info.lastDocument.opTime.getTimestamp();
if (lastTS >= docTS) {
return Status(ErrorCodes::OplogOutOfOrder,
str::stream() << "Out of order entries in oplog. lastTS: "
<< lastTS.toString()
<< " outOfOrderTS:"
<< docTS.toString()
<< " in batch with "
<< info.networkDocumentCount
<< "docs; first-batch:"
<< first
<< ", doc:"
<< doc);
}
lastTS = docTS;
}
// These numbers are for the documents we will apply.
info.toApplyDocumentCount = documents.size();
info.toApplyDocumentBytes = info.networkDocumentBytes;
if (first) {
// The count is one less since the first document found was already applied ($gte $ts query)
// and we will not apply it again.
--info.toApplyDocumentCount;
auto alreadyAppliedDocument = documents.cbegin();
info.toApplyDocumentBytes -= alreadyAppliedDocument->objsize();
}
return info;
}
开发者ID:ChineseDr,项目名称:mongo,代码行数:60,代码来源:oplog_fetcher.cpp
示例6: syncRollBackLocalOperations
StatusWith<RollBackLocalOperations::RollbackCommonPoint> syncRollBackLocalOperations(
const OplogInterface& localOplog,
const OplogInterface& remoteOplog,
const RollBackLocalOperations::RollbackOperationFn& rollbackOperation) {
auto remoteIterator = remoteOplog.makeIterator();
auto remoteResult = remoteIterator->next();
if (!remoteResult.isOK()) {
return StatusWith<RollBackLocalOperations::RollbackCommonPoint>(
ErrorCodes::InvalidSyncSource, "remote oplog empty or unreadable");
}
RollBackLocalOperations finder(localOplog, rollbackOperation);
Timestamp theirTime;
while (remoteResult.isOK()) {
theirTime = remoteResult.getValue().first["ts"].timestamp();
BSONObj theirObj = remoteResult.getValue().first;
auto result = finder.onRemoteOperation(theirObj);
if (result.isOK()) {
return result.getValue();
} else if (result.getStatus().code() != ErrorCodes::NoSuchKey) {
return result;
}
remoteResult = remoteIterator->next();
}
severe() << "rollback error RS100 reached beginning of remote oplog";
log() << " them: " << remoteOplog.toString();
log() << " theirTime: " << theirTime.toStringLong();
return StatusWith<RollBackLocalOperations::RollbackCommonPoint>(
ErrorCodes::NoMatchingDocument, "RS100 reached beginning of remote oplog [1]");
}
开发者ID:vnvizitiu,项目名称:mongo,代码行数:31,代码来源:roll_back_local_operations.cpp
示例7: docsToInsert
void OplogBufferCollection::pushAllNonBlocking(OperationContext* txn,
Batch::const_iterator begin,
Batch::const_iterator end) {
if (begin == end) {
return;
}
size_t numDocs = std::distance(begin, end);
Batch docsToInsert(numDocs);
Timestamp ts;
std::transform(begin, end, docsToInsert.begin(), [&ts](const Value& value) {
auto pair = addIdToDocument(value);
invariant(ts.isNull() || pair.second > ts);
ts = pair.second;
return pair.first;
});
stdx::lock_guard<stdx::mutex> lk(_mutex);
auto status = _storageInterface->insertDocuments(txn, _nss, docsToInsert);
fassertStatusOK(40161, status);
_lastPushedTimestamp = ts;
_count += numDocs;
_size += std::accumulate(begin, end, 0U, [](const size_t& docSize, const Value& value) {
return docSize + size_t(value.objsize());
});
_cvNoLongerEmpty.notify_all();
}
开发者ID:judahschvimer,项目名称:mongo,代码行数:27,代码来源:oplog_buffer_collection.cpp
示例8: timer
void TimerQueue::reset(std::vector<TimerQueue::Entry> expired, Timestamp now)
{
for (auto iter : expired)
{
ActiveTimer timer(iter.second, iter.second->sequeue());
if (iter.second->repeat() &&
cancleTimers_.find(timer) == cancleTimers_.end())
{
iter.second->restart(now);
//timers_.insert(iter);
//activeTimers_.insert(timer);
insert(iter.second);
}
else
{
delete iter.second;
}
}
Timestamp time;
if (!timers_.empty())
{
time = timers_.begin()->second->expiration();
}
if (time.valid())
{
ext::resetTimerfd(timerfd_, time);
}
}
开发者ID:chenyu1927,项目名称:hello-world,代码行数:30,代码来源:TimerQueue.cpp
示例9: reset
void TimerQueue::reset(const std::vector<Entry>& expired, Timestamp now)
{
Timestamp nextExpire;
for (std::vector<Entry>::const_iterator it = expired.begin();
it != expired.end(); it++)
{
ActiveTimer timer(it->second, it->second->sequence());
if (it->second->repeat()
&& cancelingTimers_.find(timer) == cancelingTimers_.end())
{
it->second->restart(now);
insert(it->second);
}
else
{
delete it->second;
}
}
if (!timers_.empty())
{
nextExpire = timers_.begin()->second->expiration();
}
if (nextExpire.valid())
{
resetTimerfd(timerfd_, nextExpire);
}
}
开发者ID:kevinneu,项目名称:dbdky_cac,代码行数:30,代码来源:TimerQueue.cpp
示例10: getGlobalReplicationCoordinator
void SyncTail::handleSlaveDelay(const BSONObj& lastOp) {
ReplicationCoordinator* replCoord = getGlobalReplicationCoordinator();
int slaveDelaySecs = durationCount<Seconds>(replCoord->getSlaveDelaySecs());
// ignore slaveDelay if the box is still initializing. once
// it becomes secondary we can worry about it.
if (slaveDelaySecs > 0 && replCoord->getMemberState().secondary()) {
const Timestamp ts = lastOp["ts"].timestamp();
long long a = ts.getSecs();
long long b = time(0);
long long lag = b - a;
long long sleeptime = slaveDelaySecs - lag;
if (sleeptime > 0) {
uassert(12000,
"rs slaveDelay differential too big check clocks and systems",
sleeptime < 0x40000000);
if (sleeptime < 60) {
sleepsecs((int)sleeptime);
} else {
warning() << "slavedelay causing a long sleep of " << sleeptime << " seconds";
// sleep(hours) would prevent reconfigs from taking effect & such!
long long waitUntil = b + sleeptime;
while (time(0) < waitUntil) {
sleepsecs(6);
// Handle reconfigs that changed the slave delay
if (durationCount<Seconds>(replCoord->getSlaveDelaySecs()) != slaveDelaySecs)
break;
}
}
}
} // endif slaveDelay
}
开发者ID:Jaryli,项目名称:mongo,代码行数:33,代码来源:sync_tail.cpp
示例11: Compare
int Timestamp::Compare(const Timestamp &aCompare) const
{
uint64_t thisSeconds = GetSeconds();
uint64_t compareSeconds = aCompare.GetSeconds();
uint16_t thisTicks = GetTicks();
uint16_t compareTicks = aCompare.GetTicks();
int rval;
if (compareSeconds > thisSeconds)
{
rval = 1;
}
else if (compareSeconds < thisSeconds)
{
rval = -1;
}
else if (compareTicks > thisTicks)
{
rval = 1;
}
else if (compareTicks < thisTicks)
{
rval = -1;
}
else
{
rval = 0;
}
return rval;
}
开发者ID:NCTU-ivan,项目名称:embarc_osp,代码行数:31,代码来源:timestamp.cpp
示例12: sslTest2
void sslTest2()
{
tracef("ssl test 2 begin: ssl send data.");
Context::Ptr pContext = new Context(Context::TLSV1_CLIENT_USE, "", Context::VERIFY_NONE);
SecureStreamSocket sss(pContext);
SocketAddress sa("127.0.0.1", 12222);
sss.connect(sa, Timespan(3, 0));
DynamicStruct ds;
ds["type"] = "request";
ds["action"] = "server.token";
Timestamp t;
UInt64 tms = t.epochMicroseconds();
char tms_str[32];
snprintf(tms_str, 31, "%llu", tms);
std::string key = "alpha2015";
key += tms_str;
MD5Engine md5;
md5.update(key);
const DigestEngine::Digest& digest = md5.digest();
std::string md5key = DigestEngine::digestToHex(digest);
DynamicStruct param;
param["key"] = md5key;
param["timestamp"] = tms_str;
param["dev_name"] = "lock1";
param["dev_type"] = "sc-01";
param["uuid"] = "SC00000001";
ds["param"] = param;
tracef("data send: %s.", ds.toString().c_str());
sss.sendBytes(ds.toString().c_str(), ds.toString().length());
sss.close();
tracef("socket closed.");
tracef("ssl test 2 finished.\n");
}
开发者ID:shuchuangtech,项目名称:Shuchuang,代码行数:34,代码来源:main.cpp
示例13: assert
void SSLContext::flushSessionCache()
{
assert(_usage == SERVER_USE);
Timestamp now;
SSL_CTX_flush_sessions(_sslContext, static_cast<long>(now.epochTime()));
}
开发者ID:delort,项目名称:libsourcey,代码行数:7,代码来源:sslcontext.cpp
示例14: Assert
void ReqGetNewMsgs::OnSuccess()
{
PXml p = m_xml.getChildNode(0);
Assert(SafeStrCmp(p.getName(), "now"));
timestamp = p.getText();
p = m_xml.getChildNode(1);
if (SafeStrCmp(p.getName(), "msgs"))
{
int numMsgs = p.nChildNode();
for (int i = 0; i < numMsgs; i++)
{
PXml msg = p.getChildNode(i);
int id = atoi(msg.getChildNode(0).getText());
int senderId = atoi(msg.getChildNode(1).getText());
timestamp = msg.getChildNode(2).getText();
Timestamp whenSent = atoi(timestamp.c_str());
std::string text = msg.getChildNode(3).getText();
text = DecodeMsg(text); ////Replace(text, "_", " "); // replace underscores with spaces -- TODO punctuation
int recipId = atoi(msg.getChildNode(4).getText());
std::cout << "GOT NEW MSG!! ID: " << id << " sender: " << senderId << " sent: " << whenSent.ToString() << " text: " << text << "\n";
TheMsgManager::Instance()->QueueMsg(MsgManager::Msg(id, text, senderId, recipId, whenSent));
}
}
else
{
ShowError("Unexpected format for msgs response");
}
}
开发者ID:jason-amju,项目名称:amjulib,代码行数:32,代码来源:ReqGetNewMsgs.cpp
示例15: packs
Ref<Database> PackageService::buildLookupDB(const String& path, StreamSourceMap& packCfgs)
{
Ref<Database> db = Database::open(path);
db->exec("DROP TABLE IF EXISTS packs; CREATE TABLE packs (name PRIMARY KEY, timestamp INT)");
db->exec("DROP TABLE IF EXISTS lookup; CREATE TABLE lookup (type, key, subtype, pack, entry, PRIMARY KEY (type, key))");
db->exec("DROP INDEX IF EXISTS lookup_packidx; CREATE INDEX lookup_packidx ON lookup (pack ASC)");
Ref<Database::Query> packInsert =
db->prepare("INSERT INTO packs (name, timestamp) VALUES (?, ?)");
Ref<Database::Query> lookupInsert =
db->prepare("INSERT INTO lookup (type, key, subtype, pack, entry) VALUES ($type, $key, $subtype, $pack, $entry)");
for (StreamSourceMap::iterator itr = packCfgs.begin(), end = packCfgs.end(); itr != end; ++itr)
{
const String& packName = itr->first;
Ref<Settings> cfg = Settings::load(itr->second);
if (cfg == NULL)
{
LOG(0, "*** can't load '%s'\n", cfg->getUrl().c_str());
continue;
}
Timestamp time = itr->second->getTimestamp();
packInsert->reset();
packInsert->bind(1, packName);
packInsert->bind(2, time.getUnixTime64());
packInsert->step();
Ref<Settings> section = cfg->getSection("lookup");
if (section == NULL)
continue;
for (Settings::Iterator itr = section->begin(), end = section->end(); itr != end; ++itr)
{
String type = itr->first;
String key = itr->second;
String sub, entry;
splitLookupEntry(type, key, sub, entry);
lookupInsert->reset();
lookupInsert->bind("$type", type);
lookupInsert->bind("$key", key);
lookupInsert->bind("$subtype", sub);
lookupInsert->bind("$entry", entry);
lookupInsert->bind("$pack", packName);
lookupInsert->step();
}
}
return db;
}
开发者ID:noriter,项目名称:nit,代码行数:59,代码来源:PackageService.cpp
示例16: operator
auto greater::operator()<Timestamp&, Timestamp&>(Timestamp& a, Timestamp& b) const noexcept
{
if (a.is_null())
return false;
if (b.is_null())
return true;
return a > b;
}
开发者ID:joelparkerhenderson,项目名称:demo_swift_rest,代码行数:8,代码来源:primitive_list.cpp
示例17: main
int main(int argc, char const *argv[])
{
Timestamp now = Timestamp::now();
cout << now.toString() << endl;
cout << now.toFormatString() << endl;
return 0;
}
开发者ID:jianxinzhou,项目名称:Z_CodeHub,代码行数:8,代码来源:test_timestamp.cpp
示例18: fraction
/**
* This function returns the fraction of time elapsed after the beginning
* till the end
*/
double fraction(Timestamp currentTime, Timestamp endTime) {
if ( (currentTime.after(*this)) && (endTime.after(currentTime)) ) {
return(((double)currentTime.subUsec(*this)) /
((double)endTime.subUsec(*this)));
} else {
return -1.0;
}
}
开发者ID:CalSPEED,项目名称:iPerf,代码行数:12,代码来源:Timestamp.hpp
示例19: invariant
std::pair<BSONObj, Timestamp> OplogBufferCollection::addIdToDocument(const BSONObj& orig) {
invariant(!orig.isEmpty());
BSONObjBuilder bob;
Timestamp ts = orig["ts"].timestamp();
invariant(!ts.isNull());
bob.append("_id", ts);
bob.append(kOplogEntryFieldName, orig);
return std::pair<BSONObj, Timestamp> {bob.obj(), ts};
}
开发者ID:judahschvimer,项目名称:mongo,代码行数:9,代码来源:oplog_buffer_collection.cpp
示例20: delay_loop
void delay_loop( unsigned long usec ) {
Timestamp end;
end.add( usec * 1e-6 );
Timestamp now;
while ( now.before( end ) ) {
now.setnow();
}
}
开发者ID:CalSPEED,项目名称:iPerf,代码行数:9,代码来源:delay.cpp
注:本文中的Timestamp类示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论