1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
|
/*
* Linux WiMax
* Shared/common routines
*
*
* Copyright (C) 2007-2008 Intel Corporation. All rights reserved.
* Inaky Perez-Gonzalez <inaky.perez-gonzalez@intel.com>
*
* 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 Intel Corporation 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
* OWNER 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.
*
*
* These are a set of facilities used by the implementation of the
* different ops in this library.
*/
#define _GNU_SOURCE
#include <sys/types.h>
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <stdarg.h>
#include <errno.h>
#include <assert.h>
#include <linux/types.h>
#include <netlink/msg.h>
#include <netlink/genl/genl.h>
#include <wimaxll.h>
#include "internal.h"
#define D_LOCAL 0
#include "debug.h"
/**
* Netlink callback to process netlink callback errors
*
* \internal
*
* \param nla Source netlink address
* \param nlerr Netlink error descritor
* \param _mch Pointer to (\a struct wimaxll_mc_handle)
*
* \return 'enum nl_cb_action', NL_OK if there is no error, NL_STOP on
* error and _mch->result possibly updated.
*
* While reading from netlink and processing with callbacks (using
* nl_recvmsgs()), we use this for the callback 'state machine' to
* store the result of an error message from the kernel.
*/
int wimaxll_gnl_error_cb(struct sockaddr_nl *nla, struct nlmsgerr *nlerr,
void *_mch)
{
struct wimaxll_mc_handle *mch = _mch;
struct wimaxll_handle *wmx = mch->wmx;
d_fnstart(7, wmx, "(nla %p nlnerr %p [%d] mch %p)\n",
nla, nlerr, nlerr->error, _mch);
wimaxll_mch_maybe_set_result(mch, nlerr->error);
d_fnend(7, wmx, "(nla %p nlnerr %p [%d] mch %p) = %d\n",
nla, nlerr, nlerr->error, _mch, NL_STOP);
return NL_STOP;
}
/**
* Netlink callback to process an ack message and pass the 'error' code
*
* \internal
*
* Process a netlink ack message and extract the error code, which is
* placed in the context passed as argument for the calling function
* to use.
*
* We use this so that ACKers in the kernel can pass a simple error
* code (integer) in the ACK that netlink sends, without having to
* send an extra message.
*
* Complementary to wimaxll_gnl_error_cb().
*
* Frontend to this is wimaxll_wait_for_ack()
*/
int wimaxll_gnl_ack_cb(struct nl_msg *msg, void *_mch)
{
int result;
struct nlmsghdr *nl_hdr;
struct nlmsgerr *nl_err;
size_t size = nlmsg_len(nlmsg_hdr(msg));
struct wimaxll_mc_handle *mch = _mch;
d_fnstart(7, NULL, "(msg %p mch %p)\n", msg, _mch);
nl_hdr = nlmsg_hdr(msg);
size = nlmsg_len(nl_hdr);
nl_err = nlmsg_data(nl_hdr);
if (size < sizeof(*nl_err)) {
wimaxll_msg(NULL, "E: netlink ack: buffer too small "
"(%zu vs %zu expected)\n",
size, sizeof(*nl_hdr) + sizeof(*nl_err));
result = -EIO;
goto error_ack_short;
}
d_printf(4, NULL, "netlink ack: nlmsghdr len %u type %u flags 0x%04x "
"seq 0x%x pid %u\n", nl_hdr->nlmsg_len, nl_hdr->nlmsg_type,
nl_hdr->nlmsg_flags, nl_hdr->nlmsg_seq, nl_hdr->nlmsg_pid);
if (nl_hdr->nlmsg_type != NLMSG_ERROR) {
wimaxll_msg(NULL, "E: netlink ack: message is not an ack but "
"type %u\n", nl_hdr->nlmsg_type);
result = -EBADE;
goto error_bad_type;
}
d_printf(4, NULL, "netlink ack: nlmsgerr error %d for "
"nlmsghdr len %u type %u flags 0x%04x seq 0x%x pid %u\n",
nl_err->error,
nl_err->msg.nlmsg_len, nl_err->msg.nlmsg_type,
nl_err->msg.nlmsg_flags, nl_err->msg.nlmsg_seq,
nl_err->msg.nlmsg_pid);
wimaxll_mch_maybe_set_result(mch, nl_err->error);
if (nl_err->error < 0)
d_printf(2, NULL, "D: netlink ack: received netlink error %d\n",
nl_err->error);
error_ack_short:
error_bad_type:
d_fnend(7, NULL, "(msg %p mch %p) = NL_STOP\n", msg, _mch);
return NL_STOP;
}
/**
* Wait for a netlink ACK and pass on the result code it passed
*
* \internal
*
* \param wmx WiMAX device handle
* \return error code passed by the kernel in the nlmsgerr structure
* that contained the ACK.
*
* Similar to nl_wait_for_ack(), but returns the value in
* nlmsgerr->error, so it can be used by the kernel to return simple
* error codes.
*/
int wimaxll_wait_for_ack(struct wimaxll_handle *wmx)
{
int result;
struct nl_cb *cb;
struct wimaxll_mc_handle fake_mch;
fake_mch.wmx = wmx;
fake_mch.result = -EINPROGRESS;
cb = nl_socket_get_cb(wmx->nlh_tx);
nl_cb_set(cb, NL_CB_ACK, NL_CB_CUSTOM, wimaxll_gnl_ack_cb, &fake_mch);
nl_cb_set(cb, NL_CB_VALID, NL_CB_CUSTOM, NL_CB_DEFAULT, NULL);
nl_cb_err(cb, NL_CB_CUSTOM, wimaxll_gnl_error_cb, &fake_mch);
result = nl_recvmsgs_default(wmx->nlh_tx);
nl_cb_set(cb, NL_CB_ACK, NL_CB_CUSTOM, NL_CB_DEFAULT, NULL);
nl_cb_put(cb);
if (result < 0)
return result;
return fake_mch.result;
}
/**
* WIMAX_GNL_RP_RESULT: policy specification
*
* \internal
*
* Authoritative reference for this is at the kernel code,
* drivers/net/wimax/stack.c.
*/
static
struct nla_policy wimaxll_gnl_result_policy[WIMAX_GNL_ATTR_MAX + 1] = {
/* This is really a signed-64 bit number that has to be
* casted from a u64 */
[WIMAX_GNL_RESULT_CODE] = { .type = NLA_U64 },
};
/**
* Netlink callback to process a WIMAX_GNL_RP_RESULT message
*
* \internal
*
* \param msg Netlink message containing the reply
* \param _mch Pointer to a \a struct wimaxll_mc_handle where the
* result of the operation will be returned.
*
* \return 'enum nl_cb_action', NL_OK if there is no error, NL_STOP on
* error and _mch->result updated.
*
* This will take a received netlink message, check it is a \a
* WIMAX_GNL_RP_RESULT, parse the status code in it and store it the
* \m _mch's result data member for the caller to use later on.
*/
static
int wimaxll_gnl_rp_result_cb(struct nl_msg *msg, void *_mch)
{
int result;
struct wimaxll_mc_handle *mch = _mch;
struct wimaxll_handle *wmx = mch->wmx;
struct nlmsghdr *nl_hdr;
struct genlmsghdr *genl_hdr;
struct nlattr *tb[WIMAX_GNL_ATTR_MAX + 1];
d_fnstart(7, wmx, "(msg %p mch %p)\n", msg, _mch);
nl_hdr = nlmsg_hdr(msg);
genl_hdr = nlmsg_data(nl_hdr);
if (genl_hdr->cmd != WIMAX_GNL_RP_RESULT) {
result = NL_SKIP;
d_printf(1, wmx, "D: ignoring unknown command %d\n",
genl_hdr->cmd);
goto error_parse;
}
/* Parse the attributes */
result = genlmsg_parse(nl_hdr, 0, tb, WIMAX_GNL_ATTR_MAX,
wimaxll_gnl_result_policy);
if (result < 0) {
wimaxll_msg(wmx, "E: %s: genlmsg_parse() failed: %d\n",
__func__, result);
wimaxll_mch_maybe_set_result(mch, -ENXIO);
result = NL_SKIP;
goto error_parse;
}
if (tb[WIMAX_GNL_RESULT_CODE] == NULL) {
wimaxll_msg(wmx, "E: %s: No result code argument passed\n",
__func__);
wimaxll_mch_maybe_set_result(mch, -ENXIO);
result = NL_SKIP;
goto error_no_result_code;
}
result = (ssize_t) nla_get_u64(tb[WIMAX_GNL_RESULT_CODE]);
wimaxll_mch_maybe_set_result(mch, result);
result = NL_OK;
error_no_result_code:
error_parse:
d_fnend(7, wmx, "(msg %p mch %p) = %d\n", msg, _mch, result);
return result;
}
/**
* Wait for a WIMAX_GNL_RP_RESULT reply (and an ack) and report its code
*
* \internal
*
* Many ops we execute in the kernel return just a signed integer for
* status using a WIMAX_GNL_RP_RESULT command for reply before sending
* the ACK.
*
* This function simplifies waiting for that and getting the reply.
*
* You still need to wait for the ack in your function calling
* nl_wait_for_ack().
*
* \note We use the same handler used for transmission in the TX side
* and it's callback set, that we modifiy. As noted in the doc for
* \a struct wimaxll_handle, each call site to nl_recvmsgs_default()
* on \a wmx->nlh_tx must make sure the NL_CB_VALID and
* nl_cb_err() callbacks are properly set.
*/
ssize_t wimaxll_wait_for_rp_result(struct wimaxll_handle *wmx)
{
ssize_t result;
struct nl_cb *cb;
struct wimaxll_mc_handle fake_mch;
d_fnstart(5, wmx, "(wmx %p)\n", wmx);
fake_mch.wmx = wmx;
fake_mch.result = -EINPROGRESS;
cb = nl_socket_get_cb(wmx->nlh_tx);
nl_cb_set(cb, NL_CB_VALID, NL_CB_CUSTOM,
wimaxll_gnl_rp_result_cb, &fake_mch);
nl_cb_err(cb, NL_CB_CUSTOM, wimaxll_gnl_error_cb, &fake_mch);
nl_recvmsgs_default(wmx->nlh_tx);
nl_cb_put(cb);
result = fake_mch.result;
if (result == -EINPROGRESS)
wimaxll_msg(wmx, "E: %s: the kernel didn't reply with a "
"WIMAX_GNL_RP_RESULT message\n", __func__);
else
d_printf(1, wmx, "D: WIMAX_GNL_RP_RESULT code is %d\n", result);
d_fnend(5, wmx, "(wmx %p) = %zd\n", wmx, result);
return result;
}
/**
* \defgroup diagnostics_group Output of diagnostics messages
*
* The \e libwimaxll library prints diagnostics by default to \a
* stderr. Said destination can be changed by the user by setting the
* wimaxll_vmsg() function pointer before calling any other \a
* libwimaxll function.
*
* To restore the default diagnostics destination, set wimaxll_vmsg()
* back to wimaxll_vmsg_stderr().
*/
/**
* Deliver \e libwimaxll diagnostics messages to \e stderr
*
* \param fmt printf-like format
* \param vargs variable-argument list as created by
* stdargs.h:va_list() that will be formatted according to \e
* fmt.
*
* Default diagnostics printing function.
*
* \ingroup diagnostics_group
*/
void wimaxll_vmsg_stderr(const char *fmt, va_list vargs)
{
vfprintf(stderr, fmt, vargs);
}
/**
* Print library diagnostics messages [backend]
*
* @param fmt printf-like format
* @param vargs variable-argument list as created by
* stdargs.h:va_list() that will be formatted according to \e
* fmt.
*
* Prints/writes the \e libwimaxll's diagnostics messages to a
* destination as selected by the user of the library.
*
* \note This function pointer must be set \b before calling any other
* \e libwimaxll function.
*
* By default, diagnostics are printed with wimaxll_vmsg_stderr() to
* \a stderr.
*
* For example, to deliver diagnostics to syslog:
*
* @code
* #include <syslog.h>
* ...
* static
* void wimaxll_vmsg_syslog(const char *fmt, va_list vargs)
* {
* vsyslog(LOG_MAKEPRI(LOG_USER, LOG_INFO), fmt, vargs);
* }
* ...
* wimaxll_vmsg = wimaxll_vmsg_syslog();
* ...
* wimaxll_open(BLAH);
* @endcode
*
* \ingroup diagnostics_group
* \internal
*
* The internal function wimaxll_msg() is used as as a frontend to
* this function.
*/
void (*wimaxll_vmsg)(const char *fmt, va_list vargs) = wimaxll_vmsg_stderr;
static
void __wimaxll_msg(const char *fmt, ...)
{
va_list vargs;
va_start(vargs, fmt);
wimaxll_vmsg(fmt, vargs);
va_end(vargs);
}
/**
* \internal
*
* Prints library diagnostic messages with a predefined format [frontend]
*
* @param wmx WiMAX handle; if NULL, no device header will be presented.
* @param fmt printf-like format followed by any arguments
*
* Called by the library functions to print status/error messages. By
* default these are sent over to stderr.
*
* However, library users can change this default behaviour by setting
* wimaxll_vmsg() as documented in that function pointer's
* documentation.
*
* \ingroup diagnostics_group
*/
void wimaxll_msg(struct wimaxll_handle *wmx, const char *fmt, ...)
{
va_list vargs;
if (wmx == NULL)
__wimaxll_msg("libwimax: ");
else if ((unsigned long) wmx < 4096) {
__wimaxll_msg("libwimax: E: Corrupt device handle %p\n", wmx);
__wimaxll_msg("libwimax[n/a]: ");
} else
__wimaxll_msg("libwimax[%s]: ", wmx->name);
va_start(vargs, fmt);
wimaxll_vmsg(fmt, vargs);
va_end(vargs);
}
/**
* Return the name of a the system's WiMAX interface associated to an
* open handle
*
* \param wmx WiMAX device handle
* \return Interface name (only valid while the handle is open)
*
* \ingroup device_management
*/
const char *wimaxll_ifname(const struct wimaxll_handle *wmx)
{
return wmx->name;
}
void wimax_ifname() __attribute__ ((weak, alias("wimaxll_ifname")));
|