char buf[256];
snprintf(buf, sizeof buf, "%d %s %s %.3f %llu", i, addrStr, callStr, secs,
- (unsigned long long)info->getNCalls());
+ (uint64_t)info->getNCalls());
result.push_back(buf);
}
# define ntohll(n) bswap_64(n)
# define htonll(n) bswap_64(n)
# else /* GNUC & GLIBC */
-# define ntohll(n) ( (((unsigned long long)ntohl(n)) << 32) + ntohl(n >> 32) )
-# define htonll(n) ( (((unsigned long long)htonl(n)) << 32) + htonl(n >> 32) )
+# define ntohll(n) ( (((uint64_t)ntohl(n)) << 32) + ntohl(n >> 32) )
+# define htonll(n) ( (((uint64_t)htonl(n)) << 32) + htonl(n >> 32) )
# endif /* GNUC & GLIBC */
#else /* __BYTE_ORDER */
# error "Can't define htonll or ntohll!"
// 3. size indicates that event crosses chunk boundary
T_ERROR("Read corrupt event. Event crosses chunk boundary. Event size:%u Offset:%lld",
readState_.event_->eventSize_,
- (long long int) (offset_ + readState_.bufferPtr_ + 4));
+ (int64_t) (offset_ + readState_.bufferPtr_ + 4));
return true;
}
currentEvent_ = NULL;
char errorMsg[1024];
sprintf(errorMsg, "TFileTransport: log file corrupted at offset: %lld",
- (long long int) (offset_ + readState_.lastDispatchPtr_));
+ (int64_t) (offset_ + readState_.lastDispatchPtr_));
GlobalOutput(errorMsg);
throw TTransportException(errorMsg);
// Current time, microseconds since the epoch
uint64_t now()
{
- long long ret;
+ int64_t ret;
struct timeval tv;
gettimeofday(&tv, NULL);
size_t& _workerCount;
size_t _loopCount;
TType _loopType;
- long long _startTime;
- long long _endTime;
+ int64_t _startTime;
+ int64_t _endTime;
bool _done;
Monitor _sleep;
};
(*thread)->start();
}
- long long time00;
- long long time01;
+ int64_t time00;
+ int64_t time01;
{Synchronized s(monitor);
threadCount = clientCount;
time01 = Util::currentTime();
}
- long long firstTime = 9223372036854775807LL;
- long long lastTime = 0;
+ int64_t firstTime = 9223372036854775807LL;
+ int64_t lastTime = 0;
double averageTime = 0;
- long long minTime = 9223372036854775807LL;
- long long maxTime = 0;
+ int64_t minTime = 9223372036854775807LL;
+ int64_t maxTime = 0;
for (set<shared_ptr<Thread> >::iterator ix = clientThreads.begin(); ix != clientThreads.end(); ix++) {
shared_ptr<ClientThread> client = dynamic_pointer_cast<ClientThread>((*ix)->runnable());
- long long delta = client->_endTime - client->_startTime;
+ int64_t delta = client->_endTime - client->_startTime;
assert(delta > 0);
size_t& _workerCount;
size_t _loopCount;
TType _loopType;
- long long _startTime;
- long long _endTime;
+ int64_t _startTime;
+ int64_t _endTime;
bool _done;
Monitor _sleep;
};
(*thread)->start();
}
- long long time00;
- long long time01;
+ int64_t time00;
+ int64_t time01;
{Synchronized s(monitor);
threadCount = clientCount;
time01 = Util::currentTime();
}
- long long firstTime = 9223372036854775807LL;
- long long lastTime = 0;
+ int64_t firstTime = 9223372036854775807LL;
+ int64_t lastTime = 0;
double averageTime = 0;
- long long minTime = 9223372036854775807LL;
- long long maxTime = 0;
+ int64_t minTime = 9223372036854775807LL;
+ int64_t maxTime = 0;
for (set<shared_ptr<Thread> >::iterator ix = clientThreads.begin(); ix != clientThreads.end(); ix++) {
shared_ptr<ClientThread> client = dynamic_pointer_cast<ClientThread>((*ix)->runnable());
- long long delta = client->_endTime - client->_startTime;
+ int64_t delta = client->_endTime - client->_startTime;
assert(delta > 0);