commit 4779412135de0245a461ec7037c400b5eb6daa75
Author: Oswald Buddenhagen <o...@users.sf.net>
Date: Sat Nov 16 17:14:57 2019 +0100
rename socket_expect_read() => socket_expect_activity()
... to better reflect its (mostly new) function.
src/drv_imap.c | 16 ++++++++--------
src/socket.c | 10 +++++-----
src/socket.h | 2 +-
3 files changed, 14 insertions(+), 14 deletions(-)
diff --git a/src/drv_imap.c b/src/drv_imap.c
index 18c42fa..d1bad29 100644
--- a/src/drv_imap.c
+++ b/src/drv_imap.c
@@ -348,7 +348,7 @@ DIAG_POP
*ctx->in_progress_append = cmd;
ctx->in_progress_append = &cmd->next;
ctx->num_in_progress++;
- socket_expect_read( &ctx->conn, 1 );
+ socket_expect_activity( &ctx->conn, 1 );
}
static int
@@ -412,7 +412,7 @@ cancel_sent_imap_cmds( imap_store_t *ctx )
{
imap_cmd_t *cmd;
- socket_expect_read( &ctx->conn, 0 );
+ socket_expect_activity( &ctx->conn, 0 );
while ((cmd = ctx->in_progress)) {
ctx->in_progress = cmd->next;
/* don't update num_in_progress and in_progress_append - store
is dead */
@@ -1469,7 +1469,7 @@ imap_socket_read( void *aux )
error( "IMAP error: unexpected reply: %s %s\n", arg,
cmd ? cmd : "" );
break; /* this may mean anything, so prefer not to spam
the log */
} else if (*arg == '+') {
- socket_expect_read( &ctx->conn, 0 );
+ socket_expect_activity( &ctx->conn, 0 );
/* There can be any number of commands in flight, but
only the last
* one can require a continuation, as it enforces a
round-trip. */
cmdp = (imap_cmd_t *)((char *)ctx->in_progress_append -
@@ -1499,7 +1499,7 @@ imap_socket_read( void *aux )
error( "IMAP error: unexpected command
continuation request\n" );
break;
}
- socket_expect_read( &ctx->conn, 1 );
+ socket_expect_activity( &ctx->conn, 1 );
} else {
tag = atoi( arg );
for (pcmdp = &ctx->in_progress; (cmdp = *pcmdp); pcmdp
= &cmdp->next)
@@ -1511,7 +1511,7 @@ imap_socket_read( void *aux )
if (!(*pcmdp = cmdp->next))
ctx->in_progress_append = pcmdp;
if (!--ctx->num_in_progress)
- socket_expect_read( &ctx->conn, 0 );
+ socket_expect_activity( &ctx->conn, 0 );
arg = next_arg( &cmd );
if (!arg) {
error( "IMAP error: malformed tagged
response\n" );
@@ -1801,7 +1801,7 @@ imap_open_store_connected( int ok, void *aux )
socket_start_tls( &ctx->conn, imap_open_store_tlsstarted1 );
#endif
else
- socket_expect_read( &ctx->conn, 1 );
+ socket_expect_activity( &ctx->conn, 1 );
}
#ifdef HAVE_LIBSSL
@@ -1813,14 +1813,14 @@ imap_open_store_tlsstarted1( int ok, void *aux )
if (!ok)
imap_open_store_ssl_bail( ctx );
else
- socket_expect_read( &ctx->conn, 1 );
+ socket_expect_activity( &ctx->conn, 1 );
}
#endif
static void
imap_open_store_greeted( imap_store_t *ctx )
{
- socket_expect_read( &ctx->conn, 0 );
+ socket_expect_activity( &ctx->conn, 0 );
if (!ctx->caps)
imap_exec( ctx, NULL, imap_open_store_p2, "CAPABILITY" );
else
diff --git a/src/socket.c b/src/socket.c
index d97e79a..c5cf10d 100644
--- a/src/socket.c
+++ b/src/socket.c
@@ -332,7 +332,7 @@ socket_start_tls( conn_t *conn, void (*cb)( int ok, void
*aux ) )
return;
}
SSL_set_mode( conn->ssl, SSL_MODE_ACCEPT_MOVING_WRITE_BUFFER );
- socket_expect_read( conn, 1 );
+ socket_expect_activity( conn, 1 );
start_tls_p2( conn );
}
@@ -351,7 +351,7 @@ start_tls_p2( conn_t *conn )
static void start_tls_p3( conn_t *conn, int ok )
{
- socket_expect_read( conn, 0 );
+ socket_expect_activity( conn, 0 );
conn->state = SCK_READY;
conn->callbacks.starttls( ok, conn->callback_aux );
}
@@ -567,7 +567,7 @@ socket_connect_one( conn_t *sock )
return;
}
conf_notifier( &sock->notify, 0, POLLOUT );
- socket_expect_read( sock, 1 );
+ socket_expect_activity( sock, 1 );
sock->state = SCK_CONNECTING;
info( "\v\n" );
return;
@@ -607,7 +607,7 @@ socket_connected( conn_t *conn )
}
#endif
conf_notifier( &conn->notify, 0, POLLIN );
- socket_expect_read( conn, 0 );
+ socket_expect_activity( conn, 0 );
conn->state = SCK_READY;
conn->callbacks.connect( 1, conn->callback_aux );
}
@@ -771,7 +771,7 @@ socket_fill( conn_t *sock )
}
void
-socket_expect_read( conn_t *conn, int expect )
+socket_expect_activity( conn_t *conn, int expect )
{
if (conn->conf->timeout > 0 && expect != pending_wakeup(
&conn->fd_timeout ))
conf_wakeup( &conn->fd_timeout, expect ? conn->conf->timeout :
-1 );
diff --git a/src/socket.h b/src/socket.h
index c4df81e..e7cca05 100644
--- a/src/socket.h
+++ b/src/socket.h
@@ -139,7 +139,7 @@ void socket_connect( conn_t *conn, void (*cb)( int ok, void
*aux ) );
void socket_start_tls(conn_t *conn, void (*cb)( int ok, void *aux ) );
void socket_start_deflate( conn_t *conn );
void socket_close( conn_t *sock );
-void socket_expect_read( conn_t *sock, int expect );
+void socket_expect_activity( conn_t *sock, int expect );
int socket_read( conn_t *sock, char *buf, uint len ); /* never waits */
char *socket_read_line( conn_t *sock ); /* don't free return value; never
waits */
typedef enum { KeepOwn = 0, GiveOwn } ownership_t;
_______________________________________________
isync-devel mailing list
isync-devel@lists.sourceforge.net
https://lists.sourceforge.net/lists/listinfo/isync-devel
