Introduce pending data for connection type

Introduce .has_pending_data and .process_pending_data for connection
type, and hide tlsHasPendingData() and tlsProcessPendingData(). Also
set .has_pending_data and .process_pending_data as NULL explicitly in
socket.c.

Signed-off-by: zhenwei pi <pizhenwei@bytedance.com>

1 files changed, 10 insertions, 2 deletions

diff --git a/src/connection.h b/src/connection.h
index b3eb6cc20..dac4dc3ea 100644
--- a/src/connection.h
+++ b/src/connection.h
@@ -91,6 +91,10 @@ typedef struct ConnectionType {
     ssize_t (*sync_write)(struct connection *conn, char *ptr, ssize_t size, long long timeout);
     ssize_t (*sync_read)(struct connection *conn, char *ptr, ssize_t size, long long timeout);
     ssize_t (*sync_readline)(struct connection *conn, char *ptr, ssize_t size, long long timeout);
+
+    /* pending data */
+    int (*has_pending_data)(void);
+    int (*process_pending_data)(void);
 } ConnectionType;
 
 struct connection {
@@ -332,8 +336,6 @@ int connRecvTimeout(connection *conn, long long ms);
 
 /* Helpers for tls special considerations */
 sds connTLSGetPeerCert(connection *conn);
-int tlsHasPendingData();
-int tlsProcessPendingData();
 
 /* Initialize the redis connection framework */
 int connTypeInitialize();
@@ -352,6 +354,12 @@ void connTypeCleanup(int type);
 /* Walk all the connection type, and cleanup them all if possible */
 void connTypeCleanupAll();
 
+/* Test all the connection type has pending data or not. */
+int connTypeHasPendingData(void);
+
+/* walk all the connection types and process pending data for each connection type */
+int connTypeProcessPendingData(void);
+
 int RedisRegisterConnectionTypeSocket();
 int RedisRegisterConnectionTypeTLS();