eta.insert(0, 0)
dba.add_status_message_date_time(cs_id, date, time,
- num_peers, dht, download_speed,
- upload_speed, download_size, upload_size, eta)
+ num_peers, dht, download_speed,
+ upload_speed, download_size, upload_size, eta)
else:
break
listen_port = int(message_array[8].strip())
dba.add_verbose_message_date_time(cs_id, date, time,
- peer_ip, peer_port, message_type,
- index, begin, length, listen_port)
+ peer_ip, peer_port, message_type,
+ index, begin, length, listen_port)
else:
break
listen_port = int(sys.stdin.readline().strip())
dba.add_verbose_messages_date_time(cs_id, date, time,
- peer_ip, peer_port, message_type, index,
- begin, length, listen_port)
+ peer_ip, peer_port, message_type, index,
+ begin, length, listen_port)
if action == "delete":
dba.delete_verbose_messages(id)
time = timestamp[1]
logger.debug("(%d, %s, %s, %s, %d, %d, %s, %d, %d, %d, %s, %s)"
- %(swarm_id, client_name, system_os,
- system_os_version, system_ram,
- system_cpu, public_ip, public_port,
- ds_limit, us_limit, date, time))
+ %(swarm_id, client_name, system_os,
+ system_os_version, system_ram,
+ system_cpu, public_ip, public_port,
+ ds_limit, us_limit, date, time))
dba.add_client_session_date_time(swarm_id, client_name,
- system_os, system_os_version, system_ram,
- system_cpu, public_ip, public_port,
- ds_limit, us_limit, date, time)
+ system_os, system_os_version, system_ram,
+ system_cpu, public_ip, public_port,
+ ds_limit, us_limit, date, time)
else:
break
try:
opts, args = getopt.getopt(sys.argv[1:], "ha:l:d:r:m:s:c:i:",
- ["help", "add=", "list=", "delete=", "read=",
- "sep=", "swarm=", "client=", "id="])
+ ["help", "add=", "list=", "delete=", "read=",
+ "sep=", "swarm=", "client=", "id="])
except getopt.GetoptError, err:
logger.error(str(err))
usage()
start_time = sys.stdin.readline().strip().split(' ')
dba.add_client_sessions_date_time(swarm_id, client_name,
- system_os, os_version, ram, cpu, ip, port,
- ds_limit, us_limit, date, time)
+ system_os, os_version, ram, cpu, ip, port,
+ ds_limit, us_limit, date, time)
if action == "delete":
if client_session_list_option == "id":
dba.delete_client_session_by_id(id)
dba.show_client_sessions_by_swarm(swarm, client)
if action == "read":
read_client_sessions(dba, sep)
-
+
dba.disconnect()
if __name__ == "__main__":