001// Generated by the protocol buffer compiler. DO NOT EDIT! 002// source: test_rpc_service.proto 003 004package org.apache.hadoop.ipc.protobuf; 005 006public final class TestRpcServiceProtos { 007 private TestRpcServiceProtos() {} 008 public static void registerAllExtensions( 009 com.google.protobuf.ExtensionRegistry registry) { 010 } 011 /** 012 * Protobuf service {@code hadoop.common.TestProtobufRpcProto} 013 * 014 * <pre> 015 ** 016 * A protobuf service for use in tests 017 * </pre> 018 */ 019 public static abstract class TestProtobufRpcProto 020 implements com.google.protobuf.Service { 021 protected TestProtobufRpcProto() {} 022 023 public interface Interface { 024 /** 025 * <code>rpc ping(.hadoop.common.EmptyRequestProto) returns (.hadoop.common.EmptyResponseProto);</code> 026 */ 027 public abstract void ping( 028 com.google.protobuf.RpcController controller, 029 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 030 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done); 031 032 /** 033 * <code>rpc echo(.hadoop.common.EchoRequestProto) returns (.hadoop.common.EchoResponseProto);</code> 034 */ 035 public abstract void echo( 036 com.google.protobuf.RpcController controller, 037 org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto request, 038 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto> done); 039 040 /** 041 * <code>rpc error(.hadoop.common.EmptyRequestProto) returns (.hadoop.common.EmptyResponseProto);</code> 042 */ 043 public abstract void error( 044 com.google.protobuf.RpcController controller, 045 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 046 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done); 047 048 /** 049 * <code>rpc error2(.hadoop.common.EmptyRequestProto) returns (.hadoop.common.EmptyResponseProto);</code> 050 */ 051 public abstract void error2( 052 com.google.protobuf.RpcController controller, 053 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 054 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done); 055 056 /** 057 * <code>rpc slowPing(.hadoop.common.SlowPingRequestProto) returns (.hadoop.common.EmptyResponseProto);</code> 058 */ 059 public abstract void slowPing( 060 com.google.protobuf.RpcController controller, 061 org.apache.hadoop.ipc.protobuf.TestProtos.SlowPingRequestProto request, 062 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done); 063 064 /** 065 * <code>rpc echo2(.hadoop.common.EchoRequestProto2) returns (.hadoop.common.EchoResponseProto2);</code> 066 */ 067 public abstract void echo2( 068 com.google.protobuf.RpcController controller, 069 org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto2 request, 070 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto2> done); 071 072 /** 073 * <code>rpc add(.hadoop.common.AddRequestProto) returns (.hadoop.common.AddResponseProto);</code> 074 */ 075 public abstract void add( 076 com.google.protobuf.RpcController controller, 077 org.apache.hadoop.ipc.protobuf.TestProtos.AddRequestProto request, 078 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.AddResponseProto> done); 079 080 /** 081 * <code>rpc add2(.hadoop.common.AddRequestProto2) returns (.hadoop.common.AddResponseProto);</code> 082 */ 083 public abstract void add2( 084 com.google.protobuf.RpcController controller, 085 org.apache.hadoop.ipc.protobuf.TestProtos.AddRequestProto2 request, 086 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.AddResponseProto> done); 087 088 /** 089 * <code>rpc testServerGet(.hadoop.common.EmptyRequestProto) returns (.hadoop.common.EmptyResponseProto);</code> 090 */ 091 public abstract void testServerGet( 092 com.google.protobuf.RpcController controller, 093 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 094 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done); 095 096 /** 097 * <code>rpc exchange(.hadoop.common.ExchangeRequestProto) returns (.hadoop.common.ExchangeResponseProto);</code> 098 */ 099 public abstract void exchange( 100 com.google.protobuf.RpcController controller, 101 org.apache.hadoop.ipc.protobuf.TestProtos.ExchangeRequestProto request, 102 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.ExchangeResponseProto> done); 103 104 /** 105 * <code>rpc sleep(.hadoop.common.SleepRequestProto) returns (.hadoop.common.EmptyResponseProto);</code> 106 */ 107 public abstract void sleep( 108 com.google.protobuf.RpcController controller, 109 org.apache.hadoop.ipc.protobuf.TestProtos.SleepRequestProto request, 110 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done); 111 112 /** 113 * <code>rpc getAuthMethod(.hadoop.common.EmptyRequestProto) returns (.hadoop.common.AuthMethodResponseProto);</code> 114 */ 115 public abstract void getAuthMethod( 116 com.google.protobuf.RpcController controller, 117 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 118 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.AuthMethodResponseProto> done); 119 120 /** 121 * <code>rpc getAuthUser(.hadoop.common.EmptyRequestProto) returns (.hadoop.common.AuthUserResponseProto);</code> 122 */ 123 public abstract void getAuthUser( 124 com.google.protobuf.RpcController controller, 125 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 126 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.AuthUserResponseProto> done); 127 128 /** 129 * <code>rpc echoPostponed(.hadoop.common.EchoRequestProto) returns (.hadoop.common.EchoResponseProto);</code> 130 */ 131 public abstract void echoPostponed( 132 com.google.protobuf.RpcController controller, 133 org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto request, 134 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto> done); 135 136 /** 137 * <code>rpc sendPostponed(.hadoop.common.EmptyRequestProto) returns (.hadoop.common.EmptyResponseProto);</code> 138 */ 139 public abstract void sendPostponed( 140 com.google.protobuf.RpcController controller, 141 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 142 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done); 143 144 } 145 146 public static com.google.protobuf.Service newReflectiveService( 147 final Interface impl) { 148 return new TestProtobufRpcProto() { 149 @java.lang.Override 150 public void ping( 151 com.google.protobuf.RpcController controller, 152 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 153 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done) { 154 impl.ping(controller, request, done); 155 } 156 157 @java.lang.Override 158 public void echo( 159 com.google.protobuf.RpcController controller, 160 org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto request, 161 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto> done) { 162 impl.echo(controller, request, done); 163 } 164 165 @java.lang.Override 166 public void error( 167 com.google.protobuf.RpcController controller, 168 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 169 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done) { 170 impl.error(controller, request, done); 171 } 172 173 @java.lang.Override 174 public void error2( 175 com.google.protobuf.RpcController controller, 176 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 177 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done) { 178 impl.error2(controller, request, done); 179 } 180 181 @java.lang.Override 182 public void slowPing( 183 com.google.protobuf.RpcController controller, 184 org.apache.hadoop.ipc.protobuf.TestProtos.SlowPingRequestProto request, 185 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done) { 186 impl.slowPing(controller, request, done); 187 } 188 189 @java.lang.Override 190 public void echo2( 191 com.google.protobuf.RpcController controller, 192 org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto2 request, 193 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto2> done) { 194 impl.echo2(controller, request, done); 195 } 196 197 @java.lang.Override 198 public void add( 199 com.google.protobuf.RpcController controller, 200 org.apache.hadoop.ipc.protobuf.TestProtos.AddRequestProto request, 201 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.AddResponseProto> done) { 202 impl.add(controller, request, done); 203 } 204 205 @java.lang.Override 206 public void add2( 207 com.google.protobuf.RpcController controller, 208 org.apache.hadoop.ipc.protobuf.TestProtos.AddRequestProto2 request, 209 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.AddResponseProto> done) { 210 impl.add2(controller, request, done); 211 } 212 213 @java.lang.Override 214 public void testServerGet( 215 com.google.protobuf.RpcController controller, 216 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 217 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done) { 218 impl.testServerGet(controller, request, done); 219 } 220 221 @java.lang.Override 222 public void exchange( 223 com.google.protobuf.RpcController controller, 224 org.apache.hadoop.ipc.protobuf.TestProtos.ExchangeRequestProto request, 225 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.ExchangeResponseProto> done) { 226 impl.exchange(controller, request, done); 227 } 228 229 @java.lang.Override 230 public void sleep( 231 com.google.protobuf.RpcController controller, 232 org.apache.hadoop.ipc.protobuf.TestProtos.SleepRequestProto request, 233 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done) { 234 impl.sleep(controller, request, done); 235 } 236 237 @java.lang.Override 238 public void getAuthMethod( 239 com.google.protobuf.RpcController controller, 240 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 241 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.AuthMethodResponseProto> done) { 242 impl.getAuthMethod(controller, request, done); 243 } 244 245 @java.lang.Override 246 public void getAuthUser( 247 com.google.protobuf.RpcController controller, 248 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 249 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.AuthUserResponseProto> done) { 250 impl.getAuthUser(controller, request, done); 251 } 252 253 @java.lang.Override 254 public void echoPostponed( 255 com.google.protobuf.RpcController controller, 256 org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto request, 257 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto> done) { 258 impl.echoPostponed(controller, request, done); 259 } 260 261 @java.lang.Override 262 public void sendPostponed( 263 com.google.protobuf.RpcController controller, 264 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 265 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done) { 266 impl.sendPostponed(controller, request, done); 267 } 268 269 }; 270 } 271 272 public static com.google.protobuf.BlockingService 273 newReflectiveBlockingService(final BlockingInterface impl) { 274 return new com.google.protobuf.BlockingService() { 275 public final com.google.protobuf.Descriptors.ServiceDescriptor 276 getDescriptorForType() { 277 return getDescriptor(); 278 } 279 280 public final com.google.protobuf.Message callBlockingMethod( 281 com.google.protobuf.Descriptors.MethodDescriptor method, 282 com.google.protobuf.RpcController controller, 283 com.google.protobuf.Message request) 284 throws com.google.protobuf.ServiceException { 285 if (method.getService() != getDescriptor()) { 286 throw new java.lang.IllegalArgumentException( 287 "Service.callBlockingMethod() given method descriptor for " + 288 "wrong service type."); 289 } 290 switch(method.getIndex()) { 291 case 0: 292 return impl.ping(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto)request); 293 case 1: 294 return impl.echo(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto)request); 295 case 2: 296 return impl.error(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto)request); 297 case 3: 298 return impl.error2(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto)request); 299 case 4: 300 return impl.slowPing(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.SlowPingRequestProto)request); 301 case 5: 302 return impl.echo2(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto2)request); 303 case 6: 304 return impl.add(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.AddRequestProto)request); 305 case 7: 306 return impl.add2(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.AddRequestProto2)request); 307 case 8: 308 return impl.testServerGet(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto)request); 309 case 9: 310 return impl.exchange(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.ExchangeRequestProto)request); 311 case 10: 312 return impl.sleep(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.SleepRequestProto)request); 313 case 11: 314 return impl.getAuthMethod(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto)request); 315 case 12: 316 return impl.getAuthUser(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto)request); 317 case 13: 318 return impl.echoPostponed(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto)request); 319 case 14: 320 return impl.sendPostponed(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto)request); 321 default: 322 throw new java.lang.AssertionError("Can't get here."); 323 } 324 } 325 326 public final com.google.protobuf.Message 327 getRequestPrototype( 328 com.google.protobuf.Descriptors.MethodDescriptor method) { 329 if (method.getService() != getDescriptor()) { 330 throw new java.lang.IllegalArgumentException( 331 "Service.getRequestPrototype() given method " + 332 "descriptor for wrong service type."); 333 } 334 switch(method.getIndex()) { 335 case 0: 336 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto.getDefaultInstance(); 337 case 1: 338 return org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto.getDefaultInstance(); 339 case 2: 340 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto.getDefaultInstance(); 341 case 3: 342 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto.getDefaultInstance(); 343 case 4: 344 return org.apache.hadoop.ipc.protobuf.TestProtos.SlowPingRequestProto.getDefaultInstance(); 345 case 5: 346 return org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto2.getDefaultInstance(); 347 case 6: 348 return org.apache.hadoop.ipc.protobuf.TestProtos.AddRequestProto.getDefaultInstance(); 349 case 7: 350 return org.apache.hadoop.ipc.protobuf.TestProtos.AddRequestProto2.getDefaultInstance(); 351 case 8: 352 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto.getDefaultInstance(); 353 case 9: 354 return org.apache.hadoop.ipc.protobuf.TestProtos.ExchangeRequestProto.getDefaultInstance(); 355 case 10: 356 return org.apache.hadoop.ipc.protobuf.TestProtos.SleepRequestProto.getDefaultInstance(); 357 case 11: 358 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto.getDefaultInstance(); 359 case 12: 360 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto.getDefaultInstance(); 361 case 13: 362 return org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto.getDefaultInstance(); 363 case 14: 364 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto.getDefaultInstance(); 365 default: 366 throw new java.lang.AssertionError("Can't get here."); 367 } 368 } 369 370 public final com.google.protobuf.Message 371 getResponsePrototype( 372 com.google.protobuf.Descriptors.MethodDescriptor method) { 373 if (method.getService() != getDescriptor()) { 374 throw new java.lang.IllegalArgumentException( 375 "Service.getResponsePrototype() given method " + 376 "descriptor for wrong service type."); 377 } 378 switch(method.getIndex()) { 379 case 0: 380 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(); 381 case 1: 382 return org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto.getDefaultInstance(); 383 case 2: 384 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(); 385 case 3: 386 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(); 387 case 4: 388 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(); 389 case 5: 390 return org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto2.getDefaultInstance(); 391 case 6: 392 return org.apache.hadoop.ipc.protobuf.TestProtos.AddResponseProto.getDefaultInstance(); 393 case 7: 394 return org.apache.hadoop.ipc.protobuf.TestProtos.AddResponseProto.getDefaultInstance(); 395 case 8: 396 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(); 397 case 9: 398 return org.apache.hadoop.ipc.protobuf.TestProtos.ExchangeResponseProto.getDefaultInstance(); 399 case 10: 400 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(); 401 case 11: 402 return org.apache.hadoop.ipc.protobuf.TestProtos.AuthMethodResponseProto.getDefaultInstance(); 403 case 12: 404 return org.apache.hadoop.ipc.protobuf.TestProtos.AuthUserResponseProto.getDefaultInstance(); 405 case 13: 406 return org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto.getDefaultInstance(); 407 case 14: 408 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(); 409 default: 410 throw new java.lang.AssertionError("Can't get here."); 411 } 412 } 413 414 }; 415 } 416 417 /** 418 * <code>rpc ping(.hadoop.common.EmptyRequestProto) returns (.hadoop.common.EmptyResponseProto);</code> 419 */ 420 public abstract void ping( 421 com.google.protobuf.RpcController controller, 422 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 423 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done); 424 425 /** 426 * <code>rpc echo(.hadoop.common.EchoRequestProto) returns (.hadoop.common.EchoResponseProto);</code> 427 */ 428 public abstract void echo( 429 com.google.protobuf.RpcController controller, 430 org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto request, 431 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto> done); 432 433 /** 434 * <code>rpc error(.hadoop.common.EmptyRequestProto) returns (.hadoop.common.EmptyResponseProto);</code> 435 */ 436 public abstract void error( 437 com.google.protobuf.RpcController controller, 438 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 439 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done); 440 441 /** 442 * <code>rpc error2(.hadoop.common.EmptyRequestProto) returns (.hadoop.common.EmptyResponseProto);</code> 443 */ 444 public abstract void error2( 445 com.google.protobuf.RpcController controller, 446 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 447 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done); 448 449 /** 450 * <code>rpc slowPing(.hadoop.common.SlowPingRequestProto) returns (.hadoop.common.EmptyResponseProto);</code> 451 */ 452 public abstract void slowPing( 453 com.google.protobuf.RpcController controller, 454 org.apache.hadoop.ipc.protobuf.TestProtos.SlowPingRequestProto request, 455 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done); 456 457 /** 458 * <code>rpc echo2(.hadoop.common.EchoRequestProto2) returns (.hadoop.common.EchoResponseProto2);</code> 459 */ 460 public abstract void echo2( 461 com.google.protobuf.RpcController controller, 462 org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto2 request, 463 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto2> done); 464 465 /** 466 * <code>rpc add(.hadoop.common.AddRequestProto) returns (.hadoop.common.AddResponseProto);</code> 467 */ 468 public abstract void add( 469 com.google.protobuf.RpcController controller, 470 org.apache.hadoop.ipc.protobuf.TestProtos.AddRequestProto request, 471 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.AddResponseProto> done); 472 473 /** 474 * <code>rpc add2(.hadoop.common.AddRequestProto2) returns (.hadoop.common.AddResponseProto);</code> 475 */ 476 public abstract void add2( 477 com.google.protobuf.RpcController controller, 478 org.apache.hadoop.ipc.protobuf.TestProtos.AddRequestProto2 request, 479 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.AddResponseProto> done); 480 481 /** 482 * <code>rpc testServerGet(.hadoop.common.EmptyRequestProto) returns (.hadoop.common.EmptyResponseProto);</code> 483 */ 484 public abstract void testServerGet( 485 com.google.protobuf.RpcController controller, 486 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 487 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done); 488 489 /** 490 * <code>rpc exchange(.hadoop.common.ExchangeRequestProto) returns (.hadoop.common.ExchangeResponseProto);</code> 491 */ 492 public abstract void exchange( 493 com.google.protobuf.RpcController controller, 494 org.apache.hadoop.ipc.protobuf.TestProtos.ExchangeRequestProto request, 495 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.ExchangeResponseProto> done); 496 497 /** 498 * <code>rpc sleep(.hadoop.common.SleepRequestProto) returns (.hadoop.common.EmptyResponseProto);</code> 499 */ 500 public abstract void sleep( 501 com.google.protobuf.RpcController controller, 502 org.apache.hadoop.ipc.protobuf.TestProtos.SleepRequestProto request, 503 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done); 504 505 /** 506 * <code>rpc getAuthMethod(.hadoop.common.EmptyRequestProto) returns (.hadoop.common.AuthMethodResponseProto);</code> 507 */ 508 public abstract void getAuthMethod( 509 com.google.protobuf.RpcController controller, 510 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 511 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.AuthMethodResponseProto> done); 512 513 /** 514 * <code>rpc getAuthUser(.hadoop.common.EmptyRequestProto) returns (.hadoop.common.AuthUserResponseProto);</code> 515 */ 516 public abstract void getAuthUser( 517 com.google.protobuf.RpcController controller, 518 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 519 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.AuthUserResponseProto> done); 520 521 /** 522 * <code>rpc echoPostponed(.hadoop.common.EchoRequestProto) returns (.hadoop.common.EchoResponseProto);</code> 523 */ 524 public abstract void echoPostponed( 525 com.google.protobuf.RpcController controller, 526 org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto request, 527 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto> done); 528 529 /** 530 * <code>rpc sendPostponed(.hadoop.common.EmptyRequestProto) returns (.hadoop.common.EmptyResponseProto);</code> 531 */ 532 public abstract void sendPostponed( 533 com.google.protobuf.RpcController controller, 534 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 535 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done); 536 537 public static final 538 com.google.protobuf.Descriptors.ServiceDescriptor 539 getDescriptor() { 540 return org.apache.hadoop.ipc.protobuf.TestRpcServiceProtos.getDescriptor().getServices().get(0); 541 } 542 public final com.google.protobuf.Descriptors.ServiceDescriptor 543 getDescriptorForType() { 544 return getDescriptor(); 545 } 546 547 public final void callMethod( 548 com.google.protobuf.Descriptors.MethodDescriptor method, 549 com.google.protobuf.RpcController controller, 550 com.google.protobuf.Message request, 551 com.google.protobuf.RpcCallback< 552 com.google.protobuf.Message> done) { 553 if (method.getService() != getDescriptor()) { 554 throw new java.lang.IllegalArgumentException( 555 "Service.callMethod() given method descriptor for wrong " + 556 "service type."); 557 } 558 switch(method.getIndex()) { 559 case 0: 560 this.ping(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto)request, 561 com.google.protobuf.RpcUtil.<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto>specializeCallback( 562 done)); 563 return; 564 case 1: 565 this.echo(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto)request, 566 com.google.protobuf.RpcUtil.<org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto>specializeCallback( 567 done)); 568 return; 569 case 2: 570 this.error(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto)request, 571 com.google.protobuf.RpcUtil.<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto>specializeCallback( 572 done)); 573 return; 574 case 3: 575 this.error2(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto)request, 576 com.google.protobuf.RpcUtil.<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto>specializeCallback( 577 done)); 578 return; 579 case 4: 580 this.slowPing(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.SlowPingRequestProto)request, 581 com.google.protobuf.RpcUtil.<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto>specializeCallback( 582 done)); 583 return; 584 case 5: 585 this.echo2(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto2)request, 586 com.google.protobuf.RpcUtil.<org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto2>specializeCallback( 587 done)); 588 return; 589 case 6: 590 this.add(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.AddRequestProto)request, 591 com.google.protobuf.RpcUtil.<org.apache.hadoop.ipc.protobuf.TestProtos.AddResponseProto>specializeCallback( 592 done)); 593 return; 594 case 7: 595 this.add2(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.AddRequestProto2)request, 596 com.google.protobuf.RpcUtil.<org.apache.hadoop.ipc.protobuf.TestProtos.AddResponseProto>specializeCallback( 597 done)); 598 return; 599 case 8: 600 this.testServerGet(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto)request, 601 com.google.protobuf.RpcUtil.<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto>specializeCallback( 602 done)); 603 return; 604 case 9: 605 this.exchange(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.ExchangeRequestProto)request, 606 com.google.protobuf.RpcUtil.<org.apache.hadoop.ipc.protobuf.TestProtos.ExchangeResponseProto>specializeCallback( 607 done)); 608 return; 609 case 10: 610 this.sleep(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.SleepRequestProto)request, 611 com.google.protobuf.RpcUtil.<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto>specializeCallback( 612 done)); 613 return; 614 case 11: 615 this.getAuthMethod(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto)request, 616 com.google.protobuf.RpcUtil.<org.apache.hadoop.ipc.protobuf.TestProtos.AuthMethodResponseProto>specializeCallback( 617 done)); 618 return; 619 case 12: 620 this.getAuthUser(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto)request, 621 com.google.protobuf.RpcUtil.<org.apache.hadoop.ipc.protobuf.TestProtos.AuthUserResponseProto>specializeCallback( 622 done)); 623 return; 624 case 13: 625 this.echoPostponed(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto)request, 626 com.google.protobuf.RpcUtil.<org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto>specializeCallback( 627 done)); 628 return; 629 case 14: 630 this.sendPostponed(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto)request, 631 com.google.protobuf.RpcUtil.<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto>specializeCallback( 632 done)); 633 return; 634 default: 635 throw new java.lang.AssertionError("Can't get here."); 636 } 637 } 638 639 public final com.google.protobuf.Message 640 getRequestPrototype( 641 com.google.protobuf.Descriptors.MethodDescriptor method) { 642 if (method.getService() != getDescriptor()) { 643 throw new java.lang.IllegalArgumentException( 644 "Service.getRequestPrototype() given method " + 645 "descriptor for wrong service type."); 646 } 647 switch(method.getIndex()) { 648 case 0: 649 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto.getDefaultInstance(); 650 case 1: 651 return org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto.getDefaultInstance(); 652 case 2: 653 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto.getDefaultInstance(); 654 case 3: 655 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto.getDefaultInstance(); 656 case 4: 657 return org.apache.hadoop.ipc.protobuf.TestProtos.SlowPingRequestProto.getDefaultInstance(); 658 case 5: 659 return org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto2.getDefaultInstance(); 660 case 6: 661 return org.apache.hadoop.ipc.protobuf.TestProtos.AddRequestProto.getDefaultInstance(); 662 case 7: 663 return org.apache.hadoop.ipc.protobuf.TestProtos.AddRequestProto2.getDefaultInstance(); 664 case 8: 665 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto.getDefaultInstance(); 666 case 9: 667 return org.apache.hadoop.ipc.protobuf.TestProtos.ExchangeRequestProto.getDefaultInstance(); 668 case 10: 669 return org.apache.hadoop.ipc.protobuf.TestProtos.SleepRequestProto.getDefaultInstance(); 670 case 11: 671 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto.getDefaultInstance(); 672 case 12: 673 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto.getDefaultInstance(); 674 case 13: 675 return org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto.getDefaultInstance(); 676 case 14: 677 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto.getDefaultInstance(); 678 default: 679 throw new java.lang.AssertionError("Can't get here."); 680 } 681 } 682 683 public final com.google.protobuf.Message 684 getResponsePrototype( 685 com.google.protobuf.Descriptors.MethodDescriptor method) { 686 if (method.getService() != getDescriptor()) { 687 throw new java.lang.IllegalArgumentException( 688 "Service.getResponsePrototype() given method " + 689 "descriptor for wrong service type."); 690 } 691 switch(method.getIndex()) { 692 case 0: 693 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(); 694 case 1: 695 return org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto.getDefaultInstance(); 696 case 2: 697 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(); 698 case 3: 699 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(); 700 case 4: 701 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(); 702 case 5: 703 return org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto2.getDefaultInstance(); 704 case 6: 705 return org.apache.hadoop.ipc.protobuf.TestProtos.AddResponseProto.getDefaultInstance(); 706 case 7: 707 return org.apache.hadoop.ipc.protobuf.TestProtos.AddResponseProto.getDefaultInstance(); 708 case 8: 709 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(); 710 case 9: 711 return org.apache.hadoop.ipc.protobuf.TestProtos.ExchangeResponseProto.getDefaultInstance(); 712 case 10: 713 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(); 714 case 11: 715 return org.apache.hadoop.ipc.protobuf.TestProtos.AuthMethodResponseProto.getDefaultInstance(); 716 case 12: 717 return org.apache.hadoop.ipc.protobuf.TestProtos.AuthUserResponseProto.getDefaultInstance(); 718 case 13: 719 return org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto.getDefaultInstance(); 720 case 14: 721 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(); 722 default: 723 throw new java.lang.AssertionError("Can't get here."); 724 } 725 } 726 727 public static Stub newStub( 728 com.google.protobuf.RpcChannel channel) { 729 return new Stub(channel); 730 } 731 732 public static final class Stub extends org.apache.hadoop.ipc.protobuf.TestRpcServiceProtos.TestProtobufRpcProto implements Interface { 733 private Stub(com.google.protobuf.RpcChannel channel) { 734 this.channel = channel; 735 } 736 737 private final com.google.protobuf.RpcChannel channel; 738 739 public com.google.protobuf.RpcChannel getChannel() { 740 return channel; 741 } 742 743 public void ping( 744 com.google.protobuf.RpcController controller, 745 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 746 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done) { 747 channel.callMethod( 748 getDescriptor().getMethods().get(0), 749 controller, 750 request, 751 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(), 752 com.google.protobuf.RpcUtil.generalizeCallback( 753 done, 754 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.class, 755 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance())); 756 } 757 758 public void echo( 759 com.google.protobuf.RpcController controller, 760 org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto request, 761 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto> done) { 762 channel.callMethod( 763 getDescriptor().getMethods().get(1), 764 controller, 765 request, 766 org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto.getDefaultInstance(), 767 com.google.protobuf.RpcUtil.generalizeCallback( 768 done, 769 org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto.class, 770 org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto.getDefaultInstance())); 771 } 772 773 public void error( 774 com.google.protobuf.RpcController controller, 775 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 776 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done) { 777 channel.callMethod( 778 getDescriptor().getMethods().get(2), 779 controller, 780 request, 781 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(), 782 com.google.protobuf.RpcUtil.generalizeCallback( 783 done, 784 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.class, 785 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance())); 786 } 787 788 public void error2( 789 com.google.protobuf.RpcController controller, 790 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 791 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done) { 792 channel.callMethod( 793 getDescriptor().getMethods().get(3), 794 controller, 795 request, 796 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(), 797 com.google.protobuf.RpcUtil.generalizeCallback( 798 done, 799 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.class, 800 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance())); 801 } 802 803 public void slowPing( 804 com.google.protobuf.RpcController controller, 805 org.apache.hadoop.ipc.protobuf.TestProtos.SlowPingRequestProto request, 806 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done) { 807 channel.callMethod( 808 getDescriptor().getMethods().get(4), 809 controller, 810 request, 811 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(), 812 com.google.protobuf.RpcUtil.generalizeCallback( 813 done, 814 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.class, 815 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance())); 816 } 817 818 public void echo2( 819 com.google.protobuf.RpcController controller, 820 org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto2 request, 821 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto2> done) { 822 channel.callMethod( 823 getDescriptor().getMethods().get(5), 824 controller, 825 request, 826 org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto2.getDefaultInstance(), 827 com.google.protobuf.RpcUtil.generalizeCallback( 828 done, 829 org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto2.class, 830 org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto2.getDefaultInstance())); 831 } 832 833 public void add( 834 com.google.protobuf.RpcController controller, 835 org.apache.hadoop.ipc.protobuf.TestProtos.AddRequestProto request, 836 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.AddResponseProto> done) { 837 channel.callMethod( 838 getDescriptor().getMethods().get(6), 839 controller, 840 request, 841 org.apache.hadoop.ipc.protobuf.TestProtos.AddResponseProto.getDefaultInstance(), 842 com.google.protobuf.RpcUtil.generalizeCallback( 843 done, 844 org.apache.hadoop.ipc.protobuf.TestProtos.AddResponseProto.class, 845 org.apache.hadoop.ipc.protobuf.TestProtos.AddResponseProto.getDefaultInstance())); 846 } 847 848 public void add2( 849 com.google.protobuf.RpcController controller, 850 org.apache.hadoop.ipc.protobuf.TestProtos.AddRequestProto2 request, 851 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.AddResponseProto> done) { 852 channel.callMethod( 853 getDescriptor().getMethods().get(7), 854 controller, 855 request, 856 org.apache.hadoop.ipc.protobuf.TestProtos.AddResponseProto.getDefaultInstance(), 857 com.google.protobuf.RpcUtil.generalizeCallback( 858 done, 859 org.apache.hadoop.ipc.protobuf.TestProtos.AddResponseProto.class, 860 org.apache.hadoop.ipc.protobuf.TestProtos.AddResponseProto.getDefaultInstance())); 861 } 862 863 public void testServerGet( 864 com.google.protobuf.RpcController controller, 865 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 866 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done) { 867 channel.callMethod( 868 getDescriptor().getMethods().get(8), 869 controller, 870 request, 871 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(), 872 com.google.protobuf.RpcUtil.generalizeCallback( 873 done, 874 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.class, 875 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance())); 876 } 877 878 public void exchange( 879 com.google.protobuf.RpcController controller, 880 org.apache.hadoop.ipc.protobuf.TestProtos.ExchangeRequestProto request, 881 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.ExchangeResponseProto> done) { 882 channel.callMethod( 883 getDescriptor().getMethods().get(9), 884 controller, 885 request, 886 org.apache.hadoop.ipc.protobuf.TestProtos.ExchangeResponseProto.getDefaultInstance(), 887 com.google.protobuf.RpcUtil.generalizeCallback( 888 done, 889 org.apache.hadoop.ipc.protobuf.TestProtos.ExchangeResponseProto.class, 890 org.apache.hadoop.ipc.protobuf.TestProtos.ExchangeResponseProto.getDefaultInstance())); 891 } 892 893 public void sleep( 894 com.google.protobuf.RpcController controller, 895 org.apache.hadoop.ipc.protobuf.TestProtos.SleepRequestProto request, 896 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done) { 897 channel.callMethod( 898 getDescriptor().getMethods().get(10), 899 controller, 900 request, 901 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(), 902 com.google.protobuf.RpcUtil.generalizeCallback( 903 done, 904 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.class, 905 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance())); 906 } 907 908 public void getAuthMethod( 909 com.google.protobuf.RpcController controller, 910 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 911 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.AuthMethodResponseProto> done) { 912 channel.callMethod( 913 getDescriptor().getMethods().get(11), 914 controller, 915 request, 916 org.apache.hadoop.ipc.protobuf.TestProtos.AuthMethodResponseProto.getDefaultInstance(), 917 com.google.protobuf.RpcUtil.generalizeCallback( 918 done, 919 org.apache.hadoop.ipc.protobuf.TestProtos.AuthMethodResponseProto.class, 920 org.apache.hadoop.ipc.protobuf.TestProtos.AuthMethodResponseProto.getDefaultInstance())); 921 } 922 923 public void getAuthUser( 924 com.google.protobuf.RpcController controller, 925 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 926 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.AuthUserResponseProto> done) { 927 channel.callMethod( 928 getDescriptor().getMethods().get(12), 929 controller, 930 request, 931 org.apache.hadoop.ipc.protobuf.TestProtos.AuthUserResponseProto.getDefaultInstance(), 932 com.google.protobuf.RpcUtil.generalizeCallback( 933 done, 934 org.apache.hadoop.ipc.protobuf.TestProtos.AuthUserResponseProto.class, 935 org.apache.hadoop.ipc.protobuf.TestProtos.AuthUserResponseProto.getDefaultInstance())); 936 } 937 938 public void echoPostponed( 939 com.google.protobuf.RpcController controller, 940 org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto request, 941 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto> done) { 942 channel.callMethod( 943 getDescriptor().getMethods().get(13), 944 controller, 945 request, 946 org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto.getDefaultInstance(), 947 com.google.protobuf.RpcUtil.generalizeCallback( 948 done, 949 org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto.class, 950 org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto.getDefaultInstance())); 951 } 952 953 public void sendPostponed( 954 com.google.protobuf.RpcController controller, 955 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 956 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done) { 957 channel.callMethod( 958 getDescriptor().getMethods().get(14), 959 controller, 960 request, 961 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(), 962 com.google.protobuf.RpcUtil.generalizeCallback( 963 done, 964 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.class, 965 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance())); 966 } 967 } 968 969 public static BlockingInterface newBlockingStub( 970 com.google.protobuf.BlockingRpcChannel channel) { 971 return new BlockingStub(channel); 972 } 973 974 public interface BlockingInterface { 975 public org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto ping( 976 com.google.protobuf.RpcController controller, 977 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request) 978 throws com.google.protobuf.ServiceException; 979 980 public org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto echo( 981 com.google.protobuf.RpcController controller, 982 org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto request) 983 throws com.google.protobuf.ServiceException; 984 985 public org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto error( 986 com.google.protobuf.RpcController controller, 987 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request) 988 throws com.google.protobuf.ServiceException; 989 990 public org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto error2( 991 com.google.protobuf.RpcController controller, 992 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request) 993 throws com.google.protobuf.ServiceException; 994 995 public org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto slowPing( 996 com.google.protobuf.RpcController controller, 997 org.apache.hadoop.ipc.protobuf.TestProtos.SlowPingRequestProto request) 998 throws com.google.protobuf.ServiceException; 999 1000 public org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto2 echo2( 1001 com.google.protobuf.RpcController controller, 1002 org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto2 request) 1003 throws com.google.protobuf.ServiceException; 1004 1005 public org.apache.hadoop.ipc.protobuf.TestProtos.AddResponseProto add( 1006 com.google.protobuf.RpcController controller, 1007 org.apache.hadoop.ipc.protobuf.TestProtos.AddRequestProto request) 1008 throws com.google.protobuf.ServiceException; 1009 1010 public org.apache.hadoop.ipc.protobuf.TestProtos.AddResponseProto add2( 1011 com.google.protobuf.RpcController controller, 1012 org.apache.hadoop.ipc.protobuf.TestProtos.AddRequestProto2 request) 1013 throws com.google.protobuf.ServiceException; 1014 1015 public org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto testServerGet( 1016 com.google.protobuf.RpcController controller, 1017 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request) 1018 throws com.google.protobuf.ServiceException; 1019 1020 public org.apache.hadoop.ipc.protobuf.TestProtos.ExchangeResponseProto exchange( 1021 com.google.protobuf.RpcController controller, 1022 org.apache.hadoop.ipc.protobuf.TestProtos.ExchangeRequestProto request) 1023 throws com.google.protobuf.ServiceException; 1024 1025 public org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto sleep( 1026 com.google.protobuf.RpcController controller, 1027 org.apache.hadoop.ipc.protobuf.TestProtos.SleepRequestProto request) 1028 throws com.google.protobuf.ServiceException; 1029 1030 public org.apache.hadoop.ipc.protobuf.TestProtos.AuthMethodResponseProto getAuthMethod( 1031 com.google.protobuf.RpcController controller, 1032 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request) 1033 throws com.google.protobuf.ServiceException; 1034 1035 public org.apache.hadoop.ipc.protobuf.TestProtos.AuthUserResponseProto getAuthUser( 1036 com.google.protobuf.RpcController controller, 1037 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request) 1038 throws com.google.protobuf.ServiceException; 1039 1040 public org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto echoPostponed( 1041 com.google.protobuf.RpcController controller, 1042 org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto request) 1043 throws com.google.protobuf.ServiceException; 1044 1045 public org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto sendPostponed( 1046 com.google.protobuf.RpcController controller, 1047 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request) 1048 throws com.google.protobuf.ServiceException; 1049 } 1050 1051 private static final class BlockingStub implements BlockingInterface { 1052 private BlockingStub(com.google.protobuf.BlockingRpcChannel channel) { 1053 this.channel = channel; 1054 } 1055 1056 private final com.google.protobuf.BlockingRpcChannel channel; 1057 1058 public org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto ping( 1059 com.google.protobuf.RpcController controller, 1060 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request) 1061 throws com.google.protobuf.ServiceException { 1062 return (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto) channel.callBlockingMethod( 1063 getDescriptor().getMethods().get(0), 1064 controller, 1065 request, 1066 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance()); 1067 } 1068 1069 1070 public org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto echo( 1071 com.google.protobuf.RpcController controller, 1072 org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto request) 1073 throws com.google.protobuf.ServiceException { 1074 return (org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto) channel.callBlockingMethod( 1075 getDescriptor().getMethods().get(1), 1076 controller, 1077 request, 1078 org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto.getDefaultInstance()); 1079 } 1080 1081 1082 public org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto error( 1083 com.google.protobuf.RpcController controller, 1084 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request) 1085 throws com.google.protobuf.ServiceException { 1086 return (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto) channel.callBlockingMethod( 1087 getDescriptor().getMethods().get(2), 1088 controller, 1089 request, 1090 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance()); 1091 } 1092 1093 1094 public org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto error2( 1095 com.google.protobuf.RpcController controller, 1096 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request) 1097 throws com.google.protobuf.ServiceException { 1098 return (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto) channel.callBlockingMethod( 1099 getDescriptor().getMethods().get(3), 1100 controller, 1101 request, 1102 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance()); 1103 } 1104 1105 1106 public org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto slowPing( 1107 com.google.protobuf.RpcController controller, 1108 org.apache.hadoop.ipc.protobuf.TestProtos.SlowPingRequestProto request) 1109 throws com.google.protobuf.ServiceException { 1110 return (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto) channel.callBlockingMethod( 1111 getDescriptor().getMethods().get(4), 1112 controller, 1113 request, 1114 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance()); 1115 } 1116 1117 1118 public org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto2 echo2( 1119 com.google.protobuf.RpcController controller, 1120 org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto2 request) 1121 throws com.google.protobuf.ServiceException { 1122 return (org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto2) channel.callBlockingMethod( 1123 getDescriptor().getMethods().get(5), 1124 controller, 1125 request, 1126 org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto2.getDefaultInstance()); 1127 } 1128 1129 1130 public org.apache.hadoop.ipc.protobuf.TestProtos.AddResponseProto add( 1131 com.google.protobuf.RpcController controller, 1132 org.apache.hadoop.ipc.protobuf.TestProtos.AddRequestProto request) 1133 throws com.google.protobuf.ServiceException { 1134 return (org.apache.hadoop.ipc.protobuf.TestProtos.AddResponseProto) channel.callBlockingMethod( 1135 getDescriptor().getMethods().get(6), 1136 controller, 1137 request, 1138 org.apache.hadoop.ipc.protobuf.TestProtos.AddResponseProto.getDefaultInstance()); 1139 } 1140 1141 1142 public org.apache.hadoop.ipc.protobuf.TestProtos.AddResponseProto add2( 1143 com.google.protobuf.RpcController controller, 1144 org.apache.hadoop.ipc.protobuf.TestProtos.AddRequestProto2 request) 1145 throws com.google.protobuf.ServiceException { 1146 return (org.apache.hadoop.ipc.protobuf.TestProtos.AddResponseProto) channel.callBlockingMethod( 1147 getDescriptor().getMethods().get(7), 1148 controller, 1149 request, 1150 org.apache.hadoop.ipc.protobuf.TestProtos.AddResponseProto.getDefaultInstance()); 1151 } 1152 1153 1154 public org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto testServerGet( 1155 com.google.protobuf.RpcController controller, 1156 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request) 1157 throws com.google.protobuf.ServiceException { 1158 return (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto) channel.callBlockingMethod( 1159 getDescriptor().getMethods().get(8), 1160 controller, 1161 request, 1162 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance()); 1163 } 1164 1165 1166 public org.apache.hadoop.ipc.protobuf.TestProtos.ExchangeResponseProto exchange( 1167 com.google.protobuf.RpcController controller, 1168 org.apache.hadoop.ipc.protobuf.TestProtos.ExchangeRequestProto request) 1169 throws com.google.protobuf.ServiceException { 1170 return (org.apache.hadoop.ipc.protobuf.TestProtos.ExchangeResponseProto) channel.callBlockingMethod( 1171 getDescriptor().getMethods().get(9), 1172 controller, 1173 request, 1174 org.apache.hadoop.ipc.protobuf.TestProtos.ExchangeResponseProto.getDefaultInstance()); 1175 } 1176 1177 1178 public org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto sleep( 1179 com.google.protobuf.RpcController controller, 1180 org.apache.hadoop.ipc.protobuf.TestProtos.SleepRequestProto request) 1181 throws com.google.protobuf.ServiceException { 1182 return (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto) channel.callBlockingMethod( 1183 getDescriptor().getMethods().get(10), 1184 controller, 1185 request, 1186 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance()); 1187 } 1188 1189 1190 public org.apache.hadoop.ipc.protobuf.TestProtos.AuthMethodResponseProto getAuthMethod( 1191 com.google.protobuf.RpcController controller, 1192 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request) 1193 throws com.google.protobuf.ServiceException { 1194 return (org.apache.hadoop.ipc.protobuf.TestProtos.AuthMethodResponseProto) channel.callBlockingMethod( 1195 getDescriptor().getMethods().get(11), 1196 controller, 1197 request, 1198 org.apache.hadoop.ipc.protobuf.TestProtos.AuthMethodResponseProto.getDefaultInstance()); 1199 } 1200 1201 1202 public org.apache.hadoop.ipc.protobuf.TestProtos.AuthUserResponseProto getAuthUser( 1203 com.google.protobuf.RpcController controller, 1204 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request) 1205 throws com.google.protobuf.ServiceException { 1206 return (org.apache.hadoop.ipc.protobuf.TestProtos.AuthUserResponseProto) channel.callBlockingMethod( 1207 getDescriptor().getMethods().get(12), 1208 controller, 1209 request, 1210 org.apache.hadoop.ipc.protobuf.TestProtos.AuthUserResponseProto.getDefaultInstance()); 1211 } 1212 1213 1214 public org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto echoPostponed( 1215 com.google.protobuf.RpcController controller, 1216 org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto request) 1217 throws com.google.protobuf.ServiceException { 1218 return (org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto) channel.callBlockingMethod( 1219 getDescriptor().getMethods().get(13), 1220 controller, 1221 request, 1222 org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto.getDefaultInstance()); 1223 } 1224 1225 1226 public org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto sendPostponed( 1227 com.google.protobuf.RpcController controller, 1228 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request) 1229 throws com.google.protobuf.ServiceException { 1230 return (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto) channel.callBlockingMethod( 1231 getDescriptor().getMethods().get(14), 1232 controller, 1233 request, 1234 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance()); 1235 } 1236 1237 } 1238 1239 // @@protoc_insertion_point(class_scope:hadoop.common.TestProtobufRpcProto) 1240 } 1241 1242 /** 1243 * Protobuf service {@code hadoop.common.TestProtobufRpc2Proto} 1244 */ 1245 public static abstract class TestProtobufRpc2Proto 1246 implements com.google.protobuf.Service { 1247 protected TestProtobufRpc2Proto() {} 1248 1249 public interface Interface { 1250 /** 1251 * <code>rpc ping2(.hadoop.common.EmptyRequestProto) returns (.hadoop.common.EmptyResponseProto);</code> 1252 */ 1253 public abstract void ping2( 1254 com.google.protobuf.RpcController controller, 1255 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 1256 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done); 1257 1258 /** 1259 * <code>rpc echo2(.hadoop.common.EchoRequestProto) returns (.hadoop.common.EchoResponseProto);</code> 1260 */ 1261 public abstract void echo2( 1262 com.google.protobuf.RpcController controller, 1263 org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto request, 1264 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto> done); 1265 1266 /** 1267 * <code>rpc sleep(.hadoop.common.SleepRequestProto) returns (.hadoop.common.SleepResponseProto);</code> 1268 */ 1269 public abstract void sleep( 1270 com.google.protobuf.RpcController controller, 1271 org.apache.hadoop.ipc.protobuf.TestProtos.SleepRequestProto request, 1272 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.SleepResponseProto> done); 1273 1274 } 1275 1276 public static com.google.protobuf.Service newReflectiveService( 1277 final Interface impl) { 1278 return new TestProtobufRpc2Proto() { 1279 @java.lang.Override 1280 public void ping2( 1281 com.google.protobuf.RpcController controller, 1282 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 1283 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done) { 1284 impl.ping2(controller, request, done); 1285 } 1286 1287 @java.lang.Override 1288 public void echo2( 1289 com.google.protobuf.RpcController controller, 1290 org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto request, 1291 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto> done) { 1292 impl.echo2(controller, request, done); 1293 } 1294 1295 @java.lang.Override 1296 public void sleep( 1297 com.google.protobuf.RpcController controller, 1298 org.apache.hadoop.ipc.protobuf.TestProtos.SleepRequestProto request, 1299 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.SleepResponseProto> done) { 1300 impl.sleep(controller, request, done); 1301 } 1302 1303 }; 1304 } 1305 1306 public static com.google.protobuf.BlockingService 1307 newReflectiveBlockingService(final BlockingInterface impl) { 1308 return new com.google.protobuf.BlockingService() { 1309 public final com.google.protobuf.Descriptors.ServiceDescriptor 1310 getDescriptorForType() { 1311 return getDescriptor(); 1312 } 1313 1314 public final com.google.protobuf.Message callBlockingMethod( 1315 com.google.protobuf.Descriptors.MethodDescriptor method, 1316 com.google.protobuf.RpcController controller, 1317 com.google.protobuf.Message request) 1318 throws com.google.protobuf.ServiceException { 1319 if (method.getService() != getDescriptor()) { 1320 throw new java.lang.IllegalArgumentException( 1321 "Service.callBlockingMethod() given method descriptor for " + 1322 "wrong service type."); 1323 } 1324 switch(method.getIndex()) { 1325 case 0: 1326 return impl.ping2(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto)request); 1327 case 1: 1328 return impl.echo2(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto)request); 1329 case 2: 1330 return impl.sleep(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.SleepRequestProto)request); 1331 default: 1332 throw new java.lang.AssertionError("Can't get here."); 1333 } 1334 } 1335 1336 public final com.google.protobuf.Message 1337 getRequestPrototype( 1338 com.google.protobuf.Descriptors.MethodDescriptor method) { 1339 if (method.getService() != getDescriptor()) { 1340 throw new java.lang.IllegalArgumentException( 1341 "Service.getRequestPrototype() given method " + 1342 "descriptor for wrong service type."); 1343 } 1344 switch(method.getIndex()) { 1345 case 0: 1346 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto.getDefaultInstance(); 1347 case 1: 1348 return org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto.getDefaultInstance(); 1349 case 2: 1350 return org.apache.hadoop.ipc.protobuf.TestProtos.SleepRequestProto.getDefaultInstance(); 1351 default: 1352 throw new java.lang.AssertionError("Can't get here."); 1353 } 1354 } 1355 1356 public final com.google.protobuf.Message 1357 getResponsePrototype( 1358 com.google.protobuf.Descriptors.MethodDescriptor method) { 1359 if (method.getService() != getDescriptor()) { 1360 throw new java.lang.IllegalArgumentException( 1361 "Service.getResponsePrototype() given method " + 1362 "descriptor for wrong service type."); 1363 } 1364 switch(method.getIndex()) { 1365 case 0: 1366 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(); 1367 case 1: 1368 return org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto.getDefaultInstance(); 1369 case 2: 1370 return org.apache.hadoop.ipc.protobuf.TestProtos.SleepResponseProto.getDefaultInstance(); 1371 default: 1372 throw new java.lang.AssertionError("Can't get here."); 1373 } 1374 } 1375 1376 }; 1377 } 1378 1379 /** 1380 * <code>rpc ping2(.hadoop.common.EmptyRequestProto) returns (.hadoop.common.EmptyResponseProto);</code> 1381 */ 1382 public abstract void ping2( 1383 com.google.protobuf.RpcController controller, 1384 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 1385 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done); 1386 1387 /** 1388 * <code>rpc echo2(.hadoop.common.EchoRequestProto) returns (.hadoop.common.EchoResponseProto);</code> 1389 */ 1390 public abstract void echo2( 1391 com.google.protobuf.RpcController controller, 1392 org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto request, 1393 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto> done); 1394 1395 /** 1396 * <code>rpc sleep(.hadoop.common.SleepRequestProto) returns (.hadoop.common.SleepResponseProto);</code> 1397 */ 1398 public abstract void sleep( 1399 com.google.protobuf.RpcController controller, 1400 org.apache.hadoop.ipc.protobuf.TestProtos.SleepRequestProto request, 1401 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.SleepResponseProto> done); 1402 1403 public static final 1404 com.google.protobuf.Descriptors.ServiceDescriptor 1405 getDescriptor() { 1406 return org.apache.hadoop.ipc.protobuf.TestRpcServiceProtos.getDescriptor().getServices().get(1); 1407 } 1408 public final com.google.protobuf.Descriptors.ServiceDescriptor 1409 getDescriptorForType() { 1410 return getDescriptor(); 1411 } 1412 1413 public final void callMethod( 1414 com.google.protobuf.Descriptors.MethodDescriptor method, 1415 com.google.protobuf.RpcController controller, 1416 com.google.protobuf.Message request, 1417 com.google.protobuf.RpcCallback< 1418 com.google.protobuf.Message> done) { 1419 if (method.getService() != getDescriptor()) { 1420 throw new java.lang.IllegalArgumentException( 1421 "Service.callMethod() given method descriptor for wrong " + 1422 "service type."); 1423 } 1424 switch(method.getIndex()) { 1425 case 0: 1426 this.ping2(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto)request, 1427 com.google.protobuf.RpcUtil.<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto>specializeCallback( 1428 done)); 1429 return; 1430 case 1: 1431 this.echo2(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto)request, 1432 com.google.protobuf.RpcUtil.<org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto>specializeCallback( 1433 done)); 1434 return; 1435 case 2: 1436 this.sleep(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.SleepRequestProto)request, 1437 com.google.protobuf.RpcUtil.<org.apache.hadoop.ipc.protobuf.TestProtos.SleepResponseProto>specializeCallback( 1438 done)); 1439 return; 1440 default: 1441 throw new java.lang.AssertionError("Can't get here."); 1442 } 1443 } 1444 1445 public final com.google.protobuf.Message 1446 getRequestPrototype( 1447 com.google.protobuf.Descriptors.MethodDescriptor method) { 1448 if (method.getService() != getDescriptor()) { 1449 throw new java.lang.IllegalArgumentException( 1450 "Service.getRequestPrototype() given method " + 1451 "descriptor for wrong service type."); 1452 } 1453 switch(method.getIndex()) { 1454 case 0: 1455 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto.getDefaultInstance(); 1456 case 1: 1457 return org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto.getDefaultInstance(); 1458 case 2: 1459 return org.apache.hadoop.ipc.protobuf.TestProtos.SleepRequestProto.getDefaultInstance(); 1460 default: 1461 throw new java.lang.AssertionError("Can't get here."); 1462 } 1463 } 1464 1465 public final com.google.protobuf.Message 1466 getResponsePrototype( 1467 com.google.protobuf.Descriptors.MethodDescriptor method) { 1468 if (method.getService() != getDescriptor()) { 1469 throw new java.lang.IllegalArgumentException( 1470 "Service.getResponsePrototype() given method " + 1471 "descriptor for wrong service type."); 1472 } 1473 switch(method.getIndex()) { 1474 case 0: 1475 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(); 1476 case 1: 1477 return org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto.getDefaultInstance(); 1478 case 2: 1479 return org.apache.hadoop.ipc.protobuf.TestProtos.SleepResponseProto.getDefaultInstance(); 1480 default: 1481 throw new java.lang.AssertionError("Can't get here."); 1482 } 1483 } 1484 1485 public static Stub newStub( 1486 com.google.protobuf.RpcChannel channel) { 1487 return new Stub(channel); 1488 } 1489 1490 public static final class Stub extends org.apache.hadoop.ipc.protobuf.TestRpcServiceProtos.TestProtobufRpc2Proto implements Interface { 1491 private Stub(com.google.protobuf.RpcChannel channel) { 1492 this.channel = channel; 1493 } 1494 1495 private final com.google.protobuf.RpcChannel channel; 1496 1497 public com.google.protobuf.RpcChannel getChannel() { 1498 return channel; 1499 } 1500 1501 public void ping2( 1502 com.google.protobuf.RpcController controller, 1503 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 1504 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done) { 1505 channel.callMethod( 1506 getDescriptor().getMethods().get(0), 1507 controller, 1508 request, 1509 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(), 1510 com.google.protobuf.RpcUtil.generalizeCallback( 1511 done, 1512 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.class, 1513 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance())); 1514 } 1515 1516 public void echo2( 1517 com.google.protobuf.RpcController controller, 1518 org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto request, 1519 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto> done) { 1520 channel.callMethod( 1521 getDescriptor().getMethods().get(1), 1522 controller, 1523 request, 1524 org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto.getDefaultInstance(), 1525 com.google.protobuf.RpcUtil.generalizeCallback( 1526 done, 1527 org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto.class, 1528 org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto.getDefaultInstance())); 1529 } 1530 1531 public void sleep( 1532 com.google.protobuf.RpcController controller, 1533 org.apache.hadoop.ipc.protobuf.TestProtos.SleepRequestProto request, 1534 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.SleepResponseProto> done) { 1535 channel.callMethod( 1536 getDescriptor().getMethods().get(2), 1537 controller, 1538 request, 1539 org.apache.hadoop.ipc.protobuf.TestProtos.SleepResponseProto.getDefaultInstance(), 1540 com.google.protobuf.RpcUtil.generalizeCallback( 1541 done, 1542 org.apache.hadoop.ipc.protobuf.TestProtos.SleepResponseProto.class, 1543 org.apache.hadoop.ipc.protobuf.TestProtos.SleepResponseProto.getDefaultInstance())); 1544 } 1545 } 1546 1547 public static BlockingInterface newBlockingStub( 1548 com.google.protobuf.BlockingRpcChannel channel) { 1549 return new BlockingStub(channel); 1550 } 1551 1552 public interface BlockingInterface { 1553 public org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto ping2( 1554 com.google.protobuf.RpcController controller, 1555 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request) 1556 throws com.google.protobuf.ServiceException; 1557 1558 public org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto echo2( 1559 com.google.protobuf.RpcController controller, 1560 org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto request) 1561 throws com.google.protobuf.ServiceException; 1562 1563 public org.apache.hadoop.ipc.protobuf.TestProtos.SleepResponseProto sleep( 1564 com.google.protobuf.RpcController controller, 1565 org.apache.hadoop.ipc.protobuf.TestProtos.SleepRequestProto request) 1566 throws com.google.protobuf.ServiceException; 1567 } 1568 1569 private static final class BlockingStub implements BlockingInterface { 1570 private BlockingStub(com.google.protobuf.BlockingRpcChannel channel) { 1571 this.channel = channel; 1572 } 1573 1574 private final com.google.protobuf.BlockingRpcChannel channel; 1575 1576 public org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto ping2( 1577 com.google.protobuf.RpcController controller, 1578 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request) 1579 throws com.google.protobuf.ServiceException { 1580 return (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto) channel.callBlockingMethod( 1581 getDescriptor().getMethods().get(0), 1582 controller, 1583 request, 1584 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance()); 1585 } 1586 1587 1588 public org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto echo2( 1589 com.google.protobuf.RpcController controller, 1590 org.apache.hadoop.ipc.protobuf.TestProtos.EchoRequestProto request) 1591 throws com.google.protobuf.ServiceException { 1592 return (org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto) channel.callBlockingMethod( 1593 getDescriptor().getMethods().get(1), 1594 controller, 1595 request, 1596 org.apache.hadoop.ipc.protobuf.TestProtos.EchoResponseProto.getDefaultInstance()); 1597 } 1598 1599 1600 public org.apache.hadoop.ipc.protobuf.TestProtos.SleepResponseProto sleep( 1601 com.google.protobuf.RpcController controller, 1602 org.apache.hadoop.ipc.protobuf.TestProtos.SleepRequestProto request) 1603 throws com.google.protobuf.ServiceException { 1604 return (org.apache.hadoop.ipc.protobuf.TestProtos.SleepResponseProto) channel.callBlockingMethod( 1605 getDescriptor().getMethods().get(2), 1606 controller, 1607 request, 1608 org.apache.hadoop.ipc.protobuf.TestProtos.SleepResponseProto.getDefaultInstance()); 1609 } 1610 1611 } 1612 1613 // @@protoc_insertion_point(class_scope:hadoop.common.TestProtobufRpc2Proto) 1614 } 1615 1616 /** 1617 * Protobuf service {@code hadoop.common.OldProtobufRpcProto} 1618 */ 1619 public static abstract class OldProtobufRpcProto 1620 implements com.google.protobuf.Service { 1621 protected OldProtobufRpcProto() {} 1622 1623 public interface Interface { 1624 /** 1625 * <code>rpc ping(.hadoop.common.EmptyRequestProto) returns (.hadoop.common.EmptyResponseProto);</code> 1626 */ 1627 public abstract void ping( 1628 com.google.protobuf.RpcController controller, 1629 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 1630 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done); 1631 1632 /** 1633 * <code>rpc echo(.hadoop.common.EmptyRequestProto) returns (.hadoop.common.EmptyResponseProto);</code> 1634 */ 1635 public abstract void echo( 1636 com.google.protobuf.RpcController controller, 1637 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 1638 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done); 1639 1640 } 1641 1642 public static com.google.protobuf.Service newReflectiveService( 1643 final Interface impl) { 1644 return new OldProtobufRpcProto() { 1645 @java.lang.Override 1646 public void ping( 1647 com.google.protobuf.RpcController controller, 1648 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 1649 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done) { 1650 impl.ping(controller, request, done); 1651 } 1652 1653 @java.lang.Override 1654 public void echo( 1655 com.google.protobuf.RpcController controller, 1656 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 1657 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done) { 1658 impl.echo(controller, request, done); 1659 } 1660 1661 }; 1662 } 1663 1664 public static com.google.protobuf.BlockingService 1665 newReflectiveBlockingService(final BlockingInterface impl) { 1666 return new com.google.protobuf.BlockingService() { 1667 public final com.google.protobuf.Descriptors.ServiceDescriptor 1668 getDescriptorForType() { 1669 return getDescriptor(); 1670 } 1671 1672 public final com.google.protobuf.Message callBlockingMethod( 1673 com.google.protobuf.Descriptors.MethodDescriptor method, 1674 com.google.protobuf.RpcController controller, 1675 com.google.protobuf.Message request) 1676 throws com.google.protobuf.ServiceException { 1677 if (method.getService() != getDescriptor()) { 1678 throw new java.lang.IllegalArgumentException( 1679 "Service.callBlockingMethod() given method descriptor for " + 1680 "wrong service type."); 1681 } 1682 switch(method.getIndex()) { 1683 case 0: 1684 return impl.ping(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto)request); 1685 case 1: 1686 return impl.echo(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto)request); 1687 default: 1688 throw new java.lang.AssertionError("Can't get here."); 1689 } 1690 } 1691 1692 public final com.google.protobuf.Message 1693 getRequestPrototype( 1694 com.google.protobuf.Descriptors.MethodDescriptor method) { 1695 if (method.getService() != getDescriptor()) { 1696 throw new java.lang.IllegalArgumentException( 1697 "Service.getRequestPrototype() given method " + 1698 "descriptor for wrong service type."); 1699 } 1700 switch(method.getIndex()) { 1701 case 0: 1702 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto.getDefaultInstance(); 1703 case 1: 1704 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto.getDefaultInstance(); 1705 default: 1706 throw new java.lang.AssertionError("Can't get here."); 1707 } 1708 } 1709 1710 public final com.google.protobuf.Message 1711 getResponsePrototype( 1712 com.google.protobuf.Descriptors.MethodDescriptor method) { 1713 if (method.getService() != getDescriptor()) { 1714 throw new java.lang.IllegalArgumentException( 1715 "Service.getResponsePrototype() given method " + 1716 "descriptor for wrong service type."); 1717 } 1718 switch(method.getIndex()) { 1719 case 0: 1720 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(); 1721 case 1: 1722 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(); 1723 default: 1724 throw new java.lang.AssertionError("Can't get here."); 1725 } 1726 } 1727 1728 }; 1729 } 1730 1731 /** 1732 * <code>rpc ping(.hadoop.common.EmptyRequestProto) returns (.hadoop.common.EmptyResponseProto);</code> 1733 */ 1734 public abstract void ping( 1735 com.google.protobuf.RpcController controller, 1736 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 1737 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done); 1738 1739 /** 1740 * <code>rpc echo(.hadoop.common.EmptyRequestProto) returns (.hadoop.common.EmptyResponseProto);</code> 1741 */ 1742 public abstract void echo( 1743 com.google.protobuf.RpcController controller, 1744 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 1745 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done); 1746 1747 public static final 1748 com.google.protobuf.Descriptors.ServiceDescriptor 1749 getDescriptor() { 1750 return org.apache.hadoop.ipc.protobuf.TestRpcServiceProtos.getDescriptor().getServices().get(2); 1751 } 1752 public final com.google.protobuf.Descriptors.ServiceDescriptor 1753 getDescriptorForType() { 1754 return getDescriptor(); 1755 } 1756 1757 public final void callMethod( 1758 com.google.protobuf.Descriptors.MethodDescriptor method, 1759 com.google.protobuf.RpcController controller, 1760 com.google.protobuf.Message request, 1761 com.google.protobuf.RpcCallback< 1762 com.google.protobuf.Message> done) { 1763 if (method.getService() != getDescriptor()) { 1764 throw new java.lang.IllegalArgumentException( 1765 "Service.callMethod() given method descriptor for wrong " + 1766 "service type."); 1767 } 1768 switch(method.getIndex()) { 1769 case 0: 1770 this.ping(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto)request, 1771 com.google.protobuf.RpcUtil.<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto>specializeCallback( 1772 done)); 1773 return; 1774 case 1: 1775 this.echo(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto)request, 1776 com.google.protobuf.RpcUtil.<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto>specializeCallback( 1777 done)); 1778 return; 1779 default: 1780 throw new java.lang.AssertionError("Can't get here."); 1781 } 1782 } 1783 1784 public final com.google.protobuf.Message 1785 getRequestPrototype( 1786 com.google.protobuf.Descriptors.MethodDescriptor method) { 1787 if (method.getService() != getDescriptor()) { 1788 throw new java.lang.IllegalArgumentException( 1789 "Service.getRequestPrototype() given method " + 1790 "descriptor for wrong service type."); 1791 } 1792 switch(method.getIndex()) { 1793 case 0: 1794 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto.getDefaultInstance(); 1795 case 1: 1796 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto.getDefaultInstance(); 1797 default: 1798 throw new java.lang.AssertionError("Can't get here."); 1799 } 1800 } 1801 1802 public final com.google.protobuf.Message 1803 getResponsePrototype( 1804 com.google.protobuf.Descriptors.MethodDescriptor method) { 1805 if (method.getService() != getDescriptor()) { 1806 throw new java.lang.IllegalArgumentException( 1807 "Service.getResponsePrototype() given method " + 1808 "descriptor for wrong service type."); 1809 } 1810 switch(method.getIndex()) { 1811 case 0: 1812 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(); 1813 case 1: 1814 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(); 1815 default: 1816 throw new java.lang.AssertionError("Can't get here."); 1817 } 1818 } 1819 1820 public static Stub newStub( 1821 com.google.protobuf.RpcChannel channel) { 1822 return new Stub(channel); 1823 } 1824 1825 public static final class Stub extends org.apache.hadoop.ipc.protobuf.TestRpcServiceProtos.OldProtobufRpcProto implements Interface { 1826 private Stub(com.google.protobuf.RpcChannel channel) { 1827 this.channel = channel; 1828 } 1829 1830 private final com.google.protobuf.RpcChannel channel; 1831 1832 public com.google.protobuf.RpcChannel getChannel() { 1833 return channel; 1834 } 1835 1836 public void ping( 1837 com.google.protobuf.RpcController controller, 1838 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 1839 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done) { 1840 channel.callMethod( 1841 getDescriptor().getMethods().get(0), 1842 controller, 1843 request, 1844 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(), 1845 com.google.protobuf.RpcUtil.generalizeCallback( 1846 done, 1847 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.class, 1848 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance())); 1849 } 1850 1851 public void echo( 1852 com.google.protobuf.RpcController controller, 1853 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 1854 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done) { 1855 channel.callMethod( 1856 getDescriptor().getMethods().get(1), 1857 controller, 1858 request, 1859 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(), 1860 com.google.protobuf.RpcUtil.generalizeCallback( 1861 done, 1862 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.class, 1863 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance())); 1864 } 1865 } 1866 1867 public static BlockingInterface newBlockingStub( 1868 com.google.protobuf.BlockingRpcChannel channel) { 1869 return new BlockingStub(channel); 1870 } 1871 1872 public interface BlockingInterface { 1873 public org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto ping( 1874 com.google.protobuf.RpcController controller, 1875 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request) 1876 throws com.google.protobuf.ServiceException; 1877 1878 public org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto echo( 1879 com.google.protobuf.RpcController controller, 1880 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request) 1881 throws com.google.protobuf.ServiceException; 1882 } 1883 1884 private static final class BlockingStub implements BlockingInterface { 1885 private BlockingStub(com.google.protobuf.BlockingRpcChannel channel) { 1886 this.channel = channel; 1887 } 1888 1889 private final com.google.protobuf.BlockingRpcChannel channel; 1890 1891 public org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto ping( 1892 com.google.protobuf.RpcController controller, 1893 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request) 1894 throws com.google.protobuf.ServiceException { 1895 return (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto) channel.callBlockingMethod( 1896 getDescriptor().getMethods().get(0), 1897 controller, 1898 request, 1899 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance()); 1900 } 1901 1902 1903 public org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto echo( 1904 com.google.protobuf.RpcController controller, 1905 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request) 1906 throws com.google.protobuf.ServiceException { 1907 return (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto) channel.callBlockingMethod( 1908 getDescriptor().getMethods().get(1), 1909 controller, 1910 request, 1911 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance()); 1912 } 1913 1914 } 1915 1916 // @@protoc_insertion_point(class_scope:hadoop.common.OldProtobufRpcProto) 1917 } 1918 1919 /** 1920 * Protobuf service {@code hadoop.common.NewProtobufRpcProto} 1921 */ 1922 public static abstract class NewProtobufRpcProto 1923 implements com.google.protobuf.Service { 1924 protected NewProtobufRpcProto() {} 1925 1926 public interface Interface { 1927 /** 1928 * <code>rpc ping(.hadoop.common.EmptyRequestProto) returns (.hadoop.common.EmptyResponseProto);</code> 1929 */ 1930 public abstract void ping( 1931 com.google.protobuf.RpcController controller, 1932 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 1933 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done); 1934 1935 /** 1936 * <code>rpc echo(.hadoop.common.OptRequestProto) returns (.hadoop.common.OptResponseProto);</code> 1937 */ 1938 public abstract void echo( 1939 com.google.protobuf.RpcController controller, 1940 org.apache.hadoop.ipc.protobuf.TestProtos.OptRequestProto request, 1941 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.OptResponseProto> done); 1942 1943 } 1944 1945 public static com.google.protobuf.Service newReflectiveService( 1946 final Interface impl) { 1947 return new NewProtobufRpcProto() { 1948 @java.lang.Override 1949 public void ping( 1950 com.google.protobuf.RpcController controller, 1951 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 1952 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done) { 1953 impl.ping(controller, request, done); 1954 } 1955 1956 @java.lang.Override 1957 public void echo( 1958 com.google.protobuf.RpcController controller, 1959 org.apache.hadoop.ipc.protobuf.TestProtos.OptRequestProto request, 1960 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.OptResponseProto> done) { 1961 impl.echo(controller, request, done); 1962 } 1963 1964 }; 1965 } 1966 1967 public static com.google.protobuf.BlockingService 1968 newReflectiveBlockingService(final BlockingInterface impl) { 1969 return new com.google.protobuf.BlockingService() { 1970 public final com.google.protobuf.Descriptors.ServiceDescriptor 1971 getDescriptorForType() { 1972 return getDescriptor(); 1973 } 1974 1975 public final com.google.protobuf.Message callBlockingMethod( 1976 com.google.protobuf.Descriptors.MethodDescriptor method, 1977 com.google.protobuf.RpcController controller, 1978 com.google.protobuf.Message request) 1979 throws com.google.protobuf.ServiceException { 1980 if (method.getService() != getDescriptor()) { 1981 throw new java.lang.IllegalArgumentException( 1982 "Service.callBlockingMethod() given method descriptor for " + 1983 "wrong service type."); 1984 } 1985 switch(method.getIndex()) { 1986 case 0: 1987 return impl.ping(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto)request); 1988 case 1: 1989 return impl.echo(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.OptRequestProto)request); 1990 default: 1991 throw new java.lang.AssertionError("Can't get here."); 1992 } 1993 } 1994 1995 public final com.google.protobuf.Message 1996 getRequestPrototype( 1997 com.google.protobuf.Descriptors.MethodDescriptor method) { 1998 if (method.getService() != getDescriptor()) { 1999 throw new java.lang.IllegalArgumentException( 2000 "Service.getRequestPrototype() given method " + 2001 "descriptor for wrong service type."); 2002 } 2003 switch(method.getIndex()) { 2004 case 0: 2005 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto.getDefaultInstance(); 2006 case 1: 2007 return org.apache.hadoop.ipc.protobuf.TestProtos.OptRequestProto.getDefaultInstance(); 2008 default: 2009 throw new java.lang.AssertionError("Can't get here."); 2010 } 2011 } 2012 2013 public final com.google.protobuf.Message 2014 getResponsePrototype( 2015 com.google.protobuf.Descriptors.MethodDescriptor method) { 2016 if (method.getService() != getDescriptor()) { 2017 throw new java.lang.IllegalArgumentException( 2018 "Service.getResponsePrototype() given method " + 2019 "descriptor for wrong service type."); 2020 } 2021 switch(method.getIndex()) { 2022 case 0: 2023 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(); 2024 case 1: 2025 return org.apache.hadoop.ipc.protobuf.TestProtos.OptResponseProto.getDefaultInstance(); 2026 default: 2027 throw new java.lang.AssertionError("Can't get here."); 2028 } 2029 } 2030 2031 }; 2032 } 2033 2034 /** 2035 * <code>rpc ping(.hadoop.common.EmptyRequestProto) returns (.hadoop.common.EmptyResponseProto);</code> 2036 */ 2037 public abstract void ping( 2038 com.google.protobuf.RpcController controller, 2039 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 2040 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done); 2041 2042 /** 2043 * <code>rpc echo(.hadoop.common.OptRequestProto) returns (.hadoop.common.OptResponseProto);</code> 2044 */ 2045 public abstract void echo( 2046 com.google.protobuf.RpcController controller, 2047 org.apache.hadoop.ipc.protobuf.TestProtos.OptRequestProto request, 2048 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.OptResponseProto> done); 2049 2050 public static final 2051 com.google.protobuf.Descriptors.ServiceDescriptor 2052 getDescriptor() { 2053 return org.apache.hadoop.ipc.protobuf.TestRpcServiceProtos.getDescriptor().getServices().get(3); 2054 } 2055 public final com.google.protobuf.Descriptors.ServiceDescriptor 2056 getDescriptorForType() { 2057 return getDescriptor(); 2058 } 2059 2060 public final void callMethod( 2061 com.google.protobuf.Descriptors.MethodDescriptor method, 2062 com.google.protobuf.RpcController controller, 2063 com.google.protobuf.Message request, 2064 com.google.protobuf.RpcCallback< 2065 com.google.protobuf.Message> done) { 2066 if (method.getService() != getDescriptor()) { 2067 throw new java.lang.IllegalArgumentException( 2068 "Service.callMethod() given method descriptor for wrong " + 2069 "service type."); 2070 } 2071 switch(method.getIndex()) { 2072 case 0: 2073 this.ping(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto)request, 2074 com.google.protobuf.RpcUtil.<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto>specializeCallback( 2075 done)); 2076 return; 2077 case 1: 2078 this.echo(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.OptRequestProto)request, 2079 com.google.protobuf.RpcUtil.<org.apache.hadoop.ipc.protobuf.TestProtos.OptResponseProto>specializeCallback( 2080 done)); 2081 return; 2082 default: 2083 throw new java.lang.AssertionError("Can't get here."); 2084 } 2085 } 2086 2087 public final com.google.protobuf.Message 2088 getRequestPrototype( 2089 com.google.protobuf.Descriptors.MethodDescriptor method) { 2090 if (method.getService() != getDescriptor()) { 2091 throw new java.lang.IllegalArgumentException( 2092 "Service.getRequestPrototype() given method " + 2093 "descriptor for wrong service type."); 2094 } 2095 switch(method.getIndex()) { 2096 case 0: 2097 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto.getDefaultInstance(); 2098 case 1: 2099 return org.apache.hadoop.ipc.protobuf.TestProtos.OptRequestProto.getDefaultInstance(); 2100 default: 2101 throw new java.lang.AssertionError("Can't get here."); 2102 } 2103 } 2104 2105 public final com.google.protobuf.Message 2106 getResponsePrototype( 2107 com.google.protobuf.Descriptors.MethodDescriptor method) { 2108 if (method.getService() != getDescriptor()) { 2109 throw new java.lang.IllegalArgumentException( 2110 "Service.getResponsePrototype() given method " + 2111 "descriptor for wrong service type."); 2112 } 2113 switch(method.getIndex()) { 2114 case 0: 2115 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(); 2116 case 1: 2117 return org.apache.hadoop.ipc.protobuf.TestProtos.OptResponseProto.getDefaultInstance(); 2118 default: 2119 throw new java.lang.AssertionError("Can't get here."); 2120 } 2121 } 2122 2123 public static Stub newStub( 2124 com.google.protobuf.RpcChannel channel) { 2125 return new Stub(channel); 2126 } 2127 2128 public static final class Stub extends org.apache.hadoop.ipc.protobuf.TestRpcServiceProtos.NewProtobufRpcProto implements Interface { 2129 private Stub(com.google.protobuf.RpcChannel channel) { 2130 this.channel = channel; 2131 } 2132 2133 private final com.google.protobuf.RpcChannel channel; 2134 2135 public com.google.protobuf.RpcChannel getChannel() { 2136 return channel; 2137 } 2138 2139 public void ping( 2140 com.google.protobuf.RpcController controller, 2141 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 2142 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done) { 2143 channel.callMethod( 2144 getDescriptor().getMethods().get(0), 2145 controller, 2146 request, 2147 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(), 2148 com.google.protobuf.RpcUtil.generalizeCallback( 2149 done, 2150 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.class, 2151 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance())); 2152 } 2153 2154 public void echo( 2155 com.google.protobuf.RpcController controller, 2156 org.apache.hadoop.ipc.protobuf.TestProtos.OptRequestProto request, 2157 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.OptResponseProto> done) { 2158 channel.callMethod( 2159 getDescriptor().getMethods().get(1), 2160 controller, 2161 request, 2162 org.apache.hadoop.ipc.protobuf.TestProtos.OptResponseProto.getDefaultInstance(), 2163 com.google.protobuf.RpcUtil.generalizeCallback( 2164 done, 2165 org.apache.hadoop.ipc.protobuf.TestProtos.OptResponseProto.class, 2166 org.apache.hadoop.ipc.protobuf.TestProtos.OptResponseProto.getDefaultInstance())); 2167 } 2168 } 2169 2170 public static BlockingInterface newBlockingStub( 2171 com.google.protobuf.BlockingRpcChannel channel) { 2172 return new BlockingStub(channel); 2173 } 2174 2175 public interface BlockingInterface { 2176 public org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto ping( 2177 com.google.protobuf.RpcController controller, 2178 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request) 2179 throws com.google.protobuf.ServiceException; 2180 2181 public org.apache.hadoop.ipc.protobuf.TestProtos.OptResponseProto echo( 2182 com.google.protobuf.RpcController controller, 2183 org.apache.hadoop.ipc.protobuf.TestProtos.OptRequestProto request) 2184 throws com.google.protobuf.ServiceException; 2185 } 2186 2187 private static final class BlockingStub implements BlockingInterface { 2188 private BlockingStub(com.google.protobuf.BlockingRpcChannel channel) { 2189 this.channel = channel; 2190 } 2191 2192 private final com.google.protobuf.BlockingRpcChannel channel; 2193 2194 public org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto ping( 2195 com.google.protobuf.RpcController controller, 2196 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request) 2197 throws com.google.protobuf.ServiceException { 2198 return (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto) channel.callBlockingMethod( 2199 getDescriptor().getMethods().get(0), 2200 controller, 2201 request, 2202 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance()); 2203 } 2204 2205 2206 public org.apache.hadoop.ipc.protobuf.TestProtos.OptResponseProto echo( 2207 com.google.protobuf.RpcController controller, 2208 org.apache.hadoop.ipc.protobuf.TestProtos.OptRequestProto request) 2209 throws com.google.protobuf.ServiceException { 2210 return (org.apache.hadoop.ipc.protobuf.TestProtos.OptResponseProto) channel.callBlockingMethod( 2211 getDescriptor().getMethods().get(1), 2212 controller, 2213 request, 2214 org.apache.hadoop.ipc.protobuf.TestProtos.OptResponseProto.getDefaultInstance()); 2215 } 2216 2217 } 2218 2219 // @@protoc_insertion_point(class_scope:hadoop.common.NewProtobufRpcProto) 2220 } 2221 2222 /** 2223 * Protobuf service {@code hadoop.common.NewerProtobufRpcProto} 2224 */ 2225 public static abstract class NewerProtobufRpcProto 2226 implements com.google.protobuf.Service { 2227 protected NewerProtobufRpcProto() {} 2228 2229 public interface Interface { 2230 /** 2231 * <code>rpc ping(.hadoop.common.EmptyRequestProto) returns (.hadoop.common.EmptyResponseProto);</code> 2232 */ 2233 public abstract void ping( 2234 com.google.protobuf.RpcController controller, 2235 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 2236 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done); 2237 2238 /** 2239 * <code>rpc echo(.hadoop.common.EmptyRequestProto) returns (.hadoop.common.EmptyResponseProto);</code> 2240 */ 2241 public abstract void echo( 2242 com.google.protobuf.RpcController controller, 2243 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 2244 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done); 2245 2246 } 2247 2248 public static com.google.protobuf.Service newReflectiveService( 2249 final Interface impl) { 2250 return new NewerProtobufRpcProto() { 2251 @java.lang.Override 2252 public void ping( 2253 com.google.protobuf.RpcController controller, 2254 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 2255 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done) { 2256 impl.ping(controller, request, done); 2257 } 2258 2259 @java.lang.Override 2260 public void echo( 2261 com.google.protobuf.RpcController controller, 2262 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 2263 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done) { 2264 impl.echo(controller, request, done); 2265 } 2266 2267 }; 2268 } 2269 2270 public static com.google.protobuf.BlockingService 2271 newReflectiveBlockingService(final BlockingInterface impl) { 2272 return new com.google.protobuf.BlockingService() { 2273 public final com.google.protobuf.Descriptors.ServiceDescriptor 2274 getDescriptorForType() { 2275 return getDescriptor(); 2276 } 2277 2278 public final com.google.protobuf.Message callBlockingMethod( 2279 com.google.protobuf.Descriptors.MethodDescriptor method, 2280 com.google.protobuf.RpcController controller, 2281 com.google.protobuf.Message request) 2282 throws com.google.protobuf.ServiceException { 2283 if (method.getService() != getDescriptor()) { 2284 throw new java.lang.IllegalArgumentException( 2285 "Service.callBlockingMethod() given method descriptor for " + 2286 "wrong service type."); 2287 } 2288 switch(method.getIndex()) { 2289 case 0: 2290 return impl.ping(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto)request); 2291 case 1: 2292 return impl.echo(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto)request); 2293 default: 2294 throw new java.lang.AssertionError("Can't get here."); 2295 } 2296 } 2297 2298 public final com.google.protobuf.Message 2299 getRequestPrototype( 2300 com.google.protobuf.Descriptors.MethodDescriptor method) { 2301 if (method.getService() != getDescriptor()) { 2302 throw new java.lang.IllegalArgumentException( 2303 "Service.getRequestPrototype() given method " + 2304 "descriptor for wrong service type."); 2305 } 2306 switch(method.getIndex()) { 2307 case 0: 2308 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto.getDefaultInstance(); 2309 case 1: 2310 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto.getDefaultInstance(); 2311 default: 2312 throw new java.lang.AssertionError("Can't get here."); 2313 } 2314 } 2315 2316 public final com.google.protobuf.Message 2317 getResponsePrototype( 2318 com.google.protobuf.Descriptors.MethodDescriptor method) { 2319 if (method.getService() != getDescriptor()) { 2320 throw new java.lang.IllegalArgumentException( 2321 "Service.getResponsePrototype() given method " + 2322 "descriptor for wrong service type."); 2323 } 2324 switch(method.getIndex()) { 2325 case 0: 2326 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(); 2327 case 1: 2328 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(); 2329 default: 2330 throw new java.lang.AssertionError("Can't get here."); 2331 } 2332 } 2333 2334 }; 2335 } 2336 2337 /** 2338 * <code>rpc ping(.hadoop.common.EmptyRequestProto) returns (.hadoop.common.EmptyResponseProto);</code> 2339 */ 2340 public abstract void ping( 2341 com.google.protobuf.RpcController controller, 2342 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 2343 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done); 2344 2345 /** 2346 * <code>rpc echo(.hadoop.common.EmptyRequestProto) returns (.hadoop.common.EmptyResponseProto);</code> 2347 */ 2348 public abstract void echo( 2349 com.google.protobuf.RpcController controller, 2350 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 2351 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done); 2352 2353 public static final 2354 com.google.protobuf.Descriptors.ServiceDescriptor 2355 getDescriptor() { 2356 return org.apache.hadoop.ipc.protobuf.TestRpcServiceProtos.getDescriptor().getServices().get(4); 2357 } 2358 public final com.google.protobuf.Descriptors.ServiceDescriptor 2359 getDescriptorForType() { 2360 return getDescriptor(); 2361 } 2362 2363 public final void callMethod( 2364 com.google.protobuf.Descriptors.MethodDescriptor method, 2365 com.google.protobuf.RpcController controller, 2366 com.google.protobuf.Message request, 2367 com.google.protobuf.RpcCallback< 2368 com.google.protobuf.Message> done) { 2369 if (method.getService() != getDescriptor()) { 2370 throw new java.lang.IllegalArgumentException( 2371 "Service.callMethod() given method descriptor for wrong " + 2372 "service type."); 2373 } 2374 switch(method.getIndex()) { 2375 case 0: 2376 this.ping(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto)request, 2377 com.google.protobuf.RpcUtil.<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto>specializeCallback( 2378 done)); 2379 return; 2380 case 1: 2381 this.echo(controller, (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto)request, 2382 com.google.protobuf.RpcUtil.<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto>specializeCallback( 2383 done)); 2384 return; 2385 default: 2386 throw new java.lang.AssertionError("Can't get here."); 2387 } 2388 } 2389 2390 public final com.google.protobuf.Message 2391 getRequestPrototype( 2392 com.google.protobuf.Descriptors.MethodDescriptor method) { 2393 if (method.getService() != getDescriptor()) { 2394 throw new java.lang.IllegalArgumentException( 2395 "Service.getRequestPrototype() given method " + 2396 "descriptor for wrong service type."); 2397 } 2398 switch(method.getIndex()) { 2399 case 0: 2400 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto.getDefaultInstance(); 2401 case 1: 2402 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto.getDefaultInstance(); 2403 default: 2404 throw new java.lang.AssertionError("Can't get here."); 2405 } 2406 } 2407 2408 public final com.google.protobuf.Message 2409 getResponsePrototype( 2410 com.google.protobuf.Descriptors.MethodDescriptor method) { 2411 if (method.getService() != getDescriptor()) { 2412 throw new java.lang.IllegalArgumentException( 2413 "Service.getResponsePrototype() given method " + 2414 "descriptor for wrong service type."); 2415 } 2416 switch(method.getIndex()) { 2417 case 0: 2418 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(); 2419 case 1: 2420 return org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(); 2421 default: 2422 throw new java.lang.AssertionError("Can't get here."); 2423 } 2424 } 2425 2426 public static Stub newStub( 2427 com.google.protobuf.RpcChannel channel) { 2428 return new Stub(channel); 2429 } 2430 2431 public static final class Stub extends org.apache.hadoop.ipc.protobuf.TestRpcServiceProtos.NewerProtobufRpcProto implements Interface { 2432 private Stub(com.google.protobuf.RpcChannel channel) { 2433 this.channel = channel; 2434 } 2435 2436 private final com.google.protobuf.RpcChannel channel; 2437 2438 public com.google.protobuf.RpcChannel getChannel() { 2439 return channel; 2440 } 2441 2442 public void ping( 2443 com.google.protobuf.RpcController controller, 2444 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 2445 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done) { 2446 channel.callMethod( 2447 getDescriptor().getMethods().get(0), 2448 controller, 2449 request, 2450 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(), 2451 com.google.protobuf.RpcUtil.generalizeCallback( 2452 done, 2453 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.class, 2454 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance())); 2455 } 2456 2457 public void echo( 2458 com.google.protobuf.RpcController controller, 2459 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request, 2460 com.google.protobuf.RpcCallback<org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto> done) { 2461 channel.callMethod( 2462 getDescriptor().getMethods().get(1), 2463 controller, 2464 request, 2465 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance(), 2466 com.google.protobuf.RpcUtil.generalizeCallback( 2467 done, 2468 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.class, 2469 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance())); 2470 } 2471 } 2472 2473 public static BlockingInterface newBlockingStub( 2474 com.google.protobuf.BlockingRpcChannel channel) { 2475 return new BlockingStub(channel); 2476 } 2477 2478 public interface BlockingInterface { 2479 public org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto ping( 2480 com.google.protobuf.RpcController controller, 2481 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request) 2482 throws com.google.protobuf.ServiceException; 2483 2484 public org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto echo( 2485 com.google.protobuf.RpcController controller, 2486 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request) 2487 throws com.google.protobuf.ServiceException; 2488 } 2489 2490 private static final class BlockingStub implements BlockingInterface { 2491 private BlockingStub(com.google.protobuf.BlockingRpcChannel channel) { 2492 this.channel = channel; 2493 } 2494 2495 private final com.google.protobuf.BlockingRpcChannel channel; 2496 2497 public org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto ping( 2498 com.google.protobuf.RpcController controller, 2499 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request) 2500 throws com.google.protobuf.ServiceException { 2501 return (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto) channel.callBlockingMethod( 2502 getDescriptor().getMethods().get(0), 2503 controller, 2504 request, 2505 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance()); 2506 } 2507 2508 2509 public org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto echo( 2510 com.google.protobuf.RpcController controller, 2511 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyRequestProto request) 2512 throws com.google.protobuf.ServiceException { 2513 return (org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto) channel.callBlockingMethod( 2514 getDescriptor().getMethods().get(1), 2515 controller, 2516 request, 2517 org.apache.hadoop.ipc.protobuf.TestProtos.EmptyResponseProto.getDefaultInstance()); 2518 } 2519 2520 } 2521 2522 // @@protoc_insertion_point(class_scope:hadoop.common.NewerProtobufRpcProto) 2523 } 2524 2525 2526 public static com.google.protobuf.Descriptors.FileDescriptor 2527 getDescriptor() { 2528 return descriptor; 2529 } 2530 private static com.google.protobuf.Descriptors.FileDescriptor 2531 descriptor; 2532 static { 2533 java.lang.String[] descriptorData = { 2534 "\n\026test_rpc_service.proto\022\rhadoop.common\032" + 2535 "\ntest.proto2\326\t\n\024TestProtobufRpcProto\022K\n\004" + 2536 "ping\022 .hadoop.common.EmptyRequestProto\032!" + 2537 ".hadoop.common.EmptyResponseProto\022I\n\004ech" + 2538 "o\022\037.hadoop.common.EchoRequestProto\032 .had" + 2539 "oop.common.EchoResponseProto\022L\n\005error\022 ." + 2540 "hadoop.common.EmptyRequestProto\032!.hadoop" + 2541 ".common.EmptyResponseProto\022M\n\006error2\022 .h" + 2542 "adoop.common.EmptyRequestProto\032!.hadoop." + 2543 "common.EmptyResponseProto\022R\n\010slowPing\022#.", 2544 "hadoop.common.SlowPingRequestProto\032!.had" + 2545 "oop.common.EmptyResponseProto\022L\n\005echo2\022 " + 2546 ".hadoop.common.EchoRequestProto2\032!.hadoo" + 2547 "p.common.EchoResponseProto2\022F\n\003add\022\036.had" + 2548 "oop.common.AddRequestProto\032\037.hadoop.comm" + 2549 "on.AddResponseProto\022H\n\004add2\022\037.hadoop.com" + 2550 "mon.AddRequestProto2\032\037.hadoop.common.Add" + 2551 "ResponseProto\022T\n\rtestServerGet\022 .hadoop." + 2552 "common.EmptyRequestProto\032!.hadoop.common" + 2553 ".EmptyResponseProto\022U\n\010exchange\022#.hadoop", 2554 ".common.ExchangeRequestProto\032$.hadoop.co" + 2555 "mmon.ExchangeResponseProto\022L\n\005sleep\022 .ha" + 2556 "doop.common.SleepRequestProto\032!.hadoop.c" + 2557 "ommon.EmptyResponseProto\022Y\n\rgetAuthMetho" + 2558 "d\022 .hadoop.common.EmptyRequestProto\032&.ha" + 2559 "doop.common.AuthMethodResponseProto\022U\n\013g" + 2560 "etAuthUser\022 .hadoop.common.EmptyRequestP" + 2561 "roto\032$.hadoop.common.AuthUserResponsePro" + 2562 "to\022R\n\rechoPostponed\022\037.hadoop.common.Echo" + 2563 "RequestProto\032 .hadoop.common.EchoRespons", 2564 "eProto\022T\n\rsendPostponed\022 .hadoop.common." + 2565 "EmptyRequestProto\032!.hadoop.common.EmptyR" + 2566 "esponseProto2\377\001\n\025TestProtobufRpc2Proto\022L" + 2567 "\n\005ping2\022 .hadoop.common.EmptyRequestProt" + 2568 "o\032!.hadoop.common.EmptyResponseProto\022J\n\005" + 2569 "echo2\022\037.hadoop.common.EchoRequestProto\032 " + 2570 ".hadoop.common.EchoResponseProto\022L\n\005slee" + 2571 "p\022 .hadoop.common.SleepRequestProto\032!.ha" + 2572 "doop.common.SleepResponseProto2\257\001\n\023OldPr" + 2573 "otobufRpcProto\022K\n\004ping\022 .hadoop.common.E", 2574 "mptyRequestProto\032!.hadoop.common.EmptyRe" + 2575 "sponseProto\022K\n\004echo\022 .hadoop.common.Empt" + 2576 "yRequestProto\032!.hadoop.common.EmptyRespo" + 2577 "nseProto2\253\001\n\023NewProtobufRpcProto\022K\n\004ping" + 2578 "\022 .hadoop.common.EmptyRequestProto\032!.had" + 2579 "oop.common.EmptyResponseProto\022G\n\004echo\022\036." + 2580 "hadoop.common.OptRequestProto\032\037.hadoop.c" + 2581 "ommon.OptResponseProto2\261\001\n\025NewerProtobuf" + 2582 "RpcProto\022K\n\004ping\022 .hadoop.common.EmptyRe" + 2583 "questProto\032!.hadoop.common.EmptyResponse", 2584 "Proto\022K\n\004echo\022 .hadoop.common.EmptyReque" + 2585 "stProto\032!.hadoop.common.EmptyResponsePro" + 2586 "toB<\n\036org.apache.hadoop.ipc.protobufB\024Te" + 2587 "stRpcServiceProtos\210\001\001\240\001\001" 2588 }; 2589 com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner = 2590 new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() { 2591 public com.google.protobuf.ExtensionRegistry assignDescriptors( 2592 com.google.protobuf.Descriptors.FileDescriptor root) { 2593 descriptor = root; 2594 return null; 2595 } 2596 }; 2597 com.google.protobuf.Descriptors.FileDescriptor 2598 .internalBuildGeneratedFileFrom(descriptorData, 2599 new com.google.protobuf.Descriptors.FileDescriptor[] { 2600 org.apache.hadoop.ipc.protobuf.TestProtos.getDescriptor(), 2601 }, assigner); 2602 } 2603 2604 // @@protoc_insertion_point(outer_class_scope) 2605}