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
1
Issues
1
List
Boards
Labels
Milestones
Merge Requests
2
Merge Requests
2
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Analytics
Analytics
CI / CD
Repository
Value Stream
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
nexedi
neoppod
Commits
83d4082d
Commit
83d4082d
authored
May 08, 2018
by
Kirill Smelkov
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
.
parent
0f745d66
Changes
3
Show whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
74 additions
and
10 deletions
+74
-10
go/xcommon/xnet/lonet/lonet.go
go/xcommon/xnet/lonet/lonet.go
+33
-10
go/xcommon/xnet/lonet/lonet.py
go/xcommon/xnet/lonet/lonet.py
+20
-0
go/xcommon/xnet/lonet/registry_sqlite.go
go/xcommon/xnet/lonet/registry_sqlite.go
+21
-0
No files found.
go/xcommon/xnet/lonet/lonet.go
View file @
83d4082d
...
@@ -19,16 +19,37 @@
...
@@ -19,16 +19,37 @@
// FIXME kill dup from pipenet!
// FIXME kill dup from pipenet!
// Package lonet provides TCP network on top of localhost TCP loopback.
// Package lonet provides TCP network
simulated
on top of localhost TCP loopback.
//
//
// XXX write that several hosts could be created with different names (virtual
// For testing distributed systems it is sometimes handy to imitate network of
// address) and that port allocation is virtual too (e.g. α:1 could correspond to 127.0.0.1:4567)
// several TCP hosts. It is also handy that port allocated on Dial/Listen/Accept on
// that hosts be predictable - that would help tests to verify network events
// against expected sequence. When whole system could be imitated in 1 OS-level
// process, package lab.nexedi.com/kirr/go123/xnet/pipenet serves the task via
// providing TCP-like synchronous in-memory network of net.Pipes. However
// pipenet cannot be used for cases where tested system consists of 2 or more
// OS-level processes. This is where lonet comes into play:
//
//
// Example:
// Similarly to pipenet addresses on lonet are host:port pairs and several
// hosts could be created with different names. A host is xnet.Networker and
// so can be worked with similarly to regular TCP network with
// Dial/Listen/Accept. Host's ports allocation is predictable: ports of a host
// are contiguous integer sequence starting from 1 that are all initially free,
// and whenever autobind is requested the first free port of the host will be
// used.
//
//
// net := lonet.New("")
// Internally lonet network maintains registry of hosts so that lonet
// h1 := net.Host("abc")
// addresses could be resolved to OS-level addresses, for example α:1 and β:1
// h2 := net.Host("def")
// to 127.0.0.1:4567 and 127.0.0.1:8765, and once lonet connection is
// established it becomes served by OS-level TCP connection over loopback.
//
// XXX several networks = possible. (or document in New?)
//
// Example: TODO adjust
//
// net := lonet.New("") // XXX network name
// h1 := net.Host("abc") // XXX err
// h2 := net.Host("def") // ...
//
//
// // XXX inject 127.0.0.1 to example...
// // XXX inject 127.0.0.1 to example...
// // starts listening on address "abc:10" (which gets mapped to "127.0.0.1:xxx")
// // starts listening on address "abc:10" (which gets mapped to "127.0.0.1:xxx")
...
@@ -38,9 +59,11 @@
...
@@ -38,9 +59,11 @@
// }()
// }()
// ccli, err := h2.Dial("abc:10") // ccli will have RemoteAddr "def:10"
// ccli, err := h2.Dial("abc:10") // ccli will have RemoteAddr "def:10"
//
//
// Lonet is similar to pipenet, but since it works via OS TCP stack it could be
// Once again lonet is similar to pipenet, but since it works via OS TCP stack
// handy for testing networked application when there are several OS-level
// it could be handy for testing networked application when there are several
// processes involved.
// OS-level processes involved.
//
// See also shipped lonet.py for accessing lonet networks from Python.
package
lonet
package
lonet
/*
/*
...
...
go/xcommon/xnet/lonet/lonet.py
0 → 100644
View file @
83d4082d
# Copyright (C) 2018 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.
# TODO doc, code
go/xcommon/xnet/lonet/registry_sqlite.go
0 → 100644
View file @
83d4082d
// Copyright (C) 2018 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
lonet
// registry implemented as shared SQLite file
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