Êþº¾4‡0com/hazelcast/client/impl/protocol/ClientMessage8com/hazelcast/client/impl/protocol/util/MessageFlyweight/com/hazelcast/internal/networking/OutboundFrameClientMessage.javaVERSIONS BEGIN_FLAG€END_FLAG@BEGIN_AND_END_FLAGSÀLISTENER_EVENT_FLAG HEADER_SIZEIPROP_HAZELCAST_PROTOCOL_UNSAFELjava/lang/String;!hazelcast.protocol.unsafe.enabled USE_UNSAFEZFRAME_LENGTH_FIELD_OFFSETVERSION_FIELD_OFFSETFLAGS_FIELD_OFFSETTYPE_FIELD_OFFSETCORRELATION_ID_FIELD_OFFSETPARTITION_ID_FIELD_OFFSETDATA_OFFSET_FIELD_OFFSET writeOffset isRetryableacquiresResource operationName connectionLcom/hazelcast/nio/Connection;()V ./ 0this2Lcom/hazelcast/client/impl/protocol/ClientMessage; getConnection ()Lcom/hazelcast/nio/Connection; ,- 6 setConnection!(Lcom/hazelcast/nio/Connection;)V wrapForEncodeB(Lcom/hazelcast/client/impl/protocol/util/ClientProtocolBuffer;I)V? =@ensureHeaderSize(II)V BC D byteArray()[B FG =H  Jwrap@([BIZ)Lcom/hazelcast/client/impl/protocol/util/MessageFlyweight; LM N  P setDataOffset5(I)Lcom/hazelcast/client/impl/protocol/ClientMessage; RS TsetFrameLength VS W getDataOffset Y? Zindex=(I)Lcom/hazelcast/client/impl/protocol/util/MessageFlyweight; \] ^setPartitionId `S abuffer>Lcom/hazelcast/client/impl/protocol/util/ClientProtocolBuffer;offset#java/lang/IndexOutOfBoundsExceptionfjava/lang/StringBuilderh i0+ClientMessage buffer must contain at least kappend-(Ljava/lang/String;)Ljava/lang/StringBuilder; mn io(I)Ljava/lang/StringBuilder; mq ir bytes! length: t , offset: vtoString()Ljava/lang/String; xy iz(Ljava/lang/String;)V .| g}length wrapForDecode getVersion()Suint8Get(I)S ƒ„ … setVersion5(S)Lcom/hazelcast/client/impl/protocol/ClientMessage;uint8Put(IS)V ‰Š ‹version isFlagSet(S)ZgetFlags ‚ ‘flagiaddFlagflagsgetMessageType uint16Get(I)I ˜™ šsetMessageType uint16Put C žtypegetFrameLengthint32Get ¢™ £int32Set ¥C ¦getCorrelationId()Jint64Get(I)J ª« ¬setCorrelationId5(J)Lcom/hazelcast/client/impl/protocol/ClientMessage;int64Set(IJ)V °± ² correlationIdJgetPartitionId partitionId dataOffsetupdateFrameLength4()Lcom/hazelcast/client/impl/protocol/ClientMessage; \? »writeTo(Ljava/nio/ByteBuffer;)Z cd ¿ ¡? Ájava/nio/ByteBufferà remaining Å? ÄÆ ( È[BÊput([BII)Ljava/nio/ByteBuffer; ÌÍ ÄÎ bytesWritedonedstLjava/nio/ByteBuffer;size bytesWritable bytesNeededreadFromcom/hazelcast/nio/BitsØreadIntL(Ljava/nio/ByteBuffer;)I ÚÛ ÙÜposition Þ? Äß(I)Ljava/nio/Buffer; Þá Äâ"java/lang/IllegalArgumentExceptionä?Client message frame length cannot be smaller than header size.æ å} N accumulate(Ljava/nio/ByteBuffer;I)I êë ì isComplete()Z îï ðsrc frameLengthputBytes(ILjava/nio/ByteBuffer;I)V ôõ =ö readLengthisUrgent ) ú * üsetAcquiresResource(Z)V setRetryablesetOperationName + getOperationNameClientMessage{ i} connection=-(Ljava/lang/Object;)Ljava/lang/StringBuilder; m i  , length= , correlationId= ¨© (J)Ljava/lang/StringBuilder; m i , operation=, messageType= —? java/lang/Integer toHexString(I)Ljava/lang/String;   , partitionId=" ¶? $ , isComplete=&(Z)Ljava/lang/StringBuilder; m( i), isRetryable=+ )ï - , isEvent=/ Ž 1, writeOffset=3(C)Ljava/lang/StringBuilder; m5 i6lensbLjava/lang/StringBuilder;create 0createForEncodeCcom/hazelcast/client/impl/protocol/exception/MaxMessageSizeExceeded> ?04com/hazelcast/client/impl/protocol/util/UnsafeBufferA([B)V .C BDs(Lcom/hazelcast/client/impl/protocol/util/ClientProtocolBuffer;I)Lcom/hazelcast/client/impl/protocol/ClientMessage; =F G2com/hazelcast/client/impl/protocol/util/SafeBufferI JDinitialCapacity :; M clientMessagecreateForDecode €; Qcopy@()Lcom/hazelcast/client/impl/protocol/util/ClientProtocolBuffer; cT Ujava/util/ArraysWcopyOf([BI)[B YZ X[5com/hazelcast/client/impl/protocol/util/BufferBuilder] createBufferB([B)Lcom/hazelcast/client/impl/protocol/util/ClientProtocolBuffer; _` ^a PF c oldBinarybytes newMessagehashCode LÍ Äi h? Äkequals(Ljava/lang/Object;)Zjava/lang/ObjectogetClass()Ljava/lang/Class; qr psoLjava/lang/Object;that thisBytes thatBytesjava/lang/Boolean{ getBoolean(Ljava/lang/String;)Z }~ | ConstantValueCodeLineNumberTableLocalVariableTable StackMapTable SourceFile!         !"#$%&'‚(‚)‚*‚+,-*./‚3*·1±ƒ uv„ 2345‚/*´7°ƒy„ 2389‚>*+µ7±ƒ }~„23,-:;‚:*+¹A·E*+¹I²K·OW*²Q¶UW*²Q¶XW**¶[¶_W*¶bW±ƒ ‚ƒ"„*…3†9‡„ :23:cd:eBC‚ˆ9d²Q¢2»gY»iY·jl¶p²Q¶su¶p¶sw¶p¶s¶{·~¿±…8ƒŠ ‹8Ž„ 9239e9€;‚n$*+¹A·E*+¹I²K·OW**¶[¶_W±ƒ‘ ’“#”„ $23$cd$e‚‚0*¶†¬ƒœ„ 23‡ˆ‚@*¶Œ*°ƒ ¦§„23 Ž‚b*¶’~= §¬…ü@ƒ ¯°„ 23“  ”‚‚0*¶†¬ƒ¹„ 23•ˆ‚F**¶’€“¶Œ*°ƒ à Ä„23– —?‚1*¶›¬ƒÍ„ 23œS‚A *¶Ÿ*°ƒ ×Ø„ 23  ¡?‚0*¶¤¬ƒá„ 23VS‚@*¶§*°ƒ ëì„23¨©‚1*¶­­ƒõ„ 23®¯‚A *¶³*°ƒ ÿ„ 23 ´µ¶?‚1*¶¤¬ƒ „ 23`S‚A *¶§*°ƒ „ 23 ·Y?‚1*¶›¬ƒ„ 23RS‚A *¶Ÿ*°ƒ '(„ 23 ¸¹º‚9 **¶¼¶XW*°ƒ , -„  23½¾‚2Y*´À¹IM*¶Â>+¶Ç6*´Éd6¡ 66§ 66+,*´É¶ÏW*Y´É`µÉ™*µÉ¬…ÿ.ÄËý ƒ:1 258<$>(?.B2C5FAGLIQKVM„f (Ð+ÑY23YÒÓ OFÊJÔDÕ<Ö2'Ð5$Ñ×¾‚ì`=*´ÀÇ<+¶Ç>¢¬+¸Ý=++¶àd¶ãW²Q¢ »åYç·è¿*¼²K¶éWž§*¶Â=*+*¶¼d·íW*¶ñ¬…ý ú Cƒ6 QR TUWY[%\,]6_BaOb[c„*4Å`23`òÓ^óê낳7+¶Ç>¢§6ž"*´À*¶¼+¹÷**¶¼`¶_W¬¬… ü@ü%ƒghij&k2l5n„47237òÓ72Å&øîï‚P*¶¼²Q¡*¶¼*¶Â §¬…@ƒw„ 23ùï‚,¬ƒ|„ 23)ï‚/*´û¬ƒ€„ 23*ï‚/*´ý¬ƒ„„ 23þÿ‚>*µý±ƒ ˆ‰„23*ÿ‚>*µû±ƒ Œ„23)|‚>*+µ±ƒ ‘„23+y‚/*´°ƒ”„ 23xy‚?º*¶¼<»iY·M, ¶p*´7¶ W,¶p¶sW²Q¡,¶p*¶¶W,¶p*´¶pW,¶p*¶¸!¶pW,#¶p*¶%¶sW,'¶p*¶ñ¶*W,,¶p*¶.¶*W,0¶p*¶2¶*W,4¶p*´É¶sW,}¶7W,¶{°… ý®iƒ>™š›œ+2žAŸP b¡q¢€£¤Ÿ¥®§µ¨„ º23µ8ª9: ;º‚ »Y·<°ƒ¬ =S‚t0œ »?Y·@¿²K™»BY¼·E¸H°»JY¼·K¸H°… ƒ°± ³´!¶„ 0L =F‚V»Y·B”a23auvDw3':xÊ2/yÊz/‚.¸€³K³Q±ƒ`l m†