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

static int initWinSock(void){    WORD wVersionRequested;      WSADATA wsaData;     int i;     static LONG volatile initialized = 0;        wVersionRequested = MAKEWORD(1, 1);     if (InterlockedCompareExchange((LPLONG) &initialized,1L,0L) == 0L) {	/* FIXME not terminate, just a message?! */	if ((i = WSAStartup(wVersionRequested, &wsaData))) {	    EI_TRACE_ERR1("ei_connect_init",			  "ERROR: can't initialize windows sockets: %d",i);	    initialized = 2L;	    return 0;	}		if (LOBYTE(wsaData.wVersion) != 1 || HIBYTE(wsaData.wVersion) != 1) { 	    EI_TRACE_ERR0("initWinSock","ERROR: this version of windows "			  "sockets not supported");	    WSACleanup(); 	    initialized = 2L;	    return 0;	}	initialized = 3L;    } else while (initialized < 2) {	SwitchToThread();    }    return (int) (initialized - 2);}

static int recv_status(int fd, unsigned ms){    char dbuf[DEFBUF_SIZ];    char *buf = dbuf;    int is_static = 1;    int buflen = DEFBUF_SIZ;    int rlen;        if ((rlen = read_2byte_package(fd, &buf, &buflen, &is_static, ms)) <= 0) {	EI_TRACE_ERR1("recv_status",		      "<- RECV_STATUS socket read failed (%d)", rlen);	goto error;    }    if (rlen == 3 && buf[0] == 's' && buf[1] == 'o' && 	buf[2] == 'k') {	if (!is_static)	    free(buf);	EI_TRACE_CONN0("recv_status","<- RECV_STATUS (ok)");	return 0;    }error:    if (!is_static)	free(buf);    return -1;}

static int recv_status(int fd, unsigned ms){    char dbuf[DEFBUF_SIZ];    char *buf = dbuf;    int is_static = 1;    int buflen = DEFBUF_SIZ;    int rlen;        if ((rlen = read_2byte_package(fd, &buf, &buflen, &is_static, ms)) <= 0) {	EI_TRACE_ERR1("recv_status",		      "<- RECV_STATUS socket read failed (%d)", rlen);	goto error;    }    EI_TRACE_CONN2("recv_status",                   "<- RECV_STATUS (%.*s)", (rlen>20 ? 20 : rlen), buf);    if (rlen >= 3 && buf[0] == 's' && buf[1] == 'o' && buf[2] == 'k') {        /* Expecting "sok" or "sok_simultaneous" */	if (!is_static)	    free(buf);	return 0;    }error:    if (!is_static)	free(buf);    return -1;}

static int recv_challenge_reply (int fd, 				 unsigned our_challenge,				 char cookie[], 				 unsigned *her_challenge,				 unsigned ms){    char dbuf[DEFBUF_SIZ];    char *buf = dbuf;    int is_static = 1;    int buflen = DEFBUF_SIZ;    int rlen;    char *s;    char tag;    char her_digest[16], expected_digest[16];        erl_errno = EIO;		/* Default */    if ((rlen = read_2byte_package(fd, &buf, &buflen, &is_static, ms)) != 21) {	EI_TRACE_ERR1("recv_challenge_reply",		      "<- RECV_CHALLENGE_REPLY socket read failed (%d)",rlen);	goto error;    }        s = buf;    if ((tag = get8(s)) != 'r') {	EI_TRACE_ERR2("recv_challenge_reply",		      "<- RECV_CHALLENGE_REPLY incorrect tag, "		      "expected 'r' got '%c' (%u)",tag,tag);	goto error;    }    *her_challenge = get32be(s);    memcpy(her_digest, s, 16);    gen_digest(our_challenge, cookie, (unsigned char*)expected_digest);    if (memcmp(her_digest, expected_digest, 16)) {	EI_TRACE_ERR0("recv_challenge_reply",		      "<- RECV_CHALLENGE_REPLY authorization failure");	goto error;    }    if (!is_static)	free(buf);       if (ei_tracelevel >= 3) {	char buffer[33];	        EI_TRACE_CONN2("recv_challenge_reply",		   "<- RECV_CHALLENGE_REPLY (ok) challenge = %u, digest = %s",		   *her_challenge,hex(her_digest,buffer));    }    erl_errno = 0;    return 0;    error:    if (!is_static)	free(buf);    return -1;}

static int send_name_or_challenge(int fd, char *nodename,				  int f_chall,				  unsigned challenge,				  unsigned version,				  unsigned ms) {    char *buf;    unsigned char *s;    char dbuf[DEFBUF_SIZ];    int siz = 2 + 1 + 2 + 4 + strlen(nodename);    const char* function[] = {"SEND_NAME", "SEND_CHALLENGE"};    int res;    if (f_chall)	siz += 4;    buf = (siz > DEFBUF_SIZ) ? malloc(siz) : dbuf;    if (!buf) {	erl_errno = ENOMEM;	return -1;    }    s = (unsigned char *)buf;    put16be(s,siz - 2);    put8(s, 'n');    put16be(s, version);    put32be(s, (DFLAG_EXTENDED_REFERENCES		| DFLAG_DIST_MONITOR		| DFLAG_EXTENDED_PIDS_PORTS		| DFLAG_FUN_TAGS		| DFLAG_NEW_FUN_TAGS                | DFLAG_NEW_FLOATS		| DFLAG_SMALL_ATOM_TAGS		| DFLAG_UTF8_ATOMS		| DFLAG_MAP_TAG		| DFLAG_BIG_CREATION));    if (f_chall)	put32be(s, challenge);    memcpy(s, nodename, strlen(nodename));        if ((res = ei_write_fill_t(fd, buf, siz, ms)) != siz) {	EI_TRACE_ERR1("send_name_or_challenge",		      "-> %s socket write failed", function[f_chall]);	if (buf != dbuf)	    free(buf);	erl_errno = (res == -2) ? ETIMEDOUT : EIO;	return -1;    }        if (buf != dbuf)	free(buf);    return 0;}

  /*   * Set up a connection to a given Node, and   * interchange hand shake messages with it.  * Returns a valid file descriptor at success,  * otherwise a negative error code.*/int ei_connect_tmo(ei_cnode* ec, char *nodename, unsigned ms){    char *hostname, alivename[BUFSIZ];    struct hostent *hp;#if !defined (__WIN32__)     /* these are needed for the call to gethostbyname_r */    struct hostent host;    char buffer[1024];    int ei_h_errno;#endif /* !win32 */        /* extract the host and alive parts from nodename */    if (!(hostname = strchr(nodename,'@'))) {	EI_TRACE_ERR0("ei_connect","Node name has no @ in name");	return ERL_ERROR;    } else {	strncpy(alivename, nodename, hostname - nodename);	alivename[hostname - nodename] = 0x0;	hostname++;    }    #ifndef __WIN32__    hp = ei_gethostbyname_r(hostname,&host,buffer,1024,&ei_h_errno);    if (hp == NULL) {	char thishostname[EI_MAXHOSTNAMELEN+1];	if (gethostname(thishostname,EI_MAXHOSTNAMELEN) < 0) {	    EI_TRACE_ERR0("ei_connect_tmo",			  "Failed to get name of this host");	    erl_errno = EHOSTUNREACH;	    return ERL_ERROR;	} else {	    char *ct;	    /* We use a short node name */    	    if ((ct = strchr(thishostname, '.')) != NULL) *ct = '/0';	}	if (strcmp(hostname,thishostname) == 0)	    /* Both nodes on same standalone host, use loopback */	    hp = ei_gethostbyname_r("localhost",&host,buffer,1024,&ei_h_errno);	if (hp == NULL) {	    EI_TRACE_ERR2("ei_connect",			  "Can't find host for %s: %d/n",nodename,ei_h_errno);	    erl_errno = EHOSTUNREACH;	    return ERL_ERROR;	}    }#else /* __WIN32__ */    if ((hp = ei_gethostbyname(hostname)) == NULL) {	char thishostname[EI_MAXHOSTNAMELEN+1];	if (gethostname(thishostname,EI_MAXHOSTNAMELEN) < 0) {	    EI_TRACE_ERR1("ei_connect_tmo",			  "Failed to get name of this host: %d", 			  WSAGetLastError());	    erl_errno = EHOSTUNREACH;	    return ERL_ERROR;	} else {	    char *ct;	    /* We use a short node name */    	    if ((ct = strchr(thishostname, '.')) != NULL) *ct = '/0';	}	if (strcmp(hostname,thishostname) == 0)	    /* Both nodes on same standalone host, use loopback */	    hp = ei_gethostbyname("localhost");	if (hp == NULL) {	    char reason[1024];	    win32_error(reason,sizeof(reason));	    EI_TRACE_ERR2("ei_connect",			  "Can't find host for %s: %s",nodename,reason);	    erl_errno = EHOSTUNREACH;	    return ERL_ERROR;	}    }#endif /* win32 */    return ei_xconnect_tmo(ec, (Erl_IpAddr) *hp->h_addr_list, alivename, ms);} /* ei_connect */

/** Initialize by set: thishostname, thisalivename, * thisnodename and thisipaddr. At success return 0,* otherwise return -1.*/int ei_connect_init(ei_cnode* ec, const char* this_node_name,		    const char *cookie, short creation){    struct hostent *hp;    char thishostname[EI_MAXHOSTNAMELEN+1];    char thisnodename[MAXNODELEN+1];    char thisalivename[EI_MAXALIVELEN+1];#ifdef __WIN32__    if (!initWinSock()) {	EI_TRACE_ERR0("ei_connect_xinit","can't initiate winsock");	return ERL_ERROR;    }#endif /* win32 */#ifdef _REENTRANT    if (ei_sockets_lock == NULL) {	ei_sockets_lock = ei_mutex_create();    }#endif /* _REENTRANT */        if (gethostname(thishostname, EI_MAXHOSTNAMELEN) == -1) {#ifdef __WIN32__	EI_TRACE_ERR1("ei_connect_init","Failed to get host name: %d",		      WSAGetLastError());#else	EI_TRACE_ERR1("ei_connect_init","Failed to get host name: %d", errno);#endif /* win32 */	return ERL_ERROR;    }    if (this_node_name == NULL) {	sprintf(thisalivename, "c%d", (int) getpid());    } else if (strlen(this_node_name) >= sizeof(thisalivename)) {	EI_TRACE_ERR0("ei_connect_init","ERROR: this_node_name too long");	return ERL_ERROR;    } else {	strcpy(thisalivename, this_node_name);    }        if ((hp = ei_gethostbyname(thishostname)) == 0) {	/* Looking up IP given hostname fails. We must be on a standalone	   host so let's use loopback for communication instead. */	if ((hp = ei_gethostbyname("localhost")) == 0) {#ifdef __WIN32__	    char reason[1024];		    win32_error(reason,sizeof(reason));	    EI_TRACE_ERR2("ei_connect_init",			  "Can't get ip address for host %s: %s",			  thishostname, reason);#else	    EI_TRACE_ERR2("ei_connect_init",			  "Can't get ip address for host %s: %d",			  thishostname, h_errno);#endif /* win32 */	    return ERL_ERROR;	}    }    {	char* ct;	if (strcmp(hp->h_name, "localhost") == 0) {	    /* We use a short node name */    	    if ((ct = strchr(thishostname, '.')) != NULL) *ct = '/0';	    sprintf(thisnodename, "%[email
C++ EJSVAL_TO_OBJECT函数代码示例
C++ EI_TRACE_ERR0函数代码示例