| 'Autogenerated by Thrift |
| |
| DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING |
| '! |
| |
| Object subclass: #Hadoopfs |
| instanceVariableNames: '' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Generated-Hadoopfs'! |
| |
| Hadoopfs class |
| instanceVariableNames: 'constants enums'! |
| |
| !Hadoopfs class methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| enums: anObject |
| enums := anObject! ! |
| |
| !Hadoopfs class methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| enums |
| ^ enums! ! |
| |
| !Hadoopfs class methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| constants: anObject |
| constants := anObject! ! |
| |
| !Hadoopfs class methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| constants |
| ^ constants! ! |
| |
| Hadoopfs enums: Dictionary new! |
| Hadoopfs constants: Dictionary new! |
| |
| Object subclass: #ThriftHandle |
| instanceVariableNames: 'id' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Generated-Hadoopfs'! |
| |
| !ThriftHandle methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| id: anI64 |
| id := anI64! ! |
| |
| !ThriftHandle methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| id |
| ^ id! ! |
| |
| |
| Object subclass: #Pathname |
| instanceVariableNames: 'pathname' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Generated-Hadoopfs'! |
| |
| !Pathname methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| pathname: aString |
| pathname := aString! ! |
| |
| !Pathname methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| pathname |
| ^ pathname! ! |
| |
| |
| Object subclass: #FileStatus |
| instanceVariableNames: 'path length isdir blockReplication blocksize modificationTime permission owner group' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Generated-Hadoopfs'! |
| |
| !FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| path: aString |
| path := aString! ! |
| |
| !FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| path |
| ^ path! ! |
| |
| !FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| length: anI64 |
| length := anI64! ! |
| |
| !FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| length |
| ^ length! ! |
| |
| !FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| isdir: aBool |
| isdir := aBool! ! |
| |
| !FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| isdir |
| ^ isdir! ! |
| |
| !FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| blockReplication: anI16 |
| blockReplication := anI16! ! |
| |
| !FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| blockReplication |
| ^ blockReplication! ! |
| |
| !FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| blocksize: anI64 |
| blocksize := anI64! ! |
| |
| !FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| blocksize |
| ^ blocksize! ! |
| |
| !FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| modificationTime: anI64 |
| modificationTime := anI64! ! |
| |
| !FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| modificationTime |
| ^ modificationTime! ! |
| |
| !FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| permission: aString |
| permission := aString! ! |
| |
| !FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| permission |
| ^ permission! ! |
| |
| !FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| owner: aString |
| owner := aString! ! |
| |
| !FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| owner |
| ^ owner! ! |
| |
| !FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| group: aString |
| group := aString! ! |
| |
| !FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| group |
| ^ group! ! |
| |
| |
| Object subclass: #BlockLocation |
| instanceVariableNames: 'hosts names offset length' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Generated-Hadoopfs'! |
| |
| !BlockLocation methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| hosts: a |
| hosts := a! ! |
| |
| !BlockLocation methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| hosts |
| ^ hosts! ! |
| |
| !BlockLocation methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| names: a |
| names := a! ! |
| |
| !BlockLocation methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| names |
| ^ names! ! |
| |
| !BlockLocation methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| offset: anI64 |
| offset := anI64! ! |
| |
| !BlockLocation methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| offset |
| ^ offset! ! |
| |
| !BlockLocation methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| length: anI64 |
| length := anI64! ! |
| |
| !BlockLocation methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| length |
| ^ length! ! |
| |
| |
| Error subclass: #MalformedInputException |
| instanceVariableNames: 'message' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Generated-Hadoopfs'! |
| |
| !MalformedInputException methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| message: aString |
| message := aString! ! |
| |
| !MalformedInputException methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| message |
| ^ message! ! |
| |
| |
| Error subclass: #ThriftIOException |
| instanceVariableNames: 'message' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Generated-Hadoopfs'! |
| |
| !ThriftIOException methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| message: aString |
| message := aString! ! |
| |
| !ThriftIOException methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| message |
| ^ message! ! |
| |
| |
| TClient subclass: #ThriftHadoopFileSystemClient |
| instanceVariableNames: '' |
| classVariableNames: '' |
| poolDictionaries: '' |
| category: 'Generated-Hadoopfs'! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| setInactivityTimeoutPeriodPeriodInSeconds: periodInSeconds |
| "periodInSeconds: i64" |
| self sendSetInactivityTimeoutPeriodPeriodInSeconds: periodInSeconds. |
| ^ self recvSetInactivityTimeoutPeriod success |
| ! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| sendSetInactivityTimeoutPeriodPeriodInSeconds: periodInSeconds |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'setInactivityTimeoutPeriod'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'SetInactivityTimeoutPeriod_args'). |
| oprot writeFieldBegin: (TField new name: 'periodInSeconds'; type: TType i64; id: 1). |
| iprot writeI64: periodInSeconds asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| recvSetInactivityTimeoutPeriod |
| | 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! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| shutdownStatus: status |
| "status: i32" |
| self sendShutdownStatus: status. |
| ^ self recvShutdown success |
| ! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| sendShutdownStatus: status |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'shutdown'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'Shutdown_args'). |
| oprot writeFieldBegin: (TField new name: 'status'; type: TType i32; id: 1). |
| iprot writeI32: status asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| recvShutdown |
| | 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 readVoid]. |
| temp5 ifNil: [iprot skip: temp4 type]]. |
| oprot readStructEnd. |
| temp3] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| createPath: path |
| "path: Pathname" |
| self sendCreatePath: path. |
| ^ self recvCreate success |
| ! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| sendCreatePath: path |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'create'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'Create_args'). |
| oprot writeFieldBegin: (TField new name: 'path'; type: TType struct; id: 1). |
| [oprot writeStructBegin: (TStruct new name: 'Pathname'). |
| oprot writeFieldBegin: (TField new name: 'pathname'; type: TType string; id: -1). |
| iprot writeString: path pathname. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd] value. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| recvCreate |
| | 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: [|temp10 temp9| |
| temp9 := ThriftHandle new. |
| iprot readStructBegin. |
| [temp10 := iprot readFieldBegin. |
| temp10 type = TType stop] whileFalse: [|temp11| |
| temp10 id = -1 ifTrue: [ |
| temp11 := true. |
| temp9 id: iprot readI64]. |
| temp11 ifNil: [iprot skip: temp10 type]]. |
| oprot readStructEnd. |
| temp9] value]. |
| temp7 id = 1 ifTrue: [ |
| temp8 := true. |
| temp6 exception: [|temp13 temp12| |
| temp12 := ThriftIOException new. |
| iprot readStructBegin. |
| [temp13 := iprot readFieldBegin. |
| temp13 type = TType stop] whileFalse: [|temp14| |
| temp13 id = -1 ifTrue: [ |
| temp14 := true. |
| temp12 message: iprot readString]. |
| temp14 ifNil: [iprot skip: temp13 type]]. |
| oprot readStructEnd. |
| temp12] value]. |
| temp8 ifNil: [iprot skip: temp7 type]]. |
| oprot readStructEnd. |
| temp6] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| createFilePath: path mode: mode overwrite: overwrite bufferSize: bufferSize block_replication: block_replication blocksize: blocksize |
| "path: Pathname, mode: i16, overwrite: bool, bufferSize: i32, block_replication: i16, blocksize: i64" |
| self sendCreateFilePath: path mode: mode overwrite: overwrite bufferSize: bufferSize block_replication: block_replication blocksize: blocksize. |
| ^ self recvCreateFile success |
| ! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| sendCreateFilePath: path mode: mode overwrite: overwrite bufferSize: bufferSize block_replication: block_replication blocksize: blocksize |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'createFile'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'CreateFile_args'). |
| oprot writeFieldBegin: (TField new name: 'path'; type: TType struct; id: 1). |
| [oprot writeStructBegin: (TStruct new name: 'Pathname'). |
| oprot writeFieldBegin: (TField new name: 'pathname'; type: TType string; id: -1). |
| iprot writeString: path pathname. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd] value. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'mode'; type: TType i16; id: 2). |
| iprot writeI16: mode asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'overwrite'; type: TType bool; id: 3). |
| iprot writeBool: overwrite. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'bufferSize'; type: TType i32; id: 4). |
| iprot writeI32: bufferSize asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'block_replication'; type: TType i16; id: 5). |
| iprot writeI16: block_replication asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'blocksize'; type: TType i64; id: 6). |
| iprot writeI64: blocksize asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| recvCreateFile |
| | 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: [|temp19 temp18| |
| temp18 := ThriftHandle new. |
| iprot readStructBegin. |
| [temp19 := iprot readFieldBegin. |
| temp19 type = TType stop] whileFalse: [|temp20| |
| temp19 id = -1 ifTrue: [ |
| temp20 := true. |
| temp18 id: iprot readI64]. |
| temp20 ifNil: [iprot skip: temp19 type]]. |
| oprot readStructEnd. |
| temp18] value]. |
| temp16 id = 1 ifTrue: [ |
| temp17 := true. |
| temp15 exception: [|temp22 temp21| |
| temp21 := ThriftIOException new. |
| iprot readStructBegin. |
| [temp22 := iprot readFieldBegin. |
| temp22 type = TType stop] whileFalse: [|temp23| |
| temp22 id = -1 ifTrue: [ |
| temp23 := true. |
| temp21 message: iprot readString]. |
| temp23 ifNil: [iprot skip: temp22 type]]. |
| oprot readStructEnd. |
| temp21] value]. |
| temp17 ifNil: [iprot skip: temp16 type]]. |
| oprot readStructEnd. |
| temp15] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| openPath: path |
| "path: Pathname" |
| self sendOpenPath: path. |
| ^ self recvOpen success |
| ! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| sendOpenPath: path |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'open'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'Open_args'). |
| oprot writeFieldBegin: (TField new name: 'path'; type: TType struct; id: 1). |
| [oprot writeStructBegin: (TStruct new name: 'Pathname'). |
| oprot writeFieldBegin: (TField new name: 'pathname'; type: TType string; id: -1). |
| iprot writeString: path pathname. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd] value. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| recvOpen |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp25 temp24| |
| temp24 := TResult new. |
| iprot readStructBegin. |
| [temp25 := iprot readFieldBegin. |
| temp25 type = TType stop] whileFalse: [|temp26| |
| temp25 id = 0 ifTrue: [ |
| temp26 := true. |
| temp24 success: [|temp28 temp27| |
| temp27 := ThriftHandle new. |
| iprot readStructBegin. |
| [temp28 := iprot readFieldBegin. |
| temp28 type = TType stop] whileFalse: [|temp29| |
| temp28 id = -1 ifTrue: [ |
| temp29 := true. |
| temp27 id: iprot readI64]. |
| temp29 ifNil: [iprot skip: temp28 type]]. |
| oprot readStructEnd. |
| temp27] value]. |
| temp25 id = 1 ifTrue: [ |
| temp26 := true. |
| temp24 exception: [|temp31 temp30| |
| temp30 := ThriftIOException new. |
| iprot readStructBegin. |
| [temp31 := iprot readFieldBegin. |
| temp31 type = TType stop] whileFalse: [|temp32| |
| temp31 id = -1 ifTrue: [ |
| temp32 := true. |
| temp30 message: iprot readString]. |
| temp32 ifNil: [iprot skip: temp31 type]]. |
| oprot readStructEnd. |
| temp30] value]. |
| temp26 ifNil: [iprot skip: temp25 type]]. |
| oprot readStructEnd. |
| temp24] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| appendPath: path |
| "path: Pathname" |
| self sendAppendPath: path. |
| ^ self recvAppend success |
| ! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| sendAppendPath: path |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'append'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'Append_args'). |
| oprot writeFieldBegin: (TField new name: 'path'; type: TType struct; id: 1). |
| [oprot writeStructBegin: (TStruct new name: 'Pathname'). |
| oprot writeFieldBegin: (TField new name: 'pathname'; type: TType string; id: -1). |
| iprot writeString: path pathname. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd] value. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| recvAppend |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp34 temp33| |
| temp33 := TResult new. |
| iprot readStructBegin. |
| [temp34 := iprot readFieldBegin. |
| temp34 type = TType stop] whileFalse: [|temp35| |
| temp34 id = 0 ifTrue: [ |
| temp35 := true. |
| temp33 success: [|temp37 temp36| |
| temp36 := ThriftHandle new. |
| iprot readStructBegin. |
| [temp37 := iprot readFieldBegin. |
| temp37 type = TType stop] whileFalse: [|temp38| |
| temp37 id = -1 ifTrue: [ |
| temp38 := true. |
| temp36 id: iprot readI64]. |
| temp38 ifNil: [iprot skip: temp37 type]]. |
| oprot readStructEnd. |
| temp36] value]. |
| temp34 id = 1 ifTrue: [ |
| temp35 := true. |
| temp33 exception: [|temp40 temp39| |
| temp39 := ThriftIOException new. |
| iprot readStructBegin. |
| [temp40 := iprot readFieldBegin. |
| temp40 type = TType stop] whileFalse: [|temp41| |
| temp40 id = -1 ifTrue: [ |
| temp41 := true. |
| temp39 message: iprot readString]. |
| temp41 ifNil: [iprot skip: temp40 type]]. |
| oprot readStructEnd. |
| temp39] value]. |
| temp35 ifNil: [iprot skip: temp34 type]]. |
| oprot readStructEnd. |
| temp33] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| writeHandle: handle data: data |
| "handle: ThriftHandle, data: string" |
| self sendWriteHandle: handle data: data. |
| ^ self recvWrite success |
| ! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| sendWriteHandle: handle data: data |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'write'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'Write_args'). |
| oprot writeFieldBegin: (TField new name: 'handle'; type: TType struct; id: 1). |
| [oprot writeStructBegin: (TStruct new name: 'ThriftHandle'). |
| oprot writeFieldBegin: (TField new name: 'id'; type: TType i64; id: -1). |
| iprot writeI64: handle id asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd] value. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'data'; type: TType string; id: -1). |
| iprot writeString: data. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| recvWrite |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp43 temp42| |
| temp42 := TResult new. |
| iprot readStructBegin. |
| [temp43 := iprot readFieldBegin. |
| temp43 type = TType stop] whileFalse: [|temp44| |
| temp43 id = 0 ifTrue: [ |
| temp44 := true. |
| temp42 success: iprot readBool]. |
| temp43 id = 1 ifTrue: [ |
| temp44 := true. |
| temp42 exception: [|temp46 temp45| |
| temp45 := ThriftIOException new. |
| iprot readStructBegin. |
| [temp46 := iprot readFieldBegin. |
| temp46 type = TType stop] whileFalse: [|temp47| |
| temp46 id = -1 ifTrue: [ |
| temp47 := true. |
| temp45 message: iprot readString]. |
| temp47 ifNil: [iprot skip: temp46 type]]. |
| oprot readStructEnd. |
| temp45] value]. |
| temp44 ifNil: [iprot skip: temp43 type]]. |
| oprot readStructEnd. |
| temp42] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| readHandle: handle offset: offset size: size |
| "handle: ThriftHandle, offset: i64, size: i32" |
| self sendReadHandle: handle offset: offset size: size. |
| ^ self recvRead success |
| ! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| sendReadHandle: handle offset: offset size: size |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'read'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'Read_args'). |
| oprot writeFieldBegin: (TField new name: 'handle'; type: TType struct; id: 1). |
| [oprot writeStructBegin: (TStruct new name: 'ThriftHandle'). |
| oprot writeFieldBegin: (TField new name: 'id'; type: TType i64; id: -1). |
| iprot writeI64: handle id asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd] value. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'offset'; type: TType i64; id: -1). |
| iprot writeI64: offset asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'size'; type: TType i32; id: -2). |
| iprot writeI32: size asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| recvRead |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp49 temp48| |
| temp48 := TResult new. |
| iprot readStructBegin. |
| [temp49 := iprot readFieldBegin. |
| temp49 type = TType stop] whileFalse: [|temp50| |
| temp49 id = 0 ifTrue: [ |
| temp50 := true. |
| temp48 success: iprot readString]. |
| temp49 id = 1 ifTrue: [ |
| temp50 := true. |
| temp48 exception: [|temp52 temp51| |
| temp51 := ThriftIOException new. |
| iprot readStructBegin. |
| [temp52 := iprot readFieldBegin. |
| temp52 type = TType stop] whileFalse: [|temp53| |
| temp52 id = -1 ifTrue: [ |
| temp53 := true. |
| temp51 message: iprot readString]. |
| temp53 ifNil: [iprot skip: temp52 type]]. |
| oprot readStructEnd. |
| temp51] value]. |
| temp50 ifNil: [iprot skip: temp49 type]]. |
| oprot readStructEnd. |
| temp48] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| closeOut: out |
| "out: ThriftHandle" |
| self sendCloseOut: out. |
| ^ self recvClose success |
| ! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| sendCloseOut: out |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'close'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'Close_args'). |
| oprot writeFieldBegin: (TField new name: 'out'; type: TType struct; id: 1). |
| [oprot writeStructBegin: (TStruct new name: 'ThriftHandle'). |
| oprot writeFieldBegin: (TField new name: 'id'; type: TType i64; id: -1). |
| iprot writeI64: out id asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd] value. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| recvClose |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp55 temp54| |
| temp54 := TResult new. |
| iprot readStructBegin. |
| [temp55 := iprot readFieldBegin. |
| temp55 type = TType stop] whileFalse: [|temp56| |
| temp55 id = 0 ifTrue: [ |
| temp56 := true. |
| temp54 success: iprot readBool]. |
| temp55 id = 1 ifTrue: [ |
| temp56 := true. |
| temp54 exception: [|temp58 temp57| |
| temp57 := ThriftIOException new. |
| iprot readStructBegin. |
| [temp58 := iprot readFieldBegin. |
| temp58 type = TType stop] whileFalse: [|temp59| |
| temp58 id = -1 ifTrue: [ |
| temp59 := true. |
| temp57 message: iprot readString]. |
| temp59 ifNil: [iprot skip: temp58 type]]. |
| oprot readStructEnd. |
| temp57] value]. |
| temp56 ifNil: [iprot skip: temp55 type]]. |
| oprot readStructEnd. |
| temp54] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| rmPath: path recursive: recursive |
| "path: Pathname, recursive: bool" |
| self sendRmPath: path recursive: recursive. |
| ^ self recvRm success |
| ! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| sendRmPath: path recursive: recursive |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'rm'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'Rm_args'). |
| oprot writeFieldBegin: (TField new name: 'path'; type: TType struct; id: 1). |
| [oprot writeStructBegin: (TStruct new name: 'Pathname'). |
| oprot writeFieldBegin: (TField new name: 'pathname'; type: TType string; id: -1). |
| iprot writeString: path pathname. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd] value. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'recursive'; type: TType bool; id: 2). |
| iprot writeBool: recursive. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| recvRm |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp61 temp60| |
| temp60 := TResult new. |
| iprot readStructBegin. |
| [temp61 := iprot readFieldBegin. |
| temp61 type = TType stop] whileFalse: [|temp62| |
| temp61 id = 0 ifTrue: [ |
| temp62 := true. |
| temp60 success: iprot readBool]. |
| temp61 id = 1 ifTrue: [ |
| temp62 := true. |
| temp60 exception: [|temp64 temp63| |
| temp63 := ThriftIOException new. |
| iprot readStructBegin. |
| [temp64 := iprot readFieldBegin. |
| temp64 type = TType stop] whileFalse: [|temp65| |
| temp64 id = -1 ifTrue: [ |
| temp65 := true. |
| temp63 message: iprot readString]. |
| temp65 ifNil: [iprot skip: temp64 type]]. |
| oprot readStructEnd. |
| temp63] value]. |
| temp62 ifNil: [iprot skip: temp61 type]]. |
| oprot readStructEnd. |
| temp60] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| renamePath: path dest: dest |
| "path: Pathname, dest: Pathname" |
| self sendRenamePath: path dest: dest. |
| ^ self recvRename success |
| ! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| sendRenamePath: path dest: dest |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'rename'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'Rename_args'). |
| oprot writeFieldBegin: (TField new name: 'path'; type: TType struct; id: 1). |
| [oprot writeStructBegin: (TStruct new name: 'Pathname'). |
| oprot writeFieldBegin: (TField new name: 'pathname'; type: TType string; id: -1). |
| iprot writeString: path pathname. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd] value. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'dest'; type: TType struct; id: 2). |
| [oprot writeStructBegin: (TStruct new name: 'Pathname'). |
| oprot writeFieldBegin: (TField new name: 'pathname'; type: TType string; id: -1). |
| iprot writeString: dest pathname. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd] value. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| recvRename |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp67 temp66| |
| temp66 := TResult new. |
| iprot readStructBegin. |
| [temp67 := iprot readFieldBegin. |
| temp67 type = TType stop] whileFalse: [|temp68| |
| temp67 id = 0 ifTrue: [ |
| temp68 := true. |
| temp66 success: iprot readBool]. |
| temp67 id = 1 ifTrue: [ |
| temp68 := true. |
| temp66 exception: [|temp70 temp69| |
| temp69 := ThriftIOException new. |
| iprot readStructBegin. |
| [temp70 := iprot readFieldBegin. |
| temp70 type = TType stop] whileFalse: [|temp71| |
| temp70 id = -1 ifTrue: [ |
| temp71 := true. |
| temp69 message: iprot readString]. |
| temp71 ifNil: [iprot skip: temp70 type]]. |
| oprot readStructEnd. |
| temp69] value]. |
| temp68 ifNil: [iprot skip: temp67 type]]. |
| oprot readStructEnd. |
| temp66] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| mkdirsPath: path |
| "path: Pathname" |
| self sendMkdirsPath: path. |
| ^ self recvMkdirs success |
| ! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| sendMkdirsPath: path |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'mkdirs'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'Mkdirs_args'). |
| oprot writeFieldBegin: (TField new name: 'path'; type: TType struct; id: 1). |
| [oprot writeStructBegin: (TStruct new name: 'Pathname'). |
| oprot writeFieldBegin: (TField new name: 'pathname'; type: TType string; id: -1). |
| iprot writeString: path pathname. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd] value. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| recvMkdirs |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp73 temp72| |
| temp72 := TResult new. |
| iprot readStructBegin. |
| [temp73 := iprot readFieldBegin. |
| temp73 type = TType stop] whileFalse: [|temp74| |
| temp73 id = 0 ifTrue: [ |
| temp74 := true. |
| temp72 success: iprot readBool]. |
| temp73 id = 1 ifTrue: [ |
| temp74 := true. |
| temp72 exception: [|temp76 temp75| |
| temp75 := ThriftIOException new. |
| iprot readStructBegin. |
| [temp76 := iprot readFieldBegin. |
| temp76 type = TType stop] whileFalse: [|temp77| |
| temp76 id = -1 ifTrue: [ |
| temp77 := true. |
| temp75 message: iprot readString]. |
| temp77 ifNil: [iprot skip: temp76 type]]. |
| oprot readStructEnd. |
| temp75] value]. |
| temp74 ifNil: [iprot skip: temp73 type]]. |
| oprot readStructEnd. |
| temp72] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| existsPath: path |
| "path: Pathname" |
| self sendExistsPath: path. |
| ^ self recvExists success |
| ! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| sendExistsPath: path |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'exists'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'Exists_args'). |
| oprot writeFieldBegin: (TField new name: 'path'; type: TType struct; id: 1). |
| [oprot writeStructBegin: (TStruct new name: 'Pathname'). |
| oprot writeFieldBegin: (TField new name: 'pathname'; type: TType string; id: -1). |
| iprot writeString: path pathname. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd] value. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| recvExists |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp79 temp78| |
| temp78 := TResult new. |
| iprot readStructBegin. |
| [temp79 := iprot readFieldBegin. |
| temp79 type = TType stop] whileFalse: [|temp80| |
| temp79 id = 0 ifTrue: [ |
| temp80 := true. |
| temp78 success: iprot readBool]. |
| temp79 id = 1 ifTrue: [ |
| temp80 := true. |
| temp78 exception: [|temp82 temp81| |
| temp81 := ThriftIOException new. |
| iprot readStructBegin. |
| [temp82 := iprot readFieldBegin. |
| temp82 type = TType stop] whileFalse: [|temp83| |
| temp82 id = -1 ifTrue: [ |
| temp83 := true. |
| temp81 message: iprot readString]. |
| temp83 ifNil: [iprot skip: temp82 type]]. |
| oprot readStructEnd. |
| temp81] value]. |
| temp80 ifNil: [iprot skip: temp79 type]]. |
| oprot readStructEnd. |
| temp78] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| statPath: path |
| "path: Pathname" |
| self sendStatPath: path. |
| ^ self recvStat success |
| ! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| sendStatPath: path |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'stat'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'Stat_args'). |
| oprot writeFieldBegin: (TField new name: 'path'; type: TType struct; id: 1). |
| [oprot writeStructBegin: (TStruct new name: 'Pathname'). |
| oprot writeFieldBegin: (TField new name: 'pathname'; type: TType string; id: -1). |
| iprot writeString: path pathname. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd] value. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| recvStat |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp85 temp84| |
| temp84 := TResult new. |
| iprot readStructBegin. |
| [temp85 := iprot readFieldBegin. |
| temp85 type = TType stop] whileFalse: [|temp86| |
| temp85 id = 0 ifTrue: [ |
| temp86 := true. |
| temp84 success: [|temp88 temp87| |
| temp87 := FileStatus new. |
| iprot readStructBegin. |
| [temp88 := iprot readFieldBegin. |
| temp88 type = TType stop] whileFalse: [|temp89| |
| temp88 id = 1 ifTrue: [ |
| temp89 := true. |
| temp87 path: iprot readString]. |
| temp88 id = 2 ifTrue: [ |
| temp89 := true. |
| temp87 length: iprot readI64]. |
| temp88 id = 3 ifTrue: [ |
| temp89 := true. |
| temp87 isdir: iprot readBool]. |
| temp88 id = 4 ifTrue: [ |
| temp89 := true. |
| temp87 blockReplication: iprot readI16]. |
| temp88 id = 5 ifTrue: [ |
| temp89 := true. |
| temp87 blocksize: iprot readI64]. |
| temp88 id = 6 ifTrue: [ |
| temp89 := true. |
| temp87 modificationTime: iprot readI64]. |
| temp88 id = 7 ifTrue: [ |
| temp89 := true. |
| temp87 permission: iprot readString]. |
| temp88 id = 8 ifTrue: [ |
| temp89 := true. |
| temp87 owner: iprot readString]. |
| temp88 id = 9 ifTrue: [ |
| temp89 := true. |
| temp87 group: iprot readString]. |
| temp89 ifNil: [iprot skip: temp88 type]]. |
| oprot readStructEnd. |
| temp87] value]. |
| temp85 id = 1 ifTrue: [ |
| temp86 := true. |
| temp84 exception: [|temp91 temp90| |
| temp90 := ThriftIOException new. |
| iprot readStructBegin. |
| [temp91 := iprot readFieldBegin. |
| temp91 type = TType stop] whileFalse: [|temp92| |
| temp91 id = -1 ifTrue: [ |
| temp92 := true. |
| temp90 message: iprot readString]. |
| temp92 ifNil: [iprot skip: temp91 type]]. |
| oprot readStructEnd. |
| temp90] value]. |
| temp86 ifNil: [iprot skip: temp85 type]]. |
| oprot readStructEnd. |
| temp84] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| listStatusPath: path |
| "path: Pathname" |
| self sendListStatusPath: path. |
| ^ self recvListStatus success |
| ! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| sendListStatusPath: path |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'listStatus'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'ListStatus_args'). |
| oprot writeFieldBegin: (TField new name: 'path'; type: TType struct; id: 1). |
| [oprot writeStructBegin: (TStruct new name: 'Pathname'). |
| oprot writeFieldBegin: (TField new name: 'pathname'; type: TType string; id: -1). |
| iprot writeString: path pathname. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd] value. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| recvListStatus |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp94 temp93| |
| temp93 := TResult new. |
| iprot readStructBegin. |
| [temp94 := iprot readFieldBegin. |
| temp94 type = TType stop] whileFalse: [|temp95| |
| temp94 id = 0 ifTrue: [ |
| temp95 := true. |
| temp93 success: [|temp96 temp97| temp96 := iprot readListBegin. |
| temp97 := OrderedCollection new. |
| temp96 size timesRepeat: [ |
| temp97 add: [|temp99 temp98| |
| temp98 := FileStatus new. |
| iprot readStructBegin. |
| [temp99 := iprot readFieldBegin. |
| temp99 type = TType stop] whileFalse: [|temp100| |
| temp99 id = 1 ifTrue: [ |
| temp100 := true. |
| temp98 path: iprot readString]. |
| temp99 id = 2 ifTrue: [ |
| temp100 := true. |
| temp98 length: iprot readI64]. |
| temp99 id = 3 ifTrue: [ |
| temp100 := true. |
| temp98 isdir: iprot readBool]. |
| temp99 id = 4 ifTrue: [ |
| temp100 := true. |
| temp98 blockReplication: iprot readI16]. |
| temp99 id = 5 ifTrue: [ |
| temp100 := true. |
| temp98 blocksize: iprot readI64]. |
| temp99 id = 6 ifTrue: [ |
| temp100 := true. |
| temp98 modificationTime: iprot readI64]. |
| temp99 id = 7 ifTrue: [ |
| temp100 := true. |
| temp98 permission: iprot readString]. |
| temp99 id = 8 ifTrue: [ |
| temp100 := true. |
| temp98 owner: iprot readString]. |
| temp99 id = 9 ifTrue: [ |
| temp100 := true. |
| temp98 group: iprot readString]. |
| temp100 ifNil: [iprot skip: temp99 type]]. |
| oprot readStructEnd. |
| temp98] value]. |
| iprot readListEnd. |
| temp97] value]. |
| temp94 id = 1 ifTrue: [ |
| temp95 := true. |
| temp93 exception: [|temp102 temp101| |
| temp101 := ThriftIOException new. |
| iprot readStructBegin. |
| [temp102 := iprot readFieldBegin. |
| temp102 type = TType stop] whileFalse: [|temp103| |
| temp102 id = -1 ifTrue: [ |
| temp103 := true. |
| temp101 message: iprot readString]. |
| temp103 ifNil: [iprot skip: temp102 type]]. |
| oprot readStructEnd. |
| temp101] value]. |
| temp95 ifNil: [iprot skip: temp94 type]]. |
| oprot readStructEnd. |
| temp93] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| chmodPath: path mode: mode |
| "path: Pathname, mode: i16" |
| self sendChmodPath: path mode: mode. |
| ^ self recvChmod success |
| ! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| sendChmodPath: path mode: mode |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'chmod'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'Chmod_args'). |
| oprot writeFieldBegin: (TField new name: 'path'; type: TType struct; id: 1). |
| [oprot writeStructBegin: (TStruct new name: 'Pathname'). |
| oprot writeFieldBegin: (TField new name: 'pathname'; type: TType string; id: -1). |
| iprot writeString: path pathname. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd] value. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'mode'; type: TType i16; id: 2). |
| iprot writeI16: mode asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| recvChmod |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp105 temp104| |
| temp104 := TResult new. |
| iprot readStructBegin. |
| [temp105 := iprot readFieldBegin. |
| temp105 type = TType stop] whileFalse: [|temp106| |
| temp105 id = 0 ifTrue: [ |
| temp106 := true. |
| temp104 success: iprot readVoid]. |
| temp105 id = 1 ifTrue: [ |
| temp106 := true. |
| temp104 exception: [|temp108 temp107| |
| temp107 := ThriftIOException new. |
| iprot readStructBegin. |
| [temp108 := iprot readFieldBegin. |
| temp108 type = TType stop] whileFalse: [|temp109| |
| temp108 id = -1 ifTrue: [ |
| temp109 := true. |
| temp107 message: iprot readString]. |
| temp109 ifNil: [iprot skip: temp108 type]]. |
| oprot readStructEnd. |
| temp107] value]. |
| temp106 ifNil: [iprot skip: temp105 type]]. |
| oprot readStructEnd. |
| temp104] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| chownPath: path owner: owner group: group |
| "path: Pathname, owner: string, group: string" |
| self sendChownPath: path owner: owner group: group. |
| ^ self recvChown success |
| ! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| sendChownPath: path owner: owner group: group |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'chown'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'Chown_args'). |
| oprot writeFieldBegin: (TField new name: 'path'; type: TType struct; id: 1). |
| [oprot writeStructBegin: (TStruct new name: 'Pathname'). |
| oprot writeFieldBegin: (TField new name: 'pathname'; type: TType string; id: -1). |
| iprot writeString: path pathname. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd] value. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'owner'; type: TType string; id: 2). |
| iprot writeString: owner. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'group'; type: TType string; id: 3). |
| iprot writeString: group. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| recvChown |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp111 temp110| |
| temp110 := TResult new. |
| iprot readStructBegin. |
| [temp111 := iprot readFieldBegin. |
| temp111 type = TType stop] whileFalse: [|temp112| |
| temp111 id = 0 ifTrue: [ |
| temp112 := true. |
| temp110 success: iprot readVoid]. |
| temp111 id = 1 ifTrue: [ |
| temp112 := true. |
| temp110 exception: [|temp114 temp113| |
| temp113 := ThriftIOException new. |
| iprot readStructBegin. |
| [temp114 := iprot readFieldBegin. |
| temp114 type = TType stop] whileFalse: [|temp115| |
| temp114 id = -1 ifTrue: [ |
| temp115 := true. |
| temp113 message: iprot readString]. |
| temp115 ifNil: [iprot skip: temp114 type]]. |
| oprot readStructEnd. |
| temp113] value]. |
| temp112 ifNil: [iprot skip: temp111 type]]. |
| oprot readStructEnd. |
| temp110] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| setReplicationPath: path replication: replication |
| "path: Pathname, replication: i16" |
| self sendSetReplicationPath: path replication: replication. |
| ^ self recvSetReplication success |
| ! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| sendSetReplicationPath: path replication: replication |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'setReplication'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'SetReplication_args'). |
| oprot writeFieldBegin: (TField new name: 'path'; type: TType struct; id: 1). |
| [oprot writeStructBegin: (TStruct new name: 'Pathname'). |
| oprot writeFieldBegin: (TField new name: 'pathname'; type: TType string; id: -1). |
| iprot writeString: path pathname. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd] value. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'replication'; type: TType i16; id: 2). |
| iprot writeI16: replication asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| recvSetReplication |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp117 temp116| |
| temp116 := TResult new. |
| iprot readStructBegin. |
| [temp117 := iprot readFieldBegin. |
| temp117 type = TType stop] whileFalse: [|temp118| |
| temp117 id = 0 ifTrue: [ |
| temp118 := true. |
| temp116 success: iprot readVoid]. |
| temp117 id = 1 ifTrue: [ |
| temp118 := true. |
| temp116 exception: [|temp120 temp119| |
| temp119 := ThriftIOException new. |
| iprot readStructBegin. |
| [temp120 := iprot readFieldBegin. |
| temp120 type = TType stop] whileFalse: [|temp121| |
| temp120 id = -1 ifTrue: [ |
| temp121 := true. |
| temp119 message: iprot readString]. |
| temp121 ifNil: [iprot skip: temp120 type]]. |
| oprot readStructEnd. |
| temp119] value]. |
| temp118 ifNil: [iprot skip: temp117 type]]. |
| oprot readStructEnd. |
| temp116] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| getFileBlockLocationsPath: path start: start length: length |
| "path: Pathname, start: i64, length: i64" |
| self sendGetFileBlockLocationsPath: path start: start length: length. |
| ^ self recvGetFileBlockLocations success |
| ! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| sendGetFileBlockLocationsPath: path start: start length: length |
| oprot writeMessageBegin: |
| (TCallMessage new |
| name: 'getFileBlockLocations'; |
| seqid: self nextSeqid). |
| oprot writeStructBegin: (TStruct new name: 'GetFileBlockLocations_args'). |
| oprot writeFieldBegin: (TField new name: 'path'; type: TType struct; id: 1). |
| [oprot writeStructBegin: (TStruct new name: 'Pathname'). |
| oprot writeFieldBegin: (TField new name: 'pathname'; type: TType string; id: -1). |
| iprot writeString: path pathname. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd] value. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'start'; type: TType i64; id: 2). |
| iprot writeI64: start asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldBegin: (TField new name: 'length'; type: TType i64; id: 3). |
| iprot writeI64: length asInteger. |
| oprot writeFieldEnd. |
| oprot writeFieldStop; writeStructEnd; writeMessageEnd. |
| oprot transport flush! ! |
| |
| !ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'! |
| recvGetFileBlockLocations |
| | f msg res | |
| msg := oprot readMessageBegin. |
| self validateRemoteMessage: msg. |
| res := [|temp123 temp122| |
| temp122 := TResult new. |
| iprot readStructBegin. |
| [temp123 := iprot readFieldBegin. |
| temp123 type = TType stop] whileFalse: [|temp124| |
| temp123 id = 0 ifTrue: [ |
| temp124 := true. |
| temp122 success: [|temp125 temp126| temp125 := iprot readListBegin. |
| temp126 := OrderedCollection new. |
| temp125 size timesRepeat: [ |
| temp126 add: [|temp128 temp127| |
| temp127 := BlockLocation new. |
| iprot readStructBegin. |
| [temp128 := iprot readFieldBegin. |
| temp128 type = TType stop] whileFalse: [|temp129| |
| temp128 id = 1 ifTrue: [ |
| temp129 := true. |
| temp127 hosts: [|temp130 temp131| temp130 := iprot readListBegin. |
| temp131 := OrderedCollection new. |
| temp130 size timesRepeat: [ |
| temp131 add: iprot readString]. |
| iprot readListEnd. |
| temp131] value]. |
| temp128 id = 2 ifTrue: [ |
| temp129 := true. |
| temp127 names: [|temp132 temp133| temp132 := iprot readListBegin. |
| temp133 := OrderedCollection new. |
| temp132 size timesRepeat: [ |
| temp133 add: iprot readString]. |
| iprot readListEnd. |
| temp133] value]. |
| temp128 id = 3 ifTrue: [ |
| temp129 := true. |
| temp127 offset: iprot readI64]. |
| temp128 id = 4 ifTrue: [ |
| temp129 := true. |
| temp127 length: iprot readI64]. |
| temp129 ifNil: [iprot skip: temp128 type]]. |
| oprot readStructEnd. |
| temp127] value]. |
| iprot readListEnd. |
| temp126] value]. |
| temp123 id = 1 ifTrue: [ |
| temp124 := true. |
| temp122 exception: [|temp135 temp134| |
| temp134 := ThriftIOException new. |
| iprot readStructBegin. |
| [temp135 := iprot readFieldBegin. |
| temp135 type = TType stop] whileFalse: [|temp136| |
| temp135 id = -1 ifTrue: [ |
| temp136 := true. |
| temp134 message: iprot readString]. |
| temp136 ifNil: [iprot skip: temp135 type]]. |
| oprot readStructEnd. |
| temp134] value]. |
| temp124 ifNil: [iprot skip: temp123 type]]. |
| oprot readStructEnd. |
| temp122] value. |
| oprot readMessageEnd. |
| oprot transport flush. |
| res exception ifNotNil: [res exception signal]. |
| ^ res! ! |
| |
| Hadoopfs enums keysAndValuesDo: [:k :v | Hadoopfs enums at: k put: v value].! |
| Hadoopfs constants keysAndValuesDo: [:k :v | Hadoopfs constants at: k put: v value].! |
