| SystemOrganization addCategory: #Thrift! |
| SystemOrganization addCategory: #'Thrift-Protocol'! |
| SystemOrganization addCategory: #'Thrift-Test'! |
| SystemOrganization addCategory: #'Thrift-Transport'! |
| |
| Error subclass: #TError |
| instanceVariableNames: 'code' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Thrift'! |
| |
| !TError class methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 17:28'! |
| signalWithCode: anInteger |
| self new code: anInteger; signal! ! |
| |
| !TError methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 17:28'! |
| code |
| ^ code! ! |
| |
| !TError methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 17:28'! |
| code: anInteger |
| code := anInteger! ! |
| |
| TError subclass: #TProtocolError |
| instanceVariableNames: '' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Thrift-Protocol'! |
| |
| !TProtocolError class methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 18:39'! |
| badVersion |
| ^ 4! ! |
| |
| !TProtocolError class methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 18:39'! |
| invalidData |
| ^ 1! ! |
| |
| !TProtocolError class methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 18:39'! |
| negativeSize |
| ^ 2! ! |
| |
| !TProtocolError class methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 18:40'! |
| sizeLimit |
| ^ 3! ! |
| |
| !TProtocolError class methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 18:40'! |
| unknown |
| ^ 0! ! |
| |
| TError subclass: #TTransportError |
| instanceVariableNames: '' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Thrift-Transport'! |
| |
| TTransportError subclass: #TTransportClosedError |
| instanceVariableNames: '' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Thrift-Transport'! |
| |
| Error subclass: #Xception |
| instanceVariableNames: 'errorCode message' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Thrift-Test'! |
| |
| !Xception methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| errorCode |
| ^ errorCode! ! |
| |
| !Xception methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| errorCode: anI32 |
| errorCode := anI32! ! |
| |
| !Xception methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| message |
| ^ message! ! |
| |
| !Xception methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| message: aString |
| message := aString! ! |
| |
| Error subclass: #Xception2 |
| instanceVariableNames: 'errorCode structThing' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Thrift-Test'! |
| |
| !Xception2 methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| errorCode |
| ^ errorCode! ! |
| |
| !Xception2 methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| errorCode: anI32 |
| errorCode := anI32! ! |
| |
| !Xception2 methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| structThing |
| ^ structThing! ! |
| |
| !Xception2 methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| structThing: aXtruct |
| structThing := aXtruct! ! |
| |
| Object subclass: #Bonk |
| instanceVariableNames: 'message type' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Thrift-Test'! |
| |
| !Bonk methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| message |
| ^ message! ! |
| |
| !Bonk methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| message: aString |
| message := aString! ! |
| |
| !Bonk methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| type |
| ^ type! ! |
| |
| !Bonk methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| type: anI32 |
| type := anI32! ! |
| |
| Object subclass: #EmptyStruct |
| instanceVariableNames: '' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Thrift-Test'! |
| |
| Object subclass: #Insanity |
| instanceVariableNames: 'userMap xtructs' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Thrift-Test'! |
| |
| !Insanity methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| userMap |
| ^ userMap! ! |
| |
| !Insanity methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| userMap: a |
| userMap := a! ! |
| |
| !Insanity methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| xtructs |
| ^ xtructs! ! |
| |
| !Insanity methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| xtructs: a |
| xtructs := a! ! |
| |
| Object subclass: #TClient |
| instanceVariableNames: 'iprot oprot seqid remoteSeqid' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Thrift'! |
| |
| TClient subclass: #SecondServiceClient |
| instanceVariableNames: '' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Thrift-Test'! |
| |
| !SecondServiceClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| blahBlah |
| "" |
| self sendBlahBlah. |
| ^ self recvBlahBlah success |
| ! ! |
| |
| !SecondServiceClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| recvBlahBlah |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp118 temp117| |
| temp117 := TResult new. |
| iprot readStructBegin. |
| [temp118 := iprot readFieldBegin. |
| temp118 type = TType stop] whileFalse: [|temp119| |
| temp118 id = 0 ifTrue: [ |
| temp119 := true. |
| temp117 success: iprot readVoid]. |
| temp119 ifNil: [iprot skip: temp118 type]]. |
| oprot readStructEnd. |
| temp117] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !SecondServiceClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| sendBlahBlah |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'blahBlah'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'BlahBlah_args'). |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !TClient methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 23:03'! |
| inProtocol: aProtocol |
| iprot := aProtocol. |
| oprot ifNil: [oprot := aProtocol]! ! |
| |
| !TClient methodsFor: 'as yet unclassified' stamp: 'pc 10/26/2007 04:28'! |
| nextSeqid |
| ^ seqid |
| ifNil: [seqid := 0] |
| ifNotNil: [seqid := seqid + 1]! ! |
| |
| !TClient methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 22:51'! |
| outProtocol: aProtocol |
| oprot := aProtocol! ! |
| |
| !TClient methodsFor: 'as yet unclassified' stamp: 'pc 10/28/2007 15:32'! |
| validateRemoteMessage: aMsg |
| remoteSeqid |
| ifNil: [remoteSeqid := aMsg seqid] |
| ifNotNil: |
| [(remoteSeqid + 1) = aMsg seqid ifFalse: |
| [TProtocolError signal: 'Bad seqid: ', aMsg seqid asString, |
| '; wanted: ', remoteSeqid asString]. |
| remoteSeqid := aMsg seqid]! ! |
| |
| TClient subclass: #ThriftTestClient |
| instanceVariableNames: '' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Thrift-Test'! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| recvTestByte |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp7 temp6| |
| temp6 := TResult new. |
| iprot readStructBegin. |
| [temp7 := iprot readFieldBegin. |
| temp7 type = TType stop] whileFalse: [|temp8| |
| temp7 id = 0 ifTrue: [ |
| temp8 := true. |
| temp6 success: iprot readByte]. |
| temp8 ifNil: [iprot skip: temp7 type]]. |
| oprot readStructEnd. |
| temp6] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| recvTestDouble |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp19 temp18| |
| temp18 := TResult new. |
| iprot readStructBegin. |
| [temp19 := iprot readFieldBegin. |
| temp19 type = TType stop] whileFalse: [|temp20| |
| temp19 id = 0 ifTrue: [ |
| temp20 := true. |
| temp18 success: iprot readDouble]. |
| temp20 ifNil: [iprot skip: temp19 type]]. |
| oprot readStructEnd. |
| temp18] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| recvTestEnum |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp56 temp55| |
| temp55 := TResult new. |
| iprot readStructBegin. |
| [temp56 := iprot readFieldBegin. |
| temp56 type = TType stop] whileFalse: [|temp57| |
| temp56 id = 0 ifTrue: [ |
| temp57 := true. |
| temp55 success: iprot readI32]. |
| temp57 ifNil: [iprot skip: temp56 type]]. |
| oprot readStructEnd. |
| temp55] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| recvTestException |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp97 temp96| |
| temp96 := TResult new. |
| iprot readStructBegin. |
| [temp97 := iprot readFieldBegin. |
| temp97 type = TType stop] whileFalse: [|temp98| |
| temp97 id = 0 ifTrue: [ |
| temp98 := true. |
| temp96 success: iprot readVoid]. |
| temp97 id = -2 ifTrue: [ |
| temp98 := true. |
| temp96 exception: [|temp100 temp99| |
| temp99 := Xception new. |
| iprot readStructBegin. |
| [temp100 := iprot readFieldBegin. |
| temp100 type = TType stop] whileFalse: [|temp101| |
| temp100 id = 1 ifTrue: [ |
| temp101 := true. |
| temp99 errorCode: iprot readI32]. |
| temp100 id = 2 ifTrue: [ |
| temp101 := true. |
| temp99 message: iprot readString]. |
| temp101 ifNil: [iprot skip: temp100 type]]. |
| oprot readStructEnd. |
| temp99] value]. |
| temp98 ifNil: [iprot skip: temp97 type]]. |
| oprot readStructEnd. |
| temp96] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| recvTestI16 |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp10 temp9| |
| temp9 := TResult new. |
| iprot readStructBegin. |
| [temp10 := iprot readFieldBegin. |
| temp10 type = TType stop] whileFalse: [|temp11| |
| temp10 id = 0 ifTrue: [ |
| temp11 := true. |
| temp9 success: iprot readI16]. |
| temp11 ifNil: [iprot skip: temp10 type]]. |
| oprot readStructEnd. |
| temp9] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| recvTestI32 |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp13 temp12| |
| temp12 := TResult new. |
| iprot readStructBegin. |
| [temp13 := iprot readFieldBegin. |
| temp13 type = TType stop] whileFalse: [|temp14| |
| temp13 id = 0 ifTrue: [ |
| temp14 := true. |
| temp12 success: iprot readI32]. |
| temp14 ifNil: [iprot skip: temp13 type]]. |
| oprot readStructEnd. |
| temp12] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| recvTestI64 |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp16 temp15| |
| temp15 := TResult new. |
| iprot readStructBegin. |
| [temp16 := iprot readFieldBegin. |
| temp16 type = TType stop] whileFalse: [|temp17| |
| temp16 id = 0 ifTrue: [ |
| temp17 := true. |
| temp15 success: iprot readI64]. |
| temp17 ifNil: [iprot skip: temp16 type]]. |
| oprot readStructEnd. |
| temp15] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| recvTestInsanity |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp72 temp71| |
| temp71 := TResult new. |
| iprot readStructBegin. |
| [temp72 := iprot readFieldBegin. |
| temp72 type = TType stop] whileFalse: [|temp73| |
| temp72 id = 0 ifTrue: [ |
| temp73 := true. |
| temp71 success: [|temp74 temp75| |
| temp74 := iprot readMapBegin. |
| temp75 := Dictionary new. |
| temp74 size timesRepeat: [ |
| temp75 at: iprot readI64 put: [|temp76 temp77| |
| temp76 := iprot readMapBegin. |
| temp77 := Dictionary new. |
| temp76 size timesRepeat: [ |
| temp77 at: iprot readI32 put: [|temp79 temp78| |
| temp78 := Insanity new. |
| iprot readStructBegin. |
| [temp79 := iprot readFieldBegin. |
| temp79 type = TType stop] whileFalse: [|temp80| |
| temp79 id = 1 ifTrue: [ |
| temp80 := true. |
| temp78 userMap: [|temp81 temp82| |
| temp81 := iprot readMapBegin. |
| temp82 := Dictionary new. |
| temp81 size timesRepeat: [ |
| temp82 at: iprot readI32 put: iprot readI64]. |
| iprot readMapEnd. |
| temp82] value]. |
| temp79 id = 2 ifTrue: [ |
| temp80 := true. |
| temp78 xtructs: [|temp83 temp84| temp83 := iprot readListBegin. |
| temp84 := OrderedCollection new. |
| temp83 size timesRepeat: [ |
| temp84 add: [|temp86 temp85| |
| temp85 := Xtruct new. |
| iprot readStructBegin. |
| [temp86 := iprot readFieldBegin. |
| temp86 type = TType stop] whileFalse: [|temp87| |
| temp86 id = 1 ifTrue: [ |
| temp87 := true. |
| temp85 stringThing: iprot readString]. |
| temp86 id = 4 ifTrue: [ |
| temp87 := true. |
| temp85 byteThing: iprot readByte]. |
| temp86 id = 9 ifTrue: [ |
| temp87 := true. |
| temp85 i32Thing: iprot readI32]. |
| temp86 id = 11 ifTrue: [ |
| temp87 := true. |
| temp85 i64Thing: iprot readI64]. |
| temp87 ifNil: [iprot skip: temp86 type]]. |
| oprot readStructEnd. |
| temp85] value]. |
| iprot readListEnd. |
| temp84] value]. |
| temp80 ifNil: [iprot skip: temp79 type]]. |
| oprot readStructEnd. |
| temp78] value]. |
| iprot readMapEnd. |
| temp77] value]. |
| iprot readMapEnd. |
| temp75] value]. |
| temp73 ifNil: [iprot skip: temp72 type]]. |
| oprot readStructEnd. |
| temp71] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| recvTestList |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp51 temp50| |
| temp50 := TResult new. |
| iprot readStructBegin. |
| [temp51 := iprot readFieldBegin. |
| temp51 type = TType stop] whileFalse: [|temp52| |
| temp51 id = 0 ifTrue: [ |
| temp52 := true. |
| temp50 success: [|temp53 temp54| temp53 := iprot readListBegin. |
| temp54 := OrderedCollection new. |
| temp53 size timesRepeat: [ |
| temp54 add: iprot readI32]. |
| iprot readListEnd. |
| temp54] value]. |
| temp52 ifNil: [iprot skip: temp51 type]]. |
| oprot readStructEnd. |
| temp50] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| recvTestMap |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp39 temp38| |
| temp38 := TResult new. |
| iprot readStructBegin. |
| [temp39 := iprot readFieldBegin. |
| temp39 type = TType stop] whileFalse: [|temp40| |
| temp39 id = 0 ifTrue: [ |
| temp40 := true. |
| temp38 success: [|temp41 temp42| |
| temp41 := iprot readMapBegin. |
| temp42 := Dictionary new. |
| temp41 size timesRepeat: [ |
| temp42 at: iprot readI32 put: iprot readI32]. |
| iprot readMapEnd. |
| temp42] value]. |
| temp40 ifNil: [iprot skip: temp39 type]]. |
| oprot readStructEnd. |
| temp38] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| recvTestMapMap |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp62 temp61| |
| temp61 := TResult new. |
| iprot readStructBegin. |
| [temp62 := iprot readFieldBegin. |
| temp62 type = TType stop] whileFalse: [|temp63| |
| temp62 id = 0 ifTrue: [ |
| temp63 := true. |
| temp61 success: [|temp64 temp65| |
| temp64 := iprot readMapBegin. |
| temp65 := Dictionary new. |
| temp64 size timesRepeat: [ |
| temp65 at: iprot readI32 put: [|temp66 temp67| |
| temp66 := iprot readMapBegin. |
| temp67 := Dictionary new. |
| temp66 size timesRepeat: [ |
| temp67 at: iprot readI32 put: iprot readI32]. |
| iprot readMapEnd. |
| temp67] value]. |
| iprot readMapEnd. |
| temp65] value]. |
| temp63 ifNil: [iprot skip: temp62 type]]. |
| oprot readStructEnd. |
| temp61] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| recvTestMulti |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp91 temp90| |
| temp90 := TResult new. |
| iprot readStructBegin. |
| [temp91 := iprot readFieldBegin. |
| temp91 type = TType stop] whileFalse: [|temp92| |
| temp91 id = 0 ifTrue: [ |
| temp92 := true. |
| temp90 success: [|temp94 temp93| |
| temp93 := Xtruct new. |
| iprot readStructBegin. |
| [temp94 := iprot readFieldBegin. |
| temp94 type = TType stop] whileFalse: [|temp95| |
| temp94 id = 1 ifTrue: [ |
| temp95 := true. |
| temp93 stringThing: iprot readString]. |
| temp94 id = 4 ifTrue: [ |
| temp95 := true. |
| temp93 byteThing: iprot readByte]. |
| temp94 id = 9 ifTrue: [ |
| temp95 := true. |
| temp93 i32Thing: iprot readI32]. |
| temp94 id = 11 ifTrue: [ |
| temp95 := true. |
| temp93 i64Thing: iprot readI64]. |
| temp95 ifNil: [iprot skip: temp94 type]]. |
| oprot readStructEnd. |
| temp93] value]. |
| temp92 ifNil: [iprot skip: temp91 type]]. |
| oprot readStructEnd. |
| temp90] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| recvTestMultiException |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp103 temp102| |
| temp102 := TResult new. |
| iprot readStructBegin. |
| [temp103 := iprot readFieldBegin. |
| temp103 type = TType stop] whileFalse: [|temp104| |
| temp103 id = 0 ifTrue: [ |
| temp104 := true. |
| temp102 success: [|temp106 temp105| |
| temp105 := Xtruct new. |
| iprot readStructBegin. |
| [temp106 := iprot readFieldBegin. |
| temp106 type = TType stop] whileFalse: [|temp107| |
| temp106 id = 1 ifTrue: [ |
| temp107 := true. |
| temp105 stringThing: iprot readString]. |
| temp106 id = 4 ifTrue: [ |
| temp107 := true. |
| temp105 byteThing: iprot readByte]. |
| temp106 id = 9 ifTrue: [ |
| temp107 := true. |
| temp105 i32Thing: iprot readI32]. |
| temp106 id = 11 ifTrue: [ |
| temp107 := true. |
| temp105 i64Thing: iprot readI64]. |
| temp107 ifNil: [iprot skip: temp106 type]]. |
| oprot readStructEnd. |
| temp105] value]. |
| temp103 id = -3 ifTrue: [ |
| temp104 := true. |
| temp102 exception: [|temp109 temp108| |
| temp108 := Xception new. |
| iprot readStructBegin. |
| [temp109 := iprot readFieldBegin. |
| temp109 type = TType stop] whileFalse: [|temp110| |
| temp109 id = 1 ifTrue: [ |
| temp110 := true. |
| temp108 errorCode: iprot readI32]. |
| temp109 id = 2 ifTrue: [ |
| temp110 := true. |
| temp108 message: iprot readString]. |
| temp110 ifNil: [iprot skip: temp109 type]]. |
| oprot readStructEnd. |
| temp108] value]. |
| temp103 id = -4 ifTrue: [ |
| temp104 := true. |
| temp102 exception: [|temp112 temp111| |
| temp111 := Xception2 new. |
| iprot readStructBegin. |
| [temp112 := iprot readFieldBegin. |
| temp112 type = TType stop] whileFalse: [|temp113| |
| temp112 id = 1 ifTrue: [ |
| temp113 := true. |
| temp111 errorCode: iprot readI32]. |
| temp112 id = 2 ifTrue: [ |
| temp113 := true. |
| temp111 structThing: [|temp115 temp114| |
| temp114 := Xtruct new. |
| iprot readStructBegin. |
| [temp115 := iprot readFieldBegin. |
| temp115 type = TType stop] whileFalse: [|temp116| |
| temp115 id = 1 ifTrue: [ |
| temp116 := true. |
| temp114 stringThing: iprot readString]. |
| temp115 id = 4 ifTrue: [ |
| temp116 := true. |
| temp114 byteThing: iprot readByte]. |
| temp115 id = 9 ifTrue: [ |
| temp116 := true. |
| temp114 i32Thing: iprot readI32]. |
| temp115 id = 11 ifTrue: [ |
| temp116 := true. |
| temp114 i64Thing: iprot readI64]. |
| temp116 ifNil: [iprot skip: temp115 type]]. |
| oprot readStructEnd. |
| temp114] value]. |
| temp113 ifNil: [iprot skip: temp112 type]]. |
| oprot readStructEnd. |
| temp111] value]. |
| temp104 ifNil: [iprot skip: temp103 type]]. |
| oprot readStructEnd. |
| temp102] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| recvTestNest |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp28 temp27| |
| temp27 := TResult new. |
| iprot readStructBegin. |
| [temp28 := iprot readFieldBegin. |
| temp28 type = TType stop] whileFalse: [|temp29| |
| temp28 id = 0 ifTrue: [ |
| temp29 := true. |
| temp27 success: [|temp31 temp30| |
| temp30 := Xtruct2 new. |
| iprot readStructBegin. |
| [temp31 := iprot readFieldBegin. |
| temp31 type = TType stop] whileFalse: [|temp32| |
| temp31 id = 1 ifTrue: [ |
| temp32 := true. |
| temp30 byteThing: iprot readByte]. |
| temp31 id = 2 ifTrue: [ |
| temp32 := true. |
| temp30 structThing: [|temp34 temp33| |
| temp33 := Xtruct new. |
| iprot readStructBegin. |
| [temp34 := iprot readFieldBegin. |
| temp34 type = TType stop] whileFalse: [|temp35| |
| temp34 id = 1 ifTrue: [ |
| temp35 := true. |
| temp33 stringThing: iprot readString]. |
| temp34 id = 4 ifTrue: [ |
| temp35 := true. |
| temp33 byteThing: iprot readByte]. |
| temp34 id = 9 ifTrue: [ |
| temp35 := true. |
| temp33 i32Thing: iprot readI32]. |
| temp34 id = 11 ifTrue: [ |
| temp35 := true. |
| temp33 i64Thing: iprot readI64]. |
| temp35 ifNil: [iprot skip: temp34 type]]. |
| oprot readStructEnd. |
| temp33] value]. |
| temp31 id = 3 ifTrue: [ |
| temp32 := true. |
| temp30 i32Thing: iprot readI32]. |
| temp32 ifNil: [iprot skip: temp31 type]]. |
| oprot readStructEnd. |
| temp30] value]. |
| temp29 ifNil: [iprot skip: temp28 type]]. |
| oprot readStructEnd. |
| temp27] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| recvTestSet |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp45 temp44| |
| temp44 := TResult new. |
| iprot readStructBegin. |
| [temp45 := iprot readFieldBegin. |
| temp45 type = TType stop] whileFalse: [|temp46| |
| temp45 id = 0 ifTrue: [ |
| temp46 := true. |
| temp44 success: [|temp47 temp48| temp47 := iprot readSetBegin. |
| temp48 := Set new. |
| temp47 size timesRepeat: [ |
| temp48 add: iprot readI32]. |
| iprot readSetEnd. |
| temp48] value]. |
| temp46 ifNil: [iprot skip: temp45 type]]. |
| oprot readStructEnd. |
| temp44] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| recvTestString |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp4 temp3| |
| temp3 := TResult new. |
| iprot readStructBegin. |
| [temp4 := iprot readFieldBegin. |
| temp4 type = TType stop] whileFalse: [|temp5| |
| temp4 id = 0 ifTrue: [ |
| temp5 := true. |
| temp3 success: iprot readString]. |
| temp5 ifNil: [iprot skip: temp4 type]]. |
| oprot readStructEnd. |
| temp3] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| recvTestStruct |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp22 temp21| |
| temp21 := TResult new. |
| iprot readStructBegin. |
| [temp22 := iprot readFieldBegin. |
| temp22 type = TType stop] whileFalse: [|temp23| |
| temp22 id = 0 ifTrue: [ |
| temp23 := true. |
| temp21 success: [|temp25 temp24| |
| temp24 := Xtruct new. |
| iprot readStructBegin. |
| [temp25 := iprot readFieldBegin. |
| temp25 type = TType stop] whileFalse: [|temp26| |
| temp25 id = 1 ifTrue: [ |
| temp26 := true. |
| temp24 stringThing: iprot readString]. |
| temp25 id = 4 ifTrue: [ |
| temp26 := true. |
| temp24 byteThing: iprot readByte]. |
| temp25 id = 9 ifTrue: [ |
| temp26 := true. |
| temp24 i32Thing: iprot readI32]. |
| temp25 id = 11 ifTrue: [ |
| temp26 := true. |
| temp24 i64Thing: iprot readI64]. |
| temp26 ifNil: [iprot skip: temp25 type]]. |
| oprot readStructEnd. |
| temp24] value]. |
| temp23 ifNil: [iprot skip: temp22 type]]. |
| oprot readStructEnd. |
| temp21] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| recvTestTypedef |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp59 temp58| |
| temp58 := TResult new. |
| iprot readStructBegin. |
| [temp59 := iprot readFieldBegin. |
| temp59 type = TType stop] whileFalse: [|temp60| |
| temp59 id = 0 ifTrue: [ |
| temp60 := true. |
| temp58 success: iprot readI64]. |
| temp60 ifNil: [iprot skip: temp59 type]]. |
| oprot readStructEnd. |
| temp58] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| recvTestVoid |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp1 temp0| |
| temp0 := TResult new. |
| iprot readStructBegin. |
| [temp1 := iprot readFieldBegin. |
| temp1 type = TType stop] whileFalse: [|temp2| |
| temp1 id = 0 ifTrue: [ |
| temp2 := true. |
| temp0 success: iprot readVoid]. |
| temp2 ifNil: [iprot skip: temp1 type]]. |
| oprot readStructEnd. |
| temp0] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| sendTestByteThing: thing |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'testByte'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'TestByte_args'). |
| oprot writeFieldBegin: (TField new name: 'thing'; type: TType byte; id: 1). |
| iprot writeByte: thing asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| sendTestDoubleThing: thing |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'testDouble'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'TestDouble_args'). |
| oprot writeFieldBegin: (TField new name: 'thing'; type: TType double; id: 1). |
| iprot writeDouble: thing asFloat. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| sendTestEnumThing: thing |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'testEnum'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'TestEnum_args'). |
| oprot writeFieldBegin: (TField new name: 'thing'; type: TType i32; id: 1). |
| iprot writeI32: thing. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| sendTestExceptionArg: arg |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'testException'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'TestException_args'). |
| oprot writeFieldBegin: (TField new name: 'arg'; type: TType string; id: -1). |
| iprot writeString: arg. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| sendTestI16Thing: thing |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'testI16'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'TestI16_args'). |
| oprot writeFieldBegin: (TField new name: 'thing'; type: TType i16; id: 1). |
| iprot writeI16: thing asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| sendTestI32Thing: thing |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'testI32'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'TestI32_args'). |
| oprot writeFieldBegin: (TField new name: 'thing'; type: TType i32; id: 1). |
| iprot writeI32: thing asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| sendTestI64Thing: thing |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'testI64'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'TestI64_args'). |
| oprot writeFieldBegin: (TField new name: 'thing'; type: TType i64; id: 1). |
| iprot writeI64: thing asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| sendTestInsanityArgument: argument |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'testInsanity'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'TestInsanity_args'). |
| oprot writeFieldBegin: (TField new name: 'argument'; type: TType struct; id: 1). |
| [oprot writeStructBegin: (TStruct new name: 'Insanity'). |
| oprot writeFieldBegin: (TField new name: 'userMap'; type: TType map; id: 1). |
| [oprot writeMapBegin: (TMap new keyType: TType i32; valueType: TType i64; size: argument userMap size). |
| argument userMap keysAndValuesDo: [:temp68 :temp69 | |
| iprot writeI32: temp68. |
| iprot writeI64: temp69 asInteger]. |
| oprot writeMapEnd] value. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'xtructs'; type: TType list; id: 2). |
| [oprot writeListBegin: (TList new elemType: TType struct; size: argument xtructs size). |
| argument xtructs do: [:temp70| |
| [oprot writeStructBegin: (TStruct new name: 'Xtruct'). |
| oprot writeFieldBegin: (TField new name: 'string_thing'; type: TType string; id: 1). |
| iprot writeString: temp70 stringThing. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'byte_thing'; type: TType byte; id: 4). |
| iprot writeByte: temp70 byteThing asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'i32_thing'; type: TType i32; id: 9). |
| iprot writeI32: temp70 i32Thing asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'i64_thing'; type: TType i64; id: 11). |
| iprot writeI64: temp70 i64Thing asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd] value |
| ]. |
| oprot writeListEnd] value. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd] value. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| sendTestListThing: thing |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'testList'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'TestList_args'). |
| oprot writeFieldBegin: (TField new name: 'thing'; type: TType list; id: 1). |
| [oprot writeListBegin: (TList new elemType: TType i32; size: thing size). |
| thing do: [:temp49| |
| iprot writeI32: temp49 asInteger |
| ]. |
| oprot writeListEnd] value. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| sendTestMapMapHello: hello |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'testMapMap'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'TestMapMap_args'). |
| oprot writeFieldBegin: (TField new name: 'hello'; type: TType i32; id: 1). |
| iprot writeI32: hello asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| sendTestMapThing: thing |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'testMap'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'TestMap_args'). |
| oprot writeFieldBegin: (TField new name: 'thing'; type: TType map; id: 1). |
| [oprot writeMapBegin: (TMap new keyType: TType i32; valueType: TType i32; size: thing size). |
| thing keysAndValuesDo: [:temp36 :temp37 | |
| iprot writeI32: temp36 asInteger. |
| iprot writeI32: temp37 asInteger]. |
| oprot writeMapEnd] value. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| sendTestMultiArg0: arg0 arg1: arg1 arg2: arg2 arg3: arg3 arg4: arg4 arg5: arg5 |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'testMulti'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'TestMulti_args'). |
| oprot writeFieldBegin: (TField new name: 'arg0'; type: TType byte; id: -1). |
| iprot writeByte: arg0 asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'arg1'; type: TType i32; id: -2). |
| iprot writeI32: arg1 asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'arg2'; type: TType i64; id: -3). |
| iprot writeI64: arg2 asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'arg3'; type: TType map; id: -4). |
| [oprot writeMapBegin: (TMap new keyType: TType i16; valueType: TType string; size: arg3 size). |
| arg3 keysAndValuesDo: [:temp88 :temp89 | |
| iprot writeI16: temp88 asInteger. |
| iprot writeString: temp89]. |
| oprot writeMapEnd] value. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'arg4'; type: TType i32; id: -5). |
| iprot writeI32: arg4. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'arg5'; type: TType i64; id: -6). |
| iprot writeI64: arg5 asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| sendTestMultiExceptionArg0: arg0 arg1: arg1 |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'testMultiException'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'TestMultiException_args'). |
| oprot writeFieldBegin: (TField new name: 'arg0'; type: TType string; id: -1). |
| iprot writeString: arg0. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'arg1'; type: TType string; id: -2). |
| iprot writeString: arg1. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| sendTestNestThing: thing |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'testNest'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'TestNest_args'). |
| oprot writeFieldBegin: (TField new name: 'thing'; type: TType struct; id: 1). |
| [oprot writeStructBegin: (TStruct new name: 'Xtruct2'). |
| oprot writeFieldBegin: (TField new name: 'byte_thing'; type: TType byte; id: 1). |
| iprot writeByte: thing byteThing asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'struct_thing'; type: TType struct; id: 2). |
| [oprot writeStructBegin: (TStruct new name: 'Xtruct'). |
| oprot writeFieldBegin: (TField new name: 'string_thing'; type: TType string; id: 1). |
| iprot writeString: thing structThing stringThing. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'byte_thing'; type: TType byte; id: 4). |
| iprot writeByte: thing structThing byteThing asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'i32_thing'; type: TType i32; id: 9). |
| iprot writeI32: thing structThing i32Thing asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'i64_thing'; type: TType i64; id: 11). |
| iprot writeI64: thing structThing i64Thing asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd] value. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'i32_thing'; type: TType i32; id: 3). |
| iprot writeI32: thing i32Thing asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd] value. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| sendTestSetThing: thing |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'testSet'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'TestSet_args'). |
| oprot writeFieldBegin: (TField new name: 'thing'; type: TType set; id: 1). |
| [oprot writeSetBegin: (TSet new elemType: TType i32; size: thing size). |
| thing do: [:temp43| |
| iprot writeI32: temp43 asInteger |
| ]. |
| oprot writeSetEnd] value. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| sendTestStringThing: thing |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'testString'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'TestString_args'). |
| oprot writeFieldBegin: (TField new name: 'thing'; type: TType string; id: 1). |
| iprot writeString: thing. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| sendTestStructThing: thing |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'testStruct'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'TestStruct_args'). |
| oprot writeFieldBegin: (TField new name: 'thing'; type: TType struct; id: 1). |
| [oprot writeStructBegin: (TStruct new name: 'Xtruct'). |
| oprot writeFieldBegin: (TField new name: 'string_thing'; type: TType string; id: 1). |
| iprot writeString: thing stringThing. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'byte_thing'; type: TType byte; id: 4). |
| iprot writeByte: thing byteThing asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'i32_thing'; type: TType i32; id: 9). |
| iprot writeI32: thing i32Thing asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'i64_thing'; type: TType i64; id: 11). |
| iprot writeI64: thing i64Thing asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd] value. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| sendTestTypedefThing: thing |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'testTypedef'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'TestTypedef_args'). |
| oprot writeFieldBegin: (TField new name: 'thing'; type: TType i64; id: 1). |
| iprot writeI64: thing asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| sendTestVoid |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'testVoid'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'TestVoid_args'). |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| testByteThing: thing |
| "thing: byte" |
| self sendTestByteThing: thing. |
| ^ self recvTestByte success |
| ! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| testDoubleThing: thing |
| "thing: double" |
| self sendTestDoubleThing: thing. |
| ^ self recvTestDouble success |
| ! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| testEnumThing: thing |
| "thing: Numberz" |
| self sendTestEnumThing: thing. |
| ^ self recvTestEnum success |
| ! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| testExceptionArg: arg |
| "arg: string" |
| self sendTestExceptionArg: arg. |
| ^ self recvTestException success |
| ! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| testI16Thing: thing |
| "thing: i16" |
| self sendTestI16Thing: thing. |
| ^ self recvTestI16 success |
| ! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| testI32Thing: thing |
| "thing: i32" |
| self sendTestI32Thing: thing. |
| ^ self recvTestI32 success |
| ! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| testI64Thing: thing |
| "thing: i64" |
| self sendTestI64Thing: thing. |
| ^ self recvTestI64 success |
| ! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| testInsanityArgument: argument |
| "argument: Insanity" |
| self sendTestInsanityArgument: argument. |
| ^ self recvTestInsanity success |
| ! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| testListThing: thing |
| "thing: " |
| self sendTestListThing: thing. |
| ^ self recvTestList success |
| ! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| testMapMapHello: hello |
| "hello: i32" |
| self sendTestMapMapHello: hello. |
| ^ self recvTestMapMap success |
| ! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| testMapThing: thing |
| "thing: " |
| self sendTestMapThing: thing. |
| ^ self recvTestMap success |
| ! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| testMultiArg0: arg0 arg1: arg1 arg2: arg2 arg3: arg3 arg4: arg4 arg5: arg5 |
| "arg0: byte, arg1: i32, arg2: i64, arg3: , arg4: Numberz, arg5: UserId" |
| self sendTestMultiArg0: arg0 arg1: arg1 arg2: arg2 arg3: arg3 arg4: arg4 arg5: arg5. |
| ^ self recvTestMulti success |
| ! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| testMultiExceptionArg0: arg0 arg1: arg1 |
| "arg0: string, arg1: string" |
| self sendTestMultiExceptionArg0: arg0 arg1: arg1. |
| ^ self recvTestMultiException success |
| ! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| testNestThing: thing |
| "thing: Xtruct2" |
| self sendTestNestThing: thing. |
| ^ self recvTestNest success |
| ! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| testSetThing: thing |
| "thing: " |
| self sendTestSetThing: thing. |
| ^ self recvTestSet success |
| ! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| testStringThing: thing |
| "thing: string" |
| self sendTestStringThing: thing. |
| ^ self recvTestString success |
| ! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| testStructThing: thing |
| "thing: Xtruct" |
| self sendTestStructThing: thing. |
| ^ self recvTestStruct success |
| ! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| testTypedefThing: thing |
| "thing: UserId" |
| self sendTestTypedefThing: thing. |
| ^ self recvTestTypedef success |
| ! ! |
| |
| !ThriftTestClient methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| testVoid |
| "" |
| self sendTestVoid. |
| ^ self recvTestVoid success |
| ! ! |
| |
| Object subclass: #TField |
| instanceVariableNames: 'name type id' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Thrift-Protocol'! |
| |
| !TField methodsFor: 'accessing' stamp: 'pc 10/24/2007 20:05'! |
| id |
| ^ id ifNil: [0]! ! |
| |
| !TField methodsFor: 'accessing' stamp: 'pc 10/24/2007 19:44'! |
| id: anInteger |
| id := anInteger! ! |
| |
| !TField methodsFor: 'accessing' stamp: 'pc 10/24/2007 20:04'! |
| name |
| ^ name ifNil: ['']! ! |
| |
| !TField methodsFor: 'accessing' stamp: 'pc 10/24/2007 19:44'! |
| name: anObject |
| name := anObject! ! |
| |
| !TField methodsFor: 'accessing' stamp: 'pc 10/24/2007 20:05'! |
| type |
| ^ type ifNil: [TType stop]! ! |
| |
| !TField methodsFor: 'accessing' stamp: 'pc 10/24/2007 19:44'! |
| type: anInteger |
| type := anInteger! ! |
| |
| Object subclass: #TMessage |
| instanceVariableNames: 'name seqid type' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Thrift-Protocol'! |
| |
| TMessage subclass: #TCallMessage |
| instanceVariableNames: '' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Thrift-Protocol'! |
| |
| !TCallMessage methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 22:53'! |
| type |
| ^ 1! ! |
| |
| !TMessage methodsFor: 'accessing' stamp: 'pc 10/24/2007 20:05'! |
| name |
| ^ name ifNil: ['']! ! |
| |
| !TMessage methodsFor: 'accessing' stamp: 'pc 10/24/2007 19:35'! |
| name: aString |
| name := aString! ! |
| |
| !TMessage methodsFor: 'accessing' stamp: 'pc 10/24/2007 20:05'! |
| seqid |
| ^ seqid ifNil: [0]! ! |
| |
| !TMessage methodsFor: 'accessing' stamp: 'pc 10/24/2007 19:35'! |
| seqid: anInteger |
| seqid := anInteger! ! |
| |
| !TMessage methodsFor: 'accessing' stamp: 'pc 10/24/2007 20:06'! |
| type |
| ^ type ifNil: [0]! ! |
| |
| !TMessage methodsFor: 'accessing' stamp: 'pc 10/24/2007 19:35'! |
| type: anInteger |
| type := anInteger! ! |
| |
| Object subclass: #TProtocol |
| instanceVariableNames: 'transport' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Thrift-Protocol'! |
| |
| TProtocol subclass: #TBinaryProtocol |
| instanceVariableNames: '' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Thrift-Protocol'! |
| |
| !TBinaryProtocol methodsFor: 'reading' stamp: 'pc 11/1/2007 04:24'! |
| intFromByteArray: buf |
| | vals | |
| vals := Array new: buf size. |
| 1 to: buf size do: [:n | vals at: n put: ((buf at: n) bitShift: (buf size - n) * 8)]. |
| ^ vals sum! ! |
| |
| !TBinaryProtocol methodsFor: 'reading' stamp: 'pc 10/24/2007 18:46'! |
| readBool |
| ^ self readByte isZero not! ! |
| |
| !TBinaryProtocol methodsFor: 'reading' stamp: 'pc 10/25/2007 00:02'! |
| readByte |
| ^ (self transport read: 1) first! ! |
| |
| !TBinaryProtocol methodsFor: 'reading' stamp: 'pc 10/28/2007 16:24'! |
| readDouble |
| | val | |
| val := Float new: 2. |
| ^ val basicAt: 1 put: (self readRawInt: 4); |
| basicAt: 2 put: (self readRawInt: 4); |
| yourself! ! |
| |
| !TBinaryProtocol methodsFor: 'reading' stamp: 'pc 10/24/2007 20:02'! |
| readFieldBegin |
| | field | |
| field := TField new type: self readByte. |
| |
| ^ field type = TType stop |
| ifTrue: [field] |
| ifFalse: [field id: self readI16; yourself]! ! |
| |
| !TBinaryProtocol methodsFor: 'reading' stamp: 'pc 10/24/2007 19:15'! |
| readI16 |
| ^ self readInt: 2! ! |
| |
| !TBinaryProtocol methodsFor: 'reading' stamp: 'pc 10/24/2007 19:20'! |
| readI32 |
| ^ self readInt: 4! ! |
| |
| !TBinaryProtocol methodsFor: 'reading' stamp: 'pc 10/24/2007 19:20'! |
| readI64 |
| ^ self readInt: 8! ! |
| |
| !TBinaryProtocol methodsFor: 'reading' stamp: 'pc 11/1/2007 02:35'! |
| readInt: size |
| | buf val | |
| buf := transport read: size. |
| val := self intFromByteArray: buf. |
| ^ buf first > 16r7F |
| ifTrue: [self unsignedInt: val size: size] |
| ifFalse: [val]! ! |
| |
| !TBinaryProtocol methodsFor: 'reading' stamp: 'pc 10/24/2007 19:57'! |
| readListBegin |
| ^ TList new |
| elemType: self readByte; |
| size: self readI32! ! |
| |
| !TBinaryProtocol methodsFor: 'reading' stamp: 'pc 10/24/2007 19:58'! |
| readMapBegin |
| ^ TMap new |
| keyType: self readByte; |
| valueType: self readByte; |
| size: self readI32! ! |
| |
| !TBinaryProtocol methodsFor: 'reading' stamp: 'pc 11/1/2007 04:22'! |
| readMessageBegin |
| | version | |
| version := self readI32. |
| |
| (version bitAnd: self versionMask) = self version1 |
| ifFalse: [TProtocolError signalWithCode: TProtocolError badVersion]. |
| |
| ^ TMessage new |
| type: (version bitAnd: 16r000000FF); |
| name: self readString; |
| seqid: self readI32! ! |
| |
| !TBinaryProtocol methodsFor: 'reading' stamp: 'pc 10/28/2007 16:24'! |
| readRawInt: size |
| ^ self intFromByteArray: (transport read: size)! ! |
| |
| !TBinaryProtocol methodsFor: 'reading' stamp: 'pc 11/1/2007 00:59'! |
| readSetBegin |
| "element type, size" |
| ^ TSet new |
| elemType: self readByte; |
| size: self readI32! ! |
| |
| !TBinaryProtocol methodsFor: 'reading' stamp: 'pc 10/26/2007 04:48'! |
| readString |
| ^ (transport read: self readI32) asString! ! |
| |
| !TBinaryProtocol methodsFor: 'reading' stamp: 'pc 11/1/2007 04:22'! |
| unsignedInt: val size: size |
| ^ 0 - ((val - 1) bitXor: ((2 raisedTo: (size * 8)) - 1))! ! |
| |
| !TBinaryProtocol methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 22:13'! |
| version1 |
| ^ 16r80010000 ! ! |
| |
| !TBinaryProtocol methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 18:01'! |
| versionMask |
| ^ 16rFFFF0000! ! |
| |
| !TBinaryProtocol methodsFor: 'writing' stamp: 'pc 10/24/2007 18:35'! |
| write: aString |
| transport write: aString! ! |
| |
| !TBinaryProtocol methodsFor: 'writing' stamp: 'pc 10/24/2007 19:23'! |
| writeBool: bool |
| bool ifTrue: [self writeByte: 1] |
| ifFalse: [self writeByte: 0]! ! |
| |
| !TBinaryProtocol methodsFor: 'writing' stamp: 'pc 10/26/2007 09:31'! |
| writeByte: aNumber |
| aNumber > 16rFF ifTrue: [TError signal: 'writeByte too big']. |
| transport write: (Array with: aNumber)! ! |
| |
| !TBinaryProtocol methodsFor: 'writing' stamp: 'pc 10/28/2007 16:16'! |
| writeDouble: aDouble |
| self writeI32: (aDouble basicAt: 1); |
| writeI32: (aDouble basicAt: 2)! ! |
| |
| !TBinaryProtocol methodsFor: 'writing' stamp: 'pc 10/24/2007 19:56'! |
| writeField: aField |
| self writeByte: aField type; |
| writeI16: aField id! ! |
| |
| !TBinaryProtocol methodsFor: 'writing' stamp: 'pc 10/25/2007 00:01'! |
| writeFieldBegin: aField |
| self writeByte: aField type. |
| self writeI16: aField id! ! |
| |
| !TBinaryProtocol methodsFor: 'writing' stamp: 'pc 10/24/2007 18:04'! |
| writeFieldStop |
| self writeByte: TType stop! ! |
| |
| !TBinaryProtocol methodsFor: 'writing' stamp: 'pc 11/1/2007 02:06'! |
| writeI16: i16 |
| self writeInt: i16 size: 2! ! |
| |
| !TBinaryProtocol methodsFor: 'writing' stamp: 'pc 11/1/2007 02:06'! |
| writeI32: i32 |
| self writeInt: i32 size: 4! ! |
| |
| !TBinaryProtocol methodsFor: 'writing' stamp: 'pc 11/1/2007 02:06'! |
| writeI64: i64 |
| self writeInt: i64 size: 8! ! |
| |
| !TBinaryProtocol methodsFor: 'writing' stamp: 'pc 11/1/2007 04:23'! |
| writeInt: val size: size |
| 1 to: size do: [:n | self writeByte: ((val bitShift: (size negated + n) * 8) bitAnd: 16rFF)]! ! |
| |
| !TBinaryProtocol methodsFor: 'writing' stamp: 'pc 11/1/2007 00:48'! |
| writeListBegin: aList |
| self writeByte: aList elemType; writeI32: aList size! ! |
| |
| !TBinaryProtocol methodsFor: 'writing' stamp: 'pc 10/24/2007 19:55'! |
| writeMapBegin: aMap |
| self writeByte: aMap keyType; |
| writeByte: aMap valueType; |
| writeI32: aMap size! ! |
| |
| !TBinaryProtocol methodsFor: 'writing' stamp: 'pc 10/24/2007 20:36'! |
| writeMessageBegin: msg |
| self writeI32: (self version1 bitOr: msg type); |
| writeString: msg name; |
| writeI32: msg seqid! ! |
| |
| !TBinaryProtocol methodsFor: 'writing' stamp: 'pc 11/1/2007 00:56'! |
| writeSetBegin: aSet |
| self writeByte: aSet elemType; writeI32: aSet size! ! |
| |
| !TBinaryProtocol methodsFor: 'writing' stamp: 'pc 10/24/2007 18:35'! |
| writeString: aString |
| self writeI32: aString size; |
| write: aString! ! |
| |
| !TProtocol methodsFor: 'reading' stamp: 'pc 10/24/2007 19:40'! |
| readBool! ! |
| |
| !TProtocol methodsFor: 'reading' stamp: 'pc 10/24/2007 19:40'! |
| readByte! ! |
| |
| !TProtocol methodsFor: 'reading' stamp: 'pc 10/24/2007 19:40'! |
| readDouble! ! |
| |
| !TProtocol methodsFor: 'reading' stamp: 'pc 10/24/2007 19:40'! |
| readFieldBegin! ! |
| |
| !TProtocol methodsFor: 'reading' stamp: 'pc 10/24/2007 19:40'! |
| readFieldEnd! ! |
| |
| !TProtocol methodsFor: 'reading' stamp: 'pc 10/24/2007 19:40'! |
| readI16! ! |
| |
| !TProtocol methodsFor: 'reading' stamp: 'pc 10/24/2007 19:40'! |
| readI32! ! |
| |
| !TProtocol methodsFor: 'reading' stamp: 'pc 10/24/2007 19:40'! |
| readI64! ! |
| |
| !TProtocol methodsFor: 'reading' stamp: 'pc 10/24/2007 19:40'! |
| readListBegin! ! |
| |
| !TProtocol methodsFor: 'reading' stamp: 'pc 10/24/2007 19:40'! |
| readListEnd! ! |
| |
| !TProtocol methodsFor: 'reading' stamp: 'pc 10/24/2007 19:40'! |
| readMapBegin! ! |
| |
| !TProtocol methodsFor: 'reading' stamp: 'pc 10/24/2007 19:40'! |
| readMapEnd! ! |
| |
| !TProtocol methodsFor: 'reading' stamp: 'pc 10/24/2007 19:39'! |
| readMessageBegin! ! |
| |
| !TProtocol methodsFor: 'reading' stamp: 'pc 10/24/2007 19:39'! |
| readMessageEnd! ! |
| |
| !TProtocol methodsFor: 'reading' stamp: 'pc 10/24/2007 19:40'! |
| readSetBegin! ! |
| |
| !TProtocol methodsFor: 'reading' stamp: 'pc 10/24/2007 19:40'! |
| readSetEnd! ! |
| |
| !TProtocol methodsFor: 'reading' stamp: 'pc 10/25/2007 16:10'! |
| readSimpleType: aType |
| aType = TType bool ifTrue: [^ self readBool]. |
| aType = TType byte ifTrue: [^ self readByte]. |
| aType = TType double ifTrue: [^ self readDouble]. |
| aType = TType i16 ifTrue: [^ self readI16]. |
| aType = TType i32 ifTrue: [^ self readI32]. |
| aType = TType i64 ifTrue: [^ self readI64]. |
| aType = TType list ifTrue: [^ self readBool].! ! |
| |
| !TProtocol methodsFor: 'reading' stamp: 'pc 10/24/2007 19:40'! |
| readString! ! |
| |
| !TProtocol methodsFor: 'reading' stamp: 'pc 10/24/2007 19:40'! |
| readStructBegin |
| ! ! |
| |
| !TProtocol methodsFor: 'reading' stamp: 'pc 10/24/2007 19:40'! |
| readStructEnd! ! |
| |
| !TProtocol methodsFor: 'reading' stamp: 'pc 10/26/2007 21:34'! |
| skip: aType |
| aType = TType stop ifTrue: [^ self]. |
| aType = TType bool ifTrue: [^ self readBool]. |
| aType = TType byte ifTrue: [^ self readByte]. |
| aType = TType i16 ifTrue: [^ self readI16]. |
| aType = TType i32 ifTrue: [^ self readI32]. |
| aType = TType i64 ifTrue: [^ self readI64]. |
| aType = TType string ifTrue: [^ self readString]. |
| aType = TType double ifTrue: [^ self readDouble]. |
| aType = TType struct ifTrue: |
| [| field | |
| self readStructBegin. |
| [(field := self readFieldBegin) type = TType stop] whileFalse: |
| [self skip: field type. self readFieldEnd]. |
| ^ self readStructEnd]. |
| aType = TType map ifTrue: |
| [| map | |
| map := self readMapBegin. |
| map size timesRepeat: [self skip: map keyType. self skip: map valueType]. |
| ^ self readMapEnd]. |
| aType = TType list ifTrue: |
| [| list | |
| list := self readListBegin. |
| list size timesRepeat: [self skip: list elemType]. |
| ^ self readListEnd]. |
| aType = TType set ifTrue: |
| [| set | |
| set := self readSetBegin. |
| set size timesRepeat: [self skip: set elemType]. |
| ^ self readSetEnd]. |
| |
| self error: 'Unknown type'! ! |
| |
| !TProtocol methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 23:02'! |
| transport |
| ^ transport! ! |
| |
| !TProtocol methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 17:28'! |
| transport: aTransport |
| transport := aTransport! ! |
| |
| !TProtocol methodsFor: 'writing' stamp: 'pc 10/24/2007 19:37'! |
| writeBool: aBool! ! |
| |
| !TProtocol methodsFor: 'writing' stamp: 'pc 10/24/2007 19:37'! |
| writeByte: aByte! ! |
| |
| !TProtocol methodsFor: 'writing' stamp: 'pc 10/24/2007 19:38'! |
| writeDouble: aFloat! ! |
| |
| !TProtocol methodsFor: 'writing' stamp: 'pc 10/24/2007 19:38'! |
| writeFieldBegin: aField! ! |
| |
| !TProtocol methodsFor: 'writing' stamp: 'pc 10/24/2007 19:37'! |
| writeFieldEnd! ! |
| |
| !TProtocol methodsFor: 'writing' stamp: 'pc 10/24/2007 19:37'! |
| writeFieldStop! ! |
| |
| !TProtocol methodsFor: 'writing' stamp: 'pc 10/24/2007 19:37'! |
| writeI16: i16! ! |
| |
| !TProtocol methodsFor: 'writing' stamp: 'pc 10/24/2007 19:37'! |
| writeI32: i32! ! |
| |
| !TProtocol methodsFor: 'writing' stamp: 'pc 10/24/2007 19:37'! |
| writeI64: i64! ! |
| |
| !TProtocol methodsFor: 'writing' stamp: 'pc 10/24/2007 19:39'! |
| writeListBegin: aList! ! |
| |
| !TProtocol methodsFor: 'writing' stamp: 'pc 10/24/2007 19:37'! |
| writeListEnd! ! |
| |
| !TProtocol methodsFor: 'writing' stamp: 'pc 10/24/2007 19:39'! |
| writeMapBegin: aMap! ! |
| |
| !TProtocol methodsFor: 'writing' stamp: 'pc 10/24/2007 19:37'! |
| writeMapEnd! ! |
| |
| !TProtocol methodsFor: 'writing' stamp: 'pc 10/24/2007 19:36'! |
| writeMessageBegin! ! |
| |
| !TProtocol methodsFor: 'writing' stamp: 'pc 10/24/2007 19:36'! |
| writeMessageEnd! ! |
| |
| !TProtocol methodsFor: 'writing' stamp: 'pc 10/24/2007 19:39'! |
| writeSetBegin: aSet! ! |
| |
| !TProtocol methodsFor: 'writing' stamp: 'pc 10/24/2007 19:37'! |
| writeSetEnd! ! |
| |
| !TProtocol methodsFor: 'writing' stamp: 'pc 10/24/2007 19:38'! |
| writeString: aString! ! |
| |
| !TProtocol methodsFor: 'writing' stamp: 'pc 10/24/2007 19:38'! |
| writeStructBegin: aStruct! ! |
| |
| !TProtocol methodsFor: 'writing' stamp: 'pc 10/24/2007 19:37'! |
| writeStructEnd! ! |
| |
| Object subclass: #TResult |
| instanceVariableNames: 'success oprot iprot exception' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Thrift'! |
| |
| !TResult methodsFor: 'as yet unclassified' stamp: 'pc 10/26/2007 21:35'! |
| exception |
| ^ exception! ! |
| |
| !TResult methodsFor: 'as yet unclassified' stamp: 'pc 10/26/2007 21:35'! |
| exception: anError |
| exception := anError! ! |
| |
| !TResult methodsFor: 'as yet unclassified' stamp: 'pc 10/26/2007 14:43'! |
| success |
| ^ success! ! |
| |
| !TResult methodsFor: 'as yet unclassified' stamp: 'pc 10/26/2007 14:43'! |
| success: anObject |
| success := anObject! ! |
| |
| Object subclass: #TSizedObject |
| instanceVariableNames: 'size' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Thrift-Protocol'! |
| |
| TSizedObject subclass: #TList |
| instanceVariableNames: 'elemType' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Thrift-Protocol'! |
| |
| !TList methodsFor: 'accessing' stamp: 'pc 10/24/2007 20:04'! |
| elemType |
| ^ elemType ifNil: [TType stop]! ! |
| |
| !TList methodsFor: 'accessing' stamp: 'pc 10/24/2007 19:42'! |
| elemType: anInteger |
| elemType := anInteger! ! |
| |
| TList subclass: #TSet |
| instanceVariableNames: '' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Thrift-Protocol'! |
| |
| TSizedObject subclass: #TMap |
| instanceVariableNames: 'keyType valueType' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Thrift-Protocol'! |
| |
| !TMap methodsFor: 'accessing' stamp: 'pc 10/24/2007 20:04'! |
| keyType |
| ^ keyType ifNil: [TType stop]! ! |
| |
| !TMap methodsFor: 'accessing' stamp: 'pc 10/24/2007 19:45'! |
| keyType: anInteger |
| keyType := anInteger! ! |
| |
| !TMap methodsFor: 'accessing' stamp: 'pc 10/24/2007 20:04'! |
| valueType |
| ^ valueType ifNil: [TType stop]! ! |
| |
| !TMap methodsFor: 'accessing' stamp: 'pc 10/24/2007 19:45'! |
| valueType: anInteger |
| valueType := anInteger! ! |
| |
| !TSizedObject methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 20:03'! |
| size |
| ^ size ifNil: [0]! ! |
| |
| !TSizedObject methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 20:06'! |
| size: anInteger |
| size := anInteger! ! |
| |
| Object subclass: #TSocket |
| instanceVariableNames: 'host port stream' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Thrift-Transport'! |
| |
| !TSocket methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 22:34'! |
| close |
| self isOpen ifTrue: [stream close]! ! |
| |
| !TSocket methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 22:23'! |
| connect |
| ^ (self socketStream openConnectionToHost: |
| (NetNameResolver addressForName: host) port: port) |
| timeout: 180; |
| binary; |
| yourself! ! |
| |
| !TSocket methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 20:35'! |
| flush |
| stream flush! ! |
| |
| !TSocket methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 17:08'! |
| host: aString |
| host := aString! ! |
| |
| !TSocket methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 20:34'! |
| isOpen |
| ^ stream isNil not |
| and: [stream socket isConnected] |
| and: [stream socket isOtherEndClosed not]! ! |
| |
| !TSocket methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 22:22'! |
| open |
| stream := self connect! ! |
| |
| !TSocket methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 17:09'! |
| port: anInteger |
| port := anInteger! ! |
| |
| !TSocket methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 17:17'! |
| read: size |
| | data | |
| [data := stream next: size. |
| data isEmpty ifTrue: [TTransportError signal: 'Could not read ', size asString, ' bytes']. |
| ^ data] |
| on: ConnectionClosed |
| do: [TTransportClosedError signal]! ! |
| |
| !TSocket methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 22:18'! |
| socketStream |
| ^ Smalltalk at: #FastSocketStream ifAbsent: [SocketStream] ! ! |
| |
| !TSocket methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 22:17'! |
| write: aCollection |
| [stream nextPutAll: aCollection] |
| on: ConnectionClosed |
| do: [TTransportClosedError signal]! ! |
| |
| Object subclass: #TStruct |
| instanceVariableNames: 'name' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Thrift-Protocol'! |
| |
| !TStruct methodsFor: 'accessing' stamp: 'pc 10/24/2007 19:47'! |
| name |
| ^ name! ! |
| |
| !TStruct methodsFor: 'accessing' stamp: 'pc 10/24/2007 19:47'! |
| name: aString |
| name := aString! ! |
| |
| Object subclass: #TTest |
| instanceVariableNames: 'prot' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Thrift-Test'! |
| |
| !TTest methodsFor: 'as yet unclassified' stamp: 'pc 11/1/2007 04:47'! |
| protocol: aProtocol |
| prot := aProtocol! ! |
| |
| !TTest methodsFor: 'as yet unclassified' stamp: 'pc 11/1/2007 04:49'! |
| runAll |
| | c | |
| c := ThriftTestClient new inProtocol: prot. |
| c testByteThing: 32. |
| c testDoubleThing: -1.0. |
| c testEnumThing: 1. |
| c testExceptionArg: 'foo'. |
| c testI16Thing: 16. |
| c testI16Thing: -16. |
| c testI32Thing: 32. |
| c testI32Thing: -32. |
| c testI64Thing: 123. |
| c testDoubleThing: 1.2. |
| c testStructThing: (Xtruct new byteThing: 1; i32Thing: 2; i64Thing: 3; stringThing: 'foo'). |
| c testSetThing: (Set new). |
| c testListThing: (OrderedCollection new). |
| c testEnumThing: 1. |
| c testInsanityArgument: |
| (Insanity new |
| userMap: (Dictionary new at: 1 put: 2; yourself); |
| xtructs: (OrderedCollection new)). |
| c testMultiArg0: 1 arg1: 2 arg2: 3 arg3: (Dictionary new) arg4: ((ThriftTest enums at: 'Numberz') at: 'FIVE') arg5: 6. |
| c testExceptionArg: 'Xception'. |
| c testMultiExceptionArg0: 'Xception' arg1: 'Xception2'! ! |
| |
| Object subclass: #TTransport |
| instanceVariableNames: '' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Thrift-Transport'! |
| |
| !TTransport methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 17:18'! |
| close |
| self subclassResponsibility! ! |
| |
| !TTransport methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 17:22'! |
| flush |
| self subclassResponsibility! ! |
| |
| !TTransport methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 17:18'! |
| isOpen |
| self subclassResponsibility! ! |
| |
| !TTransport methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 17:18'! |
| open |
| self subclassResponsibility! ! |
| |
| !TTransport methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 17:18'! |
| read: anInteger |
| self subclassResponsibility! ! |
| |
| !TTransport methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 17:22'! |
| readAll: anInteger |
| ^ String streamContents: [:str | |
| [str size < anInteger] whileTrue: |
| [str nextPutAll: (self read: anInteger - str size)]]! ! |
| |
| !TTransport methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 17:22'! |
| write: aString |
| self subclassResponsibility! ! |
| |
| Object subclass: #TType |
| instanceVariableNames: '' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Thrift'! |
| |
| !TType class methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 17:03'! |
| bool |
| ^ 2! ! |
| |
| !TType class methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 17:03'! |
| byte |
| ^ 3! ! |
| |
| !TType class methodsFor: 'as yet unclassified' stamp: 'pc 10/25/2007 15:55'! |
| codeOf: aTypeName |
| self typeMap do: [:each | each first = aTypeName ifTrue: [^ each second]]. |
| ^ nil! ! |
| |
| !TType class methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 17:03'! |
| double |
| ^ 4! ! |
| |
| !TType class methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 17:04'! |
| i16 |
| ^ 6! ! |
| |
| !TType class methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 17:04'! |
| i32 |
| ^ 8! ! |
| |
| !TType class methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 17:04'! |
| i64 |
| ^ 10! ! |
| |
| !TType class methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 17:04'! |
| list |
| ^ 15! ! |
| |
| !TType class methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 17:04'! |
| map |
| ^ 13! ! |
| |
| !TType class methodsFor: 'as yet unclassified' stamp: 'pc 10/25/2007 15:56'! |
| nameOf: aTypeCode |
| self typeMap do: [:each | each second = aTypeCode ifTrue: [^ each first]]. |
| ^ nil! ! |
| |
| !TType class methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 17:04'! |
| set |
| ^ 14! ! |
| |
| !TType class methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 17:03'! |
| stop |
| ^ 0! ! |
| |
| !TType class methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 17:04'! |
| string |
| ^ 11! ! |
| |
| !TType class methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 17:04'! |
| struct |
| ^ 12! ! |
| |
| !TType class methodsFor: 'as yet unclassified' stamp: 'pc 10/25/2007 15:51'! |
| typeMap |
| ^ #((bool 2) (byte 3) (double 4) (i16 6) (i32 8) (i64 10) (list 15) |
| (map 13) (set 15) (stop 0) (string 11) (struct 12) (void 1))! ! |
| |
| !TType class methodsFor: 'as yet unclassified' stamp: 'pc 10/24/2007 17:03'! |
| void |
| ^ 1! ! |
| |
| Object subclass: #Xtruct |
| instanceVariableNames: 'stringThing byteThing i32Thing i64Thing' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Thrift-Test'! |
| |
| !Xtruct methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| byteThing |
| ^ byteThing! ! |
| |
| !Xtruct methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| byteThing: aByte |
| byteThing := aByte! ! |
| |
| !Xtruct methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| i32Thing |
| ^ i32Thing! ! |
| |
| !Xtruct methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| i32Thing: anI32 |
| i32Thing := anI32! ! |
| |
| !Xtruct methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| i64Thing |
| ^ i64Thing! ! |
| |
| !Xtruct methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| i64Thing: anI64 |
| i64Thing := anI64! ! |
| |
| !Xtruct methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| stringThing |
| ^ stringThing! ! |
| |
| !Xtruct methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| stringThing: aString |
| stringThing := aString! ! |
| |
| Object subclass: #Xtruct2 |
| instanceVariableNames: 'byteThing structThing i32Thing' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Thrift-Test'! |
| |
| !Xtruct2 methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| byteThing |
| ^ byteThing! ! |
| |
| !Xtruct2 methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| byteThing: aByte |
| byteThing := aByte! ! |
| |
| !Xtruct2 methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| i32Thing |
| ^ i32Thing! ! |
| |
| !Xtruct2 methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| i32Thing: anI32 |
| i32Thing := anI32! ! |
| |
| !Xtruct2 methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| structThing |
| ^ structThing! ! |
| |
| !Xtruct2 methodsFor: 'as yet uncategorized' stamp: 'thrift 11/01/2007 04:43'! |
| structThing: aXtruct |
| structThing := aXtruct! ! |