Unlock 30% off on Manual Testing Annual Plans this Holiday Season.

Copied to Clipboard!

How to use sendToNodeServlet method of com.paypal.selion.proxy.SeLionRemoteProxy class

Best SeLion code snippet using com.paypal.selion.proxy.SeLionRemoteProxy.sendToNodeServlet

Source:SeLionRemoteProxy.java

...210        }211        LOGGER.exiting(true);212        return true;213    }214    private HttpResponse sendToNodeServlet(Class<? extends HttpServlet> servlet, List<NameValuePair> nvps) {215        LOGGER.entering();216        RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(CONNECTION_TIMEOUT)217                .setSocketTimeout(CONNECTION_TIMEOUT).build();218        CloseableHttpClient client = HttpClientBuilder.create().setDefaultRequestConfig(requestConfig).build();219        String url = String.format("http://%s:%d/extra/%s", machine, this.getRemoteHost().getPort(),220                servlet.getSimpleName());221        HttpResponse postResponse = null;222        try {223            HttpPost post = new HttpPost(url);224            post.setEntity(new UrlEncodedFormEntity(nvps));225            postResponse = client.execute(post);226        } catch (IOException e) {227            LOGGER.log(Level.SEVERE, e.getMessage(), e);228        } finally {229            try {230                client.close();231            } catch (IOException e) {232                LOGGER.log(Level.SEVERE, e.getMessage(), e);233            }234        }235        LOGGER.exiting(postResponse);236        return postResponse;237    }238    /**239     * Upgrades the node by calling {@link NodeAutoUpgradeServlet} and then {@link #requestNodeShutdown}240     *241     * @param downloadJSON242     *            the download.json to install on node243     * @return <code>true</code> on success. <code>false</code> when an error occured.244     */245    public boolean upgradeNode(String downloadJSON) {246        LOGGER.entering(downloadJSON);247        // verify the servlet is supported on the node248        if (!supportsAutoUpgrade()) {249            LOGGER.exiting(false);250            return false;251        }252        // call the NodeAutoUpgradeServlet on the node253        proxyLogger.fine("Upgrading node " + getId());254        List<NameValuePair> nvps = new ArrayList<>();255        nvps.add(new BasicNameValuePair(NodeAutoUpgradeServlet.TOKEN_PARAMETER,256                NodeAutoUpgradeServlet.CONFIGURED_TOKEN_VALUE));257        NameValuePair jsonNVP = new BasicNameValuePair(GridAutoUpgradeDelegateServlet.PARAM_JSON, downloadJSON);258        nvps.add(jsonNVP);259        HttpResponse response = sendToNodeServlet(NodeAutoUpgradeServlet.class, nvps);260        if (response == null) {261            proxyLogger.warning("Node " + getId() + " failed to upgrade and returned a null response.");262            LOGGER.exiting(false);263            return false;264        }265        final int responseStatusCode = response.getStatusLine().getStatusCode();266        if (responseStatusCode != HttpStatus.SC_OK) {267            proxyLogger.warning("Node " + getId() + " failed to upgrade and returned HTTP " + responseStatusCode);268            LOGGER.exiting(false);269            return false;270        }271        requestNodeShutdown();272        LOGGER.exiting(true);273        return true;274    }275    /**276     * @return whether the proxy has reached the max unique sessions277     */278    private boolean isMaxUniqueSessionsReached() {279        if (!isEnabledMaxUniqueSessions()) {280            return false;281        }282        return totalSessionsStarted >= getMaxSessionsAllowed();283    }284    @Override285    public TestSession getNewSession(Map<String, Object> requestedCapability) {286        LOGGER.entering();287        // verification should be before lock to avoid unnecessarily acquiring lock288        if (isMaxUniqueSessionsReached() || scheduledShutdown) {289            LOGGER.exiting(null);290            return logSessionInfo();291        }292        try {293            accessLock.lock();294            // As per double-checked locking pattern need to have check once again295            // to avoid spawning additional session then maxSessionAllowed296            if (isMaxUniqueSessionsReached() || scheduledShutdown) {297                LOGGER.exiting(null);298                return logSessionInfo();299            }300            TestSession session = super.getNewSession(requestedCapability);301            if (session != null) {302                // count ONLY if the session was a valid one303                totalSessionsStarted++;304                if (isMaxUniqueSessionsReached()) {305                    startNodeRecycleThread();306                }307                proxyLogger.fine("Beginning session #" + totalSessionsStarted + " (" + session.toString() + ")");308            }309            LOGGER.exiting((session != null) ? session.toString() : null);310            return session;311        } finally {312            accessLock.unlock();313        }314    }315    private TestSession logSessionInfo() {316        proxyLogger.fine("Was max sessions reached? " + (isMaxUniqueSessionsReached()) + " on node " + getId());317        proxyLogger.fine("Was this a scheduled shutdown? " + (scheduledShutdown) + " on node " + getId());318        return null;319    }320    private void startNodeRecycleThread() {321        if (!getNodeRecycleThread().isAlive()) {322            getNodeRecycleThread().start();323        }324    }325    private void stopNodeRecycleThread() {326        if (getNodeRecycleThread().isAlive()) {327            try {328                getNodeRecycleThread().shutdown();329                getNodeRecycleThread().join(2000); // Wait no longer than 2x the recycle thread's loop330            } catch (InterruptedException e) { // NOSONAR331                // ignore332            }333        }334    }335    private void updateBrowserCache(RegistrationRequest request) throws MalformedURLException {336        // Update the browser information cache. Used by GridStatics servlet337        for (MutableCapabilities desiredCapabilities : request.getConfiguration().capabilities) {338            Map<String, ?> capabilitiesMap = desiredCapabilities.asMap();339            String browserName = capabilitiesMap.get(CapabilityType.BROWSER_NAME).toString();340            String maxInstancesAsString = capabilitiesMap.get("maxInstances").toString();341            if (StringUtils.isNotBlank(browserName) && StringUtils.isNotBlank(maxInstancesAsString)) {342                int maxInstances = Integer.valueOf(maxInstancesAsString);343                BrowserInformationCache cache = BrowserInformationCache.getInstance();344                cache.updateBrowserInfo(getRemoteHost(), browserName, maxInstances);345            }346        }347    }348    @Override349    public void afterSession(TestSession session) {350        LOGGER.entering();351        totalSessionsCompleted++;352        proxyLogger.fine("Completed session #" + totalSessionsCompleted + " (" + session.toString() + ")");353        proxyLogger.fine("Total number of slots used: " + getTotalUsed() + " on node: " + getId());354        LOGGER.exiting();355    }356    /**357     * Gracefully shuts the node down by;<br>358     * <br>359     * 1. Stops accepting new sessions<br>360     * 2. Waits for sessions to complete<br>361     * 3. Calls {@link #forceNodeShutdown}<br>362     */363    public void requestNodeShutdown() {364        LOGGER.entering();365        scheduledShutdown = true;366        startNodeRecycleThread();367        LOGGER.exiting();368    }369    /**370     * Forcefully shuts the node down by calling {@link NodeForceRestartServlet}371     */372    public synchronized void forceNodeShutdown() {373        LOGGER.entering();374        // stop the node recycle thread375        stopNodeRecycleThread();376        // verify the servlet is supported on the node377        if (!canForceShutdown) {378            // allow this proxy to keep going379            disableMaxSessions();380            scheduledShutdown = false;381            LOGGER.exiting();382            return;383        }384        // clean up the test slots385        for (TestSlot slot : getTestSlots()) {386            if (slot.getSession() != null) {387                totalSessionsCompleted++;388                proxyLogger.info("Timing out session #" + totalSessionsCompleted + " (" + slot.getSession().toString()389                        + ")");390                getRegistry().forceRelease(slot, SessionTerminationReason.TIMEOUT);391            }392        }393        // call the node servlet394        List<NameValuePair> nvps = new ArrayList<>();395        nvps.add(new BasicNameValuePair(NodeForceRestartServlet.TOKEN_PARAMETER,396                NodeForceRestartServlet.CONFIGURED_TOKEN_VALUE));397        HttpResponse response = sendToNodeServlet(NodeForceRestartServlet.class, nvps);398        if (response == null) {399            proxyLogger.warning("Node " + getId() + " failed to shutdown and returned a null response.");400            // stop the polling thread, mark this proxy as down, force this proxy to re-register401            teardown("it failed to shutdown and must re-register");402            LOGGER.exiting();403            return;404        }405        final int responseStatusCode = response.getStatusLine().getStatusCode();406        if (responseStatusCode != HttpStatus.SC_OK) {407            proxyLogger.warning("Node " + getId() + " did not shutdown and returned HTTP " + responseStatusCode);408            // stop the polling thread, mark this proxy as down, force this proxy to re-register409            teardown("it failed to shutdown and must re-register");410            LOGGER.exiting();411            return;...

sendToNodeServlet

Using AI Code Generation

1import com.paypal.selion.proxy.SeLionRemoteProxy;2import org.openqa.selenium.remote.RemoteWebDriver;3public class SendToNodeServlet {4    public static void main(String[] args) {5        RemoteWebDriver driver = new RemoteWebDriver();6        SeLionRemoteProxy.sendToNodeServlet(driver, "test", "test");7    }8}9import com.paypal.selion.proxy.SeLionRemoteProxy;10import org.openqa.selenium.remote.RemoteWebDriver;11public class SendToNodeServlet {12    public static void main(String[] args) {13        RemoteWebDriver driver = new RemoteWebDriver();14        SeLionRemoteProxy.sendToNodeServlet(driver, "test", "test");15    }16}17import com.paypal.selion.proxy.SeLionRemoteProxy;18import org.openqa.selenium.remote.RemoteWebDriver;19public class SendToNodeServlet {20    public static void main(String[] args) {21        RemoteWebDriver driver = new RemoteWebDriver();22        SeLionRemoteProxy.sendToNodeServlet(driver, "test", "test");23    }24}25import com.paypal.selion.proxy.SeLionRemoteProxy;26import org.openqa.selenium.remote.RemoteWebDriver;27public class SendToNodeServlet {28    public static void main(String[] args) {29        RemoteWebDriver driver = new RemoteWebDriver();30        SeLionRemoteProxy.sendToNodeServlet(driver, "test", "test");31    }32}33import com.paypal.selion.proxy.SeLionRemoteProxy;34import org.openqa.selenium.remote.RemoteWebDriver;35public class SendToNodeServlet {36    public static void main(String[] args) {37        RemoteWebDriver driver = new RemoteWebDriver();38        SeLionRemoteProxy.sendToNodeServlet(driver, "test", "test");39    }40}41import com.paypal.selion.proxy.SeLionRemoteProxy;42import org.openqa.selenium.remote.RemoteWebDriver;43public class SendToNodeServlet {44    public static void main(String[] args) {

sendToNodeServlet

Using AI Code Generation

1import com.paypal.selion.proxy.SeLionRemoteProxy;2import com.paypal.selion.proxy.SeLionRemoteProxy;3public class SendToNodeServlet {4    public static void main(String[] args) {5    }6}7import com.paypal.selion.proxy.SeLionRemoteProxy;8import com.paypal.selion.proxy.SeLionRemoteProxy;9public class SendToNodeServlet {10    public static void main(String[] args) {11    }12}13import com.paypal.selion.proxy.SeLionRemoteProxy;14import com.paypal.selion.proxy.SeLionRemoteProxy;15public class SendToNodeServlet {16    public static void main(String[] args) {17    }18}19import com.paypal.selion.proxy.SeLionRemoteProxy;20import com.paypal.selion.proxy.SeLionRemoteProxy;21public class SendToNodeServlet {22    public static void main(String[] args) {23    }24}25import com.paypal.selion.proxy.SeLionRemoteProxy;26import com.paypal.selion.proxy.SeLionRemoteProxy;27public class SendToNodeServlet {28    public static void main(String[] args) {29    }30}31import com.paypal.selion.proxy.SeLionRemoteProxy;32import com.paypal.selion.proxy.SeLionRemoteProxy;33public class SendToNodeServlet {34    public static void main(String[] args) {35    }36}37import com.paypal.selion.proxy.SeLionRemoteProxy;38import com.paypal.selion.proxy.SeLionRemoteProxy;

sendToNodeServlet

Using AI Code Generation

1import com.paypal.selion.proxy.SeLionRemoteProxy;2import com.paypal.selion.proxy.SeLionRemoteProxyPool;3import com.paypal.selion.proxy.SeLionRemoteProxyPool.PoolState;4import com.paypal.selion.proxy.SeLionRemoteProxyPool.PoolState.State;5import com.paypal.selion.proxy.SeLionRemoteProxyPool.PoolState.StateChange;6import com.paypal.selion.proxy.SeLionRemoteProxyPool.PoolState.StateChange.Change;7import com.paypal.selion.proxy.SeLionRemoteProxyPool.PoolState.StateChange.ChangeType;8import com.paypal.selion.proxy.SeLionRemoteProxyPool.PoolState.StateChange.ChangeType.Type;9import com.paypal.selion.proxy.SeLionRemoteProxyPool.PoolState.StateChange.ChangeType.TypeChange;10import com.paypal.selion.proxy.SeLionRemoteProxyPool.PoolState.StateChange.ChangeType.TypeChange.TypeChangeType;11import com.paypal.selion.proxy.SeLionRemoteProxyPool.PoolState.StateChange.ChangeType.TypeChange.TypeChangeType.TypeChangeTypeValue;12import com.paypal.selion.proxy.SeLionRemoteProxyPool.PoolState.StateChange.ChangeType.TypeChange.TypeChangeType.TypeChangeTypeValue.TypeChangeTypeValueValue;13import com.paypal.selion.proxy.SeLionRemoteProxyPool.PoolState.StateChange.ChangeType.TypeChange.TypeChangeType.TypeChangeTypeValue.TypeChangeTypeValueValue.TypeChangeTypeValueValueValue;14import com.paypal.selion.proxy.SeLionRemoteProxyPool.PoolState.StateChange.ChangeType.TypeChange.TypeChangeType.TypeChangeTypeValue.TypeChangeTypeValueValue.TypeChangeTypeValueValueValue.TypeChangeTypeValueValueValueValue;15import com.paypal.selion.proxy.SeLionRemoteProxyPool.PoolState.StateChange.ChangeType.TypeChange.TypeChangeType.TypeChangeTypeValue.TypeChangeTypeValueValue.TypeChangeTypeValueValueValue.TypeChangeTypeValueValueValueValue.TypeChangeTypeValueValueValueValueValue;16import com.paypal.selion.proxy.SeLionRemoteProxyPool.PoolState.StateChange.ChangeType.TypeChange.TypeChangeType.TypeChangeTypeValue.Type

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.