mirror of
https://github.com/tezc/sc.git
synced 2025-01-28 07:03:06 +08:00
cancelled setting buffer size of a socket
This commit is contained in:
parent
b78f0b7000
commit
27a370071b
@ -321,9 +321,6 @@ static int sc_sock_bind_unix(struct sc_sock *s, const char *host)
|
|||||||
|
|
||||||
static int sc_sock_bind(struct sc_sock *s, const char *host, const char *port)
|
static int sc_sock_bind(struct sc_sock *s, const char *host, const char *port)
|
||||||
{
|
{
|
||||||
const int bf = SC_SOCK_BUF_SIZE;
|
|
||||||
const socklen_t sz = sizeof(bf);
|
|
||||||
|
|
||||||
int rc, rv = 0;
|
int rc, rv = 0;
|
||||||
struct addrinfo *servinfo = NULL;
|
struct addrinfo *servinfo = NULL;
|
||||||
struct addrinfo hints = {
|
struct addrinfo hints = {
|
||||||
@ -341,16 +338,6 @@ static int sc_sock_bind(struct sc_sock *s, const char *host, const char *port)
|
|||||||
|
|
||||||
s->fdt.fd = fd;
|
s->fdt.fd = fd;
|
||||||
|
|
||||||
rc = setsockopt(fd, SOL_SOCKET, SO_RCVBUF, (void *) &bf, sz);
|
|
||||||
if (rc != 0) {
|
|
||||||
goto error_unix;
|
|
||||||
}
|
|
||||||
|
|
||||||
rc = setsockopt(fd, SOL_SOCKET, SO_SNDBUF, (void *) &bf, sz);
|
|
||||||
if (rc != 0) {
|
|
||||||
goto error_unix;
|
|
||||||
}
|
|
||||||
|
|
||||||
rc = sc_sock_bind_unix(s, host);
|
rc = sc_sock_bind_unix(s, host);
|
||||||
if (rc != 0) {
|
if (rc != 0) {
|
||||||
goto error_unix;
|
goto error_unix;
|
||||||
@ -407,16 +394,6 @@ error_unix:
|
|||||||
goto error;
|
goto error;
|
||||||
}
|
}
|
||||||
|
|
||||||
rc = setsockopt(fd, SOL_SOCKET, SO_RCVBUF, (void *) &bf, sz);
|
|
||||||
if (rc != 0) {
|
|
||||||
goto error;
|
|
||||||
}
|
|
||||||
|
|
||||||
rc = setsockopt(fd, SOL_SOCKET, SO_SNDBUF, (void *) &bf, sz);
|
|
||||||
if (rc != 0) {
|
|
||||||
goto error;
|
|
||||||
}
|
|
||||||
|
|
||||||
rc = bind(s->fdt.fd, p->ai_addr, (socklen_t) p->ai_addrlen);
|
rc = bind(s->fdt.fd, p->ai_addr, (socklen_t) p->ai_addrlen);
|
||||||
if (rc == -1) {
|
if (rc == -1) {
|
||||||
goto error;
|
goto error;
|
||||||
@ -451,8 +428,6 @@ int sc_sock_finish_connect(struct sc_sock *s)
|
|||||||
|
|
||||||
static int sc_sock_connect_unix(struct sc_sock *s, const char *addr)
|
static int sc_sock_connect_unix(struct sc_sock *s, const char *addr)
|
||||||
{
|
{
|
||||||
const int bf = SC_SOCK_BUF_SIZE;
|
|
||||||
const socklen_t sz = sizeof(bf);
|
|
||||||
const size_t len = strlen(addr);
|
const size_t len = strlen(addr);
|
||||||
|
|
||||||
int rc;
|
int rc;
|
||||||
@ -468,16 +443,6 @@ static int sc_sock_connect_unix(struct sc_sock *s, const char *addr)
|
|||||||
|
|
||||||
s->fdt.fd = fd;
|
s->fdt.fd = fd;
|
||||||
|
|
||||||
rc = setsockopt(s->fdt.fd, SOL_SOCKET, SO_RCVBUF, (void *) &bf, sz);
|
|
||||||
if (rc != 0) {
|
|
||||||
goto err;
|
|
||||||
}
|
|
||||||
|
|
||||||
rc = setsockopt(s->fdt.fd, SOL_SOCKET, SO_SNDBUF, (void *) &bf, sz);
|
|
||||||
if (rc != 0) {
|
|
||||||
goto err;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (len >= sizeof(un.sun_path)) {
|
if (len >= sizeof(un.sun_path)) {
|
||||||
errno = EINVAL;
|
errno = EINVAL;
|
||||||
goto err;
|
goto err;
|
||||||
@ -541,8 +506,6 @@ int sc_sock_connect(struct sc_sock *s, const char *dst_addr,
|
|||||||
const char *dst_port, const char *src_addr,
|
const char *dst_port, const char *src_addr,
|
||||||
const char *src_port)
|
const char *src_port)
|
||||||
{
|
{
|
||||||
const int bf = SC_SOCK_BUF_SIZE;
|
|
||||||
|
|
||||||
int rc, rv = 0;
|
int rc, rv = 0;
|
||||||
sc_sock_int fd;
|
sc_sock_int fd;
|
||||||
void *tmp;
|
void *tmp;
|
||||||
@ -588,18 +551,6 @@ int sc_sock_connect(struct sc_sock *s, const char *dst_addr,
|
|||||||
goto error;
|
goto error;
|
||||||
}
|
}
|
||||||
|
|
||||||
rc = setsockopt(fd, SOL_SOCKET, SO_RCVBUF, (void *) &bf,
|
|
||||||
sizeof(int));
|
|
||||||
if (rc != 0) {
|
|
||||||
goto error;
|
|
||||||
}
|
|
||||||
|
|
||||||
rc = setsockopt(fd, SOL_SOCKET, SO_SNDBUF, (void *) &bf,
|
|
||||||
sizeof(int));
|
|
||||||
if (rc != 0) {
|
|
||||||
goto error;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (src_addr || src_port) {
|
if (src_addr || src_port) {
|
||||||
rc = sc_sock_bind_src(s, src_addr, src_port);
|
rc = sc_sock_bind_src(s, src_addr, src_port);
|
||||||
if (rc != 0) {
|
if (rc != 0) {
|
||||||
@ -695,8 +646,6 @@ retry:
|
|||||||
|
|
||||||
int sc_sock_accept(struct sc_sock *s, struct sc_sock *in)
|
int sc_sock_accept(struct sc_sock *s, struct sc_sock *in)
|
||||||
{
|
{
|
||||||
const int bf = SC_SOCK_BUF_SIZE;
|
|
||||||
const socklen_t sz = sizeof(bf);
|
|
||||||
const void *tmp = (void *) &(int){1};
|
const void *tmp = (void *) &(int){1};
|
||||||
|
|
||||||
int rc;
|
int rc;
|
||||||
@ -724,16 +673,6 @@ int sc_sock_accept(struct sc_sock *s, struct sc_sock *in)
|
|||||||
goto error;
|
goto error;
|
||||||
}
|
}
|
||||||
|
|
||||||
rc = setsockopt(in->fdt.fd, SOL_SOCKET, SO_RCVBUF, (void *) &bf, sz);
|
|
||||||
if (rc != 0) {
|
|
||||||
goto error;
|
|
||||||
}
|
|
||||||
|
|
||||||
rc = setsockopt(in->fdt.fd, SOL_SOCKET, SO_SNDBUF, (void *) &bf, sz);
|
|
||||||
if (rc != 0) {
|
|
||||||
goto error;
|
|
||||||
}
|
|
||||||
|
|
||||||
return 0;
|
return 0;
|
||||||
|
|
||||||
error:
|
error:
|
||||||
|
@ -60,8 +60,6 @@ typedef SOCKET sc_sock_int;
|
|||||||
typedef int sc_sock_int;
|
typedef int sc_sock_int;
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
#define SC_SOCK_BUF_SIZE 32768
|
|
||||||
|
|
||||||
enum sc_sock_ev
|
enum sc_sock_ev
|
||||||
{
|
{
|
||||||
SC_SOCK_NONE = 0u,
|
SC_SOCK_NONE = 0u,
|
||||||
|
Loading…
x
Reference in New Issue
Block a user