ClientNamenodeProtocol.proto 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846
  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 RenameRequestProto {
  166. required string src = 1;
  167. required string dst = 2;
  168. }
  169. message RenameResponseProto {
  170. required bool result = 1;
  171. }
  172. message Rename2RequestProto {
  173. required string src = 1;
  174. required string dst = 2;
  175. required bool overwriteDest = 3;
  176. }
  177. message Rename2ResponseProto { // void response
  178. }
  179. message DeleteRequestProto {
  180. required string src = 1;
  181. required bool recursive = 2;
  182. }
  183. message DeleteResponseProto {
  184. required bool result = 1;
  185. }
  186. message MkdirsRequestProto {
  187. required string src = 1;
  188. required FsPermissionProto masked = 2;
  189. required bool createParent = 3;
  190. }
  191. message MkdirsResponseProto {
  192. required bool result = 1;
  193. }
  194. message GetListingRequestProto {
  195. required string src = 1;
  196. required bytes startAfter = 2;
  197. required bool needLocation = 3;
  198. }
  199. message GetListingResponseProto {
  200. optional DirectoryListingProto dirList = 1;
  201. }
  202. message GetSnapshottableDirListingRequestProto { // no input parameters
  203. }
  204. message GetSnapshottableDirListingResponseProto {
  205. optional SnapshottableDirectoryListingProto snapshottableDirList = 1;
  206. }
  207. message GetSnapshotDiffReportRequestProto {
  208. required string snapshotRoot = 1;
  209. required string fromSnapshot = 2;
  210. required string toSnapshot = 3;
  211. }
  212. message GetSnapshotDiffReportResponseProto {
  213. required SnapshotDiffReportProto diffReport = 1;
  214. }
  215. message RenewLeaseRequestProto {
  216. required string clientName = 1;
  217. }
  218. message RenewLeaseResponseProto { //void response
  219. }
  220. message RecoverLeaseRequestProto {
  221. required string src = 1;
  222. required string clientName = 2;
  223. }
  224. message RecoverLeaseResponseProto {
  225. required bool result = 1;
  226. }
  227. message GetFsStatusRequestProto { // no input paramters
  228. }
  229. message GetFsStatsResponseProto {
  230. required uint64 capacity = 1;
  231. required uint64 used = 2;
  232. required uint64 remaining = 3;
  233. required uint64 under_replicated = 4;
  234. required uint64 corrupt_blocks = 5;
  235. required uint64 missing_blocks = 6;
  236. optional uint64 missing_repl_one_blocks = 7;
  237. }
  238. enum DatanodeReportTypeProto { // type of the datanode report
  239. ALL = 1;
  240. LIVE = 2;
  241. DEAD = 3;
  242. DECOMMISSIONING = 4;
  243. }
  244. message GetDatanodeReportRequestProto {
  245. required DatanodeReportTypeProto type = 1;
  246. }
  247. message GetDatanodeReportResponseProto {
  248. repeated DatanodeInfoProto di = 1;
  249. }
  250. message GetDatanodeStorageReportRequestProto {
  251. required DatanodeReportTypeProto type = 1;
  252. }
  253. message DatanodeStorageReportProto {
  254. required DatanodeInfoProto datanodeInfo = 1;
  255. repeated StorageReportProto storageReports = 2;
  256. }
  257. message GetDatanodeStorageReportResponseProto {
  258. repeated DatanodeStorageReportProto datanodeStorageReports = 1;
  259. }
  260. message GetPreferredBlockSizeRequestProto {
  261. required string filename = 1;
  262. }
  263. message GetPreferredBlockSizeResponseProto {
  264. required uint64 bsize = 1;
  265. }
  266. enum SafeModeActionProto {
  267. SAFEMODE_LEAVE = 1;
  268. SAFEMODE_ENTER = 2;
  269. SAFEMODE_GET = 3;
  270. }
  271. message SetSafeModeRequestProto {
  272. required SafeModeActionProto action = 1;
  273. optional bool checked = 2 [default = false];
  274. }
  275. message SetSafeModeResponseProto {
  276. required bool result = 1;
  277. }
  278. message SaveNamespaceRequestProto { // no parameters
  279. }
  280. message SaveNamespaceResponseProto { // void response
  281. }
  282. message RollEditsRequestProto { // no parameters
  283. }
  284. message RollEditsResponseProto { // response
  285. required uint64 newSegmentTxId = 1;
  286. }
  287. message RestoreFailedStorageRequestProto {
  288. required string arg = 1;
  289. }
  290. message RestoreFailedStorageResponseProto {
  291. required bool result = 1;
  292. }
  293. message RefreshNodesRequestProto { // no parameters
  294. }
  295. message RefreshNodesResponseProto { // void response
  296. }
  297. message FinalizeUpgradeRequestProto { // no parameters
  298. }
  299. message FinalizeUpgradeResponseProto { // void response
  300. }
  301. enum RollingUpgradeActionProto {
  302. QUERY = 1;
  303. START = 2;
  304. FINALIZE = 3;
  305. }
  306. message RollingUpgradeRequestProto {
  307. required RollingUpgradeActionProto action = 1;
  308. }
  309. message RollingUpgradeInfoProto {
  310. required RollingUpgradeStatusProto status = 1;
  311. required uint64 startTime = 2;
  312. required uint64 finalizeTime = 3;
  313. required bool createdRollbackImages = 4;
  314. }
  315. message RollingUpgradeResponseProto {
  316. optional RollingUpgradeInfoProto rollingUpgradeInfo= 1;
  317. }
  318. message ListCorruptFileBlocksRequestProto {
  319. required string path = 1;
  320. optional string cookie = 2;
  321. }
  322. message ListCorruptFileBlocksResponseProto {
  323. required CorruptFileBlocksProto corrupt = 1;
  324. }
  325. message MetaSaveRequestProto {
  326. required string filename = 1;
  327. }
  328. message MetaSaveResponseProto { // void response
  329. }
  330. message GetFileInfoRequestProto {
  331. required string src = 1;
  332. }
  333. message GetFileInfoResponseProto {
  334. optional HdfsFileStatusProto fs = 1;
  335. }
  336. message IsFileClosedRequestProto {
  337. required string src = 1;
  338. }
  339. message IsFileClosedResponseProto {
  340. required bool result = 1;
  341. }
  342. message CacheDirectiveInfoProto {
  343. optional int64 id = 1;
  344. optional string path = 2;
  345. optional uint32 replication = 3;
  346. optional string pool = 4;
  347. optional CacheDirectiveInfoExpirationProto expiration = 5;
  348. }
  349. message CacheDirectiveInfoExpirationProto {
  350. required int64 millis = 1;
  351. required bool isRelative = 2;
  352. }
  353. message CacheDirectiveStatsProto {
  354. required int64 bytesNeeded = 1;
  355. required int64 bytesCached = 2;
  356. required int64 filesNeeded = 3;
  357. required int64 filesCached = 4;
  358. required bool hasExpired = 5;
  359. }
  360. enum CacheFlagProto {
  361. FORCE = 0x01; // Ignore pool resource limits
  362. }
  363. message AddCacheDirectiveRequestProto {
  364. required CacheDirectiveInfoProto info = 1;
  365. optional uint32 cacheFlags = 2; // bits set using CacheFlag
  366. }
  367. message AddCacheDirectiveResponseProto {
  368. required int64 id = 1;
  369. }
  370. message ModifyCacheDirectiveRequestProto {
  371. required CacheDirectiveInfoProto info = 1;
  372. optional uint32 cacheFlags = 2; // bits set using CacheFlag
  373. }
  374. message ModifyCacheDirectiveResponseProto {
  375. }
  376. message RemoveCacheDirectiveRequestProto {
  377. required int64 id = 1;
  378. }
  379. message RemoveCacheDirectiveResponseProto {
  380. }
  381. message ListCacheDirectivesRequestProto {
  382. required int64 prevId = 1;
  383. required CacheDirectiveInfoProto filter = 2;
  384. }
  385. message CacheDirectiveEntryProto {
  386. required CacheDirectiveInfoProto info = 1;
  387. required CacheDirectiveStatsProto stats = 2;
  388. }
  389. message ListCacheDirectivesResponseProto {
  390. repeated CacheDirectiveEntryProto elements = 1;
  391. required bool hasMore = 2;
  392. }
  393. message CachePoolInfoProto {
  394. optional string poolName = 1;
  395. optional string ownerName = 2;
  396. optional string groupName = 3;
  397. optional int32 mode = 4;
  398. optional int64 limit = 5;
  399. optional int64 maxRelativeExpiry = 6;
  400. }
  401. message CachePoolStatsProto {
  402. required int64 bytesNeeded = 1;
  403. required int64 bytesCached = 2;
  404. required int64 bytesOverlimit = 3;
  405. required int64 filesNeeded = 4;
  406. required int64 filesCached = 5;
  407. }
  408. message AddCachePoolRequestProto {
  409. required CachePoolInfoProto info = 1;
  410. }
  411. message AddCachePoolResponseProto { // void response
  412. }
  413. message ModifyCachePoolRequestProto {
  414. required CachePoolInfoProto info = 1;
  415. }
  416. message ModifyCachePoolResponseProto { // void response
  417. }
  418. message RemoveCachePoolRequestProto {
  419. required string poolName = 1;
  420. }
  421. message RemoveCachePoolResponseProto { // void response
  422. }
  423. message ListCachePoolsRequestProto {
  424. required string prevPoolName = 1;
  425. }
  426. message ListCachePoolsResponseProto {
  427. repeated CachePoolEntryProto entries = 1;
  428. required bool hasMore = 2;
  429. }
  430. message CachePoolEntryProto {
  431. required CachePoolInfoProto info = 1;
  432. required CachePoolStatsProto stats = 2;
  433. }
  434. message GetFileLinkInfoRequestProto {
  435. required string src = 1;
  436. }
  437. message GetFileLinkInfoResponseProto {
  438. optional HdfsFileStatusProto fs = 1;
  439. }
  440. message GetContentSummaryRequestProto {
  441. required string path = 1;
  442. }
  443. message GetContentSummaryResponseProto {
  444. required ContentSummaryProto summary = 1;
  445. }
  446. message SetQuotaRequestProto {
  447. required string path = 1;
  448. required uint64 namespaceQuota = 2;
  449. required uint64 diskspaceQuota = 3;
  450. }
  451. message SetQuotaResponseProto { // void response
  452. }
  453. message FsyncRequestProto {
  454. required string src = 1;
  455. required string client = 2;
  456. optional sint64 lastBlockLength = 3 [default = -1];
  457. optional uint64 fileId = 4 [default = 0]; // default to GRANDFATHER_INODE_ID
  458. }
  459. message FsyncResponseProto { // void response
  460. }
  461. message SetTimesRequestProto {
  462. required string src = 1;
  463. required uint64 mtime = 2;
  464. required uint64 atime = 3;
  465. }
  466. message SetTimesResponseProto { // void response
  467. }
  468. message CreateSymlinkRequestProto {
  469. required string target = 1;
  470. required string link = 2;
  471. required FsPermissionProto dirPerm = 3;
  472. required bool createParent = 4;
  473. }
  474. message CreateSymlinkResponseProto { // void response
  475. }
  476. message GetLinkTargetRequestProto {
  477. required string path = 1;
  478. }
  479. message GetLinkTargetResponseProto {
  480. optional string targetPath = 1;
  481. }
  482. message UpdateBlockForPipelineRequestProto {
  483. required ExtendedBlockProto block = 1;
  484. required string clientName = 2;
  485. }
  486. message UpdateBlockForPipelineResponseProto {
  487. required LocatedBlockProto block = 1;
  488. }
  489. message UpdatePipelineRequestProto {
  490. required string clientName = 1;
  491. required ExtendedBlockProto oldBlock = 2;
  492. required ExtendedBlockProto newBlock = 3;
  493. repeated DatanodeIDProto newNodes = 4;
  494. repeated string storageIDs = 5;
  495. }
  496. message UpdatePipelineResponseProto { // void response
  497. }
  498. message SetBalancerBandwidthRequestProto {
  499. required int64 bandwidth = 1;
  500. }
  501. message SetBalancerBandwidthResponseProto { // void response
  502. }
  503. message GetDataEncryptionKeyRequestProto { // no parameters
  504. }
  505. message GetDataEncryptionKeyResponseProto {
  506. optional DataEncryptionKeyProto dataEncryptionKey = 1;
  507. }
  508. message CreateSnapshotRequestProto {
  509. required string snapshotRoot = 1;
  510. optional string snapshotName = 2;
  511. }
  512. message CreateSnapshotResponseProto {
  513. required string snapshotPath = 1;
  514. }
  515. message RenameSnapshotRequestProto {
  516. required string snapshotRoot = 1;
  517. required string snapshotOldName = 2;
  518. required string snapshotNewName = 3;
  519. }
  520. message RenameSnapshotResponseProto { // void response
  521. }
  522. message AllowSnapshotRequestProto {
  523. required string snapshotRoot = 1;
  524. }
  525. message AllowSnapshotResponseProto {
  526. }
  527. message DisallowSnapshotRequestProto {
  528. required string snapshotRoot = 1;
  529. }
  530. message DisallowSnapshotResponseProto {
  531. }
  532. message DeleteSnapshotRequestProto {
  533. required string snapshotRoot = 1;
  534. required string snapshotName = 2;
  535. }
  536. message DeleteSnapshotResponseProto { // void response
  537. }
  538. message CheckAccessRequestProto {
  539. required string path = 1;
  540. required AclEntryProto.FsActionProto mode = 2;
  541. }
  542. message CheckAccessResponseProto { // void response
  543. }
  544. message GetCurrentEditLogTxidRequestProto {
  545. }
  546. message GetCurrentEditLogTxidResponseProto {
  547. required int64 txid = 1;
  548. }
  549. message GetEditsFromTxidRequestProto {
  550. required int64 txid = 1;
  551. }
  552. message GetEditsFromTxidResponseProto {
  553. required EventsListProto eventsList = 1;
  554. }
  555. service ClientNamenodeProtocol {
  556. rpc getBlockLocations(GetBlockLocationsRequestProto)
  557. returns(GetBlockLocationsResponseProto);
  558. rpc getServerDefaults(GetServerDefaultsRequestProto)
  559. returns(GetServerDefaultsResponseProto);
  560. rpc create(CreateRequestProto)returns(CreateResponseProto);
  561. rpc append(AppendRequestProto) returns(AppendResponseProto);
  562. rpc setReplication(SetReplicationRequestProto)
  563. returns(SetReplicationResponseProto);
  564. rpc setStoragePolicy(SetStoragePolicyRequestProto)
  565. returns(SetStoragePolicyResponseProto);
  566. rpc getStoragePolicies(GetStoragePoliciesRequestProto)
  567. returns(GetStoragePoliciesResponseProto);
  568. rpc setPermission(SetPermissionRequestProto)
  569. returns(SetPermissionResponseProto);
  570. rpc setOwner(SetOwnerRequestProto) returns(SetOwnerResponseProto);
  571. rpc abandonBlock(AbandonBlockRequestProto) returns(AbandonBlockResponseProto);
  572. rpc addBlock(AddBlockRequestProto) returns(AddBlockResponseProto);
  573. rpc getAdditionalDatanode(GetAdditionalDatanodeRequestProto)
  574. returns(GetAdditionalDatanodeResponseProto);
  575. rpc complete(CompleteRequestProto) returns(CompleteResponseProto);
  576. rpc reportBadBlocks(ReportBadBlocksRequestProto)
  577. returns(ReportBadBlocksResponseProto);
  578. rpc concat(ConcatRequestProto) returns(ConcatResponseProto);
  579. rpc rename(RenameRequestProto) returns(RenameResponseProto);
  580. rpc rename2(Rename2RequestProto) returns(Rename2ResponseProto);
  581. rpc delete(DeleteRequestProto) returns(DeleteResponseProto);
  582. rpc mkdirs(MkdirsRequestProto) returns(MkdirsResponseProto);
  583. rpc getListing(GetListingRequestProto) returns(GetListingResponseProto);
  584. rpc renewLease(RenewLeaseRequestProto) returns(RenewLeaseResponseProto);
  585. rpc recoverLease(RecoverLeaseRequestProto)
  586. returns(RecoverLeaseResponseProto);
  587. rpc getFsStats(GetFsStatusRequestProto) returns(GetFsStatsResponseProto);
  588. rpc getDatanodeReport(GetDatanodeReportRequestProto)
  589. returns(GetDatanodeReportResponseProto);
  590. rpc getDatanodeStorageReport(GetDatanodeStorageReportRequestProto)
  591. returns(GetDatanodeStorageReportResponseProto);
  592. rpc getPreferredBlockSize(GetPreferredBlockSizeRequestProto)
  593. returns(GetPreferredBlockSizeResponseProto);
  594. rpc setSafeMode(SetSafeModeRequestProto)
  595. returns(SetSafeModeResponseProto);
  596. rpc saveNamespace(SaveNamespaceRequestProto)
  597. returns(SaveNamespaceResponseProto);
  598. rpc rollEdits(RollEditsRequestProto)
  599. returns(RollEditsResponseProto);
  600. rpc restoreFailedStorage(RestoreFailedStorageRequestProto)
  601. returns(RestoreFailedStorageResponseProto);
  602. rpc refreshNodes(RefreshNodesRequestProto) returns(RefreshNodesResponseProto);
  603. rpc finalizeUpgrade(FinalizeUpgradeRequestProto)
  604. returns(FinalizeUpgradeResponseProto);
  605. rpc rollingUpgrade(RollingUpgradeRequestProto)
  606. returns(RollingUpgradeResponseProto);
  607. rpc listCorruptFileBlocks(ListCorruptFileBlocksRequestProto)
  608. returns(ListCorruptFileBlocksResponseProto);
  609. rpc metaSave(MetaSaveRequestProto) returns(MetaSaveResponseProto);
  610. rpc getFileInfo(GetFileInfoRequestProto) returns(GetFileInfoResponseProto);
  611. rpc addCacheDirective(AddCacheDirectiveRequestProto)
  612. returns (AddCacheDirectiveResponseProto);
  613. rpc modifyCacheDirective(ModifyCacheDirectiveRequestProto)
  614. returns (ModifyCacheDirectiveResponseProto);
  615. rpc removeCacheDirective(RemoveCacheDirectiveRequestProto)
  616. returns (RemoveCacheDirectiveResponseProto);
  617. rpc listCacheDirectives(ListCacheDirectivesRequestProto)
  618. returns (ListCacheDirectivesResponseProto);
  619. rpc addCachePool(AddCachePoolRequestProto)
  620. returns(AddCachePoolResponseProto);
  621. rpc modifyCachePool(ModifyCachePoolRequestProto)
  622. returns(ModifyCachePoolResponseProto);
  623. rpc removeCachePool(RemoveCachePoolRequestProto)
  624. returns(RemoveCachePoolResponseProto);
  625. rpc listCachePools(ListCachePoolsRequestProto)
  626. returns(ListCachePoolsResponseProto);
  627. rpc getFileLinkInfo(GetFileLinkInfoRequestProto)
  628. returns(GetFileLinkInfoResponseProto);
  629. rpc getContentSummary(GetContentSummaryRequestProto)
  630. returns(GetContentSummaryResponseProto);
  631. rpc setQuota(SetQuotaRequestProto) returns(SetQuotaResponseProto);
  632. rpc fsync(FsyncRequestProto) returns(FsyncResponseProto);
  633. rpc setTimes(SetTimesRequestProto) returns(SetTimesResponseProto);
  634. rpc createSymlink(CreateSymlinkRequestProto)
  635. returns(CreateSymlinkResponseProto);
  636. rpc getLinkTarget(GetLinkTargetRequestProto)
  637. returns(GetLinkTargetResponseProto);
  638. rpc updateBlockForPipeline(UpdateBlockForPipelineRequestProto)
  639. returns(UpdateBlockForPipelineResponseProto);
  640. rpc updatePipeline(UpdatePipelineRequestProto)
  641. returns(UpdatePipelineResponseProto);
  642. rpc getDelegationToken(hadoop.common.GetDelegationTokenRequestProto)
  643. returns(hadoop.common.GetDelegationTokenResponseProto);
  644. rpc renewDelegationToken(hadoop.common.RenewDelegationTokenRequestProto)
  645. returns(hadoop.common.RenewDelegationTokenResponseProto);
  646. rpc cancelDelegationToken(hadoop.common.CancelDelegationTokenRequestProto)
  647. returns(hadoop.common.CancelDelegationTokenResponseProto);
  648. rpc setBalancerBandwidth(SetBalancerBandwidthRequestProto)
  649. returns(SetBalancerBandwidthResponseProto);
  650. rpc getDataEncryptionKey(GetDataEncryptionKeyRequestProto)
  651. returns(GetDataEncryptionKeyResponseProto);
  652. rpc createSnapshot(CreateSnapshotRequestProto)
  653. returns(CreateSnapshotResponseProto);
  654. rpc renameSnapshot(RenameSnapshotRequestProto)
  655. returns(RenameSnapshotResponseProto);
  656. rpc allowSnapshot(AllowSnapshotRequestProto)
  657. returns(AllowSnapshotResponseProto);
  658. rpc disallowSnapshot(DisallowSnapshotRequestProto)
  659. returns(DisallowSnapshotResponseProto);
  660. rpc getSnapshottableDirListing(GetSnapshottableDirListingRequestProto)
  661. returns(GetSnapshottableDirListingResponseProto);
  662. rpc deleteSnapshot(DeleteSnapshotRequestProto)
  663. returns(DeleteSnapshotResponseProto);
  664. rpc getSnapshotDiffReport(GetSnapshotDiffReportRequestProto)
  665. returns(GetSnapshotDiffReportResponseProto);
  666. rpc isFileClosed(IsFileClosedRequestProto)
  667. returns(IsFileClosedResponseProto);
  668. rpc modifyAclEntries(ModifyAclEntriesRequestProto)
  669. returns(ModifyAclEntriesResponseProto);
  670. rpc removeAclEntries(RemoveAclEntriesRequestProto)
  671. returns(RemoveAclEntriesResponseProto);
  672. rpc removeDefaultAcl(RemoveDefaultAclRequestProto)
  673. returns(RemoveDefaultAclResponseProto);
  674. rpc removeAcl(RemoveAclRequestProto)
  675. returns(RemoveAclResponseProto);
  676. rpc setAcl(SetAclRequestProto)
  677. returns(SetAclResponseProto);
  678. rpc getAclStatus(GetAclStatusRequestProto)
  679. returns(GetAclStatusResponseProto);
  680. rpc setXAttr(SetXAttrRequestProto)
  681. returns(SetXAttrResponseProto);
  682. rpc getXAttrs(GetXAttrsRequestProto)
  683. returns(GetXAttrsResponseProto);
  684. rpc listXAttrs(ListXAttrsRequestProto)
  685. returns(ListXAttrsResponseProto);
  686. rpc removeXAttr(RemoveXAttrRequestProto)
  687. returns(RemoveXAttrResponseProto);
  688. rpc checkAccess(CheckAccessRequestProto)
  689. returns(CheckAccessResponseProto);
  690. rpc createEncryptionZone(CreateEncryptionZoneRequestProto)
  691. returns(CreateEncryptionZoneResponseProto);
  692. rpc listEncryptionZones(ListEncryptionZonesRequestProto)
  693. returns(ListEncryptionZonesResponseProto);
  694. rpc getEZForPath(GetEZForPathRequestProto)
  695. returns(GetEZForPathResponseProto);
  696. rpc getCurrentEditLogTxid(GetCurrentEditLogTxidRequestProto)
  697. returns(GetCurrentEditLogTxidResponseProto);
  698. rpc getEditsFromTxid(GetEditsFromTxidRequestProto)
  699. returns(GetEditsFromTxidResponseProto);
  700. }