import threading, signal

is_exit = False

def write_login(self):

		global is_exit

		write_log('login rsync start!!!')

		count = 0

		data_list = []

		data_line = ''

		while not is_exit:

			# if debug, then log_array = self._redis.lrange(self._list_name, 0, 0), data_line = log_json

			try:

				log_array = self._redis.lrange(self._list_name, 0, 9999)

			except Exception,e:

				write_log("[write_login][redis err]" + str(e) + data_line)

				data_list = []

				is_exit = True

				return