X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=include%2Flibnfs-private.h;h=a2f3e1a2a09bc8cebba77132ba1f8bdc6850c1d7;hb=37e3eace2ae31e9ee4efff61cf1b72d98635f213;hp=79ac411339668ffcb4e79d3edd00c95ed2b4f54c;hpb=67a9f57e67c3b2c147969c752532fd55eb99259c;p=deb_libnfs.git diff --git a/include/libnfs-private.h b/include/libnfs-private.h index 79ac411..a2f3e1a 100644 --- a/include/libnfs-private.h +++ b/include/libnfs-private.h @@ -56,9 +56,10 @@ struct rpc_fragment { }; #define RPC_CONTEXT_MAGIC 0xc6e46435 +#define RPC_PARAM_UNDEFINED -1 struct rpc_context { - uint32_t magic; + uint32_t magic; int fd; int is_connected; @@ -68,37 +69,42 @@ struct rpc_context { void *connect_data; struct AUTH *auth; - unsigned long xid; + uint32_t xid; - /* buffer used for encoding RPC PDU */ - char *encodebuf; - int encodebuflen; + /* buffer used for encoding RPC PDU */ + char *encodebuf; + int encodebuflen; - struct rpc_pdu *outqueue; - struct sockaddr_storage udp_src; - struct rpc_pdu *waitpdu; + struct rpc_pdu *outqueue; + struct sockaddr_storage udp_src; + struct rpc_pdu *waitpdu; - uint32_t inpos; - uint32_t insize; - char *inbuf; + uint32_t inpos; + uint32_t insize; + char *inbuf; - /* special fields for UDP, which can sometimes be BROADCASTed */ - int is_udp; - struct sockaddr *udp_dest; - int is_broadcast; + /* special fields for UDP, which can sometimes be BROADCASTed */ + int is_udp; + struct sockaddr *udp_dest; + int is_broadcast; - /* track the address we connect to so we can auto-reconnect on session failure */ - struct sockaddr_storage s; - int auto_reconnect; + /* track the address we connect to so we can auto-reconnect on session failure */ + struct sockaddr_storage s; + int auto_reconnect; /* fragment reassembly */ struct rpc_fragment *fragments; + + /* parameters passable via URL */ + int tcp_syncnt; + int uid; + int gid; }; struct rpc_pdu { struct rpc_pdu *next; - unsigned long xid; + uint32_t xid; ZDR zdr; uint32_t written; @@ -135,6 +141,10 @@ struct sockaddr *rpc_get_recv_sockaddr(struct rpc_context *rpc); void rpc_set_autoreconnect(struct rpc_context *rpc); void rpc_unset_autoreconnect(struct rpc_context *rpc); +void rpc_set_tcp_syncnt(struct rpc_context *rpc, int v); +void rpc_set_uid(struct rpc_context *rpc, int uid); +void rpc_set_gid(struct rpc_context *rpc, int gid); + int rpc_add_fragment(struct rpc_context *rpc, char *data, uint64_t size); void rpc_free_all_fragments(struct rpc_context *rpc);