usr/block_server/local_server.c

64     errval_t err;
70                                   errval_t err,
74     pa->err = err;
88     errval_t err = SYS_ERR_OK;
105         err = bulk_channel_assign_pool(&block_server->tx_chan, pool, cont);
108         err = bulk_channel_assign_pool(&block_server->rx_chan, pool, cont);
111     if (err_is_fail(err)) {
112         return err;
120     err = arg->err;
123     return err;
140     errval_t err;
145         err = block_net_write(block_server, 1, &buffer, meta, BULK_CONT_NOP);
146         if (err_is_fail(err)) {
147             debug_printf("ERROR: block net write. %s", err_getstring(err));
150         err = block_storage_write(bs->block_id, buffer->address);
151         if (err_is_fail(err)) {
154         err = bulk_channel_pass(channel, buffer, meta,
156         if (err_is_fail(err)) {
157             DEBUG_ERR(err, "failed to pass the buffer back");
159         send_status_reply(local_server.binding, err, bs->req_id,
207                               errval_t err,
213     if (err_is_fail(err)) {
214         DEBUG_ERR(err, "callback: Binding failed.\n");
239     enum block_net_err err;
250     errval_t err;
255     err = block_service_status__tx(req->binding, txcont, req->err, req->seqn,
257     if (err_is_fail(err)) {
258         if (err_no(err) == FLOUNDER_ERR_TX_BUSY) {
261             err = req->binding->register_send(req->binding, ws, txcont);
262             if (err_is_fail(err)) {
264                 DEBUG_ERR(err, "register_send on binding failed!");
280     req->err = error_code;
298     errval_t err;
305         err = block_net_read(block_server, start_block, count, seqn,
307         if (err_is_fail(err)) {
336         err = block_storage_read(start_block + i, buf->address);
337         if (err_is_fail(err)) {
347         err = bulk_channel_move(chan, buf, meta_data + i, BULK_CONT_NOP);
348         if (err_is_fail(err)) {
349             send_status_reply(binding, BLOCK_NET_MSG_READ, seqn, err);
365     errval_t err;
377     err = bulk_sm_ep_create_remote(&ls->rx_ep, rx_iref);
378     assert(!err_is_fail(err));
380     err = bulk_sm_ep_create_remote(&ls->tx_ep, tx_iref);
381     assert(!err_is_fail(err));
393     err = bulk_channel_bind(&ls->rx_chan,
396     if (err_is_fail(err)) {
397         DEBUG_ERR(err, "binding failed.");
400     err = bulk_channel_bind(&ls->tx_chan,
403     if (err_is_fail(err)) {
404         DEBUG_ERR(err, "binding failed.");
438 static void block_local_export_cb(void *st, errval_t err, iref_t iref)
441     if (err_is_fail(err)) {
458     errval_t err;
465     err = block_service_export(NULL, block_local_export_cb,
468     if (err_is_fail(err)) {
469         return err;
498     errval_t err = nameservice_register(BLOCK_SERVER_NAME, server_iref);
499     if (err_is_fail(err)) {
500         return err;
531     errval_t err;
533     err = bulk_channel_move(&local_server.tx_chan, buffer, meta, BULK_CONT_NOP);
534     if (err_is_fail(err)) {
535         DEBUG_ERR(err, "could not do the move");
547     errval_t err;
554     err = bulk_channel_pass(local_chan, buffer, meta, BULK_CONT_NOP);
555     if (err_is_fail(err)) {
556         DEBUG_ERR(err, "could not pass the buffer");