@@ -40,7 +40,7 @@ class SnapProcessor {
40
40
}
41
41
42
42
virtual void end () {
43
- ESP_LOGD (TAG, " start " );
43
+ ESP_LOGD (TAG, " >>> end " );
44
44
audioEnd ();
45
45
send_receive_buffer.resize (0 );
46
46
base_message_serialized.resize (0 );
@@ -113,7 +113,7 @@ class SnapProcessor {
113
113
SnapTime &snap_time = SnapTime::instance();
114
114
115
115
void processLoop (void *pvParameters = nullptr ) {
116
- ESP_LOGI (TAG, " processLoop" );
116
+ ESP_LOGI (TAG, " >>> processLoop" );
117
117
118
118
while (true ) {
119
119
ESP_LOGD (TAG, " startig new connection" );
@@ -155,16 +155,16 @@ class SnapProcessor {
155
155
}
156
156
157
157
bool resizeData () {
158
- ESP_LOGD (TAG, " start " );
158
+ ESP_LOGD (TAG, " >>> resizeData " );
159
159
audio.resize (frame_size);
160
160
send_receive_buffer.resize (CONFIG_SNAPCAST_BUFF_LEN);
161
161
base_message_serialized.resize (BASE_MESSAGE_SIZE);
162
- ESP_LOGD (TAG, " end! " );
162
+ ESP_LOGD (TAG, " <<< resizeData " );
163
163
return true ;
164
164
}
165
165
166
166
bool processMessageLoop () {
167
- ESP_LOGD (TAG, " start " );
167
+ ESP_LOGD (TAG, " >>> processMessageLoop " );
168
168
169
169
if (!readBaseMessage ())
170
170
return false ;
@@ -207,7 +207,7 @@ class SnapProcessor {
207
207
}
208
208
209
209
bool connectClient () {
210
- ESP_LOGD (TAG, " start " );
210
+ ESP_LOGD (TAG, " >>> connectClient " );
211
211
p_client->setTimeout (CONFIG_CLIENT_TIMEOUT_SEC);
212
212
if (!p_client->connect (server_ip, server_port)) {
213
213
ESP_LOGE (TAG, " ... socket connect failed errno=%d" , errno);
@@ -218,7 +218,7 @@ class SnapProcessor {
218
218
}
219
219
220
220
bool writeHallo () {
221
- ESP_LOGD (TAG, " start " );
221
+ ESP_LOGD (TAG, " >>> writeHallo " );
222
222
// setup base_message
223
223
base_message.type = SNAPCAST_MESSAGE_HELLO;
224
224
base_message.id = 0x0 ;
@@ -262,7 +262,7 @@ class SnapProcessor {
262
262
}
263
263
264
264
bool readBaseMessage () {
265
- ESP_LOGD (TAG, " %d" , BASE_MESSAGE_SIZE);
265
+ ESP_LOGD (TAG, " >>> readBaseMessage: %d" , BASE_MESSAGE_SIZE);
266
266
// Wait for timeout
267
267
// uint64_t end = millis() + CONFIG_WEBSOCKET_SERVER_TIMEOUT_SEC * 1000;
268
268
while (p_client->available () < BASE_MESSAGE_SIZE) {
@@ -289,7 +289,7 @@ class SnapProcessor {
289
289
}
290
290
291
291
bool readData () {
292
- ESP_LOGD (TAG, " %d" , base_message.size );
292
+ ESP_LOGD (TAG, " >>> readData: %d" , base_message.size );
293
293
if (base_message.size > send_receive_buffer.size ()) {
294
294
send_receive_buffer.resize (base_message.size );
295
295
}
@@ -301,7 +301,7 @@ class SnapProcessor {
301
301
}
302
302
303
303
bool processMessageCodecHeader () {
304
- ESP_LOGD (TAG, " start " );
304
+ ESP_LOGD (TAG, " >>> processMessageCodecHeader " );
305
305
SnapMessageCodecHeader codec_header_message;
306
306
start = &send_receive_buffer[0 ];
307
307
int result = codec_header_message.deserialize (start, size);
@@ -339,7 +339,7 @@ class SnapProcessor {
339
339
}
340
340
341
341
bool processMessageCodecHeaderOpus (codec_type codecType) {
342
- ESP_LOGD (TAG, " start " );
342
+ ESP_LOGD (TAG, " >>> processMessageCodecHeaderOpus " );
343
343
uint32_t rate;
344
344
memcpy (&rate, start + 4 , sizeof (rate));
345
345
uint16_t bits;
@@ -354,7 +354,7 @@ class SnapProcessor {
354
354
}
355
355
356
356
bool processMessageCodecHeaderExt (codec_type codecType) {
357
- ESP_LOGD (TAG, " start " );
357
+ ESP_LOGD (TAG, " >>> processMessageCodecHeaderExt " );
358
358
codec_from_server = codecType;
359
359
audioBegin ();
360
360
// send the data to the codec
@@ -363,7 +363,7 @@ class SnapProcessor {
363
363
}
364
364
365
365
bool processMessageWireChunk () {
366
- ESP_LOGD (TAG, " start " );
366
+ ESP_LOGD (TAG, " >>> processMessageWireChunk " );
367
367
start = &send_receive_buffer[0 ];
368
368
SnapMessageWireChunk wire_chunk_message;
369
369
memset ((void *)&wire_chunk_message, 0 , sizeof (wire_chunk_message));
@@ -388,7 +388,7 @@ class SnapProcessor {
388
388
}
389
389
390
390
bool wireChunk (SnapMessageWireChunk &wire_chunk_message) {
391
- ESP_LOGD (TAG, " start " );
391
+ ESP_LOGD (TAG, " >>> wireChunk " );
392
392
SnapAudioHeader header;
393
393
header.size = wire_chunk_message.size ;
394
394
@@ -407,7 +407,7 @@ class SnapProcessor {
407
407
}
408
408
409
409
bool processMessageServerSettings () {
410
- ESP_LOGD (TAG, " start " );
410
+ ESP_LOGD (TAG, " >>> processMessageServerSettings " );
411
411
SnapMessageServerSettings server_settings_message;
412
412
413
413
// The first 4 bytes in the buffer are the size of the string.
@@ -444,7 +444,7 @@ class SnapProcessor {
444
444
}
445
445
446
446
bool processMessageTime () {
447
- ESP_LOGD (TAG, " start " );
447
+ ESP_LOGD (TAG, " >>> processMessageTime " );
448
448
int result = time_message.deserialize (start, size);
449
449
if (result) {
450
450
ESP_LOGI (TAG, " Failed to deserialize time message" );
@@ -473,7 +473,7 @@ class SnapProcessor {
473
473
}
474
474
475
475
bool writeTimedMessage () {
476
- ESP_LOGD (TAG, " start " );
476
+ ESP_LOGD (TAG, " >>> writeTimedMessage " );
477
477
uint32_t time_ms = millis () - last_time_sync;
478
478
if (time_ms >= 1000 ) {
479
479
last_time_sync = millis ();
@@ -485,7 +485,7 @@ class SnapProcessor {
485
485
}
486
486
487
487
bool writeMessage () {
488
- ESP_LOGD (TAG, " start " );
488
+ ESP_LOGD (TAG, " >>> writeMessage " );
489
489
490
490
now = snap_time.time ();
491
491
0 commit comments