4  F F F  F  F  F  F  F  F  F F F  F  F  F  F  F ! # # # F  F , ; ; ; ; F F  ; ; ; ; F k  # ; # F !"# K$ %& %' () %*+ S, F- F. ;/ 01 F23 4 5'6 #78 F9: F;< F=> F?@A FBC FDE FFG FHI FJK FLM FNO FPQ FRS FTU FVW FXY FZ[ F\] F^_ F`a Fbc Fde Ffg Fhi ;j Fkl Fmn Fop Fqr Fst Fuv Fwx Fyz F{|} F~ F F F F F F F F F F F F F F F F F F F F F F F F F F F F F F F/ F F F F F  ; F ;   #                       k  ;       & & & , + +  1           d         !" !# !$ %& # '( ') #*+ F, -. / -0 -1 -2 3 456 e 7 h8 9:; k< 9= 9>? o@A oB CD E 0F G HI J KL  MNOPQR = S T U V : W X Y Z [ e\` ]^_` a b c d efg h >i j k l m h > j a b c dn op qr s tx uvw uxy uz u{| } ~  ~  } F  }  H     E     E                 X   F      9j   F F F F F F F F F      b b  f  F FDefaultLineReader InnerClassesONE_KBI ConstantValue ONE_THOUSAND ONE_HUNDREDdONE_HOURMAX_THREAD_COUNTHUNDRED_CONSTANT BYTE_TO_BIT LENGTH_BORDERqueueLcom/hazelcast/core/IQueue; Signature/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; namespaceLjava/lang/String;executorNamespacesilentZecho hazelcast&Lcom/hazelcast/core/HazelcastInstance; lineReader"Lcom/hazelcast/console/LineReader;running)(Lcom/hazelcast/core/HazelcastInstance;)VCodeLineNumberTableLocalVariableTablethis/Lcom/hazelcast/client/console/ClientConsoleApp;getQueue()Lcom/hazelcast/core/IQueue;1()Lcom/hazelcast/core/IQueue;getTopic()Lcom/hazelcast/core/ITopic;1()Lcom/hazelcast/core/ITopic;getMap()Lcom/hazelcast/core/IMap;A()Lcom/hazelcast/core/IMap; getMultiMap()Lcom/hazelcast/core/MultiMap;E()Lcom/hazelcast/core/MultiMap;getAtomicNumber"()Lcom/hazelcast/core/IAtomicLong;getSet()Lcom/hazelcast/core/ISet;/()Lcom/hazelcast/core/ISet;getList()Lcom/hazelcast/core/IList;0()Lcom/hazelcast/core/IList; setHazelcaststop()Vstart([Ljava/lang/String;)VcommandeLjava/lang/Throwable;args[Ljava/lang/String; StackMapTable handleCommand(Ljava/lang/String;)Virepeatt0JthreadIDLjava/lang/Exception;forkpool&Ljava/util/concurrent/ExecutorService; threadCommandcommandInputtedfirst spaceIndex argsSplit+RuntimeInvisibleAnnotations4Ledu/umd/cs/findbugs/annotations/SuppressFBWarnings;valueDM_EXIThandleExecutorSimulatememberLcom/hazelcast/core/Member;fLjava/util/concurrent/Future;k Ljava/lang/InterruptedException;)Ljava/util/concurrent/ExecutionException; threadCount taskCount durationSecstartMsexecutor%Lcom/hazelcast/core/IExecutorService;futuresLjava/util/List;memberstotalThreadCountlatchId durationMsLocalVariableTypeTable/Ljava/util/List;-Ljava/util/List; handleColonstLjava/util/StringTokenizer;handleAtlLjava/io/IOException;brLjava/io/BufferedReader;Ljava/io/File;DM_DEFAULT_ENCODING handleEcho threadNamehandleNamespace handleJvmruntimeLjava/lang/Runtime; freeMemoryfreeMemoryPercentagetotalfreeDM_GC handleWhoami handleWhosbLjava/lang/StringBuilder;Ljava/util/Collection;3Ljava/util/Collection;handleAtomicNumberGethandleAtomicNumberSetvhandleAtomicNumberInchandleAtomicNumberDechandlePartitionscountLjava/lang/Integer;newCountowner partitionLcom/hazelcast/core/Partition;entryEntryLjava/util/Map$Entry; partitionsLjava/util/Set;partitionCountsLjava/util/Map;entriesELjava/util/Map$Entry;/Ljava/util/Set;?Ljava/util/Map;VLjava/util/Set;>;7;handleInstancesdistributedObject&Lcom/hazelcast/core/DistributedObject;distributedObjects>Ljava/util/Collection;handleListContainshandleListRemoveindex!Ljava/lang/NumberFormatException;I handleListAdd handleListSethandleListAddManysuccess successCountt1 handleMapPuthandleMapPutAsynchandleMapPutIfAbsenthandleMapReplace handleMapGethandleMapGetAsynchandleMapGetMapEntryhandleMapRemovehandleMapDeletehandleMapEvicthandleMapPutManyb[BtheMap%Ljava/util/Map;handleMapGetManyhandleMapRemoveMany handleMapLockhandleMapTryLocklockedkeytimehandleMapUnlockhandleMapLocalKeysitLjava/util/Iterator;handleMapLocalSize handleMapKeyshandleMapEntrieshandleMapValueshandleMultiMapPuthandleMultiMapGethandleMultiMapRemovehandleMultiMapKeyshandleMultiMapEntrieshandleMultiMapValueshandleMultiMapLockhandleMultiMapTryLockhandleMultiMapUnlock handStats iteratorStr handleLocktimeoutlockStrlock!Ljava/util/concurrent/locks/Lock;handleAddListenerhandleRemoveListener handleSetAddhandleSetRemovehandleSetAddManyhandleSetRemoveManyhandleIterator removeStrremovehandleContainsdataresult handleSizesize handleClear handleDestroy handleQOfferoffered handleQTake handleQPollhandleTopicPublishhandleQOfferManyLjava/lang/Object;handleQPollManyobjc handleQPeekhandleQCapacityexecute executeOnKeyexecuteOnMember doExecute(ZZ[Ljava/lang/String;)Vfuture memberIndexexecutorServicecallableLcom/hazelcast/console/Echo;onKeyonMember1Ljava/util/concurrent/Future;executeOnMemberstaskresults]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 itemEventLcom/hazelcast/core/ItemEvent; itemRemoved onMessage(Lcom/hazelcast/core/Message;)VmsgLcom/hazelcast/core/Message; handleHelp silentBeforeprintGeneralCommandsprintQueueCommandsprintSetCommandsprintLockCommandsprintMapCommandsprintMulitiMapCommandsprintExecutorServiceCommandsprintAtomicLongCommandsprintListCommandsprintln(Ljava/lang/Object;)Vprintmain clientConfig*Lcom/hazelcast/client/config/ClientConfig;$Ljava/lang/IllegalArgumentException;clientclientConsoleApp SourceFileClientConsoleApp.java default Sample Executor     !  "  #  $%  &  '   ( ) * + , - ?com/hazelcast/client/console/ClientConsoleApp$DefaultLineReaderjava/lang/StringBuilder hazelcast[ ./] > 01 2 31 java/lang/Throwable 4__ 56 78 9: ;<   // => ?1 @) 9A java/lang/Stringhelp # B:C DE\$i .F GHops/s = -com/hazelcast/client/console/ClientConsoleApp .I &J KL/com/hazelcast/client/console/ClientConsoleApp$1 M NO 3P QR STjava/lang/Exception@   UVW X> shutdown YZ[echo: .\ns whoami who jvm ock. u.size .clear .destroy  .iterator  .contains .stats s t.publish q.offer q.take q.poll q.peek  q.capacity  q.offermany  q.pollmany s.add }s.remove ~ s.addmany  s.removemany  m.replace O m.putIfAbsent ]> N m.putAsync M m.getAsync Qm.put Lm.get P m.getMapEntry Rm.remove Sm.delete Tm.evict U m.putmanym.putAll V m.getmany [ m.removemany \ m.localKeys c m.localSize fm.keys gm.values i m.entries hm.lock ] m.tryLock ^m.unlock b .addListener {m.removeMapListener |mm.put jmm.get k mm.remove lmm.keys m mm.values o mm.entries nmm.lock p mm.tryLock q mm.unlock rl.add Fl.set G l.addmany Hl.remove B l.contains Aa.get  a.set !a.inc #a.dec $  %    instances <quitexit^ _ .simulateLoad `> type 'help' for help ;ajava/lang/RuntimeException5threadcount can't be smaller than 1 or larger than 16  .b cdjava/util/LinkedList efg hi j klcom/hazelcast/core/Memberlatch mno pq&com/hazelcast/console/SimulateLoadTask r st uV vw xy z{java/util/concurrent/Future k{java/lang/InterruptedException| }~ 'java/util/concurrent/ExecutionExceptionExecuted %s tasks in %s msjava/lang/Object   java/util/StringTokenizer;  y 1usage: @ java/io/FileExecuting script file 1 yjava/io/BufferedReaderjava/io/FileReader   java/io/IOExceptionFile not found! 1  []  namespace:   Memory max: E E Memory free: M E Used Memory:MB # procs:  k) OS info:   1 1JVM:  1 1 1  Members [] { . }  kE   E E  ijava/util/HashMapcom/hazelcast/core/Partition  kjava/lang/Integer )  ijava/util/Map$Entry {: { $com/hazelcast/core/DistributedObject 5V  l Vjava/lang/NumberFormatException  utrue Added  objects.size = ,  evt/s        V _  evt/s,  Kbit/s,  KB added x V  w iTotal  Local Size = i:   k m. mm. q.   xunlock wtrylock y Ts.   t.  l.Removed  removed V Vmmm. Contains: Size =  Cleared all.  Destroyed!  {   V { { ) com/hazelcast/console/Echo #java/lang/IndexOutOfBoundsExceptionMember index:  must be smaller than NResult:  Item added =  {Item removed = Topic received =  { Commands:         -- General commandsTecho 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..C When using #x or &x, is is advised to use silent true as well. When using &x with m.putmany and m.removemany, each thread will get a different share of keys unless a start key index is specifiedFjvm //displays info about the runtimeFwho //displays info about the clusterNwhoami //displays info about this cluster memberns //switch the namespace for using the distributed queue/map/set/list (defaults to "default"l@ //executes the given script. Use '//' for comments in the script-- Queue commandsHq.offer //adds a string object to the queueEq.poll //takes an object from the queuewq.offermany [] //adds indicated number of string objects to the queue ('obj' or byte[]) Wq.pollmany //takes indicated number of objects from the queueNq.iterator [remove] //iterates the queue, remove if specified8q.size //size of the queue7q.clear //clears the queue-- Set commandsFs.add //adds a string object to the setMs.remove //removes the string object from the setds.addmany //adds indicated number of string objects to the set ('obj')Us.removemany //takes indicated number of objects from the setMs.iterator [remove] //iterates the set, removes if specified6s.size //size of the set5s.clear //clears the set-- Lock commandsLlock //same as Hazelcast.getLock(key).lock()OtryLock //same as Hazelcast.getLock(key).tryLock()TtryLock