Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
N
neoppod
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Analytics
Analytics
CI / CD
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
Levin Zimmermann
neoppod
Commits
607e8e46
Commit
607e8e46
authored
6 years ago
by
Kirill Smelkov
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
.
parent
a6f6207b
Changes
26
Show whitespace changes
Inline
Side-by-side
Showing
26 changed files
with
35 additions
and
55 deletions
+35
-55
go/internal/README
go/internal/README
+2
-0
go/internal/log/log.go
go/internal/log/log.go
+1
-1
go/internal/packed/packed.go
go/internal/packed/packed.go
+0
-0
go/internal/task/task.go
go/internal/task/task.go
+2
-2
go/internal/xcontext/task/task.go
go/internal/xcontext/task/task.go
+0
-0
go/internal/xcontext/xcontext.go
go/internal/xcontext/xcontext.go
+0
-0
go/internal/xio/xio.go
go/internal/xio/xio.go
+2
-2
go/internal/xtracing/tracetest/example_test.go
go/internal/xtracing/tracetest/example_test.go
+0
-0
go/internal/xtracing/tracetest/tracetest.go
go/internal/xtracing/tracetest/tracetest.go
+0
-0
go/neo/client.go
go/neo/client.go
+3
-3
go/neo/cmd/neo/misc.go
go/neo/cmd/neo/misc.go
+1
-1
go/neo/master.go
go/neo/master.go
+4
-4
go/neo/neo.go
go/neo/neo.go
+3
-3
go/neo/neo_test.go
go/neo/neo_test.go
+1
-1
go/neo/neonet/connection.go
go/neo/neonet/connection.go
+1
-1
go/neo/neonet/connection_test.go
go/neo/neonet/connection_test.go
+1
-1
go/neo/neonet/pkt.go
go/neo/neonet/pkt.go
+1
-1
go/neo/nodetab.go
go/neo/nodetab.go
+2
-2
go/neo/proto/proto.go
go/neo/proto/proto.go
+1
-1
go/neo/server.go
go/neo/server.go
+1
-1
go/neo/storage.go
go/neo/storage.go
+4
-4
go/neo/t/tzodb.go
go/neo/t/tzodb.go
+2
-2
go/neo/t_cluster_test.go
go/neo/t_cluster_test.go
+1
-1
go/neo/t_events_test.go
go/neo/t_events_test.go
+1
-1
go/neo/util.go
go/neo/util.go
+1
-1
go/xcommon/xcommon.go
go/xcommon/xcommon.go
+0
-22
No files found.
go/internal/README
0 → 100644
View file @
607e8e46
// internal/ is a staging place for common utilities not yet sorted out
// to their proper homes.
This diff is collapsed.
Click to expand it.
go/
xcommon
/log/log.go
→
go/
internal
/log/log.go
View file @
607e8e46
...
@@ -29,7 +29,7 @@ import (
...
@@ -29,7 +29,7 @@ import (
"github.com/golang/glog"
"github.com/golang/glog"
"lab.nexedi.com/kirr/neo/go/
xcommon
/xcontext/task"
"lab.nexedi.com/kirr/neo/go/
internal
/xcontext/task"
)
)
// withTask prepends string describing current operational task stack to argv and returns it
// withTask prepends string describing current operational task stack to argv and returns it
...
...
This diff is collapsed.
Click to expand it.
go/
xcommon
/packed/packed.go
→
go/
internal
/packed/packed.go
View file @
607e8e46
File moved
This diff is collapsed.
Click to expand it.
go/
xcommon
/task/task.go
→
go/
internal
/task/task.go
View file @
607e8e46
...
@@ -24,8 +24,8 @@ import (
...
@@ -24,8 +24,8 @@ import (
"context"
"context"
"fmt"
"fmt"
taskctx
"lab.nexedi.com/kirr/neo/go/
xcommon
/xcontext/task"
taskctx
"lab.nexedi.com/kirr/neo/go/
internal
/xcontext/task"
"lab.nexedi.com/kirr/neo/go/
xcommon
/log"
"lab.nexedi.com/kirr/neo/go/
internal
/log"
)
)
// Running is syntactic sugar to push new task to operational stack, log it and
// Running is syntactic sugar to push new task to operational stack, log it and
...
...
This diff is collapsed.
Click to expand it.
go/
xcommon
/xcontext/task/task.go
→
go/
internal
/xcontext/task/task.go
View file @
607e8e46
File moved
This diff is collapsed.
Click to expand it.
go/
xcommon
/xcontext/xcontext.go
→
go/
internal
/xcontext/xcontext.go
View file @
607e8e46
File moved
This diff is collapsed.
Click to expand it.
go/
xcommon
/xio/xio.go
→
go/
internal
/xio/xio.go
View file @
607e8e46
...
@@ -24,8 +24,8 @@ import (
...
@@ -24,8 +24,8 @@ import (
"context"
"context"
"io"
"io"
"lab.nexedi.com/kirr/neo/go/
xcommon
/log"
"lab.nexedi.com/kirr/neo/go/
internal
/log"
"lab.nexedi.com/kirr/neo/go/
xcommon
/xcontext"
"lab.nexedi.com/kirr/neo/go/
internal
/xcontext"
)
)
// CloseWhenDone arranges for c to be closed either when ctx is cancelled or
// CloseWhenDone arranges for c to be closed either when ctx is cancelled or
...
...
This diff is collapsed.
Click to expand it.
go/
xcommon
/xtracing/tracetest/example_test.go
→
go/
internal
/xtracing/tracetest/example_test.go
View file @
607e8e46
File moved
This diff is collapsed.
Click to expand it.
go/
xcommon
/xtracing/tracetest/tracetest.go
→
go/
internal
/xtracing/tracetest/tracetest.go
View file @
607e8e46
File moved
This diff is collapsed.
Click to expand it.
go/neo/client.go
View file @
607e8e46
...
@@ -38,9 +38,9 @@ import (
...
@@ -38,9 +38,9 @@ import (
"lab.nexedi.com/kirr/neo/go/neo/neonet"
"lab.nexedi.com/kirr/neo/go/neo/neonet"
"lab.nexedi.com/kirr/neo/go/neo/proto"
"lab.nexedi.com/kirr/neo/go/neo/proto"
"lab.nexedi.com/kirr/neo/go/zodb"
"lab.nexedi.com/kirr/neo/go/zodb"
"lab.nexedi.com/kirr/neo/go/
xcommon
/log"
"lab.nexedi.com/kirr/neo/go/
internal
/log"
"lab.nexedi.com/kirr/neo/go/
xcommon
/task"
"lab.nexedi.com/kirr/neo/go/
internal
/task"
"lab.nexedi.com/kirr/neo/go/
xcommon
/xio"
"lab.nexedi.com/kirr/neo/go/
internal
/xio"
)
)
// Client is NEO node that talks to NEO cluster and exposes access to it via ZODB interfaces.
// Client is NEO node that talks to NEO cluster and exposes access to it via ZODB interfaces.
...
...
This diff is collapsed.
Click to expand it.
go/neo/cmd/neo/misc.go
View file @
607e8e46
...
@@ -33,7 +33,7 @@ import (
...
@@ -33,7 +33,7 @@ import (
"github.com/soheilhy/cmux"
"github.com/soheilhy/cmux"
"lab.nexedi.com/kirr/go123/xnet"
"lab.nexedi.com/kirr/go123/xnet"
"lab.nexedi.com/kirr/neo/go/
xcommon
/log"
"lab.nexedi.com/kirr/neo/go/
internal
/log"
// for http://.../debug/pprof
// for http://.../debug/pprof
...
...
This diff is collapsed.
Click to expand it.
go/neo/master.go
View file @
607e8e46
...
@@ -37,10 +37,10 @@ import (
...
@@ -37,10 +37,10 @@ import (
"lab.nexedi.com/kirr/neo/go/neo/neonet"
"lab.nexedi.com/kirr/neo/go/neo/neonet"
"lab.nexedi.com/kirr/neo/go/neo/proto"
"lab.nexedi.com/kirr/neo/go/neo/proto"
"lab.nexedi.com/kirr/neo/go/zodb"
"lab.nexedi.com/kirr/neo/go/zodb"
"lab.nexedi.com/kirr/neo/go/
xcommon
/log"
"lab.nexedi.com/kirr/neo/go/
internal
/log"
"lab.nexedi.com/kirr/neo/go/
xcommon
/task"
"lab.nexedi.com/kirr/neo/go/
internal
/task"
"lab.nexedi.com/kirr/neo/go/
xcommon
/xcontext"
"lab.nexedi.com/kirr/neo/go/
internal
/xcontext"
"lab.nexedi.com/kirr/neo/go/
xcommon
/xio"
"lab.nexedi.com/kirr/neo/go/
internal
/xio"
)
)
// Master is a node overseeing and managing how whole NEO cluster works.
// Master is a node overseeing and managing how whole NEO cluster works.
...
...
This diff is collapsed.
Click to expand it.
go/neo/neo.go
View file @
607e8e46
...
@@ -33,9 +33,9 @@ import (
...
@@ -33,9 +33,9 @@ import (
"lab.nexedi.com/kirr/go123/xerr"
"lab.nexedi.com/kirr/go123/xerr"
"lab.nexedi.com/kirr/go123/xnet"
"lab.nexedi.com/kirr/go123/xnet"
"lab.nexedi.com/kirr/neo/go/
xcommon
/log"
"lab.nexedi.com/kirr/neo/go/
internal
/log"
"lab.nexedi.com/kirr/neo/go/
xcommon
/task"
"lab.nexedi.com/kirr/neo/go/
internal
/task"
//"lab.nexedi.com/kirr/neo/go/
xcommon
/xio"
//"lab.nexedi.com/kirr/neo/go/
internal
/xio"
"lab.nexedi.com/kirr/neo/go/neo/neonet"
"lab.nexedi.com/kirr/neo/go/neo/neonet"
"lab.nexedi.com/kirr/neo/go/neo/proto"
"lab.nexedi.com/kirr/neo/go/neo/proto"
...
...
This diff is collapsed.
Click to expand it.
go/neo/neo_test.go
View file @
607e8e46
...
@@ -36,7 +36,7 @@ import (
...
@@ -36,7 +36,7 @@ import (
"lab.nexedi.com/kirr/neo/go/zodb"
"lab.nexedi.com/kirr/neo/go/zodb"
"lab.nexedi.com/kirr/neo/go/
xcommon
/xtracing/tracetest"
"lab.nexedi.com/kirr/neo/go/
internal
/xtracing/tracetest"
"lab.nexedi.com/kirr/go123/exc"
"lab.nexedi.com/kirr/go123/exc"
"lab.nexedi.com/kirr/go123/tracing"
"lab.nexedi.com/kirr/go123/tracing"
...
...
This diff is collapsed.
Click to expand it.
go/neo/neonet/connection.go
View file @
607e8e46
...
@@ -57,7 +57,7 @@ import (
...
@@ -57,7 +57,7 @@ import (
"time"
"time"
"lab.nexedi.com/kirr/neo/go/neo/proto"
"lab.nexedi.com/kirr/neo/go/neo/proto"
"lab.nexedi.com/kirr/neo/go/
xcommon
/packed"
"lab.nexedi.com/kirr/neo/go/
internal
/packed"
"github.com/someonegg/gocontainer/rbuf"
"github.com/someonegg/gocontainer/rbuf"
...
...
This diff is collapsed.
Click to expand it.
go/neo/neonet/connection_test.go
View file @
607e8e46
...
@@ -34,7 +34,7 @@ import (
...
@@ -34,7 +34,7 @@ import (
"lab.nexedi.com/kirr/go123/exc"
"lab.nexedi.com/kirr/go123/exc"
"lab.nexedi.com/kirr/go123/xerr"
"lab.nexedi.com/kirr/go123/xerr"
"lab.nexedi.com/kirr/neo/go/
xcommon
/packed"
"lab.nexedi.com/kirr/neo/go/
internal
/packed"
"lab.nexedi.com/kirr/neo/go/zodb"
"lab.nexedi.com/kirr/neo/go/zodb"
"lab.nexedi.com/kirr/neo/go/neo/proto"
"lab.nexedi.com/kirr/neo/go/neo/proto"
...
...
This diff is collapsed.
Click to expand it.
go/neo/neonet/pkt.go
View file @
607e8e46
...
@@ -29,7 +29,7 @@ import (
...
@@ -29,7 +29,7 @@ import (
"lab.nexedi.com/kirr/go123/xbytes"
"lab.nexedi.com/kirr/go123/xbytes"
"lab.nexedi.com/kirr/neo/go/neo/proto"
"lab.nexedi.com/kirr/neo/go/neo/proto"
"lab.nexedi.com/kirr/neo/go/
xcommon
/packed"
"lab.nexedi.com/kirr/neo/go/
internal
/packed"
)
)
// pktBuf is a buffer with full raw packet (header + data).
// pktBuf is a buffer with full raw packet (header + data).
...
...
This diff is collapsed.
Click to expand it.
go/neo/nodetab.go
View file @
607e8e46
...
@@ -30,8 +30,8 @@ import (
...
@@ -30,8 +30,8 @@ import (
"lab.nexedi.com/kirr/neo/go/neo/neonet"
"lab.nexedi.com/kirr/neo/go/neo/neonet"
"lab.nexedi.com/kirr/neo/go/neo/proto"
"lab.nexedi.com/kirr/neo/go/neo/proto"
"lab.nexedi.com/kirr/neo/go/
xcommon
/log"
"lab.nexedi.com/kirr/neo/go/
internal
/log"
"lab.nexedi.com/kirr/neo/go/
xcommon
/task"
"lab.nexedi.com/kirr/neo/go/
internal
/task"
)
)
// NodeTable represents known nodes in a cluster.
// NodeTable represents known nodes in a cluster.
...
...
This diff is collapsed.
Click to expand it.
go/neo/proto/proto.go
View file @
607e8e46
...
@@ -70,7 +70,7 @@ import (
...
@@ -70,7 +70,7 @@ import (
"lab.nexedi.com/kirr/neo/go/zodb"
"lab.nexedi.com/kirr/neo/go/zodb"
"lab.nexedi.com/kirr/go123/mem"
"lab.nexedi.com/kirr/go123/mem"
"lab.nexedi.com/kirr/neo/go/
xcommon
/packed"
"lab.nexedi.com/kirr/neo/go/
internal
/packed"
"encoding/binary"
"encoding/binary"
"errors"
"errors"
...
...
This diff is collapsed.
Click to expand it.
go/neo/server.go
View file @
607e8e46
...
@@ -29,7 +29,7 @@ import (
...
@@ -29,7 +29,7 @@ import (
"lab.nexedi.com/kirr/neo/go/neo/neonet"
"lab.nexedi.com/kirr/neo/go/neo/neonet"
"lab.nexedi.com/kirr/neo/go/neo/proto"
"lab.nexedi.com/kirr/neo/go/neo/proto"
"lab.nexedi.com/kirr/neo/go/
xcommon
/log"
"lab.nexedi.com/kirr/neo/go/
internal
/log"
"lab.nexedi.com/kirr/go123/xerr"
"lab.nexedi.com/kirr/go123/xerr"
)
)
...
...
This diff is collapsed.
Click to expand it.
go/neo/storage.go
View file @
607e8e46
...
@@ -33,10 +33,10 @@ import (
...
@@ -33,10 +33,10 @@ import (
"lab.nexedi.com/kirr/neo/go/neo/proto"
"lab.nexedi.com/kirr/neo/go/neo/proto"
"lab.nexedi.com/kirr/neo/go/neo/storage"
"lab.nexedi.com/kirr/neo/go/neo/storage"
"lab.nexedi.com/kirr/neo/go/zodb"
"lab.nexedi.com/kirr/neo/go/zodb"
"lab.nexedi.com/kirr/neo/go/
xcommon
/log"
"lab.nexedi.com/kirr/neo/go/
internal
/log"
"lab.nexedi.com/kirr/neo/go/
xcommon
/task"
"lab.nexedi.com/kirr/neo/go/
internal
/task"
xxcontext
"lab.nexedi.com/kirr/neo/go/
xcommon
/xcontext"
xxcontext
"lab.nexedi.com/kirr/neo/go/
internal
/xcontext"
"lab.nexedi.com/kirr/neo/go/
xcommon
/xio"
"lab.nexedi.com/kirr/neo/go/
internal
/xio"
"lab.nexedi.com/kirr/go123/xcontext"
"lab.nexedi.com/kirr/go123/xcontext"
"lab.nexedi.com/kirr/go123/xerr"
"lab.nexedi.com/kirr/go123/xerr"
...
...
This diff is collapsed.
Click to expand it.
go/neo/t/tzodb.go
View file @
607e8e46
...
@@ -42,8 +42,8 @@ import (
...
@@ -42,8 +42,8 @@ import (
"lab.nexedi.com/kirr/go123/prog"
"lab.nexedi.com/kirr/go123/prog"
"lab.nexedi.com/kirr/go123/xerr"
"lab.nexedi.com/kirr/go123/xerr"
"lab.nexedi.com/kirr/neo/go/
xcommon
/log"
"lab.nexedi.com/kirr/neo/go/
internal
/log"
"lab.nexedi.com/kirr/neo/go/
xcommon
/task"
"lab.nexedi.com/kirr/neo/go/
internal
/task"
"lab.nexedi.com/kirr/neo/go/zodb"
"lab.nexedi.com/kirr/neo/go/zodb"
_
"lab.nexedi.com/kirr/neo/go/zodb/wks"
_
"lab.nexedi.com/kirr/neo/go/zodb/wks"
...
...
This diff is collapsed.
Click to expand it.
go/neo/t_cluster_test.go
View file @
607e8e46
...
@@ -29,7 +29,7 @@ import (
...
@@ -29,7 +29,7 @@ import (
"lab.nexedi.com/kirr/go123/xnet"
"lab.nexedi.com/kirr/go123/xnet"
"lab.nexedi.com/kirr/go123/xnet/pipenet"
"lab.nexedi.com/kirr/go123/xnet/pipenet"
"lab.nexedi.com/kirr/neo/go/
xcommon
/xtracing/tracetest"
"lab.nexedi.com/kirr/neo/go/
internal
/xtracing/tracetest"
"lab.nexedi.com/kirr/neo/go/neo/storage"
"lab.nexedi.com/kirr/neo/go/neo/storage"
"lab.nexedi.com/kirr/neo/go/zodb"
"lab.nexedi.com/kirr/neo/go/zodb"
...
...
This diff is collapsed.
Click to expand it.
go/neo/t_events_test.go
View file @
607e8e46
...
@@ -25,7 +25,7 @@ import (
...
@@ -25,7 +25,7 @@ import (
"net"
"net"
"sync"
"sync"
"lab.nexedi.com/kirr/neo/go/
xcommon
/xtracing/tracetest"
"lab.nexedi.com/kirr/neo/go/
internal
/xtracing/tracetest"
"lab.nexedi.com/kirr/neo/go/neo/proto"
"lab.nexedi.com/kirr/neo/go/neo/proto"
)
)
...
...
This diff is collapsed.
Click to expand it.
go/neo/util.go
View file @
607e8e46
...
@@ -24,7 +24,7 @@ import (
...
@@ -24,7 +24,7 @@ import (
"io"
"io"
"lab.nexedi.com/kirr/neo/go/zodb"
"lab.nexedi.com/kirr/neo/go/zodb"
"lab.nexedi.com/kirr/neo/go/
xcommon
/log"
"lab.nexedi.com/kirr/neo/go/
internal
/log"
)
)
// lclose closes c and logs closing error if there was any.
// lclose closes c and logs closing error if there was any.
...
...
This diff is collapsed.
Click to expand it.
go/xcommon/xcommon.go
deleted
100644 → 0
View file @
a6f6207b
// Copyright (C) 2017 Nexedi SA and Contributors.
// Kirill Smelkov <kirr@nexedi.com>
//
// This program is free software: you can Use, Study, Modify and Redistribute
// it under the terms of the GNU General Public License version 3, or (at your
// option) any later version, as published by the Free Software Foundation.
//
// You can also Link and Combine this program with other software covered by
// the terms of any of the Free Software licenses or any of the Open Source
// Initiative approved licenses and Convey the resulting work. Corresponding
// source of such a combination shall include the source code for all other
// software used.
//
// This program is distributed WITHOUT ANY WARRANTY; without even the implied
// warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
//
// See COPYING file for full licensing terms.
// See https://www.nexedi.com/licensing for rationale and options.
// Package xcommon is a staging place for common utilities not yet sorted out
// to their proper homes.
package
xcommon
This diff is collapsed.
Click to expand it.
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment