FWD » Documentation

** 007 GBB 20240709 Hard-coded config names replaced by ConfigItem constants.

** 008 GBB 20240729 Initialize CentralLogger after SecurityManager is created.

** 009 AP  20250303 Added timeout for spawner launching.

*/

/*

** This program is free software: you can redistribute it and/or modify

   /** CLASSPATH placeholder */

   public static final String PARAM_CP = "${remote.broker.classpath}";

   /** Broker P2J server address net:server:host */

   public static final String BROKER_HOST = "BROKER_HOST";

   /** Broker runtime class path */

   public static final String BROKER_CLASSPATH = "BROKER_CLASSPATH";

   /** Logger. */

   private static final CentralLogger LOG = CentralLogger.get(BrokerCore.class.getName());

      args.getEnvironment().put(BROKER_PORT, port);

      args.getEnvironment().put(BROKER_JVMARGS, jvmargs);

      args.getEnvironment().put(BROKER_CLASSPATH, classpath);

      pb.environment().putAll(args.getEnvironment());

            command.add("-classpath");

            command.add(classpath);

         }

         else

         {

            command.add(cmd);

         }

      }

      LOG.logp(Level.INFO,

               "BrokerCore.spawn()",

               "",

         LOG.logp(Level.SEVERE,

                  BrokerCore.class.getName(),

                  "initialize",

      }

      // get the associated user account name

      associatedUser = cfg.getString("remote", "agent", "user", "");

      // get the dedicated broker mode

      // JVM arguments

      String jargs = cfg.getString("remote", "java", "args", "");

** Module   : BrokerManager.java

** Abstract : server side broker manager implementation.

**

**

** -#- -I- --Date-- ---------------------------------Description----------------------------------

** 008 GBB 20240709 CLIENT_IP constant moved here from WebDriverHandler.

**                  WebClientConfig renamed to WebAllocatedResources.

**                  Hard-coded config names replaced by ConfigItem constants.

*/

/*

** This program is free software: you can redistribute it and/or modify

         {

            throw new RuntimeException("Only process accounts are allowed.");

         }

         // broker name if any

         params.setBrokerName(sm.getBrokerForProcess(params.getUserId()));

         if (params.getBrokerName() == null)

                                         Brokers brokers,

                                         BrokerSpawnParameters args)

   {

   }

   /**

    * 

    * @return  The result of remote spawn.

    */

                                         Brokers brokers,

                                         BrokerSpawnParameters args,

                                         WebClientAllocator allocator,

                                                                                uuid,

                                                                                dedicatedUser);

                  spawn = (clientConfig != null);

               }

               if (spawn)

               {

                                                                             uuid,

                                                                             dedicatedUser);

               spawn = (clientConfig != null);

            }

            if (spawn)

            {

                                               Map<String, List<String>> targetUserHosts)

   {

      List<String> userHosts = targetUserHosts.get(user);

      {

         targetUserHosts.remove(user);

      }

   /**

    * Update the command line parameters for the spawning process with the web client configuration.

    * 

    * @param    args

    *           The broker spawn parameters to update

    * @param    allocatedResources

    *           The allocated web resources

    */

                                              WebAllocatedResources allocatedResources)

   {

      if (allocatedResources != null)

         int port = allocatedResources.getPort();

         if (port > 0)

         {

            args.getCommand().add(ConfigItem.PORT.fullOption() + "=" + port);

         }

** 022 CA  20240910 'net:socket:nio' is enabled by default only for Java 8.

** 023 CA  20250221 Added constants for the spawner modes.

** 024 AL2 20250523 'net:socket:nio' is disabled by default.

*/

/*

   }

   /**

    * Remove the spawn command registered for this UUID.

    * 

    * @param    uuid

         args.setPassword(params.getOsPass());

      }

   }

   /**

** Module   : NativeSecureConnection.java

** Abstract : Helper for connecting to a remote P2J server from native code, via JNI.

**

**

** -#- -I- --Date-- ---------------------------------Description---------------------------------

** 001 CA  20140211 Created initial version.

**     IAS 20210325 Added NIO configuration via BootstrapConfig

** 004 GBB 20230512 Logging methods replaced by CentralLogger/ConversionStatus.

** 005 GBB 20240729 Initialize CentralLogger in try-catch.

*/

/*

** This program is free software: you can redistribute it and/or modify

 */

public class NativeSecureConnection

{

   /**

    * Establish a secure connection to the target P2J server and retrieve the spawn command

    * registered with this request, via the specified UUID.

   private static String[] remote(String[] args)

   {

      // Get environment variables

      // host

      // secure port

      // JVM arguments

      String jvmargs = env.get(BrokerCore.BROKER_JVMARGS);

      // classpath

      String classpath = env.get(BrokerCore.BROKER_CLASSPATH);

      // Command line arguments

      List<String> command = new LinkedList<String>();

         {

            if (host == null)

            {

            }

            // host

            command.add(cmd.replace(BrokerCore.PARAM_HOST, host));

         {

            if (port == null)

            {

            }

            // secure port

            command.add(cmd.replace(BrokerCore.PARAM_PORT, port));

         {

            if (jvmargs == null)

            {

            }

            // add JVM arguments

            String[] tokens = jvmargs.split("\\" + BrokerCore.BROKER_JVMARGS_SEPARATOR);

         {

            if (classpath == null)

            {

            }            

            // add CLASSAPTH

            command.add("-classpath");

            command.add(classpath);

         }

         else

         {

            command.add(cmd);

** 017 GBB 20240719 Null check for project token.

** 018 GBB 20240730 Get the project token from the web parameters instead of resolving each time.

** 019 CA  20250221 Added constants for the spawner modes.

*/

/*

** This program is free software: you can redistribute it and/or modify

         command.add(ConfigItem.SSO_STORAGE_ID.fullOption() + "=" + params.getStorageId());

      }

      UUID_OPTIONS.put(this.params.getUuid(), new PostInitOptions(dirOptions.getDriverType(),

                                                                  remote,

                                                                  dirOptions.getOverriddenOptions(),

** 018 AI  20250904 Renamed accessedAtLeastOnce to safeRemoveListener.

** 019 SBI 20250910 Removed configuration parameters: MAX_LOST_PINGS and PING_DELAY.

** 020 TJD 20250807 Added SNI_HOST_CHECK option to control Jetty's SNIHostCheck feature

*/

/*

** This program is free software: you can redistribute it and/or modify

         int port = config.getInt(ConfigItem.PORT, 0);

         String host = config.getString(ConfigItem.HOST, null);

         // dedicated mode section placed just before the driver created

         if (dedicatedMode)

**                  update readInClient to be able to read list of objects.

** 010 ES  20251008 Added UNITTEST_LEGACY_NAMES parameter.

** 011 TJD 20250807 Added SNI_HOST_CHECK option to control Jetty's SNIHostCheck feature

*/

/*

** This program is free software: you can redistribute it and/or modify

   public static final ConfigItem<String> SPAWNER_UUID =

      new ConfigItem<>(String.class, "", "server", "spawner", "uuid", Type.RUNTIME);

   /** Enables web client debug logging in js. */

   public static final ConfigItem<Boolean> JS_DEBUG_LOGGING = new ConfigItem<>(Boolean.class,

                                                                               "enableDebugLogging",