ClientNamenodeProtocol.proto 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857
  1. /**
  2. * Licensed to the Apache Software Foundation (ASF) under one
  3. * or more contributor license agreements. See the NOTICE file
  4. * distributed with this work for additional information
  5. * regarding copyright ownership. The ASF licenses this file
  6. * to you under the Apache License, Version 2.0 (the
  7. * "License"); you may not use this file except in compliance
  8. * with the License. You may obtain a copy of the License at
  9. *
  10. * http://www.apache.org/licenses/LICENSE-2.0
  11. *
  12. * Unless required by applicable law or agreed to in writing, software
  13. * distributed under the License is distributed on an "AS IS" BASIS,
  14. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15. * See the License for the specific language governing permissions and
  16. * limitations under the License.
  17. */
  18. /**
  19. * These .proto interfaces are private and stable.
  20. * Please see http://wiki.apache.org/hadoop/Compatibility
  21. * for what changes are allowed for a *stable* .proto interface.
  22. */
  23. option java_package = "org.apache.hadoop.hdfs.protocol.proto";
  24. option java_outer_classname = "ClientNamenodeProtocolProtos";
  25. option java_generic_services = true;
  26. option java_generate_equals_and_hash = true;
  27. package hadoop.hdfs;
  28. import "Security.proto";
  29. import "hdfs.proto";
  30. import "acl.proto";
  31. import "xattr.proto";
  32. import "encryption.proto";
  33. import "inotify.proto";
  34. /**
  35. * The ClientNamenodeProtocol Service defines the interface between a client
  36. * (as runnign inside a MR Task) and the Namenode.
  37. * See org.apache.hadoop.hdfs.protocol.ClientProtocol for the javadoc
  38. * for each of the methods.
  39. * The exceptions declared in the above class also apply to this protocol.
  40. * Exceptions are unwrapped and thrown by the PB libraries.
  41. */
  42. message GetBlockLocationsRequestProto {
  43. required string src = 1; // file name
  44. required uint64 offset = 2; // range start offset
  45. required uint64 length = 3; // range length
  46. }
  47. message GetBlockLocationsResponseProto {
  48. optional LocatedBlocksProto locations = 1;
  49. }
  50. message GetServerDefaultsRequestProto { // No parameters
  51. }
  52. message GetServerDefaultsResponseProto {
  53. required FsServerDefaultsProto serverDefaults = 1;
  54. }
  55. enum CreateFlagProto {
  56. CREATE = 0x01; // Create a file
  57. OVERWRITE = 0x02; // Truncate/overwrite a file. Same as POSIX O_TRUNC
  58. APPEND = 0x04; // Append to a file
  59. LAZY_PERSIST = 0x10; // File with reduced durability guarantees.
  60. }
  61. message CreateRequestProto {
  62. required string src = 1;
  63. required FsPermissionProto masked = 2;
  64. required string clientName = 3;
  65. required uint32 createFlag = 4; // bits set using CreateFlag
  66. required bool createParent = 5;
  67. required uint32 replication = 6; // Short: Only 16 bits used
  68. required uint64 blockSize = 7;
  69. repeated CryptoProtocolVersionProto cryptoProtocolVersion = 8;
  70. }
  71. message CreateResponseProto {
  72. optional HdfsFileStatusProto fs = 1;
  73. }
  74. message AppendRequestProto {
  75. required string src = 1;
  76. required string clientName = 2;
  77. }
  78. message AppendResponseProto {
  79. optional LocatedBlockProto block = 1;
  80. optional HdfsFileStatusProto stat = 2;
  81. }
  82. message SetReplicationRequestProto {
  83. required string src = 1;
  84. required uint32 replication = 2; // Short: Only 16 bits used
  85. }
  86. message SetReplicationResponseProto {
  87. required bool result = 1;
  88. }
  89. message SetStoragePolicyRequestProto {
  90. required string src = 1;
  91. required string policyName = 2;
  92. }
  93. message SetStoragePolicyResponseProto { // void response
  94. }
  95. message GetStoragePoliciesRequestProto { // void request
  96. }
  97. message GetStoragePoliciesResponseProto {
  98. repeated BlockStoragePolicyProto policies = 1;
  99. }
  100. message SetPermissionRequestProto {
  101. required string src = 1;
  102. required FsPermissionProto permission = 2;
  103. }
  104. message SetPermissionResponseProto { // void response
  105. }
  106. message SetOwnerRequestProto {
  107. required string src = 1;
  108. optional string username = 2;
  109. optional string groupname = 3;
  110. }
  111. message SetOwnerResponseProto { // void response
  112. }
  113. message AbandonBlockRequestProto {
  114. required ExtendedBlockProto b = 1;
  115. required string src = 2;
  116. required string holder = 3;
  117. optional uint64 fileId = 4 [default = 0]; // default to GRANDFATHER_INODE_ID
  118. }
  119. message AbandonBlockResponseProto { // void response
  120. }
  121. message AddBlockRequestProto {
  122. required string src = 1;
  123. required string clientName = 2;
  124. optional ExtendedBlockProto previous = 3;
  125. repeated DatanodeInfoProto excludeNodes = 4;
  126. optional uint64 fileId = 5 [default = 0]; // default as a bogus id
  127. repeated string favoredNodes = 6; //the set of datanodes to use for the block
  128. }
  129. message AddBlockResponseProto {
  130. required LocatedBlockProto block = 1;
  131. }
  132. message GetAdditionalDatanodeRequestProto {
  133. required string src = 1;
  134. required ExtendedBlockProto blk = 2;
  135. repeated DatanodeInfoProto existings = 3;
  136. repeated DatanodeInfoProto excludes = 4;
  137. required uint32 numAdditionalNodes = 5;
  138. required string clientName = 6;
  139. repeated string existingStorageUuids = 7;
  140. optional uint64 fileId = 8 [default = 0]; // default to GRANDFATHER_INODE_ID
  141. }
  142. message GetAdditionalDatanodeResponseProto {
  143. required LocatedBlockProto block = 1;
  144. }
  145. message CompleteRequestProto {
  146. required string src = 1;
  147. required string clientName = 2;
  148. optional ExtendedBlockProto last = 3;
  149. optional uint64 fileId = 4 [default = 0]; // default to GRANDFATHER_INODE_ID
  150. }
  151. message CompleteResponseProto {
  152. required bool result = 1;
  153. }
  154. message ReportBadBlocksRequestProto {
  155. repeated LocatedBlockProto blocks = 1;
  156. }
  157. message ReportBadBlocksResponseProto { // void response
  158. }
  159. message ConcatRequestProto {
  160. required string trg = 1;
  161. repeated string srcs = 2;
  162. }
  163. message ConcatResponseProto { // void response
  164. }
  165. message TruncateRequestProto {
  166. required string src = 1;
  167. required uint64 newLength = 2;
  168. required string clientName = 3;
  169. }
  170. message TruncateResponseProto {
  171. required bool result = 1;
  172. }
  173. message RenameRequestProto {
  174. required string src = 1;
  175. required string dst = 2;
  176. }
  177. message RenameResponseProto {
  178. required bool result = 1;
  179. }
  180. message Rename2RequestProto {
  181. required string src = 1;
  182. required string dst = 2;
  183. required bool overwriteDest = 3;
  184. }
  185. message Rename2ResponseProto { // void response
  186. }
  187. message DeleteRequestProto {
  188. required string src = 1;
  189. required bool recursive = 2;
  190. }
  191. message DeleteResponseProto {
  192. required bool result = 1;
  193. }
  194. message MkdirsRequestProto {
  195. required string src = 1;
  196. required FsPermissionProto masked = 2;
  197. required bool createParent = 3;
  198. }
  199. message MkdirsResponseProto {
  200. required bool result = 1;
  201. }
  202. message GetListingRequestProto {
  203. required string src = 1;
  204. required bytes startAfter = 2;
  205. required bool needLocation = 3;
  206. }
  207. message GetListingResponseProto {
  208. optional DirectoryListingProto dirList = 1;
  209. }
  210. message GetSnapshottableDirListingRequestProto { // no input parameters
  211. }
  212. message GetSnapshottableDirListingResponseProto {
  213. optional SnapshottableDirectoryListingProto snapshottableDirList = 1;
  214. }
  215. message GetSnapshotDiffReportRequestProto {
  216. required string snapshotRoot = 1;
  217. required string fromSnapshot = 2;
  218. required string toSnapshot = 3;
  219. }
  220. message GetSnapshotDiffReportResponseProto {
  221. required SnapshotDiffReportProto diffReport = 1;
  222. }
  223. message RenewLeaseRequestProto {
  224. required string clientName = 1;
  225. }
  226. message RenewLeaseResponseProto { //void response
  227. }
  228. message RecoverLeaseRequestProto {
  229. required string src = 1;
  230. required string clientName = 2;
  231. }
  232. message RecoverLeaseResponseProto {
  233. required bool result = 1;
  234. }
  235. message GetFsStatusRequestProto { // no input paramters
  236. }
  237. message GetFsStatsResponseProto {
  238. required uint64 capacity = 1;
  239. required uint64 used = 2;
  240. required uint64 remaining = 3;
  241. required uint64 under_replicated = 4;
  242. required uint64 corrupt_blocks = 5;
  243. required uint64 missing_blocks = 6;
  244. optional uint64 missing_repl_one_blocks = 7;
  245. }
  246. enum DatanodeReportTypeProto { // type of the datanode report
  247. ALL = 1;
  248. LIVE = 2;
  249. DEAD = 3;
  250. DECOMMISSIONING = 4;
  251. }
  252. message GetDatanodeReportRequestProto {
  253. required DatanodeReportTypeProto type = 1;
  254. }
  255. message GetDatanodeReportResponseProto {
  256. repeated DatanodeInfoProto di = 1;
  257. }
  258. message GetDatanodeStorageReportRequestProto {
  259. required DatanodeReportTypeProto type = 1;
  260. }
  261. message DatanodeStorageReportProto {
  262. required DatanodeInfoProto datanodeInfo = 1;
  263. repeated StorageReportProto storageReports = 2;
  264. }
  265. message GetDatanodeStorageReportResponseProto {
  266. repeated DatanodeStorageReportProto datanodeStorageReports = 1;
  267. }
  268. message GetPreferredBlockSizeRequestProto {
  269. required string filename = 1;
  270. }
  271. message GetPreferredBlockSizeResponseProto {
  272. required uint64 bsize = 1;
  273. }
  274. enum SafeModeActionProto {
  275. SAFEMODE_LEAVE = 1;
  276. SAFEMODE_ENTER = 2;
  277. SAFEMODE_GET = 3;
  278. }
  279. message SetSafeModeRequestProto {
  280. required SafeModeActionProto action = 1;
  281. optional bool checked = 2 [default = false];
  282. }
  283. message SetSafeModeResponseProto {
  284. required bool result = 1;
  285. }
  286. message SaveNamespaceRequestProto { // no parameters
  287. }
  288. message SaveNamespaceResponseProto { // void response
  289. }
  290. message RollEditsRequestProto { // no parameters
  291. }
  292. message RollEditsResponseProto { // response
  293. required uint64 newSegmentTxId = 1;
  294. }
  295. message RestoreFailedStorageRequestProto {
  296. required string arg = 1;
  297. }
  298. message RestoreFailedStorageResponseProto {
  299. required bool result = 1;
  300. }
  301. message RefreshNodesRequestProto { // no parameters
  302. }
  303. message RefreshNodesResponseProto { // void response
  304. }
  305. message FinalizeUpgradeRequestProto { // no parameters
  306. }
  307. message FinalizeUpgradeResponseProto { // void response
  308. }
  309. enum RollingUpgradeActionProto {
  310. QUERY = 1;
  311. START = 2;
  312. FINALIZE = 3;
  313. }
  314. message RollingUpgradeRequestProto {
  315. required RollingUpgradeActionProto action = 1;
  316. }
  317. message RollingUpgradeInfoProto {
  318. required RollingUpgradeStatusProto status = 1;
  319. required uint64 startTime = 2;
  320. required uint64 finalizeTime = 3;
  321. required bool createdRollbackImages = 4;
  322. }
  323. message RollingUpgradeResponseProto {
  324. optional RollingUpgradeInfoProto rollingUpgradeInfo= 1;
  325. }
  326. message ListCorruptFileBlocksRequestProto {
  327. required string path = 1;
  328. optional string cookie = 2;
  329. }
  330. message ListCorruptFileBlocksResponseProto {
  331. required CorruptFileBlocksProto corrupt = 1;
  332. }
  333. message MetaSaveRequestProto {
  334. required string filename = 1;
  335. }
  336. message MetaSaveResponseProto { // void response
  337. }
  338. message GetFileInfoRequestProto {
  339. required string src = 1;
  340. }
  341. message GetFileInfoResponseProto {
  342. optional HdfsFileStatusProto fs = 1;
  343. }
  344. message IsFileClosedRequestProto {
  345. required string src = 1;
  346. }
  347. message IsFileClosedResponseProto {
  348. required bool result = 1;
  349. }
  350. message CacheDirectiveInfoProto {
  351. optional int64 id = 1;
  352. optional string path = 2;
  353. optional uint32 replication = 3;
  354. optional string pool = 4;
  355. optional CacheDirectiveInfoExpirationProto expiration = 5;
  356. }
  357. message CacheDirectiveInfoExpirationProto {
  358. required int64 millis = 1;
  359. required bool isRelative = 2;
  360. }
  361. message CacheDirectiveStatsProto {
  362. required int64 bytesNeeded = 1;
  363. required int64 bytesCached = 2;
  364. required int64 filesNeeded = 3;
  365. required int64 filesCached = 4;
  366. required bool hasExpired = 5;
  367. }
  368. enum CacheFlagProto {
  369. FORCE = 0x01; // Ignore pool resource limits
  370. }
  371. message AddCacheDirectiveRequestProto {
  372. required CacheDirectiveInfoProto info = 1;
  373. optional uint32 cacheFlags = 2; // bits set using CacheFlag
  374. }
  375. message AddCacheDirectiveResponseProto {
  376. required int64 id = 1;
  377. }
  378. message ModifyCacheDirectiveRequestProto {
  379. required CacheDirectiveInfoProto info = 1;
  380. optional uint32 cacheFlags = 2; // bits set using CacheFlag
  381. }
  382. message ModifyCacheDirectiveResponseProto {
  383. }
  384. message RemoveCacheDirectiveRequestProto {
  385. required int64 id = 1;
  386. }
  387. message RemoveCacheDirectiveResponseProto {
  388. }
  389. message ListCacheDirectivesRequestProto {
  390. required int64 prevId = 1;
  391. required CacheDirectiveInfoProto filter = 2;
  392. }
  393. message CacheDirectiveEntryProto {
  394. required CacheDirectiveInfoProto info = 1;
  395. required CacheDirectiveStatsProto stats = 2;
  396. }
  397. message ListCacheDirectivesResponseProto {
  398. repeated CacheDirectiveEntryProto elements = 1;
  399. required bool hasMore = 2;
  400. }
  401. message CachePoolInfoProto {
  402. optional string poolName = 1;
  403. optional string ownerName = 2;
  404. optional string groupName = 3;
  405. optional int32 mode = 4;
  406. optional int64 limit = 5;
  407. optional int64 maxRelativeExpiry = 6;
  408. }
  409. message CachePoolStatsProto {
  410. required int64 bytesNeeded = 1;
  411. required int64 bytesCached = 2;
  412. required int64 bytesOverlimit = 3;
  413. required int64 filesNeeded = 4;
  414. required int64 filesCached = 5;
  415. }
  416. message AddCachePoolRequestProto {
  417. required CachePoolInfoProto info = 1;
  418. }
  419. message AddCachePoolResponseProto { // void response
  420. }
  421. message ModifyCachePoolRequestProto {
  422. required CachePoolInfoProto info = 1;
  423. }
  424. message ModifyCachePoolResponseProto { // void response
  425. }
  426. message RemoveCachePoolRequestProto {
  427. required string poolName = 1;
  428. }
  429. message RemoveCachePoolResponseProto { // void response
  430. }
  431. message ListCachePoolsRequestProto {
  432. required string prevPoolName = 1;
  433. }
  434. message ListCachePoolsResponseProto {
  435. repeated CachePoolEntryProto entries = 1;
  436. required bool hasMore = 2;
  437. }
  438. message CachePoolEntryProto {
  439. required CachePoolInfoProto info = 1;
  440. required CachePoolStatsProto stats = 2;
  441. }
  442. message GetFileLinkInfoRequestProto {
  443. required string src = 1;
  444. }
  445. message GetFileLinkInfoResponseProto {
  446. optional HdfsFileStatusProto fs = 1;
  447. }
  448. message GetContentSummaryRequestProto {
  449. required string path = 1;
  450. }
  451. message GetContentSummaryResponseProto {
  452. required ContentSummaryProto summary = 1;
  453. }
  454. message SetQuotaRequestProto {
  455. required string path = 1;
  456. required uint64 namespaceQuota = 2;
  457. required uint64 diskspaceQuota = 3;
  458. }
  459. message SetQuotaResponseProto { // void response
  460. }
  461. message FsyncRequestProto {
  462. required string src = 1;
  463. required string client = 2;
  464. optional sint64 lastBlockLength = 3 [default = -1];
  465. optional uint64 fileId = 4 [default = 0]; // default to GRANDFATHER_INODE_ID
  466. }
  467. message FsyncResponseProto { // void response
  468. }
  469. message SetTimesRequestProto {
  470. required string src = 1;
  471. required uint64 mtime = 2;
  472. required uint64 atime = 3;
  473. }
  474. message SetTimesResponseProto { // void response
  475. }
  476. message CreateSymlinkRequestProto {
  477. required string target = 1;
  478. required string link = 2;
  479. required FsPermissionProto dirPerm = 3;
  480. required bool createParent = 4;
  481. }
  482. message CreateSymlinkResponseProto { // void response
  483. }
  484. message GetLinkTargetRequestProto {
  485. required string path = 1;
  486. }
  487. message GetLinkTargetResponseProto {
  488. optional string targetPath = 1;
  489. }
  490. message UpdateBlockForPipelineRequestProto {
  491. required ExtendedBlockProto block = 1;
  492. required string clientName = 2;
  493. }
  494. message UpdateBlockForPipelineResponseProto {
  495. required LocatedBlockProto block = 1;
  496. }
  497. message UpdatePipelineRequestProto {
  498. required string clientName = 1;
  499. required ExtendedBlockProto oldBlock = 2;
  500. required ExtendedBlockProto newBlock = 3;
  501. repeated DatanodeIDProto newNodes = 4;
  502. repeated string storageIDs = 5;
  503. }
  504. message UpdatePipelineResponseProto { // void response
  505. }
  506. message SetBalancerBandwidthRequestProto {
  507. required int64 bandwidth = 1;
  508. }
  509. message SetBalancerBandwidthResponseProto { // void response
  510. }
  511. message GetDataEncryptionKeyRequestProto { // no parameters
  512. }
  513. message GetDataEncryptionKeyResponseProto {
  514. optional DataEncryptionKeyProto dataEncryptionKey = 1;
  515. }
  516. message CreateSnapshotRequestProto {
  517. required string snapshotRoot = 1;
  518. optional string snapshotName = 2;
  519. }
  520. message CreateSnapshotResponseProto {
  521. required string snapshotPath = 1;
  522. }
  523. message RenameSnapshotRequestProto {
  524. required string snapshotRoot = 1;
  525. required string snapshotOldName = 2;
  526. required string snapshotNewName = 3;
  527. }
  528. message RenameSnapshotResponseProto { // void response
  529. }
  530. message AllowSnapshotRequestProto {
  531. required string snapshotRoot = 1;
  532. }
  533. message AllowSnapshotResponseProto {
  534. }
  535. message DisallowSnapshotRequestProto {
  536. required string snapshotRoot = 1;
  537. }
  538. message DisallowSnapshotResponseProto {
  539. }
  540. message DeleteSnapshotRequestProto {
  541. required string snapshotRoot = 1;
  542. required string snapshotName = 2;
  543. }
  544. message DeleteSnapshotResponseProto { // void response
  545. }
  546. message CheckAccessRequestProto {
  547. required string path = 1;
  548. required AclEntryProto.FsActionProto mode = 2;
  549. }
  550. message CheckAccessResponseProto { // void response
  551. }
  552. message GetCurrentEditLogTxidRequestProto {
  553. }
  554. message GetCurrentEditLogTxidResponseProto {
  555. required int64 txid = 1;
  556. }
  557. message GetEditsFromTxidRequestProto {
  558. required int64 txid = 1;
  559. }
  560. message GetEditsFromTxidResponseProto {
  561. required EventsListProto eventsList = 1;
  562. }
  563. service ClientNamenodeProtocol {
  564. rpc getBlockLocations(GetBlockLocationsRequestProto)
  565. returns(GetBlockLocationsResponseProto);
  566. rpc getServerDefaults(GetServerDefaultsRequestProto)
  567. returns(GetServerDefaultsResponseProto);
  568. rpc create(CreateRequestProto)returns(CreateResponseProto);
  569. rpc append(AppendRequestProto) returns(AppendResponseProto);
  570. rpc setReplication(SetReplicationRequestProto)
  571. returns(SetReplicationResponseProto);
  572. rpc setStoragePolicy(SetStoragePolicyRequestProto)
  573. returns(SetStoragePolicyResponseProto);
  574. rpc getStoragePolicies(GetStoragePoliciesRequestProto)
  575. returns(GetStoragePoliciesResponseProto);
  576. rpc setPermission(SetPermissionRequestProto)
  577. returns(SetPermissionResponseProto);
  578. rpc setOwner(SetOwnerRequestProto) returns(SetOwnerResponseProto);
  579. rpc abandonBlock(AbandonBlockRequestProto) returns(AbandonBlockResponseProto);
  580. rpc addBlock(AddBlockRequestProto) returns(AddBlockResponseProto);
  581. rpc getAdditionalDatanode(GetAdditionalDatanodeRequestProto)
  582. returns(GetAdditionalDatanodeResponseProto);
  583. rpc complete(CompleteRequestProto) returns(CompleteResponseProto);
  584. rpc reportBadBlocks(ReportBadBlocksRequestProto)
  585. returns(ReportBadBlocksResponseProto);
  586. rpc concat(ConcatRequestProto) returns(ConcatResponseProto);
  587. rpc truncate(TruncateRequestProto) returns(TruncateResponseProto);
  588. rpc rename(RenameRequestProto) returns(RenameResponseProto);
  589. rpc rename2(Rename2RequestProto) returns(Rename2ResponseProto);
  590. rpc delete(DeleteRequestProto) returns(DeleteResponseProto);
  591. rpc mkdirs(MkdirsRequestProto) returns(MkdirsResponseProto);
  592. rpc getListing(GetListingRequestProto) returns(GetListingResponseProto);
  593. rpc renewLease(RenewLeaseRequestProto) returns(RenewLeaseResponseProto);
  594. rpc recoverLease(RecoverLeaseRequestProto)
  595. returns(RecoverLeaseResponseProto);
  596. rpc getFsStats(GetFsStatusRequestProto) returns(GetFsStatsResponseProto);
  597. rpc getDatanodeReport(GetDatanodeReportRequestProto)
  598. returns(GetDatanodeReportResponseProto);
  599. rpc getDatanodeStorageReport(GetDatanodeStorageReportRequestProto)
  600. returns(GetDatanodeStorageReportResponseProto);
  601. rpc getPreferredBlockSize(GetPreferredBlockSizeRequestProto)
  602. returns(GetPreferredBlockSizeResponseProto);
  603. rpc setSafeMode(SetSafeModeRequestProto)
  604. returns(SetSafeModeResponseProto);
  605. rpc saveNamespace(SaveNamespaceRequestProto)
  606. returns(SaveNamespaceResponseProto);
  607. rpc rollEdits(RollEditsRequestProto)
  608. returns(RollEditsResponseProto);
  609. rpc restoreFailedStorage(RestoreFailedStorageRequestProto)
  610. returns(RestoreFailedStorageResponseProto);
  611. rpc refreshNodes(RefreshNodesRequestProto) returns(RefreshNodesResponseProto);
  612. rpc finalizeUpgrade(FinalizeUpgradeRequestProto)
  613. returns(FinalizeUpgradeResponseProto);
  614. rpc rollingUpgrade(RollingUpgradeRequestProto)
  615. returns(RollingUpgradeResponseProto);
  616. rpc listCorruptFileBlocks(ListCorruptFileBlocksRequestProto)
  617. returns(ListCorruptFileBlocksResponseProto);
  618. rpc metaSave(MetaSaveRequestProto) returns(MetaSaveResponseProto);
  619. rpc getFileInfo(GetFileInfoRequestProto) returns(GetFileInfoResponseProto);
  620. rpc addCacheDirective(AddCacheDirectiveRequestProto)
  621. returns (AddCacheDirectiveResponseProto);
  622. rpc modifyCacheDirective(ModifyCacheDirectiveRequestProto)
  623. returns (ModifyCacheDirectiveResponseProto);
  624. rpc removeCacheDirective(RemoveCacheDirectiveRequestProto)
  625. returns (RemoveCacheDirectiveResponseProto);
  626. rpc listCacheDirectives(ListCacheDirectivesRequestProto)
  627. returns (ListCacheDirectivesResponseProto);
  628. rpc addCachePool(AddCachePoolRequestProto)
  629. returns(AddCachePoolResponseProto);
  630. rpc modifyCachePool(ModifyCachePoolRequestProto)
  631. returns(ModifyCachePoolResponseProto);
  632. rpc removeCachePool(RemoveCachePoolRequestProto)
  633. returns(RemoveCachePoolResponseProto);
  634. rpc listCachePools(ListCachePoolsRequestProto)
  635. returns(ListCachePoolsResponseProto);
  636. rpc getFileLinkInfo(GetFileLinkInfoRequestProto)
  637. returns(GetFileLinkInfoResponseProto);
  638. rpc getContentSummary(GetContentSummaryRequestProto)
  639. returns(GetContentSummaryResponseProto);
  640. rpc setQuota(SetQuotaRequestProto) returns(SetQuotaResponseProto);
  641. rpc fsync(FsyncRequestProto) returns(FsyncResponseProto);
  642. rpc setTimes(SetTimesRequestProto) returns(SetTimesResponseProto);
  643. rpc createSymlink(CreateSymlinkRequestProto)
  644. returns(CreateSymlinkResponseProto);
  645. rpc getLinkTarget(GetLinkTargetRequestProto)
  646. returns(GetLinkTargetResponseProto);
  647. rpc updateBlockForPipeline(UpdateBlockForPipelineRequestProto)
  648. returns(UpdateBlockForPipelineResponseProto);
  649. rpc updatePipeline(UpdatePipelineRequestProto)
  650. returns(UpdatePipelineResponseProto);
  651. rpc getDelegationToken(hadoop.common.GetDelegationTokenRequestProto)
  652. returns(hadoop.common.GetDelegationTokenResponseProto);
  653. rpc renewDelegationToken(hadoop.common.RenewDelegationTokenRequestProto)
  654. returns(hadoop.common.RenewDelegationTokenResponseProto);
  655. rpc cancelDelegationToken(hadoop.common.CancelDelegationTokenRequestProto)
  656. returns(hadoop.common.CancelDelegationTokenResponseProto);
  657. rpc setBalancerBandwidth(SetBalancerBandwidthRequestProto)
  658. returns(SetBalancerBandwidthResponseProto);
  659. rpc getDataEncryptionKey(GetDataEncryptionKeyRequestProto)
  660. returns(GetDataEncryptionKeyResponseProto);
  661. rpc createSnapshot(CreateSnapshotRequestProto)
  662. returns(CreateSnapshotResponseProto);
  663. rpc renameSnapshot(RenameSnapshotRequestProto)
  664. returns(RenameSnapshotResponseProto);
  665. rpc allowSnapshot(AllowSnapshotRequestProto)
  666. returns(AllowSnapshotResponseProto);
  667. rpc disallowSnapshot(DisallowSnapshotRequestProto)
  668. returns(DisallowSnapshotResponseProto);
  669. rpc getSnapshottableDirListing(GetSnapshottableDirListingRequestProto)
  670. returns(GetSnapshottableDirListingResponseProto);
  671. rpc deleteSnapshot(DeleteSnapshotRequestProto)
  672. returns(DeleteSnapshotResponseProto);
  673. rpc getSnapshotDiffReport(GetSnapshotDiffReportRequestProto)
  674. returns(GetSnapshotDiffReportResponseProto);
  675. rpc isFileClosed(IsFileClosedRequestProto)
  676. returns(IsFileClosedResponseProto);
  677. rpc modifyAclEntries(ModifyAclEntriesRequestProto)
  678. returns(ModifyAclEntriesResponseProto);
  679. rpc removeAclEntries(RemoveAclEntriesRequestProto)
  680. returns(RemoveAclEntriesResponseProto);
  681. rpc removeDefaultAcl(RemoveDefaultAclRequestProto)
  682. returns(RemoveDefaultAclResponseProto);
  683. rpc removeAcl(RemoveAclRequestProto)
  684. returns(RemoveAclResponseProto);
  685. rpc setAcl(SetAclRequestProto)
  686. returns(SetAclResponseProto);
  687. rpc getAclStatus(GetAclStatusRequestProto)
  688. returns(GetAclStatusResponseProto);
  689. rpc setXAttr(SetXAttrRequestProto)
  690. returns(SetXAttrResponseProto);
  691. rpc getXAttrs(GetXAttrsRequestProto)
  692. returns(GetXAttrsResponseProto);
  693. rpc listXAttrs(ListXAttrsRequestProto)
  694. returns(ListXAttrsResponseProto);
  695. rpc removeXAttr(RemoveXAttrRequestProto)
  696. returns(RemoveXAttrResponseProto);
  697. rpc checkAccess(CheckAccessRequestProto)
  698. returns(CheckAccessResponseProto);
  699. rpc createEncryptionZone(CreateEncryptionZoneRequestProto)
  700. returns(CreateEncryptionZoneResponseProto);
  701. rpc listEncryptionZones(ListEncryptionZonesRequestProto)
  702. returns(ListEncryptionZonesResponseProto);
  703. rpc getEZForPath(GetEZForPathRequestProto)
  704. returns(GetEZForPathResponseProto);
  705. rpc getCurrentEditLogTxid(GetCurrentEditLogTxidRequestProto)
  706. returns(GetCurrentEditLogTxidResponseProto);
  707. rpc getEditsFromTxid(GetEditsFromTxidRequestProto)
  708. returns(GetEditsFromTxidResponseProto);
  709. }