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
bde6097c
Commit
bde6097c
authored
Feb 19, 2020
by
Kirill Smelkov
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
.
parent
1ce70454
Changes
1
Show whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
4 additions
and
4 deletions
+4
-4
wcfs/client/wcfs_watchlink.cpp
wcfs/client/wcfs_watchlink.cpp
+4
-4
No files found.
wcfs/client/wcfs_watchlink.cpp
View file @
bde6097c
...
...
@@ -123,7 +123,7 @@ error _WatchLink::close() {
// _serveRX receives messages from ._f and dispatches them according to streamID.
error
_WatchLink
::
_serveRX
(
context
::
Context
ctx
)
{
// XXX error -> where ?
_WatchLink
&
wlink
=
*
this
;
xerr
::
Contextf
E
(
"
wlink X: serve rx"
);
// XXX +wlink details
xerr
::
Contextf
E
(
"
%s: serve rx"
,
v
(
wlink
));
// when finishing - wakeup everyone waiting for rx
defer
([
&
]()
{
...
...
@@ -253,7 +253,7 @@ error _WatchLink::_write(const string &pkt) {
// XXX -> reply | None when EOF
pair
<
string
,
error
>
_WatchLink
::
sendReq
(
context
::
Context
ctx
,
const
string
&
req
)
{
_WatchLink
*
wlink
=
this
;
xerr
::
Contextf
E
(
"
wlink X: sendReq"
);
// XXX wlink details
xerr
::
Contextf
E
(
"
%s: sendReq"
,
v
(
wlink
));
//printf("wlink sendReq '%s'\n", v(req));
...
...
@@ -321,7 +321,7 @@ tuple</*rxq*/chan<rxPkt>, error> _WatchLink::_sendReq(context::Context ctx, cons
// XXX document EOF. XXX -> no EOF here - only ErrUnexpectedEOF
error
_WatchLink
::
replyReq
(
context
::
Context
ctx
,
const
PinReq
*
req
,
const
string
&
answer
)
{
_WatchLink
*
wlink
=
this
;
xerr
::
Contextf
E
(
"
wlink X: replyReq"
);
// XXX +wlink details
xerr
::
Contextf
E
(
"
%s: replyReq"
,
v
(
wlink
));
//print('C: reply %s <- %r ...' % (req, answer))
wlink
->
_rxmu
.
lock
();
...
...
@@ -351,7 +351,7 @@ error _WatchLink::replyReq(context::Context ctx, const PinReq *req, const string
static
error
_parsePinReq
(
PinReq
*
pin
,
const
rxPkt
*
pkt
);
error
_WatchLink
::
recvReq
(
context
::
Context
ctx
,
PinReq
*
prx
)
{
_WatchLink
&
wlink
=
*
this
;
xerr
::
Contextf
E
(
"
wlink X: recvReq"
);
// XXX +wlink details
xerr
::
Contextf
E
(
"
%s: recvReq"
,
v
(
wlink
));
rxPkt
pkt
;
bool
ok
;
...
...
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