Package org.glite.ce.creamapi.jobmanagement

Examples of org.glite.ce.creamapi.jobmanagement.Job.addExtraAttribute()

308
309
310
311
312
313
314
315
316
317
318
        job.setSequenceCode(getAttributeValue(jobAd, "LB_sequence_code"));
        job.setTokenURL(getAttributeValue(jobAd, "ReallyRunningToken"));

        String mwVersion = getAttributeValue(jobAd, Jdl.MW_VERSION);
        if (mwVersion != null) {
            job.addExtraAttribute(Jdl.MW_VERSION, mwVersion);
        }

        String lbAddress = getAttributeValue(jobAd, Jdl.LB_ADDRESS);
        if (lbAddress != null) {
            job.addVolatileProperty(Job.LB_ADDRESS, lbAddress);
View Full Code Here
1722
1723
1724
1725
1726
1727
1728
1729
1730
1731
1732
            job.setLRMSJobId(Job.NOT_AVAILABLE_VALUE);
            job.setWorkerNode(Job.NOT_AVAILABLE_VALUE);
            job.setWorkingDirectory(Job.NOT_AVAILABLE_VALUE);

            if (cmd.containsParameterKey("USER_DN")) {
                job.addExtraAttribute("USER_DN", cmd.getParameterAsString("USER_DN").replaceAll("\\s+", "\\\\ "));
            }

            if (cmd.containsParameterKey("USER_DN_X500")) {
                job.addExtraAttribute("USER_DN_X500", cmd.getParameterAsString("USER_DN_X500").replaceAll("\\s+", "\\\\ "));
            }
View Full Code Here
1726
1727
1728
1729
1730
1731
1732
1733
1734
1735
1736
            if (cmd.containsParameterKey("USER_DN")) {
                job.addExtraAttribute("USER_DN", cmd.getParameterAsString("USER_DN").replaceAll("\\s+", "\\\\ "));
            }

            if (cmd.containsParameterKey("USER_DN_X500")) {
                job.addExtraAttribute("USER_DN_X500", cmd.getParameterAsString("USER_DN_X500").replaceAll("\\s+", "\\\\ "));
            }

            if (cmd.containsParameterKey("LOCAL_USER_GROUP")) {
                job.addExtraAttribute("LOCAL_USER_GROUP", cmd.getParameterAsString("LOCAL_USER_GROUP"));
            }
View Full Code Here
1730
1731
1732
1733
1734
1735
1736
1737
1738
1739
1740
            if (cmd.containsParameterKey("USER_DN_X500")) {
                job.addExtraAttribute("USER_DN_X500", cmd.getParameterAsString("USER_DN_X500").replaceAll("\\s+", "\\\\ "));
            }

            if (cmd.containsParameterKey("LOCAL_USER_GROUP")) {
                job.addExtraAttribute("LOCAL_USER_GROUP", cmd.getParameterAsString("LOCAL_USER_GROUP"));
            }

            if (cmd.containsParameterKey("USER_FQAN")) {
                List<String> fqanList = cmd.getParameterMultivalue("USER_FQAN");
               
View Full Code Here
1746
1747
1748
1749
1750
1751
1752
1753
1754
1755
1756
                    }

                    fqanBuffer.deleteCharAt(fqanBuffer.length() - 1);
                    fqanBuffer.deleteCharAt(fqanBuffer.length() - 1);
                   
                    job.addExtraAttribute("USER_FQAN", fqanBuffer.toString());
                }
            }
            
            if (this.containsParameterKey("LRMS_EVENT_LISTENER_PORT")) {
                job.setLoggerDestURI(InetAddress.getLocalHost().getHostAddress() + ":" + getParameterValueAsString("LRMS_EVENT_LISTENER_PORT"));
View Full Code Here
402
403
404
405
406
407
408
409
410
411
412
        expression = jobAd.lookup(Jdl.WHOLE_NODES);
        if (expression != null && expression.type == Expr.BOOLEAN && expression.isTrue()) {
            wholeNodes = true;
        }

        job.addExtraAttribute(Jdl.WHOLE_NODES, Boolean.toString(wholeNodes));

        expression = jobAd.lookup(Jdl.SMP_GRANULARITY);
        if (expression != null) {
            if (expression.type != Expr.INTEGER || expression.intValue() <= 0) {
                 throw new Exception("wrong value for " + Jdl.SMP_GRANULARITY + ": it must be >=1");
View Full Code Here
410
411
412
413
414
415
416
417
418
419
420
        if (expression != null) {
            if (expression.type != Expr.INTEGER || expression.intValue() <= 0) {
                 throw new Exception("wrong value for " + Jdl.SMP_GRANULARITY + ": it must be >=1");
            }

            job.addExtraAttribute(Jdl.SMP_GRANULARITY, "" + expression.intValue());
        }

        expression = jobAd.lookup(Jdl.HOST_NUMBER);
        if (expression != null) {
            if (expression.type != Expr.INTEGER || expression.intValue() <= 0) {
View Full Code Here
419
420
421
422
423
424
425
426
427
428
429
        if (expression != null) {
            if (expression.type != Expr.INTEGER || expression.intValue() <= 0) {
                 throw new Exception("wrong value for " + Jdl.HOST_NUMBER + ": it must be >=1");
            }

            job.addExtraAttribute(Jdl.HOST_NUMBER, "" + expression.intValue());
        }

        if (!wholeNodes && job.containsExtraAttribute(Jdl.SMP_GRANULARITY) && job.containsExtraAttribute(Jdl.HOST_NUMBER)) {
            throw new Exception("the SMPGranularity and HostNumber attributes cannot be specified together when WholeNodes=false");
        }
View Full Code Here
136
137
138
139
140
141
142
143
144
145
146
                throw new Exception(JDL.OUTPUTSANDBOX_DESTURI + " & " + JDL.OUTPUTSANDBOX_BASEDESTURI + ": one (and only one) among the OutputSandboxDestURI and OutputSandboxBaseDestURI attributes is allowed");
            }
        }

        boolean isWholeNodes = jdl.isWholeNodes();
        job.addExtraAttribute(JDL.WHOLENODES, "" + isWholeNodes);

        int smpGranularity = jdl.getSMPGranularity();
        if (smpGranularity > 0) {
            job.addExtraAttribute(JDL.SMPGRANULARITY, "" + smpGranularity);
        }
View Full Code Here
140
141
142
143
144
145
146
147
148
149
150
        boolean isWholeNodes = jdl.isWholeNodes();
        job.addExtraAttribute(JDL.WHOLENODES, "" + isWholeNodes);

        int smpGranularity = jdl.getSMPGranularity();
        if (smpGranularity > 0) {
            job.addExtraAttribute(JDL.SMPGRANULARITY, "" + smpGranularity);
        }

        int hostNumber = jdl.getHostNumber();
        if (hostNumber > 0) {
            job.addExtraAttribute(JDL.HOSTNUMBER, "" + hostNumber);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.