update

wangzhengquan

2020-09-10 591aacee97f4a6486631c38a6b418e20b2c4109c

update

 .gitignore

@@ -22,7 +22,6 @@
# Compiled Static libraries
*.lai
*.la
*.lib

# Executables
*.exe

 device/libnetdisk.a

Binary files differ

 device/libnetdisk.so

Binary files differ

 service/netdisk_service

Binary files differ

 test/Makefile

@@ -19,7 +19,7 @@
include $(ROOT)/Make.defines.$(PLATFORM)


PROGS = nng/pubsub
PROGS = nng/server nng/client

build: $(PROGS)


 test/nng/bus

Binary files differ

 test/nng/bus.c

New file
@@ -0,0 +1,74 @@


#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>

#include <nng/nng.h>
#include <nng/protocol/bus0/bus.h>

void
fatal(const char *func, int rv)
{
        fprintf(stderr, "%s: %s\n", func, nng_strerror(rv));
        exit(1);
}

int
node(int argc, char **argv)
{
        nng_socket sock;
        int rv;
        size_t sz;

        if ((rv = nng_bus0_open(&sock)) != 0) {
                fatal("nng_bus0_open", rv);
        }
        if ((rv = nng_listen(sock, argv[2], NULL, 0)) != 0) {
                fatal("nng_listen", rv);
        }

        sleep(1); // wait for peers to bind
        if (argc >= 3) {
                for (int x = 3; x < argc; x++) {
                        if ((rv = nng_dial(sock, argv[x], NULL, 0)) != 0) {
                                fatal("nng_dial", rv);
                        }
                }
        }

        sleep(1); // wait for connects to establish

        // SEND
        sz = strlen(argv[1]) + 1; // '\0' too
        printf("%s: SENDING '%s' ONTO BUS\n", argv[1], argv[1]);
        if ((rv = nng_send(sock, argv[1], sz, 0)) != 0) {
                fatal("nng_send", rv);
        }

        // RECV
        for (;;) {
                char *buf = NULL;
                size_t sz;
                if ((rv = nng_recv(sock, &buf, &sz, NNG_FLAG_ALLOC)) !=0) {
                        if (rv == NNG_ETIMEDOUT) {
                                fatal("nng_recv", rv);
                        }
                }
                printf("%s: RECEIVED '%s' FROM BUS\n", argv[1], buf); 
                nng_free(buf, sz);
        }
        nng_close(sock);
        return (0);
}

int
main(int argc, char **argv)
{
        if (argc >= 3) {
                return (node(argc, argv));
        }
        fprintf(stderr, "Usage: bus <NODE_NAME> <URL> <URL> ...\n");
        return 1;
}

 test/nng/bus.sh

New file
@@ -0,0 +1,7 @@
./bus node0 ipc:///tmp/node0.ipc ipc:///tmp/node1.ipc ipc:///tmp/node2.ipc & node0=$!
./bus node1 ipc:///tmp/node1.ipc ipc:///tmp/node2.ipc ipc:///tmp/node3.ipc & node1=$!
./bus node1 ipc:///tmp/node1.ipc ipc:///tmp/node3.ipc & node1=$!
./bus node2 ipc:///tmp/node2.ipc ipc:///tmp/node3.ipc & node2=$!
./bus node3 ipc:///tmp/node3.ipc ipc:///tmp/node0.ipc & node3=$!
sleep 5
kill $node0 $node1 $node2 $node3

 test/nng/client

Binary files differ

 test/nng/client.c

New file
@@ -0,0 +1,71 @@
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <time.h>

#include <nng/nng.h>
#include <nng/protocol/reqrep0/rep.h>
#include <nng/protocol/reqrep0/req.h>

#define NODE0 "node0"
#define NODE1 "node1"
#define DATE "DATE"

void
fatal(const char *func, int rv)
{
        fprintf(stderr, "%s: %s\n", func, nng_strerror(rv));
        exit(1);
}

char *
date(void)
{
        time_t now = time(&now);
        struct tm *info = localtime(&now);
        char *text = asctime(info);
        text[strlen(text)-1] = '\0'; // remove '\n'
        return (text);
}

 
int
client(const char *url)
{
        nng_socket sock;
        int rv;
        size_t sz;
        char * buf;
        char sendbuf[512];

        if ((rv = nng_req0_open(&sock)) != 0) {
                fatal("nng_socket", rv);
        }
        if ((rv = nng_dial(sock, url, NULL, 0)) != 0) {
                fatal("nng_dial", rv);
        }
        //printf("NODE1: SENDING DATE REQUEST %s\n", DATE);
        while(true) {
            printf("say something:\n");
            scanf("%s", sendbuf);
            if ((rv = nng_send(sock, sendbuf, strlen(sendbuf)+1, 0)) != 0) {
                fatal("nng_send", rv);
            }
            if ((rv = nng_recv(sock, &buf, &sz, NNG_FLAG_ALLOC)) != 0) {
                    fatal("nng_recv", rv);
            }
            printf("NODE1: RECEIVED DATE %s\n", buf);  
            nng_free(buf, sz);
        }
        
        nng_close(sock);
        return (0);
}

int
main(const int argc, const char **argv)
{
         
    char *url = "ipc:///tmp/reqrep.ipc";
    client(url);
}

 test/nng/core

Binary files differ

 test/nng/pubsub

Binary files differ

 test/nng/server

Binary files differ

 test/nng/server.c

New file
@@ -0,0 +1,71 @@
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <time.h>

#include <nng/nng.h>
#include <nng/protocol/reqrep0/rep.h>
#include <nng/protocol/reqrep0/req.h>

#define NODE0 "node0"
#define NODE1 "node1"
#define DATE "DATE"

void
fatal(const char *func, int rv)
{
        fprintf(stderr, "%s: %s\n", func, nng_strerror(rv));
        exit(1);
}

char *
date(void)
{
        time_t now = time(&now);
        struct tm *info = localtime(&now);
        char *text = asctime(info);
        text[strlen(text)-1] = '\0'; // remove '\n'
        return (text);
}

int
server(const char *url)
{
        nng_socket sock;
        int rv;

        if ((rv = nng_rep0_open(&sock)) != 0) {
                fatal("nng_rep0_open", rv);
        }
          if ((rv = nng_listen(sock, url, NULL, 0)) != 0) {
                fatal("nng_listen", rv);
        }
        char sendbuf[512];
        for (;;) {
            char *buf = NULL;
            size_t sz;
            if ((rv = nng_recv(sock, &buf, &sz, NNG_FLAG_ALLOC)) != 0) {
                    fatal("nng_recv", rv);
            }


            printf("NODE0: RECEIVED:%s\n", buf);
            char *d = date();
            sprintf(sendbuf, "%s: %s", d, buf);
            printf("NODE0: SENDING DATE %s\n", d);
            if ((rv = nng_send(sock, sendbuf, strlen(sendbuf) + 1, 0)) != 0) {
                fatal("nng_send", rv);
            }
            nng_free(buf, sz);
        }
}

 

int
main(const int argc, const char **argv)
{
         
    char *url = "ipc:///tmp/reqrep.ipc";
    server(url);
}

 test/nng/新建文本文档.txt

New file
@@ -0,0 +1,103 @@
#include <stdlib.h>

#include <stdio.h>

#include <string.h>

#include <time.h>



#include <nng/nng.h>

#include <nng/protocol/reqrep0/rep.h>

#include <nng/protocol/reqrep0/req.h>



#define NODE0 "node0"

#define NODE1 "node1"

#define DATE "DATE"



void

fatal(const char *func, int rv)

{

        fprintf(stderr, "%s: %s\n", func, nng_strerror(rv));

        exit(1);

}



char *

date(void)

{

        time_t now = time(&now);

        struct tm *info = localtime(&now);

        char *text = asctime(info);

        text[strlen(text)-1] = '\0'; // remove '\n'

        return (text);

}



int

node0(const char *url)

{

        nng_socket sock;

        int rv;



        if ((rv = nng_rep0_open(&sock)) != 0) {

                fatal("nng_rep0_open", rv);

        }

          if ((rv = nng_listen(sock, url, NULL, 0)) != 0) {

                fatal("nng_listen", rv);

        }

        for (;;) {

                char *buf = NULL;

                size_t sz;

                if ((rv = nng_recv(sock, &buf, &sz, NNG_FLAG_ALLOC)) != 0) {

                        fatal("nng_recv", rv);

                }

                if ((sz == (strlen(DATE) + 1)) && (strcmp(DATE, buf) == 0)) {

                        printf("NODE0: RECEIVED DATE REQUEST\n");

                        char *d = date();

                        printf("NODE0: SENDING DATE %s\n", d);

                        if ((rv = nng_send(sock, d, strlen(d) + 1, 0)) != 0) {

                                fatal("nng_send", rv);

                        }

                }

                nng_free(buf, sz);

        }

}



int

node1(const char *url)

{

        nng_socket sock;

        int rv;

        size_t sz;

        char *buf = NULL;



        if ((rv = nng_req0_open(&sock)) != 0) {

                fatal("nng_socket", rv);

        }

        if ((rv = nng_dial(sock, url, NULL, 0)) != 0) {

                fatal("nng_dial", rv);

        }

        printf("NODE1: SENDING DATE REQUEST %s\n", DATE);

        if ((rv = nng_send(sock, DATE, strlen(DATE)+1, 0)) != 0) {

                fatal("nng_send", rv);

        }

        if ((rv = nng_recv(sock, &buf, &sz, NNG_FLAG_ALLOC)) != 0) {

                fatal("nng_recv", rv);

        }

        printf("NODE1: RECEIVED DATE %s\n", buf);  
        nng_free(buf, sz);

        nng_close(sock);

        return (0);

}



int

main(const int argc, const char **argv)

{

        if ((argc > 1) && (strcmp(NODE0, argv[1]) == 0))

                return (node0(argv[2]));



        if ((argc > 1) && (strcmp(NODE1, argv[1]) == 0))

                return (node1(argv[2]));



      fprintf(stderr, "Usage: reqrep %s|%s <URL> ...\n", NODE0, NODE1);

      return (1);

}





./reqrep node0 ipc:///tmp/reqrep.ipc & node0=$! && sleep 1

./reqrep node1 ipc:///tmp/reqrep.ipc