- public AAFLocator(SecurityInfoC<HttpURLConnection> si, URI locatorURI) throws LocatorException {
- super(si.access, nameFromLocatorURI(locatorURI), 10000L /* Wait at least 10 seconds between refreshes */);
- synchronized(sr) {
- if(env==null) {
- env = new RosettaEnv(access.getProperties());
- }
- }
-
- int connectTimeout = Integer.parseInt(si.access.getProperty(Config.AAF_CONN_TIMEOUT, Config.AAF_CONN_TIMEOUT_DEF));
- try {
- String[] path = Split.split('/',locatorURI.getPath());
- String host = locatorURI.getHost();
- if(host==null) {
- host = locatorURI.getAuthority(); // this happens when no port
- }
- if("AAF_LOCATE_URL".equals(host)) {
- URI uri = new URI(
- locatorURI.getScheme(),
- locatorURI.getUserInfo(),
- aaf_locator_uri.getHost(),
- aaf_locator_uri.getPort(),
- "/locate"+locatorURI.getPath(),
- null,
- null
- );
- client = createClient(si.defSS, uri, connectTimeout);
- } else if(path.length>1 && "locate".equals(path[1])) {
- StringBuilder sb = new StringBuilder();
- for(int i=3;i<path.length;++i) {
- sb.append('/');
- sb.append(path[i]);
- }
- setPathInfo(sb.toString());
- URI uri = new URI(
- locatorURI.getScheme(),
- locatorURI.getUserInfo(),
- locatorURI.getHost(),
- locatorURI.getPort(),
- "/locate/"+name + '/' + version,
- null,
- null
- );
- client = createClient(si.defSS, uri, connectTimeout);
- } else {
- client = new HClient(si.defSS, locatorURI, connectTimeout);
- }
- epsDF = env.newDataFactory(Endpoints.class);
- } catch (APIException | URISyntaxException e) {
- throw new LocatorException(e);
- }
- }
+ public AAFLocator(SecurityInfoC<HttpURLConnection> si, URI locatorURI) throws LocatorException {
+ super(si.access, nameFromLocatorURI(locatorURI), 10000L /* Wait at least 10 seconds between refreshes */);
+ synchronized(sr) {
+ if (env==null) {
+ env = new RosettaEnv(access.getProperties());
+ }
+ }
+
+ int connectTimeout = Integer.parseInt(si.access.getProperty(Config.AAF_CONN_TIMEOUT, Config.AAF_CONN_TIMEOUT_DEF));
+ try {
+ String[] path = Split.split('/',locatorURI.getPath());
+ FixURIinfo fui = new FixURIinfo(locatorURI);
+ if ("AAF_LOCATE_URL".equals(fui.getHost())) {
+ client = createClient(si.defSS, locatorURI, connectTimeout);
+ } else if (path.length>1 && "locate".equals(path[1])) {
+ StringBuilder sb = new StringBuilder();
+ for (int i=3;i<path.length;++i) {
+ sb.append('/');
+ sb.append(path[i]);
+ }
+ setPathInfo(sb.toString());
+// URI uri = new URI(
+// locatorURI.getScheme(),
+// locatorURI.getAuthority(),
+// locatorURI.getPath(),
+// null,
+// null
+// );
+ client = createClient(si.defSS, locatorURI, connectTimeout);
+ } else {
+ client = new HClient(si.defSS, locatorURI, connectTimeout);
+ }
+ epsDF = env.newDataFactory(Endpoints.class);
+
+ } catch (APIException /*| URISyntaxException*/ e) {
+ throw new LocatorException(e);
+ }
+
+ if(si.access.willLog(Access.Level.DEBUG)) {
+ si.access.log(Access.Level.DEBUG, "Root URI:",client.getURI());
+ }
+ }