anton-povarov

#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)

anton-povarov

package main

import (
	"encoding/binary"
	"fmt"
	"github.com/coocood/freecache"
	"github.com/davecheney/profile"
	"log"
	"math/rand"
	"runtime"

anton-povarov

package main

import (
	"fmt"
	"math/rand"
	"testing"
	"time"
)

import proto "github.com/gogo/protobuf/proto"

anton-povarov

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

anton-povarov

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

anton-povarov

package main

import (
	"io"
	"log"
	"os"
	"os/signal"
	"syscall"
	"time"