.gitignore

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

# Executables
*.exe

 data/config.txt

@@ -1,9 +1,9 @@
# nng本地服务地址
# server_url=tcp://192.168.20.104:8801
server_url=tcp://192.168.20.104:7701
server_url=tcp://192.168.20.104:8801
#server_url=tcp://192.168.20.104:7701
# nng远程调用地址地址
client_url=tcp://192.168.20.104:7702
# client_url=tcp://192.168.20.10:8802
#client_url=tcp://192.168.20.104:7702
client_url=tcp://192.168.20.10:8802

# å¿ƒè·³æœåŠ¡å™¨
heart_server=tcp://192.168.20.10:5006

 device/hcnetdisk.c

@@ -247,7 +247,7 @@
    printf("Be downloading...%d %%\n", nPos);
    sleep(1);
  }
  printf("have got %d\n", nPos);
  // printf("have got %d\n", nPos);
//停止下载
  if (!NET_DVR_StopGetFile(hPlayback))
  {
@@ -255,7 +255,7 @@
    bRes = -1;
    return bRes;
  }
  printf("%s\n", srcfile);
  // printf("%s\n", srcfile);
  if (nPos < 0 || nPos > 100)
  {
    printf("download err [%d]\n", NET_DVR_GetLastError());

 device/libnetdisk.a

Binary files differ

 device/libnetdisk.so

Binary files differ

 service/netdisk_service

Binary files differ

 service/netdisk_service.c

@@ -97,18 +97,6 @@
  }
 

  // Json::Value response;
  // Json::Value payload;
  // response["code"] = rv;
  // response["msg"] = rmsg;

  // Json::Value filelist;
  // for(std::string f : files) {
  //   filelist.append(f);
  // }
  // payload["filelist"] = filelist;
  // response["payload"] = payload;

  Json::Value request;
  request["method"] = "downloadByTimeCallBack";
  Json::Value arguments;
@@ -122,8 +110,7 @@
  request["arguments"] = arguments;
  std::string str = request.toStyledString();

  std::cout << "download finished, call back" << std::endl;
  std::cout << str << std::endl;
  std::cout << "SENDING download finished\n" << str << std::endl;
  connectAndSend(remoteUrl.c_str(), strdup(str.c_str()) );
  
  return 0;
@@ -214,11 +201,11 @@
    char *buf = NULL;
    size_t sz;
    if ((rv = nng_recv(sock, &buf, &sz, NNG_FLAG_ALLOC)) == 0) {
printf("CLIENT (%s): RECEIVED \"%s\" SURVEY REQUEST\n", name, buf);
//printf("CLIENT (%s): RECEIVED \"%s\" SURVEY REQUEST\n", name, buf);
      nng_free(buf, sz);
      char response[1024];
      sprintf(response, "%s-%d", name, getpid());
printf("CLIENT (%s): SENDING SURVEY RESPONSE:%s\n", name, response);
//printf("CLIENT (%s): SENDING SURVEY RESPONSE:%s\n", name, response);
      if ((rv = nng_send(sock, response, strlen(response) + 1, 0)) != 0) {
        fatal("nng_send", rv);
      }

 service/test_client

Binary files differ

 service/test_client.c

@@ -113,7 +113,7 @@
    end["mon"] = 4;
    end["day"] = 10;
    end["hour"] = 14;
    end["min"] = 30;
    end["min"] = 40;
    end["sec"] = 0;
    arguments["end"] = end;
    

 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