mirror of
https://github.com/xcat2/confluent.git
synced 2024-11-26 11:30:23 +00:00
Breakup logentries exceeding 65k
The data length of a log entry must not exceed 65k. If an attempt is made to log that much, break it up and duplicate the records. It may make sense to indicate a continuation explicitly, but for now just extend.
This commit is contained in:
parent
12d0fe21cd
commit
9e44087047
@ -31,8 +31,25 @@ console = eventlet.import_patched('pyghmi.ipmi.console')
|
||||
ipmicommand = eventlet.import_patched('pyghmi.ipmi.command')
|
||||
import socket
|
||||
|
||||
|
||||
# There is something not right with the RLocks used in pyghmi when
|
||||
# eventlet comes into play. It seems like sometimes on acquire,
|
||||
# it calls _get_ident and it isn't the id(greenlet) and so
|
||||
# a thread deadlocks itself due to identity crisis?
|
||||
# However, since we are not really threaded, the operations being protected
|
||||
# are not actually dangerously multiplexed... so we can replace with
|
||||
# a null context manager for now
|
||||
class NullLock(object):
|
||||
def __enter__(self, *args, **kwargs):
|
||||
return 1
|
||||
|
||||
def __exit__(self, *args, **kwargs):
|
||||
return 1
|
||||
|
||||
console.session.select = eventlet.green.select
|
||||
console.session.threading = eventlet.green.threading
|
||||
console.session.WAITING_SESSIONS = NullLock()
|
||||
console.session.KEEPALIVE_SESSIONS = NullLock()
|
||||
console.session.socket.getaddrinfo = eventlet.support.greendns.getaddrinfo
|
||||
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user