Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
M
mobject-store
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
13
Issues
13
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
sds
mobject-store
Commits
bbf0ca8d
Commit
bbf0ca8d
authored
Dec 07, 2017
by
Matthieu Dorier
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
moved printer into new directory
parent
ec622820
Changes
6
Hide whitespace changes
Inline
Side-by-side
Showing
6 changed files
with
23 additions
and
17 deletions
+23
-17
src/Makefile.subdir
src/Makefile.subdir
+4
-4
src/server/mobject-server.c
src/server/mobject-server.c
+17
-11
src/server/printer/print-read-op.c
src/server/printer/print-read-op.c
+1
-1
src/server/printer/print-read-op.h
src/server/printer/print-read-op.h
+0
-0
src/server/printer/print-write-op.c
src/server/printer/print-write-op.c
+1
-1
src/server/printer/print-write-op.h
src/server/printer/print-write-op.h
+0
-0
No files found.
src/Makefile.subdir
View file @
bbf0ca8d
...
...
@@ -20,8 +20,8 @@ noinst_HEADERS += \
src/omap-iter/proc-omap-iter.h
\
src/rpc-types/read-op.h
\
src/rpc-types/write-op.h
\
src/server/print-read-op.h
\
src/server/print-write-op.h
\
src/server/print
er/print
-read-op.h
\
src/server/print
er/print
-write-op.h
\
src/util/buffer-union.h
\
src/util/log.h
\
src/util/utlist.h
...
...
@@ -61,8 +61,8 @@ src_server_libmobject_server_la_SOURCES = \
src/server/fake/fake-db.cpp
\
src/server/core/core-write-op.cpp
\
src/server/core/core-read-op.cpp
\
src/server/print-write-op.c
\
src/server/print-read-op.c
src/server/print
er/print
-write-op.c
\
src/server/print
er/print
-read-op.c
src_server_libmobject_server_la_CPPFLAGS
=
${AM_CPPFLAGS}
${SERVER_CPPFLAGS}
src_server_libmobject_server_la_CFLAGS
=
${AM_CFLAGS}
${SERVER_CFLAGS}
src_server_libmobject_server_la_LIBADD
=
src/omap-iter/libomap-iter.la
\
...
...
src/server/mobject-server.c
View file @
bbf0ca8d
...
...
@@ -4,6 +4,8 @@
* See COPYRIGHT in top-level directory.
*/
//#define FAKE_CPP_SERVER
#include <assert.h>
#include <mpi.h>
#include <abt.h>
...
...
@@ -22,10 +24,13 @@
#include "src/io-chain/write-op-impl.h"
#include "src/io-chain/read-op-impl.h"
#include "src/server/visitor-args.h"
//#include "src/server/fake/fake-write-op.h"
//#include "src/server/fake/fake-write-op.h"
#ifdef FAKE_CPP_SERVER
#include "src/server/fake/fake-read-op.h"
#include "src/server/fake/fake-write-op.h"
#else
#include "src/server/core/core-read-op.h"
#include "src/server/core/core-write-op.h"
#endif
struct
mobject_server_context
{
...
...
@@ -75,13 +80,6 @@ mobject_server_context_t* mobject_server_init(margo_instance_id mid, const char
ABT_mutex_create
(
&
srv_ctx
->
shutdown_mutex
);
ABT_cond_create
(
&
srv_ctx
->
shutdown_cond
);
/* TODO sds-keyval */
# if 0
kv_context
*
metadata
;
struct
bake_pool_info
*
pool_info
;
pool_info
=
bake_server_makepool
(
poolname
);
#endif
ret
=
ssg_init
(
mid
);
if
(
ret
!=
SSG_SUCCESS
)
{
...
...
@@ -133,6 +131,8 @@ mobject_server_context_t* mobject_server_init(margo_instance_id mid, const char
bake_probe_instance
(
mid
,
self_addr
,
&
(
srv_ctx
->
bake_id
));
// XXX: check return value of the above calls
/* TODO setup sds-keyval */
mobject_server_is_initialized
=
1
;
return
srv_ctx
;
...
...
@@ -231,8 +231,11 @@ static hg_return_t mobject_write_op_ult(hg_handle_t h)
/* Execute the operation chain */
//print_write_op(in.write_op, in.object_name);
//fake_write_op(in.write_op, &vargs);
#ifdef FAKE_CPP_SERVER
fake_write_op
(
in
.
write_op
,
&
vargs
);
#else
core_write_op
(
in
.
write_op
,
&
vargs
);
#endif
// set the return value of the RPC
out
.
ret
=
0
;
...
...
@@ -277,8 +280,11 @@ static hg_return_t mobject_read_op_ult(hg_handle_t h)
/* Compute the result. */
//print_read_op(in.read_op, in.object_name);
//fake_read_op(in.read_op, &vargs);
#ifdef FAKE_CPP_SERVER
fake_read_op
(
in
.
read_op
,
&
vargs
);
#else
core_read_op
(
in
.
read_op
,
&
vargs
);
#endif
out
.
responses
=
resp
;
...
...
src/server/print-read-op.c
→
src/server/print
er/print
-read-op.c
View file @
bbf0ca8d
...
...
@@ -2,7 +2,7 @@
#include "src/io-chain/read-op-visitor.h"
#include "src/io-chain/read-resp-impl.h"
#include "src/omap-iter/omap-iter-impl.h"
#include "src/server/print-read-op.h"
#include "src/server/print
er/print
-read-op.h"
static
void
read_op_printer_begin
(
void
*
);
static
void
read_op_printer_stat
(
void
*
,
uint64_t
*
,
time_t
*
,
int
*
);
...
...
src/server/print-read-op.h
→
src/server/print
er/print
-read-op.h
View file @
bbf0ca8d
File moved
src/server/print-write-op.c
→
src/server/print
er/print
-write-op.c
View file @
bbf0ca8d
#include <stdio.h>
#include "src/server/print-write-op.h"
#include "src/server/print
er/print
-write-op.h"
#include "src/io-chain/write-op-visitor.h"
static
void
write_op_printer_begin
(
void
*
);
...
...
src/server/print-write-op.h
→
src/server/print
er/print
-write-op.h
View file @
bbf0ca8d
File moved
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