自学教程：C++ to_socket函数代码示例

static voidngx_lcb_timer_thunk(ngx_event_t *ev){    ngx_lcb_context_t *ctx = ev->data;    ctx->handler(to_socket(-1), 0, ctx->handler_data);}

static ssize_t pccard_store_insert(struct device *dev, struct device_attribute *attr,				   const char *buf, size_t count){	struct pcmcia_socket *s = to_socket(dev);	if (!count)		return -EINVAL;	pcmcia_parse_uevents(s, PCMCIA_UEVENT_INSERT);	return count;}

/* allocate ngx_peer_connection_t struct */static lcb_socket_tngx_lcb_socket(lcb_io_opt_t io, const char *hostname, const char *servname){    ngx_lcb_context_t *ctx;    ngx_lcb_cookie_t cookie = io->v.v0.cookie;    ctx = ngx_pcalloc(cookie->pool, sizeof(ngx_lcb_context_t));    if (ctx == NULL) {        return to_socket(-1);    }    ctx->io_len = io->v.v0.iov_max;    ctx->io_chains = ngx_pcalloc(cookie->pool, sizeof(ngx_chain_t) * ctx->io_len);    ctx->io_bufs = ngx_pcalloc(cookie->pool, sizeof(ngx_buf_t) * ctx->io_len);    ctx->peer = ngx_pcalloc(cookie->pool, sizeof(ngx_peer_connection_t));    if (ctx->io_chains == NULL || ctx->io_bufs == NULL || ctx->peer == NULL) {        ngx_lcb_close(io, to_socket(ctx));        return to_socket(-1);    }    ctx->peer->log = cookie->log;    ctx->peer->log_error = NGX_ERROR_ERR;    ctx->peer->get = ngx_event_get_peer;    if (common_getaddrinfo(hostname, servname, &ctx->root_ai) != 0) {        ngx_lcb_close(io, to_socket(ctx));        return to_socket(-1);    }    ctx->curr_ai = ctx->root_ai;    return to_socket(ctx);}

static void ngx_lcb_handler_thunk(ngx_event_t *ev){    ngx_connection_t *conn = ev->data;    ngx_lcb_context_t *ctx = conn->data;    int which = 0;    if (ev->write) {        which |= LCB_WRITE_EVENT;    } else {        which |= LCB_READ_EVENT;    }    if (ctx->handler_mask & which) {        ctx->handler(to_socket(ctx), which, ctx->handler_data);    }}

static ssize_t pccard_store_resource(struct device *dev,				     struct device_attribute *attr,				     const char *buf, size_t count){	struct pcmcia_socket *s = to_socket(dev);	if (!count)		return -EINVAL;	mutex_lock(&s->ops_mutex);	if (!s->resource_setup_done)		s->resource_setup_done = 1;	mutex_unlock(&s->ops_mutex);	pcmcia_parse_uevents(s, PCMCIA_UEVENT_REQUERY);	return count;}

static ssize_t pccard_store_card_pm_state(struct device *dev,					  struct device_attribute *attr,					  const char *buf, size_t count){	struct pcmcia_socket *s = to_socket(dev);	ssize_t ret = count;	if (!count)		return -EINVAL;	if (!strncmp(buf, "off", 3))		pcmcia_parse_uevents(s, PCMCIA_UEVENT_SUSPEND);	else {		if (!strncmp(buf, "on", 2))			pcmcia_parse_uevents(s, PCMCIA_UEVENT_RESUME);		else			ret = -EINVAL;	}	return ret;}

static void add_nodes(Scene *scene,                      BL::RenderEngine& b_engine,                      BL::BlendData& b_data,                      BL::Scene& b_scene,                      const bool background,                      ShaderGraph *graph,                      BL::ShaderNodeTree& b_ntree,                      const ProxyMap &proxy_input_map,                      const ProxyMap &proxy_output_map){	/* add nodes */	BL::ShaderNodeTree::nodes_iterator b_node;	PtrInputMap input_map;	PtrOutputMap output_map;	BL::Node::inputs_iterator b_input;	BL::Node::outputs_iterator b_output;	/* find the node to use for output if there are multiple */	bool found_active_output = false;	BL::ShaderNode output_node(PointerRNA_NULL);	for(b_ntree.nodes.begin(b_node); b_node != b_ntree.nodes.end(); ++b_node) {		if(is_output_node(*b_node)) {			BL::ShaderNodeOutputMaterial b_output_node(*b_node);			if(b_output_node.is_active_output()) {				output_node = b_output_node;				found_active_output = true;				break;			}			else if(!output_node.ptr.data && !found_active_output) {				output_node = b_output_node;			}		}	}	/* add nodes */	for(b_ntree.nodes.begin(b_node); b_node != b_ntree.nodes.end(); ++b_node) {		if(b_node->mute() || b_node->is_a(&RNA_NodeReroute)) {			/* replace muted node with internal links */			BL::Node::internal_links_iterator b_link;			for(b_node->internal_links.begin(b_link); b_link != b_node->internal_links.end(); ++b_link) {				BL::NodeSocket to_socket(b_link->to_socket());				ProxyNode *proxy = new ProxyNode(convert_socket_type(to_socket));				input_map[b_link->from_socket().ptr.data] = proxy->inputs[0];				output_map[b_link->to_socket().ptr.data] = proxy->outputs[0];				graph->add(proxy);			}		}		else if(b_node->is_a(&RNA_ShaderNodeGroup) || b_node->is_a(&RNA_NodeCustomGroup)) {						BL::ShaderNodeTree b_group_ntree(PointerRNA_NULL);			if(b_node->is_a(&RNA_ShaderNodeGroup))				b_group_ntree = BL::ShaderNodeTree(((BL::NodeGroup)(*b_node)).node_tree());			else				b_group_ntree = BL::ShaderNodeTree(((BL::NodeCustomGroup)(*b_node)).node_tree());			ProxyMap group_proxy_input_map, group_proxy_output_map;			/* Add a proxy node for each socket			 * Do this even if the node group has no internal tree,			 * so that links have something to connect to and assert won't fail.			 */			for(b_node->inputs.begin(b_input); b_input != b_node->inputs.end(); ++b_input) {				ProxyNode *proxy = new ProxyNode(convert_socket_type(*b_input));				graph->add(proxy);				/* register the proxy node for internal binding */				group_proxy_input_map[b_input->identifier()] = proxy;				input_map[b_input->ptr.data] = proxy->inputs[0];				set_default_value(proxy->inputs[0], *b_input, b_data, b_ntree);			}			for(b_node->outputs.begin(b_output); b_output != b_node->outputs.end(); ++b_output) {				ProxyNode *proxy = new ProxyNode(convert_socket_type(*b_output));				graph->add(proxy);				/* register the proxy node for internal binding */				group_proxy_output_map[b_output->identifier()] = proxy;				output_map[b_output->ptr.data] = proxy->outputs[0];			}						if(b_group_ntree) {				add_nodes(scene,				          b_engine,				          b_data,				          b_scene,				          background,				          graph,				          b_group_ntree,				          group_proxy_input_map,				          group_proxy_output_map);			}		}		else if(b_node->is_a(&RNA_NodeGroupInput)) {			/* map each socket to a proxy node *///.........这里部分代码省略.........