struct sockaddr_vm addr;
socklen_t len = sizeof addr;
int port;
+ int fd;
gchar *msg;
g_debug("Entering %s\n", __FUNCTION__);
ASSERT(asock != NULL);
+ fd = AsyncSocket_GetFd(asock);
+ ASSERT(fd >= 0);
+
/* get the listening port */
- if (getsockname(AsyncSocket_GetFd(asock),
- (struct sockaddr *)&addr, &len) == SOCKET_ERROR) {
+ if (getsockname(fd, (struct sockaddr *)&addr, &len) == SOCKET_ERROR) {
g_warning("Error in socket getsockname: error=%d.\n", sockerr());
return FALSE;
}
gboolean mapCreated = FALSE;
char *ver;
+ g_debug("Entering %s\n", __FUNCTION__);
+
res = DataMap_Create(&map);
if (res != DMERR_SUCCESS) {
goto quit;
ErrorCode res;
int64 cmdType;
+ g_debug("Entering %s\n", __FUNCTION__);
+
res = DataMap_GetInt64(map, RMQPROXYDM_FLD_COMMAND, &cmdType);
ASSERT(res == DMERR_SUCCESS);