// Weather update server // Binds PUB socket to tcp://*:5556 // Publishes random weather updates #include #include #include #include #include "utils.h" // Global: char *__logdir; int __loginterval; int main (int argc, char *argv []) { if(argc != 3){ printf("Usage: %s ",argv[0]); exit(1); } //----- Init global variables __logdir=argv[1]; __loginterval=atoi(argv[2]); DIR *dr = opendir(__logdir); struct dirent *de; // Pointer for directory entry for(int i=0;i<0;i++){ int interval=INTERVAL(__loginterval); int interval_next=INTERVAL_NEXT(__loginterval); while ((de = readdir(dr)) != NULL){ if(strcmp(de->d_name,".") && strcmp(de->d_name,"..")){ char *client=de->d_name; printf("aa%s\n",client); } } } closedir(dr); return 0; // Prepare our context and publisher void *context = zmq_ctx_new (); void *publisher = zmq_socket (context, ZMQ_PUB); int rc = zmq_bind (publisher, "tcp://*:"STRINGIFY(PUBLISHER_PORT)); assert (rc == 0); // Initialize random number generator while (1) { zmq_send (publisher, "Hello World", 5, 0); printf("AA\n"); } zmq_close (publisher); zmq_ctx_destroy (context); return 0; }