001/*
002 * Licensed to the Apache Software Foundation (ASF) under one
003 * or more contributor license agreements.  See the NOTICE file
004 * distributed with this work for additional information
005 * regarding copyright ownership.  The ASF licenses this file
006 * to you under the Apache License, Version 2.0 (the
007 * "License"); you may not use this file except in compliance
008 * with the License.  You may obtain a copy of the License at
009 *
010 *     http://www.apache.org/licenses/LICENSE-2.0
011 *
012 * Unless required by applicable law or agreed to in writing, software
013 * distributed under the License is distributed on an "AS IS" BASIS,
014 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
015 * See the License for the specific language governing permissions and
016 * limitations under the License.
017 */
018package org.apache.hadoop.hbase.ipc;
019
020import java.io.IOException;
021import java.net.InetAddress;
022import org.apache.hadoop.hbase.ExtendedCellScanner;
023import org.apache.hadoop.hbase.io.ByteBuffAllocator;
024import org.apache.hadoop.hbase.ipc.RpcServer.CallCleanup;
025import org.apache.yetus.audience.InterfaceAudience;
026
027import org.apache.hbase.thirdparty.com.google.protobuf.BlockingService;
028import org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor;
029import org.apache.hbase.thirdparty.com.google.protobuf.Message;
030
031import org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader;
032
033/**
034 * Datastructure that holds all necessary to a method invocation and then afterward, carries the
035 * result.
036 * @since 2.0.0
037 */
038@InterfaceAudience.Private
039class NettyServerCall extends ServerCall<NettyServerRpcConnection> {
040
041  NettyServerCall(int id, BlockingService service, MethodDescriptor md, RequestHeader header,
042    Message param, ExtendedCellScanner cellScanner, NettyServerRpcConnection connection, long size,
043    InetAddress remoteAddress, long receiveTime, int timeout, ByteBuffAllocator bbAllocator,
044    CellBlockBuilder cellBlockBuilder, CallCleanup reqCleanup) {
045    super(id, service, md, header, param, cellScanner, connection, size, remoteAddress, receiveTime,
046      timeout, bbAllocator, cellBlockBuilder, reqCleanup);
047  }
048
049  /**
050   * If we have a response, and delay is not set, then respond immediately. Otherwise, do not
051   * respond to client. This is called by the RPC code in the context of the Handler thread.
052   */
053  @Override
054  public synchronized void sendResponseIfReady() throws IOException {
055    // set param null to reduce memory pressure
056    this.param = null;
057    connection.doRespond(this);
058  }
059}