Commit e2da07cd authored by unknown's avatar unknown

Merge willster.(none):/home/stewart/Documents/MySQL/5.0/ndb

into  willster.(none):/home/stewart/Documents/MySQL/5.1/ndb


storage/ndb/src/mgmapi/mgmapi.cpp:
  Auto merged
storage/ndb/src/mgmclient/CommandInterpreter.cpp:
  Auto merged
parents be495c39 105ed9de
...@@ -1395,7 +1395,7 @@ ndb_mgm_listen_event_internal(NdbMgmHandle handle, const int filter[], ...@@ -1395,7 +1395,7 @@ ndb_mgm_listen_event_internal(NdbMgmHandle handle, const int filter[],
MGM_END() MGM_END()
}; };
CHECK_HANDLE(handle, -1); CHECK_HANDLE(handle, -1);
const char *hostname= ndb_mgm_get_connected_host(handle); const char *hostname= ndb_mgm_get_connected_host(handle);
int port= ndb_mgm_get_connected_port(handle); int port= ndb_mgm_get_connected_port(handle);
SocketClient s(hostname, port); SocketClient s(hostname, port);
...@@ -1417,19 +1417,20 @@ ndb_mgm_listen_event_internal(NdbMgmHandle handle, const int filter[], ...@@ -1417,19 +1417,20 @@ ndb_mgm_listen_event_internal(NdbMgmHandle handle, const int filter[],
} }
args.put("filter", tmp.c_str()); args.put("filter", tmp.c_str());
} }
int tmp = handle->socket; int tmp = handle->socket;
handle->socket = sockfd; handle->socket = sockfd;
const Properties *reply; const Properties *reply;
reply = ndb_mgm_call(handle, stat_reply, "listen event", &args); reply = ndb_mgm_call(handle, stat_reply, "listen event", &args);
handle->socket = tmp; handle->socket = tmp;
if(reply == NULL) { if(reply == NULL) {
close(sockfd); close(sockfd);
CHECK_REPLY(reply, -1); CHECK_REPLY(reply, -1);
} }
delete reply;
return sockfd; return sockfd;
} }
......
...@@ -1173,6 +1173,7 @@ CommandInterpreter::executeShow(char* parameters) ...@@ -1173,6 +1173,7 @@ CommandInterpreter::executeShow(char* parameters)
if(it == 0){ if(it == 0){
ndbout_c("Unable to create config iterator"); ndbout_c("Unable to create config iterator");
ndb_mgm_destroy_configuration(conf);
return; return;
} }
NdbAutoPtr<ndb_mgm_configuration_iterator> ptr(it); NdbAutoPtr<ndb_mgm_configuration_iterator> ptr(it);
...@@ -1217,6 +1218,7 @@ CommandInterpreter::executeShow(char* parameters) ...@@ -1217,6 +1218,7 @@ CommandInterpreter::executeShow(char* parameters)
print_nodes(state, it, "ndb_mgmd", mgm_nodes, NDB_MGM_NODE_TYPE_MGM, 0); print_nodes(state, it, "ndb_mgmd", mgm_nodes, NDB_MGM_NODE_TYPE_MGM, 0);
print_nodes(state, it, "mysqld", api_nodes, NDB_MGM_NODE_TYPE_API, 0); print_nodes(state, it, "mysqld", api_nodes, NDB_MGM_NODE_TYPE_API, 0);
// ndbout << helpTextShow; // ndbout << helpTextShow;
ndb_mgm_destroy_configuration(conf);
return; return;
} else if (strcasecmp(parameters, "PROPERTIES") == 0 || } else if (strcasecmp(parameters, "PROPERTIES") == 0 ||
strcasecmp(parameters, "PROP") == 0) { strcasecmp(parameters, "PROP") == 0) {
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment