source: proiecte/HadoopJUnit/hadoop-0.20.1/src/contrib/thriftfs/gen-st/hadoopfs.st @ 120

Last change on this file since 120 was 120, checked in by (none), 14 years ago

Added the mail files for the Hadoop JUNit Project
  • Property svn:executable set to *
File size: 55.2 KB
Line 
1'Autogenerated by Thrift
2
3DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
4'!
5
6Object subclass: #Hadoopfs
7  instanceVariableNames: ''
8  classVariableNames: ''
9  poolDictionaries: ''
10  category: 'Generated-Hadoopfs'!
11
12Hadoopfs class
13        instanceVariableNames: 'constants enums'!
14
15!Hadoopfs class methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
16enums: anObject
17    enums := anObject! !
18
19!Hadoopfs class methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
20enums
21    ^ enums! !
22
23!Hadoopfs class methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
24constants: anObject
25    constants := anObject! !
26
27!Hadoopfs class methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
28constants
29    ^ constants! !
30
31Hadoopfs enums: Dictionary new!
32Hadoopfs constants: Dictionary new!
33
34Object subclass: #ThriftHandle
35        instanceVariableNames: 'id'
36        classVariableNames: ''
37        poolDictionaries: ''
38        category: 'Generated-Hadoopfs'!
39
40!ThriftHandle methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
41id: anI64
42    id := anI64! !
43
44!ThriftHandle methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
45id
46    ^ id! !
47
48
49Object subclass: #Pathname
50        instanceVariableNames: 'pathname'
51        classVariableNames: ''
52        poolDictionaries: ''
53        category: 'Generated-Hadoopfs'!
54
55!Pathname methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
56pathname: aString
57    pathname := aString! !
58
59!Pathname methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
60pathname
61    ^ pathname! !
62
63
64Object subclass: #FileStatus
65        instanceVariableNames: 'path length isdir blockReplication blocksize modificationTime permission owner group'
66        classVariableNames: ''
67        poolDictionaries: ''
68        category: 'Generated-Hadoopfs'!
69
70!FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
71path: aString
72    path := aString! !
73
74!FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
75path
76    ^ path! !
77
78!FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
79length: anI64
80    length := anI64! !
81
82!FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
83length
84    ^ length! !
85
86!FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
87isdir: aBool
88    isdir := aBool! !
89
90!FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
91isdir
92    ^ isdir! !
93
94!FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
95blockReplication: anI16
96    blockReplication := anI16! !
97
98!FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
99blockReplication
100    ^ blockReplication! !
101
102!FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
103blocksize: anI64
104    blocksize := anI64! !
105
106!FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
107blocksize
108    ^ blocksize! !
109
110!FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
111modificationTime: anI64
112    modificationTime := anI64! !
113
114!FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
115modificationTime
116    ^ modificationTime! !
117
118!FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
119permission: aString
120    permission := aString! !
121
122!FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
123permission
124    ^ permission! !
125
126!FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
127owner: aString
128    owner := aString! !
129
130!FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
131owner
132    ^ owner! !
133
134!FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
135group: aString
136    group := aString! !
137
138!FileStatus methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
139group
140    ^ group! !
141
142
143Object subclass: #BlockLocation
144        instanceVariableNames: 'hosts names offset length'
145        classVariableNames: ''
146        poolDictionaries: ''
147        category: 'Generated-Hadoopfs'!
148
149!BlockLocation methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
150hosts: a
151    hosts := a! !
152
153!BlockLocation methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
154hosts
155    ^ hosts! !
156
157!BlockLocation methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
158names: a
159    names := a! !
160
161!BlockLocation methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
162names
163    ^ names! !
164
165!BlockLocation methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
166offset: anI64
167    offset := anI64! !
168
169!BlockLocation methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
170offset
171    ^ offset! !
172
173!BlockLocation methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
174length: anI64
175    length := anI64! !
176
177!BlockLocation methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
178length
179    ^ length! !
180
181
182Error subclass: #MalformedInputException
183        instanceVariableNames: 'message'
184        classVariableNames: ''
185        poolDictionaries: ''
186        category: 'Generated-Hadoopfs'!
187
188!MalformedInputException methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
189message: aString
190    message := aString! !
191
192!MalformedInputException methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
193message
194    ^ message! !
195
196
197Error subclass: #ThriftIOException
198        instanceVariableNames: 'message'
199        classVariableNames: ''
200        poolDictionaries: ''
201        category: 'Generated-Hadoopfs'!
202
203!ThriftIOException methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
204message: aString
205    message := aString! !
206
207!ThriftIOException methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
208message
209    ^ message! !
210
211
212TClient subclass: #ThriftHadoopFileSystemClient
213        instanceVariableNames: ''
214        classVariableNames: ''
215        poolDictionaries: ''
216        category: 'Generated-Hadoopfs'!
217
218!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
219setInactivityTimeoutPeriodPeriodInSeconds: periodInSeconds
220    "periodInSeconds: i64"
221    self sendSetInactivityTimeoutPeriodPeriodInSeconds: periodInSeconds.
222    ^ self recvSetInactivityTimeoutPeriod success 
223! !
224
225!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
226sendSetInactivityTimeoutPeriodPeriodInSeconds: periodInSeconds
227    oprot writeMessageBegin:
228      (TCallMessage new
229        name: 'setInactivityTimeoutPeriod'; 
230        seqid: self nextSeqid).
231    oprot writeStructBegin: (TStruct new name: 'SetInactivityTimeoutPeriod_args').
232    oprot writeFieldBegin: (TField new name: 'periodInSeconds'; type: TType i64; id: 1).
233    iprot writeI64: periodInSeconds asInteger.
234    oprot writeFieldEnd.
235    oprot writeFieldStop; writeStructEnd; writeMessageEnd.
236    oprot transport flush! !
237
238!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
239recvSetInactivityTimeoutPeriod
240    | f msg res | 
241    msg := oprot readMessageBegin.
242    self validateRemoteMessage: msg.
243    res := [|temp1 temp0|
244      temp0 := TResult new.
245      iprot readStructBegin.
246      [temp1 := iprot readFieldBegin.
247      temp1 type = TType stop] whileFalse: [|temp2|
248        temp1 id = 0 ifTrue: [
249          temp2 := true.
250          temp0 success: iprot readVoid].
251        temp2 ifNil: [iprot skip: temp1 type]].
252      oprot readStructEnd.
253      temp0] value.
254    oprot readMessageEnd.
255    oprot transport flush.
256    res exception ifNotNil: [res exception signal].
257    ^ res! !
258
259!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
260shutdownStatus: status
261    "status: i32"
262    self sendShutdownStatus: status.
263    ^ self recvShutdown success 
264! !
265
266!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
267sendShutdownStatus: status
268    oprot writeMessageBegin:
269      (TCallMessage new
270        name: 'shutdown'; 
271        seqid: self nextSeqid).
272    oprot writeStructBegin: (TStruct new name: 'Shutdown_args').
273    oprot writeFieldBegin: (TField new name: 'status'; type: TType i32; id: 1).
274    iprot writeI32: status asInteger.
275    oprot writeFieldEnd.
276    oprot writeFieldStop; writeStructEnd; writeMessageEnd.
277    oprot transport flush! !
278
279!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
280recvShutdown
281    | f msg res | 
282    msg := oprot readMessageBegin.
283    self validateRemoteMessage: msg.
284    res := [|temp4 temp3|
285      temp3 := TResult new.
286      iprot readStructBegin.
287      [temp4 := iprot readFieldBegin.
288      temp4 type = TType stop] whileFalse: [|temp5|
289        temp4 id = 0 ifTrue: [
290          temp5 := true.
291          temp3 success: iprot readVoid].
292        temp5 ifNil: [iprot skip: temp4 type]].
293      oprot readStructEnd.
294      temp3] value.
295    oprot readMessageEnd.
296    oprot transport flush.
297    res exception ifNotNil: [res exception signal].
298    ^ res! !
299
300!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
301createPath: path
302    "path: Pathname"
303    self sendCreatePath: path.
304    ^ self recvCreate success 
305! !
306
307!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
308sendCreatePath: path
309    oprot writeMessageBegin:
310      (TCallMessage new
311        name: 'create'; 
312        seqid: self nextSeqid).
313    oprot writeStructBegin: (TStruct new name: 'Create_args').
314    oprot writeFieldBegin: (TField new name: 'path'; type: TType struct; id: 1).
315    [oprot writeStructBegin: (TStruct new name: 'Pathname').
316      oprot writeFieldBegin: (TField new name: 'pathname'; type: TType string; id: -1).
317      iprot writeString: path pathname.
318      oprot writeFieldEnd.
319      oprot writeFieldStop; writeStructEnd] value.
320    oprot writeFieldEnd.
321    oprot writeFieldStop; writeStructEnd; writeMessageEnd.
322    oprot transport flush! !
323
324!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
325recvCreate
326    | f msg res | 
327    msg := oprot readMessageBegin.
328    self validateRemoteMessage: msg.
329    res := [|temp7 temp6|
330      temp6 := TResult new.
331      iprot readStructBegin.
332      [temp7 := iprot readFieldBegin.
333      temp7 type = TType stop] whileFalse: [|temp8|
334        temp7 id = 0 ifTrue: [
335          temp8 := true.
336          temp6 success: [|temp10 temp9|
337            temp9 := ThriftHandle new.
338            iprot readStructBegin.
339            [temp10 := iprot readFieldBegin.
340            temp10 type = TType stop] whileFalse: [|temp11|
341              temp10 id = -1 ifTrue: [
342                temp11 := true.
343                temp9 id: iprot readI64].
344              temp11 ifNil: [iprot skip: temp10 type]].
345            oprot readStructEnd.
346            temp9] value].
347        temp7 id = 1 ifTrue: [
348          temp8 := true.
349          temp6 exception: [|temp13 temp12|
350            temp12 := ThriftIOException new.
351            iprot readStructBegin.
352            [temp13 := iprot readFieldBegin.
353            temp13 type = TType stop] whileFalse: [|temp14|
354              temp13 id = -1 ifTrue: [
355                temp14 := true.
356                temp12 message: iprot readString].
357              temp14 ifNil: [iprot skip: temp13 type]].
358            oprot readStructEnd.
359            temp12] value].
360        temp8 ifNil: [iprot skip: temp7 type]].
361      oprot readStructEnd.
362      temp6] value.
363    oprot readMessageEnd.
364    oprot transport flush.
365    res exception ifNotNil: [res exception signal].
366    ^ res! !
367
368!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
369createFilePath: path mode: mode overwrite: overwrite bufferSize: bufferSize block_replication: block_replication blocksize: blocksize
370    "path: Pathname, mode: i16, overwrite: bool, bufferSize: i32, block_replication: i16, blocksize: i64"
371    self sendCreateFilePath: path mode: mode overwrite: overwrite bufferSize: bufferSize block_replication: block_replication blocksize: blocksize.
372    ^ self recvCreateFile success 
373! !
374
375!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
376sendCreateFilePath: path mode: mode overwrite: overwrite bufferSize: bufferSize block_replication: block_replication blocksize: blocksize
377    oprot writeMessageBegin:
378      (TCallMessage new
379        name: 'createFile'; 
380        seqid: self nextSeqid).
381    oprot writeStructBegin: (TStruct new name: 'CreateFile_args').
382    oprot writeFieldBegin: (TField new name: 'path'; type: TType struct; id: 1).
383    [oprot writeStructBegin: (TStruct new name: 'Pathname').
384      oprot writeFieldBegin: (TField new name: 'pathname'; type: TType string; id: -1).
385      iprot writeString: path pathname.
386      oprot writeFieldEnd.
387      oprot writeFieldStop; writeStructEnd] value.
388    oprot writeFieldEnd.
389    oprot writeFieldBegin: (TField new name: 'mode'; type: TType i16; id: 2).
390    iprot writeI16: mode asInteger.
391    oprot writeFieldEnd.
392    oprot writeFieldBegin: (TField new name: 'overwrite'; type: TType bool; id: 3).
393    iprot writeBool: overwrite.
394    oprot writeFieldEnd.
395    oprot writeFieldBegin: (TField new name: 'bufferSize'; type: TType i32; id: 4).
396    iprot writeI32: bufferSize asInteger.
397    oprot writeFieldEnd.
398    oprot writeFieldBegin: (TField new name: 'block_replication'; type: TType i16; id: 5).
399    iprot writeI16: block_replication asInteger.
400    oprot writeFieldEnd.
401    oprot writeFieldBegin: (TField new name: 'blocksize'; type: TType i64; id: 6).
402    iprot writeI64: blocksize asInteger.
403    oprot writeFieldEnd.
404    oprot writeFieldStop; writeStructEnd; writeMessageEnd.
405    oprot transport flush! !
406
407!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
408recvCreateFile
409    | f msg res | 
410    msg := oprot readMessageBegin.
411    self validateRemoteMessage: msg.
412    res := [|temp16 temp15|
413      temp15 := TResult new.
414      iprot readStructBegin.
415      [temp16 := iprot readFieldBegin.
416      temp16 type = TType stop] whileFalse: [|temp17|
417        temp16 id = 0 ifTrue: [
418          temp17 := true.
419          temp15 success: [|temp19 temp18|
420            temp18 := ThriftHandle new.
421            iprot readStructBegin.
422            [temp19 := iprot readFieldBegin.
423            temp19 type = TType stop] whileFalse: [|temp20|
424              temp19 id = -1 ifTrue: [
425                temp20 := true.
426                temp18 id: iprot readI64].
427              temp20 ifNil: [iprot skip: temp19 type]].
428            oprot readStructEnd.
429            temp18] value].
430        temp16 id = 1 ifTrue: [
431          temp17 := true.
432          temp15 exception: [|temp22 temp21|
433            temp21 := ThriftIOException new.
434            iprot readStructBegin.
435            [temp22 := iprot readFieldBegin.
436            temp22 type = TType stop] whileFalse: [|temp23|
437              temp22 id = -1 ifTrue: [
438                temp23 := true.
439                temp21 message: iprot readString].
440              temp23 ifNil: [iprot skip: temp22 type]].
441            oprot readStructEnd.
442            temp21] value].
443        temp17 ifNil: [iprot skip: temp16 type]].
444      oprot readStructEnd.
445      temp15] value.
446    oprot readMessageEnd.
447    oprot transport flush.
448    res exception ifNotNil: [res exception signal].
449    ^ res! !
450
451!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
452openPath: path
453    "path: Pathname"
454    self sendOpenPath: path.
455    ^ self recvOpen success 
456! !
457
458!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
459sendOpenPath: path
460    oprot writeMessageBegin:
461      (TCallMessage new
462        name: 'open'; 
463        seqid: self nextSeqid).
464    oprot writeStructBegin: (TStruct new name: 'Open_args').
465    oprot writeFieldBegin: (TField new name: 'path'; type: TType struct; id: 1).
466    [oprot writeStructBegin: (TStruct new name: 'Pathname').
467      oprot writeFieldBegin: (TField new name: 'pathname'; type: TType string; id: -1).
468      iprot writeString: path pathname.
469      oprot writeFieldEnd.
470      oprot writeFieldStop; writeStructEnd] value.
471    oprot writeFieldEnd.
472    oprot writeFieldStop; writeStructEnd; writeMessageEnd.
473    oprot transport flush! !
474
475!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
476recvOpen
477    | f msg res | 
478    msg := oprot readMessageBegin.
479    self validateRemoteMessage: msg.
480    res := [|temp25 temp24|
481      temp24 := TResult new.
482      iprot readStructBegin.
483      [temp25 := iprot readFieldBegin.
484      temp25 type = TType stop] whileFalse: [|temp26|
485        temp25 id = 0 ifTrue: [
486          temp26 := true.
487          temp24 success: [|temp28 temp27|
488            temp27 := ThriftHandle new.
489            iprot readStructBegin.
490            [temp28 := iprot readFieldBegin.
491            temp28 type = TType stop] whileFalse: [|temp29|
492              temp28 id = -1 ifTrue: [
493                temp29 := true.
494                temp27 id: iprot readI64].
495              temp29 ifNil: [iprot skip: temp28 type]].
496            oprot readStructEnd.
497            temp27] value].
498        temp25 id = 1 ifTrue: [
499          temp26 := true.
500          temp24 exception: [|temp31 temp30|
501            temp30 := ThriftIOException new.
502            iprot readStructBegin.
503            [temp31 := iprot readFieldBegin.
504            temp31 type = TType stop] whileFalse: [|temp32|
505              temp31 id = -1 ifTrue: [
506                temp32 := true.
507                temp30 message: iprot readString].
508              temp32 ifNil: [iprot skip: temp31 type]].
509            oprot readStructEnd.
510            temp30] value].
511        temp26 ifNil: [iprot skip: temp25 type]].
512      oprot readStructEnd.
513      temp24] value.
514    oprot readMessageEnd.
515    oprot transport flush.
516    res exception ifNotNil: [res exception signal].
517    ^ res! !
518
519!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
520appendPath: path
521    "path: Pathname"
522    self sendAppendPath: path.
523    ^ self recvAppend success 
524! !
525
526!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
527sendAppendPath: path
528    oprot writeMessageBegin:
529      (TCallMessage new
530        name: 'append'; 
531        seqid: self nextSeqid).
532    oprot writeStructBegin: (TStruct new name: 'Append_args').
533    oprot writeFieldBegin: (TField new name: 'path'; type: TType struct; id: 1).
534    [oprot writeStructBegin: (TStruct new name: 'Pathname').
535      oprot writeFieldBegin: (TField new name: 'pathname'; type: TType string; id: -1).
536      iprot writeString: path pathname.
537      oprot writeFieldEnd.
538      oprot writeFieldStop; writeStructEnd] value.
539    oprot writeFieldEnd.
540    oprot writeFieldStop; writeStructEnd; writeMessageEnd.
541    oprot transport flush! !
542
543!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
544recvAppend
545    | f msg res | 
546    msg := oprot readMessageBegin.
547    self validateRemoteMessage: msg.
548    res := [|temp34 temp33|
549      temp33 := TResult new.
550      iprot readStructBegin.
551      [temp34 := iprot readFieldBegin.
552      temp34 type = TType stop] whileFalse: [|temp35|
553        temp34 id = 0 ifTrue: [
554          temp35 := true.
555          temp33 success: [|temp37 temp36|
556            temp36 := ThriftHandle new.
557            iprot readStructBegin.
558            [temp37 := iprot readFieldBegin.
559            temp37 type = TType stop] whileFalse: [|temp38|
560              temp37 id = -1 ifTrue: [
561                temp38 := true.
562                temp36 id: iprot readI64].
563              temp38 ifNil: [iprot skip: temp37 type]].
564            oprot readStructEnd.
565            temp36] value].
566        temp34 id = 1 ifTrue: [
567          temp35 := true.
568          temp33 exception: [|temp40 temp39|
569            temp39 := ThriftIOException new.
570            iprot readStructBegin.
571            [temp40 := iprot readFieldBegin.
572            temp40 type = TType stop] whileFalse: [|temp41|
573              temp40 id = -1 ifTrue: [
574                temp41 := true.
575                temp39 message: iprot readString].
576              temp41 ifNil: [iprot skip: temp40 type]].
577            oprot readStructEnd.
578            temp39] value].
579        temp35 ifNil: [iprot skip: temp34 type]].
580      oprot readStructEnd.
581      temp33] value.
582    oprot readMessageEnd.
583    oprot transport flush.
584    res exception ifNotNil: [res exception signal].
585    ^ res! !
586
587!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
588writeHandle: handle data: data
589    "handle: ThriftHandle, data: string"
590    self sendWriteHandle: handle data: data.
591    ^ self recvWrite success 
592! !
593
594!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
595sendWriteHandle: handle data: data
596    oprot writeMessageBegin:
597      (TCallMessage new
598        name: 'write'; 
599        seqid: self nextSeqid).
600    oprot writeStructBegin: (TStruct new name: 'Write_args').
601    oprot writeFieldBegin: (TField new name: 'handle'; type: TType struct; id: 1).
602    [oprot writeStructBegin: (TStruct new name: 'ThriftHandle').
603      oprot writeFieldBegin: (TField new name: 'id'; type: TType i64; id: -1).
604      iprot writeI64: handle id asInteger.
605      oprot writeFieldEnd.
606      oprot writeFieldStop; writeStructEnd] value.
607    oprot writeFieldEnd.
608    oprot writeFieldBegin: (TField new name: 'data'; type: TType string; id: -1).
609    iprot writeString: data.
610    oprot writeFieldEnd.
611    oprot writeFieldStop; writeStructEnd; writeMessageEnd.
612    oprot transport flush! !
613
614!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
615recvWrite
616    | f msg res | 
617    msg := oprot readMessageBegin.
618    self validateRemoteMessage: msg.
619    res := [|temp43 temp42|
620      temp42 := TResult new.
621      iprot readStructBegin.
622      [temp43 := iprot readFieldBegin.
623      temp43 type = TType stop] whileFalse: [|temp44|
624        temp43 id = 0 ifTrue: [
625          temp44 := true.
626          temp42 success: iprot readBool].
627        temp43 id = 1 ifTrue: [
628          temp44 := true.
629          temp42 exception: [|temp46 temp45|
630            temp45 := ThriftIOException new.
631            iprot readStructBegin.
632            [temp46 := iprot readFieldBegin.
633            temp46 type = TType stop] whileFalse: [|temp47|
634              temp46 id = -1 ifTrue: [
635                temp47 := true.
636                temp45 message: iprot readString].
637              temp47 ifNil: [iprot skip: temp46 type]].
638            oprot readStructEnd.
639            temp45] value].
640        temp44 ifNil: [iprot skip: temp43 type]].
641      oprot readStructEnd.
642      temp42] value.
643    oprot readMessageEnd.
644    oprot transport flush.
645    res exception ifNotNil: [res exception signal].
646    ^ res! !
647
648!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
649readHandle: handle offset: offset size: size
650    "handle: ThriftHandle, offset: i64, size: i32"
651    self sendReadHandle: handle offset: offset size: size.
652    ^ self recvRead success 
653! !
654
655!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
656sendReadHandle: handle offset: offset size: size
657    oprot writeMessageBegin:
658      (TCallMessage new
659        name: 'read'; 
660        seqid: self nextSeqid).
661    oprot writeStructBegin: (TStruct new name: 'Read_args').
662    oprot writeFieldBegin: (TField new name: 'handle'; type: TType struct; id: 1).
663    [oprot writeStructBegin: (TStruct new name: 'ThriftHandle').
664      oprot writeFieldBegin: (TField new name: 'id'; type: TType i64; id: -1).
665      iprot writeI64: handle id asInteger.
666      oprot writeFieldEnd.
667      oprot writeFieldStop; writeStructEnd] value.
668    oprot writeFieldEnd.
669    oprot writeFieldBegin: (TField new name: 'offset'; type: TType i64; id: -1).
670    iprot writeI64: offset asInteger.
671    oprot writeFieldEnd.
672    oprot writeFieldBegin: (TField new name: 'size'; type: TType i32; id: -2).
673    iprot writeI32: size asInteger.
674    oprot writeFieldEnd.
675    oprot writeFieldStop; writeStructEnd; writeMessageEnd.
676    oprot transport flush! !
677
678!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
679recvRead
680    | f msg res | 
681    msg := oprot readMessageBegin.
682    self validateRemoteMessage: msg.
683    res := [|temp49 temp48|
684      temp48 := TResult new.
685      iprot readStructBegin.
686      [temp49 := iprot readFieldBegin.
687      temp49 type = TType stop] whileFalse: [|temp50|
688        temp49 id = 0 ifTrue: [
689          temp50 := true.
690          temp48 success: iprot readString].
691        temp49 id = 1 ifTrue: [
692          temp50 := true.
693          temp48 exception: [|temp52 temp51|
694            temp51 := ThriftIOException new.
695            iprot readStructBegin.
696            [temp52 := iprot readFieldBegin.
697            temp52 type = TType stop] whileFalse: [|temp53|
698              temp52 id = -1 ifTrue: [
699                temp53 := true.
700                temp51 message: iprot readString].
701              temp53 ifNil: [iprot skip: temp52 type]].
702            oprot readStructEnd.
703            temp51] value].
704        temp50 ifNil: [iprot skip: temp49 type]].
705      oprot readStructEnd.
706      temp48] value.
707    oprot readMessageEnd.
708    oprot transport flush.
709    res exception ifNotNil: [res exception signal].
710    ^ res! !
711
712!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
713closeOut: out
714    "out: ThriftHandle"
715    self sendCloseOut: out.
716    ^ self recvClose success 
717! !
718
719!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
720sendCloseOut: out
721    oprot writeMessageBegin:
722      (TCallMessage new
723        name: 'close'; 
724        seqid: self nextSeqid).
725    oprot writeStructBegin: (TStruct new name: 'Close_args').
726    oprot writeFieldBegin: (TField new name: 'out'; type: TType struct; id: 1).
727    [oprot writeStructBegin: (TStruct new name: 'ThriftHandle').
728      oprot writeFieldBegin: (TField new name: 'id'; type: TType i64; id: -1).
729      iprot writeI64: out id asInteger.
730      oprot writeFieldEnd.
731      oprot writeFieldStop; writeStructEnd] value.
732    oprot writeFieldEnd.
733    oprot writeFieldStop; writeStructEnd; writeMessageEnd.
734    oprot transport flush! !
735
736!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
737recvClose
738    | f msg res | 
739    msg := oprot readMessageBegin.
740    self validateRemoteMessage: msg.
741    res := [|temp55 temp54|
742      temp54 := TResult new.
743      iprot readStructBegin.
744      [temp55 := iprot readFieldBegin.
745      temp55 type = TType stop] whileFalse: [|temp56|
746        temp55 id = 0 ifTrue: [
747          temp56 := true.
748          temp54 success: iprot readBool].
749        temp55 id = 1 ifTrue: [
750          temp56 := true.
751          temp54 exception: [|temp58 temp57|
752            temp57 := ThriftIOException new.
753            iprot readStructBegin.
754            [temp58 := iprot readFieldBegin.
755            temp58 type = TType stop] whileFalse: [|temp59|
756              temp58 id = -1 ifTrue: [
757                temp59 := true.
758                temp57 message: iprot readString].
759              temp59 ifNil: [iprot skip: temp58 type]].
760            oprot readStructEnd.
761            temp57] value].
762        temp56 ifNil: [iprot skip: temp55 type]].
763      oprot readStructEnd.
764      temp54] value.
765    oprot readMessageEnd.
766    oprot transport flush.
767    res exception ifNotNil: [res exception signal].
768    ^ res! !
769
770!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
771rmPath: path recursive: recursive
772    "path: Pathname, recursive: bool"
773    self sendRmPath: path recursive: recursive.
774    ^ self recvRm success 
775! !
776
777!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
778sendRmPath: path recursive: recursive
779    oprot writeMessageBegin:
780      (TCallMessage new
781        name: 'rm'; 
782        seqid: self nextSeqid).
783    oprot writeStructBegin: (TStruct new name: 'Rm_args').
784    oprot writeFieldBegin: (TField new name: 'path'; type: TType struct; id: 1).
785    [oprot writeStructBegin: (TStruct new name: 'Pathname').
786      oprot writeFieldBegin: (TField new name: 'pathname'; type: TType string; id: -1).
787      iprot writeString: path pathname.
788      oprot writeFieldEnd.
789      oprot writeFieldStop; writeStructEnd] value.
790    oprot writeFieldEnd.
791    oprot writeFieldBegin: (TField new name: 'recursive'; type: TType bool; id: 2).
792    iprot writeBool: recursive.
793    oprot writeFieldEnd.
794    oprot writeFieldStop; writeStructEnd; writeMessageEnd.
795    oprot transport flush! !
796
797!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
798recvRm
799    | f msg res | 
800    msg := oprot readMessageBegin.
801    self validateRemoteMessage: msg.
802    res := [|temp61 temp60|
803      temp60 := TResult new.
804      iprot readStructBegin.
805      [temp61 := iprot readFieldBegin.
806      temp61 type = TType stop] whileFalse: [|temp62|
807        temp61 id = 0 ifTrue: [
808          temp62 := true.
809          temp60 success: iprot readBool].
810        temp61 id = 1 ifTrue: [
811          temp62 := true.
812          temp60 exception: [|temp64 temp63|
813            temp63 := ThriftIOException new.
814            iprot readStructBegin.
815            [temp64 := iprot readFieldBegin.
816            temp64 type = TType stop] whileFalse: [|temp65|
817              temp64 id = -1 ifTrue: [
818                temp65 := true.
819                temp63 message: iprot readString].
820              temp65 ifNil: [iprot skip: temp64 type]].
821            oprot readStructEnd.
822            temp63] value].
823        temp62 ifNil: [iprot skip: temp61 type]].
824      oprot readStructEnd.
825      temp60] value.
826    oprot readMessageEnd.
827    oprot transport flush.
828    res exception ifNotNil: [res exception signal].
829    ^ res! !
830
831!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
832renamePath: path dest: dest
833    "path: Pathname, dest: Pathname"
834    self sendRenamePath: path dest: dest.
835    ^ self recvRename success 
836! !
837
838!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
839sendRenamePath: path dest: dest
840    oprot writeMessageBegin:
841      (TCallMessage new
842        name: 'rename'; 
843        seqid: self nextSeqid).
844    oprot writeStructBegin: (TStruct new name: 'Rename_args').
845    oprot writeFieldBegin: (TField new name: 'path'; type: TType struct; id: 1).
846    [oprot writeStructBegin: (TStruct new name: 'Pathname').
847      oprot writeFieldBegin: (TField new name: 'pathname'; type: TType string; id: -1).
848      iprot writeString: path pathname.
849      oprot writeFieldEnd.
850      oprot writeFieldStop; writeStructEnd] value.
851    oprot writeFieldEnd.
852    oprot writeFieldBegin: (TField new name: 'dest'; type: TType struct; id: 2).
853    [oprot writeStructBegin: (TStruct new name: 'Pathname').
854      oprot writeFieldBegin: (TField new name: 'pathname'; type: TType string; id: -1).
855      iprot writeString: dest pathname.
856      oprot writeFieldEnd.
857      oprot writeFieldStop; writeStructEnd] value.
858    oprot writeFieldEnd.
859    oprot writeFieldStop; writeStructEnd; writeMessageEnd.
860    oprot transport flush! !
861
862!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
863recvRename
864    | f msg res | 
865    msg := oprot readMessageBegin.
866    self validateRemoteMessage: msg.
867    res := [|temp67 temp66|
868      temp66 := TResult new.
869      iprot readStructBegin.
870      [temp67 := iprot readFieldBegin.
871      temp67 type = TType stop] whileFalse: [|temp68|
872        temp67 id = 0 ifTrue: [
873          temp68 := true.
874          temp66 success: iprot readBool].
875        temp67 id = 1 ifTrue: [
876          temp68 := true.
877          temp66 exception: [|temp70 temp69|
878            temp69 := ThriftIOException new.
879            iprot readStructBegin.
880            [temp70 := iprot readFieldBegin.
881            temp70 type = TType stop] whileFalse: [|temp71|
882              temp70 id = -1 ifTrue: [
883                temp71 := true.
884                temp69 message: iprot readString].
885              temp71 ifNil: [iprot skip: temp70 type]].
886            oprot readStructEnd.
887            temp69] value].
888        temp68 ifNil: [iprot skip: temp67 type]].
889      oprot readStructEnd.
890      temp66] value.
891    oprot readMessageEnd.
892    oprot transport flush.
893    res exception ifNotNil: [res exception signal].
894    ^ res! !
895
896!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
897mkdirsPath: path
898    "path: Pathname"
899    self sendMkdirsPath: path.
900    ^ self recvMkdirs success 
901! !
902
903!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
904sendMkdirsPath: path
905    oprot writeMessageBegin:
906      (TCallMessage new
907        name: 'mkdirs'; 
908        seqid: self nextSeqid).
909    oprot writeStructBegin: (TStruct new name: 'Mkdirs_args').
910    oprot writeFieldBegin: (TField new name: 'path'; type: TType struct; id: 1).
911    [oprot writeStructBegin: (TStruct new name: 'Pathname').
912      oprot writeFieldBegin: (TField new name: 'pathname'; type: TType string; id: -1).
913      iprot writeString: path pathname.
914      oprot writeFieldEnd.
915      oprot writeFieldStop; writeStructEnd] value.
916    oprot writeFieldEnd.
917    oprot writeFieldStop; writeStructEnd; writeMessageEnd.
918    oprot transport flush! !
919
920!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
921recvMkdirs
922    | f msg res | 
923    msg := oprot readMessageBegin.
924    self validateRemoteMessage: msg.
925    res := [|temp73 temp72|
926      temp72 := TResult new.
927      iprot readStructBegin.
928      [temp73 := iprot readFieldBegin.
929      temp73 type = TType stop] whileFalse: [|temp74|
930        temp73 id = 0 ifTrue: [
931          temp74 := true.
932          temp72 success: iprot readBool].
933        temp73 id = 1 ifTrue: [
934          temp74 := true.
935          temp72 exception: [|temp76 temp75|
936            temp75 := ThriftIOException new.
937            iprot readStructBegin.
938            [temp76 := iprot readFieldBegin.
939            temp76 type = TType stop] whileFalse: [|temp77|
940              temp76 id = -1 ifTrue: [
941                temp77 := true.
942                temp75 message: iprot readString].
943              temp77 ifNil: [iprot skip: temp76 type]].
944            oprot readStructEnd.
945            temp75] value].
946        temp74 ifNil: [iprot skip: temp73 type]].
947      oprot readStructEnd.
948      temp72] value.
949    oprot readMessageEnd.
950    oprot transport flush.
951    res exception ifNotNil: [res exception signal].
952    ^ res! !
953
954!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
955existsPath: path
956    "path: Pathname"
957    self sendExistsPath: path.
958    ^ self recvExists success 
959! !
960
961!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
962sendExistsPath: path
963    oprot writeMessageBegin:
964      (TCallMessage new
965        name: 'exists'; 
966        seqid: self nextSeqid).
967    oprot writeStructBegin: (TStruct new name: 'Exists_args').
968    oprot writeFieldBegin: (TField new name: 'path'; type: TType struct; id: 1).
969    [oprot writeStructBegin: (TStruct new name: 'Pathname').
970      oprot writeFieldBegin: (TField new name: 'pathname'; type: TType string; id: -1).
971      iprot writeString: path pathname.
972      oprot writeFieldEnd.
973      oprot writeFieldStop; writeStructEnd] value.
974    oprot writeFieldEnd.
975    oprot writeFieldStop; writeStructEnd; writeMessageEnd.
976    oprot transport flush! !
977
978!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
979recvExists
980    | f msg res | 
981    msg := oprot readMessageBegin.
982    self validateRemoteMessage: msg.
983    res := [|temp79 temp78|
984      temp78 := TResult new.
985      iprot readStructBegin.
986      [temp79 := iprot readFieldBegin.
987      temp79 type = TType stop] whileFalse: [|temp80|
988        temp79 id = 0 ifTrue: [
989          temp80 := true.
990          temp78 success: iprot readBool].
991        temp79 id = 1 ifTrue: [
992          temp80 := true.
993          temp78 exception: [|temp82 temp81|
994            temp81 := ThriftIOException new.
995            iprot readStructBegin.
996            [temp82 := iprot readFieldBegin.
997            temp82 type = TType stop] whileFalse: [|temp83|
998              temp82 id = -1 ifTrue: [
999                temp83 := true.
1000                temp81 message: iprot readString].
1001              temp83 ifNil: [iprot skip: temp82 type]].
1002            oprot readStructEnd.
1003            temp81] value].
1004        temp80 ifNil: [iprot skip: temp79 type]].
1005      oprot readStructEnd.
1006      temp78] value.
1007    oprot readMessageEnd.
1008    oprot transport flush.
1009    res exception ifNotNil: [res exception signal].
1010    ^ res! !
1011
1012!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
1013statPath: path
1014    "path: Pathname"
1015    self sendStatPath: path.
1016    ^ self recvStat success 
1017! !
1018
1019!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
1020sendStatPath: path
1021    oprot writeMessageBegin:
1022      (TCallMessage new
1023        name: 'stat'; 
1024        seqid: self nextSeqid).
1025    oprot writeStructBegin: (TStruct new name: 'Stat_args').
1026    oprot writeFieldBegin: (TField new name: 'path'; type: TType struct; id: 1).
1027    [oprot writeStructBegin: (TStruct new name: 'Pathname').
1028      oprot writeFieldBegin: (TField new name: 'pathname'; type: TType string; id: -1).
1029      iprot writeString: path pathname.
1030      oprot writeFieldEnd.
1031      oprot writeFieldStop; writeStructEnd] value.
1032    oprot writeFieldEnd.
1033    oprot writeFieldStop; writeStructEnd; writeMessageEnd.
1034    oprot transport flush! !
1035
1036!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
1037recvStat
1038    | f msg res | 
1039    msg := oprot readMessageBegin.
1040    self validateRemoteMessage: msg.
1041    res := [|temp85 temp84|
1042      temp84 := TResult new.
1043      iprot readStructBegin.
1044      [temp85 := iprot readFieldBegin.
1045      temp85 type = TType stop] whileFalse: [|temp86|
1046        temp85 id = 0 ifTrue: [
1047          temp86 := true.
1048          temp84 success: [|temp88 temp87|
1049            temp87 := FileStatus new.
1050            iprot readStructBegin.
1051            [temp88 := iprot readFieldBegin.
1052            temp88 type = TType stop] whileFalse: [|temp89|
1053              temp88 id = 1 ifTrue: [
1054                temp89 := true.
1055                temp87 path: iprot readString].
1056              temp88 id = 2 ifTrue: [
1057                temp89 := true.
1058                temp87 length: iprot readI64].
1059              temp88 id = 3 ifTrue: [
1060                temp89 := true.
1061                temp87 isdir: iprot readBool].
1062              temp88 id = 4 ifTrue: [
1063                temp89 := true.
1064                temp87 blockReplication: iprot readI16].
1065              temp88 id = 5 ifTrue: [
1066                temp89 := true.
1067                temp87 blocksize: iprot readI64].
1068              temp88 id = 6 ifTrue: [
1069                temp89 := true.
1070                temp87 modificationTime: iprot readI64].
1071              temp88 id = 7 ifTrue: [
1072                temp89 := true.
1073                temp87 permission: iprot readString].
1074              temp88 id = 8 ifTrue: [
1075                temp89 := true.
1076                temp87 owner: iprot readString].
1077              temp88 id = 9 ifTrue: [
1078                temp89 := true.
1079                temp87 group: iprot readString].
1080              temp89 ifNil: [iprot skip: temp88 type]].
1081            oprot readStructEnd.
1082            temp87] value].
1083        temp85 id = 1 ifTrue: [
1084          temp86 := true.
1085          temp84 exception: [|temp91 temp90|
1086            temp90 := ThriftIOException new.
1087            iprot readStructBegin.
1088            [temp91 := iprot readFieldBegin.
1089            temp91 type = TType stop] whileFalse: [|temp92|
1090              temp91 id = -1 ifTrue: [
1091                temp92 := true.
1092                temp90 message: iprot readString].
1093              temp92 ifNil: [iprot skip: temp91 type]].
1094            oprot readStructEnd.
1095            temp90] value].
1096        temp86 ifNil: [iprot skip: temp85 type]].
1097      oprot readStructEnd.
1098      temp84] value.
1099    oprot readMessageEnd.
1100    oprot transport flush.
1101    res exception ifNotNil: [res exception signal].
1102    ^ res! !
1103
1104!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
1105listStatusPath: path
1106    "path: Pathname"
1107    self sendListStatusPath: path.
1108    ^ self recvListStatus success 
1109! !
1110
1111!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
1112sendListStatusPath: path
1113    oprot writeMessageBegin:
1114      (TCallMessage new
1115        name: 'listStatus'; 
1116        seqid: self nextSeqid).
1117    oprot writeStructBegin: (TStruct new name: 'ListStatus_args').
1118    oprot writeFieldBegin: (TField new name: 'path'; type: TType struct; id: 1).
1119    [oprot writeStructBegin: (TStruct new name: 'Pathname').
1120      oprot writeFieldBegin: (TField new name: 'pathname'; type: TType string; id: -1).
1121      iprot writeString: path pathname.
1122      oprot writeFieldEnd.
1123      oprot writeFieldStop; writeStructEnd] value.
1124    oprot writeFieldEnd.
1125    oprot writeFieldStop; writeStructEnd; writeMessageEnd.
1126    oprot transport flush! !
1127
1128!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
1129recvListStatus
1130    | f msg res | 
1131    msg := oprot readMessageBegin.
1132    self validateRemoteMessage: msg.
1133    res := [|temp94 temp93|
1134      temp93 := TResult new.
1135      iprot readStructBegin.
1136      [temp94 := iprot readFieldBegin.
1137      temp94 type = TType stop] whileFalse: [|temp95|
1138        temp94 id = 0 ifTrue: [
1139          temp95 := true.
1140          temp93 success: [|temp96 temp97| temp96 := iprot readListBegin.
1141            temp97 := OrderedCollection new.
1142            temp96 size timesRepeat: [
1143              temp97 add: [|temp99 temp98|
1144                temp98 := FileStatus new.
1145                iprot readStructBegin.
1146                [temp99 := iprot readFieldBegin.
1147                temp99 type = TType stop] whileFalse: [|temp100|
1148                  temp99 id = 1 ifTrue: [
1149                    temp100 := true.
1150                    temp98 path: iprot readString].
1151                  temp99 id = 2 ifTrue: [
1152                    temp100 := true.
1153                    temp98 length: iprot readI64].
1154                  temp99 id = 3 ifTrue: [
1155                    temp100 := true.
1156                    temp98 isdir: iprot readBool].
1157                  temp99 id = 4 ifTrue: [
1158                    temp100 := true.
1159                    temp98 blockReplication: iprot readI16].
1160                  temp99 id = 5 ifTrue: [
1161                    temp100 := true.
1162                    temp98 blocksize: iprot readI64].
1163                  temp99 id = 6 ifTrue: [
1164                    temp100 := true.
1165                    temp98 modificationTime: iprot readI64].
1166                  temp99 id = 7 ifTrue: [
1167                    temp100 := true.
1168                    temp98 permission: iprot readString].
1169                  temp99 id = 8 ifTrue: [
1170                    temp100 := true.
1171                    temp98 owner: iprot readString].
1172                  temp99 id = 9 ifTrue: [
1173                    temp100 := true.
1174                    temp98 group: iprot readString].
1175                  temp100 ifNil: [iprot skip: temp99 type]].
1176                oprot readStructEnd.
1177                temp98] value].
1178            iprot readListEnd.
1179            temp97] value].
1180        temp94 id = 1 ifTrue: [
1181          temp95 := true.
1182          temp93 exception: [|temp102 temp101|
1183            temp101 := ThriftIOException new.
1184            iprot readStructBegin.
1185            [temp102 := iprot readFieldBegin.
1186            temp102 type = TType stop] whileFalse: [|temp103|
1187              temp102 id = -1 ifTrue: [
1188                temp103 := true.
1189                temp101 message: iprot readString].
1190              temp103 ifNil: [iprot skip: temp102 type]].
1191            oprot readStructEnd.
1192            temp101] value].
1193        temp95 ifNil: [iprot skip: temp94 type]].
1194      oprot readStructEnd.
1195      temp93] value.
1196    oprot readMessageEnd.
1197    oprot transport flush.
1198    res exception ifNotNil: [res exception signal].
1199    ^ res! !
1200
1201!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
1202chmodPath: path mode: mode
1203    "path: Pathname, mode: i16"
1204    self sendChmodPath: path mode: mode.
1205    ^ self recvChmod success 
1206! !
1207
1208!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
1209sendChmodPath: path mode: mode
1210    oprot writeMessageBegin:
1211      (TCallMessage new
1212        name: 'chmod'; 
1213        seqid: self nextSeqid).
1214    oprot writeStructBegin: (TStruct new name: 'Chmod_args').
1215    oprot writeFieldBegin: (TField new name: 'path'; type: TType struct; id: 1).
1216    [oprot writeStructBegin: (TStruct new name: 'Pathname').
1217      oprot writeFieldBegin: (TField new name: 'pathname'; type: TType string; id: -1).
1218      iprot writeString: path pathname.
1219      oprot writeFieldEnd.
1220      oprot writeFieldStop; writeStructEnd] value.
1221    oprot writeFieldEnd.
1222    oprot writeFieldBegin: (TField new name: 'mode'; type: TType i16; id: 2).
1223    iprot writeI16: mode asInteger.
1224    oprot writeFieldEnd.
1225    oprot writeFieldStop; writeStructEnd; writeMessageEnd.
1226    oprot transport flush! !
1227
1228!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
1229recvChmod
1230    | f msg res | 
1231    msg := oprot readMessageBegin.
1232    self validateRemoteMessage: msg.
1233    res := [|temp105 temp104|
1234      temp104 := TResult new.
1235      iprot readStructBegin.
1236      [temp105 := iprot readFieldBegin.
1237      temp105 type = TType stop] whileFalse: [|temp106|
1238        temp105 id = 0 ifTrue: [
1239          temp106 := true.
1240          temp104 success: iprot readVoid].
1241        temp105 id = 1 ifTrue: [
1242          temp106 := true.
1243          temp104 exception: [|temp108 temp107|
1244            temp107 := ThriftIOException new.
1245            iprot readStructBegin.
1246            [temp108 := iprot readFieldBegin.
1247            temp108 type = TType stop] whileFalse: [|temp109|
1248              temp108 id = -1 ifTrue: [
1249                temp109 := true.
1250                temp107 message: iprot readString].
1251              temp109 ifNil: [iprot skip: temp108 type]].
1252            oprot readStructEnd.
1253            temp107] value].
1254        temp106 ifNil: [iprot skip: temp105 type]].
1255      oprot readStructEnd.
1256      temp104] value.
1257    oprot readMessageEnd.
1258    oprot transport flush.
1259    res exception ifNotNil: [res exception signal].
1260    ^ res! !
1261
1262!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
1263chownPath: path owner: owner group: group
1264    "path: Pathname, owner: string, group: string"
1265    self sendChownPath: path owner: owner group: group.
1266    ^ self recvChown success 
1267! !
1268
1269!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
1270sendChownPath: path owner: owner group: group
1271    oprot writeMessageBegin:
1272      (TCallMessage new
1273        name: 'chown'; 
1274        seqid: self nextSeqid).
1275    oprot writeStructBegin: (TStruct new name: 'Chown_args').
1276    oprot writeFieldBegin: (TField new name: 'path'; type: TType struct; id: 1).
1277    [oprot writeStructBegin: (TStruct new name: 'Pathname').
1278      oprot writeFieldBegin: (TField new name: 'pathname'; type: TType string; id: -1).
1279      iprot writeString: path pathname.
1280      oprot writeFieldEnd.
1281      oprot writeFieldStop; writeStructEnd] value.
1282    oprot writeFieldEnd.
1283    oprot writeFieldBegin: (TField new name: 'owner'; type: TType string; id: 2).
1284    iprot writeString: owner.
1285    oprot writeFieldEnd.
1286    oprot writeFieldBegin: (TField new name: 'group'; type: TType string; id: 3).
1287    iprot writeString: group.
1288    oprot writeFieldEnd.
1289    oprot writeFieldStop; writeStructEnd; writeMessageEnd.
1290    oprot transport flush! !
1291
1292!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
1293recvChown
1294    | f msg res | 
1295    msg := oprot readMessageBegin.
1296    self validateRemoteMessage: msg.
1297    res := [|temp111 temp110|
1298      temp110 := TResult new.
1299      iprot readStructBegin.
1300      [temp111 := iprot readFieldBegin.
1301      temp111 type = TType stop] whileFalse: [|temp112|
1302        temp111 id = 0 ifTrue: [
1303          temp112 := true.
1304          temp110 success: iprot readVoid].
1305        temp111 id = 1 ifTrue: [
1306          temp112 := true.
1307          temp110 exception: [|temp114 temp113|
1308            temp113 := ThriftIOException new.
1309            iprot readStructBegin.
1310            [temp114 := iprot readFieldBegin.
1311            temp114 type = TType stop] whileFalse: [|temp115|
1312              temp114 id = -1 ifTrue: [
1313                temp115 := true.
1314                temp113 message: iprot readString].
1315              temp115 ifNil: [iprot skip: temp114 type]].
1316            oprot readStructEnd.
1317            temp113] value].
1318        temp112 ifNil: [iprot skip: temp111 type]].
1319      oprot readStructEnd.
1320      temp110] value.
1321    oprot readMessageEnd.
1322    oprot transport flush.
1323    res exception ifNotNil: [res exception signal].
1324    ^ res! !
1325
1326!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
1327setReplicationPath: path replication: replication
1328    "path: Pathname, replication: i16"
1329    self sendSetReplicationPath: path replication: replication.
1330    ^ self recvSetReplication success 
1331! !
1332
1333!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
1334sendSetReplicationPath: path replication: replication
1335    oprot writeMessageBegin:
1336      (TCallMessage new
1337        name: 'setReplication'; 
1338        seqid: self nextSeqid).
1339    oprot writeStructBegin: (TStruct new name: 'SetReplication_args').
1340    oprot writeFieldBegin: (TField new name: 'path'; type: TType struct; id: 1).
1341    [oprot writeStructBegin: (TStruct new name: 'Pathname').
1342      oprot writeFieldBegin: (TField new name: 'pathname'; type: TType string; id: -1).
1343      iprot writeString: path pathname.
1344      oprot writeFieldEnd.
1345      oprot writeFieldStop; writeStructEnd] value.
1346    oprot writeFieldEnd.
1347    oprot writeFieldBegin: (TField new name: 'replication'; type: TType i16; id: 2).
1348    iprot writeI16: replication asInteger.
1349    oprot writeFieldEnd.
1350    oprot writeFieldStop; writeStructEnd; writeMessageEnd.
1351    oprot transport flush! !
1352
1353!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
1354recvSetReplication
1355    | f msg res | 
1356    msg := oprot readMessageBegin.
1357    self validateRemoteMessage: msg.
1358    res := [|temp117 temp116|
1359      temp116 := TResult new.
1360      iprot readStructBegin.
1361      [temp117 := iprot readFieldBegin.
1362      temp117 type = TType stop] whileFalse: [|temp118|
1363        temp117 id = 0 ifTrue: [
1364          temp118 := true.
1365          temp116 success: iprot readVoid].
1366        temp117 id = 1 ifTrue: [
1367          temp118 := true.
1368          temp116 exception: [|temp120 temp119|
1369            temp119 := ThriftIOException new.
1370            iprot readStructBegin.
1371            [temp120 := iprot readFieldBegin.
1372            temp120 type = TType stop] whileFalse: [|temp121|
1373              temp120 id = -1 ifTrue: [
1374                temp121 := true.
1375                temp119 message: iprot readString].
1376              temp121 ifNil: [iprot skip: temp120 type]].
1377            oprot readStructEnd.
1378            temp119] value].
1379        temp118 ifNil: [iprot skip: temp117 type]].
1380      oprot readStructEnd.
1381      temp116] value.
1382    oprot readMessageEnd.
1383    oprot transport flush.
1384    res exception ifNotNil: [res exception signal].
1385    ^ res! !
1386
1387!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
1388getFileBlockLocationsPath: path start: start length: length
1389    "path: Pathname, start: i64, length: i64"
1390    self sendGetFileBlockLocationsPath: path start: start length: length.
1391    ^ self recvGetFileBlockLocations success 
1392! !
1393
1394!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
1395sendGetFileBlockLocationsPath: path start: start length: length
1396    oprot writeMessageBegin:
1397      (TCallMessage new
1398        name: 'getFileBlockLocations'; 
1399        seqid: self nextSeqid).
1400    oprot writeStructBegin: (TStruct new name: 'GetFileBlockLocations_args').
1401    oprot writeFieldBegin: (TField new name: 'path'; type: TType struct; id: 1).
1402    [oprot writeStructBegin: (TStruct new name: 'Pathname').
1403      oprot writeFieldBegin: (TField new name: 'pathname'; type: TType string; id: -1).
1404      iprot writeString: path pathname.
1405      oprot writeFieldEnd.
1406      oprot writeFieldStop; writeStructEnd] value.
1407    oprot writeFieldEnd.
1408    oprot writeFieldBegin: (TField new name: 'start'; type: TType i64; id: 2).
1409    iprot writeI64: start asInteger.
1410    oprot writeFieldEnd.
1411    oprot writeFieldBegin: (TField new name: 'length'; type: TType i64; id: 3).
1412    iprot writeI64: length asInteger.
1413    oprot writeFieldEnd.
1414    oprot writeFieldStop; writeStructEnd; writeMessageEnd.
1415    oprot transport flush! !
1416
1417!ThriftHadoopFileSystemClient methodsFor: 'as yet uncategorized' stamp: 'thrift 08/27/2008 14:54'!
1418recvGetFileBlockLocations
1419    | f msg res | 
1420    msg := oprot readMessageBegin.
1421    self validateRemoteMessage: msg.
1422    res := [|temp123 temp122|
1423      temp122 := TResult new.
1424      iprot readStructBegin.
1425      [temp123 := iprot readFieldBegin.
1426      temp123 type = TType stop] whileFalse: [|temp124|
1427        temp123 id = 0 ifTrue: [
1428          temp124 := true.
1429          temp122 success: [|temp125 temp126| temp125 := iprot readListBegin.
1430            temp126 := OrderedCollection new.
1431            temp125 size timesRepeat: [
1432              temp126 add: [|temp128 temp127|
1433                temp127 := BlockLocation new.
1434                iprot readStructBegin.
1435                [temp128 := iprot readFieldBegin.
1436                temp128 type = TType stop] whileFalse: [|temp129|
1437                  temp128 id = 1 ifTrue: [
1438                    temp129 := true.
1439                    temp127 hosts: [|temp130 temp131| temp130 := iprot readListBegin.
1440                      temp131 := OrderedCollection new.
1441                      temp130 size timesRepeat: [
1442                        temp131 add: iprot readString].
1443                      iprot readListEnd.
1444                      temp131] value].
1445                  temp128 id = 2 ifTrue: [
1446                    temp129 := true.
1447                    temp127 names: [|temp132 temp133| temp132 := iprot readListBegin.
1448                      temp133 := OrderedCollection new.
1449                      temp132 size timesRepeat: [
1450                        temp133 add: iprot readString].
1451                      iprot readListEnd.
1452                      temp133] value].
1453                  temp128 id = 3 ifTrue: [
1454                    temp129 := true.
1455                    temp127 offset: iprot readI64].
1456                  temp128 id = 4 ifTrue: [
1457                    temp129 := true.
1458                    temp127 length: iprot readI64].
1459                  temp129 ifNil: [iprot skip: temp128 type]].
1460                oprot readStructEnd.
1461                temp127] value].
1462            iprot readListEnd.
1463            temp126] value].
1464        temp123 id = 1 ifTrue: [
1465          temp124 := true.
1466          temp122 exception: [|temp135 temp134|
1467            temp134 := ThriftIOException new.
1468            iprot readStructBegin.
1469            [temp135 := iprot readFieldBegin.
1470            temp135 type = TType stop] whileFalse: [|temp136|
1471              temp135 id = -1 ifTrue: [
1472                temp136 := true.
1473                temp134 message: iprot readString].
1474              temp136 ifNil: [iprot skip: temp135 type]].
1475            oprot readStructEnd.
1476            temp134] value].
1477        temp124 ifNil: [iprot skip: temp123 type]].
1478      oprot readStructEnd.
1479      temp122] value.
1480    oprot readMessageEnd.
1481    oprot transport flush.
1482    res exception ifNotNil: [res exception signal].
1483    ^ res! !
1484
1485Hadoopfs enums keysAndValuesDo: [:k :v | Hadoopfs enums at: k put: v value].!
1486Hadoopfs constants keysAndValuesDo: [:k :v | Hadoopfs constants at: k put: v value].!
Note: See TracBrowser for help on using the repository browser.