diff options
Diffstat (limited to 'src/client')
| -rw-r--r-- | src/client/Makefile | 15 | ||||
| -rw-r--r-- | src/client/main.c | 39 |
2 files changed, 0 insertions, 54 deletions
diff --git a/src/client/Makefile b/src/client/Makefile deleted file mode 100644 index 1afa44c..0000000 --- a/src/client/Makefile +++ /dev/null @@ -1,15 +0,0 @@ -include $(CONF) -EXEC=client -CFLAGS+=-lzmq - -DEFINES=\ --DPUBLISHER_PORT=$(PUBLISHER_PORT) \ --DPUBLISHER_ADDR=$(PUBLISHER_ADDR) - -all: main.c - $(CC) $^ -o $(OUT)/$(EXEC) $(CFLAGS) $(DEFINES) - -clean: - rm -f $(OUT)/$(EXEC) - -.PHONY: clean diff --git a/src/client/main.c b/src/client/main.c deleted file mode 100644 index e4b3498..0000000 --- a/src/client/main.c +++ /dev/null @@ -1,39 +0,0 @@ -// Weather update client -// Connects SUB socket to tcp://localhost:5556 -// Collects weather updates and finds avg temp in zipcode -#include <zmq.h> -#include <assert.h> -#include <time.h> -#include <string.h> - -#include "../utils.h" - - -int main (int argc, char *argv []) -{ - // Socket to talk to server - printf ("Collecting updates from weather server...\n"); - void *context = zmq_ctx_new (); - void *subscriber = zmq_socket (context, ZMQ_SUB); - int rc = zmq_connect (subscriber, "tcp://"STRINGIFY(PUBLISHER_ADDR)":"STRINGIFY(PUBLISHER_PORT)); - assert (rc == 0); - - // Subscribe to zipcode, default is NYC, 10001 - // Subscribe to zipcode, default is NYC, 10001 - const char *filter = "Hello"; - rc = zmq_setsockopt (subscriber, ZMQ_SUBSCRIBE, - filter, strlen(filter)); - assert (rc == 0); - - // Process 100 updates - int update_nbr; - char buffer[10]; - for (update_nbr = 0; update_nbr < 100; update_nbr++) { - zmq_recv (subscriber, buffer, 10, 0); - printf("Received!"); - } - - zmq_close (subscriber); - zmq_ctx_destroy (context); - return 0; -}
\ No newline at end of file |
