summaryrefslogtreecommitdiff
authormjm <mjm>2002-11-27 21:16:52 (UTC)
committer mjm <mjm>2002-11-27 21:16:52 (UTC)
commite16163a106d5f814e9774f6a630cdb2ee488a616 (patch) (side-by-side diff)
treeec0468c5a4cc889f3c4f7cca26c3dcb1d3e324b6
parentc118084479a4d146244b3e9e86b958f618a80a6d (diff)
downloadopie-e16163a106d5f814e9774f6a630cdb2ee488a616.zip
opie-e16163a106d5f814e9774f6a630cdb2ee488a616.tar.gz
opie-e16163a106d5f814e9774f6a630cdb2ee488a616.tar.bz2
new funection recvcomm for receiving commands, cleanup,...
Diffstat (more/less context) (show whitespace changes)
-rw-r--r--noncore/net/wellenreiter/libwellenreiter/source/sock.cc28
-rw-r--r--noncore/net/wellenreiter/libwellenreiter/source/sock.hh1
2 files changed, 25 insertions, 4 deletions
diff --git a/noncore/net/wellenreiter/libwellenreiter/source/sock.cc b/noncore/net/wellenreiter/libwellenreiter/source/sock.cc
index 2cc16eb..90fc20a 100644
--- a/noncore/net/wellenreiter/libwellenreiter/source/sock.cc
+++ b/noncore/net/wellenreiter/libwellenreiter/source/sock.cc
@@ -45,29 +45,49 @@ int sendcomm(const char *host, int port, const char *string, ...)
/* Generate string */
memset(buffer, 0, sizeof(buffer));
va_start(ap, string);
vsnprintf(buffer, sizeof(buffer)-1, string, ap);
va_end(ap);
+ saddr.sin_family = AF_INET;
+ saddr.sin_port = htons(port);
+ saddr.sin_addr.s_addr = inet_addr(host);
+
/* Setup socket */
if((sock=socket(AF_INET, SOCK_DGRAM, 0)) < 0)
{
wl_logerr("Cannot set up socket: %s", strerror(errno));
return -1;
}
- saddr.sin_family = AF_INET;
- saddr.sin_port = htons(port);
- saddr.sin_addr.s_addr = inet_addr(host);
-
if(sendto(sock, buffer, sizeof(buffer), 0, (struct sockaddr *)&saddr, sizeof(saddr)) < 0)
{
wl_logerr("Cannot write to socket: %s", strerror(errno));
close(sock);
return 0;
}
if(close(sock) < 0)
wl_logerr("Cannot close socket: %s", strerror(errno));
return 1;
}
+
+/* Check for new messages on commsock */
+int recvcomm(int *sock, char *out, int maxlen)
+{
+ struct sockaddr_in *cliaddr;
+ socklen_t len=sizeof(struct sockaddr);
+ char buffer[128], retval[3];
+
+ memset(buffer, 0, sizeof(buffer));
+ if(recvfrom(*sock, buffer, sizeof(buffer)-1, 0, (struct sockaddr *)cliaddr, &len) < 0)
+ return -1;
+
+ memset(out, 0, maxlen);
+ memcpy(out, buffer, maxlen - 1);
+
+ memset(retval, 0, sizeof(retval));
+ memcpy(retval, out, 2);
+
+ return atoi(retval);
+}
diff --git a/noncore/net/wellenreiter/libwellenreiter/source/sock.hh b/noncore/net/wellenreiter/libwellenreiter/source/sock.hh
index afde641..611e335 100644
--- a/noncore/net/wellenreiter/libwellenreiter/source/sock.hh
+++ b/noncore/net/wellenreiter/libwellenreiter/source/sock.hh
@@ -12,8 +12,9 @@
#include <unistd.h>
#include <stdlib.h>
#include <errno.h>
int commsock(const char *, int);
int sendcomm(const char *, int, const char *, ...);
+int recvcomm(int *, char *, int);
#endif /* WLSOCK_HH */