4 com/hazelcast/console/ConsoleAppLjava/lang/Object;Lcom/hazelcast/core/EntryListener;Lcom/hazelcast/core/ItemListener;Lcom/hazelcast/core/MessageListener;java/lang/Object com/hazelcast/core/EntryListenercom/hazelcast/core/ItemListener"com/hazelcast/core/MessageListener ConsoleApp.java"com/hazelcast/console/ConsoleApp$1 java/util/Map$Entry java/util/MapEntryEXECUTOR_NAMESPACELjava/lang/String;Sample ExecutorLOAD_EXECUTORS_COUNTI ONE_HUNDREDdqueueLcom/hazelcast/core/IQueue;/Lcom/hazelcast/core/IQueue;topicLcom/hazelcast/core/ITopic;/Lcom/hazelcast/core/ITopic;mapLcom/hazelcast/core/IMap;?Lcom/hazelcast/core/IMap;multiMapLcom/hazelcast/core/MultiMap;CLcom/hazelcast/core/MultiMap;setLcom/hazelcast/core/ISet;-Lcom/hazelcast/core/ISet;listLcom/hazelcast/core/IList;.Lcom/hazelcast/core/IList; atomicNumber Lcom/hazelcast/core/IAtomicLong; namespacesilentZecho hazelcast&Lcom/hazelcast/core/HazelcastInstance; lineReader"Lcom/hazelcast/console/LineReader;running)(Lcom/hazelcast/core/HazelcastInstance;)V()V :< =default? 1 A 56 Cthis"Lcom/hazelcast/console/ConsoleApp;getQueue()Lcom/hazelcast/core/IQueue;1()Lcom/hazelcast/core/IQueue;$com/hazelcast/core/HazelcastInstanceJ/(Ljava/lang/String;)Lcom/hazelcast/core/IQueue; GL KM  OgetTopic()Lcom/hazelcast/core/ITopic;1()Lcom/hazelcast/core/ITopic;/(Ljava/lang/String;)Lcom/hazelcast/core/ITopic; QT KU ! WgetMap()Lcom/hazelcast/core/IMap;A()Lcom/hazelcast/core/IMap;-(Ljava/lang/String;)Lcom/hazelcast/core/IMap; Y\ K] #$ _ getMultiMap()Lcom/hazelcast/core/MultiMap;E()Lcom/hazelcast/core/MultiMap;1(Ljava/lang/String;)Lcom/hazelcast/core/MultiMap; ad Ke &' ggetAtomicNumber"()Lcom/hazelcast/core/IAtomicLong; getAtomicLong4(Ljava/lang/String;)Lcom/hazelcast/core/IAtomicLong; kl Km /0 ogetSet()Lcom/hazelcast/core/ISet;/()Lcom/hazelcast/core/ISet;-(Ljava/lang/String;)Lcom/hazelcast/core/ISet; qt Ku )* wgetList()Lcom/hazelcast/core/IList;0()Lcom/hazelcast/core/IList;.(Ljava/lang/String;)Lcom/hazelcast/core/IList; y| K} ,-  setHazelcaststop 93 startjava/lang/Exceptionjava/lang/Throwable YZ com/hazelcast/core/IMapsize()I yz com/hazelcast/core/IList qr com/hazelcast/core/ISet GH com/hazelcast/core/IQueue QR com/hazelcast/core/ITopicgetLocalTopicStats)()Lcom/hazelcast/monitor/LocalTopicStats; ab com/hazelcast/core/MultiMap getExecutorService9(Ljava/lang/String;)Lcom/hazelcast/core/IExecutorService; K#com/hazelcast/core/IExecutorServicegetLocalExecutorStats,()Lcom/hazelcast/monitor/LocalExecutorStats; java/lang/StringBuilder =Sample Executor append-(Ljava/lang/String;)Ljava/lang/StringBuilder; (I)Ljava/lang/StringBuilder; toString()Ljava/lang/String; 78 'com/hazelcast/console/DefaultLineReader = hazelcast[] > print(Ljava/lang/Object;)V  com/hazelcast/console/LineReaderreadLine  handleCommand(Ljava/lang/String;)V printStackTrace < icommandeLjava/lang/Throwable;java/lang/Stringcom/hazelcast/util/StringUtiltrim&(Ljava/lang/String;)Ljava/lang/String; length __contains(Ljava/lang/CharSequence;)Z split'(Ljava/lang/String;)[Ljava/lang/String; indexOf(Ljava/lang/String;)I  substring(I)Ljava/lang/String;  43  handleEcho  // startsWith(Ljava/lang/String;)Z    (I)I   [Ljava/lang/String;help handleHelp  #java/lang/IntegerparseInt  com/hazelcast/util/Clock currentTimeMillis()J "# !$\$i&( replaceAll8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; *+ , ops/s = %.2f.@@java/lang/Double2valueOf(D)Ljava/lang/Double; 45 36format9(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String; 89 :println < =.Bingo, all the operations finished in no time!?&Ajava/util/concurrent/ExecutorsCnewFixedThreadPool)(I)Ljava/util/concurrent/ExecutorService; EF DG$java/util/concurrent/ExecutorServiceI8(Lcom/hazelcast/console/ConsoleApp;Ljava/lang/String;I)V :K Lsubmit3(Ljava/lang/Runnable;)Ljava/util/concurrent/Future; NO JPshutdown R< JSjava/util/concurrent/TimeUnitUHOURSLjava/util/concurrent/TimeUnit; WX VYawaitTermination#(JLjava/util/concurrent/TimeUnit;)Z [\ J] @`handleAt b c handleColon e f2equals(Ljava/lang/Object;)Z ij kjava/lang/Booleanm parseBoolean o np 23 rRequalsIgnoreCase'(Ljava/lang/String;Ljava/lang/String;)Z uv whandleShutdown y< z4echo: }(Z)Ljava/lang/StringBuilder;  nshandleNamespace  whoami handleWhoami < who handleWho < jvm handleJvm < ock. handleLock([Ljava/lang/String;)V  .size handleSize  .clear handleClear  .destroy handleDestroy   .iteratorhandleIterator   .containshandleContains  .stats handStats   t.publishhandleTopicPublish  q.offer handleQOffer  q.take handleQTake  q.poll handleQPoll  q.peek handleQPeek   q.capacityhandleQCapacity   q.offermanyhandleQOfferMany   q.pollmanyhandleQPollMany  s.add handleSetAdd  s.removehandleSetRemove   s.addmanyhandleSetAddMany   s.removemanyhandleSetRemoveMany   m.replacehandleMapReplace   m.putIfAbsenthandleMapPutIfAbsent   m.putAsynchandleMapPutAsync   m.getAsynchandleMapGetAsync    m.put  handleMapPut  m.get handleMapGet   m.getMapEntryhandleMapGetMapEntry  m.removehandleMapRemove  m.delete handleMapDelete " #m.evict%handleMapEvict ' ( m.putmany*m.putAll,handleMapPutMany . / m.getmany1handleMapGetMany 3 4 m.removemany6handleMapRemoveMany 8 9 m.localKeys;handleMapLocalKeys =< > m.localSize@handleMapLocalSize B< Cm.keysE handleMapKeys G< Hm.valuesJhandleMapValues L< M m.entriesOhandleMapEntries Q< Rm.lockT handleMapLock V W m.tryLockYhandleMapTryLock [ \m.unlock^handleMapUnlock ` a .addListenerchandleAddListener e fm.removeMapListenerhhandleRemoveListener j kmm.putmhandleMultiMapPut o pmm.getrhandleMultiMapGet t u mm.removewhandleMultiMapRemove y zmm.keys|handleMultiMapKeys ~<  mm.valueshandleMultiMapValues <  mm.entrieshandleMultiMapEntries < mm.lockhandleMultiMapLock   mm.tryLockhandleMultiMapTryLock   mm.unlockhandleMultiMapUnlock  l.add handleListAdd  l.set handleListSet   l.addmanyhandleListAddMany  l.removehandleListRemove   l.containshandleListContains  a.gethandleAtomicNumberGet  a.sethandleAtomicNumberSet  a.inchandleAtomicNumberInc  a.dechandleAtomicNumberDec  execute   partitionshandlePartitions   executeOnKey  executeOnMember  executeOnMembers   instanceshandleInstances  quitexit handleExit <  .simulateLoadendsWith  handleExecutorSimulate  type 'help' for helprepeatstartedJelapsedMilliSecondsthreadIDLjava/lang/Exception;fork threadCommandpool&Ljava/util/concurrent/ExecutorService; inputCommandfirst spaceIndex argsSplitargsgetLifecycleService'()Lcom/hazelcast/core/LifecycleService;  K#com/hazelcast/core/LifecycleService Sjava/lang/System (I)V    java/lang/InterruptedException'java/util/concurrent/ExecutionException(II)Ljava/lang/String;  java/lang/RuntimeException5threadCount can't be smaller than 1 or larger than 16 :   $java/util/LinkedList = getCluster()Lcom/hazelcast/core/Cluster;  K!com/hazelcast/core/Cluster# getMembers()Ljava/util/Set; %& $'(Ljava/util/Collection;)V :) * java/util/Set, -java/util/List/ 0get(I)Ljava/lang/Object; 23 04com/hazelcast/core/Member6latch8getCountDownLatch8(Ljava/lang/String;)Lcom/hazelcast/core/ICountDownLatch; :; K<"com/hazelcast/core/ICountDownLatch> trySetCount(I)Z @A ?B&com/hazelcast/console/SimulateLoadTaskD(IILjava/lang/String;)V :F EGsubmitToMemberY(Ljava/util/concurrent/Callable;Lcom/hazelcast/core/Member;)Ljava/util/concurrent/Future; IJ Kadd Mj 0Niterator()Ljava/util/Iterator; PQ 0Rjava/util/IteratorThasNext()Z VW UXnext()Ljava/lang/Object; Z[ U\java/util/concurrent/Future^ 2[ _`java/lang/Threadb currentThread()Ljava/lang/Thread; de cf interrupt h< ci  Executed %s tasks in %s msm(I)Ljava/lang/Integer; 4o pjava/lang/Longr(J)Ljava/lang/Long; 4t sumemberLcom/hazelcast/core/Member;fLjava/util/concurrent/Future; Ljava/lang/InterruptedException;)Ljava/util/concurrent/ExecutionException; threadCount taskCount durationSecstartMsexecutor%Lcom/hazelcast/core/IExecutorService;futures/Ljava/util/List;Ljava/util/List;members-Ljava/util/List;totalThreadCountlatchId durationMsjava/util/StringTokenizer;'(Ljava/lang/String;Ljava/lang/String;)V :  hasMoreTokens W  nextToken  stLjava/util/StringTokenizer;java/io/IOExceptionusage: @ java/io/File Executing script file getAbsolutePath  exists W java/io/BufferedReaderjava/io/InputStreamReaderjava/io/FileInputStream(Ljava/io/File;)V : UTF-8*(Ljava/io/InputStream;Ljava/lang/String;)V : (Ljava/io/Reader;)V :  com/hazelcast/nio/IOUtil closeResource(Ljava/io/Closeable;)V   File not found! lLjava/io/IOException;brLjava/io/BufferedReader;Ljava/io/File;getName  clowerCaseInternal  main []  threadNameisEmpty W  namespace: 4Ledu/umd/cs/findbugs/annotations/SuppressFBWarnings;valueDM_GCgc <  java/lang/Runtime getRuntime()Ljava/lang/Runtime;   maxMemory #  totalMemory #  freeMemory #  Memory max: com/hazelcast/memory/MemoryUnitBYTES!Lcom/hazelcast/memory/MemoryUnit;   toMegaBytes(J)J  (J)Ljava/lang/StringBuilder;  MB Memory free: MB d% Used Memory:  # procs:  6com/hazelcast/internal/util/RuntimeAvailableProcessors 2  OS info: &java/lang/management/ManagementFactorygetOperatingSystemMXBean.()Ljava/lang/management/OperatingSystemMXBean;  *java/lang/management/OperatingSystemMXBeangetArch    getVersion   JVM: "getRuntimeMXBean&()Ljava/lang/management/RuntimeMXBean; $% &"java/lang/management/RuntimeMXBean( getVmVendor * )+ getVmName - ). getVmVersion 0 )1maxtotalfreegetLocalMember()Lcom/hazelcast/core/Member; 67 $8 Members [: java/util/Collection= >] {@ >R C-(Ljava/lang/Object;)Ljava/lang/StringBuilder; E F } HsbLjava/lang/StringBuilder;3Ljava/util/Collection;Ljava/util/Collection; ij Ncom/hazelcast/core/IAtomicLongP 2# QR parseLong(Ljava/lang/String;)J TU sV(J)V )X QYvincrementAndGet \# Q]decrementAndGet _# Q`getPartitionService'()Lcom/hazelcast/core/PartitionService; bc Kd#com/hazelcast/core/PartitionServicef getPartitions h& gijava/util/HashMapk l= -Rcom/hazelcast/core/PartitionogetOwner q7 pr&(Ljava/lang/Object;)Ljava/lang/Object; 2t uintValue w xput8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; z{ |entrySet ~& getKey [ : getValue [ countLjava/lang/Integer;newCountowner partitionLcom/hazelcast/core/Partition;entryELjava/util/Map$Entry;Ljava/util/Map$Entry;/Ljava/util/Set;Ljava/util/Set;partitionCounts?Ljava/util/Map;Ljava/util/Map;entriesVLjava/util/Set;>;getDistributedObjects()Ljava/util/Collection;  K$com/hazelcast/core/DistributedObjectdistributedObject&Lcom/hazelcast/core/DistributedObject;distributedObjects>Ljava/util/Collection; j (Z)Ljava/lang/Boolean; 4 njava/lang/NumberFormatException(Ljava/lang/Throwable;)V : remove 3  j index!Ljava/lang/NumberFormatException;(ILjava/lang/Object;)V M true N'(ILjava/lang/Object;)Ljava/lang/Object; ) objAdded  objects.size = ,  MILLISECONDS X V toSeconds  V evt/ssuccess successCount elapsedMillis@m.put requires a key and a value. You have not specified either.Bm.put requires a key and a value. You have only specified the key Ym.put takes two arguments, a key and a value. You have specified more than two arguments. |putAsyncM(Ljava/lang/Object;Ljava/lang/Object;)Lcom/hazelcast/core/ICompletableFuture;  %com/hazelcast/core/ICompletableFuture ` putIfAbsent { replace {  ugetAsync;(Ljava/lang/Object;)Lcom/hazelcast/core/ICompletableFuture;   getEntryView2(Ljava/lang/Object;)Lcom/hazelcast/core/EntryView;   t delete  evict j [Bcom/hazelcast/util/MapUtil createHashMap(I)Ljava/util/Map;  keyputAll(Ljava/util/Map;)V   toKiloBytes   evt/s,  KBit/s,   KB addedaddedKiloBytesbtheMap%Ljava/util/Map;lock  tryLock j SECONDS X V5(Ljava/lang/Object;JLjava/util/concurrent/TimeUnit;)Z  lockedtimeunlock " # localKeySet %& &Total (itLjava/util/Iterator; Local Size = ,keySet .& / values 2 3'(Ljava/lang/Object;Ljava/lang/Object;)Z z5 6*(Ljava/lang/Object;)Ljava/util/Collection; 28 9 8 ; /  3    #m.DgetLocalMapStats'()Lcom/hazelcast/monitor/LocalMapStats; FG Hmm.JgetLocalMultiMapStats,()Lcom/hazelcast/monitor/LocalMultiMapStats; LM Nq.PgetLocalQueueStats)()Lcom/hazelcast/monitor/LocalQueueStats; RS T iteratorStrgetLock.(Ljava/lang/String;)Lcom/hazelcast/core/ILock; WX KYjava/util/concurrent/locks/Lock\ < ]^" "< ]atrylockc W ]e \ ]gtimeoutlockStr!Ljava/util/concurrent/locks/Lock;s.laddItemListener6(Lcom/hazelcast/core/ItemListener;Z)Ljava/lang/String; no paddEntryListenerI(Lcom/hazelcast/core/EntryListener;Ljava/lang/Object;Z)Ljava/lang/String; rs t7(Lcom/hazelcast/core/EntryListener;Z)Ljava/lang/String; rv w t w pt.|addMessageListener8(Lcom/hazelcast/core/MessageListener;)Ljava/lang/String; ~ l. p N Removed  R R R < U removed removeStr  containsKey j  containsValue j mmm.    Contains: dataresultSize: clear <      Cleared all.destroy <       Destroyed!offer  offeredtake [ poll4(JLjava/util/concurrent/TimeUnit;)Ljava/lang/Object;  publish   j Ljava/lang/Object; [ cpeek [ remainingCapacity   doExecute(ZZ[Ljava/lang/String;)V  com/hazelcast/console/Echo submitToKeyOwnerP(Ljava/util/concurrent/Callable;Ljava/lang/Object;)Ljava/util/concurrent/Future;  #java/lang/IndexOutOfBoundsExceptionMember index:  must be smaller than  >(Ljava/util/concurrent/Callable;)Ljava/util/concurrent/Future; N Result: future1Ljava/util/concurrent/Future; memberIndexexecutorServicecallableLcom/hazelcast/console/Echo;onKeyonMembersubmitToAllMembers0(Ljava/util/concurrent/Callable;)Ljava/util/Map;   3taskresults]Ljava/util/Map;>; entryAdded"(Lcom/hazelcast/core/EntryEvent;)VeventLcom/hazelcast/core/EntryEvent; entryRemoved entryUpdated entryEvicted mapEvicted (Lcom/hazelcast/core/MapEvent;)VLcom/hazelcast/core/MapEvent; mapCleared itemAdded!(Lcom/hazelcast/core/ItemEvent;)V Item added = com/hazelcast/core/ItemEventgetItem  [   itemEventLcom/hazelcast/core/ItemEvent; itemRemovedItem removed =  onMessage(Lcom/hazelcast/core/Message;)VTopic received = com/hazelcast/core/MessagegetMessageObject [ msgLcom/hazelcast/core/Message; Commands:printGeneralCommands < printQueueCommands !< "printSetCommands $< %printLockCommands '< (printMapCommands *< +printMulitiMapCommands -< .printListCommands 0< 1printAtomicLongCommands 3< 4printExecutorServiceCommands 6< 7 silentBefore-- General commands:Techo true|false //turns on/off echo of commands (default false)<\silent true|false //turns on/off silent of command output (default false)># //repeats time , replace $i in with current iteration (0..)@& //forks threads to execute , replace $t in with current thread number (0..BC When using #x or &x, is is advised to use silent true as well.D When using &x with m.putmany and m.removemany, each thread will get a different share of keys unless a start key index is specifiedFFjvm //displays info about the runtimeHFwho //displays info about the clusterJNwhoami //displays info about this cluster memberLns //switch the namespace for using the distributed queue/map/set/list (defaults to "default"Nl@ //executes the given script. Use '//' for comments in the scriptP-- Queue commandsRHq.offer //adds a string object to the queueTEq.poll //takes an object from the queueVwq.offermany [] //adds indicated number of string objects to the queue ('obj' or byte[]) XWq.pollmany //takes indicated number of objects from the queueZNq.iterator [remove] //iterates the queue, remove if specified\8q.size //size of the queue^7q.clear //clears the queue`-- Set commandsbFs.add //adds a string object to the setdMs.remove //removes the string object from the setfds.addmany //adds indicated number of string objects to the set ('obj')hUs.removemany //takes indicated number of objects from the setjMs.iterator [remove] //iterates the set, removes if specifiedl6s.size //size of the setn5s.clear //clears the setp-- Lock commandsrLlock //same as Hazelcast.getLock(key).lock()tOtryLock //same as Hazelcast.getLock(key).tryLock()vTtryLock