*/
static void kdc_tcp_recv_handler(struct stream_connection *conn, uint16_t flags)
{
- struct kdc_tcp_connection *kdcconn = talloc_get_type(conn->private,
+ struct kdc_tcp_connection *kdcconn = talloc_get_type(conn->private_data,
struct kdc_tcp_connection);
packet_recv(kdcconn->packet);
}
*/
static void kdc_tcp_send(struct stream_connection *conn, uint16_t flags)
{
- struct kdc_tcp_connection *kdcconn = talloc_get_type(conn->private,
+ struct kdc_tcp_connection *kdcconn = talloc_get_type(conn->private_data,
struct kdc_tcp_connection);
packet_queue_run(kdcconn->packet);
}
*/
static void kdc_tcp_generic_accept(struct stream_connection *conn, kdc_process_fn_t process_fn)
{
- struct kdc_server *kdc = talloc_get_type(conn->private, struct kdc_server);
+ struct kdc_server *kdc = talloc_get_type(conn->private_data, struct kdc_server);
struct kdc_tcp_connection *kdcconn;
kdcconn = talloc_zero(conn, struct kdc_tcp_connection);
kdcconn->conn = conn;
kdcconn->kdc = kdc;
kdcconn->process = process_fn;
- conn->private = kdcconn;
+ conn->private_data = kdcconn;
kdcconn->packet = packet_init(kdcconn);
if (kdcconn->packet == NULL) {
void ldapsrv_recv(struct stream_connection *c, uint16_t flags)
{
struct ldapsrv_connection *conn =
- talloc_get_type(c->private, struct ldapsrv_connection);
+ talloc_get_type(c->private_data, struct ldapsrv_connection);
if (conn->limits.ite) { /* clean initial timeout if any */
talloc_free(conn->limits.ite);
static void ldapsrv_send(struct stream_connection *c, uint16_t flags)
{
struct ldapsrv_connection *conn =
- talloc_get_type(c->private, struct ldapsrv_connection);
+ talloc_get_type(c->private_data, struct ldapsrv_connection);
packet_queue_run(conn->packet);
}
static void ldapsrv_accept(struct stream_connection *c)
{
struct ldapsrv_service *ldapsrv_service =
- talloc_get_type(c->private, struct ldapsrv_service);
+ talloc_get_type(c->private_data, struct ldapsrv_service);
struct ldapsrv_connection *conn;
struct cli_credentials *server_credentials;
struct socket_address *socket_address;
conn->sockets.raw = c->socket;
conn->lp_ctx = ldapsrv_service->task->lp_ctx;
- c->private = conn;
+ c->private_data = conn;
socket_address = socket_get_my_addr(c->socket, conn);
if (!socket_address) {
*/
static void ntp_signd_recv_handler(struct stream_connection *conn, uint16_t flags)
{
- struct ntp_signd_connection *ntp_signdconn = talloc_get_type(conn->private,
+ struct ntp_signd_connection *ntp_signdconn = talloc_get_type(conn->private_data,
struct ntp_signd_connection);
packet_recv(ntp_signdconn->packet);
}
*/
static void ntp_signd_send(struct stream_connection *conn, uint16_t flags)
{
- struct ntp_signd_connection *ntp_signdconn = talloc_get_type(conn->private,
+ struct ntp_signd_connection *ntp_signdconn = talloc_get_type(conn->private_data,
struct ntp_signd_connection);
packet_queue_run(ntp_signdconn->packet);
}
*/
static void ntp_signd_accept(struct stream_connection *conn)
{
- struct ntp_signd_server *ntp_signd = talloc_get_type(conn->private, struct ntp_signd_server);
+ struct ntp_signd_server *ntp_signd = talloc_get_type(conn->private_data, struct ntp_signd_server);
struct ntp_signd_connection *ntp_signdconn;
ntp_signdconn = talloc_zero(conn, struct ntp_signd_connection);
}
ntp_signdconn->conn = conn;
ntp_signdconn->ntp_signd = ntp_signd;
- conn->private = ntp_signdconn;
+ conn->private_data = ntp_signdconn;
ntp_signdconn->packet = packet_init(ntp_signdconn);
if (ntp_signdconn->packet == NULL) {
{
NTSTATUS status;
struct dcesrv_socket_context *dcesrv_sock =
- talloc_get_type(srv_conn->private, struct dcesrv_socket_context);
+ talloc_get_type(srv_conn->private_data, struct dcesrv_socket_context);
struct dcesrv_connection *dcesrv_conn = NULL;
if (!srv_conn->session_info) {
dcesrv_conn->auth_state.session_key = dcesrv_inherited_session_key;
}
- srv_conn->private = dcesrv_conn;
+ srv_conn->private_data = dcesrv_conn;
irpc_add_name(srv_conn->msg_ctx, "rpc_server");
static void dcesrv_sock_recv(struct stream_connection *conn, uint16_t flags)
{
NTSTATUS status;
- struct dcesrv_connection *dce_conn = talloc_get_type(conn->private, struct dcesrv_connection);
+ struct dcesrv_connection *dce_conn = talloc_get_type(conn->private_data, struct dcesrv_connection);
DATA_BLOB tmp_blob;
size_t nread;
static void dcesrv_sock_send(struct stream_connection *conn, uint16_t flags)
{
- struct dcesrv_connection *dce_conn = talloc_get_type(conn->private, struct dcesrv_connection);
+ struct dcesrv_connection *dce_conn = talloc_get_type(conn->private_data, struct dcesrv_connection);
NTSTATUS status;
status = dcesrv_output(dce_conn, conn->socket, dcerpc_write_fn);
*/
static void smbsrv_recv(struct stream_connection *conn, uint16_t flags)
{
- struct smbsrv_connection *smb_conn = talloc_get_type(conn->private,
+ struct smbsrv_connection *smb_conn = talloc_get_type(conn->private_data,
struct smbsrv_connection);
DEBUG(10,("smbsrv_recv\n"));
*/
static void smbsrv_send(struct stream_connection *conn, uint16_t flags)
{
- struct smbsrv_connection *smb_conn = talloc_get_type(conn->private,
+ struct smbsrv_connection *smb_conn = talloc_get_type(conn->private_data,
struct smbsrv_connection);
packet_queue_run(smb_conn->packet);
}
smb_conn->lp_ctx = conn->lp_ctx;
smb_conn->connection = conn;
- conn->private = smb_conn;
+ conn->private_data = smb_conn;
smb_conn->statistics.connect_time = timeval_current();
/*
* remove the named_pipe layer together with its packet layer
*/
- conn->ops = pipe_conn->pipe_sock->ops;
- conn->private = pipe_conn->pipe_sock->private_data;
+ conn->ops = pipe_conn->pipe_sock->ops;
+ conn->private_data = pipe_conn->pipe_sock->private_data;
talloc_free(pipe_conn);
/* we're now ready to start receiving events on this stream */
static void named_pipe_recv(struct stream_connection *conn, uint16_t flags)
{
struct named_pipe_connection *pipe_conn = talloc_get_type(
- conn->private, struct named_pipe_connection);
+ conn->private_data, struct named_pipe_connection);
DEBUG(10,("named_pipe_recv\n"));
static void named_pipe_send(struct stream_connection *conn, uint16_t flags)
{
struct named_pipe_connection *pipe_conn = talloc_get_type(
- conn->private, struct named_pipe_connection);
+ conn->private_data, struct named_pipe_connection);
packet_queue_run(pipe_conn->packet);
}
static void named_pipe_accept(struct stream_connection *conn)
{
struct named_pipe_socket *pipe_sock = talloc_get_type(
- conn->private, struct named_pipe_socket);
+ conn->private_data, struct named_pipe_socket);
struct named_pipe_connection *pipe_conn;
DEBUG(5,("named_pipe_accept\n"));
pipe_conn->pipe_sock = pipe_sock;
pipe_conn->connection = conn;
- conn->private = pipe_conn;
+ conn->private_data = pipe_conn;
}
static const struct stream_server_ops named_pipe_stream_ops = {
talloc_steal(srv_conn, sock);
- srv_conn->private = private_data;
+ srv_conn->private_data = private_data;
srv_conn->model_ops = model_ops;
srv_conn->socket = sock;
srv_conn->server_id = cluster_id(0, 0);
talloc_steal(srv_conn, sock);
- srv_conn->private = stream_socket->private_data;
+ srv_conn->private_data = stream_socket->private_data;
srv_conn->model_ops = stream_socket->model_ops;
srv_conn->socket = sock;
srv_conn->server_id = server_id;
const struct stream_server_ops *ops;
const struct model_ops *model_ops;
struct server_id server_id;
- void *private;
+ void *private_data;
struct {
struct tevent_context *ctx;
static void websrv_recv(struct stream_connection *conn, uint16_t flags)
{
struct web_server_data *wdata;
- struct websrv_context *web = talloc_get_type(conn->private,
+ struct websrv_context *web = talloc_get_type(conn->private_data,
struct websrv_context);
NTSTATUS status;
uint8_t buf[1024];
*/
static void websrv_send(struct stream_connection *conn, uint16_t flags)
{
- struct websrv_context *web = talloc_get_type(conn->private,
+ struct websrv_context *web = talloc_get_type(conn->private_data,
struct websrv_context);
NTSTATUS status;
size_t nsent;
*/
static void websrv_accept(struct stream_connection *conn)
{
- struct task_server *task = talloc_get_type(conn->private, struct task_server);
+ struct task_server *task = talloc_get_type(conn->private_data, struct task_server);
struct web_server_data *wdata = talloc_get_type(task->private_data, struct web_server_data);
struct websrv_context *web;
struct socket_context *tls_socket;
web->task = task;
web->conn = conn;
- conn->private = web;
+ conn->private_data = web;
talloc_set_destructor(web, websrv_destructor);
event_add_timed(conn->event.ctx, web,
static void wbsrv_accept(struct stream_connection *conn)
{
- struct wbsrv_listen_socket *listen_socket = talloc_get_type(conn->private,
+ struct wbsrv_listen_socket *listen_socket = talloc_get_type(conn->private_data,
struct wbsrv_listen_socket);
struct wbsrv_connection *wbconn;
wbconn->conn = conn;
wbconn->listen_socket = listen_socket;
wbconn->lp_ctx = listen_socket->service->task->lp_ctx;
- conn->private = wbconn;
+ conn->private_data = wbconn;
wbconn->packet = packet_init(wbconn);
if (wbconn->packet == NULL) {
*/
static void wbsrv_recv(struct stream_connection *conn, uint16_t flags)
{
- struct wbsrv_connection *wbconn = talloc_get_type(conn->private,
+ struct wbsrv_connection *wbconn = talloc_get_type(conn->private_data,
struct wbsrv_connection);
packet_recv(wbconn->packet);
*/
static void wbsrv_send(struct stream_connection *conn, uint16_t flags)
{
- struct wbsrv_connection *wbconn = talloc_get_type(conn->private,
+ struct wbsrv_connection *wbconn = talloc_get_type(conn->private_data,
struct wbsrv_connection);
packet_queue_run(wbconn->packet);
}
*/
static void wreplsrv_recv(struct stream_connection *conn, uint16_t flags)
{
- struct wreplsrv_in_connection *wreplconn = talloc_get_type(conn->private,
+ struct wreplsrv_in_connection *wreplconn = talloc_get_type(conn->private_data,
struct wreplsrv_in_connection);
packet_recv(wreplconn->packet);
*/
static void wreplsrv_send(struct stream_connection *conn, uint16_t flags)
{
- struct wreplsrv_in_connection *wreplconn = talloc_get_type(conn->private,
+ struct wreplsrv_in_connection *wreplconn = talloc_get_type(conn->private_data,
struct wreplsrv_in_connection);
packet_queue_run(wreplconn->packet);
}
*/
static void wreplsrv_accept(struct stream_connection *conn)
{
- struct wreplsrv_service *service = talloc_get_type(conn->private, struct wreplsrv_service);
+ struct wreplsrv_service *service = talloc_get_type(conn->private_data, struct wreplsrv_service);
struct wreplsrv_in_connection *wreplconn;
struct socket_address *peer_ip;
wreplconn->partner = wreplsrv_find_partner(service, peer_ip->addr);
- conn->private = wreplconn;
+ conn->private_data = wreplconn;
irpc_add_name(conn->msg_ctx, "wreplsrv_connection");
}