/**
* raw_socket_read - Read data from a socket - Implements Connection::conn_read()
*/
-int raw_socket_read(struct Connection *conn, char *buf, size_t len)
+int raw_socket_read(struct Connection *conn, char *buf, size_t count)
{
int rc;
mutt_sig_allow_interrupt(1);
- rc = read(conn->fd, buf, len);
+ rc = read(conn->fd, buf, count);
if (rc == -1)
{
mutt_error(_("Error talking to %s (%s)"), conn->account.host, strerror(errno));
int (*conn_open) (struct Connection *conn);
/**
* conn_read - Read from a socket Connection
- * @param conn Connection to a server
- * @param buf Buffer to store the data
- * @param len Number of bytes to read
+ * @param conn Connection to a server
+ * @param buf Buffer to store the data
+ * @param count Number of bytes to read
* @retval >0 Success, number of bytes read
* @retval -1 Error, see errno
*/
- int (*conn_read) (struct Connection *conn, char *buf, size_t len);
+ int (*conn_read) (struct Connection *conn, char *buf, size_t count);
/**
* conn_write - Write to a socket Connection
- * @param conn Connection to a server
- * @param buf Buffer to read into
- * @param len Number of bytes to read
+ * @param conn Connection to a server
+ * @param buf Buffer to read into
+ * @param count Number of bytes to read
* @retval >0 Success, number of bytes written
* @retval -1 Error, see errno
*/
}
/**
- * mutt_sasl_conn_open - empty wrapper for underlying open function
- * @param conn Connection to the server
- * @retval 0 Success
- * @retval -1 Error
+ * mutt_sasl_conn_open - empty wrapper for underlying open function - Implements Connection::conn_open()
*
* We don't know in advance that a connection will use SASL, so we replace
* conn's methods with sasl methods when authentication is successful, using
}
/**
- * mutt_sasl_conn_close - close SASL connection
- * @param conn Connection to a server
- * @retval 0 Success
- * @retval -1 Error
+ * mutt_sasl_conn_close - close SASL connection - Implements Connection::conn_close()
*
* Calls underlying close function and disposes of the sasl_conn_t object, then
* restores connection to pre-sasl state
}
/**
- * mutt_sasl_conn_read - Read data from an SASL connection
- * @param conn Connection to a server
- * @param buf Buffer to store the data
- * @param buflen Number of bytes to read
- * @retval >0 Success, number of bytes read
- * @retval -1 Error, see errno
+ * mutt_sasl_conn_read - Read data from an SASL connection - Implements Connection::conn_read()
*/
-static int mutt_sasl_conn_read(struct Connection *conn, char *buf, size_t buflen)
+static int mutt_sasl_conn_read(struct Connection *conn, char *buf, size_t count)
{
int rc;
unsigned int olen;
/* if we still have data in our read buffer, copy it into buf */
if (sasldata->blen > sasldata->bpos)
{
- olen = (sasldata->blen - sasldata->bpos > buflen) ?
- buflen :
+ olen = (sasldata->blen - sasldata->bpos > count) ?
+ count :
sasldata->blen - sasldata->bpos;
memcpy(buf, sasldata->buf + sasldata->bpos, olen);
do
{
/* call the underlying read function to fill the buffer */
- rc = (sasldata->msasl_read)(conn, buf, buflen);
+ rc = (sasldata->msasl_read)(conn, buf, count);
if (rc <= 0)
goto out;
}
} while (sasldata->blen == 0);
- olen = (sasldata->blen - sasldata->bpos > buflen) ?
- buflen :
+ olen = (sasldata->blen - sasldata->bpos > count) ?
+ count :
sasldata->blen - sasldata->bpos;
memcpy(buf, sasldata->buf, olen);
rc = olen;
}
else
- rc = (sasldata->msasl_read)(conn, buf, buflen);
+ rc = (sasldata->msasl_read)(conn, buf, count);
out:
conn->sockdata = sasldata;
}
/**
- * mutt_sasl_conn_write - Write to an SASL connection
- * @param conn Connection to a server
- * @param buf Buffer to store the data
- * @param buflen Number of bytes to read
- * @retval >0 Success, number of bytes read
- * @retval -1 Error, see errno
+ * mutt_sasl_conn_write - Write to an SASL connection - Implements Connection::conn_write()
*/
-static int mutt_sasl_conn_write(struct Connection *conn, const char *buf, size_t buflen)
+static int mutt_sasl_conn_write(struct Connection *conn, const char *buf, size_t count)
{
int rc;
const char *pbuf = NULL;
/* handle data larger than MAXOUTBUF */
do
{
- olen = (buflen > *sasldata->pbufsize) ? *sasldata->pbufsize : buflen;
+ olen = (count > *sasldata->pbufsize) ? *sasldata->pbufsize : count;
rc = sasl_encode(sasldata->saslconn, buf, olen, &pbuf, &plen);
if (rc != SASL_OK)
if (rc != plen)
goto fail;
- buflen -= olen;
+ count -= olen;
buf += olen;
- } while (buflen > *sasldata->pbufsize);
+ } while (count > *sasldata->pbufsize);
}
else
{
/* just write using the underlying socket function */
- rc = (sasldata->msasl_write)(conn, buf, buflen);
+ rc = (sasldata->msasl_write)(conn, buf, count);
}
conn->sockdata = sasldata;
}
/**
- * mutt_sasl_conn_poll - Check an SASL connection for data
- * @param conn Connection to a server
- * @param wait_secs How long to wait for a response
- * @retval >0 There is data to read
- * @retval 0 Read would block
- * @retval -1 Connection doesn't support polling
+ * mutt_sasl_conn_poll - Check an SASL connection for data - Implements Connection::conn_poll()
*/
static int mutt_sasl_conn_poll(struct Connection *conn, time_t wait_secs)
{
}
/**
- * ssl_socket_open_err - Error callback for opening an SSL connection
- * @param conn Connection to a server
+ * ssl_socket_open_err - Error callback for opening an SSL connection - Implements Connection::conn_open()
* @retval -1 Always
*/
static int ssl_socket_open_err(struct Connection *conn)
}
/**
- * ssl_socket_close_and_restore - Close an SSL Connection and restore Connnection callbacks
- * @param conn Connection to a server
- * @retval 0 Success
- * @retval -1 Error, see errno
+ * ssl_socket_close_and_restore - Close an SSL Connection and restore Connnection callbacks - Implements Connection::conn_close()
*/
static int ssl_socket_close_and_restore(struct Connection *conn)
{
/**
* ssl_socket_read - Read data from an SSL socket - Implements Connection::conn_read()
*/
-static int ssl_socket_read(struct Connection *conn, char *buf, size_t len)
+static int ssl_socket_read(struct Connection *conn, char *buf, size_t count)
{
struct SslSockData *data = conn->sockdata;
int rc;
- rc = SSL_read(data->ssl, buf, len);
+ rc = SSL_read(data->ssl, buf, count);
if (rc <= 0 || errno == EINTR)
{
if (errno == EINTR)
/**
* ssl_socket_write - Write data to an SSL socket - Implements Connection::conn_write()
*/
-static int ssl_socket_write(struct Connection *conn, const char *buf, size_t len)
+static int ssl_socket_write(struct Connection *conn, const char *buf, size_t count)
{
struct SslSockData *data = conn->sockdata;
int rc;
- rc = SSL_write(data->ssl, buf, len);
+ rc = SSL_write(data->ssl, buf, count);
if (rc <= 0 || errno == EINTR)
{
if (errno == EINTR)
}
/**
- * tls_starttls_close - Close a TLS connection
- * @param conn Connection to a server
- * @retval 0 Success
- * @retval -1 Error, see errno
+ * tls_starttls_close - Close a TLS connection - Implements Connection::conn_close()
*/
static int tls_starttls_close(struct Connection *conn)
{
/**
* tls_socket_read - Read data from a TLS socket - Implements Connection::conn_read()
*/
-static int tls_socket_read(struct Connection *conn, char *buf, size_t len)
+static int tls_socket_read(struct Connection *conn, char *buf, size_t count)
{
struct TlsSockData *data = conn->sockdata;
int rc;
do
{
- rc = gnutls_record_recv(data->state, buf, len);
+ rc = gnutls_record_recv(data->state, buf, count);
if ((rc < 0 && gnutls_error_is_fatal(rc) == 1) || rc == GNUTLS_E_INTERRUPTED)
{
mutt_error("tls_socket_read (%s)", gnutls_strerror(rc));
/**
* tls_socket_write - Write data to a TLS socket - Implements Connection::conn_write()
*/
-static int tls_socket_write(struct Connection *conn, const char *buf, size_t len)
+static int tls_socket_write(struct Connection *conn, const char *buf, size_t count)
{
struct TlsSockData *data = conn->sockdata;
size_t sent = 0;
do
{
- const int ret = gnutls_record_send(data->state, buf + sent, len - sent);
+ const int ret = gnutls_record_send(data->state, buf + sent, count - sent);
if (ret < 0)
{
if (gnutls_error_is_fatal(ret) == 1 || ret == GNUTLS_E_INTERRUPTED)
return ret;
}
sent += ret;
- } while (sent < len);
+ } while (sent < count);
return sent;
}
/**
* tunnel_socket_read - Read data from a tunnel socket - Implements Connection::conn_read()
*/
-static int tunnel_socket_read(struct Connection *conn, char *buf, size_t len)
+static int tunnel_socket_read(struct Connection *conn, char *buf, size_t count)
{
struct TunnelSockData *tunnel = conn->sockdata;
int rc;
- rc = read(tunnel->readfd, buf, len);
+ rc = read(tunnel->readfd, buf, count);
if (rc == -1)
{
mutt_error(_("Tunnel error talking to %s: %s"), conn->account.host, strerror(errno));
/**
* tunnel_socket_write - Write data to a tunnel socket - Implements Connection::conn_write()
*/
-static int tunnel_socket_write(struct Connection *conn, const char *buf, size_t len)
+static int tunnel_socket_write(struct Connection *conn, const char *buf, size_t count)
{
struct TunnelSockData *tunnel = conn->sockdata;
int rc;
- rc = write(tunnel->writefd, buf, len);
+ rc = write(tunnel->writefd, buf, count);
if (rc == -1)
{
mutt_error(_("Tunnel error talking to %s: %s"), conn->account.host, strerror(errno));