This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
#include <assert.h> | |
#include <stdio.h> | |
#include <pthread.h> | |
#include <nanomsg/nn.h> | |
#include <nanomsg/reqrep.h> | |
static char* endpoint = "inproc://test"; | |
void* thread_func(void *ctx) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
package main | |
import ( | |
"encoding/binary" | |
"fmt" | |
"github.com/coocood/freecache" | |
"github.com/davecheney/profile" | |
"log" | |
"math/rand" | |
"runtime" |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
package main | |
import ( | |
"fmt" | |
"math/rand" | |
"testing" | |
"time" | |
) | |
import proto "github.com/gogo/protobuf/proto" |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
diff --git a/plugin/unmarshal/unmarshal.go b/plugin/unmarshal/unmarshal.go | |
index ef232d0..ffafc65 100644 | |
--- a/plugin/unmarshal/unmarshal.go | |
+++ b/plugin/unmarshal/unmarshal.go | |
@@ -685,24 +685,21 @@ func (p *unmarshal) Generate(file *generator.FileDescriptor) { | |
} | |
p.atleastOne = true | |
- // Count the required fields | |
- var rfList []string |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
diff --git a/native/packet.go b/native/packet.go | |
index 6fc606e..a2609c5 100644 | |
--- a/native/packet.go | |
+++ b/native/packet.go | |
@@ -107,9 +107,31 @@ func (pr *pktReader) readAll() (buf []byte) { | |
return | |
} | |
-var skipBuf [4069]byte | |
+//var skipBuf [4069]byte |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
package main | |
import ( | |
"io" | |
"log" | |
"os" | |
"os/signal" | |
"syscall" | |
"time" |