diff options
Diffstat (limited to 'kernel/taskstats.c')
| -rw-r--r-- | kernel/taskstats.c | 32 |
1 files changed, 14 insertions, 18 deletions
diff --git a/kernel/taskstats.c b/kernel/taskstats.c index f45179ce028e..e78187657330 100644 --- a/kernel/taskstats.c +++ b/kernel/taskstats.c | |||
| @@ -121,46 +121,45 @@ static int send_reply(struct sk_buff *skb, pid_t pid) | |||
| 121 | /* | 121 | /* |
| 122 | * Send taskstats data in @skb to listeners registered for @cpu's exit data | 122 | * Send taskstats data in @skb to listeners registered for @cpu's exit data |
| 123 | */ | 123 | */ |
| 124 | static int send_cpu_listeners(struct sk_buff *skb, unsigned int cpu) | 124 | static void send_cpu_listeners(struct sk_buff *skb, unsigned int cpu) |
| 125 | { | 125 | { |
| 126 | struct genlmsghdr *genlhdr = nlmsg_data((struct nlmsghdr *)skb->data); | 126 | struct genlmsghdr *genlhdr = nlmsg_data((struct nlmsghdr *)skb->data); |
| 127 | struct listener_list *listeners; | 127 | struct listener_list *listeners; |
| 128 | struct listener *s, *tmp; | 128 | struct listener *s, *tmp; |
| 129 | struct sk_buff *skb_next, *skb_cur = skb; | 129 | struct sk_buff *skb_next, *skb_cur = skb; |
| 130 | void *reply = genlmsg_data(genlhdr); | 130 | void *reply = genlmsg_data(genlhdr); |
| 131 | int rc, ret, delcount = 0; | 131 | int rc, delcount = 0; |
| 132 | 132 | ||
| 133 | rc = genlmsg_end(skb, reply); | 133 | rc = genlmsg_end(skb, reply); |
| 134 | if (rc < 0) { | 134 | if (rc < 0) { |
| 135 | nlmsg_free(skb); | 135 | nlmsg_free(skb); |
| 136 | return rc; | 136 | return; |
| 137 | } | 137 | } |
| 138 | 138 | ||
| 139 | rc = 0; | 139 | rc = 0; |
| 140 | listeners = &per_cpu(listener_array, cpu); | 140 | listeners = &per_cpu(listener_array, cpu); |
| 141 | down_read(&listeners->sem); | 141 | down_read(&listeners->sem); |
| 142 | list_for_each_entry_safe(s, tmp, &listeners->list, list) { | 142 | list_for_each_entry(s, &listeners->list, list) { |
| 143 | skb_next = NULL; | 143 | skb_next = NULL; |
| 144 | if (!list_is_last(&s->list, &listeners->list)) { | 144 | if (!list_is_last(&s->list, &listeners->list)) { |
| 145 | skb_next = skb_clone(skb_cur, GFP_KERNEL); | 145 | skb_next = skb_clone(skb_cur, GFP_KERNEL); |
| 146 | if (!skb_next) { | 146 | if (!skb_next) |
| 147 | nlmsg_free(skb_cur); | ||
| 148 | rc = -ENOMEM; | ||
| 149 | break; | 147 | break; |
| 150 | } | ||
| 151 | } | 148 | } |
| 152 | ret = genlmsg_unicast(skb_cur, s->pid); | 149 | rc = genlmsg_unicast(skb_cur, s->pid); |
| 153 | if (ret == -ECONNREFUSED) { | 150 | if (rc == -ECONNREFUSED) { |
| 154 | s->valid = 0; | 151 | s->valid = 0; |
| 155 | delcount++; | 152 | delcount++; |
| 156 | rc = ret; | ||
| 157 | } | 153 | } |
| 158 | skb_cur = skb_next; | 154 | skb_cur = skb_next; |
| 159 | } | 155 | } |
| 160 | up_read(&listeners->sem); | 156 | up_read(&listeners->sem); |
| 161 | 157 | ||
| 158 | if (skb_cur) | ||
| 159 | nlmsg_free(skb_cur); | ||
| 160 | |||
| 162 | if (!delcount) | 161 | if (!delcount) |
| 163 | return rc; | 162 | return; |
| 164 | 163 | ||
| 165 | /* Delete invalidated entries */ | 164 | /* Delete invalidated entries */ |
| 166 | down_write(&listeners->sem); | 165 | down_write(&listeners->sem); |
| @@ -171,13 +170,12 @@ static int send_cpu_listeners(struct sk_buff *skb, unsigned int cpu) | |||
| 171 | } | 170 | } |
| 172 | } | 171 | } |
| 173 | up_write(&listeners->sem); | 172 | up_write(&listeners->sem); |
| 174 | return rc; | ||
| 175 | } | 173 | } |
| 176 | 174 | ||
| 177 | static int fill_pid(pid_t pid, struct task_struct *pidtsk, | 175 | static int fill_pid(pid_t pid, struct task_struct *pidtsk, |
| 178 | struct taskstats *stats) | 176 | struct taskstats *stats) |
| 179 | { | 177 | { |
| 180 | int rc; | 178 | int rc = 0; |
| 181 | struct task_struct *tsk = pidtsk; | 179 | struct task_struct *tsk = pidtsk; |
| 182 | 180 | ||
| 183 | if (!pidtsk) { | 181 | if (!pidtsk) { |
| @@ -196,12 +194,10 @@ static int fill_pid(pid_t pid, struct task_struct *pidtsk, | |||
| 196 | * Each accounting subsystem adds calls to its functions to | 194 | * Each accounting subsystem adds calls to its functions to |
| 197 | * fill in relevant parts of struct taskstsats as follows | 195 | * fill in relevant parts of struct taskstsats as follows |
| 198 | * | 196 | * |
| 199 | * rc = per-task-foo(stats, tsk); | 197 | * per-task-foo(stats, tsk); |
| 200 | * if (rc) | ||
| 201 | * goto err; | ||
| 202 | */ | 198 | */ |
| 203 | 199 | ||
| 204 | rc = delayacct_add_tsk(stats, tsk); | 200 | delayacct_add_tsk(stats, tsk); |
| 205 | stats->version = TASKSTATS_VERSION; | 201 | stats->version = TASKSTATS_VERSION; |
| 206 | 202 | ||
| 207 | /* Define err: label here if needed */ | 203 | /* Define err: label here if needed */ |
