summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--src/zabbix_server/nodewatcher/nodecomms.c98
-rw-r--r--src/zabbix_server/trapper/trapper.c6
2 files changed, 3 insertions, 101 deletions
diff --git a/src/zabbix_server/nodewatcher/nodecomms.c b/src/zabbix_server/nodewatcher/nodecomms.c
index 7dd132f7..e7fe4cd5 100644
--- a/src/zabbix_server/nodewatcher/nodecomms.c
+++ b/src/zabbix_server/nodewatcher/nodecomms.c
@@ -71,19 +71,9 @@
******************************************************************************/
int send_to_node(int dest_nodeid, int nodeid, char *data)
{
- int i,s;
-/* char answer[MAX_STRING_LEN];*/
- struct hostent *hp;
-
- struct sockaddr_in myaddr_in;
- struct sockaddr_in servaddr_in;
char ip[MAX_STRING_LEN];
int port;
int ret = FAIL;
- int written;
-
- char header[5]="ZBXD\1";
- zbx_uint64_t len64;
DB_RESULT result;
DB_ROW row;
@@ -141,93 +131,5 @@ int send_to_node(int dest_nodeid, int nodeid, char *data)
zbx_tcp_close(&sock);
-
-
-/* servaddr_in.sin_family=AF_INET;
-
- if(NULL == (hp = zbx_gethost(ip)))
- {
- zabbix_log( LOG_LEVEL_WARNING, "Cannot resolve [%s] for node [%d]", ip, dest_nodeid);
- return FAIL;
- }
-
- servaddr_in.sin_addr.s_addr=((struct in_addr *)(hp->h_addr))->s_addr;
-
- servaddr_in.sin_port=htons(port);
-
- s=socket(AF_INET,SOCK_STREAM,0);
- if(s == -1)
- {
- zabbix_log( LOG_LEVEL_WARNING, "Cannot create socket [%s] for node [%d]", ip, dest_nodeid);
- return FAIL;
- }
-
- myaddr_in.sin_family = AF_INET;
- myaddr_in.sin_port=0;
- myaddr_in.sin_addr.s_addr=INADDR_ANY;
-
- if( connect(s,(struct sockaddr *)&servaddr_in,sizeof(struct sockaddr_in)) == -1 )
- {
- zabbix_log( LOG_LEVEL_WARNING, "Cannot connect [%s] to node [%d]", ip, dest_nodeid);
- close(s);
- return FAIL;
- }
-
- written = 0;
-
- i=write(s, header, 5);
- if(i == -1)
- {
- zabbix_log( LOG_LEVEL_WARNING, "Error writing to node [%d] [%s]", dest_nodeid, strerror(errno));
- close(s);
- return FAIL;
- }
- len64 = (zbx_uint64_t)strlen(data);
-
- i=write(s, &len64, sizeof(len64));
- if(i == -1)
- {
- zabbix_log( LOG_LEVEL_WARNING, "Error writing to node [%d] [%s]", dest_nodeid, strerror(errno));
- close(s);
- return FAIL;
- }
-
- while(written<strlen(data))
- {
- i=write(s, data+written,strlen(data)-written);
- if(i == -1)
- {
- zabbix_log( LOG_LEVEL_WARNING, "Error writing to node [%d] [%s]", dest_nodeid, strerror(errno));
- close(s);
- return FAIL;
- }
- written+=i;
- }
- i=sizeof(struct sockaddr_in);
- i=read(s,answer,MAX_STRING_LEN-1);
- if(i==-1)
- {
- zabbix_log( LOG_LEVEL_WARNING, "Error reading from node [%d]", dest_nodeid);
- close(s);
- return FAIL;
- }
-
- answer[i-1]=0;
-
- zabbix_log( LOG_LEVEL_WARNING, "Read [%s]", answer);
- if(strcmp(answer,"OK") == 0)
- {
- zabbix_log( LOG_LEVEL_WARNING, "OK");
- ret = SUCCEED;
- }
- else
- {
- zabbix_log( LOG_LEVEL_WARNING, "NOT OK");
- }
-
- if( close(s)!=0 )
- {
- }*/
-
return ret;
}
diff --git a/src/zabbix_server/trapper/trapper.c b/src/zabbix_server/trapper/trapper.c
index e0ba0bd4..58a5e674 100644
--- a/src/zabbix_server/trapper/trapper.c
+++ b/src/zabbix_server/trapper/trapper.c
@@ -228,16 +228,16 @@ void process_trapper_child(zbx_sock_t *sock)
gettimeofday(&tv, NULL);
msec = tv.tv_usec;
- alarm(CONFIG_TIMEOUT);
+/* alarm(CONFIG_TIMEOUT);*/
if(zbx_tcp_recv(sock, &data) != SUCCEED)
{
- alarm(0);
+/* alarm(0);*/
return;
}
process_trap(sock, data, sizeof(data));
- alarm(0);
+/* alarm(0);*/
gettimeofday(&tv, NULL);
zabbix_log( LOG_LEVEL_DEBUG, "Trap processed in %f seconds", (float)(tv.tv_usec-msec)/1000000 );