false true false SERVERS ${__P(cb.servers,127.0.0.1)} = THREADS ${__P(cb.threads,1)} = DURATION ${__P(cb.duration,600)} = RAMPUP ${__P(cb.rampup,50)} = RESULTS_FILE ${__P(cb.resultsFile,Baseline)} = RESULTS_PATH ${__P(cb.resultpath,results)} = JVMS ${__P(cb.jvms,4)} = BUCKET ${__P(cb.bucket,TEST_BUCKET)} = PASSWORD ${__P(cb.password,Password@123)} = KEYPREFIX ${__P(cb.keyprefix,jmeter)} = EXPIRY ${__P(cb.expiry,300)} = TIMEOUT ${__P(cb.timeout,5000)} = CONNECTTIMEOUT ${__P(cb.connecttimeout,5000)} = KVTIMEOUT ${__P(cb.kvtimeout,2500)} = KVENDPOINTS ${__P(cb.kvendpoints,4)} = IOPOOLSIZE ${__P(cb.iopoolsize,4)} = REQBUFFSIZE ${__P(cb.reqbuffsize,2097152)} = RESBUFFSIZE ${__P(cb.resbuffsize,2097152)} = CBDEBUG ${__P(cb.debug,true)} = lib RESULTSFILE ${RESULTS_PATH}/${RESULTS_FILE}_${HOSTNAME}_Threads${THREADS}_Duration${DURATION}_JVMS${JVMS}_${__time(yyyyMMddHHmm)}.jtl = ERRORS ${RESULTS_PATH}/${RESULTS_FILE}_${HOSTNAME}_Threads${THREADS}_Duration${DURATION}_JVMS${JVMS}_${__time(yyyyMMddHHmm)}_errors.xml = myValue ${__RandomString(2500,"abcdefghijklmnopqrstuvwxyz1234567890")} = continue false 1 1 1 false false groovy true import com.couchbase.client.java.Bucket; import com.couchbase.client.java.Cluster; import com.couchbase.client.java.CouchbaseCluster; import com.couchbase.client.java.env.CouchbaseEnvironment; import com.couchbase.client.java.env.DefaultCouchbaseEnvironment; int kvendpoints = Integer.parseInt(vars.get("KVENDPOINTS")); int iopoolsize = Integer.parseInt(vars.get("IOPOOLSIZE")); int reqbuffsize = Integer.parseInt(vars.get("REQBUFFSIZE")); int resbuffsize = Integer.parseInt(vars.get("RESBUFFSIZE")); int connecttimeout = Integer.parseInt(vars.get("CONNECTTIMEOUT")); int kvtimeout = Integer.parseInt(vars.get("KVTIMEOUT")); String bucketName = vars.get("BUCKET"); String pass = vars.get("PASSWORD"); List<String> nodes= new ArrayList<String>(); String servers = vars.get("SERVERS"); String[] arrServers=servers.split(","); for(String server: arrServers) { nodes.add(server); } CouchbaseEnvironment env = DefaultCouchbaseEnvironment.builder().kvEndpoints(kvendpoints).connectTimeout(connecttimeout).kvTimeout(kvtimeout).ioPoolSize(iopoolsize).requestBufferSize(reqbuffsize).responseBufferSize(resbuffsize).build(); //log.info("Environemnt Details:::" + env) Cluster cluster = CouchbaseCluster.create(env, nodes); Thread.sleep(5000) if(cluster != null){ bucket = cluster.openBucket(bucketName, pass); } log.info("Bucket object Details:::" + bucket) props.put("objBucket", bucket) //vars.putObject("objBucket", bucket) true prev.setIgnore() groovy continue false -1 ${THREADS} ${RAMPUP} true ${DURATION} false groovy true import java.util.concurrent.TimeUnit; import com.couchbase.client.java.Bucket; import com.couchbase.client.java.document.StringDocument; //Creating java object and then type casting to Couchbase Bucket Object obj = props.get("objBucket"); Bucket bucket = (Bucket) obj; vars.putObject("bucketObj", bucket) StringDocument cbDocument = null Random rnd = new Random() String randNumKey= rnd.nextInt(999999999).toString() vars.put("myKey", randNumKey) String key = vars.get("KEYPREFIX")+"_"+randNumKey String value = vars.get("myValue") String method = vars.get("METHOD") long expiry = Long.parseLong(vars.get("EXPIRY")) long timeout = Long.parseLong(vars.get("TIMEOUT")) boolean useTimeout = timeout > 0; // Resetting the stop watch to to set current time as startTime. SampleResult.setStartTime(System.currentTimeMillis()); try{ long startTime = System.nanoTime(); cbDocument = StringDocument.create(key); if(useTimeout){ cbDocument = bucket.get(cbDocument,timeout, TimeUnit.MILLISECONDS) }else { cbDocument = bucket.get(cbDocument) } long endTime = System.nanoTime(); if(cbDocument == null) { SampleResult.setResponseCode("204") SampleResult.setSuccessful(true) SampleResult.setResponseMessage("Success") }else { String responseData = "elapseTime: "+ (endTime-startTime)+1 +"\n"+"key: "+key+"\n"+"value: "+cbDocument.content(); SampleResult.setResponseData(responseData.getBytes()); SampleResult.setResponseCodeOK(); SampleResult.setBytes(responseData.length()); } }catch (Exception e) { SampleResult.setResponseCode("500"); SampleResult.setSuccessful(false); SampleResult.setResponseMessage("Success"); SampleResult.setResponseMessage("Exception: " +e) } code getStatus (.*) $1$ 1 ${__jexl3("${getStatus}" == "204",)} false true groovy true import java.util.concurrent.TimeUnit; import com.couchbase.client.java.Bucket; import com.couchbase.client.java.document.StringDocument; Bucket bucket = vars.getObject("bucketObj") StringDocument cbDocument = null Random rnd = new Random() String key = vars.get("KEYPREFIX")+"_"+vars.get("myKey") String value = vars.get("myValue") String method = vars.get("METHOD") int expiry = Integer.parseInt(vars.get("EXPIRY")) long timeout = Long.parseLong(vars.get("TIMEOUT")) boolean useTimeout = timeout > 0; // Resetting the stop watch to to set current time as startTime. SampleResult.setStartTime(System.currentTimeMillis()); try{ long startTime = System.nanoTime(); cbDocument = StringDocument.create(key, expiry, value); if(useTimeout){ cbDocument = bucket.upsert(cbDocument, timeout, TimeUnit.MILLISECONDS); }else { cbDocument = bucket.upsert(cbDocument); } long endTime = System.nanoTime(); if(cbDocument == null) { SampleResult.setResponseCode("204") SampleResult.setSuccessful(true) SampleResult.setResponseMessage("Success") }else { String responseData = "elapseTime: "+ (endTime-startTime)+1 +"\n"+"key: "+key+"\n"+"value: "+cbDocument.content(); SampleResult.setResponseData(responseData.getBytes()); SampleResult.setResponseCodeOK(); SampleResult.setBytes(responseData.length()); } }catch (Exception e) { SampleResult.setResponseCode("500"); SampleResult.setSuccessful(false); SampleResult.setResponseMessage("Success"); SampleResult.setResponseMessage("Exception: " +e) } groovy true import java.util.concurrent.TimeUnit; import com.couchbase.client.java.Bucket; import com.couchbase.client.java.document.StringDocument; Bucket bucket = vars.getObject("bucketObj") StringDocument cbDocument = null Random rnd = new Random() String key = vars.get("KEYPREFIX")+"_"+vars.get("myKey") String value = vars.get("myValue") String method = vars.get("METHOD") long expiry = Long.parseLong(vars.get("EXPIRY")) long timeout = Long.parseLong(vars.get("TIMEOUT")) boolean useTimeout = timeout > 0; // Resetting the stop watch to to set current time as startTime. SampleResult.setStartTime(System.currentTimeMillis()) try{ long startTime = System.nanoTime(); cbDocument = StringDocument.create(key); if(useTimeout){ cbDocument = bucket.get(cbDocument,timeout, TimeUnit.MILLISECONDS) }else { cbDocument = bucket.get(cbDocument) } long endTime = System.nanoTime(); if(cbDocument == null) { SampleResult.setResponseCode("204") SampleResult.setSuccessful(true) SampleResult.setResponseMessage("Success") }else { String responseData = "elapseTime: "+ (endTime-startTime)+1 +"\n"+"key: "+key+"\n"+"value: "+cbDocument.content(); SampleResult.setResponseData(responseData.getBytes()); SampleResult.setResponseCodeOK(); SampleResult.setBytes(responseData.length()); } }catch (Exception e) { SampleResult.setResponseCode("500"); SampleResult.setSuccessful(false); SampleResult.setResponseMessage("Success"); SampleResult.setResponseMessage("Exception: " +e) } code getStatus (.*) $1$ 1 false true false continue false 1 1 1 false false groovy true import com.couchbase.client.java.Bucket; //Creating java object and then type casting to Couchbase Bucket Object obj = props.get("objBucket"); Bucket bucket = (Bucket) obj; if(bucket != null){ try { bucket.close(); log.info("Connection terminated successfully") }catch (Exception e){ log.info("Exeption while terminating the connection"+e) } } true prev.setIgnore() groovy false saveConfig true true true true true true true true true true false true false false false true false false false false 0 true true true true true true true false saveConfig true true true true true true true true true true false true false false false true false false false false 0 true true true true true true true true saveConfig true true true true true true true true true true true true true true true false true true false true 0 true true true true true true true true true ${ERRORS}