X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=include%2Flibnfs-private.h;h=6b64033c6af13c1046ca90f45374e152680687cc;hb=1c8b4547cee99df587ed6b5d0112ab3f48d6534d;hp=328d79dc62720d45f2205bb61f9d1c3081fa0b30;hpb=d2ec73c75a60604419171f6ea086a702607ad69f;p=deb_libnfs.git diff --git a/include/libnfs-private.h b/include/libnfs-private.h index 328d79d..6b64033 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; @@ -70,29 +71,32 @@ struct rpc_context { struct AUTH *auth; 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; }; struct rpc_pdu { @@ -135,6 +139,8 @@ 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); + int rpc_add_fragment(struct rpc_context *rpc, char *data, uint64_t size); void rpc_free_all_fragments(struct rpc_context *rpc);