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
46a7c9e6
Commit
46a7c9e6
authored
Dec 09, 2020
by
Kirill Smelkov
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
X Refine neo:// URL schem
See next patch.
parent
cf6fc795
Changes
3
Show whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
21 additions
and
21 deletions
+21
-21
go/neo/t/neotest
go/neo/t/neotest
+18
-18
go/zodb/zodbtools/help.go
go/zodb/zodbtools/help.go
+2
-2
neo/lib/connector.py
neo/lib/connector.py
+1
-1
No files found.
go/neo/t/neotest
View file @
46a7c9e6
...
@@ -496,7 +496,7 @@ GENsqlite() {
...
@@ -496,7 +496,7 @@ GENsqlite() {
NEOpylite
NEOpylite
# NOTE compression is disabled because when benchmarking server latency
# NOTE compression is disabled because when benchmarking server latency
# we do not want the time client(s) take to decompress data to interfere.
# we do not want the time client(s) take to decompress data to interfere.
${
dataset
}
_gen_data neo://
$
neocluster
@
$Mbind
?compress
=
false
$dataset_size
${
dataset
}
_gen_data neo://
$
Mbind
/
$neocluster
?compress
=
false
$dataset_size
xneoctl
set
cluster stopping
xneoctl
set
cluster stopping
wait
# XXX fragile - won't work if there are children spawned outside
wait
# XXX fragile - won't work if there are children spawned outside
sync
sync
...
@@ -509,7 +509,7 @@ GENsql() {
...
@@ -509,7 +509,7 @@ GENsql() {
echo
-e
'\n*** generating sql data...'
echo
-e
'\n*** generating sql data...'
NEOpysql
NEOpysql
# NOTE compression is disabled - see ^^^ (sqlite) for rationale.
# NOTE compression is disabled - see ^^^ (sqlite) for rationale.
${
dataset
}
_gen_data neo://
$
neocluster
@
$Mbind
?compress
=
false
$dataset_size
${
dataset
}
_gen_data neo://
$
Mbind
/
$neocluster
?compress
=
false
$dataset_size
xneoctl
set
cluster stopping
xneoctl
set
cluster stopping
sleep
1
# XXX fragile
sleep
1
# XXX fragile
xmysql
-e
"SHUTDOWN"
xmysql
-e
"SHUTDOWN"
...
@@ -1191,21 +1191,21 @@ zbench_local() {
...
@@ -1191,21 +1191,21 @@ zbench_local() {
# XXX save time - we show only neo/py(!log)/sqlite
# XXX save time - we show only neo/py(!log)/sqlite
#echo -e "\n*** NEO/py sqlite"
#echo -e "\n*** NEO/py sqlite"
#NEOpylite
#NEOpylite
#zbench neo://$
neocluster@$Mbind
neo/py/sqlite·P$Pneo $zhashok
#zbench neo://$
Mbind/$neocluster
neo/py/sqlite·P$Pneo $zhashok
#xneoctl set cluster stopping
#xneoctl set cluster stopping
#wait
#wait
# XXX JM asked to also have NEO/py with logging disabled
# XXX JM asked to also have NEO/py with logging disabled
echo
-e
"
\n
*** NEO/py sqlite (logging disabled)"
echo
-e
"
\n
*** NEO/py sqlite (logging disabled)"
X_NEOPY_LOG_SKIP
=
y NEOpylite
X_NEOPY_LOG_SKIP
=
y NEOpylite
zbench neo://
$
neocluster
@
$Mbind
"neo/py(!log)/sqlite·P
$Pneo
"
$zhashok
zbench neo://
$
Mbind
/
$neocluster
"neo/py(!log)/sqlite·P
$Pneo
"
$zhashok
xneoctl
set
cluster stopping
xneoctl
set
cluster stopping
wait
wait
# XXX save time - we show only neo/py(!log)/sql
# XXX save time - we show only neo/py(!log)/sql
#echo -e "\n*** NEO/py sql"
#echo -e "\n*** NEO/py sql"
#NEOpysql
#NEOpysql
#zbench neo://$
neocluster@$Mbind
neo/py/sql·P$Pneo $zhashok
#zbench neo://$
Mbind/$neocluster
neo/py/sql·P$Pneo $zhashok
#xneoctl set cluster stopping
#xneoctl set cluster stopping
#xmysql -e "SHUTDOWN"
#xmysql -e "SHUTDOWN"
#wait
#wait
...
@@ -1213,27 +1213,27 @@ zbench_local() {
...
@@ -1213,27 +1213,27 @@ zbench_local() {
# XXX JM asked to also have NEO/py with logging disabled
# XXX JM asked to also have NEO/py with logging disabled
echo
-e
"
\n
*** NEO/py sql (logging disabled)"
echo
-e
"
\n
*** NEO/py sql (logging disabled)"
X_NEOPY_LOG_SKIP
=
y NEOpysql
X_NEOPY_LOG_SKIP
=
y NEOpysql
zbench neo://
$
neocluster
@
$Mbind
"neo/py(!log)/sql·P
$Pneo
"
$zhashok
zbench neo://
$
Mbind
/
$neocluster
"neo/py(!log)/sql·P
$Pneo
"
$zhashok
xneoctl
set
cluster stopping
xneoctl
set
cluster stopping
xmysql
-e
"SHUTDOWN"
xmysql
-e
"SHUTDOWN"
wait
wait
echo
-e
"
\n
*** NEO/go fs1"
echo
-e
"
\n
*** NEO/go fs1"
NEOgofs1
NEOgofs1
zbench neo://
$
neocluster
@
$Mbind
neo/go/fs1·P1
$zhashok
zbench neo://
$
Mbind
/
$neocluster
neo/go/fs1·P1
$zhashok
xneoctl
set
cluster stopping
xneoctl
set
cluster stopping
wait
wait
echo
-e
"
\n
*** NEO/go fs1 (sha1 disabled on: storage, client)"
echo
-e
"
\n
*** NEO/go fs1 (sha1 disabled on: storage, client)"
X_NEOGO_SHA1_SKIP
=
y NEOgofs1
X_NEOGO_SHA1_SKIP
=
y NEOgofs1
X_NEOGO_SHA1_SKIP
=
y zbench_go neo://
$
neocluster
@
$Mbind
"neo/go/fs1(!sha1)·P1"
$zhashok
X_NEOGO_SHA1_SKIP
=
y zbench_go neo://
$
Mbind
/
$neocluster
"neo/go/fs1(!sha1)·P1"
$zhashok
xneoctl
set
cluster stopping
xneoctl
set
cluster stopping
wait
wait
echo
-e
"
\n
*** NEO/go sqlite"
echo
-e
"
\n
*** NEO/go sqlite"
if
[
$Pneo
==
1
]
;
then
if
[
$Pneo
==
1
]
;
then
NEOgolite
NEOgolite
zbench neo://
$
neocluster
@
$Mbind
neo/go/sqlite·P
$Pneo
$zhashok
zbench neo://
$
Mbind
/
$neocluster
@
neo/go/sqlite·P
$Pneo
$zhashok
xneoctl
set
cluster stopping
xneoctl
set
cluster stopping
wait
wait
else
else
...
@@ -1243,7 +1243,7 @@ zbench_local() {
...
@@ -1243,7 +1243,7 @@ zbench_local() {
echo
-e
"
\n
*** NEO/go sqlite (sha1 disabled on: client)"
echo
-e
"
\n
*** NEO/go sqlite (sha1 disabled on: client)"
if
[
$Pneo
==
1
]
;
then
if
[
$Pneo
==
1
]
;
then
NEOgolite
NEOgolite
X_NEOGO_SHA1_SKIP
=
y zbench_go neo://
$
neocluster
@
$Mbind
"neo/go/sqlite·P
$Pneo
"
$zhashok
X_NEOGO_SHA1_SKIP
=
y zbench_go neo://
$
Mbind
/
$neocluster
"neo/go/sqlite·P
$Pneo
"
$zhashok
xneoctl
set
cluster stopping
xneoctl
set
cluster stopping
wait
wait
else
else
...
@@ -1312,21 +1312,21 @@ zbench_cluster() {
...
@@ -1312,21 +1312,21 @@ zbench_cluster() {
# XXX save time - we show only neo/py(!log)/sqlite
# XXX save time - we show only neo/py(!log)/sqlite
#echo -e "\n*** NEO/py sqlite"
#echo -e "\n*** NEO/py sqlite"
#NEOpylite
#NEOpylite
#on $url ./neotest zbench-client neo://$
neocluster@$Mbind
neo/py/sqlite·P$Pneo $zhashok
#on $url ./neotest zbench-client neo://$
Mbind/$neocluster
neo/py/sqlite·P$Pneo $zhashok
#xneoctl set cluster stopping
#xneoctl set cluster stopping
#wait
#wait
# XXX JM asked to also have NEO/py with logging disabled
# XXX JM asked to also have NEO/py with logging disabled
echo
-e
"
\n
*** NEO/py sqlite (logging disabled)"
echo
-e
"
\n
*** NEO/py sqlite (logging disabled)"
X_NEOPY_LOG_SKIP
=
y NEOpylite
X_NEOPY_LOG_SKIP
=
y NEOpylite
on
$url
./neotest zbench-client neo://
$
neocluster
@
$Mbind
"
\\\"
neo/py(!log)/sqlite
\\\"
·P
$Pneo
"
$zhashok
on
$url
./neotest zbench-client neo://
$
Mbind
/
$neocluster
"
\\\"
neo/py(!log)/sqlite
\\\"
·P
$Pneo
"
$zhashok
xneoctl
set
cluster stopping
xneoctl
set
cluster stopping
wait
wait
# XXX save time - we show only neo/py(!log)/sql
# XXX save time - we show only neo/py(!log)/sql
#echo -e "\n*** NEO/py sql"
#echo -e "\n*** NEO/py sql"
#NEOpysql
#NEOpysql
#on $url ./neotest zbench-client neo://$
neocluster@$Mbind
neo/py/sql·P$Pneo $zhashok
#on $url ./neotest zbench-client neo://$
Mbind/$neocluster
neo/py/sql·P$Pneo $zhashok
#xneoctl set cluster stopping
#xneoctl set cluster stopping
#xmysql -e "SHUTDOWN"
#xmysql -e "SHUTDOWN"
#wait
#wait
...
@@ -1334,27 +1334,27 @@ zbench_cluster() {
...
@@ -1334,27 +1334,27 @@ zbench_cluster() {
# XXX JM asked to also have NEO/py with logging disabled
# XXX JM asked to also have NEO/py with logging disabled
echo
-e
"
\n
*** NEO/py sql (logging disabled)"
echo
-e
"
\n
*** NEO/py sql (logging disabled)"
X_NEOPY_LOG_SKIP
=
y NEOpysql
X_NEOPY_LOG_SKIP
=
y NEOpysql
on
$url
./neotest zbench-client neo://
$
neocluster
@
$Mbind
"
\\\"
neo/py(!log)/sql
\\\"
·P
$Pneo
"
$zhashok
on
$url
./neotest zbench-client neo://
$
Mbind
/
$neocluster
"
\\\"
neo/py(!log)/sql
\\\"
·P
$Pneo
"
$zhashok
xneoctl
set
cluster stopping
xneoctl
set
cluster stopping
xmysql
-e
"SHUTDOWN"
xmysql
-e
"SHUTDOWN"
wait
wait
echo
-e
"
\n
*** NEO/go fs"
echo
-e
"
\n
*** NEO/go fs"
NEOgofs1
NEOgofs1
on
$url
./neotest zbench-client neo://
$
neocluster
@
$Mbind
neo/go/fs1·P1
$zhashok
on
$url
./neotest zbench-client neo://
$
Mbind
/
$neocluster
neo/go/fs1·P1
$zhashok
xneoctl
set
cluster stopping
xneoctl
set
cluster stopping
wait
wait
echo
-e
"
\n
*** NEO/go fs1 (sha1 disabled on: storage, client)"
echo
-e
"
\n
*** NEO/go fs1 (sha1 disabled on: storage, client)"
X_NEOGO_SHA1_SKIP
=
y NEOgofs1
X_NEOGO_SHA1_SKIP
=
y NEOgofs1
on
$url
X_NEOGO_SHA1_SKIP
=
y ./neotest zbench-client
--goonly
neo://
$
neocluster
@
$Mbind
"
\\\"
neo/go/fs1(!sha1)
\\\"
·P1"
$zhashok
on
$url
X_NEOGO_SHA1_SKIP
=
y ./neotest zbench-client
--goonly
neo://
$
Mbind
/
$neocluster
"
\\\"
neo/go/fs1(!sha1)
\\\"
·P1"
$zhashok
xneoctl
set
cluster stopping
xneoctl
set
cluster stopping
wait
wait
echo
-e
"
\n
*** NEO/go sqlite"
echo
-e
"
\n
*** NEO/go sqlite"
if
[
$Pneo
==
1
]
;
then
if
[
$Pneo
==
1
]
;
then
NEOgolite
NEOgolite
on
$url
./neotest zbench-client neo://
$
neocluster
@
$Mbind
neo/go/sqlite·P
$Pneo
$zhashok
on
$url
./neotest zbench-client neo://
$
Mbind
/
$neocluster
neo/go/sqlite·P
$Pneo
$zhashok
xneoctl
set
cluster stopping
xneoctl
set
cluster stopping
wait
wait
else
else
...
@@ -1364,7 +1364,7 @@ zbench_cluster() {
...
@@ -1364,7 +1364,7 @@ zbench_cluster() {
echo
-e
"
\n
*** NEO/go sqlite (sha1 disabled on: client)"
echo
-e
"
\n
*** NEO/go sqlite (sha1 disabled on: client)"
if
[
$Pneo
==
1
]
;
then
if
[
$Pneo
==
1
]
;
then
NEOgolite
NEOgolite
on
$url
X_NEOGO_SHA1_SKIP
=
y ./neotest zbench-client
--goonly
neo://
$
neocluster
@
$Mbind
"
\\\"
neo/go/sqlite
\\\"
·P
$Pneo
"
$zhashok
on
$url
X_NEOGO_SHA1_SKIP
=
y ./neotest zbench-client
--goonly
neo://
$
Mbind
/
$neocluster
"
\\\"
neo/go/sqlite
\\\"
·P
$Pneo
"
$zhashok
xneoctl
set
cluster stopping
xneoctl
set
cluster stopping
wait
wait
else
else
...
...
go/zodb/zodbtools/help.go
View file @
46a7c9e6
// Copyright (C) 2017-20
19
Nexedi SA and Contributors.
// Copyright (C) 2017-20
20
Nexedi SA and Contributors.
// Kirill Smelkov <kirr@nexedi.com>
// Kirill Smelkov <kirr@nexedi.com>
//
//
// This program is free software: you can Use, Study, Modify and Redistribute
// This program is free software: you can Use, Study, Modify and Redistribute
...
@@ -41,7 +41,7 @@ and using path to that file with zconfig:// schema:
...
@@ -41,7 +41,7 @@ and using path to that file with zconfig:// schema:
There are also following simpler ways:
There are also following simpler ways:
- neo://<
db>@<master
> for a NEO database
- neo://<
master>/<db
> for a NEO database
- zeo://<host>:<port> for a ZEO database
- zeo://<host>:<port> for a ZEO database
- /path/to/file for a FileStorage database
- /path/to/file for a FileStorage database
...
...
neo/lib/connector.py
View file @
46a7c9e6
...
@@ -291,7 +291,7 @@ class _SSLHandshake(_SSL):
...
@@ -291,7 +291,7 @@ class _SSLHandshake(_SSL):
# non-SSL connections as soon as possible, by checking the first
# non-SSL connections as soon as possible, by checking the first
# byte. It even does nothing before receiving a full TLSPlaintext
# byte. It even does nothing before receiving a full TLSPlaintext
# frame (5 bytes).
# frame (5 bytes).
# The NEO protocol is such that a client connection is always the
# The NEO protocol is such that a client connection is always the
NOTE
# first to send a packet, as soon as the connection is established,
# first to send a packet, as soon as the connection is established,
# and without waiting that the protocol versions are checked.
# and without waiting that the protocol versions are checked.
# So in practice, non-SSL connection to SSL would never hang, but
# So in practice, non-SSL connection to SSL would never hang, but
...
...
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