Page 4 of 11
Article Index
Page 54 Not listed in full in book
Simple integer state request
#include <stdio.h>
#include "pico/stdlib.h"
#include "pico/cyw43_arch.h"
#include "setupWifi.h"
#include "lwip/altcp.h"
#define BUF_SIZE 2048
char myBuff[BUF_SIZE];
char header[] = "GET /index.html HTTP/1.1\r\nHOST:example.com\r\n\r\n";
err_t sent(void *arg, struct altcp_pcb *pcb, u16_t len)
{
printf("data sent %d\n", len);
}
err_t recv(void *arg, struct altcp_pcb *pcb, struct pbuf *p, err_t err)
{
if (p != NULL)
{
printf("recv total %d this buffer %d next %d err %d\n", p->tot_len, p->len, p->next, err);
if ((p->tot_len) > 2)
{
pbuf_copy_partial(p, myBuff, p->tot_len, 0);
myBuff[p->tot_len] = 0;
*(int *)arg = 4;
altcp_recved(pcb, p->tot_len);
}
pbuf_free(p);
}
else
{
printf("Connection Closed \n");
altcp_close(pcb);
*(int *)arg = 6;
}
return ERR_OK;
}
static err_t altcp_client_connected(void *arg, struct altcp_pcb *pcb, err_t err)
{
*(int *)arg = 2;
return ERR_OK;
}
err_t poll(void *arg, struct altcp_pcb *pcb)
{
printf("Connection Closed \n");
*(int *)arg = 6;
altcp_close(pcb);
}
void err(void *arg, err_t err)
{
if (err != ERR_ABRT)
{
printf("client_err %d\n", err);
}
}
int main()
{
stdio_init_all();
connect();
int state = 0;
struct altcp_pcb *pcb = altcp_new(NULL);
altcp_recv(pcb, recv);
altcp_sent(pcb, sent);
altcp_err(pcb, err);
altcp_poll(pcb, poll, 10);
altcp_arg(pcb, &state);
ip_addr_t ip;
IP4_ADDR(&ip, 93, 184, 216, 34);
cyw43_arch_lwip_begin();
err_t err = altcp_connect(pcb, &ip, 80, altcp_client_connected);
cyw43_arch_lwip_end();
state = 1;
while (state != 0)
{
switch (state)
{
case 0:
case 1:
case 3:
break;
case 2:
state = 3;
cyw43_arch_lwip_begin();
err = altcp_write(pcb, header, strlen(header), 0);
err = altcp_output(pcb);
cyw43_arch_lwip_end();
break;
case 4:
state = 5;
break;
case 6:
printf("Buffer= %s\n", myBuff);
state = 0;
break;
default:
sleep_ms(1000);
printf("LED Flash\n");
}
}
printf("Data Transfered\n");
}
Page 59 State use a struct
#include <stdio.h>
#include "pico/stdlib.h"
#include "pico/cyw43_arch.h"
#include "setupWifi.h"
#include "lwip/altcp.h"
#define BUF_SIZE 2048
char myBuff[BUF_SIZE];
char header[] = "GET /index.html HTTP/1.1\r\nHOST:example.com\r\n\r\n";
struct connectionState
{
int state;
struct altcp_pcb *pcb;
char *myBuff;
int start;
};
err_t sent(void *arg, struct altcp_pcb *pcb, u16_t len)
{
printf("data sent %d\n", len);
}
err_t recv(void *arg, struct altcp_pcb *pcb, struct pbuf *p, err_t err)
{
struct connectionState *cs = (struct connectionState *)arg;
if (p != NULL)
{
printf("recv total %d this buffer %d next %d err %d\n", p->tot_len, p->len, p->next, err);
if ((p->tot_len) > 2)
{
pbuf_copy_partial(p, (cs->myBuff) + (cs->start), p->tot_len, 0);
cs->start += p->tot_len;
cs->myBuff[cs->start] = 0;
cs->state = 4;
altcp_recved(pcb, p->tot_len);
}
pbuf_free(p);
}
else
{
printf("Connection Closed\n");
altcp_close(pcb);
cs->state = 6;
}
return ERR_OK;
}
static err_t connected(void *arg, struct altcp_pcb *pcb, err_t err)
{
struct connectionState *cs = (struct connectionState *)arg;
cs->state = 2;
return ERR_OK;
}
err_t poll(void *arg, struct altcp_pcb *pcb)
{
printf("Connection Closed \n");
struct connectionState *cs = (struct connectionState *)arg;
cs->state = 6;
altcp_close(pcb);
}
void err(void *arg, err_t err)
{
if (err != ERR_ABRT)
{
printf("client_err %d\n", err);
}
}
err_t newConnection(struct connectionState *cs, char *buf)
{
cs->state = 0;
cs->pcb = altcp_new(NULL);
altcp_recv(cs->pcb, recv);
altcp_sent(cs->pcb, sent);
altcp_err(cs->pcb, err);
altcp_poll(cs->pcb, poll, 10);
altcp_arg(cs->pcb, cs);
cs->myBuff = buf;
cs->start = 0;
return ERR_OK;
}
int pollConnection(struct connectionState *cs)
{
switch (cs->state)
{
case 0:
case 1:
case 3:
case 6:
break;
case 2:
cs->state = 3;
cyw43_arch_lwip_begin();
err_t err = altcp_write(cs->pcb, header, strlen(header), 0);
err = altcp_output(cs->pcb);
cyw43_arch_lwip_end();
break;
case 4:
cs->state = 5;
break;
}
return cs->state;
}
int main()
{
stdio_init_all();
connect();
struct connectionState cs;
newConnection(&cs, myBuff);
ip_addr_t ip;
IP4_ADDR(&ip, 93, 184, 216, 34);
cyw43_arch_lwip_begin();
err_t err = altcp_connect(cs.pcb, &ip, 80, connected);
cyw43_arch_lwip_end();
cs.state = 1;
while (true)
{
if (pollConnection(&cs) == 6)
{
printf("Buffer= %s\n", cs.myBuff);
cs.state = 0;
break;
}
sleep_ms(1000);
printf("LED Flash\n");
}
printf("Data Transfered\n");
}
Page 65 Non blocking general Request.h
struct connectionState
{
int state;
struct altcp_pcb *pcb;
char *sendData;
char *recvData;
int start;
};
err_t sent(void *arg, struct altcp_pcb *pcb, u16_t len)
{
printf("data sent %d\n", len);
}
err_t recv(void *arg, struct altcp_pcb *pcb, struct pbuf *p, err_t err)
{
struct connectionState *cs = (struct connectionState *)arg;
if (p != NULL)
{
printf("recv total %d this buffer %d next %d err %d\n", p->tot_len, p->len, p->next, err);
if ((p->tot_len) > 2)
{
pbuf_copy_partial(p, (cs->recvData) + (cs->start), p->tot_len, 0);
cs->start += p->tot_len;
cs->recvData[cs->start] = 0;
cs->state = 4;
altcp_recved(pcb, p->tot_len);
}
pbuf_free(p);
}
else
{
cs->state = 6;
}
return ERR_OK;
}
static err_t connected(void *arg, struct altcp_pcb *pcb, err_t err)
{
struct connectionState *cs = (struct connectionState *)arg;
cs->state = 2;
return ERR_OK;
}
err_t poll(void *arg, struct altcp_pcb *pcb)
{
printf("Connection Closed \n");
struct connectionState *cs = (struct connectionState *)arg;
cs->state = 6;
}
void err(void *arg, err_t err)
{
if (err != ERR_ABRT)
{
printf("client_err %d\n", err);
}
}
struct connectionState *newConnection(char *sendData, char *recvData)
{
struct connectionState *cs = (struct connectionState *)malloc(sizeof(struct connectionState));
cs->state = 0;
cs->pcb = altcp_new(NULL);
altcp_recv(cs->pcb, recv);
altcp_sent(cs->pcb, sent);
altcp_err(cs->pcb, err);
altcp_poll(cs->pcb, poll, 10);
altcp_arg(cs->pcb, cs);
cs->sendData = sendData;
cs->recvData = recvData;
cs->start = 0;
return cs;
}
struct connectionState *doRequest(ip_addr_t *ip, char *host, u16_t port, char *request, char *file, char *sendData, char *recvData)
{
char headerTemplate[] = "%s %s HTTP/1.1\r\nHOST:%s:%d\r\nConnection: close\r\nContent-length: %d\r\n\r\n%s";
int len = snprintf(NULL, 0, headerTemplate, request, file, host, port, strlen(sendData), sendData);
char *requestData = malloc(len + 1);
snprintf(requestData, len + 1, headerTemplate, request, file, host, port, strlen(sendData), sendData);
struct connectionState *cs = newConnection(requestData, recvData);
cyw43_arch_lwip_begin();
err_t err = altcp_connect(cs->pcb, ip, port, connected);
cyw43_arch_lwip_end();
cs->state = 1;
return cs;
}
int pollRequest(struct connectionState **pcs)
{
if(*pcs==NULL) return 0;
struct connectionState *cs=*pcs;
switch (cs->state)
{
case 0:
case 1:
case 3:
break;
case 2:
cs->state = 3;
cyw43_arch_lwip_begin();
err_t err = altcp_write(cs->pcb, cs->sendData, strlen(cs->sendData), 0);
err = altcp_output(cs->pcb);
cyw43_arch_lwip_end();
break;
case 4:
cs->state = 5;
break;
case 6:
cyw43_arch_lwip_begin();
altcp_close(cs->pcb);
cyw43_arch_lwip_end();
free(cs);
*pcs = NULL;
return 0;
}
return cs->state;
}
Page 27 Non blocking Request main program downloading two requests.
#include <stdio.h>
#include "pico/stdlib.h"
#include "pico/cyw43_arch.h"
#include "lwip/altcp.h"
#include "setupWifi.h"
#include "request.h"
#define BUF_SIZE 2048
char myBuff1[BUF_SIZE];
char myBuff2[BUF_SIZE];
int main()
{
stdio_init_all();
connect();
ip_addr_t ip;
IP4_ADDR(&ip, 93, 184, 216, 34);
struct connectionState *cs1 = doRequest(&ip, "example.com", 80, "GET", "/", NULL, myBuff1);
IP4_ADDR(&ip, 192, 168, 11, 101);
struct connectionState *cs2 = doRequest(&ip, "192.168.11.101", 8080, "PUT", "/", "Hello PUT world", myBuff2);
while (pollRequest(&cs1) + pollRequest(&cs2))
{
sleep_ms(100);
}
printf("Both complete\n");
printf("Buffer 1 = \n%s\n\n", myBuff1);
printf("Buffer 2 = \n%s\n\n", myBuff2);
printf("Data Transferred\n");
cyw43_arch_deinit();
return 0;
}
Page 70 Temperature PUT client main program
#include <stdio.h>
#include "pico/stdlib.h"
#include "pico/cyw43_arch.h"
#include "setupWifi.h"
#include "lwip/altcp.h"
#include "request.h"
#define BUF_SIZE 4096
char myBuff1[BUF_SIZE];
int readTemp()
{
return 33;
}
int main()
{
char ssid[] = "laribina";
char pass[] = "hawkhawk";
uint32_t country = CYW43_COUNTRY_UK;
uint32_t auth = CYW43_AUTH_WPA2_MIXED_PSK;
stdio_init_all();
setup(country, ssid, pass, auth, "MyPicoW", NULL, NULL, NULL);
ip_addr_t ip;
IP4_ADDR(&ip, 192, 168, 11, 101);
while (true)
{
int t = readTemp();
int len = snprintf(NULL, 0, "%d", t);
char *requestData = malloc(len + 1);
snprintf(requestData, len + 1, "%d", t);
printf("%s\n",requestData);
struct connectionState *cs1 = doRequest(&ip, "192.168.11.101", 8080, "PUT", "/", requestData, myBuff1);
while (pollRequest(&cs1) )
{
sleep_ms(200);
}
printf("%s\n",myBuff1);
sleep_ms(5000);
}
return 0;
}
Page 71 Custom Sever For the PUT Temperature Client
from http.server import HTTPServer, BaseHTTPRequestHandler
from io import BytesIO
class SimpleHTTPRequestHandler(BaseHTTPRequestHandler):
def log_message(self,*args, **kwargs):
pass
def do_PUT(self):
content_length = int(self.headers['Content-Length'])
body = self.rfile.read(content_length)
bodyString= body.decode(encoding="utf-8")
temp=float(bodyString)
print(temp,"C")
self.send_response(200)
self.end_headers()
httpd = HTTPServer(('', 8080), SimpleHTTPRequestHandler)
httpd.serve_forever()
Page 72 full listing not in book
Binary request version of request.h
struct connectionState
{
int state;
struct altcp_pcb *pcb;
char *sendData;
int bytes;
char *recvData;
int start;
};
err_t sent(void *arg, struct altcp_pcb *pcb, u16_t len)
{
printf("data sent %d\n", len);
}
err_t recv(void *arg, struct altcp_pcb *pcb, struct pbuf *p, err_t err)
{
struct connectionState *cs = (struct connectionState *)arg;
if (p != NULL)
{
printf("recv total %d this buffer %d next %d err %d\n", p->tot_len, p->len, p->next, err);
if ((p->tot_len) > 2)
{
pbuf_copy_partial(p, (cs->recvData) + (cs->start), p->tot_len, 0);
cs->start += p->tot_len;
cs->recvData[cs->start] = 0;
cs->state = 4;
altcp_recved(pcb, p->tot_len);
}
pbuf_free(p);
}
else
{
cs->state = 6;
}
return ERR_OK;
}
static err_t connected(void *arg, struct altcp_pcb *pcb, err_t err)
{
struct connectionState *cs = (struct connectionState *)arg;
cs->state = 2;
return ERR_OK;
}
err_t poll(void *arg, struct altcp_pcb *pcb)
{
printf("Connection Closed \n");
struct connectionState *cs = (struct connectionState *)arg;
cs->state = 6;
}
void err(void *arg, err_t err)
{
if (err != ERR_ABRT)
{
printf("client_err %d\n", err);
}
}
struct connectionState *newConnection(char *sendData, int bytes, char *recvData)
{
struct connectionState *cs = (struct connectionState *)malloc(sizeof(struct connectionState));
cs->state = 0;
cs->pcb = altcp_new(NULL);
altcp_recv(cs->pcb, recv);
altcp_sent(cs->pcb, sent);
altcp_err(cs->pcb, err);
altcp_poll(cs->pcb, poll, 10);
altcp_arg(cs->pcb, cs);
cs->sendData = sendData;
cs->bytes=bytes;
cs->recvData = recvData;
cs->start = 0;
return cs;
}
struct connectionState *doRequest(ip_addr_t *ip, char *host, u16_t port, char *request, char *file, char *sendData, char *recvData)
{
char headerTemplate[] = "%s %s HTTP/1.1\r\nHOST:%s:%d\r\nConnection: close\r\nContent-length: %d\r\n\r\n%s";
int len = snprintf(NULL, 0, headerTemplate, request, file, host, port, strlen(sendData), sendData);
char *requestData = malloc(len + 1);
snprintf(requestData, len + 1, headerTemplate, request, file, host, port, strlen(sendData), sendData);
struct connectionState *cs = newConnection(requestData, strlen(requestData),recvData);
cyw43_arch_lwip_begin();
err_t err = altcp_connect(cs->pcb, ip, port, connected);
cyw43_arch_lwip_end();
cs->state = 1;
return cs;
}
struct connectionState *doRequestBinary(ip_addr_t *ip, char *host, u16_t port, char *request, char *file, char *sendData, int bytes, char *recvData)
{
char headerTemplate[] = "%s %s HTTP/1.1\r\nHOST:%s:%d\r\nConnection: close\r\nContent-length: %d\r\n\r\n";
int len = snprintf(NULL, 0, headerTemplate, request, file, host, port, bytes);
char *requestData = malloc(len + bytes + 1);
snprintf(requestData, len + 1, headerTemplate, request, file, host, port, bytes);
memcpy(requestData + len, sendData, bytes);
struct connectionState *cs = newConnection(requestData, len + bytes, recvData);
cyw43_arch_lwip_begin();
err_t err = altcp_connect(cs->pcb, ip, port, connected);
cyw43_arch_lwip_end();
cs->state = 1;
return cs;
}
int pollRequest(struct connectionState **pcs)
{
if (*pcs == NULL)
return 0;
struct connectionState *cs = *pcs;
switch (cs->state)
{
case 0:
case 1:
case 3:
break;
case 2:
cs->state = 3;
cyw43_arch_lwip_begin();
err_t err = altcp_write(cs->pcb, cs->sendData, cs->bytes, 0);
err = altcp_output(cs->pcb);
cyw43_arch_lwip_end();
break;
case 4:
cs->state = 5;
break;
case 6:
cyw43_arch_lwip_begin();
altcp_close(cs->pcb);
cyw43_arch_lwip_end();
free(cs);
*pcs = NULL;
return 0;
}
return cs->state;
}
Page 74 Binary request main program
#include <stdio.h>
#include "pico/stdlib.h"
#include "pico/cyw43_arch.h"
#include "setupWifi.h"
#include "lwip/altcp.h"
#include "request.h"
#define BUF_SIZE 4096
char myBuff1[BUF_SIZE];
int main()
{
char ssid[] = "laribina";
char pass[] = "hawkhawk";
uint32_t country = CYW43_COUNTRY_UK;
uint32_t auth = CYW43_AUTH_WPA2_MIXED_PSK;
stdio_init_all();
setup(country, ssid, pass, auth, "MyPicoW", NULL, NULL, NULL);
char randdata[500];
ip_addr_t ip;
IP4_ADDR(&ip, 192, 168, 11, 101);
for (int p = 0; p < 500; p++)
{
randdata[p] = (uint8_t)rand();
}
struct connectionState *cs1 = doRequestBinary(&ip, "192.168.11.101", 8080, "PUT", "/", randdata, 500, myBuff1);
while (pollRequest(&cs1))
{
sleep_ms(200);
}
printf("%s\n", myBuff1);
return 0;
}
Page 75 Python Custom server for Binary request
from http.server import HTTPServer, BaseHTTPRequestHandler
from io import BytesIO
class SimpleHTTPRequestHandler(BaseHTTPRequestHandler):
def log_message(self,*args, **kwargs):
pass
def do_PUT(self):
content_length = int(self.headers['Content-Length'])
body = self.rfile.read(content_length)
print(content_length)
with open("data.bin",mode="wb") as f:
f.write(body)
self.send_response(200)
self.end_headers()
response = BytesIO()
response.write(b'Received:' )
self.wfile.write(response.getvalue())
httpd = HTTPServer(('', 8080), SimpleHTTPRequestHandler)
httpd.serve_forever()
Page 77 full listing not in book
DNS Main Program needs requests.h
#include <stdio.h>
#include "pico/stdlib.h"
#include "pico/cyw43_arch.h"
#include "lwip/altcp.h"
#include "lwip/dns.h"
#include "setupWifi.h"
#include "request.h"
#define BUF_SIZE 2048
char myBuff1[BUF_SIZE];
void dns_found(const char *name, const ip_addr_t *ip, void *arg)
{
ip_addr_t *ipResult = (ip_addr_t *)arg;
if (ip)
{
ip4_addr_copy(*ipResult, *ip);
}
else
{
ip4_addr_set_loopback(ipResult);
}
return;
}
err_t getIP(char *URL, ip_addr_t *ipResult)
{
cyw43_arch_lwip_begin();
err_t err = dns_gethostbyname(URL, ipResult, dns_found, ipResult);
cyw43_arch_lwip_end();
return err;
}
int main()
{
stdio_init_all();
connect();
ip_addr_t ip;
ip4_addr_set_zero(&ip);
getIP("example.com", &ip);
while (!ip_addr_get_ip4_u32(&ip))
{
sleep_ms(100);
};
if (ip4_addr_isloopback(&ip))
{
printf("address not found");
}
struct connectionState *cs1 = doRequest(&ip, "example.com", 80, "GET", "/", NULL, myBuff1);
while (pollRequest(&cs1))
{
sleep_ms(100);
}
printf("Buffer 1 = \n%s\n\n", myBuff1);
printf("Data Transferred\n");
cyw43_arch_deinit();
return 0;
}
