3
3
using namespace std ;
4
4
5
5
/* -------------------------------------------------------------------------- */
6
- WiFiClient::WiFiClient () : _sock(-1 ), destroy_at_distructor(true ), rx_buffer(nullptr ) {
6
+ WiFiClient::WiFiClient () : _sock(-1 ), destroy_at_distructor(true ), rx_buffer(nullptr ) {
7
7
rx_buffer = std::shared_ptr<FifoBuffer<uint8_t ,RX_BUFFER_DIM>>(new FifoBuffer<uint8_t ,RX_BUFFER_DIM>());
8
8
}
9
9
/* -------------------------------------------------------------------------- */
10
-
10
+
11
11
/* -------------------------------------------------------------------------- */
12
12
WiFiClient::WiFiClient (int s) : _sock(s), destroy_at_distructor(false ), rx_buffer(nullptr ) {
13
13
rx_buffer = std::shared_ptr<FifoBuffer<uint8_t ,RX_BUFFER_DIM>>(new FifoBuffer<uint8_t ,RX_BUFFER_DIM>());
@@ -18,9 +18,9 @@ WiFiClient::WiFiClient(int s) : _sock(s), destroy_at_distructor(false), rx_buffe
18
18
WiFiClient::~WiFiClient () { }
19
19
/* -------------------------------------------------------------------------- */
20
20
21
- /* -------------------------------------------------------------------------- */
21
+ /* -------------------------------------------------------------------------- */
22
22
WiFiClient::WiFiClient (const WiFiClient& c) {
23
- /* -------------------------------------------------------------------------- */
23
+ /* -------------------------------------------------------------------------- */
24
24
_sock = c._sock ;
25
25
rx_buffer = c.rx_buffer ;
26
26
}
@@ -34,7 +34,7 @@ void WiFiClient::getSocket() {
34
34
if (modem.write (string (PROMPT (_BEGINCLIENT)),res, " %s" , CMD (_BEGINCLIENT))) {
35
35
_sock = atoi (res.c_str ());
36
36
}
37
- }
37
+ }
38
38
}
39
39
40
40
/* -------------------------------------------------------------------------- */
@@ -45,7 +45,7 @@ int WiFiClient::connect(IPAddress ip, uint16_t port){
45
45
46
46
/* -------------------------------------------------------------------------- */
47
47
int WiFiClient::connect (const char *host, uint16_t port){
48
- /* -------------------------------------------------------------------------- */
48
+ /* -------------------------------------------------------------------------- */
49
49
getSocket ();
50
50
if (_sock >= 0 ) {
51
51
string res = " " ;
@@ -55,17 +55,18 @@ int WiFiClient::connect(const char *host, uint16_t port){
55
55
return 1 ;
56
56
}
57
57
} else {
58
- if (modem.write (string (PROMPT (_CLIENTCONNECTNAME)),res, " %s%d,%s,%d\r\n " , CMD_WRITE (_CLIENTCONNECTNAME), _sock, host,port)) {
59
- return 1 ;
60
- }
58
+ if (modem.write (string (PROMPT (_CLIENTCONNECTNAME)),res, " %s%d,%s,%d\r\n " , CMD_WRITE (_CLIENTCONNECTNAME), _sock, host,port)) {
59
+ return 1 ;
60
+ }
61
61
}
62
62
}
63
+
63
64
return 0 ;
64
65
}
65
66
66
67
/* -------------------------------------------------------------------------- */
67
68
size_t WiFiClient::write (uint8_t b){
68
- /* -------------------------------------------------------------------------- */
69
+ /* -------------------------------------------------------------------------- */
69
70
return write (&b, 1 );
70
71
}
71
72
@@ -79,15 +80,14 @@ size_t WiFiClient::write(const uint8_t *buf, size_t size){
79
80
if (modem.passthrough (buf,size)) {
80
81
return size;
81
82
}
82
-
83
83
}
84
84
return 0 ;
85
85
86
86
}
87
87
88
88
/* -------------------------------------------------------------------------- */
89
89
int WiFiClient::available () {
90
- /* -------------------------------------------------------------------------- */
90
+ /* -------------------------------------------------------------------------- */
91
91
int rv = 0 ;
92
92
if (_sock >= 0 && rx_buffer != nullptr ) {
93
93
if (rx_buffer->available () > 0 ) {
@@ -109,17 +109,17 @@ int WiFiClient::available() {
109
109
110
110
/* -------------------------------------------------------------------------- */
111
111
int WiFiClient::_read () {
112
- /* -------------------------------------------------------------------------- */
112
+ /* -------------------------------------------------------------------------- */
113
113
int rv = -1 ;
114
114
if (_sock >= 0 && rx_buffer != nullptr ) {
115
115
string res = " " ;
116
116
uint32_t size = rx_buffer->freePositions () - 1 ;
117
117
modem.begin ();
118
-
118
+
119
119
/* important - it works one shot */
120
120
modem.avoid_trim_results ();
121
121
modem.read_using_size ();
122
-
122
+
123
123
if (modem.write (string (PROMPT (_CLIENTRECEIVE)),res, " %s%d,%d\r\n " , CMD_WRITE (_CLIENTRECEIVE), _sock, size)) {
124
124
if (res.size () > 0 ) {
125
125
for (int i = 0 , rv = 0 ; i < size && i < res.size (); i++) {
@@ -133,11 +133,11 @@ int WiFiClient::_read() {
133
133
}
134
134
}
135
135
return rv;
136
- }
136
+ }
137
137
138
138
/* -------------------------------------------------------------------------- */
139
139
void WiFiClient::read_if_needed (size_t s) {
140
- /* -------------------------------------------------------------------------- */
140
+ /* -------------------------------------------------------------------------- */
141
141
if (rx_buffer != nullptr ) {
142
142
if ((size_t )rx_buffer->available () < s) {
143
143
_read ();
@@ -147,12 +147,12 @@ void WiFiClient::read_if_needed(size_t s) {
147
147
148
148
/* -------------------------------------------------------------------------- */
149
149
int WiFiClient::read () {
150
- /* -------------------------------------------------------------------------- */
150
+ /* -------------------------------------------------------------------------- */
151
151
uint8_t b;
152
152
if (read (&b, 1 ) == 1 ) {
153
153
return b;
154
154
}
155
- return -1 ;
155
+ return -1 ;
156
156
}
157
157
158
158
/* -------------------------------------------------------------------------- */
@@ -173,27 +173,27 @@ int WiFiClient::read(uint8_t *buf, size_t size) {
173
173
}
174
174
}
175
175
}
176
- return rv;
176
+ return rv;
177
177
}
178
178
179
179
/* -------------------------------------------------------------------------- */
180
180
int WiFiClient::peek () {
181
- /* -------------------------------------------------------------------------- */
181
+ /* -------------------------------------------------------------------------- */
182
182
int rv = -1 ;
183
183
if (_sock >= 0 ) {
184
184
string res = " " ;
185
185
modem.begin ();
186
186
if (modem.write (string (PROMPT (_PEEK)),res, " %s%d\r\n " , CMD_WRITE (_PEEK), _sock)) {
187
187
rv = atoi (res.c_str ());
188
- }
188
+ }
189
189
}
190
190
return rv;
191
191
}
192
192
193
193
194
194
/* -------------------------------------------------------------------------- */
195
195
void WiFiClient::flush () {
196
- /* -------------------------------------------------------------------------- */
196
+ /* -------------------------------------------------------------------------- */
197
197
if (_sock >= 0 ) {
198
198
string res = " " ;
199
199
modem.begin ();
@@ -203,7 +203,7 @@ void WiFiClient::flush() {
203
203
204
204
/* -------------------------------------------------------------------------- */
205
205
void WiFiClient::stop () {
206
- /* -------------------------------------------------------------------------- */
206
+ /* -------------------------------------------------------------------------- */
207
207
if (_sock >= 0 ) {
208
208
string res = " " ;
209
209
modem.begin ();
@@ -214,7 +214,7 @@ void WiFiClient::stop() {
214
214
215
215
/* -------------------------------------------------------------------------- */
216
216
uint8_t WiFiClient::connected () {
217
- /* -------------------------------------------------------------------------- */
217
+ /* -------------------------------------------------------------------------- */
218
218
uint8_t rv = 0 ;
219
219
if (this ->available () > 0 ) {
220
220
return 1 ;
@@ -224,16 +224,16 @@ uint8_t WiFiClient::connected() {
224
224
modem.begin ();
225
225
if (modem.write (string (PROMPT (_CLIENTCONNECTED)),res, " %s%d\r\n " , CMD_WRITE (_CLIENTCONNECTED), _sock)) {
226
226
rv = atoi (res.c_str ());
227
- }
227
+ }
228
228
}
229
+
229
230
return rv;
230
231
}
231
232
232
233
/* -------------------------------------------------------------------------- */
233
- bool WiFiClient::operator ==(const WiFiClient& whs)
234
- {
235
- /* -------------------------------------------------------------------------- */
236
- return _sock == whs._sock ;
234
+ bool WiFiClient::operator ==(const WiFiClient& whs) {
235
+ /* -------------------------------------------------------------------------- */
236
+ return _sock == whs._sock ;
237
237
}
238
238
239
239
/* -------------------------------------------------------------------------- */
@@ -246,22 +246,22 @@ IPAddress WiFiClient::remoteIP() {
246
246
if (modem.write (string (PROMPT (_REMOTEIP)),res, " %s%d\r\n " , CMD_WRITE (_REMOTEIP), _sock)) {
247
247
ip.fromString (res.c_str ());
248
248
return ip;
249
- }
249
+ }
250
250
}
251
251
return IPAddress (0 ,0 ,0 ,0 );
252
252
}
253
253
254
254
/* -------------------------------------------------------------------------- */
255
255
uint16_t WiFiClient::remotePort (){
256
- /* -------------------------------------------------------------------------- */
256
+ /* -------------------------------------------------------------------------- */
257
257
uint16_t rv = 0 ;
258
258
if (_sock >= 0 ) {
259
259
string res = " " ;
260
260
modem.begin ();
261
261
if (modem.write (string (PROMPT (_REMOTEPORT)),res, " %s%d\r\n " , CMD_WRITE (_REMOTEPORT), _sock)) {
262
262
rv = atoi (res.c_str ());
263
263
return rv;
264
- }
264
+ }
265
265
}
266
- return rv;
266
+ return rv;
267
267
}
0 commit comments