| 268 frame->payload.data = g_new(guint8, frame->payload.len); |
268 frame->payload.data = g_new(guint8, frame->payload.len); |
| 269 conn->frame = frame; |
269 conn->frame = frame; |
| 270 } |
270 } |
| 271 |
271 |
| 272 /* If this frame has a payload then attempt to read it */ |
272 /* If this frame has a payload then attempt to read it */ |
| 273 if (frame->payload.len - frame->payload.offset > 0) |
273 if (frame->payload.offset < frame->payload.len) { |
| 274 { |
|
| 275 /* Read data into the temporary buffer until it is complete */ |
274 /* Read data into the temporary buffer until it is complete */ |
| 276 read = recv(conn->fd, |
275 read = recv(conn->fd, |
| 277 &frame->payload.data[frame->payload.offset], |
276 &frame->payload.data[frame->payload.offset], |
| 278 frame->payload.len - frame->payload.offset, |
277 frame->payload.len - frame->payload.offset, |
| 279 0); |
278 0); |