| /thrift-3.4.0/lib/cpp/src/thrift/concurrency/ |
| D | TimerManager.cpp | 81 Synchronized s(manager_->monitor_); in run() local
91 Synchronized s(manager_->monitor_); in run() local
132 Synchronized s(manager_->monitor_); in run() local
178 Synchronized s(monitor_); in start() local
194 Synchronized s(monitor_); in start() local
205 Synchronized s(monitor_); in stop() local
228 Synchronized s(monitor_); in threadFactory() local
233 Synchronized s(monitor_); in threadFactory() local
252 Synchronized s(monitor_); in add() local
277 Synchronized s(monitor_); in remove() local
[all …]
|
| /thrift-3.4.0/lib/cpp/test/processor/ |
| D | ServerThread.cpp | 49 concurrency::Synchronized s(serverMonitor_); in start() local
108 concurrency::Synchronized s(serverMonitor_); in run() local
123 concurrency::Synchronized s(serverMonitor_); in run() local
138 concurrency::Synchronized s(serverMonitor_); in preServe() local
|
| D | EventLog.cpp | 85 Synchronized s(monitor_); in append() local
95 Synchronized s(monitor_); in waitForEvent() local
111 Synchronized s(monitor_); in waitForConnEvent() local
|
| /thrift-3.4.0/test/ocaml/client/ |
| D | TestClient.ml | 23 let s = new TSocket.t "127.0.0.1" 9090;; var
62 let s = Hashtbl.create 5 in var
|
| /thrift-3.4.0/lib/d/src/thrift/util/ |
| D | future.d | 145 auto s = atomicLoad(status_); in get() local
158 auto s = atomicLoad(status_); in getException() local
179 auto s = atomicLoad(status_); in succeed() local
194 auto s = atomicLoad(status_); in succeed() local
|
| /thrift-3.4.0/lib/java/src/test/java/org/apache/thrift/protocol/ |
| D | TestShortStack.java | 30 ShortStack s = new ShortStack(1); in testOps() local
|
| D | TestTProtocolUtil.java | 41 GuessProtocolStruct s = new GuessProtocolStruct(); in testGuessProtocolFactory_JSON() local
|
| /thrift-3.4.0/lib/cpp/test/ |
| D | OptionalRequiredTest.cpp | 77 Simple s; in BOOST_AUTO_TEST_CASE() local
91 Simple s; in BOOST_AUTO_TEST_CASE() local
106 Simple s; in BOOST_AUTO_TEST_CASE() local
123 Simple s; in BOOST_AUTO_TEST_CASE() local
139 Simple s; in BOOST_AUTO_TEST_CASE() local
|
| D | ToStringTest.cpp | 106 std::set<char> s; in BOOST_AUTO_TEST_CASE() local
111 std::set<char> s; in BOOST_AUTO_TEST_CASE() local
117 std::set<char> s; in BOOST_AUTO_TEST_CASE() local
|
| D | TransportTest.cpp | 360 apache::thrift::concurrency::Synchronized s(g_alarm_monitor); in alarm_handler() local
394 apache::thrift::concurrency::Synchronized s(g_alarm_monitor); in alarm_handler_wrapper() local
426 apache::thrift::concurrency::Synchronized s(g_alarm_monitor); in add_trigger() local
447 apache::thrift::concurrency::Synchronized s(g_alarm_monitor); in clear_triggers() local
1041 apache::thrift::concurrency::Synchronized s(g_alarm_monitor); in ~global_fixture() local
|
| /thrift-3.4.0/lib/javame/src/org/apache/thrift/protocol/ |
| D | TSet.java | 29 public TSet(byte t, int s) { in TSet()
|
| D | TList.java | 29 public TList(byte t, int s) { in TList()
|
| D | TMap.java | 29 public TMap(byte k, byte v, int s) { in TMap()
|
| D | TMessage.java | 29 public TMessage(String n, byte t, int s) { in TMessage()
|
| /thrift-3.4.0/lib/cpp/src/thrift/windows/ |
| D | WinFcntl.cpp | 47 std::string s(ws.begin(), ws.end()); in thrift_wstr2str() local
|
| /thrift-3.4.0/lib/cpp/src/thrift/protocol/ |
| D | TMap.h | 42 TMap(TType k, TType v, int s) in TMap()
|
| D | TSet.h | 40 TSet(TType t, int s) in TSet()
|
| /thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/protocol/ |
| D | TList.java | 28 public TList(byte t, int s) { in TList()
|
| D | TSet.java | 28 public TSet(byte t, int s) { in TSet()
|
| D | TMap.java | 28 public TMap(byte k, byte v, int s) { in TMap()
|
| D | TMessage.java | 28 public TMessage(String n, byte t, int s) { in TMessage()
|
| /thrift-3.4.0/test/cpp/src/ |
| D | StressTest.cpp | 130 Synchronized s(_monitor); in run() local
171 Synchronized s(_monitor); in run() local
244 apache::thrift::concurrency::Synchronized s(m_); in preServe() local
249 apache::thrift::concurrency::Synchronized s(m_); in waitForService() local
538 Synchronized s(monitor); in main() local
|
| /thrift-3.4.0/compiler/cpp/src/thrift/parse/ |
| D | t_const_value.h | 128 size_t s = ret.find('.'); in get_identifier_name() local
142 size_t s = ret.find('.'); in get_identifier_with_parent() local
|
| /thrift-3.4.0/test/threads/ |
| D | ThreadsServer.cpp | 91 Synchronized s(m); in go2sleep() local
|
| /thrift-3.4.0/test/py.twisted/ |
| D | test_suite.py | 53 def testString(self, s): argument
77 def testException(self, s): argument
|
