Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
R
re6stnet
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
2
Issues
2
List
Boards
Labels
Milestones
Merge Requests
4
Merge Requests
4
Analytics
Analytics
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Commits
Issue Boards
Open sidebar
nexedi
re6stnet
Commits
c6decc47
Commit
c6decc47
authored
May 16, 2024
by
Tom Niget
Committed by
Tom Niget
Jun 18, 2024
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
style: remove new-style class code from the Python2 days
parent
0695c66d
Changes
13
Hide whitespace changes
Inline
Side-by-side
Showing
13 changed files
with
26 additions
and
26 deletions
+26
-26
draft/re6st-geo
draft/re6st-geo
+1
-1
re6st/cache.py
re6st/cache.py
+1
-1
re6st/ctl.py
re6st/ctl.py
+7
-7
re6st/debug.py
re6st/debug.py
+2
-2
re6st/multicast.py
re6st/multicast.py
+2
-2
re6st/registry.py
re6st/registry.py
+2
-2
re6st/tests/test_end2end/test_registry_client.py
re6st/tests/test_end2end/test_registry_client.py
+1
-1
re6st/tests/test_network/network_build.py
re6st/tests/test_network/network_build.py
+1
-1
re6st/tests/test_network/re6st_wrap.py
re6st/tests/test_network/re6st_wrap.py
+2
-2
re6st/tunnel.py
re6st/tunnel.py
+3
-3
re6st/upnpigd.py
re6st/upnpigd.py
+1
-1
re6st/utils.py
re6st/utils.py
+1
-1
re6st/x509.py
re6st/x509.py
+2
-2
No files found.
draft/re6st-geo
View file @
c6decc47
...
...
@@ -11,7 +11,7 @@ from re6st.registry import RegistryServer
@
apply
class
proxy
(
object
)
:
class
proxy
:
def
__init__
(
self
):
self
.
sock
=
socket
.
socket
(
socket
.
AF_INET6
,
socket
.
SOCK_DGRAM
)
...
...
re6st/cache.py
View file @
c6decc47
...
...
@@ -3,7 +3,7 @@ from itertools import chain
from
.registry
import
RegistryClient
from
.
import
utils
,
version
,
x509
class
Cache
(
object
)
:
class
Cache
:
def
__init__
(
self
,
db_path
,
registry
,
cert
:
x509
.
Cert
,
db_size
=
200
):
self
.
_prefix
=
cert
.
prefix
...
...
re6st/ctl.py
View file @
c6decc47
...
...
@@ -5,7 +5,7 @@ from . import utils
uint16
=
struct
.
Struct
(
"!H"
)
header
=
struct
.
Struct
(
"!HI"
)
class
Struct
(
object
)
:
class
Struct
:
def
__init__
(
self
,
format
,
*
args
):
if
args
:
...
...
@@ -29,7 +29,7 @@ class Struct(object):
self
.
encode
=
encode
self
.
decode
=
decode
class
Array
(
object
)
:
class
Array
:
def
__init__
(
self
,
item
):
self
.
_item
=
item
...
...
@@ -49,7 +49,7 @@ class Array(object):
r
.
append
(
x
)
return
o
,
r
class
String
(
object
)
:
class
String
:
@
staticmethod
def
encode
(
buffer
:
bytes
,
value
:
str
):
...
...
@@ -61,7 +61,7 @@ class String(object):
return
i
+
1
,
buffer
[
offset
:
i
].
decode
(
"utf-8"
)
class
Buffer
(
object
)
:
class
Buffer
:
def
__init__
(
self
):
self
.
_buf
=
bytearray
()
...
...
@@ -114,7 +114,7 @@ class Buffer(object):
struct
.
pack_into
(
self
.
_buf
,
offset
,
*
args
)
class
Packet
(
object
)
:
class
Packet
:
response_dict
=
{}
...
...
@@ -167,7 +167,7 @@ class ConnectionClosed(BabelException):
return
"connection to babeld closed (%s)"
%
self
.
args
class
Babel
(
object
)
:
class
Babel
:
_decode
=
None
...
...
@@ -295,7 +295,7 @@ class Babel(object):
pass
class
iterRoutes
(
object
)
:
class
iterRoutes
:
_waiting
=
True
...
...
re6st/debug.py
View file @
c6decc47
import
errno
,
os
,
socket
,
stat
,
threading
class
Socket
(
object
)
:
class
Socket
:
def
__init__
(
self
,
socket
):
# In case that the default timeout is not None.
...
...
@@ -44,7 +44,7 @@ class Socket(object):
return
False
class
Console
(
object
)
:
class
Console
:
def
__init__
(
self
,
path
,
pdb
):
self
.
path
=
path
...
...
re6st/multicast.py
View file @
c6decc47
...
...
@@ -43,7 +43,7 @@ freeifaddrs = libc.freeifaddrs
freeifaddrs
.
restype
=
None
freeifaddrs
.
argtypes
=
[
POINTER
(
struct_ifaddrs
)]
class
unpacker
(
object
)
:
class
unpacker
:
def
__init__
(
self
,
buf
):
self
.
_buf
=
buf
...
...
@@ -55,7 +55,7 @@ class unpacker(object):
self
.
_offset
+=
s
.
size
return
result
class
PimDm
(
object
)
:
class
PimDm
:
def
__init__
(
self
):
s_netlink
=
socket
(
AF_NETLINK
,
SOCK_RAW
,
NETLINK_ROUTE
)
...
...
re6st/registry.py
View file @
c6decc47
...
...
@@ -51,7 +51,7 @@ class HTTPError(Exception):
pass
class
RegistryServer
(
object
)
:
class
RegistryServer
:
peers
=
0
,
()
cert_duration
=
365
*
86400
...
...
@@ -795,7 +795,7 @@ class RegistryServer(object):
return
json
.
dumps
({
k
:
list
(
v
)
for
k
,
v
in
graph
.
items
()})
class
RegistryClient
(
object
)
:
class
RegistryClient
:
_hmac
=
None
user_agent
=
"re6stnet/%s, %s"
%
(
version
.
version
,
platform
.
platform
())
...
...
re6st/tests/test_end2end/test_registry_client.py
View file @
c6decc47
...
...
@@ -15,7 +15,7 @@ from re6st.tests import DEMO_PATH
DH_FILE
=
DEMO_PATH
/
"dh2048.pem"
class
DummyNode
(
object
)
:
class
DummyNode
:
"""fake node to reuse Re6stRegistry
error: node.Popen has destory method which not in subprocess.Popen
...
...
re6st/tests/test_network/network_build.py
View file @
c6decc47
...
...
@@ -50,7 +50,7 @@ class Node(nemu.Node):
if_s
.
add_v4_address
(
ip
,
prefix_len
=
prefix_len
)
return
if_s
class
NetManager
(
object
)
:
class
NetManager
:
"""contain all the nemu object created, so they can live more time"""
def
__init__
(
self
):
self
.
object
=
[]
...
...
re6st/tests/test_network/re6st_wrap.py
View file @
c6decc47
...
...
@@ -37,7 +37,7 @@ def ip_to_serial(ip6):
return
int
(
ip6
,
16
)
class
Re6stRegistry
(
object
)
:
class
Re6stRegistry
:
"""class run a re6st-registry service on a namespace"""
registry_seq
=
0
...
...
@@ -140,7 +140,7 @@ class Re6stRegistry(object):
pass
class
Re6stNode
(
object
)
:
class
Re6stNode
:
"""class run a re6stnet service on a namespace"""
node_seq
=
0
...
...
re6st/tunnel.py
View file @
c6decc47
...
...
@@ -59,7 +59,7 @@ class MultiGatewayManager(dict):
except
:
pass
class
Connection
(
object
)
:
class
Connection
:
_retry
=
0
serial
=
None
...
...
@@ -132,7 +132,7 @@ class Connection(object):
self
.
open
()
return
0
class
TunnelKiller
(
object
)
:
class
TunnelKiller
:
state
=
None
...
...
@@ -186,7 +186,7 @@ class TunnelKiller(object):
locked
=
unlocking
=
lambda
_
:
None
class
BaseTunnelManager
(
object
)
:
class
BaseTunnelManager
:
# TODO: To minimize downtime when network parameters change, we should do
# our best to not restart any process. Ideally, this list should be
...
...
re6st/upnpigd.py
View file @
c6decc47
...
...
@@ -7,7 +7,7 @@ class UPnPException(Exception):
pass
class
Forwarder
(
object
)
:
class
Forwarder
:
"""
External port is chosen randomly between 32768 & 49151 included.
"""
...
...
re6st/utils.py
View file @
c6decc47
...
...
@@ -114,7 +114,7 @@ class ArgParser(argparse.ArgumentParser):
ca /etc/re6stnet/ca.crt"""
,
**
kw
)
class
exit
(
object
)
:
class
exit
:
status
=
None
...
...
re6st/x509.py
View file @
c6decc47
...
...
@@ -84,7 +84,7 @@ class NewSessionError(Exception):
pass
class
Cert
(
object
)
:
class
Cert
:
def
__init__
(
self
,
ca
,
key
,
cert
=
None
):
self
.
ca_path
=
ca
...
...
@@ -175,7 +175,7 @@ class Cert(object):
PACKED_PROTOCOL
=
utils
.
packInteger
(
protocol
)
class
Peer
(
object
)
:
class
Peer
:
"""
UDP: A ─────────────────────────────────────────────> B
...
...
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