updated README, renamed monitor and osd files

Author: vivekvardhanadepu

README.md

@@ -1,3 +1,3 @@
 # Distributed-Storage-System
-This is a working module of Ceph distribute storage system.
-We have used AWS, SQL Lite and Python 
+This is a prototype Distributed Storage System mostly based on Ceph[https://ceph.io/]</br>
+We have used SQLite as database, AWS for the servers, and python for both GUI and backend

monitor/monitor.py

@@ -0,0 +1,54 @@
+"""
+@author: Kartik Saini
+@author: Harshit Soora
+@author: Vivek Vardhan Adepu
+"""
+
+import socket
+import pickle
+from transfer import _send_msg, _recv_msg
+from object_pg import DataObject, PlacementGroup
+
+#HEADERSIZE = 10
+
+s = socket.socket()
+print ("Socket successfully created")
+
+# reserve a port on your computer in our
+# case it is 12345 but it can be anything
+port = 12345
+
+# Next bind to the port
+# we have not typed any ip in the ip field
+# instead we have inputted an empty string
+# this makes the server listen to requests
+# coming from other computers on the network
+s.bind(('', port))
+print ("socket binded to %s" %(port))
+
+# put the socket into listening mode
+s.listen(5)
+print ("socket is listening")
+
+# a forever loop until we interrupt it or
+# an error occurs
+while True:
+
+    # Establish connection with client.
+    c, addr = s.accept()
+    print ('Got connection from', addr )
+
+    # send a thank you message to the client.
+    msg = _recv_msg(c, 1024)
+
+    print(msg)
+
+    res = {"osd_ip":[["127.0.0.1", 12346], ["127.0.0.1", 8090]]}
+
+    _send_msg(c, res)
+
+    c.close()
+
+s.close()
+# Close the connection with the client
+#c.close()

monitor/tmp_monitor.py

@@ -0,0 +1,76 @@
+"""
+@author: Kartik Saini
+@author: Harshit Soora
+@author: Vivek Vardhan Adepu
+"""
+
+import socket
+import pickle
+from transfer import _send_msg, _recv_msg
+HEADERSIZE = 10
+
+s = socket.socket()
+print ("Socket successfully created")
+
+# reserve a port on your computer in our
+# case it is 12345 but it can be anything
+port = 12346
+
+# Next bind to the port
+# we have not typed any ip in the ip field
+# instead we have inputted an empty string
+# this makes the server listen to requests
+# coming from other computers on the network
+s.bind(('', port))
+print ("socket binded to %s" %(port))
+
+# put the socket into listening mode
+s.listen(5)
+print ("socket is listening")
+
+# a forever loop until we interrupt it or
+# an error occurs
+while True:
+
+    # Establish connection with client.
+    c, addr = s.accept()
+    print ('Got connection from', addr )
+
+    # send a thank you message to the client.
+    msg = _recv_msg(c, 1024)
+
+    print(msg)
+
+    if(msg["type"] == "WRITE"):
+    	pg = msg["PG"]
+    	file = open("./data/"+pg.pg_id, 'wb')
+
+    	pg_b = pickle.dumps(pg)
+    	file.write(pg_b)
+
+    	# pickle.dump(pg, file)
+    	file.close()
+
+    	_send_msg(c, [pg.pg_id, "SUCCESS"])
+
+    elif msg["type"] == "READ":
+    	pg_id = msg["PG_id"]
+    	file = open("./data/"+pg_id, 'rb')
+
+    	pg_b = file.read()
+    	pg = pickle.loads(pg_b)
+
+    	file.close()
+    	# print(pg)
+    	msg = {"pg_id": pg.pg_id, "res":"SUCCESS", "PG":pg}
+
+    	_send_msg(c, msg)
+
+    c.close()
+
+    print("RECV")
+    print(msg)
+
+s.close()
+# Close the connection with the client
+#c.close()