update

wangzhengquan

2020-06-15 73866a4c527cbdf726c5fd824526d5657d0e15ee

 test/nanomsg/pubsub.c

@@ -6,6 +6,7 @@

#include <nanomsg/nn.h>
#include <nanomsg/pubsub.h>
#include <nanomsg/reqrep.h>

#define SERVER "server"
#define CLIENT "client"
@@ -31,7 +32,7 @@
{
        int sock;

        if ((sock = nn_socket(AF_SP, NN_PUB)) < 0) {
        if ((sock = nn_socket(AF_SP, NN_REQ )) < 0) {
                fatal("nn_socket");
        }
          if (nn_bind(sock, url) < 0) {
@@ -54,14 +55,14 @@
{
        int sock;

        if ((sock = nn_socket(AF_SP, NN_SUB)) < 0) {
        if ((sock = nn_socket(AF_SP, NN_REP)) < 0) {
                fatal("nn_socket");
        }

        // subscribe to everything ("" means all topics)
        if (nn_setsockopt(sock, NN_SUB, NN_SUB_SUBSCRIBE, "", 0) < 0) {
                fatal("nn_setsockopt");
        }
        // if (nn_setsockopt(sock, NN_SUB, NN_SUB_SUBSCRIBE, "sjhdfjsdfh", 0) < 0) {
        //         fatal("nn_setsockopt");
        // }
        if (nn_connect(sock, url) < 0) {
                fatal("nn_connet");
        }