网格计算

开发平台：
Java

hadoopfs.st：源码内容
							'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].!

						