|
|
|
@ -83,6 +83,7 @@ static u8_t
|
|
|
|
|
buf_bufdata(struct psock_buf *buf, u16_t len,
|
|
|
|
|
u8_t **dataptr, u16_t *datalen)
|
|
|
|
|
{
|
|
|
|
|
( void ) len;
|
|
|
|
|
if(*datalen < buf->left) {
|
|
|
|
|
memcpy(buf->ptr, *dataptr, *datalen);
|
|
|
|
|
buf->ptr += *datalen;
|
|
|
|
@ -185,7 +186,7 @@ PT_THREAD(psock_send(register struct psock *s, const char *buf,
|
|
|
|
|
|
|
|
|
|
/* Save the length of and a pointer to the data that is to be
|
|
|
|
|
sent. */
|
|
|
|
|
s->sendptr = buf;
|
|
|
|
|
s->sendptr = (unsigned char*)buf;
|
|
|
|
|
s->sendlen = len;
|
|
|
|
|
|
|
|
|
|
s->state = STATE_NONE;
|
|
|
|
@ -273,7 +274,7 @@ PT_THREAD(psock_readto(register struct psock *psock, unsigned char c))
|
|
|
|
|
{
|
|
|
|
|
PT_BEGIN(&psock->psockpt);
|
|
|
|
|
|
|
|
|
|
buf_setup(&psock->buf, psock->bufptr, psock->bufsize);
|
|
|
|
|
buf_setup(&psock->buf, (unsigned char*)psock->bufptr, psock->bufsize);
|
|
|
|
|
|
|
|
|
|
/* XXX: Should add buf_checkmarker() before do{} loop, if
|
|
|
|
|
incoming data has been handled while waiting for a write. */
|
|
|
|
@ -300,7 +301,7 @@ PT_THREAD(psock_readbuf(register struct psock *psock))
|
|
|
|
|
{
|
|
|
|
|
PT_BEGIN(&psock->psockpt);
|
|
|
|
|
|
|
|
|
|
buf_setup(&psock->buf, psock->bufptr, psock->bufsize);
|
|
|
|
|
buf_setup(&psock->buf, (unsigned char * ) psock->bufptr, psock->bufsize);
|
|
|
|
|
|
|
|
|
|
/* XXX: Should add buf_checkmarker() before do{} loop, if
|
|
|
|
|
incoming data has been handled while waiting for a write. */
|
|
|
|
@ -331,7 +332,7 @@ psock_init(register struct psock *psock, char *buffer, unsigned int buffersize)
|
|
|
|
|
psock->readlen = 0;
|
|
|
|
|
psock->bufptr = buffer;
|
|
|
|
|
psock->bufsize = buffersize;
|
|
|
|
|
buf_setup(&psock->buf, buffer, buffersize);
|
|
|
|
|
buf_setup(&psock->buf, (unsigned char*) buffer, buffersize);
|
|
|
|
|
PT_INIT(&psock->pt);
|
|
|
|
|
PT_INIT(&psock->psockpt);
|
|
|
|
|
}
|
|
|
|
|