|
@@ -33,6 +33,8 @@ import time
|
|
import urllib2
|
|
import urllib2
|
|
import urlparse
|
|
import urlparse
|
|
|
|
|
|
|
|
+from ambari_commons.os_family_impl import OsFamilyFuncImpl, OsFamilyImpl
|
|
|
|
+from ambari_commons import OSConst
|
|
|
|
|
|
class Source(object):
|
|
class Source(object):
|
|
def __init__(self, name):
|
|
def __init__(self, name):
|
|
@@ -74,10 +76,16 @@ class StaticFile(Source):
|
|
|
|
|
|
return self.read_file(path)
|
|
return self.read_file(path)
|
|
|
|
|
|
|
|
+ @OsFamilyFuncImpl(os_family=OsFamilyImpl.DEFAULT)
|
|
def read_file(self, path):
|
|
def read_file(self, path):
|
|
from resource_management.core import sudo
|
|
from resource_management.core import sudo
|
|
return sudo.read_file(path)
|
|
return sudo.read_file(path)
|
|
|
|
|
|
|
|
+ @OsFamilyFuncImpl(os_family=OSConst.WINSRV_FAMILY)
|
|
|
|
+ def read_file(self, path):
|
|
|
|
+ with open(path, "rb") as fp:
|
|
|
|
+ return fp.read()
|
|
|
|
+
|
|
|
|
|
|
try:
|
|
try:
|
|
from ambari_jinja2 import Environment as JinjaEnvironment, BaseLoader, TemplateNotFound, FunctionLoader, StrictUndefined
|
|
from ambari_jinja2 import Environment as JinjaEnvironment, BaseLoader, TemplateNotFound, FunctionLoader, StrictUndefined
|