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
1ce70454
Commit
1ce70454
authored
Feb 19, 2020
by
Kirill Smelkov
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
.
parent
a36a24a0
Changes
3
Show whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
9 additions
and
3 deletions
+9
-3
wcfs/client/wcfs.cpp
wcfs/client/wcfs.cpp
+1
-2
wcfs/client/wcfs_watchlink.cpp
wcfs/client/wcfs_watchlink.cpp
+6
-1
wcfs/client/wcfs_watchlink.h
wcfs/client/wcfs_watchlink.h
+2
-0
No files found.
wcfs/client/wcfs.cpp
View file @
1ce70454
...
@@ -821,8 +821,7 @@ string WCFS::String() const {
...
@@ -821,8 +821,7 @@ string WCFS::String() const {
string
_Conn
::
String
()
const
{
string
_Conn
::
String
()
const
{
const
_Conn
&
wconn
=
*
this
;
const
_Conn
&
wconn
=
*
this
;
return
""
;
// XXX temp
return
fmt
::
sprintf
(
"%s: conn%d @%s"
,
v
(
wconn
.
_wc
),
7
/*XXX wconn._wlink->_f.fd()*/
,
v
(
wconn
.
at
));
//return fmt::sprintf("%s: conn%d @%s", v(wconn._wc), wconn._wlink->_f.fd(), v(wconn.at));
}
}
_Conn
::
_Conn
()
{}
_Conn
::
_Conn
()
{}
...
...
wcfs/client/wcfs_watchlink.cpp
View file @
1ce70454
...
@@ -39,6 +39,11 @@ void _WatchLink::decref() {
...
@@ -39,6 +39,11 @@ void _WatchLink::decref() {
delete
this
;
delete
this
;
}
}
string
_WatchLink
::
String
()
const
{
const
_WatchLink
&
wlink
=
*
this
;
return
fmt
::
sprintf
(
"%s: wlink%d"
,
v
(
wlink
.
_wc
),
wlink
.
_f
->
fd
());
}
// _openwatch opens new watch link on wcfs.
// _openwatch opens new watch link on wcfs.
pair
<
WatchLink
,
error
>
WCFS
::
_openwatch
()
{
pair
<
WatchLink
,
error
>
WCFS
::
_openwatch
()
{
WCFS
*
wc
=
this
;
WCFS
*
wc
=
this
;
...
@@ -91,7 +96,7 @@ error _WatchLink::closeWrite() {
...
@@ -91,7 +96,7 @@ error _WatchLink::closeWrite() {
// close closes the link.
// close closes the link.
error
_WatchLink
::
close
()
{
error
_WatchLink
::
close
()
{
_WatchLink
&
wlink
=
*
this
;
_WatchLink
&
wlink
=
*
this
;
xerr
::
Contextf
E
(
"
wlink close"
);
// XXX + wlink ID? + wcfs ID
xerr
::
Contextf
E
(
"
%s: close"
,
v
(
wlink
));
error
err
=
wlink
.
closeWrite
();
error
err
=
wlink
.
closeWrite
();
wlink
.
_serveCancel
();
wlink
.
_serveCancel
();
...
...
wcfs/client/wcfs_watchlink.h
View file @
1ce70454
...
@@ -110,6 +110,8 @@ public:
...
@@ -110,6 +110,8 @@ public:
error
recvReq
(
context
::
Context
ctx
,
PinReq
*
rx_into
);
error
recvReq
(
context
::
Context
ctx
,
PinReq
*
rx_into
);
error
replyReq
(
context
::
Context
ctx
,
const
PinReq
*
req
,
const
string
&
reply
);
error
replyReq
(
context
::
Context
ctx
,
const
PinReq
*
req
,
const
string
&
reply
);
string
String
()
const
;
private:
private:
error
_serveRX
(
context
::
Context
ctx
);
error
_serveRX
(
context
::
Context
ctx
);
tuple
<
string
,
error
>
_readline
();
tuple
<
string
,
error
>
_readline
();
...
...
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