connection
struct connection *conn;
struct connection *c = NULL, *oldest_c = NULL;
struct connection *newconn, *conn;
struct connection *conn;
struct connection *conn = NULL;
struct connection *conn;
struct connection *conn;
struct connection *newconn;
free_connection(struct connection *conn)
struct connection *conn = NULL;
int sock, struct connection *conn)
struct connection *newconn;
struct connection *conn;
connection = __open_cached_connection(¶ms);
if (connection == NULL) {
res = __cached_read(connection, cache_info->entry_name,
__close_cached_connection(connection);
cached_connection connection;
connection = __open_cached_connection(¶ms);
if (connection == NULL) {
__close_cached_connection(connection);
res = __cached_write(connection, cache_info->entry_name,
__close_cached_connection(connection);
cached_connection connection;
connection = __open_cached_connection(¶ms);
if (connection == NULL) {
res = __cached_write(connection, cache_info->entry_name,
__close_cached_connection(connection);
cached_connection connection;
safe_read(struct cached_connection_ *connection, void *data, size_t data_size)
nevents = _kevent(connection->read_queue, NULL, 0, &eventlist,
s_result = _read(connection->sockfd, data + result,
send_credentials(struct cached_connection_ *connection, int type)
EV_SET(&eventlist, connection->sockfd, EVFILT_WRITE, EV_ADD,
(void)_kevent(connection->write_queue, &eventlist, 1, NULL, 0, NULL);
nevents = _kevent(connection->write_queue, NULL, 0, &eventlist, 1,
result = _sendmsg(connection->sockfd, &mhdr,
EV_SET(&eventlist, connection->sockfd, EVFILT_WRITE, EV_ADD,
_kevent(connection->write_queue, &eventlist, 1, NULL, 0, NULL);
__close_cached_connection(struct cached_connection_ *connection)
assert(connection != NULL);
_close(connection->sockfd);
_close(connection->read_queue);
_close(connection->write_queue);
free(connection);
__cached_write(struct cached_connection_ *connection, const char *entry_name,
result = send_credentials(connection, CET_WRITE_REQUEST);
result = safe_write(connection, &name_size, sizeof(size_t));
result = safe_write(connection, &key_size, sizeof(size_t));
result = safe_write(connection, &data_size, sizeof(size_t));
result = safe_write(connection, entry_name, name_size);
result = safe_write(connection, key, key_size);
result = safe_write(connection, data, data_size);
result = safe_read(connection, &error_code, sizeof(int));
__cached_read(struct cached_connection_ *connection, const char *entry_name,
assert(connection != NULL);
result = send_credentials(connection, CET_READ_REQUEST);
result = safe_write(connection, &name_size, sizeof(size_t));
result = safe_write(connection, &key_size, sizeof(size_t));
result = safe_write(connection, entry_name, name_size);
result = safe_write(connection, key, key_size);
result = safe_read(connection, &rec_error_code, sizeof(int));
result = safe_read(connection, &result_size, sizeof(size_t));
result = safe_read(connection, data, result_size);
struct cached_connection_ *connection, *retval;
connection = __open_cached_connection(params);
if (connection == NULL)
connection->mp_flag = 1;
result = send_credentials(connection, CET_MP_WRITE_SESSION_REQUEST);
result = safe_write(connection, &name_size, sizeof(size_t));
result = safe_write(connection, entry_name, name_size);
result = safe_read(connection, &error_code, sizeof(int));
__close_cached_connection(connection);
retval = connection;
struct cached_connection_ *connection, *retval;
connection = __open_cached_connection(params);
if (connection == NULL)
connection->mp_flag = 1;
result = send_credentials(connection, CET_MP_READ_SESSION_REQUEST);
result = safe_write(connection, &name_size, sizeof(size_t));
result = safe_write(connection, entry_name, name_size);
result = safe_read(connection, &error_code, sizeof(int));
__close_cached_connection(connection);
retval = connection;
safe_write(struct cached_connection_ *connection, const void *data,
nevents = _kevent(connection->write_queue, NULL, 0, &eventlist,
s_result = _sendto(connection->sockfd, data + result,
connection_init(struct connection *conn, const struct connection_ops *ops,
struct pdu *pdu_new(struct connection *ic);
void text_send_request(struct connection *conn,
struct keys * text_read_response(struct connection *conn);
struct keys * text_read_request(struct connection *conn,
void connection_init(struct connection *conn,
struct connection *pdu_connection;
void (*fail)(const struct connection *, const char *);
pdu_read(const struct connection *conn, char *data, size_t len)
struct connection *conn;
struct connection *conn;
pdu_new(struct connection *conn)
text_receive_response(struct connection *conn)
text_send_request(struct connection *conn, struct keys *request_keys)
text_read_response(struct connection *conn)
text_read_request(struct connection *conn, struct pdu **requestp)
struct connection *conn = request->pdu_connection;
text_new_request(struct connection *conn, uint32_t ttt)
text_receive_request(struct connection *conn)
struct connection *conn;
phy-connection-type = "10gbase-r";
phy-connection-type = "qsgmii";
out_resp->connection = connector->status;
__u32 connection;
bit8 connection; /**< How device is connected:
pDevice->devInfo.sataDeviceInfo.connection = pm;
TI_DBG2(("ossaGetDeviceInfoCB: connection %d\n", agSATADeviceInfo->connection));
struct ngd_connection *connection = NULL;
NG_SEND_MSG_HOOK(error, sc->node, msg, connection->active_hook, 0);
tcpp_client_closeconn(struct connection *conn)
struct connection *conn;
static struct connection *
struct connection *conn;
tcpp_server_closeconn(struct connection *conn)
struct connection *conn;
static struct connection *
struct connection *conn;
logout_receive(struct connection *conn)
struct connection *conn;
static void pdu_fail(const struct connection *conn, const char *reason);
struct connection *conn;
pdu_fail(const struct connection *conn __unused, const char *reason __unused)
struct connection conn;
struct connection *conn;
login_receive(struct connection *conn, bool initial)
struct connection *conn;
login_receive_chap_a(struct connection *conn)
login_receive_chap_r(struct connection *conn, struct auth_group *ag,
logout_receive(struct connection *conn)
logout_new_request(struct connection *conn)
resolve_addr(const struct connection *conn, const char *address,
fail(const struct connection *base_conn, const char *reason)
struct connection conn;
void fail(const struct connection *, const char *);
login_receive(struct connection *conn)
login_new_request(struct connection *conn, int csg)
login_send_chap_a(struct connection *conn)
nscd_connection connection;
connection = open_nscd_connection__(&connection_params);
if (connection == INVALID_NSCD_CONNECTION)
result = nscd_transform__(connection,
result = nscd_transform__(connection,
close_nscd_connection__(connection);
nevents = kevent(connection->read_queue, NULL, 0, &eventlist, 1,
s_result = read(connection->sockfd,
send_credentials(struct nscd_connection_ *connection, int type)
EV_SET(&eventlist, connection->sockfd, EVFILT_WRITE, EV_ADD,
kevent(connection->write_queue, &eventlist, 1, NULL, 0, NULL);
nevents = kevent(connection->write_queue, NULL, 0, &eventlist, 1, NULL);
result = sendmsg(connection->sockfd, &mhdr, 0) == -1 ? -1 : 0;
EV_SET(&eventlist, connection->sockfd, EVFILT_WRITE, EV_ADD,
kevent(connection->write_queue, &eventlist, 1, NULL, 0, NULL);
close_nscd_connection__(struct nscd_connection_ *connection)
assert(connection != NULL);
close(connection->sockfd);
close(connection->read_queue);
close(connection->write_queue);
free(connection);
nscd_transform__(struct nscd_connection_ *connection,
result = send_credentials(connection, CET_TRANSFORM_REQUEST);
result = safe_write(connection, &name_size, sizeof(size_t));
result = safe_write(connection, &transformation_type, sizeof(int));
result = safe_write(connection, entry_name, name_size);
result = safe_read(connection, &error_code, sizeof(int));
safe_write(struct nscd_connection_ *connection, const void *data,
nevents = kevent(connection->write_queue, NULL, 0, &eventlist,
s_result = write(connection->sockfd,
safe_read(struct nscd_connection_ *connection, void *data, size_t data_size)