static void dreplsrv_out_drsuapi_bind_recv(struct rpc_request *req)
{
- struct dreplsrv_out_drsuapi_state *st = talloc_get_type(req->async.private,
+ struct dreplsrv_out_drsuapi_state *st = talloc_get_type(req->async.private_data,
struct dreplsrv_out_drsuapi_state);
struct composite_context *c = st->creq;
static void dreplsrv_op_pull_source_get_changes_recv(struct rpc_request *req)
{
- struct dreplsrv_op_pull_source_state *st = talloc_get_type(req->async.private,
+ struct dreplsrv_op_pull_source_state *st = talloc_get_type(req->async.private_data,
struct dreplsrv_op_pull_source_state);
struct composite_context *c = st->creq;
struct drsuapi_DsGetNCChanges *r = talloc_get_type(req->ndr.struct_ptr,
{
if (composite_nomem(new_req, ctx)) return;
new_req->async.callback = continuation;
- new_req->async.private = private_data;
+ new_req->async.private_data = private_data;
}
_PUBLIC_ void composite_continue_irpc(struct composite_context *ctx,
static void becomeDC_drsuapi1_bind_recv(struct rpc_request *req)
{
- struct libnet_BecomeDC_state *s = talloc_get_type(req->async.private,
+ struct libnet_BecomeDC_state *s = talloc_get_type(req->async.private_data,
struct libnet_BecomeDC_state);
struct composite_context *c = s->creq;
WERROR status;
static void becomeDC_drsuapi1_add_entry_recv(struct rpc_request *req)
{
- struct libnet_BecomeDC_state *s = talloc_get_type(req->async.private,
+ struct libnet_BecomeDC_state *s = talloc_get_type(req->async.private_data,
struct libnet_BecomeDC_state);
struct composite_context *c = s->creq;
struct drsuapi_DsAddEntry *r = talloc_get_type(req->ndr.struct_ptr,
static void becomeDC_drsuapi2_bind_recv(struct rpc_request *req)
{
- struct libnet_BecomeDC_state *s = talloc_get_type(req->async.private,
+ struct libnet_BecomeDC_state *s = talloc_get_type(req->async.private_data,
struct libnet_BecomeDC_state);
struct composite_context *c = s->creq;
char *binding_str;
static void becomeDC_drsuapi3_pull_schema_recv(struct rpc_request *req)
{
- struct libnet_BecomeDC_state *s = talloc_get_type(req->async.private,
+ struct libnet_BecomeDC_state *s = talloc_get_type(req->async.private_data,
struct libnet_BecomeDC_state);
struct composite_context *c = s->creq;
struct drsuapi_DsGetNCChanges *r = talloc_get_type(req->ndr.struct_ptr,
static void becomeDC_drsuapi3_pull_config_recv(struct rpc_request *req)
{
- struct libnet_BecomeDC_state *s = talloc_get_type(req->async.private,
+ struct libnet_BecomeDC_state *s = talloc_get_type(req->async.private_data,
struct libnet_BecomeDC_state);
struct composite_context *c = s->creq;
struct drsuapi_DsGetNCChanges *r = talloc_get_type(req->ndr.struct_ptr,
static void becomeDC_drsuapi3_pull_domain_recv(struct rpc_request *req)
{
- struct libnet_BecomeDC_state *s = talloc_get_type(req->async.private,
+ struct libnet_BecomeDC_state *s = talloc_get_type(req->async.private_data,
struct libnet_BecomeDC_state);
struct composite_context *c = s->creq;
struct drsuapi_DsGetNCChanges *r = talloc_get_type(req->ndr.struct_ptr,
static void becomeDC_drsuapi2_update_refs_schema_recv(struct rpc_request *req)
{
- struct libnet_BecomeDC_state *s = talloc_get_type(req->async.private,
+ struct libnet_BecomeDC_state *s = talloc_get_type(req->async.private_data,
struct libnet_BecomeDC_state);
struct composite_context *c = s->creq;
struct drsuapi_DsReplicaUpdateRefs *r = talloc_get_type(req->ndr.struct_ptr,
static void becomeDC_drsuapi2_update_refs_config_recv(struct rpc_request *req)
{
- struct libnet_BecomeDC_state *s = talloc_get_type(req->async.private,
+ struct libnet_BecomeDC_state *s = talloc_get_type(req->async.private_data,
struct libnet_BecomeDC_state);
struct composite_context *c = s->creq;
struct drsuapi_DsReplicaUpdateRefs *r = talloc_get_type(req->ndr.struct_ptr,
static void becomeDC_drsuapi2_update_refs_domain_recv(struct rpc_request *req)
{
- struct libnet_BecomeDC_state *s = talloc_get_type(req->async.private,
+ struct libnet_BecomeDC_state *s = talloc_get_type(req->async.private_data,
struct libnet_BecomeDC_state);
struct composite_context *c = s->creq;
struct drsuapi_DsReplicaUpdateRefs *r = talloc_get_type(req->ndr.struct_ptr,
struct domain_open_samr_state *s;
struct rpc_request *conn_req;
- c = talloc_get_type(req->async.private, struct composite_context);
+ c = talloc_get_type(req->async.private_data, struct composite_context);
s = talloc_get_type(c->private_data, struct domain_open_samr_state);
/* receive samr_Close reply */
struct rpc_request *lookup_req;
struct samr_LookupDomain *r;
- c = talloc_get_type(req->async.private, struct composite_context);
+ c = talloc_get_type(req->async.private_data, struct composite_context);
s = talloc_get_type(c->private_data, struct domain_open_samr_state);
/* receive samr_Connect reply */
struct rpc_request *opendom_req;
struct samr_OpenDomain *r;
- c = talloc_get_type(req->async.private, struct composite_context);
+ c = talloc_get_type(req->async.private_data, struct composite_context);
s = talloc_get_type(c->private_data, struct domain_open_samr_state);
/* receive samr_LookupDomain reply */
struct composite_context *c;
struct domain_open_samr_state *s;
- c = talloc_get_type(req->async.private, struct composite_context);
+ c = talloc_get_type(req->async.private_data, struct composite_context);
s = talloc_get_type(c->private_data, struct domain_open_samr_state);
/* receive samr_OpenDomain reply */
struct composite_context *c;
struct domain_open_lsa_state *s;
- c = talloc_get_type(req->async.private, struct composite_context);
+ c = talloc_get_type(req->async.private_data, struct composite_context);
s = talloc_get_type(c->private_data, struct domain_open_lsa_state);
c->status = dcerpc_ndr_request_recv(req);
struct composite_context *c;
struct domain_close_lsa_state *s;
- c = talloc_get_type(req->async.private, struct composite_context);
+ c = talloc_get_type(req->async.private_data, struct composite_context);
s = talloc_get_type(c->private_data, struct domain_close_lsa_state);
c->status = dcerpc_ndr_request_recv(req);
struct composite_context *c;
struct domain_close_samr_state *s;
- c = talloc_get_type(req->async.private, struct composite_context);
+ c = talloc_get_type(req->async.private_data, struct composite_context);
s = talloc_get_type(c->private_data, struct domain_close_samr_state);
c->status = dcerpc_ndr_request_recv(req);
struct domain_list_state *s;
struct rpc_request *enumdom_req;
- c = talloc_get_type(req->async.private, struct composite_context);
+ c = talloc_get_type(req->async.private_data, struct composite_context);
s = talloc_get_type(c->private_data, struct domain_list_state);
c->status = dcerpc_ndr_request_recv(req);
struct rpc_request *enumdom_req;
struct rpc_request *samrclose_req;
- c = talloc_get_type(req->async.private, struct composite_context);
+ c = talloc_get_type(req->async.private_data, struct composite_context);
s = talloc_get_type(c->private_data, struct domain_list_state);
c->status = dcerpc_ndr_request_recv(req);
struct composite_context *c;
struct domain_list_state *s;
- c = talloc_get_type(req->async.private, struct composite_context);
+ c = talloc_get_type(req->async.private_data, struct composite_context);
s = talloc_get_type(c->private_data, struct domain_list_state);
c->status = dcerpc_ndr_request_recv(req);
struct composite_context *c;
struct lookup_name_state *s;
- c = talloc_get_type(req->async.private, struct composite_context);
+ c = talloc_get_type(req->async.private_data, struct composite_context);
s = talloc_get_type(c->private_data, struct lookup_name_state);
c->status = dcerpc_ndr_request_recv(req);
struct rpc_connect_dci_state *s;
struct rpc_request *query_info_req;
- c = talloc_get_type(req->async.private, struct composite_context);
+ c = talloc_get_type(req->async.private_data, struct composite_context);
s = talloc_get_type(c->private_data, struct rpc_connect_dci_state);
c->status = dcerpc_ndr_request_recv(req);
struct rpc_connect_dci_state *s;
struct rpc_request *query_info_req;
- c = talloc_get_type(req->async.private, struct composite_context);
+ c = talloc_get_type(req->async.private_data, struct composite_context);
s = talloc_get_type(c->private_data, struct rpc_connect_dci_state);
c->status = dcerpc_ndr_request_recv(req);
struct composite_context *c;
struct rpc_connect_dci_state *s;
- c = talloc_get_type(req->async.private, struct composite_context);
+ c = talloc_get_type(req->async.private_data, struct composite_context);
s = talloc_get_type(c->private_data, struct rpc_connect_dci_state);
c->status = dcerpc_ndr_request_recv(req);
static void unbecomeDC_drsuapi_bind_recv(struct rpc_request *req)
{
- struct libnet_UnbecomeDC_state *s = talloc_get_type(req->async.private,
+ struct libnet_UnbecomeDC_state *s = talloc_get_type(req->async.private_data,
struct libnet_UnbecomeDC_state);
struct composite_context *c = s->creq;
static void unbecomeDC_drsuapi_remove_ds_server_recv(struct rpc_request *req)
{
- struct libnet_UnbecomeDC_state *s = talloc_get_type(req->async.private,
+ struct libnet_UnbecomeDC_state *s = talloc_get_type(req->async.private_data,
struct libnet_UnbecomeDC_state);
struct composite_context *c = s->creq;
struct drsuapi_DsRemoveDSServer *r = &s->drsuapi.rm_ds_srv_r;
struct rpc_request *enum_req;
BOOL prereq_met = False;
- c = talloc_get_type(req->async.private, struct composite_context);
+ c = talloc_get_type(req->async.private_data, struct composite_context);
s = talloc_get_type(c->private_data, struct userlist_state);
/* receive result of rpc request */
struct userlist_state *s;
int i;
- c = talloc_get_type(req->async.private, struct composite_context);
+ c = talloc_get_type(req->async.private_data, struct composite_context);
s = talloc_get_type(c->private_data, struct userlist_state);
/* receive result of rpc request */
struct monitor_msg msg;
struct msg_rpc_lookup_name *msg_lookup;
- c = talloc_get_type(req->async.private, struct composite_context);
+ c = talloc_get_type(req->async.private_data, struct composite_context);
s = talloc_get_type(c->private_data, struct userinfo_state);
/* receive samr_Lookup reply */
struct monitor_msg msg;
struct msg_rpc_open_user *msg_open;
- c = talloc_get_type(req->async.private, struct composite_context);
+ c = talloc_get_type(req->async.private_data, struct composite_context);
s = talloc_get_type(c->private_data, struct userinfo_state);
/* receive samr_OpenUser reply */
struct monitor_msg msg;
struct msg_rpc_query_user *msg_query;
- c = talloc_get_type(req->async.private, struct composite_context);
+ c = talloc_get_type(req->async.private_data, struct composite_context);
s = talloc_get_type(c->private_data, struct userinfo_state);
/* receive samr_QueryUserInfo reply */
struct monitor_msg msg;
struct msg_rpc_close_user *msg_close;
- c = talloc_get_type(req->async.private, struct composite_context);
+ c = talloc_get_type(req->async.private_data, struct composite_context);
s = talloc_get_type(c->private_data, struct userinfo_state);
/* receive samr_Close reply */
*/
static void useradd_handler(struct rpc_request *req)
{
- struct composite_context *c = req->async.private;
+ struct composite_context *c = req->async.private_data;
struct useradd_state *s = talloc_get_type(c->private_data, struct useradd_state);
struct monitor_msg msg;
struct msg_rpc_create_user *rpc_create;
/* callback handler for continuation */
s->req->async.callback = useradd_handler;
- s->req->async.private = c;
+ s->req->async.private_data = c;
s->stage = USERADD_CREATE;
return c;
/* callback handler setup */
s->req->async.callback = userdel_handler;
- s->req->async.private = c;
+ s->req->async.private_data = c;
s->stage = USERDEL_OPEN;
return NT_STATUS_OK;
/* callback handler setup */
s->req->async.callback = userdel_handler;
- s->req->async.private = c;
+ s->req->async.private_data = c;
s->stage = USERDEL_DELETE;
return NT_STATUS_OK;
struct msg_rpc_lookup_name *msg_lookup;
struct msg_rpc_open_user *msg_open;
- c = talloc_get_type(req->async.private, struct composite_context);
+ c = talloc_get_type(req->async.private_data, struct composite_context);
s = talloc_get_type(c->private_data, struct userdel_state);
switch (s->stage) {
/* callback handler setup */
s->req->async.callback = userdel_handler;
- s->req->async.private = c;
+ s->req->async.private_data = c;
s->stage = USERDEL_LOOKUP;
return c;
/* callback handler setup */
s->req->async.callback = usermod_handler;
- s->req->async.private = c;
+ s->req->async.private_data = c;
s->stage = USERMOD_OPEN;
return NT_STATUS_OK;
/* callback handler setup */
s->req->async.callback = usermod_handler;
- s->req->async.private = c;
+ s->req->async.private_data = c;
return NT_STATUS_OK;
}
/* callback handler setup */
s->req->async.callback = usermod_handler;
- s->req->async.private = c;
+ s->req->async.private_data = c;
return NT_STATUS_OK;
}
struct msg_rpc_lookup_name *msg_lookup;
struct msg_rpc_open_user *msg_open;
- c = talloc_get_type(req->async.private, struct composite_context);
+ c = talloc_get_type(req->async.private_data, struct composite_context);
s = talloc_get_type(c->private_data, struct usermod_state);
switch (s->stage) {
/* callback handler setup */
s->req->async.callback = usermod_handler;
- s->req->async.private = c;
+ s->req->async.private_data = c;
s->stage = USERMOD_LOOKUP;
return c;
*/
static void dcerpc_composite_fail(struct rpc_request *req)
{
- struct composite_context *c = talloc_get_type(req->async.private,
+ struct composite_context *c = talloc_get_type(req->async.private_data,
struct composite_context);
composite_error(c, req->status);
}
struct composite_context *c;
struct dcerpc_connection *conn;
- c = talloc_get_type(req->async.private, struct composite_context);
+ c = talloc_get_type(req->async.private_data, struct composite_context);
if (pkt->ptype == DCERPC_PKT_BIND_NAK) {
DEBUG(2,("dcerpc: bind_nak reason %d\n",
req->state = RPC_REQUEST_PENDING;
req->call_id = pkt.call_id;
- req->async.private = c;
+ req->async.private_data = c;
req->async.callback = dcerpc_composite_fail;
req->p = p;
req->recv_handler = dcerpc_bind_recv_handler;
req->async_call = async;
req->ignore_timeout = False;
req->async.callback = NULL;
- req->async.private = NULL;
+ req->async.private_data = NULL;
req->recv_handler = NULL;
if (object != NULL) {
struct composite_context *c;
struct dcerpc_pipe *recv_pipe;
- c = talloc_get_type(req->async.private, struct composite_context);
+ c = talloc_get_type(req->async.private_data, struct composite_context);
recv_pipe = talloc_get_type(c->private_data, struct dcerpc_pipe);
if (pkt->ptype == DCERPC_PKT_ALTER_RESP &&
req->state = RPC_REQUEST_PENDING;
req->call_id = pkt.call_id;
- req->async.private = c;
+ req->async.private_data = c;
req->async.callback = dcerpc_composite_fail;
req->p = p;
req->recv_handler = dcerpc_alter_recv_handler;
struct dcerpc_transport {
enum dcerpc_transport_t transport;
- void *private;
+ void *private_data;
NTSTATUS (*shutdown_pipe)(struct dcerpc_connection *, NTSTATUS status);
struct {
void (*callback)(struct rpc_request *);
- void *private;
+ void *private_data;
} async;
};
struct schannel_key_state *s;
struct rpc_request *srv_auth2_req;
- c = talloc_get_type(req->async.private, struct composite_context);
+ c = talloc_get_type(req->async.private_data, struct composite_context);
s = talloc_get_type(c->private_data, struct schannel_key_state);
/* receive rpc request result - netlogon challenge */
struct composite_context *c;
struct schannel_key_state *s;
- c = talloc_get_type(req->async.private, struct composite_context);
+ c = talloc_get_type(req->async.private_data, struct composite_context);
s = talloc_get_type(c->private_data, struct schannel_key_state);
/* receive rpc request result - auth2 credentials */
*/
static void pipe_dead(struct dcerpc_connection *c, NTSTATUS status)
{
- struct smb_private *smb = c->transport.private;
+ struct smb_private *smb = c->transport.private_data;
if (smb->dead) {
return;
NTSTATUS status;
state = talloc_get_type(req->async.private, struct smb_read_state);
- smb = talloc_get_type(state->c->transport.private, struct smb_private);
+ smb = talloc_get_type(state->c->transport.private_data, struct smb_private);
io = state->io;
status = smb_raw_read_recv(state->req, io);
*/
static NTSTATUS send_read_request_continue(struct dcerpc_connection *c, DATA_BLOB *blob)
{
- struct smb_private *smb = c->transport.private;
+ struct smb_private *smb = c->transport.private_data;
union smb_read *io;
struct smb_read_state *state;
struct smbcli_request *req;
*/
static NTSTATUS send_read_request(struct dcerpc_connection *c)
{
- struct smb_private *smb = c->transport.private;
+ struct smb_private *smb = c->transport.private_data;
if (smb->dead) {
return NT_STATUS_CONNECTION_DISCONNECTED;
*/
static NTSTATUS smb_send_trans_request(struct dcerpc_connection *c, DATA_BLOB *blob)
{
- struct smb_private *smb = c->transport.private;
+ struct smb_private *smb = c->transport.private_data;
struct smb_trans2 *trans;
uint16_t setup[2];
struct smb_trans_state *state;
*/
static NTSTATUS smb_send_request(struct dcerpc_connection *c, DATA_BLOB *blob, BOOL trigger_read)
{
- struct smb_private *smb = c->transport.private;
+ struct smb_private *smb = c->transport.private_data;
union smb_write io;
struct smbcli_request *req;
*/
static NTSTATUS smb_shutdown_pipe(struct dcerpc_connection *c, NTSTATUS status)
{
- struct smb_private *smb = c->transport.private;
+ struct smb_private *smb = c->transport.private_data;
union smb_close io;
struct smbcli_request *req;
*/
static const char *smb_peer_name(struct dcerpc_connection *c)
{
- struct smb_private *smb = c->transport.private;
+ struct smb_private *smb = c->transport.private_data;
return smb->server_name;
}
*/
static const char *smb_target_hostname(struct dcerpc_connection *c)
{
- struct smb_private *smb = talloc_get_type(c->transport.private, struct smb_private);
+ struct smb_private *smb = talloc_get_type(c->transport.private_data, struct smb_private);
return smb->tree->session->transport->socket->hostname;
}
*/
static NTSTATUS smb_session_key(struct dcerpc_connection *c, DATA_BLOB *session_key)
{
- struct smb_private *smb = c->transport.private;
+ struct smb_private *smb = c->transport.private_data;
if (smb->tree->session->user_session_key.data) {
*session_key = smb->tree->session->user_session_key;
fill in the transport methods
*/
c->transport.transport = NCACN_NP;
- c->transport.private = NULL;
+ c->transport.private_data = NULL;
c->transport.shutdown_pipe = smb_shutdown_pipe;
c->transport.peer_name = smb_peer_name;
c->transport.target_hostname = smb_target_hostname;
if (composite_nomem(smb->server_name, ctx)) return;
smb->dead = false;
- c->transport.private = smb;
+ c->transport.private_data = smb;
composite_done(ctx);
}
if (c->transport.transport != NCACN_NP) return NULL;
- smb = talloc_get_type(c->transport.private, struct smb_private);
+ smb = talloc_get_type(c->transport.private_data, struct smb_private);
if (!smb) return NULL;
return smb->tree;
if (c->transport.transport != NCACN_NP) return 0;
- smb = talloc_get_type(c->transport.private, struct smb_private);
+ smb = talloc_get_type(c->transport.private_data, struct smb_private);
if (!smb) return 0;
return smb->fnum;
*/
static void pipe_dead(struct dcerpc_connection *c, NTSTATUS status)
{
- struct smb2_private *smb = c->transport.private;
+ struct smb2_private *smb = c->transport.private_data;
if (smb->dead) {
return;
NTSTATUS status;
state = talloc_get_type(req->async.private, struct smb2_read_state);
- smb = talloc_get_type(state->c->transport.private, struct smb2_private);
+ smb = talloc_get_type(state->c->transport.private_data, struct smb2_private);
status = smb2_read_recv(req, state, &io);
if (NT_STATUS_IS_ERR(status)) {
*/
static NTSTATUS send_read_request_continue(struct dcerpc_connection *c, DATA_BLOB *blob)
{
- struct smb2_private *smb = c->transport.private;
+ struct smb2_private *smb = c->transport.private_data;
struct smb2_read io;
struct smb2_read_state *state;
struct smb2_request *req;
*/
static NTSTATUS send_read_request(struct dcerpc_connection *c)
{
- struct smb2_private *smb = c->transport.private;
+ struct smb2_private *smb = c->transport.private_data;
if (smb->dead) {
return NT_STATUS_CONNECTION_DISCONNECTED;
*/
static NTSTATUS smb2_send_trans_request(struct dcerpc_connection *c, DATA_BLOB *blob)
{
- struct smb2_private *smb = talloc_get_type(c->transport.private,
+ struct smb2_private *smb = talloc_get_type(c->transport.private_data,
struct smb2_private);
struct smb2_ioctl io;
struct smb2_trans_state *state;
static NTSTATUS smb2_send_request(struct dcerpc_connection *c, DATA_BLOB *blob,
BOOL trigger_read)
{
- struct smb2_private *smb = c->transport.private;
+ struct smb2_private *smb = c->transport.private_data;
struct smb2_write io;
struct smb2_request *req;
*/
static NTSTATUS smb2_shutdown_pipe(struct dcerpc_connection *c, NTSTATUS status)
{
- struct smb2_private *smb = c->transport.private;
+ struct smb2_private *smb = c->transport.private_data;
struct smb2_close io;
struct smb2_request *req;
*/
static const char *smb2_peer_name(struct dcerpc_connection *c)
{
- struct smb2_private *smb = talloc_get_type(c->transport.private,
+ struct smb2_private *smb = talloc_get_type(c->transport.private_data,
struct smb2_private);
return smb->server_name;
}
*/
static const char *smb2_target_hostname(struct dcerpc_connection *c)
{
- struct smb2_private *smb = talloc_get_type(c->transport.private,
+ struct smb2_private *smb = talloc_get_type(c->transport.private_data,
struct smb2_private);
return smb->tree->session->transport->socket->hostname;
}
*/
static NTSTATUS smb2_session_key(struct dcerpc_connection *c, DATA_BLOB *session_key)
{
- struct smb2_private *smb = talloc_get_type(c->transport.private,
+ struct smb2_private *smb = talloc_get_type(c->transport.private_data,
struct smb2_private);
*session_key = smb->tree->session->session_key;
if (session_key->data == NULL) {
fill in the transport methods
*/
c->transport.transport = NCACN_NP;
- c->transport.private = NULL;
+ c->transport.private_data = NULL;
c->transport.shutdown_pipe = smb2_shutdown_pipe;
c->transport.peer_name = smb2_peer_name;
c->transport.target_hostname = smb2_target_hostname;
if (composite_nomem(smb->server_name, ctx)) return;
smb->dead = false;
- c->transport.private = smb;
+ c->transport.private_data = smb;
composite_done(ctx);
}
*/
struct smb2_tree *dcerpc_smb2_tree(struct dcerpc_connection *c)
{
- struct smb2_private *smb = talloc_get_type(c->transport.private,
+ struct smb2_private *smb = talloc_get_type(c->transport.private_data,
struct smb2_private);
return smb->tree;
}
*/
static void sock_dead(struct dcerpc_connection *p, NTSTATUS status)
{
- struct sock_private *sock = p->transport.private;
+ struct sock_private *sock = p->transport.private_data;
if (!sock) return;
{
struct dcerpc_connection *p = talloc_get_type(private,
struct dcerpc_connection);
- struct sock_private *sock = p->transport.private;
+ struct sock_private *sock = p->transport.private_data;
sock->pending_reads--;
if (sock->pending_reads == 0) {
packet_recv_disable(sock->packet);
{
struct dcerpc_connection *p = talloc_get_type(private,
struct dcerpc_connection);
- struct sock_private *sock = p->transport.private;
+ struct sock_private *sock = p->transport.private_data;
if (flags & EVENT_FD_WRITE) {
packet_queue_run(sock->packet);
*/
static NTSTATUS sock_send_read(struct dcerpc_connection *p)
{
- struct sock_private *sock = p->transport.private;
+ struct sock_private *sock = p->transport.private_data;
sock->pending_reads++;
if (sock->pending_reads == 1) {
packet_recv_enable(sock->packet);
static NTSTATUS sock_send_request(struct dcerpc_connection *p, DATA_BLOB *data,
BOOL trigger_read)
{
- struct sock_private *sock = p->transport.private;
+ struct sock_private *sock = p->transport.private_data;
DATA_BLOB blob;
NTSTATUS status;
*/
static NTSTATUS sock_shutdown_pipe(struct dcerpc_connection *p, NTSTATUS status)
{
- struct sock_private *sock = p->transport.private;
+ struct sock_private *sock = p->transport.private_data;
if (sock && sock->sock) {
sock_dead(p, status);
*/
static const char *sock_peer_name(struct dcerpc_connection *p)
{
- struct sock_private *sock = talloc_get_type(p->transport.private, struct sock_private);
+ struct sock_private *sock = talloc_get_type(p->transport.private_data, struct sock_private);
return sock->server_name;
}
*/
static const char *sock_target_hostname(struct dcerpc_connection *p)
{
- struct sock_private *sock = talloc_get_type(p->transport.private, struct sock_private);
+ struct sock_private *sock = talloc_get_type(p->transport.private_data, struct sock_private);
return sock->server_name;
}
fill in the transport methods
*/
conn->transport.transport = s->transport;
- conn->transport.private = NULL;
+ conn->transport.private_data = NULL;
conn->transport.send_request = sock_send_request;
conn->transport.send_read = sock_send_read;
sock->fde = event_add_fd(conn->event_ctx, sock->sock, socket_get_fd(sock->sock),
EVENT_FD_READ, sock_io_handler, conn);
- conn->transport.private = sock;
+ conn->transport.private_data = sock;
sock->packet = packet_init(sock);
if (sock->packet == NULL) {
*/
static void continue_epm_map(struct rpc_request *req)
{
- struct composite_context *c = talloc_get_type(req->async.private,
+ struct composite_context *c = talloc_get_type(req->async.private_data,
struct composite_context);
struct epm_map_binding_state *s = talloc_get_type(c->private_data,
struct epm_map_binding_state);
static void lookupsids_cb(struct rpc_request *req)
{
- int *replies = (int *)req->async.private;
+ int *replies = (int *)req->async.private_data;
NTSTATUS status;
status = dcerpc_ndr_request_recv(req);
}
req[i]->async.callback = lookupsids_cb;
- req[i]->async.private = &replies;
+ req[i]->async.private_data = &replies;
}
while (replies >= 0 && replies < num_async_requests) {
static void async_callback(struct rpc_request *req)
{
- int *counter = req->async.private;
+ int *counter = req->async.private_data;
if (NT_STATUS_IS_OK(req->status)) {
(*counter)++;
}
req[i] = dcerpc_netr_LogonGetDomainInfo_send(p, mem_ctx, &r);
req[i]->async.callback = async_callback;
- req[i]->async.private = async_counter;
+ req[i]->async.private_data = async_counter;
/* even with this flush per request a w2k3 server seems to
clag with multiple outstanding requests. bleergh. */
static void get_schannel_creds_recv_chal(struct rpc_request *req)
{
struct composite_context *c =
- talloc_get_type(req->async.private,
+ talloc_get_type(req->async.private_data,
struct composite_context);
struct get_schannel_creds_state *state =
talloc_get_type(c->private_data,
static void get_schannel_creds_recv_auth(struct rpc_request *req)
{
struct composite_context *c =
- talloc_get_type(req->async.private,
+ talloc_get_type(req->async.private_data,
struct composite_context);
struct get_schannel_creds_state *state =
talloc_get_type(c->private_data,
if (req == NULL) goto failed;
req->async.callback = lsa_lookupsids_recv_names;
- req->async.private = state;
+ req->async.private_data = state;
return result;
failed:
static void lsa_lookupsids_recv_names(struct rpc_request *req)
{
struct lsa_lookupsids_state *state =
- talloc_get_type(req->async.private,
+ talloc_get_type(req->async.private_data,
struct lsa_lookupsids_state);
int i;
if (req == NULL) goto failed;
req->async.callback = lsa_lookupnames_recv_sids;
- req->async.private = state;
+ req->async.private_data = state;
return result;
failed:
static void lsa_lookupnames_recv_sids(struct rpc_request *req)
{
struct lsa_lookupnames_state *state =
- talloc_get_type(req->async.private,
+ talloc_get_type(req->async.private_data,
struct lsa_lookupnames_state);
int i;
if (req == NULL) goto failed;
req->async.callback = samr_usergroups_recv_open;
- req->async.private = state;
+ req->async.private_data = state;
return result;
failed:
static void samr_usergroups_recv_open(struct rpc_request *req)
{
struct samr_getuserdomgroups_state *state =
- talloc_get_type(req->async.private,
+ talloc_get_type(req->async.private_data,
struct samr_getuserdomgroups_state);
state->ctx->status = dcerpc_ndr_request_recv(req);
static void samr_usergroups_recv_groups(struct rpc_request *req)
{
struct samr_getuserdomgroups_state *state =
- talloc_get_type(req->async.private,
+ talloc_get_type(req->async.private_data,
struct samr_getuserdomgroups_state);
state->ctx->status = dcerpc_ndr_request_recv(req);
static void samr_usergroups_recv_close(struct rpc_request *req)
{
struct samr_getuserdomgroups_state *state =
- talloc_get_type(req->async.private,
+ talloc_get_type(req->async.private_data,
struct samr_getuserdomgroups_state);
state->ctx->status = dcerpc_ndr_request_recv(req);
static void getdcname_recv_dcname(struct rpc_request *req)
{
struct cmd_getdcname_state *state =
- talloc_get_type(req->async.private,
+ talloc_get_type(req->async.private_data,
struct cmd_getdcname_state);
state->ctx->status = dcerpc_ndr_request_recv(req);
static void cmd_list_trustdoms_recv_doms(struct rpc_request *req)
{
struct cmd_list_trustdom_state *state =
- talloc_get_type(req->async.private,
+ talloc_get_type(req->async.private_data,
struct cmd_list_trustdom_state);
int i, old_num_domains;
static void usersids_recv_aliases(struct rpc_request *req)
{
struct cmd_usersids_state *state =
- talloc_get_type(req->async.private,
+ talloc_get_type(req->async.private_data,
struct cmd_usersids_state);
int i;
static void init_lsa_recv_openpol(struct rpc_request *req)
{
struct init_lsa_state *state =
- talloc_get_type(req->async.private,
+ talloc_get_type(req->async.private_data,
struct init_lsa_state);
state->ctx->status = dcerpc_ndr_request_recv(req);
static void connect_samr_recv_conn(struct rpc_request *req)
{
struct connect_samr_state *state =
- talloc_get_type(req->async.private,
+ talloc_get_type(req->async.private_data,
struct connect_samr_state);
state->ctx->status = dcerpc_ndr_request_recv(req);
static void connect_samr_recv_open(struct rpc_request *req)
{
struct connect_samr_state *state =
- talloc_get_type(req->async.private,
+ talloc_get_type(req->async.private_data,
struct connect_samr_state);
state->ctx->status = dcerpc_ndr_request_recv(req);
static void trusted_dom_info_recv_dsr(struct rpc_request *req)
{
struct trusted_dom_info_state *state =
- talloc_get_type(req->async.private,
+ talloc_get_type(req->async.private_data,
struct trusted_dom_info_state);
state->ctx->status = dcerpc_ndr_request_recv(req);
static void trusted_dom_info_recv_dcname(struct rpc_request *req)
{
struct trusted_dom_info_state *state =
- talloc_get_type(req->async.private,
+ talloc_get_type(req->async.private_data,
struct trusted_dom_info_state);
struct composite_context *ctx;
struct nbt_name name;
static void init_domain_recv_queryinfo(struct rpc_request *req)
{
struct init_domain_state *state =
- talloc_get_type(req->async.private, struct init_domain_state);
+ talloc_get_type(req->async.private_data, struct init_domain_state);
struct lsa_DomainInfo *dominfo;
struct composite_context *ctx;
const char *ldap_url;
static void pam_auth_crap_recv_samlogon(struct rpc_request *req)
{
struct pam_auth_crap_state *state =
- talloc_get_type(req->async.private,
+ talloc_get_type(req->async.private_data,
struct pam_auth_crap_state);
struct netr_SamBaseInfo *base;
DATA_BLOB tmp_blob;
*/
static void wb_sam_logon_recv_samlogon(struct rpc_request *req)
{
- struct wb_sam_logon_state *s = talloc_get_type(req->async.private,
+ struct wb_sam_logon_state *s = talloc_get_type(req->async.private_data,
struct wb_sam_logon_state);
s->ctx->status = dcerpc_ndr_request_recv(req);