Allowing read() to continue after socket close if data is still available
Only for modules that buffer the data internally
This commit is contained in:
		
							
								
								
									
										4
									
								
								.gitignore
									
									
									
									
										vendored
									
									
								
							
							
						
						
									
										4
									
								
								.gitignore
									
									
									
									
										vendored
									
									
								
							@@ -27,6 +27,4 @@ extras/docs/*
 | 
				
			|||||||
.gcc-flags.json
 | 
					.gcc-flags.json
 | 
				
			||||||
platformio.ini
 | 
					platformio.ini
 | 
				
			||||||
lib/readme.txt
 | 
					lib/readme.txt
 | 
				
			||||||
.vscode/.browse.c_cpp.db*
 | 
					\.vscode/
 | 
				
			||||||
.vscode/c_cpp_properties.json
 | 
					 | 
				
			||||||
.vscode/launch.json
 | 
					 | 
				
			||||||
 
 | 
				
			|||||||
@@ -122,7 +122,7 @@ public:
 | 
				
			|||||||
    TINY_GSM_YIELD();
 | 
					    TINY_GSM_YIELD();
 | 
				
			||||||
    at->maintain();
 | 
					    at->maintain();
 | 
				
			||||||
    size_t cnt = 0;
 | 
					    size_t cnt = 0;
 | 
				
			||||||
    while (cnt < size && sock_connected) {
 | 
					    while (cnt < size) {
 | 
				
			||||||
      size_t chunk = TinyGsmMin(size-cnt, rx.size());
 | 
					      size_t chunk = TinyGsmMin(size-cnt, rx.size());
 | 
				
			||||||
      if (chunk > 0) {
 | 
					      if (chunk > 0) {
 | 
				
			||||||
        rx.get(buf, chunk);
 | 
					        rx.get(buf, chunk);
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -122,7 +122,7 @@ public:
 | 
				
			|||||||
    TINY_GSM_YIELD();
 | 
					    TINY_GSM_YIELD();
 | 
				
			||||||
    at->maintain();
 | 
					    at->maintain();
 | 
				
			||||||
    size_t cnt = 0;
 | 
					    size_t cnt = 0;
 | 
				
			||||||
    while (cnt < size && sock_connected) {
 | 
					    while (cnt < size) {
 | 
				
			||||||
      size_t chunk = TinyGsmMin(size-cnt, rx.size());
 | 
					      size_t chunk = TinyGsmMin(size-cnt, rx.size());
 | 
				
			||||||
      if (chunk > 0) {
 | 
					      if (chunk > 0) {
 | 
				
			||||||
        rx.get(buf, chunk);
 | 
					        rx.get(buf, chunk);
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -126,7 +126,7 @@ public:
 | 
				
			|||||||
    TINY_GSM_YIELD();
 | 
					    TINY_GSM_YIELD();
 | 
				
			||||||
    at->maintain();
 | 
					    at->maintain();
 | 
				
			||||||
    size_t cnt = 0;
 | 
					    size_t cnt = 0;
 | 
				
			||||||
    while (cnt < size && sock_connected) {
 | 
					    while (cnt < size) {
 | 
				
			||||||
      size_t chunk = TinyGsmMin(size-cnt, rx.size());
 | 
					      size_t chunk = TinyGsmMin(size-cnt, rx.size());
 | 
				
			||||||
      if (chunk > 0) {
 | 
					      if (chunk > 0) {
 | 
				
			||||||
        rx.get(buf, chunk);
 | 
					        rx.get(buf, chunk);
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -135,7 +135,7 @@ public:
 | 
				
			|||||||
    TINY_GSM_YIELD();
 | 
					    TINY_GSM_YIELD();
 | 
				
			||||||
    at->maintain();
 | 
					    at->maintain();
 | 
				
			||||||
    size_t cnt = 0;
 | 
					    size_t cnt = 0;
 | 
				
			||||||
    while (cnt < size && sock_connected) {
 | 
					    while (cnt < size) {
 | 
				
			||||||
      size_t chunk = TinyGsmMin(size-cnt, rx.size());
 | 
					      size_t chunk = TinyGsmMin(size-cnt, rx.size());
 | 
				
			||||||
      if (chunk > 0) {
 | 
					      if (chunk > 0) {
 | 
				
			||||||
        rx.get(buf, chunk);
 | 
					        rx.get(buf, chunk);
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -120,7 +120,7 @@ public:
 | 
				
			|||||||
    TINY_GSM_YIELD();
 | 
					    TINY_GSM_YIELD();
 | 
				
			||||||
    at->maintain();
 | 
					    at->maintain();
 | 
				
			||||||
    size_t cnt = 0;
 | 
					    size_t cnt = 0;
 | 
				
			||||||
    while (cnt < size && sock_connected) {
 | 
					    while (cnt < size) {
 | 
				
			||||||
      size_t chunk = TinyGsmMin(size-cnt, rx.size());
 | 
					      size_t chunk = TinyGsmMin(size-cnt, rx.size());
 | 
				
			||||||
      if (chunk > 0) {
 | 
					      if (chunk > 0) {
 | 
				
			||||||
        rx.get(buf, chunk);
 | 
					        rx.get(buf, chunk);
 | 
				
			||||||
 
 | 
				
			|||||||
		Reference in New Issue
	
	Block a user