FreeBSD/Linux Kernel Cross Reference
sys/rpc/krpc.h

     /*-
      * Copyright (c) 2009, Sun Microsystems, Inc.
      * All rights reserved.
      *
      * Redistribution and use in source and binary forms, with or without
      * modification, are permitted provided that the following conditions are met:
      * - Redistributions of source code must retain the above copyright notice,
      *   this list of conditions and the following disclaimer.
      * - Redistributions in binary form must reproduce the above copyright notice,
     *   this list of conditions and the following disclaimer in the documentation
     *   and/or other materials provided with the distribution.
     * - Neither the name of Sun Microsystems, Inc. nor the names of its
     *   contributors may be used to endorse or promote products derived
     *   from this software without specific prior written permission.
     *
     * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
     * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE
     * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR   
     * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     * POSSIBILITY OF SUCH DAMAGE.
     *
     * $FreeBSD: releng/11.2/sys/rpc/krpc.h 331722 2018-03-29 02:50:57Z eadler $
     */
    
    #ifndef _RPC_KRPC_H_
    #define _RPC_KRPC_H_
    
    #ifdef _KERNEL
    /*
     * Definitions now shared between client and server RPC for backchannels.
     */
    #define MCALL_MSG_SIZE 24
    
    void clnt_bck_svccall(void *, struct mbuf *, uint32_t);
    enum clnt_stat clnt_bck_call(CLIENT *, struct rpc_callextra *, rpcproc_t,
        struct mbuf *, struct mbuf **, struct timeval, SVCXPRT *);
    
    /*
     * A pending RPC request which awaits a reply. Requests which have
     * received their reply will have cr_xid set to zero and cr_mrep to
     * the mbuf chain of the reply.
     */
    struct ct_request {
            TAILQ_ENTRY(ct_request) cr_link;
            uint32_t                cr_xid;         /* XID of request */
            struct mbuf             *cr_mrep;       /* reply received by upcall */
            int                     cr_error;       /* any error from upcall */
            char                    cr_verf[MAX_AUTH_BYTES]; /* reply verf */
    };
    
    TAILQ_HEAD(ct_request_list, ct_request);
    
    struct rc_data {
            struct mtx              rc_lock;
            struct sockaddr_storage rc_addr; /* server address */
            struct netconfig*       rc_nconf; /* network type */
            rpcprog_t               rc_prog;  /* program number */
            rpcvers_t               rc_vers;  /* version number */
            size_t                  rc_sendsz;
            size_t                  rc_recvsz;
            struct timeval          rc_timeout;
            struct timeval          rc_retry;
            int                     rc_retries;
            int                     rc_privport;
            char                    *rc_waitchan;
            int                     rc_intr;
            int                     rc_connecting;
            int                     rc_closed;
            struct ucred            *rc_ucred;
            CLIENT*                 rc_client; /* underlying RPC client */
            struct rpc_err          rc_err;
            void                    *rc_backchannel;
    };
    
    struct ct_data {
            struct mtx      ct_lock;
            int             ct_threads;     /* number of threads in clnt_vc_call */
            bool_t          ct_closing;     /* TRUE if we are closing */
            bool_t          ct_closed;      /* TRUE if we are closed */
            struct socket   *ct_socket;     /* connection socket */
            bool_t          ct_closeit;     /* close it on destroy */
            struct timeval  ct_wait;        /* wait interval in milliseconds */
            struct sockaddr_storage ct_addr; /* remote addr */
            struct rpc_err  ct_error;
            uint32_t        ct_xid;
            char            ct_mcallc[MCALL_MSG_SIZE]; /* marshalled callmsg */
            size_t          ct_mpos;        /* pos after marshal */
            const char      *ct_waitchan;
            int             ct_waitflag;
            struct mbuf     *ct_record;     /* current reply record */
            size_t          ct_record_resid; /* how much left of reply to read */
            bool_t          ct_record_eor;   /* true if reading last fragment */
            struct ct_request_list ct_pending;
           int             ct_upcallrefs;  /* Ref cnt of upcalls in prog. */
           SVCXPRT         *ct_backchannelxprt; /* xprt for backchannel */
   };
   
   struct cf_conn {  /* kept in xprt->xp_p1 for actual connection */
           enum xprt_stat strm_stat;
           struct mbuf *mpending;  /* unparsed data read from the socket */
           struct mbuf *mreq;      /* current record being built from mpending */
           uint32_t resid;         /* number of bytes needed for fragment */
           bool_t eor;             /* reading last fragment of current record */
   };
   
   #endif  /* _KERNEL */
   
   #endif  /* _RPC_KRPC_H_ */

Cache object: 8c056cbf8ecc703299fa24770a109735