Home
last modified time | relevance | path

Searched refs:logger (Results 1 – 25 of 26) sorted by relevance

12

/thrift-3.4.0/lib/kotlin/cross-test-server/src/main/kotlin/org/apache/thrift/test/
DTestHandler.kt39 private val logger: Logger = LoggerFactory.getLogger(TestHandler::class.java) constant
43 logger.info("testVoid()\n") in testVoid()
47 logger.info("testString(\"$thing\")\n") in testString()
52 logger.info("testBool($thing)\n") in testBool()
57 logger.info("testByte($thing)\n") in testByte()
62 logger.info("testI32($thing)\n") in testI32()
67 logger.info("testI64($thing)\n") in testI64()
72 logger.info("testDouble($thing)\n") in testDouble()
87 logger.info("testBinary($sb)\n") in testBinary()
93 logger.info("testUuid($thing)\n") in testUuid()
[all …]
/thrift-3.4.0/lib/go/thrift/
Dlogger.go46 func StdLogger(logger *log.Logger) Logger {
47 if logger == nil {
48 logger = log.New(os.Stderr, "", log.LstdFlags)
51 logger.Print(msg)
64 func fallbackLogger(logger Logger) Logger {
65 if logger == nil {
68 return logger
Dsimple_server.go72 logger Logger member
181 func (p *TSimpleServer) SetLogger(logger Logger) {
182 p.logger = logger
204 p.logger(fmt.Sprintf("error processing request: %v", err))
235 p.logger = fallbackLogger(p.logger)
Ddebug_protocol.go73 func NewTDebugProtocolFactoryWithLogger(underlying TProtocolFactory, logPrefix string, logger Logge…
77 Logger: logger,
/thrift-3.4.0/lib/py/src/transport/
Dsslcompat.py25 logger = logging.getLogger(__name__) variable
70 logger.debug('ipaddress module is available')
73 logger.warn('ipaddress module is unavailable')
80 logger.debug('backports.ssl_match_hostname module is available')
85 logger.warn('backports.ssl_match_hostname module is too old')
88 logger.warn('backports.ssl_match_hostname is unavailable')
92 logger.debug('ssl.match_hostname is available')
95 logger.warn('using legacy validation callback')
DTSocket.py28 logger = logging.getLogger(__name__) variable
129 logger.exception(msg)
145 logger.info('Could not connect to %s', sockaddr, exc_info=True)
148 logger.error(msg)
211 logger.warn('You have to set backlog before listen.')
DTSSLSocket.py31 logger = logging.getLogger(__name__) variable
198 logger.warning(
297 logger.exception(msg)
384 logger.exception('Error while accepting from %s', addr)
400 logger.warn('Failed to validate client certificate address: %s',
/thrift-3.4.0/test/
Dtest.py56 logger = multiprocessing.get_logger()
57 logger.debug('Collecting tests')
67 logger.debug('Only running known failures')
71 logger.debug('Skipping known failures')
76 logger.debug('Executing %d tests' % len(tests))
80 logger.debug('Waiting for completion')
83 logger.debug('Interrupted, shutting down')
90 logger = multiprocessing.get_logger()
91 logger.debug('Collecting tests')
103 logger.debug('Only running known failures')
[all …]
/thrift-3.4.0/test/netstd/Server/
DTestServer.cs207 private readonly TestLogDelegate logger; field in ThriftTest.TestServer.TestHandlerAsync
212 logger += TestConsoleLogger; in TestHandlerAsync()
213 logger.Invoke("New TestHandler instance created"); in TestHandlerAsync()
228 logger.Invoke("testVoid()"); in testVoid()
234 logger.Invoke("testString({0})", thing ?? "<null>"); in testString()
240 logger.Invoke("testBool({0})", thing); in testBool()
246 logger.Invoke("testByte({0})", thing); in testByte()
252 logger.Invoke("testI32({0})", thing); in testI32()
258 logger.Invoke("testI64({0})", thing); in testI64()
264 logger.Invoke("testDouble({0})", thing); in testDouble()
[all …]
/thrift-3.4.0/lib/rb/benchmark/
Dthin_server.rb42 logger = Logger.new(STDERR)
43 logger.level = Logger::WARN
44 Thrift::NonblockingServer.new(processor, transport, transport_factory, nil, 20, logger).serve
Dserver.rb46 logger = Logger.new(STDERR)
47 logger.level = Logger::WARN
48 args << logger
/thrift-3.4.0/lib/py/src/server/
DTServer.py29 logger = logging.getLogger(__name__) variable
106 logger.exception(x)
133 logger.exception(x)
155 logger.exception(x)
182 logger.exception(x)
205 logger.exception(x)
219 logger.exception(x)
230 logger.exception(x)
255 logger.warning(e, exc_info=True)
299 logger.exception(e)
[all …]
DTProcessPoolServer.py28 logger = logging.getLogger(__name__) variable
73 logger.exception(x)
88 logger.exception(x)
109 logger.exception(x)
120 logger.exception(x)
DTNonblockingServer.py42 logger = logging.getLogger(__name__) variable
62 logger.exception("Exception while processing request", exc_info=True)
90 logger.debug('ignoring socket exception', exc_info=True)
147 logger.error('could not read frame from socket')
149 logger.debug('read zero length. client might have disconnected')
155 logger.error('could not read the head from frame')
340 logger.debug("KeyError in unregistering connections...")
357 logger.debug("reached an impossible state in _poll_select")
380 logger.debug('error while accepting', exc_info=True)
/thrift-3.4.0/test/crossrunner/
Drun.py156 logger = multiprocessing.get_logger()
164 … logger.warn('[{0}] slept for {1} seconds but server is not open'.format(sv.proc.pid, slept))
168 …logger.debug('[{0}] domain(unix) socket not available yet. slept for {1} seconds so far'.format(sv…
183 logger.warn('[{0}] server process is exited'.format(sv.proc.pid))
185 …logger.debug('[{0}] socket not available yet. slept for {1} seconds so far'.format(sv.proc.pid, sl…
191 logger.debug('[{0}] server ready - waited for {1} seconds'.format(sv.proc.pid, slept))
201 logger.debug('Skipping because shutting down')
203 logger.debug('Start')
205 logger.debug('Start with port %d' % port)
209 logger.debug('Starting server')
[all …]
/thrift-3.4.0/lib/rb/lib/thrift/server/
Dnonblocking_server.rb26 …alize(processor, server_transport, transport_factory=nil, protocol_factory=nil, num=20, logger=nil) argument
29 if logger.nil?
33 @logger = logger
101 def initialize(processor, server_transport, transport_factory, protocol_factory, num, logger) argument
107 @logger = logger
263 def initialize(processor, transport_factory, protocol_factory, logger, queue) argument
267 @logger = logger
/thrift-3.4.0/lib/rb/lib/thrift/
Dprocessor.rb24 def initialize(handler, logger=nil) argument
26 if logger.nil?
30 @logger = logger
/thrift-3.4.0/lib/netstd/Thrift/Server/
DTThreadPoolAsyncServer.cs70 …oolAsyncServer(ITAsyncProcessor processor, TServerTransport serverTransport, ILogger logger = null) in TThreadPoolAsyncServer() argument
74 new Configuration(), logger) in TThreadPoolAsyncServer()
106 int minThreadPoolThreads, int maxThreadPoolThreads, ILogger logger = null) in TThreadPoolAsyncServer() argument
110 logger) in TThreadPoolAsyncServer()
121 ILogger logger = null) in TThreadPoolAsyncServer() argument
123 inputProtocolFactory, outputProtocolFactory, logger) in TThreadPoolAsyncServer()
DTServer.cs44 ILogger logger = null) in TServer() argument
52 Logger = logger; // null is absolutely legal in TServer()
DTSimpleAsyncServer.cs43 ILogger logger) in TSimpleAsyncServer() argument
50 logger) in TSimpleAsyncServer()
/thrift-3.4.0/lib/py/src/
DTTornado.py34 logger = logging.getLogger(__name__) variable
84 logger.debug('socket connecting')
185 logger.exception('thrift exception in handle_stream')
188 logger.info('client disconnected %s:%d', host, port)
/thrift-3.4.0/lib/rb/spec/
Dnonblocking_server_spec.rb110 logger = Logger.new(STDERR)
111 logger.level = Logger::WARN
112 … @server = Thrift::NonblockingServer.new(processor, @transport, transport_factory, nil, 5, logger)
/thrift-3.4.0/lib/haxe/src/org/apache/thrift/server/
DTSimpleServer.hx40 logger : Dynamic->Void = null) {
44 logger);
/thrift-3.4.0/lib/dart/lib/src/transport/
Dt_socket_transport.dart31 final Logger logger = Logger('thrift.TSocketTransport');
41 socket.onError.listen((e) => logger.warning(e));
/thrift-3.4.0/tutorial/netstd/Server/
DProgram.cs245 logger: LoggingHelper.CreateLogger<TSimpleAsyncServer >()); in RunSelectedConfigurationAsync()

12