-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathActivePackage.tar
143 lines (103 loc) · 10 KB
/
ActivePackage.tar
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
./ 0000755 6226400 0221115 00000000000 13276066011 010402 5 ustar u516036 vas_vcs ./Config.ini 0000644 6226400 0221115 00000000150 13276065615 012315 0 ustar u516036 vas_vcs IP address = 22.49.33.206
Port = 5000
Time interval to check for the process being up in seconds = 5
./index.html 0000644 6226400 0221115 00000000240 13276065631 012402 0 ustar u516036 vas_vcs <head>
<title>Not activeNonNot active</title>
</head>
<body>
<h1>The status of uDeploy application on this server is: </h1>
<h1>Not active</h1>
</body> ./PythonServer.py 0000644 6226400 0221115 00000000404 13276065656 013440 0 ustar u516036 vas_vcs #!/usr/bin/env python
import SimpleHTTPServer
import SocketServer
PORT = 8000
Handler = SimpleHTTPServer.SimpleHTTPRequestHandler
httpd = SocketServer.TCPServer(("", PORT), Handler)
print "Server running on port ", PORT
httpd.serve_forever() ./socketClient2.py 0000644 6226400 0221115 00000006313 13276065675 013507 0 ustar u516036 vas_vcs # This is a TCP client application
# This is a TCP client application
import os
import sys
import socket
import subprocess
import time
import re
import fnmatch
import platform
import string
class ClientComm1:
lines=[]
CfgData=[]
BUFFER_SIZE=512
MESSAGE='Data from client ok'
processU=''
processState=True
timeInterval=0
def __init__(self, CfgFile):
self.lines=open(CfgFile)
for line in self.lines:
self.CfgData.append(line)
self.IpAddress=(self.CfgData[0]).split('=')[1].strip()
self.Port=int((self.CfgData[1]).split('=')[1])
self.timeInterval=int((self.CfgData[2]).split('=')[1])
#print(self.timeInterval)
def OpenSocket(self):
try:
s=socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((self.IpAddress, self.Port))
s.send(self.MESSAGE.encode('utf-8'))
data=s.recv(self.BUFFER_SIZE)
#s.close()
print ('received data', data)
except:
print('Either the udeploy server app has gone down or is not running and the process has been handed over to the non active server (normal hand off)')
print('or the the non active pair to this program on the non active server is not running to accept the hand off')
return
def WriteIntoFile(self,indexFileName,oldStatus, newStatus):
f=open(indexFileName,'r')
file=f.read()
newData=file.replace(oldStatus,newStatus)
f.close()
f=open(indexFileName,'w')
f.write(newData)
f.close()
return
def variableReturns(self):
return self.timeInterval
def IsProcessUp(self):
#ProcessU=subprocess.Popen("ps -ef | grep java")
#self.processU=os.system("ps -ef|grep server | grep java")
self.processU=os.popen("ps -ef|grep server | grep java").read()
#print (self.processU)
self.processState='UDeployServer' in self.processU
return self.processState
def main():
print('start')
#ClientObject1=ClientComm.CfgData='C:/temp/Config.ini'
#ClientObject1.opensocket()
Client1=ClientComm1('Config.ini')
#Client1.OpenSocket()
#Client1.WriteIntoFile('index.html','Non Active','Active')
'''
print ('the number', Client1.variableReturns())
print ('the type ',type(Client1.variableReturns()))
print('time interval ',Client1.variableReturns())
varTimeInterval=Client1.variableReturns()
'''
while True:
Client1.IsProcessUp()
#time.sleep(Client1.variableReturns())
time.sleep(Client1.variableReturns())
'''
print('here')
'''
if (Client1.IsProcessUp()):
Client1.WriteIntoFile('index.html','Not active','Active')
else:
Client1.WriteIntoFile('index.html','Active','Not active')
Client1.OpenSocket()
break
return
if __name__=='__main__':
main()