Home
last modified time | relevance | path

Searched refs:int64_t (Results 1 – 25 of 66) sorted by relevance

123

/thrift-3.4.0/lib/lua/src/
Dlongnumberutils.c26 int64_t lualongnumber_checklong(lua_State *L, int index) { in lualongnumber_checklong()
29 return (int64_t)lua_tonumber(L, index); in lualongnumber_checklong()
33 return *((int64_t *)luaL_checkudata(L, index, LONG_NUM_TYPE)); in lualongnumber_checklong()
38 int64_t * lualongnumber_pushlong(lua_State *L, int64_t *val) { in lualongnumber_pushlong()
39 int64_t *data = (int64_t *)lua_newuserdata(L, sizeof(int64_t)); // longnum in lualongnumber_pushlong()
Dlualongnumber.c28 extern int64_t lualongnumber_checklong(lua_State *L, int index);
29 extern int64_t lualongnumber_pushlong(lua_State *L, int64_t *val);
33 static void l_serialize(char *buf, int len, int64_t val) { in l_serialize()
37 static int64_t l_deserialize(const char *buf) { in l_deserialize()
38 int64_t data; in l_deserialize()
55 int64_t val; in l_new()
61 val = (int64_t)lua_tonumber(L, 1); in l_new()
72 int64_t a, b, c; in l_add()
82 int64_t a, b, c; in l_div()
92 int64_t a, b; in l_eq()
[all …]
Dluabpack.c26 extern int64_t lualongnumber_checklong(lua_State *L, int index);
27 extern int64_t lualongnumber_pushlong(lua_State *L, int64_t *val);
30 static int64_t T_htonll(uint64_t data) { in T_htonll()
37 static int64_t T_ntohll(uint64_t data) { in T_ntohll()
76 int64_t data = lualongnumber_checklong(L, 2); in l_bpack()
77 data = (int64_t)T_htonll(data); in l_bpack()
148 int64_t val; in l_bunpack()
151 val = (int64_t)T_ntohll(val); in l_bunpack()
173 int64_t n = lualongnumber_checklong(L, 1); in l_i64ToZigzag()
174 int64_t result = (n << 1) ^ (n >> 63); in l_i64ToZigzag()
[all …]
/thrift-3.4.0/contrib/fb303/cpp/
DFacebookBase.h38 struct ReadWriteInt : Mutex {int64_t value;};
62 int64_t aliveSince();
72 int64_t incrementCounter(const std::string& key, int64_t amount = 1);
73 int64_t setCounter(const std::string& key, int64_t value);
75 void getCounters(std::map<std::string, int64_t>& _return);
76 int64_t getCounter(const std::string& key);
90 int64_t aliveSince_;
DFacebookBase.cpp27 aliveSince_ = (int64_t) time(nullptr); in FacebookBase()
49 int64_t FacebookBase::incrementCounter(const std::string& key, int64_t amount) { in incrementCounter()
67 int64_t count = it->second.value + amount; in incrementCounter()
74 int64_t FacebookBase::setCounter(const std::string& key, int64_t value) { in setCounter()
92 void FacebookBase::getCounters(std::map<std::string, int64_t>& _return) { in getCounters()
104 int64_t FacebookBase::getCounter(const std::string& key) { in getCounter()
105 int64_t rv = 0; in getCounter()
117 inline int64_t FacebookBase::aliveSince() { in aliveSince()
/thrift-3.4.0/lib/cpp/test/
DAllProtocolTests.tcc184 testNaked<TProto, int64_t>((std::numeric_limits<int32_t>::min)()); in testProtocol()
185 testNaked<TProto, int64_t>((std::numeric_limits<int32_t>::max)()); in testProtocol()
186 testNaked<TProto, int64_t>((std::numeric_limits<int32_t>::min)() + 10); in testProtocol()
187 testNaked<TProto, int64_t>((std::numeric_limits<int32_t>::max)() - 16); in testProtocol()
188 testNaked<TProto, int64_t>((std::numeric_limits<int64_t>::min)()); in testProtocol()
189 testNaked<TProto, int64_t>((std::numeric_limits<int64_t>::max)()); in testProtocol()
191 testNaked<TProto, int64_t>(0); in testProtocol()
192 for (int64_t i = 0; i < 62; i++) { in testProtocol()
193 testNaked<TProto, int64_t>(1LL << i); in testProtocol()
194 testNaked<TProto, int64_t>(-(1LL << i)); in testProtocol()
[all …]
DGenericHelpers.h49 const char* ClassNames::getName<int64_t>() {
82 …static uint32_t write(std::shared_ptr<apache::thrift::protocol::TProtocol> proto, const int64_t& v… in write()
98 …static uint32_t read(std::shared_ptr<apache::thrift::protocol::TProtocol> proto, int64_t& val) { r… in read()
/thrift-3.4.0/lib/py/src/ext/
Dbinary.h48 void writeI64(int64_t val) { in writeI64()
49 int64_t net = static_cast<int64_t>(htonll(val)); in writeI64()
50 writeBuffer(reinterpret_cast<char*>(&net), sizeof(int64_t)); in writeI64()
57 int64_t t; in writeDouble()
131 bool readI64(int64_t& val) { in readI64()
133 if (!readBytes(&buf, sizeof(int64_t))) { in readI64()
136 memcpy(&val, buf, sizeof(int64_t)); in readI64()
143 int64_t f; in readDouble()
Dcompact.h45 void writeI64(int64_t val) { writeVarint64(toZigZag64(val)); } in writeI64()
50 int64_t t; in writeDouble()
53 writeBuffer(reinterpret_cast<char*>(&transfer.t), sizeof(int64_t)); in writeDouble()
146 bool readI64(int64_t& val) { in readI64()
149 val = fromZigZag<int64_t, uint64_t>(uval); in readI64()
157 int64_t f; in readDouble()
165 memcpy(&transfer.f, buf, sizeof(int64_t)); in readDouble()
255 int64_t val; in skipI64()
295 uint64_t toZigZag64(int64_t val) { return (val >> 63) ^ (val << 1); } in toZigZag64()
/thrift-3.4.0/lib/cpp/src/thrift/server/
DTServerFramework.h98 virtual int64_t getConcurrentClientLimit() const;
104 virtual int64_t getConcurrentClientCount() const;
110 virtual int64_t getConcurrentClientCountHWM() const;
122 virtual void setConcurrentClientLimit(int64_t newLimit);
168 int64_t clients_;
173 int64_t hwm_;
178 int64_t limit_;
DTThreadPoolServer.h80 virtual int64_t getTimeout() const;
81 virtual void setTimeout(int64_t value);
83 virtual int64_t getTaskExpiration() const;
84 virtual void setTaskExpiration(int64_t value);
93 std::atomic<int64_t> timeout_;
94 std::atomic<int64_t> taskExpiration_;
DTThreadPoolServer.cpp101 int64_t TThreadPoolServer::getTimeout() const { in getTimeout()
105 void TThreadPoolServer::setTimeout(int64_t value) { in setTimeout()
109 int64_t TThreadPoolServer::getTaskExpiration() const { in getTaskExpiration()
113 void TThreadPoolServer::setTaskExpiration(int64_t value) { in setTaskExpiration()
DTServerFramework.cpp191 int64_t TServerFramework::getConcurrentClientLimit() const { in getConcurrentClientLimit()
196 int64_t TServerFramework::getConcurrentClientCount() const { in getConcurrentClientCount()
201 int64_t TServerFramework::getConcurrentClientCountHWM() const { in getConcurrentClientCountHWM()
206 void TServerFramework::setConcurrentClientLimit(int64_t newLimit) { in setConcurrentClientLimit()
/thrift-3.4.0/lib/cpp/test/concurrency/
DThreadManagerTests.h44 static void sleep_(int64_t millisec) { in sleep_()
63 Task(Monitor& monitor, size_t& count, int64_t timeout) in Task()
90 int64_t _timeout;
91 int64_t _startTime;
92 int64_t _endTime;
102 bool loadTest(size_t count = 100, int64_t timeout = 100LL, size_t workerCount = 4) {
125 …int64_t time00 = std::chrono::duration_cast<std::chrono::milliseconds>(std::chrono::steady_clock::…
145 …int64_t time01 = std::chrono::duration_cast<std::chrono::milliseconds>(std::chrono::steady_clock::…
147 int64_t firstTime = 9223372036854775807LL;
148 int64_t lastTime = 0;
[all …]
DTests.cpp95 …int64_t time00 = std::chrono::duration_cast<std::chrono::milliseconds>(std::chrono::steady_clock::… in main()
96 …int64_t time01 = std::chrono::duration_cast<std::chrono::milliseconds>(std::chrono::steady_clock::… in main()
161 int64_t delay = 10LL; in main()
202 int64_t delay = 5LL; in main()
DThreadFactoryTests.h219 bool monitorTimeoutTest(int64_t count = 1000, int64_t timeout = 2) {
223 …int64_t startTime = std::chrono::duration_cast<std::chrono::milliseconds>(std::chrono::steady_cloc…
225 for (int64_t ix = 0; ix < count; ix++) {
235 …int64_t endTime = std::chrono::duration_cast<std::chrono::milliseconds>(std::chrono::steady_clock:…
/thrift-3.4.0/lib/py/compat/win32/
Dstdint.h89 typedef signed __int64 int64_t; typedef
97 typedef int64_t int_least64_t;
107 typedef int64_t int_fast64_t;
123 typedef int64_t intmax_t;
138 #define INT64_MIN ((int64_t)_I64_MIN)
/thrift-3.4.0/test/cpp/src/
DStressTestNonBlocking.cpp92 int64_t echoI64(const int64_t arg) override { return arg; } in echoI64()
205 int64_t arg = 1; in loopEchoI64()
206 int64_t result; in loopEchoI64()
228 int64_t _startTime;
229 int64_t _endTime;
471 int64_t time00; in main()
472 int64_t time01; in main()
491 int64_t firstTime = 9223372036854775807LL; in main()
492 int64_t lastTime = 0; in main()
495 int64_t minTime = 9223372036854775807LL; in main()
[all …]
DStressTest.cpp88 int64_t echoI64(const int64_t arg) override { return arg; } in echoI64()
210 int64_t arg = 1; in loopEchoI64()
211 int64_t result; in loopEchoI64()
233 int64_t _startTime;
234 int64_t _endTime;
534 int64_t time00; in main()
535 int64_t time01; in main()
554 int64_t firstTime = 9223372036854775807LL; in main()
555 int64_t lastTime = 0; in main()
558 int64_t minTime = 9223372036854775807LL; in main()
[all …]
/thrift-3.4.0/lib/cpp/src/thrift/windows/
DGetTimeOfDay.h35 int64_t tv_sec;
36 int64_t tv_nsec;
/thrift-3.4.0/lib/cpp/src/thrift/concurrency/
DMutex.h47 virtual bool timedlock(int64_t milliseconds) const;
60 Guard(const Mutex& value, int64_t timeout = 0) : mutex_(&value) {
DThreadManager.h165 int64_t timeout = 0LL,
166 int64_t expiration = 0LL) = 0;
/thrift-3.4.0/lib/cpp/src/thrift/protocol/
DTCompactProtocol.h135 uint32_t writeI64(const int64_t i64);
179 uint64_t i64ToZigzag(const int64_t l);
208 uint32_t readI64(int64_t& i64);
228 uint32_t readVarint64(int64_t& i64);
230 int64_t zigzagToI64(uint64_t n);
/thrift-3.4.0/lib/cpp/test/processor/
DEventLog.h79 Event waitForEvent(int64_t timeout = 500);
80 Event waitForConnEvent(uint32_t connId, int64_t timeout = 500);
/thrift-3.4.0/compiler/cpp/src/thrift/parse/
Dt_const_value.h51 …t_const_value(int64_t val) : doubleVal_(0.0f), enum_((t_enum*)nullptr), valType_(CV_UNKNOWN) { set… in t_const_value()
62 void set_integer(int64_t val) { in set_integer()
67 int64_t get_integer() const { in get_integer()
208 int64_t intVal_;

123