| /thrift-3.4.0/lib/cpp/test/processor/ |
| D | EventLog.cpp | 88 Event e(type, connectionId, callId, message); in append()
94 Event EventLog::waitForEvent(int64_t timeout) { in waitForEvent()
102 return Event(ET_LOG_END, 0, 0, ""); in waitForEvent()
105 Event event = events_.front(); in waitForEvent()
110 Event EventLog::waitForConnEvent(uint32_t connId, int64_t timeout) { in waitForConnEvent()
123 return Event(ET_LOG_END, 0, 0, ""); in waitForConnEvent()
127 Event event = *it; in waitForConnEvent()
|
| D | EventLog.h | 35 struct Event { struct
36 Event(EventType type, uint32_t connectionId, uint32_t callId, const std::string& message) in Event() argument
79 Event waitForEvent(int64_t timeout = 500);
80 Event waitForConnEvent(uint32_t connId, int64_t timeout = 500);
83 typedef std::list<Event> EventList;
|
| D | ProcessorTest.cpp | 293 Event event = log->waitForEvent(10); in checkNoEvents()
304 Event event = log->waitForEvent(2500); in checkNewConnEvents()
319 Event event = log->waitForEvent(); in checkCloseEvents()
340 Event event = log->waitForEvent(); in checkCallHandlerEvents()
377 Event event = log->waitForEvent(); in checkCallPostHandlerEvents()
533 Event event = log->waitForEvent(); in testEventSequencing()
710 Event event = log->waitForEvent(); in testOnewayCall()
761 Event event = log->waitForEvent(); in testExpectedError()
817 Event event = log->waitForEvent(); in testUnexpectedError()
|
| /thrift-3.4.0/lib/swift/Sources/ |
| D | TSSLSocketTransport.swift | 166 public func stream(_ aStream: Stream, handle eventCode: Stream.Event) { in stream()
169 case Stream.Event(): break in stream()
170 case Stream.Event.hasBytesAvailable: break in stream()
171 case Stream.Event.openCompleted: break in stream()
172 case Stream.Event.hasSpaceAvailable: in stream()
230 case Stream.Event.errorOccurred: break in stream()
231 case Stream.Event.endEncountered: break in stream()
|
| /thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/transport/ |
| D | TFileTransport.java | 58 public static class Event { class in TFileTransport
68 public Event(byte[] buf) { in Event() method in TFileTransport.Event
172 Event currentEvent_ = null;
335 if (currentEvent_.getSize() < esize) currentEvent_ = new Event(new byte[esize]); in readEvent()
366 currentEvent_ = new Event(new byte[256]); in open()
|
| /thrift-3.4.0/lib/dart/lib/src/browser/ |
| D | t_web_socket.dart | 23 import 'dart:html' show Event;
105 void _onOpen(Event event) {
133 void _onError(Event event) {
|
| /thrift-3.4.0/lib/haxe/src/org/apache/thrift/transport/ |
| D | TFullDuplexHttpClient.hx | 24 import flash.events.Event;
189 this.socket.addEventListener(Event.CONNECT, socketConnected);
197 public function socketConnected(event : Event) : Void
|
| /thrift-3.4.0/lib/erl/src/ |
| D | thrift_json_parser.erl | 32 handle_event(Event, {Handler, State}, _Config) -> {Handler, Handler:handle_event(Event, State)}.
35 handle_event(Event, State) -> [Event] ++ State.
|
| D | thrift_json_protocol.erl | 360 expect(#json_protocol{jsx={event, Event, Next}}=State, ExpectedEvent) ->
361 expect(State#json_protocol{jsx={event, {Event, none}, Next}}, ExpectedEvent).
|
| /thrift-3.4.0/lib/py/test/ |
| D | test_sslsocket.py | 53 self._listening = threading.Event()
55 self._port_bound = threading.Event()
57 self._client_accepted = threading.Event()
|
| /thrift-3.4.0/test/crossrunner/ |
| D | run.py | 366 self._stop = multiprocessing.Event()
|
| /thrift-3.4.0/ |
| D | CHANGES.md | 3784 - [THRIFT-923](https://issues.apache.org/jira/browse/THRIFT-923) - Event-driven client and server s…
|
