diff options
Diffstat (limited to 'net/atm/signaling.c')
-rw-r--r-- | net/atm/signaling.c | 25 |
1 files changed, 9 insertions, 16 deletions
diff --git a/net/atm/signaling.c b/net/atm/signaling.c index d14baaf1f4c3..bced78b77f12 100644 --- a/net/atm/signaling.c +++ b/net/atm/signaling.c | |||
@@ -23,13 +23,6 @@ | |||
23 | Danger: may cause nasty hangs if the demon | 23 | Danger: may cause nasty hangs if the demon |
24 | crashes. */ | 24 | crashes. */ |
25 | 25 | ||
26 | #if 0 | ||
27 | #define DPRINTK(format,args...) printk(KERN_DEBUG format,##args) | ||
28 | #else | ||
29 | #define DPRINTK(format,args...) | ||
30 | #endif | ||
31 | |||
32 | |||
33 | struct atm_vcc *sigd = NULL; | 26 | struct atm_vcc *sigd = NULL; |
34 | #ifdef WAIT_FOR_DEMON | 27 | #ifdef WAIT_FOR_DEMON |
35 | static DECLARE_WAIT_QUEUE_HEAD(sigd_sleep); | 28 | static DECLARE_WAIT_QUEUE_HEAD(sigd_sleep); |
@@ -44,14 +37,14 @@ static void sigd_put_skb(struct sk_buff *skb) | |||
44 | add_wait_queue(&sigd_sleep,&wait); | 37 | add_wait_queue(&sigd_sleep,&wait); |
45 | while (!sigd) { | 38 | while (!sigd) { |
46 | set_current_state(TASK_UNINTERRUPTIBLE); | 39 | set_current_state(TASK_UNINTERRUPTIBLE); |
47 | DPRINTK("atmsvc: waiting for signaling demon...\n"); | 40 | pr_debug("atmsvc: waiting for signaling demon...\n"); |
48 | schedule(); | 41 | schedule(); |
49 | } | 42 | } |
50 | current->state = TASK_RUNNING; | 43 | current->state = TASK_RUNNING; |
51 | remove_wait_queue(&sigd_sleep,&wait); | 44 | remove_wait_queue(&sigd_sleep,&wait); |
52 | #else | 45 | #else |
53 | if (!sigd) { | 46 | if (!sigd) { |
54 | DPRINTK("atmsvc: no signaling demon\n"); | 47 | pr_debug("atmsvc: no signaling demon\n"); |
55 | kfree_skb(skb); | 48 | kfree_skb(skb); |
56 | return; | 49 | return; |
57 | } | 50 | } |
@@ -96,9 +89,9 @@ static int sigd_send(struct atm_vcc *vcc,struct sk_buff *skb) | |||
96 | 89 | ||
97 | msg = (struct atmsvc_msg *) skb->data; | 90 | msg = (struct atmsvc_msg *) skb->data; |
98 | atomic_sub(skb->truesize, &sk_atm(vcc)->sk_wmem_alloc); | 91 | atomic_sub(skb->truesize, &sk_atm(vcc)->sk_wmem_alloc); |
99 | DPRINTK("sigd_send %d (0x%lx)\n",(int) msg->type, | ||
100 | (unsigned long) msg->vcc); | ||
101 | vcc = *(struct atm_vcc **) &msg->vcc; | 92 | vcc = *(struct atm_vcc **) &msg->vcc; |
93 | pr_debug("sigd_send %d (0x%lx)\n",(int) msg->type, | ||
94 | (unsigned long) vcc); | ||
102 | sk = sk_atm(vcc); | 95 | sk = sk_atm(vcc); |
103 | 96 | ||
104 | switch (msg->type) { | 97 | switch (msg->type) { |
@@ -130,7 +123,7 @@ static int sigd_send(struct atm_vcc *vcc,struct sk_buff *skb) | |||
130 | case as_indicate: | 123 | case as_indicate: |
131 | vcc = *(struct atm_vcc **) &msg->listen_vcc; | 124 | vcc = *(struct atm_vcc **) &msg->listen_vcc; |
132 | sk = sk_atm(vcc); | 125 | sk = sk_atm(vcc); |
133 | DPRINTK("as_indicate!!!\n"); | 126 | pr_debug("as_indicate!!!\n"); |
134 | lock_sock(sk); | 127 | lock_sock(sk); |
135 | if (sk_acceptq_is_full(sk)) { | 128 | if (sk_acceptq_is_full(sk)) { |
136 | sigd_enq(NULL,as_reject,vcc,NULL,NULL); | 129 | sigd_enq(NULL,as_reject,vcc,NULL,NULL); |
@@ -139,7 +132,7 @@ static int sigd_send(struct atm_vcc *vcc,struct sk_buff *skb) | |||
139 | } | 132 | } |
140 | sk->sk_ack_backlog++; | 133 | sk->sk_ack_backlog++; |
141 | skb_queue_tail(&sk->sk_receive_queue, skb); | 134 | skb_queue_tail(&sk->sk_receive_queue, skb); |
142 | DPRINTK("waking sk->sk_sleep 0x%p\n", sk->sk_sleep); | 135 | pr_debug("waking sk->sk_sleep 0x%p\n", sk->sk_sleep); |
143 | sk->sk_state_change(sk); | 136 | sk->sk_state_change(sk); |
144 | as_indicate_complete: | 137 | as_indicate_complete: |
145 | release_sock(sk); | 138 | release_sock(sk); |
@@ -176,7 +169,7 @@ void sigd_enq2(struct atm_vcc *vcc,enum atmsvc_msg_type type, | |||
176 | struct atmsvc_msg *msg; | 169 | struct atmsvc_msg *msg; |
177 | static unsigned session = 0; | 170 | static unsigned session = 0; |
178 | 171 | ||
179 | DPRINTK("sigd_enq %d (0x%p)\n",(int) type,vcc); | 172 | pr_debug("sigd_enq %d (0x%p)\n",(int) type,vcc); |
180 | while (!(skb = alloc_skb(sizeof(struct atmsvc_msg),GFP_KERNEL))) | 173 | while (!(skb = alloc_skb(sizeof(struct atmsvc_msg),GFP_KERNEL))) |
181 | schedule(); | 174 | schedule(); |
182 | msg = (struct atmsvc_msg *) skb_put(skb,sizeof(struct atmsvc_msg)); | 175 | msg = (struct atmsvc_msg *) skb_put(skb,sizeof(struct atmsvc_msg)); |
@@ -226,7 +219,7 @@ static void sigd_close(struct atm_vcc *vcc) | |||
226 | struct sock *s; | 219 | struct sock *s; |
227 | int i; | 220 | int i; |
228 | 221 | ||
229 | DPRINTK("sigd_close\n"); | 222 | pr_debug("sigd_close\n"); |
230 | sigd = NULL; | 223 | sigd = NULL; |
231 | if (skb_peek(&sk_atm(vcc)->sk_receive_queue)) | 224 | if (skb_peek(&sk_atm(vcc)->sk_receive_queue)) |
232 | printk(KERN_ERR "sigd_close: closing with requests pending\n"); | 225 | printk(KERN_ERR "sigd_close: closing with requests pending\n"); |
@@ -263,7 +256,7 @@ static struct atm_dev sigd_dev = { | |||
263 | int sigd_attach(struct atm_vcc *vcc) | 256 | int sigd_attach(struct atm_vcc *vcc) |
264 | { | 257 | { |
265 | if (sigd) return -EADDRINUSE; | 258 | if (sigd) return -EADDRINUSE; |
266 | DPRINTK("sigd_attach\n"); | 259 | pr_debug("sigd_attach\n"); |
267 | sigd = vcc; | 260 | sigd = vcc; |
268 | vcc->dev = &sigd_dev; | 261 | vcc->dev = &sigd_dev; |
269 | vcc_insert_socket(sk_atm(vcc)); | 262 | vcc_insert_socket(sk_atm(vcc)); |