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
|
/*
* kernel/misc.c
*/
#include "dnbd2.h"
#include "misc.h"
uint16_t diff(uint16_t then)
{
int diff = jiffies & 0xffff;
diff -= then;
if (diff < 0)
diff += 1 << 16;
return diff;
}
int sock_xmit(struct socket *sock, int send, void *buf, int size)
{
int result;
struct msghdr msg;
struct kvec iov;
unsigned long flags;
sigset_t oldset;
spin_lock_irqsave(¤t->sighand->siglock, flags);
oldset = current->blocked;
sigfillset(¤t->blocked);
sigdelsetmask(¤t->blocked, sigmask(SIGKILL));
recalc_sigpending();
spin_unlock_irqrestore(¤t->sighand->siglock, flags);
do {
sock->sk->sk_allocation = GFP_NOIO;
iov.iov_base = buf;
iov.iov_len = size;
msg.msg_name = NULL;
msg.msg_namelen = 0;
msg.msg_control = NULL;
msg.msg_controllen = 0;
msg.msg_flags = MSG_NOSIGNAL;
if (send)
result = kernel_sendmsg(sock, &msg, &iov, 1, size);
else
result = kernel_recvmsg(sock, &msg, &iov, 1, size, 0);
if (signal_pending(current)) {
siginfo_t info;
spin_lock_irqsave(¤t->sighand->siglock, flags);
dequeue_signal(current, ¤t->blocked, &info);
spin_unlock_irqrestore(¤t->sighand->siglock,
flags);
result = -EINTR;
break;
}
if (result <= 0) {
if (result == 0)
result = -EPIPE;
break;
}
size -= result;
buf += result;
} while (size > 0);
spin_lock_irqsave(¤t->sighand->siglock, flags);
current->blocked = oldset;
recalc_sigpending();
spin_unlock_irqrestore(¤t->sighand->siglock, flags);
return result;
}
char *inet_ntoa(uint32_t ip)
{
static char buf[sizeof "aaa.bbb.ccc.ddd"];
unsigned char *nums = (unsigned char *)&ip;
sprintf(buf, "%u.%u.%u.%u", nums[0], nums[1], nums[2], nums[3]);
return buf;
}
|