{ 'size': 20, 'notifyafter': 90, 'deleteafter': 150 },
{ 'size': 5, 'deleteafter': 700 }
]
-EXCLUDED_USERNAMES = ['lost+found', 'debian']
+EXCLUDED_USERNAMES = ['lost+found', 'debian', 'buildd', 'd-i']
MAIL_FROM = 'debian-admin (via Cron) <bulk@admin.debian.org>'
MAIL_TO = '{username}@{hostname}.debian.org'
MAIL_CC = 'debian-admin (bulk sink) <bulk@admin.debian.org>'
pass
class LastlogTimes(dict):
- LASTLOG_STRUCT = '=L32s256s'
+ LASTLOG_STRUCT_32 = '=L32s256s'
+ LASTLOG_STRUCT_64 = '=Q32s256s'
def __init__(self):
- record_size = struct.calcsize(self.LASTLOG_STRUCT)
+ record_size_32 = struct.calcsize(self.LASTLOG_STRUCT_32)
+ record_size_64 = struct.calcsize(self.LASTLOG_STRUCT_64)
+ lastlog_size = os.path.getsize('/var/log/lastlog')
+ if 0 == (lastlog_size % record_size_32):
+ self.LASTLOG_STRUCT = self.LASTLOG_STRUCT_32
+ record_size = record_size_32
+ elif 0 == (lastlog_size % record_size_64):
+ self.LASTLOG_STRUCT = self.LASTLOG_STRUCT_64
+ record_size = record_size_64
+ else:
+ raise RuntimeError('Unknown architecture, cannot interpret /var/log/lastlog file size (%d)' % lastlog_size)
with open('/var/log/lastlog', 'r') as fp:
uid = -1 # there is one record per uid in lastlog
for record in iter(lambda: fp.read(record_size), ''):
def run(self):
current_time = time.time()
+ conn = None
try:
data = {}
- for user in set(self.homedir_sizes.keys()) +
+ for user in set(self.homedir_sizes.keys()) | \
set(self.lastlog_times.keys()):
data[user] = {
'homedir': self.homedir_sizes.get(user, 0),
exchange_name=config.exchange,
timeout=5)
except Exception, e:
- LOG.error("Error sending: %s" % e)
+ logging.error("Error sending: %s" % e)
finally:
if conn:
conn.close()
realname = pwd.getpwnam(username).pw_gecos.decode('utf-8').split(',', 1)[0]
except:
realname = username
- lastlog_time = self.lastlog_times[username]
+ lastlog_time = self.lastlog_times.get(username, 0)
days_ago = int( (current_time - lastlog_time) / 3600 / 24 )
kwargs = {
'hostname': platform.node(),