Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
W
wendelin.core
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
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
Joshua
wendelin.core
Commits
0ce9ff6e
Commit
0ce9ff6e
authored
Mar 03, 2020
by
Kirill Smelkov
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
.
parent
1856da8b
Changes
1
Show whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
15 additions
and
2 deletions
+15
-2
wcfs/client/wcfs.cpp
wcfs/client/wcfs.cpp
+15
-2
No files found.
wcfs/client/wcfs.cpp
View file @
0ce9ff6e
...
@@ -182,6 +182,17 @@ using std::min;
...
@@ -182,6 +182,17 @@ using std::min;
using
std
::
max
;
using
std
::
max
;
using
std
::
vector
;
using
std
::
vector
;
#define TRACE 1
#if TRACE
# define trace(format, ...) log::Debugf(format, ##__VA_ARGS__)
#else
# define trace(format, ...) do {} while (0)
#endif
// trace with op prefix taken from E.
#define etrace(format, ...) trace("%s", v(E(fmt::errorf(format, ##__VA_ARGS__))))
// wcfs::
// wcfs::
namespace
wcfs
{
namespace
wcfs
{
...
@@ -446,7 +457,7 @@ error _Conn::__pin1(PinReq *req) {
...
@@ -446,7 +457,7 @@ error _Conn::__pin1(PinReq *req) {
if
(
!
(
mmap
->
blk_start
<=
req
->
blk
&&
req
->
blk
<
mmap
->
blk_stop
()))
if
(
!
(
mmap
->
blk_start
<=
req
->
blk
&&
req
->
blk
<
mmap
->
blk_stop
()))
continue
;
// blk ∉ mmap
continue
;
// blk ∉ mmap
//trace("\tremmapblk %d @%s" % (req->blk, (v(req.at) if req.at else "head")))
trace
(
"
\t
remmapblk %d %s"
,
req
->
blk
,
(
req
->
at
==
TidHead
?
v
(
req
->
at
)
:
"@head"
));
// pin only if virtmem did not dirtied page corresponding to this block already
// pin only if virtmem did not dirtied page corresponding to this block already
// if virtmem dirtied the page - it will ask us to remmap it again after commit or abort.
// if virtmem dirtied the page - it will ask us to remmap it again after commit or abort.
...
@@ -476,7 +487,7 @@ error _Conn::__pin1(PinReq *req) {
...
@@ -476,7 +487,7 @@ error _Conn::__pin1(PinReq *req) {
if
(
err
!=
nil
)
if
(
err
!=
nil
)
return
err
;
return
err
;
//
trace("\t-> remmaped");
trace
(
"
\t
-> remmaped"
);
}
}
// update f._pinned
// update f._pinned
...
@@ -502,6 +513,8 @@ error _Conn::resync(zodb::Tid at) {
...
@@ -502,6 +513,8 @@ error _Conn::resync(zodb::Tid at) {
xerr
::
Contextf
E
(
"%s: resync -> @%s"
,
v
(
wconn
),
v
(
at
));
xerr
::
Contextf
E
(
"%s: resync -> @%s"
,
v
(
wconn
),
v
(
at
));
wconn
.
_atMu
.
RUnlock
();
wconn
.
_atMu
.
RUnlock
();
etrace
(
"..."
);
// XXX downErr -> E
// XXX downErr -> E
// XXX at ^ (increases)
// XXX at ^ (increases)
...
...
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