2 Copyright (C) 2010 by Ronnie Sahlberg <ronniesahlberg@gmail.com>
4 This program is free software; you can redistribute it and/or modify
5 it under the terms of the GNU Lesser General Public License as published by
6 the Free Software Foundation; either version 2.1 of the License, or
7 (at your option) any later version.
9 This program is distributed in the hope that it will be useful,
10 but WITHOUT ANY WARRANTY; without even the implied warranty of
11 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 GNU Lesser General Public License for more details.
14 You should have received a copy of the GNU Lesser General Public License
15 along with this program; if not, see <http://www.gnu.org/licenses/>.
27 #include "libnfs-raw.h"
28 #include "libnfs-private.h"
30 struct rpc_context
*rpc_init_context(void)
32 struct rpc_context
*rpc
;
34 rpc
= malloc(sizeof(struct rpc_context
));
36 printf("Failed to allocate rpc context\n");
39 bzero(rpc
, sizeof(struct rpc_context
));
41 rpc
->encodebuflen
= 65536;
42 rpc
->encodebuf
= malloc(rpc
->encodebuflen
);
43 if (rpc
->encodebuf
== NULL
) {
44 printf("Failed to allocate a buffer for rpc encoding\n");
49 rpc
->auth
= authunix_create_default();
50 if (rpc
->auth
== NULL
) {
51 printf("failed to create authunix\n");
63 void rpc_set_auth(struct rpc_context
*rpc
, struct AUTH
*auth
)
65 if (rpc
->auth
!= NULL
) {
66 auth_destroy(rpc
->auth
);
72 void rpc_set_error(struct rpc_context
*rpc
, char *error_string
, ...)
77 if (rpc
->error_string
!= NULL
) {
78 free(rpc
->error_string
);
80 va_start(ap
, error_string
);
81 vasprintf(&str
, error_string
, ap
);
82 rpc
->error_string
= str
;
86 char *rpc_get_error(struct rpc_context
*rpc
)
88 return rpc
->error_string
;
91 void rpc_error_all_pdus(struct rpc_context
*rpc
, char *error
)
95 while((pdu
= rpc
->outqueue
) != NULL
) {
96 pdu
->cb(rpc
, RPC_STATUS_ERROR
, error
, pdu
->private_data
);
97 SLIST_REMOVE(&rpc
->outqueue
, pdu
);
98 rpc_free_pdu(rpc
, pdu
);
100 while((pdu
= rpc
->waitpdu
) != NULL
) {
101 pdu
->cb(rpc
, RPC_STATUS_ERROR
, error
, pdu
->private_data
);
102 SLIST_REMOVE(&rpc
->waitpdu
, pdu
);
103 rpc_free_pdu(rpc
, pdu
);
108 void rpc_destroy_context(struct rpc_context
*rpc
)
112 while((pdu
= rpc
->outqueue
) != NULL
) {
113 pdu
->cb(rpc
, RPC_STATUS_CANCEL
, NULL
, pdu
->private_data
);
114 SLIST_REMOVE(&rpc
->outqueue
, pdu
);
115 rpc_free_pdu(rpc
, pdu
);
117 while((pdu
= rpc
->waitpdu
) != NULL
) {
118 pdu
->cb(rpc
, RPC_STATUS_CANCEL
, NULL
, pdu
->private_data
);
119 SLIST_REMOVE(&rpc
->waitpdu
, pdu
);
120 rpc_free_pdu(rpc
, pdu
);
123 auth_destroy(rpc
->auth
);
130 if (rpc
->encodebuf
!= NULL
) {
131 free(rpc
->encodebuf
);
132 rpc
->encodebuf
= NULL
;
135 if (rpc
->error_string
!= NULL
) {
136 free(rpc
->error_string
);
137 rpc
->error_string
= NULL
;