X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=include%2Flibnfs-private.h;h=6b64033c6af13c1046ca90f45374e152680687cc;hb=1c8b4547cee99df587ed6b5d0112ab3f48d6534d;hp=f995a7ef94a5466e1024b157563763fcc1f6e4ca;hpb=0f9fe7c64ddaaa29233b123c07c1e1c4ed1bf71d;p=deb_libnfs.git diff --git a/include/libnfs-private.h b/include/libnfs-private.h index f995a7e..6b64033 100644 --- a/include/libnfs-private.h +++ b/include/libnfs-private.h @@ -18,11 +18,14 @@ #include "config.h" /* HAVE_SOCKADDR_STORAGE ? */ #endif +#ifndef WIN32 #include /* struct sockaddr_storage */ +#endif #include "libnfs-zdr.h" -#ifndef HAVE_SOCKADDR_STORAGE + +#if !defined(HAVE_SOCKADDR_STORAGE) && !defined(WIN32) /* * RFC 2553: protocol-independent placeholder for socket addresses */ @@ -53,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; @@ -65,37 +69,40 @@ 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; }; struct rpc_pdu { struct rpc_pdu *next; - unsigned long xid; + uint32_t xid; ZDR zdr; uint32_t written; @@ -132,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);