diff options
Diffstat (limited to 'python/toree_profile.py')
-rw-r--r-- | python/toree_profile.py | 78 |
1 files changed, 78 insertions, 0 deletions
diff --git a/python/toree_profile.py b/python/toree_profile.py new file mode 100644 index 0000000..eaadc9d --- /dev/null +++ b/python/toree_profile.py @@ -0,0 +1,78 @@ +# +# (C) Copyright IBM Corp. 2017 +# +# Licensed under the Apache License, Version 2.0 (the "License"); +# you may not use this file except in compliance with the License. +# You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. +# + + +import os +import os.path +import json +import time + +class Profile: + PROCESS_FILE_NAME = "toree.pid" + CONFIGURATION_FILE_NAME = "profile.json" + + profilePath = None + + def __init__(self, profilePath): + self.profilePath = profilePath + + def pidLocation(self): + return self.profilePath + '/' + self.PROCESS_FILE_NAME + + def configurationLocation(self): + return self.profilePath + '/' + self.CONFIGURATION_FILE_NAME + + def isAvailable(self): + taken = os.path.exists(self.pidLocation()) + return not taken + + def reserve(self): + open(self.pidLocation(), 'a').close() + + def release(self): + if os.path.exists(self.pidLocation()): + os.remove(self.pidLocation()) + + def pid(self): + with open(self.pidLocation(), 'r') as pid_file: + data = pid_file.read() + return data + + def updatePid(self, pid): + try: + file = open(self.pidLocation(), 'w') + file.write(pid) + finally: + file.close + + def config(self): + with open(self.configurationLocation(), 'r') as data_file: + return json.load(data_file) #, object_hook=util._byteify + + + +""" +p = Profile('/Users/lresende/opensource/jupyter/toree-gateway/src/main/resources/profiles/kernel-1') +print(p.pidLocation()) +print(p.configurationLocation()) +print(p.isAvailable()) +c = p.config() +print(c['stdin_port']) +p.reserve() +time.sleep(10) +p.release() +""" + |