Lines Matching refs:data
672 /* See event_callback: If data comes in right away after an accept, even
969 /* Check if there is data left from the last recv operation. */
973 /* No data was left from the previous operation, so we try to get
981 /* already received data, return that (this trusts in getting the same error from
1024 /* ... check if there is data left in the pbuf */
1028 We store the pbuf but hide/free the consumed data: */
1037 /* once we have some data to return, only add more if we don't need to wait */
1043 /* ensure window update after copying all data */
1051 /* Convert a netbuf's address data to struct sockaddr */
1137 /* Check if there is data left from the last recv operation. */
1140 /* No data was left from the previous operation, so we try to get
1171 /* Check to see from where the data was.*/
1362 /* recv the data */
1380 /* pass MSG_DONTWAIT to lwip_recv_tcp() to prevent waiting for more data */
1425 lwip_send(int s, const void *data, size_t size, int flags)
1432 LWIP_DEBUGF(SOCKETS_DEBUG, ("lwip_send(%d, data=%p, size=%"SZT_F", flags=0x%x)\n",
1433 s, data, size, flags));
1444 return lwip_sendto_internal(s, data, size, flags, NULL, 0);
1446 return lwip_sendto(s, data, size, flags, NULL, 0);
1459 err = netconn_write_partly(sock->conn, data, size, write_flags, &written);
1556 /* Allocate a new netbuf and copy the data into it. */
1619 /* send the data */
1643 lwip_sendto(int s, const void *data, size_t size, int flags,
1648 return lwip_sendto_internal(s, data, size, flags, to, tolen);
1650 return distributed_net_sendto(s, data, size, flags, to, tolen);
1654 lwip_sendto_internal(int s, const void *data, size_t size, int flags,
1672 return lwip_send(s, data, size, flags);
1708 LWIP_DEBUGF(SOCKETS_DEBUG, ("lwip_sendto(%d, data=%p, short_size=%"U16_F", flags=0x%x to=",
1709 s, data, short_size, flags));
1713 /* make the buffer point to the data that should be sent */
1715 /* Allocate a new netbuf and copy the data into it. */
1721 u16_t chksum = LWIP_CHKSUM_COPY(buf.p->payload, data, short_size);
1726 MEMCPY(buf.p->payload, data, short_size);
1731 err = netbuf_ref(&buf, data, short_size);
1742 /* send the data */
1816 lwip_write(int s, const void *data, size_t size)
1818 return lwip_send(s, data, size, 0);
2522 that would be a data race because lwip_pollscan
2543 * Processes recvevent (data available) and wakes up tasks waiting for select.
2569 * will use the data later. Note that only receive events
2843 LWIP_SETGETSOCKOPT_DATA_VAR_DECLARE(data);
2865 /* MPU_COMPATIBLE copies the optval data, so check for max size here */
2873 LWIP_SETGETSOCKOPT_DATA_VAR_ALLOC(data, sock);
2874 LWIP_SETGETSOCKOPT_DATA_VAR_REF(data).s = s;
2875 LWIP_SETGETSOCKOPT_DATA_VAR_REF(data).level = level;
2876 LWIP_SETGETSOCKOPT_DATA_VAR_REF(data).optname = optname;
2877 LWIP_SETGETSOCKOPT_DATA_VAR_REF(data).optlen = *optlen;
2879 LWIP_SETGETSOCKOPT_DATA_VAR_REF(data).optval.p = optval;
2881 LWIP_SETGETSOCKOPT_DATA_VAR_REF(data).err = 0;
2883 LWIP_SETGETSOCKOPT_DATA_VAR_REF(data).completed_sem = LWIP_NETCONN_THREAD_SEM_GET();
2885 LWIP_SETGETSOCKOPT_DATA_VAR_REF(data).completed_sem = &sock->conn->op_completed;
2887 cberr = tcpip_callback(lwip_getsockopt_callback, &LWIP_SETGETSOCKOPT_DATA_VAR_REF(data));
2889 LWIP_SETGETSOCKOPT_DATA_VAR_FREE(data);
2894 sys_arch_sem_wait((sys_sem_t *)(LWIP_SETGETSOCKOPT_DATA_VAR_REF(data).completed_sem), 0);
2897 *optlen = LWIP_SETGETSOCKOPT_DATA_VAR_REF(data).optlen;
2899 MEMCPY(optval, LWIP_SETGETSOCKOPT_DATA_VAR_REF(data).optval,
2900 LWIP_SETGETSOCKOPT_DATA_VAR_REF(data).optlen);
2904 err = LWIP_SETGETSOCKOPT_DATA_VAR_REF(data).err;
2905 LWIP_SETGETSOCKOPT_DATA_VAR_FREE(data);
2920 struct lwip_setgetsockopt_data *data;
2922 data = (struct lwip_setgetsockopt_data *)arg;
2924 data->err = lwip_getsockopt_impl(data->s, data->level, data->optname,
2926 data->optval,
2928 data->optval.p,
2930 &data->optlen);
2932 sys_sem_signal((sys_sem_t *)(data->completed_sem));
3289 LWIP_SETGETSOCKOPT_DATA_VAR_DECLARE(data);
3314 /* MPU_COMPATIBLE copies the optval data, so check for max size here */
3322 LWIP_SETGETSOCKOPT_DATA_VAR_ALLOC(data, sock);
3323 LWIP_SETGETSOCKOPT_DATA_VAR_REF(data).s = s;
3324 LWIP_SETGETSOCKOPT_DATA_VAR_REF(data).level = level;
3325 LWIP_SETGETSOCKOPT_DATA_VAR_REF(data).optname = optname;
3326 LWIP_SETGETSOCKOPT_DATA_VAR_REF(data).optlen = optlen;
3328 MEMCPY(LWIP_SETGETSOCKOPT_DATA_VAR_REF(data).optval, optval, optlen);
3330 LWIP_SETGETSOCKOPT_DATA_VAR_REF(data).optval.pc = (const void *)optval;
3332 LWIP_SETGETSOCKOPT_DATA_VAR_REF(data).err = 0;
3334 LWIP_SETGETSOCKOPT_DATA_VAR_REF(data).completed_sem = LWIP_NETCONN_THREAD_SEM_GET();
3336 LWIP_SETGETSOCKOPT_DATA_VAR_REF(data).completed_sem = &sock->conn->op_completed;
3338 cberr = tcpip_callback(lwip_setsockopt_callback, &LWIP_SETGETSOCKOPT_DATA_VAR_REF(data));
3340 LWIP_SETGETSOCKOPT_DATA_VAR_FREE(data);
3345 sys_arch_sem_wait((sys_sem_t *)(LWIP_SETGETSOCKOPT_DATA_VAR_REF(data).completed_sem), 0);
3348 err = LWIP_SETGETSOCKOPT_DATA_VAR_REF(data).err;
3349 LWIP_SETGETSOCKOPT_DATA_VAR_FREE(data);
3364 struct lwip_setgetsockopt_data *data;
3366 data = (struct lwip_setgetsockopt_data *)arg;
3368 data->err = lwip_setsockopt_impl(data->s, data->level, data->optname,
3370 data->optval,
3372 data->optval.pc,
3374 data->optlen);
3376 sys_sem_signal((sys_sem_t *)(data->completed_sem));
3876 /* Check if there is data left from the last recv operation. /maq 041215 */