Sebastián Pastor / EtheriosCloudConnector

Etherios Cloud Connector very first porting for mbed. Tested in an LPC1768

Etherios Cloud Connector for Embedded v2.1.0.3 library for mbed. Early porting.

This port is centered mainly in the platform code. So it should work properly with the provided examples of send_data, device_request, data_points, RCI and firmware_update (stub implementation, not a real one... yet ;-)). Filesystem is not implemented yet, and some examples might need changes.

To run, it needs the following libraries: - mbed - mbed-rtos - EthernetInterface

Find more information (and the source code!) about Etherios Cloud Connector for Embedded here: http://www.etherios.com/products/devicecloud/support/connector and in: http://www.etherios.com

private/connector_file_system.h@0:1c358ea10753, 2013-12-03 (annotated)

Committer:
spastor
Date:
Tue Dec 03 13:34:02 2013 +0000
Revision:
0:1c358ea10753
First commit

Who changed what in which revision?

UserRevisionLine numberNew contents of line
spastor 0:1c358ea10753 1 /*
spastor 0:1c358ea10753 2 * Copyright (c) 2013 Digi International Inc.,
spastor 0:1c358ea10753 3 * All rights not expressly granted are reserved.
spastor 0:1c358ea10753 4 *
spastor 0:1c358ea10753 5 * This Source Code Form is subject to the terms of the Mozilla Public
spastor 0:1c358ea10753 6 * License, v. 2.0. If a copy of the MPL was not distributed with this file,
spastor 0:1c358ea10753 7 * You can obtain one at http://mozilla.org/MPL/2.0/.
spastor 0:1c358ea10753 8 *
spastor 0:1c358ea10753 9 * Digi International Inc. 11001 Bren Road East, Minnetonka, MN 55343
spastor 0:1c358ea10753 10 * =======================================================================
spastor 0:1c358ea10753 11 */
spastor 0:1c358ea10753 12
spastor 0:1c358ea10753 13 #define FS_TRUNC_FLAG 0x01
spastor 0:1c358ea10753 14 #define FS_IS_DIR_FLAG 0x01
spastor 0:1c358ea10753 15 #define FS_IS_REG_FLAG 0x02
spastor 0:1c358ea10753 16 #define FS_IS_LARGE_FLAG 0x02
spastor 0:1c358ea10753 17 #define FS_LS_SINGLE_FILE 0x10
spastor 0:1c358ea10753 18 #define FS_ERROR_INTERNAL_FLAG 0x40
spastor 0:1c358ea10753 19 #define FS_SESSION_ERROR_CALLED 0x80
spastor 0:1c358ea10753 20
spastor 0:1c358ea10753 21 #define FS_OPCODE_BYTES 1
spastor 0:1c358ea10753 22
spastor 0:1c358ea10753 23 typedef enum
spastor 0:1c358ea10753 24 {
spastor 0:1c358ea10753 25 fs_get_request_opcode = 1,
spastor 0:1c358ea10753 26 fs_get_response_opcode,
spastor 0:1c358ea10753 27 fs_put_request_opcode,
spastor 0:1c358ea10753 28 fs_put_response_opcode,
spastor 0:1c358ea10753 29 fs_ls_request_opcode,
spastor 0:1c358ea10753 30 fs_ls_response_opcode,
spastor 0:1c358ea10753 31 fs_rm_request_opcode,
spastor 0:1c358ea10753 32 fs_rm_response_opcode,
spastor 0:1c358ea10753 33 fs_error_opcode = 200
spastor 0:1c358ea10753 34 } fs_opcode_t;
spastor 0:1c358ea10753 35
spastor 0:1c358ea10753 36 typedef enum
spastor 0:1c358ea10753 37 {
spastor 0:1c358ea10753 38 fs_state_none,
spastor 0:1c358ea10753 39 fs_state_stat,
spastor 0:1c358ea10753 40 fs_state_open,
spastor 0:1c358ea10753 41 fs_state_lseek1,
spastor 0:1c358ea10753 42 fs_state_lseek,
spastor 0:1c358ea10753 43 fs_state_readdir,
spastor 0:1c358ea10753 44 fs_state_stat_dir_entry,
spastor 0:1c358ea10753 45 fs_state_closing,
spastor 0:1c358ea10753 46 fs_state_closed
spastor 0:1c358ea10753 47 }fs_state_t;
spastor 0:1c358ea10753 48
spastor 0:1c358ea10753 49 typedef struct
spastor 0:1c358ea10753 50 {
spastor 0:1c358ea10753 51 void * user_context;
spastor 0:1c358ea10753 52 void * errnum;
spastor 0:1c358ea10753 53 } fs_user_data;
spastor 0:1c358ea10753 54
spastor 0:1c358ea10753 55 typedef struct
spastor 0:1c358ea10753 56 {
spastor 0:1c358ea10753 57 void * user_context;
spastor 0:1c358ea10753 58 void * errnum;
spastor 0:1c358ea10753 59
spastor 0:1c358ea10753 60 void * handle;
spastor 0:1c358ea10753 61
spastor 0:1c358ea10753 62 union
spastor 0:1c358ea10753 63 {
spastor 0:1c358ea10753 64 struct
spastor 0:1c358ea10753 65 {
spastor 0:1c358ea10753 66 uint32_t bytes_done;
spastor 0:1c358ea10753 67 uint32_t data_length;
spastor 0:1c358ea10753 68 connector_file_offset_t offset;
spastor 0:1c358ea10753 69 } f;
spastor 0:1c358ea10753 70 struct
spastor 0:1c358ea10753 71 {
spastor 0:1c358ea10753 72 char path[CONNECTOR_FILE_SYSTEM_MAX_PATH_LENGTH];
spastor 0:1c358ea10753 73 size_t path_len;
spastor 0:1c358ea10753 74 uint32_t last_modified;
spastor 0:1c358ea10753 75 connector_file_offset_t file_size;
spastor 0:1c358ea10753 76 connector_file_system_hash_algorithm_t hash_alg;
spastor 0:1c358ea10753 77 } d;
spastor 0:1c358ea10753 78 }data;
spastor 0:1c358ea10753 79
spastor 0:1c358ea10753 80 fs_opcode_t opcode;
spastor 0:1c358ea10753 81 connector_status_t status;
spastor 0:1c358ea10753 82 fs_state_t state;
spastor 0:1c358ea10753 83 uint8_t flags;
spastor 0:1c358ea10753 84
spastor 0:1c358ea10753 85 } fs_context_t;
spastor 0:1c358ea10753 86
spastor 0:1c358ea10753 87 #define FsIsOpen(context) (((context)!=NULL) && ((context)->state >= fs_state_open) && ((context)->state < fs_state_closed))
spastor 0:1c358ea10753 88
spastor 0:1c358ea10753 89 #define FsIsBitSet(flag, bit) (((flag) & (bit)) == (bit))
spastor 0:1c358ea10753 90 #define FsBitSet(flag, bit) ((flag) |= (bit))
spastor 0:1c358ea10753 91 #define FsBitClear(flag, bit) ((flag) &= ~(bit))
spastor 0:1c358ea10753 92
spastor 0:1c358ea10753 93 #define FsIsDir(context) FsIsBitSet(context->flags, FS_IS_DIR_FLAG)
spastor 0:1c358ea10753 94 #define FsSetDir(context) FsBitSet(context->flags, FS_IS_DIR_FLAG)
spastor 0:1c358ea10753 95 #define FsClearDir(context) FsBitClear(context->flags, FS_IS_DIR_FLAG)
spastor 0:1c358ea10753 96
spastor 0:1c358ea10753 97 #define FsIsReg(context) FsIsBitSet(context->flags, FS_IS_REG_FLAG)
spastor 0:1c358ea10753 98 #define FsSetReg(context) FsBitSet(context->flags, FS_IS_REG_FLAG)
spastor 0:1c358ea10753 99 #define FsClearReg(context) FsBitClear(context->flags, FS_IS_REG_FLAG)
spastor 0:1c358ea10753 100
spastor 0:1c358ea10753 101 #define FsNeedTrunc(context) FsIsBitSet(context->flags, FS_TRUNC_FLAG)
spastor 0:1c358ea10753 102 #define FsSetTrunc(context) FsBitSet(context->flags, FS_TRUNC_FLAG)
spastor 0:1c358ea10753 103 #define FsClearTrunc(context) FsBitClear(context->flags, FS_TRUNC_FLAG)
spastor 0:1c358ea10753 104
spastor 0:1c358ea10753 105 #define FsIsLsSingleFile(context) FsIsBitSet(context->flags, FS_LS_SINGLE_FILE)
spastor 0:1c358ea10753 106 #define FsSetLsSingleFile(context) FsBitSet(context->flags, FS_LS_SINGLE_FILE)
spastor 0:1c358ea10753 107
spastor 0:1c358ea10753 108 #define FsHasInternalError(context) FsIsBitSet(context->flags, FS_ERROR_INTERNAL_FLAG)
spastor 0:1c358ea10753 109 #define FsSetInternalError(context, error) {FsBitSet(context->flags,FS_ERROR_INTERNAL_FLAG); context->errnum=(void *)error;}
spastor 0:1c358ea10753 110
spastor 0:1c358ea10753 111 #define FsSessionErrorCalled(context) FsIsBitSet(context->flags, FS_SESSION_ERROR_CALLED)
spastor 0:1c358ea10753 112 #define FsSetSessionErrorCalled(context) FsBitSet(context->flags, FS_SESSION_ERROR_CALLED)
spastor 0:1c358ea10753 113
spastor 0:1c358ea10753 114 #define FsSetState(context, s) (context->state = s)
spastor 0:1c358ea10753 115 #define FsGetState(context) (context->state)
spastor 0:1c358ea10753 116
spastor 0:1c358ea10753 117
spastor 0:1c358ea10753 118 #define FsOperationSuccess(status, context) (status==connector_working && context->errnum==NULL)
spastor 0:1c358ea10753 119
spastor 0:1c358ea10753 120 static void fs_set_service_error(msg_service_request_t * const service_request, connector_session_error_t const session_error)
spastor 0:1c358ea10753 121 {
spastor 0:1c358ea10753 122 service_request->error_value = session_error;
spastor 0:1c358ea10753 123 service_request->service_type = msg_service_type_error;
spastor 0:1c358ea10753 124 }
spastor 0:1c358ea10753 125
spastor 0:1c358ea10753 126 static connector_status_t fs_set_abort(connector_data_t * const connector_ptr,
spastor 0:1c358ea10753 127 fs_context_t * const context,
spastor 0:1c358ea10753 128 connector_request_id_file_system_t const file_request,
spastor 0:1c358ea10753 129 connector_status_t const error_status)
spastor 0:1c358ea10753 130 {
spastor 0:1c358ea10753 131
spastor 0:1c358ea10753 132 connector_request_id_t request_id;
spastor 0:1c358ea10753 133 request_id.file_system_request = file_request;
spastor 0:1c358ea10753 134
spastor 0:1c358ea10753 135 notify_error_status(connector_ptr->callback, connector_class_id_file_system, request_id, error_status);
spastor 0:1c358ea10753 136 context->status = connector_abort;
spastor 0:1c358ea10753 137 return context->status;
spastor 0:1c358ea10753 138 }
spastor 0:1c358ea10753 139
spastor 0:1c358ea10753 140 typedef enum
spastor 0:1c358ea10753 141 {
spastor 0:1c358ea10753 142 fs_error_path_too_long,
spastor 0:1c358ea10753 143 fs_error_format,
spastor 0:1c358ea10753 144 fs_error_invalid_offset,
spastor 0:1c358ea10753 145 fs_error_invalid_hash,
spastor 0:1c358ea10753 146 fs_error_generic,
spastor 0:1c358ea10753 147 fs_error_large_file,
spastor 0:1c358ea10753 148 fs_error_session_canceled
spastor 0:1c358ea10753 149 }fs_error_internal_t;
spastor 0:1c358ea10753 150
spastor 0:1c358ea10753 151 static void fs_get_internal_error_data(connector_file_system_get_error_t * const data)
spastor 0:1c358ea10753 152 {
spastor 0:1c358ea10753 153
spastor 0:1c358ea10753 154 unsigned long int code = (unsigned long int) data->errnum;
spastor 0:1c358ea10753 155
spastor 0:1c358ea10753 156 static struct
spastor 0:1c358ea10753 157 {
spastor 0:1c358ea10753 158 char const * hint;
spastor 0:1c358ea10753 159 connector_file_system_error_t status;
spastor 0:1c358ea10753 160
spastor 0:1c358ea10753 161 } error_data[] =
spastor 0:1c358ea10753 162 {
spastor 0:1c358ea10753 163 {"Path too long", connector_file_system_out_of_memory},
spastor 0:1c358ea10753 164 {"Request format error", connector_file_system_request_format_error},
spastor 0:1c358ea10753 165 {"Invalid offset", connector_file_system_invalid_parameter},
spastor 0:1c358ea10753 166 {"Invalid hash algorithm", connector_file_system_invalid_parameter},
spastor 0:1c358ea10753 167 {"Unspecified error", connector_file_system_unspec_error},
spastor 0:1c358ea10753 168 {"Offset is too large or negative", connector_file_system_request_format_error}
spastor 0:1c358ea10753 169 };
spastor 0:1c358ea10753 170
spastor 0:1c358ea10753 171 switch(code)
spastor 0:1c358ea10753 172 {
spastor 0:1c358ea10753 173 case fs_error_path_too_long:
spastor 0:1c358ea10753 174 case fs_error_format:
spastor 0:1c358ea10753 175 case fs_error_invalid_offset:
spastor 0:1c358ea10753 176 case fs_error_invalid_hash:
spastor 0:1c358ea10753 177 case fs_error_generic:
spastor 0:1c358ea10753 178 case fs_error_large_file:
spastor 0:1c358ea10753 179 break;
spastor 0:1c358ea10753 180
spastor 0:1c358ea10753 181 default:
spastor 0:1c358ea10753 182 ASSERT(connector_false);
spastor 0:1c358ea10753 183 code = fs_error_generic;
spastor 0:1c358ea10753 184 break;
spastor 0:1c358ea10753 185 }
spastor 0:1c358ea10753 186 ASSERT(code < asizeof(error_data));
spastor 0:1c358ea10753 187
spastor 0:1c358ea10753 188 data->error_status = error_data[code].status;
spastor 0:1c358ea10753 189 data->bytes_used = MIN_VALUE(data->bytes_available, strlen(error_data[code].hint));
spastor 0:1c358ea10753 190 memcpy(data->buffer, error_data[code].hint, data->bytes_used);
spastor 0:1c358ea10753 191 }
spastor 0:1c358ea10753 192
spastor 0:1c358ea10753 193 static connector_status_t format_file_error_msg(connector_data_t * const connector_ptr,
spastor 0:1c358ea10753 194 msg_service_request_t * const service_request,
spastor 0:1c358ea10753 195 fs_context_t * const context)
spastor 0:1c358ea10753 196 {
spastor 0:1c358ea10753 197 connector_status_t status = connector_working;
spastor 0:1c358ea10753 198
spastor 0:1c358ea10753 199 if (service_request->service_type != msg_service_type_error)
spastor 0:1c358ea10753 200 {
spastor 0:1c358ea10753 201 /* 1st message so let's parse message-start packet:
spastor 0:1c358ea10753 202 *
spastor 0:1c358ea10753 203 * File System Get request format:
spastor 0:1c358ea10753 204 * ------------------------------------------------------
spastor 0:1c358ea10753 205 * | 0 | +1 | +1 | +N |
spastor 0:1c358ea10753 206 * ------------------------------------------------------
spastor 0:1c358ea10753 207 * | Opcode | Error code | Error Hint Length | Error hint |
spastor 0:1c358ea10753 208 * ------------------------------------------------------
spastor 0:1c358ea10753 209 *
spastor 0:1c358ea10753 210 */
spastor 0:1c358ea10753 211 enum {
spastor 0:1c358ea10753 212 field_define(fs_error_response, opcode, uint8_t),
spastor 0:1c358ea10753 213 field_define(fs_error_response, error_code, uint8_t),
spastor 0:1c358ea10753 214 field_define(fs_error_response, error_hint_len, uint8_t),
spastor 0:1c358ea10753 215 record_end(fs_error_response_header)
spastor 0:1c358ea10753 216 };
spastor 0:1c358ea10753 217
spastor 0:1c358ea10753 218 msg_service_data_t * const service_data = service_request->need_data;
spastor 0:1c358ea10753 219
spastor 0:1c358ea10753 220 size_t const header_bytes = record_bytes(fs_error_response_header);
spastor 0:1c358ea10753 221 size_t const buffer_size = MIN_VALUE(service_data->length_in_bytes - header_bytes, UCHAR_MAX);
spastor 0:1c358ea10753 222
spastor 0:1c358ea10753 223 uint8_t * fs_error_response = service_data->data_ptr;
spastor 0:1c358ea10753 224 connector_file_system_get_error_t data;
spastor 0:1c358ea10753 225
spastor 0:1c358ea10753 226 data.buffer = fs_error_response + header_bytes;
spastor 0:1c358ea10753 227 data.errnum = context->errnum;
spastor 0:1c358ea10753 228 data.bytes_available = buffer_size;
spastor 0:1c358ea10753 229 data.bytes_used = 0;
spastor 0:1c358ea10753 230
spastor 0:1c358ea10753 231 if (FsHasInternalError(context))
spastor 0:1c358ea10753 232 {
spastor 0:1c358ea10753 233 fs_get_internal_error_data(&data);
spastor 0:1c358ea10753 234 }
spastor 0:1c358ea10753 235 else
spastor 0:1c358ea10753 236 {
spastor 0:1c358ea10753 237 connector_request_id_t request_id;
spastor 0:1c358ea10753 238 data.user_context = context->user_context;
spastor 0:1c358ea10753 239 request_id.file_system_request = connector_request_id_file_system_get_error;
spastor 0:1c358ea10753 240
spastor 0:1c358ea10753 241 status = connector_callback(connector_ptr->callback,
spastor 0:1c358ea10753 242 connector_class_id_file_system,
spastor 0:1c358ea10753 243 request_id,
spastor 0:1c358ea10753 244 &data) == connector_callback_continue ?
spastor 0:1c358ea10753 245 connector_working : connector_abort;
spastor 0:1c358ea10753 246
spastor 0:1c358ea10753 247 context->user_context = data.user_context;
spastor 0:1c358ea10753 248
spastor 0:1c358ea10753 249 if (status == connector_abort)
spastor 0:1c358ea10753 250 goto done;
spastor 0:1c358ea10753 251
spastor 0:1c358ea10753 252 if (data.bytes_used > buffer_size)
spastor 0:1c358ea10753 253 {
spastor 0:1c358ea10753 254 fs_set_abort(connector_ptr,
spastor 0:1c358ea10753 255 context,
spastor 0:1c358ea10753 256 connector_request_id_file_system_get_error,
spastor 0:1c358ea10753 257 connector_invalid_data_size);
spastor 0:1c358ea10753 258 status = connector_abort;
spastor 0:1c358ea10753 259 goto done;
spastor 0:1c358ea10753 260 }
spastor 0:1c358ea10753 261 }
spastor 0:1c358ea10753 262 message_store_u8(fs_error_response, opcode, fs_error_opcode);
spastor 0:1c358ea10753 263 /* coverity[uninit_use] */
spastor 0:1c358ea10753 264 message_store_u8(fs_error_response, error_code, (uint8_t)data.error_status);
spastor 0:1c358ea10753 265 message_store_u8(fs_error_response, error_hint_len, (uint8_t) data.bytes_used);
spastor 0:1c358ea10753 266
spastor 0:1c358ea10753 267 service_data->length_in_bytes = header_bytes + data.bytes_used;
spastor 0:1c358ea10753 268
spastor 0:1c358ea10753 269 MsgSetLastData(service_data->flags);
spastor 0:1c358ea10753 270 }
spastor 0:1c358ea10753 271
spastor 0:1c358ea10753 272 done:
spastor 0:1c358ea10753 273 return status;
spastor 0:1c358ea10753 274 }
spastor 0:1c358ea10753 275
spastor 0:1c358ea10753 276 static connector_status_t fs_call_user(connector_data_t * const connector_ptr,
spastor 0:1c358ea10753 277 msg_service_request_t * const service_request,
spastor 0:1c358ea10753 278 fs_context_t * const context,
spastor 0:1c358ea10753 279 connector_request_id_file_system_t const fs_request_id,
spastor 0:1c358ea10753 280 void * const pdata)
spastor 0:1c358ea10753 281 {
spastor 0:1c358ea10753 282 connector_status_t status = connector_working;
spastor 0:1c358ea10753 283 connector_callback_status_t callback_status;
spastor 0:1c358ea10753 284 connector_request_id_t request_id;
spastor 0:1c358ea10753 285 fs_user_data * const data = pdata;
spastor 0:1c358ea10753 286
spastor 0:1c358ea10753 287 request_id.file_system_request = fs_request_id;
spastor 0:1c358ea10753 288
spastor 0:1c358ea10753 289 data->user_context = context->user_context;
spastor 0:1c358ea10753 290 data->errnum = NULL;
spastor 0:1c358ea10753 291
spastor 0:1c358ea10753 292 callback_status = connector_callback(connector_ptr->callback,
spastor 0:1c358ea10753 293 connector_class_id_file_system,
spastor 0:1c358ea10753 294 request_id,
spastor 0:1c358ea10753 295 data);
spastor 0:1c358ea10753 296
spastor 0:1c358ea10753 297 context->user_context = data->user_context;
spastor 0:1c358ea10753 298
spastor 0:1c358ea10753 299 switch (callback_status)
spastor 0:1c358ea10753 300 {
spastor 0:1c358ea10753 301 case connector_callback_continue:
spastor 0:1c358ea10753 302 status = connector_working;
spastor 0:1c358ea10753 303 break;
spastor 0:1c358ea10753 304
spastor 0:1c358ea10753 305 case connector_callback_busy:
spastor 0:1c358ea10753 306 status = connector_pending;
spastor 0:1c358ea10753 307 break;
spastor 0:1c358ea10753 308
spastor 0:1c358ea10753 309 case connector_callback_unrecognized:
spastor 0:1c358ea10753 310 status = connector_working;
spastor 0:1c358ea10753 311 FsSetInternalError(context, fs_error_session_canceled);
spastor 0:1c358ea10753 312 fs_set_service_error(service_request, connector_session_error_cancel);
spastor 0:1c358ea10753 313 break;
spastor 0:1c358ea10753 314
spastor 0:1c358ea10753 315 case connector_callback_abort:
spastor 0:1c358ea10753 316 status = context->status = connector_abort;
spastor 0:1c358ea10753 317 break;
spastor 0:1c358ea10753 318
spastor 0:1c358ea10753 319 case connector_callback_error:
spastor 0:1c358ea10753 320 status = connector_working;
spastor 0:1c358ea10753 321 /* don't overwrite previous errno */
spastor 0:1c358ea10753 322 if (context->errnum == NULL)
spastor 0:1c358ea10753 323 {
spastor 0:1c358ea10753 324 if (data->errnum != NULL)
spastor 0:1c358ea10753 325 {
spastor 0:1c358ea10753 326 /* user returned errno */
spastor 0:1c358ea10753 327 context->errnum = data->errnum;
spastor 0:1c358ea10753 328 }
spastor 0:1c358ea10753 329 else
spastor 0:1c358ea10753 330 {
spastor 0:1c358ea10753 331 /* user returned connector_callback_error without setting errno */
spastor 0:1c358ea10753 332 FsSetInternalError(context, fs_error_generic);
spastor 0:1c358ea10753 333 }
spastor 0:1c358ea10753 334 }
spastor 0:1c358ea10753 335 break;
spastor 0:1c358ea10753 336 }
spastor 0:1c358ea10753 337
spastor 0:1c358ea10753 338 return status;
spastor 0:1c358ea10753 339 }
spastor 0:1c358ea10753 340
spastor 0:1c358ea10753 341 static size_t file_hash_size(connector_file_system_hash_algorithm_t const hash_alg)
spastor 0:1c358ea10753 342 {
spastor 0:1c358ea10753 343 size_t result;
spastor 0:1c358ea10753 344
spastor 0:1c358ea10753 345 switch(hash_alg)
spastor 0:1c358ea10753 346 {
spastor 0:1c358ea10753 347 case connector_file_system_hash_md5:
spastor 0:1c358ea10753 348 result = 16;
spastor 0:1c358ea10753 349 break;
spastor 0:1c358ea10753 350
spastor 0:1c358ea10753 351 case connector_file_system_hash_crc32:
spastor 0:1c358ea10753 352 result = 4;
spastor 0:1c358ea10753 353 break;
spastor 0:1c358ea10753 354
spastor 0:1c358ea10753 355 default:
spastor 0:1c358ea10753 356 result = 0;
spastor 0:1c358ea10753 357 }
spastor 0:1c358ea10753 358 return result;
spastor 0:1c358ea10753 359 }
spastor 0:1c358ea10753 360
spastor 0:1c358ea10753 361 static connector_status_t call_file_stat_user(connector_data_t * const connector_ptr,
spastor 0:1c358ea10753 362 msg_service_request_t * const service_request,
spastor 0:1c358ea10753 363 fs_context_t * const context,
spastor 0:1c358ea10753 364 char const * const path,
spastor 0:1c358ea10753 365 connector_file_system_hash_algorithm_t const hash_alg)
spastor 0:1c358ea10753 366 {
spastor 0:1c358ea10753 367 connector_status_t status;
spastor 0:1c358ea10753 368
spastor 0:1c358ea10753 369 connector_file_system_stat_t data;
spastor 0:1c358ea10753 370 data.path = path;
spastor 0:1c358ea10753 371 data.hash_algorithm.requested = hash_alg;
spastor 0:1c358ea10753 372
spastor 0:1c358ea10753 373 data.statbuf.file_size = 0;
spastor 0:1c358ea10753 374 data.statbuf.last_modified = 0;
spastor 0:1c358ea10753 375 data.statbuf.flags = connector_file_system_file_type_none;
spastor 0:1c358ea10753 376
spastor 0:1c358ea10753 377 status = fs_call_user(connector_ptr,
spastor 0:1c358ea10753 378 service_request,
spastor 0:1c358ea10753 379 context,
spastor 0:1c358ea10753 380 connector_request_id_file_system_stat,
spastor 0:1c358ea10753 381 &data);
spastor 0:1c358ea10753 382
spastor 0:1c358ea10753 383 if (status == connector_pending)
spastor 0:1c358ea10753 384 goto done;
spastor 0:1c358ea10753 385
spastor 0:1c358ea10753 386 if (!FsOperationSuccess(status, context))
spastor 0:1c358ea10753 387 goto done;
spastor 0:1c358ea10753 388
spastor 0:1c358ea10753 389 context->data.d.file_size = data.statbuf.file_size;
spastor 0:1c358ea10753 390 context->data.d.last_modified = data.statbuf.last_modified;
spastor 0:1c358ea10753 391
spastor 0:1c358ea10753 392 switch(data.statbuf.flags)
spastor 0:1c358ea10753 393 {
spastor 0:1c358ea10753 394 case connector_file_system_file_type_is_dir:
spastor 0:1c358ea10753 395 FsSetDir(context);
spastor 0:1c358ea10753 396 break;
spastor 0:1c358ea10753 397
spastor 0:1c358ea10753 398 case connector_file_system_file_type_is_reg:
spastor 0:1c358ea10753 399 FsSetReg(context);
spastor 0:1c358ea10753 400 break;
spastor 0:1c358ea10753 401
spastor 0:1c358ea10753 402 default:
spastor 0:1c358ea10753 403 context->flags = 0;
spastor 0:1c358ea10753 404 break;
spastor 0:1c358ea10753 405 }
spastor 0:1c358ea10753 406
spastor 0:1c358ea10753 407 switch(hash_alg)
spastor 0:1c358ea10753 408 {
spastor 0:1c358ea10753 409 case connector_file_system_hash_none:
spastor 0:1c358ea10753 410 context->data.d.hash_alg = hash_alg;
spastor 0:1c358ea10753 411 break;
spastor 0:1c358ea10753 412
spastor 0:1c358ea10753 413 case connector_file_system_hash_best:
spastor 0:1c358ea10753 414 switch(data.hash_algorithm.actual)
spastor 0:1c358ea10753 415 {
spastor 0:1c358ea10753 416 case connector_file_system_hash_md5:
spastor 0:1c358ea10753 417 case connector_file_system_hash_crc32:
spastor 0:1c358ea10753 418 context->data.d.hash_alg = data.hash_algorithm.actual;
spastor 0:1c358ea10753 419 break;
spastor 0:1c358ea10753 420
spastor 0:1c358ea10753 421 default:
spastor 0:1c358ea10753 422 context->data.d.hash_alg = connector_file_system_hash_none;
spastor 0:1c358ea10753 423 break;
spastor 0:1c358ea10753 424 }
spastor 0:1c358ea10753 425 break;
spastor 0:1c358ea10753 426
spastor 0:1c358ea10753 427 default:
spastor 0:1c358ea10753 428 if (hash_alg != data.hash_algorithm.actual)
spastor 0:1c358ea10753 429 context->data.d.hash_alg = connector_file_system_hash_none;
spastor 0:1c358ea10753 430 break;
spastor 0:1c358ea10753 431 }
spastor 0:1c358ea10753 432
spastor 0:1c358ea10753 433 if (context->data.d.hash_alg != connector_file_system_hash_none)
spastor 0:1c358ea10753 434 {
spastor 0:1c358ea10753 435 if (!FsIsDir(context) && !FsIsReg(context))
spastor 0:1c358ea10753 436 context->data.d.hash_alg = connector_file_system_hash_none;
spastor 0:1c358ea10753 437 }
spastor 0:1c358ea10753 438 done:
spastor 0:1c358ea10753 439 return status;
spastor 0:1c358ea10753 440 }
spastor 0:1c358ea10753 441
spastor 0:1c358ea10753 442 static connector_status_t call_file_stat_dir_entry_user(connector_data_t * const connector_ptr,
spastor 0:1c358ea10753 443 msg_service_request_t * const service_request,
spastor 0:1c358ea10753 444 fs_context_t * const context,
spastor 0:1c358ea10753 445 char const * const path)
spastor 0:1c358ea10753 446 {
spastor 0:1c358ea10753 447 connector_status_t status;
spastor 0:1c358ea10753 448
spastor 0:1c358ea10753 449 connector_file_system_stat_dir_entry_t data;
spastor 0:1c358ea10753 450 data.path = path;
spastor 0:1c358ea10753 451 data.statbuf.file_size = 0;
spastor 0:1c358ea10753 452 data.statbuf.last_modified = 0;
spastor 0:1c358ea10753 453 data.statbuf.flags = connector_file_system_file_type_none;
spastor 0:1c358ea10753 454
spastor 0:1c358ea10753 455 status = fs_call_user(connector_ptr,
spastor 0:1c358ea10753 456 service_request,
spastor 0:1c358ea10753 457 context,
spastor 0:1c358ea10753 458 connector_request_id_file_system_stat_dir_entry,
spastor 0:1c358ea10753 459 &data);
spastor 0:1c358ea10753 460
spastor 0:1c358ea10753 461 if (!FsOperationSuccess(status, context))
spastor 0:1c358ea10753 462 goto done;
spastor 0:1c358ea10753 463
spastor 0:1c358ea10753 464 context->data.d.file_size = data.statbuf.file_size;
spastor 0:1c358ea10753 465 context->data.d.last_modified = data.statbuf.last_modified;
spastor 0:1c358ea10753 466
spastor 0:1c358ea10753 467 switch(data.statbuf.flags)
spastor 0:1c358ea10753 468 {
spastor 0:1c358ea10753 469 case connector_file_system_file_type_is_dir:
spastor 0:1c358ea10753 470 FsSetDir(context);
spastor 0:1c358ea10753 471 break;
spastor 0:1c358ea10753 472
spastor 0:1c358ea10753 473 case connector_file_system_file_type_is_reg:
spastor 0:1c358ea10753 474 FsSetReg(context);
spastor 0:1c358ea10753 475 break;
spastor 0:1c358ea10753 476
spastor 0:1c358ea10753 477 default:
spastor 0:1c358ea10753 478 context->flags = 0;
spastor 0:1c358ea10753 479 break;
spastor 0:1c358ea10753 480 }
spastor 0:1c358ea10753 481
spastor 0:1c358ea10753 482 done:
spastor 0:1c358ea10753 483 return status;
spastor 0:1c358ea10753 484 }
spastor 0:1c358ea10753 485
spastor 0:1c358ea10753 486
spastor 0:1c358ea10753 487 static connector_status_t call_file_opendir_user(connector_data_t * const connector_ptr,
spastor 0:1c358ea10753 488 msg_service_request_t * const service_request,
spastor 0:1c358ea10753 489 fs_context_t * const context,
spastor 0:1c358ea10753 490 char const * const path)
spastor 0:1c358ea10753 491 {
spastor 0:1c358ea10753 492 connector_status_t status;
spastor 0:1c358ea10753 493 connector_file_system_opendir_t data;
spastor 0:1c358ea10753 494
spastor 0:1c358ea10753 495 data.path = path;
spastor 0:1c358ea10753 496 data.handle = NULL;
spastor 0:1c358ea10753 497
spastor 0:1c358ea10753 498 status = fs_call_user(connector_ptr,
spastor 0:1c358ea10753 499 service_request,
spastor 0:1c358ea10753 500 context,
spastor 0:1c358ea10753 501 connector_request_id_file_system_opendir,
spastor 0:1c358ea10753 502 &data);
spastor 0:1c358ea10753 503
spastor 0:1c358ea10753 504 if (status == connector_pending)
spastor 0:1c358ea10753 505 goto done;
spastor 0:1c358ea10753 506
spastor 0:1c358ea10753 507 if (FsOperationSuccess(status, context))
spastor 0:1c358ea10753 508 {
spastor 0:1c358ea10753 509 if (data.handle != NULL)
spastor 0:1c358ea10753 510 {
spastor 0:1c358ea10753 511 context->handle = data.handle;
spastor 0:1c358ea10753 512 FsSetState(context, fs_state_open);
spastor 0:1c358ea10753 513 }
spastor 0:1c358ea10753 514 else
spastor 0:1c358ea10753 515 {
spastor 0:1c358ea10753 516 status = fs_set_abort(connector_ptr,
spastor 0:1c358ea10753 517 context,
spastor 0:1c358ea10753 518 connector_request_id_file_system_opendir,
spastor 0:1c358ea10753 519 connector_invalid_data);
spastor 0:1c358ea10753 520 }
spastor 0:1c358ea10753 521 }
spastor 0:1c358ea10753 522
spastor 0:1c358ea10753 523 done:
spastor 0:1c358ea10753 524 return status;
spastor 0:1c358ea10753 525 }
spastor 0:1c358ea10753 526
spastor 0:1c358ea10753 527 /* This function is a custom implementation of GNU/Linux's non-standard strnlen() */
spastor 0:1c358ea10753 528 static int strnlen_(char const * const string, int maxlen)
spastor 0:1c358ea10753 529 {
spastor 0:1c358ea10753 530 volatile const char *e;
spastor 0:1c358ea10753 531 int n;
spastor 0:1c358ea10753 532
spastor 0:1c358ea10753 533 for (e = string, n = 0; *e && n < maxlen; e++, n++)
spastor 0:1c358ea10753 534 ;
spastor 0:1c358ea10753 535
spastor 0:1c358ea10753 536 return n;
spastor 0:1c358ea10753 537 }
spastor 0:1c358ea10753 538
spastor 0:1c358ea10753 539 static connector_status_t call_file_readdir_user(connector_data_t * const connector_ptr,
spastor 0:1c358ea10753 540 msg_service_request_t * const service_request,
spastor 0:1c358ea10753 541 fs_context_t * const context,
spastor 0:1c358ea10753 542 char * const path,
spastor 0:1c358ea10753 543 size_t const buffer_size)
spastor 0:1c358ea10753 544 {
spastor 0:1c358ea10753 545 connector_status_t status;
spastor 0:1c358ea10753 546
spastor 0:1c358ea10753 547 connector_file_system_readdir_t data;
spastor 0:1c358ea10753 548 data.handle = context->handle;
spastor 0:1c358ea10753 549 data.entry_name = path;
spastor 0:1c358ea10753 550 data.bytes_available = buffer_size;
spastor 0:1c358ea10753 551 *path = '\0';
spastor 0:1c358ea10753 552
spastor 0:1c358ea10753 553 status = fs_call_user(connector_ptr,
spastor 0:1c358ea10753 554 service_request,
spastor 0:1c358ea10753 555 context,
spastor 0:1c358ea10753 556 connector_request_id_file_system_readdir,
spastor 0:1c358ea10753 557 &data);
spastor 0:1c358ea10753 558 if (!FsOperationSuccess(status, context))
spastor 0:1c358ea10753 559 goto done;
spastor 0:1c358ea10753 560
spastor 0:1c358ea10753 561 if (path[strnlen_(path, buffer_size)] != '\0')
spastor 0:1c358ea10753 562 {
spastor 0:1c358ea10753 563 /* no NUL-character within buffer */
spastor 0:1c358ea10753 564 status = fs_set_abort(connector_ptr,
spastor 0:1c358ea10753 565 context,
spastor 0:1c358ea10753 566 connector_request_id_file_system_readdir,
spastor 0:1c358ea10753 567 connector_invalid_data_size);
spastor 0:1c358ea10753 568 }
spastor 0:1c358ea10753 569
spastor 0:1c358ea10753 570 done:
spastor 0:1c358ea10753 571 return status;
spastor 0:1c358ea10753 572 }
spastor 0:1c358ea10753 573
spastor 0:1c358ea10753 574 static connector_status_t call_file_close_user(connector_data_t * const connector_ptr,
spastor 0:1c358ea10753 575 msg_service_request_t * const service_request,
spastor 0:1c358ea10753 576 fs_context_t * const context,
spastor 0:1c358ea10753 577 connector_request_id_file_system_t const fs_request_id)
spastor 0:1c358ea10753 578 {
spastor 0:1c358ea10753 579 connector_status_t status = context->status;
spastor 0:1c358ea10753 580 connector_file_system_close_t data;
spastor 0:1c358ea10753 581
spastor 0:1c358ea10753 582 if (!FsIsOpen(context))
spastor 0:1c358ea10753 583 goto done;
spastor 0:1c358ea10753 584
spastor 0:1c358ea10753 585 data.handle = context->handle;
spastor 0:1c358ea10753 586
spastor 0:1c358ea10753 587 FsSetState(context, fs_state_closing);
spastor 0:1c358ea10753 588
spastor 0:1c358ea10753 589 status = fs_call_user(connector_ptr,
spastor 0:1c358ea10753 590 service_request,
spastor 0:1c358ea10753 591 context,
spastor 0:1c358ea10753 592 fs_request_id,
spastor 0:1c358ea10753 593 &data);
spastor 0:1c358ea10753 594
spastor 0:1c358ea10753 595 if (status == connector_pending)
spastor 0:1c358ea10753 596 goto done;
spastor 0:1c358ea10753 597
spastor 0:1c358ea10753 598 /* done with close, no matter if success or an error */
spastor 0:1c358ea10753 599 FsSetState(context, fs_state_closed);
spastor 0:1c358ea10753 600
spastor 0:1c358ea10753 601 done:
spastor 0:1c358ea10753 602 return status;
spastor 0:1c358ea10753 603 }
spastor 0:1c358ea10753 604
spastor 0:1c358ea10753 605 static connector_status_t call_file_hash_user(connector_data_t * const connector_ptr,
spastor 0:1c358ea10753 606 msg_service_request_t * const service_request,
spastor 0:1c358ea10753 607 fs_context_t * const context,
spastor 0:1c358ea10753 608 char const * const path,
spastor 0:1c358ea10753 609 uint8_t * const hash_ptr)
spastor 0:1c358ea10753 610 {
spastor 0:1c358ea10753 611 connector_status_t status = connector_working;
spastor 0:1c358ea10753 612 connector_file_system_hash_t data;
spastor 0:1c358ea10753 613
spastor 0:1c358ea10753 614 data.bytes_requested = file_hash_size(context->data.d.hash_alg);
spastor 0:1c358ea10753 615 data.path = path;
spastor 0:1c358ea10753 616 data.hash_algorithm = context->data.d.hash_alg;
spastor 0:1c358ea10753 617 data.hash_value = hash_ptr;
spastor 0:1c358ea10753 618
spastor 0:1c358ea10753 619 status = fs_call_user(connector_ptr,
spastor 0:1c358ea10753 620 service_request,
spastor 0:1c358ea10753 621 context,
spastor 0:1c358ea10753 622 connector_request_id_file_system_hash,
spastor 0:1c358ea10753 623 &data);
spastor 0:1c358ea10753 624
spastor 0:1c358ea10753 625 return status;
spastor 0:1c358ea10753 626 }
spastor 0:1c358ea10753 627
spastor 0:1c358ea10753 628 static connector_status_t call_file_open_user(connector_data_t * const connector_ptr,
spastor 0:1c358ea10753 629 msg_service_request_t * const service_request,
spastor 0:1c358ea10753 630 fs_context_t * context,
spastor 0:1c358ea10753 631 char const * const path,
spastor 0:1c358ea10753 632 int const oflag)
spastor 0:1c358ea10753 633 {
spastor 0:1c358ea10753 634 connector_status_t status;
spastor 0:1c358ea10753 635 connector_file_system_open_t data;
spastor 0:1c358ea10753 636
spastor 0:1c358ea10753 637 data.path = path;
spastor 0:1c358ea10753 638 data.oflag = oflag;
spastor 0:1c358ea10753 639 data.handle = NULL;
spastor 0:1c358ea10753 640
spastor 0:1c358ea10753 641 status = fs_call_user(connector_ptr,
spastor 0:1c358ea10753 642 service_request,
spastor 0:1c358ea10753 643 context,
spastor 0:1c358ea10753 644 connector_request_id_file_system_open,
spastor 0:1c358ea10753 645 &data);
spastor 0:1c358ea10753 646
spastor 0:1c358ea10753 647 if (status == connector_pending)
spastor 0:1c358ea10753 648 goto done;
spastor 0:1c358ea10753 649
spastor 0:1c358ea10753 650 if (FsOperationSuccess(status, context))
spastor 0:1c358ea10753 651 {
spastor 0:1c358ea10753 652 if (data.handle != NULL)
spastor 0:1c358ea10753 653 {
spastor 0:1c358ea10753 654 context->handle = data.handle;
spastor 0:1c358ea10753 655 FsSetState(context, fs_state_open);
spastor 0:1c358ea10753 656 }
spastor 0:1c358ea10753 657 else
spastor 0:1c358ea10753 658 {
spastor 0:1c358ea10753 659 status = fs_set_abort(connector_ptr,
spastor 0:1c358ea10753 660 context,
spastor 0:1c358ea10753 661 connector_request_id_file_system_open,
spastor 0:1c358ea10753 662 connector_invalid_data);
spastor 0:1c358ea10753 663 }
spastor 0:1c358ea10753 664 }
spastor 0:1c358ea10753 665
spastor 0:1c358ea10753 666 if (FsGetState(context) != fs_state_open)
spastor 0:1c358ea10753 667 FsSetState(context, fs_state_closed); /* never opened a file */
spastor 0:1c358ea10753 668
spastor 0:1c358ea10753 669 done:
spastor 0:1c358ea10753 670 return status;
spastor 0:1c358ea10753 671 }
spastor 0:1c358ea10753 672
spastor 0:1c358ea10753 673 static connector_status_t call_file_lseek_user(connector_data_t * const connector_ptr,
spastor 0:1c358ea10753 674 msg_service_request_t * const service_request,
spastor 0:1c358ea10753 675 fs_context_t * const context,
spastor 0:1c358ea10753 676 connector_file_offset_t const offset_in,
spastor 0:1c358ea10753 677 connector_file_system_seek_origin_t const origin,
spastor 0:1c358ea10753 678 connector_file_offset_t * const offset_out)
spastor 0:1c358ea10753 679 {
spastor 0:1c358ea10753 680 connector_file_system_lseek_t data;
spastor 0:1c358ea10753 681 connector_status_t status;
spastor 0:1c358ea10753 682
spastor 0:1c358ea10753 683 data.handle = context->handle;
spastor 0:1c358ea10753 684 data.requested_offset = offset_in;
spastor 0:1c358ea10753 685 data.resulting_offset = -1;
spastor 0:1c358ea10753 686 data.origin = origin;
spastor 0:1c358ea10753 687
spastor 0:1c358ea10753 688 status = fs_call_user(connector_ptr,
spastor 0:1c358ea10753 689 service_request,
spastor 0:1c358ea10753 690 context,
spastor 0:1c358ea10753 691 connector_request_id_file_system_lseek,
spastor 0:1c358ea10753 692 &data);
spastor 0:1c358ea10753 693
spastor 0:1c358ea10753 694 *offset_out = data.resulting_offset;
spastor 0:1c358ea10753 695
spastor 0:1c358ea10753 696 return status;
spastor 0:1c358ea10753 697 }
spastor 0:1c358ea10753 698
spastor 0:1c358ea10753 699
spastor 0:1c358ea10753 700 static connector_status_t call_file_ftruncate_user(connector_data_t * const connector_ptr,
spastor 0:1c358ea10753 701 msg_service_request_t * const service_request,
spastor 0:1c358ea10753 702 fs_context_t * const context)
spastor 0:1c358ea10753 703 {
spastor 0:1c358ea10753 704 connector_status_t status;
spastor 0:1c358ea10753 705 connector_file_system_truncate_t data;
spastor 0:1c358ea10753 706
spastor 0:1c358ea10753 707 data.handle = context->handle;
spastor 0:1c358ea10753 708 data.length_in_bytes = context->data.f.offset;
spastor 0:1c358ea10753 709
spastor 0:1c358ea10753 710 status = fs_call_user(connector_ptr,
spastor 0:1c358ea10753 711 service_request,
spastor 0:1c358ea10753 712 context,
spastor 0:1c358ea10753 713 connector_request_id_file_system_ftruncate,
spastor 0:1c358ea10753 714 &data);
spastor 0:1c358ea10753 715 return status;
spastor 0:1c358ea10753 716 }
spastor 0:1c358ea10753 717
spastor 0:1c358ea10753 718 static connector_status_t call_file_rm_user(connector_data_t * const connector_ptr,
spastor 0:1c358ea10753 719 msg_service_request_t * const service_request,
spastor 0:1c358ea10753 720 fs_context_t * const context,
spastor 0:1c358ea10753 721 char const * const path)
spastor 0:1c358ea10753 722 {
spastor 0:1c358ea10753 723 connector_status_t status;
spastor 0:1c358ea10753 724 connector_file_system_remove_t data;
spastor 0:1c358ea10753 725 data.path = path;
spastor 0:1c358ea10753 726
spastor 0:1c358ea10753 727 status = fs_call_user(connector_ptr,
spastor 0:1c358ea10753 728 service_request,
spastor 0:1c358ea10753 729 context,
spastor 0:1c358ea10753 730 connector_request_id_file_system_remove,
spastor 0:1c358ea10753 731 &data);
spastor 0:1c358ea10753 732 return status;
spastor 0:1c358ea10753 733 }
spastor 0:1c358ea10753 734
spastor 0:1c358ea10753 735 static connector_status_t call_file_read_user(connector_data_t * const connector_ptr,
spastor 0:1c358ea10753 736 msg_service_request_t * const service_request,
spastor 0:1c358ea10753 737 fs_context_t * const context,
spastor 0:1c358ea10753 738 void * const buffer,
spastor 0:1c358ea10753 739 size_t * const buffer_size)
spastor 0:1c358ea10753 740 {
spastor 0:1c358ea10753 741 connector_status_t status;
spastor 0:1c358ea10753 742 connector_file_system_read_t data;
spastor 0:1c358ea10753 743
spastor 0:1c358ea10753 744 data.handle = context->handle;
spastor 0:1c358ea10753 745 data.buffer = buffer;
spastor 0:1c358ea10753 746 data.bytes_available = *buffer_size;
spastor 0:1c358ea10753 747 data.bytes_used = 0;
spastor 0:1c358ea10753 748
spastor 0:1c358ea10753 749 status = fs_call_user(connector_ptr,
spastor 0:1c358ea10753 750 service_request,
spastor 0:1c358ea10753 751 context,
spastor 0:1c358ea10753 752 connector_request_id_file_system_read,
spastor 0:1c358ea10753 753 &data);
spastor 0:1c358ea10753 754
spastor 0:1c358ea10753 755 if (!FsOperationSuccess(status, context))
spastor 0:1c358ea10753 756 goto done;
spastor 0:1c358ea10753 757
spastor 0:1c358ea10753 758 if (data.bytes_used > *buffer_size)
spastor 0:1c358ea10753 759 {
spastor 0:1c358ea10753 760 status = fs_set_abort(connector_ptr,
spastor 0:1c358ea10753 761 context,
spastor 0:1c358ea10753 762 connector_request_id_file_system_read,
spastor 0:1c358ea10753 763 connector_invalid_data_size);
spastor 0:1c358ea10753 764 goto done;
spastor 0:1c358ea10753 765 }
spastor 0:1c358ea10753 766
spastor 0:1c358ea10753 767 *buffer_size = data.bytes_used;
spastor 0:1c358ea10753 768
spastor 0:1c358ea10753 769 done:
spastor 0:1c358ea10753 770 return status;
spastor 0:1c358ea10753 771 }
spastor 0:1c358ea10753 772
spastor 0:1c358ea10753 773 static connector_status_t call_file_write_user(connector_data_t * const connector_ptr,
spastor 0:1c358ea10753 774 msg_service_request_t * const service_request,
spastor 0:1c358ea10753 775 fs_context_t * const context,
spastor 0:1c358ea10753 776 void const * const buffer,
spastor 0:1c358ea10753 777 size_t * const bytes_done)
spastor 0:1c358ea10753 778 {
spastor 0:1c358ea10753 779 connector_status_t status;
spastor 0:1c358ea10753 780 connector_file_system_write_t data;
spastor 0:1c358ea10753 781
spastor 0:1c358ea10753 782 data.handle = context->handle;
spastor 0:1c358ea10753 783 data.buffer = buffer;
spastor 0:1c358ea10753 784 data.bytes_available = *bytes_done;
spastor 0:1c358ea10753 785 data.bytes_used = 0;
spastor 0:1c358ea10753 786
spastor 0:1c358ea10753 787 status = fs_call_user(connector_ptr,
spastor 0:1c358ea10753 788 service_request,
spastor 0:1c358ea10753 789 context,
spastor 0:1c358ea10753 790 connector_request_id_file_system_write,
spastor 0:1c358ea10753 791 &data);
spastor 0:1c358ea10753 792
spastor 0:1c358ea10753 793 if (!FsOperationSuccess(status, context))
spastor 0:1c358ea10753 794 goto done;
spastor 0:1c358ea10753 795
spastor 0:1c358ea10753 796
spastor 0:1c358ea10753 797 if (data.bytes_used > *bytes_done)
spastor 0:1c358ea10753 798 {
spastor 0:1c358ea10753 799 status = fs_set_abort(connector_ptr,
spastor 0:1c358ea10753 800 context,
spastor 0:1c358ea10753 801 connector_request_id_file_system_write,
spastor 0:1c358ea10753 802 connector_invalid_data_size);
spastor 0:1c358ea10753 803 goto done;
spastor 0:1c358ea10753 804 }
spastor 0:1c358ea10753 805
spastor 0:1c358ea10753 806 *bytes_done = data.bytes_used;
spastor 0:1c358ea10753 807
spastor 0:1c358ea10753 808 if (*bytes_done == 0)
spastor 0:1c358ea10753 809 {
spastor 0:1c358ea10753 810 status = connector_pending;
spastor 0:1c358ea10753 811 }
spastor 0:1c358ea10753 812
spastor 0:1c358ea10753 813 done:
spastor 0:1c358ea10753 814 return status;
spastor 0:1c358ea10753 815 }
spastor 0:1c358ea10753 816
spastor 0:1c358ea10753 817 static size_t parse_file_path(fs_context_t * const context,
spastor 0:1c358ea10753 818 void const * const path_ptr,
spastor 0:1c358ea10753 819 size_t const buffer_size)
spastor 0:1c358ea10753 820 {
spastor 0:1c358ea10753 821 char const * const path = path_ptr;
spastor 0:1c358ea10753 822 size_t path_len = strnlen_(path, buffer_size);
spastor 0:1c358ea10753 823
spastor 0:1c358ea10753 824 if (path_len == 0)
spastor 0:1c358ea10753 825 {
spastor 0:1c358ea10753 826 FsSetInternalError(context, fs_error_format);
spastor 0:1c358ea10753 827 }
spastor 0:1c358ea10753 828 else
spastor 0:1c358ea10753 829 if (path_len >= buffer_size)
spastor 0:1c358ea10753 830 {
spastor 0:1c358ea10753 831 FsSetInternalError(context, fs_error_path_too_long);
spastor 0:1c358ea10753 832 path_len = 0;
spastor 0:1c358ea10753 833 }
spastor 0:1c358ea10753 834 else
spastor 0:1c358ea10753 835 path_len++;
spastor 0:1c358ea10753 836
spastor 0:1c358ea10753 837 return path_len;
spastor 0:1c358ea10753 838 }
spastor 0:1c358ea10753 839
spastor 0:1c358ea10753 840 static size_t parse_file_get_header(fs_context_t * const context,
spastor 0:1c358ea10753 841 uint8_t const * const header_ptr,
spastor 0:1c358ea10753 842 size_t const buffer_size)
spastor 0:1c358ea10753 843 {
spastor 0:1c358ea10753 844
spastor 0:1c358ea10753 845 /* 1st message so let's parse message-start packet:
spastor 0:1c358ea10753 846 *
spastor 0:1c358ea10753 847 * File System Get request format:
spastor 0:1c358ea10753 848 * -------------------------------------
spastor 0:1c358ea10753 849 * | 0 | N | +4 | +4 |
spastor 0:1c358ea10753 850 * --------------------------------------
spastor 0:1c358ea10753 851 * | Opcode | Path | Offset | Length |
spastor 0:1c358ea10753 852 * -------------------------------------
spastor 0:1c358ea10753 853 *
spastor 0:1c358ea10753 854 */
spastor 0:1c358ea10753 855
spastor 0:1c358ea10753 856 enum fs_get_request {
spastor 0:1c358ea10753 857 field_define(fs_get_request, offset, uint32_t),
spastor 0:1c358ea10753 858 field_define(fs_get_request, length, uint32_t),
spastor 0:1c358ea10753 859 record_end(fs_get_request_header)
spastor 0:1c358ea10753 860 };
spastor 0:1c358ea10753 861 uint8_t const * fs_get_request = header_ptr + FS_OPCODE_BYTES;
spastor 0:1c358ea10753 862 size_t const header_len = record_bytes(fs_get_request_header) + FS_OPCODE_BYTES;
spastor 0:1c358ea10753 863
spastor 0:1c358ea10753 864 size_t len = parse_file_path(context, fs_get_request, buffer_size - header_len);
spastor 0:1c358ea10753 865 if (len == 0)
spastor 0:1c358ea10753 866 goto done;
spastor 0:1c358ea10753 867
spastor 0:1c358ea10753 868 fs_get_request += len;
spastor 0:1c358ea10753 869 context->data.f.offset = message_load_be32(fs_get_request, offset);
spastor 0:1c358ea10753 870 if (context->data.f.offset < 0)
spastor 0:1c358ea10753 871 {
spastor 0:1c358ea10753 872 FsSetInternalError(context, fs_error_large_file);
spastor 0:1c358ea10753 873 len = 0;
spastor 0:1c358ea10753 874 goto done;
spastor 0:1c358ea10753 875 }
spastor 0:1c358ea10753 876 context->data.f.data_length = message_load_be32(fs_get_request, length);
spastor 0:1c358ea10753 877 len += header_len;
spastor 0:1c358ea10753 878
spastor 0:1c358ea10753 879 done:
spastor 0:1c358ea10753 880 return len;
spastor 0:1c358ea10753 881 }
spastor 0:1c358ea10753 882
spastor 0:1c358ea10753 883 static connector_status_t process_file_get_request(connector_data_t * const connector_ptr,
spastor 0:1c358ea10753 884 msg_service_request_t * const service_request,
spastor 0:1c358ea10753 885 fs_context_t * const context)
spastor 0:1c358ea10753 886 {
spastor 0:1c358ea10753 887 msg_service_data_t * const service_data = service_request->have_data;
spastor 0:1c358ea10753 888 connector_status_t status = connector_working;
spastor 0:1c358ea10753 889
spastor 0:1c358ea10753 890 if (parse_file_get_header(context, service_data->data_ptr, service_data->length_in_bytes) > 0)
spastor 0:1c358ea10753 891 {
spastor 0:1c358ea10753 892 char const * path = service_data->data_ptr;
spastor 0:1c358ea10753 893 path += FS_OPCODE_BYTES;
spastor 0:1c358ea10753 894
spastor 0:1c358ea10753 895 status = call_file_open_user(connector_ptr, service_request, context, path, CONNECTOR_FILE_O_RDONLY);
spastor 0:1c358ea10753 896 }
spastor 0:1c358ea10753 897
spastor 0:1c358ea10753 898 return status;
spastor 0:1c358ea10753 899 }
spastor 0:1c358ea10753 900
spastor 0:1c358ea10753 901 static connector_status_t set_file_position(connector_data_t * const connector_ptr,
spastor 0:1c358ea10753 902 msg_service_request_t * const service_request,
spastor 0:1c358ea10753 903 fs_context_t * const context)
spastor 0:1c358ea10753 904
spastor 0:1c358ea10753 905 {
spastor 0:1c358ea10753 906 connector_status_t status = connector_working;
spastor 0:1c358ea10753 907 connector_file_offset_t ret;
spastor 0:1c358ea10753 908
spastor 0:1c358ea10753 909 /* Check that offset is inside the file
spastor 0:1c358ea10753 910 Some systems crash, when trying to set offset outside the file
spastor 0:1c358ea10753 911 */
spastor 0:1c358ea10753 912
spastor 0:1c358ea10753 913 if (FsGetState(context) < fs_state_lseek1)
spastor 0:1c358ea10753 914 {
spastor 0:1c358ea10753 915 status = call_file_lseek_user(connector_ptr, service_request, context, 0, connector_file_system_seek_end, &ret);
spastor 0:1c358ea10753 916 if (!FsOperationSuccess(status, context))
spastor 0:1c358ea10753 917 goto done;
spastor 0:1c358ea10753 918
spastor 0:1c358ea10753 919 if (ret < context->data.f.offset)
spastor 0:1c358ea10753 920 {
spastor 0:1c358ea10753 921 ret = -1;
spastor 0:1c358ea10753 922 FsSetInternalError(context, fs_error_invalid_offset);
spastor 0:1c358ea10753 923 goto done;
spastor 0:1c358ea10753 924 }
spastor 0:1c358ea10753 925
spastor 0:1c358ea10753 926 FsSetState(context, fs_state_lseek1);
spastor 0:1c358ea10753 927 status = call_file_lseek_user(connector_ptr, service_request, context, context->data.f.offset, connector_file_system_seek_set, &ret);
spastor 0:1c358ea10753 928 if (FsOperationSuccess(status, context) && ret == -1)
spastor 0:1c358ea10753 929 {
spastor 0:1c358ea10753 930 FsSetInternalError(context, fs_error_invalid_offset);
spastor 0:1c358ea10753 931 }
spastor 0:1c358ea10753 932 }
spastor 0:1c358ea10753 933 done:
spastor 0:1c358ea10753 934 return status;
spastor 0:1c358ea10753 935 }
spastor 0:1c358ea10753 936
spastor 0:1c358ea10753 937 static connector_status_t process_get_close(connector_data_t * const connector_ptr,
spastor 0:1c358ea10753 938 msg_service_request_t * const service_request,
spastor 0:1c358ea10753 939 fs_context_t * const context,
spastor 0:1c358ea10753 940 connector_request_id_file_system_t close_request)
spastor 0:1c358ea10753 941 {
spastor 0:1c358ea10753 942
spastor 0:1c358ea10753 943 msg_service_data_t * const service_data = service_request->need_data;
spastor 0:1c358ea10753 944 connector_status_t status = connector_working;
spastor 0:1c358ea10753 945
spastor 0:1c358ea10753 946 if (FsGetState(context) < fs_state_closed)
spastor 0:1c358ea10753 947 {
spastor 0:1c358ea10753 948 status = call_file_close_user(connector_ptr,
spastor 0:1c358ea10753 949 service_request,
spastor 0:1c358ea10753 950 context,
spastor 0:1c358ea10753 951 close_request);
spastor 0:1c358ea10753 952
spastor 0:1c358ea10753 953 if (status == connector_pending)
spastor 0:1c358ea10753 954 {
spastor 0:1c358ea10753 955 if (context->status == connector_working &&
spastor 0:1c358ea10753 956 context->errnum == NULL &&
spastor 0:1c358ea10753 957 service_data->length_in_bytes > 0)
spastor 0:1c358ea10753 958 {
spastor 0:1c358ea10753 959 /* Return final data portion, will set last bit later
spastor 0:1c358ea10753 960 when closing the file completes in the next callback */
spastor 0:1c358ea10753 961 status = connector_working;
spastor 0:1c358ea10753 962 }
spastor 0:1c358ea10753 963 goto done;
spastor 0:1c358ea10753 964 }
spastor 0:1c358ea10753 965 }
spastor 0:1c358ea10753 966
spastor 0:1c358ea10753 967 /* finished closing file */
spastor 0:1c358ea10753 968 if (context->status == connector_abort)
spastor 0:1c358ea10753 969 status = connector_abort;
spastor 0:1c358ea10753 970
spastor 0:1c358ea10753 971 /* abort condition or messaging error and session will be canceled */
spastor 0:1c358ea10753 972 if (status == connector_abort || service_request->service_type == msg_service_type_error)
spastor 0:1c358ea10753 973 goto done;
spastor 0:1c358ea10753 974
spastor 0:1c358ea10753 975 /* no errors, set last bit and send out last portion of data */
spastor 0:1c358ea10753 976 if (context->errnum == NULL)
spastor 0:1c358ea10753 977 {
spastor 0:1c358ea10753 978 MsgSetLastData(service_data->flags);
spastor 0:1c358ea10753 979 goto done;
spastor 0:1c358ea10753 980 }
spastor 0:1c358ea10753 981 /* errors */
spastor 0:1c358ea10753 982 if (MsgIsStart(service_data->flags))
spastor 0:1c358ea10753 983 {
spastor 0:1c358ea10753 984 /* send file system-level an error response if no data was sent yet, */
spastor 0:1c358ea10753 985 if (format_file_error_msg(connector_ptr, service_request, context) == connector_abort)
spastor 0:1c358ea10753 986 status = connector_abort;
spastor 0:1c358ea10753 987 }
spastor 0:1c358ea10753 988 else
spastor 0:1c358ea10753 989 {
spastor 0:1c358ea10753 990 /* or cancel the session, if it's late to send a file system level error response */
spastor 0:1c358ea10753 991 fs_set_service_error(service_request, connector_session_error_cancel);
spastor 0:1c358ea10753 992 }
spastor 0:1c358ea10753 993
spastor 0:1c358ea10753 994 done:
spastor 0:1c358ea10753 995 return status;
spastor 0:1c358ea10753 996 }
spastor 0:1c358ea10753 997
spastor 0:1c358ea10753 998
spastor 0:1c358ea10753 999 static connector_status_t process_file_get_response(connector_data_t * const connector_ptr,
spastor 0:1c358ea10753 1000 msg_service_request_t * const service_request,
spastor 0:1c358ea10753 1001 fs_context_t * const context)
spastor 0:1c358ea10753 1002 {
spastor 0:1c358ea10753 1003 msg_service_data_t * const service_data = service_request->need_data;
spastor 0:1c358ea10753 1004 connector_status_t status = connector_working;
spastor 0:1c358ea10753 1005
spastor 0:1c358ea10753 1006 if ((context->errnum != NULL) || (FsGetState(context) >= fs_state_closing))
spastor 0:1c358ea10753 1007 {
spastor 0:1c358ea10753 1008 service_data->length_in_bytes = 0;
spastor 0:1c358ea10753 1009 goto close_file;
spastor 0:1c358ea10753 1010 }
spastor 0:1c358ea10753 1011
spastor 0:1c358ea10753 1012 {
spastor 0:1c358ea10753 1013 uint8_t * data_ptr = service_data->data_ptr;
spastor 0:1c358ea10753 1014 size_t buffer_size = service_data->length_in_bytes;
spastor 0:1c358ea10753 1015 connector_bool_t last_msg = connector_false;
spastor 0:1c358ea10753 1016 size_t bytes_read = 0;
spastor 0:1c358ea10753 1017 size_t bytes_to_read;
spastor 0:1c358ea10753 1018
spastor 0:1c358ea10753 1019 if (MsgIsStart(service_data->flags))
spastor 0:1c358ea10753 1020 {
spastor 0:1c358ea10753 1021 if (FsGetState(context) < fs_state_lseek)
spastor 0:1c358ea10753 1022 {
spastor 0:1c358ea10753 1023 if (context->data.f.offset != 0)
spastor 0:1c358ea10753 1024 {
spastor 0:1c358ea10753 1025 status = set_file_position(connector_ptr, service_request, context);
spastor 0:1c358ea10753 1026 if (status == connector_pending)
spastor 0:1c358ea10753 1027 goto done;
spastor 0:1c358ea10753 1028
spastor 0:1c358ea10753 1029 if (!FsOperationSuccess(status, context))
spastor 0:1c358ea10753 1030 goto close_file;
spastor 0:1c358ea10753 1031 }
spastor 0:1c358ea10753 1032 FsSetState(context, fs_state_lseek);
spastor 0:1c358ea10753 1033 }
spastor 0:1c358ea10753 1034 *data_ptr++ = fs_get_response_opcode;
spastor 0:1c358ea10753 1035 buffer_size--;
spastor 0:1c358ea10753 1036 }
spastor 0:1c358ea10753 1037
spastor 0:1c358ea10753 1038 /* bytes to read in this callback */
spastor 0:1c358ea10753 1039 bytes_to_read = MIN_VALUE(buffer_size, context->data.f.data_length - context->data.f.bytes_done);
spastor 0:1c358ea10753 1040
spastor 0:1c358ea10753 1041 while (bytes_to_read > 0)
spastor 0:1c358ea10753 1042 {
spastor 0:1c358ea10753 1043 size_t cnt = bytes_to_read;
spastor 0:1c358ea10753 1044 status = call_file_read_user(connector_ptr, service_request, context, data_ptr, &cnt);
spastor 0:1c358ea10753 1045
spastor 0:1c358ea10753 1046 if (status == connector_pending)
spastor 0:1c358ea10753 1047 {
spastor 0:1c358ea10753 1048 if (bytes_read > 0)
spastor 0:1c358ea10753 1049 status = connector_working; /* Return what's read already */
spastor 0:1c358ea10753 1050 break;
spastor 0:1c358ea10753 1051 }
spastor 0:1c358ea10753 1052 if (!FsOperationSuccess(status, context))
spastor 0:1c358ea10753 1053 goto close_file;
spastor 0:1c358ea10753 1054
spastor 0:1c358ea10753 1055 if (cnt > 0)
spastor 0:1c358ea10753 1056 {
spastor 0:1c358ea10753 1057 data_ptr += cnt;
spastor 0:1c358ea10753 1058 bytes_to_read -= cnt;
spastor 0:1c358ea10753 1059 bytes_read += cnt;
spastor 0:1c358ea10753 1060 }
spastor 0:1c358ea10753 1061 else
spastor 0:1c358ea10753 1062 {
spastor 0:1c358ea10753 1063 bytes_to_read = 0;
spastor 0:1c358ea10753 1064 last_msg = connector_true;
spastor 0:1c358ea10753 1065 }
spastor 0:1c358ea10753 1066 }
spastor 0:1c358ea10753 1067 context->data.f.bytes_done += bytes_read;
spastor 0:1c358ea10753 1068 service_data->length_in_bytes = bytes_read;
spastor 0:1c358ea10753 1069
spastor 0:1c358ea10753 1070 if (MsgIsStart(service_data->flags))
spastor 0:1c358ea10753 1071 service_data->length_in_bytes++; /* opcode */
spastor 0:1c358ea10753 1072
spastor 0:1c358ea10753 1073 if (context->data.f.data_length == context->data.f.bytes_done)
spastor 0:1c358ea10753 1074 last_msg = connector_true;
spastor 0:1c358ea10753 1075
spastor 0:1c358ea10753 1076 if (!last_msg)
spastor 0:1c358ea10753 1077 goto done;
spastor 0:1c358ea10753 1078 }
spastor 0:1c358ea10753 1079
spastor 0:1c358ea10753 1080 close_file:
spastor 0:1c358ea10753 1081 status = process_get_close(connector_ptr,
spastor 0:1c358ea10753 1082 service_request,
spastor 0:1c358ea10753 1083 context,
spastor 0:1c358ea10753 1084 connector_request_id_file_system_close);
spastor 0:1c358ea10753 1085
spastor 0:1c358ea10753 1086 done:
spastor 0:1c358ea10753 1087 return status;
spastor 0:1c358ea10753 1088 }
spastor 0:1c358ea10753 1089
spastor 0:1c358ea10753 1090 static connector_status_t process_file_rm_request(connector_data_t * const connector_ptr,
spastor 0:1c358ea10753 1091 msg_service_request_t * const service_request,
spastor 0:1c358ea10753 1092 fs_context_t * const context)
spastor 0:1c358ea10753 1093 {
spastor 0:1c358ea10753 1094 msg_service_data_t * const service_data = service_request->have_data;
spastor 0:1c358ea10753 1095 char const * path = service_data->data_ptr;
spastor 0:1c358ea10753 1096 connector_status_t status = connector_working;
spastor 0:1c358ea10753 1097
spastor 0:1c358ea10753 1098 path += FS_OPCODE_BYTES;
spastor 0:1c358ea10753 1099
spastor 0:1c358ea10753 1100 if (parse_file_path(context, path, service_data->length_in_bytes - FS_OPCODE_BYTES) == 0)
spastor 0:1c358ea10753 1101 goto done;
spastor 0:1c358ea10753 1102
spastor 0:1c358ea10753 1103 status = call_file_rm_user(connector_ptr, service_request, context, path);
spastor 0:1c358ea10753 1104
spastor 0:1c358ea10753 1105 done:
spastor 0:1c358ea10753 1106 return status;
spastor 0:1c358ea10753 1107 }
spastor 0:1c358ea10753 1108
spastor 0:1c358ea10753 1109 static connector_status_t process_file_response_nodata(connector_data_t * const connector_ptr,
spastor 0:1c358ea10753 1110 msg_service_request_t * const service_request,
spastor 0:1c358ea10753 1111 fs_context_t * const context,
spastor 0:1c358ea10753 1112 fs_opcode_t const opcode)
spastor 0:1c358ea10753 1113 {
spastor 0:1c358ea10753 1114 msg_service_data_t * const service_data = service_request->need_data;
spastor 0:1c358ea10753 1115 connector_status_t status = connector_working;
spastor 0:1c358ea10753 1116
spastor 0:1c358ea10753 1117 if (context->errnum == NULL)
spastor 0:1c358ea10753 1118 {
spastor 0:1c358ea10753 1119 uint8_t * const data_ptr = service_data->data_ptr;
spastor 0:1c358ea10753 1120
spastor 0:1c358ea10753 1121 *data_ptr = opcode;
spastor 0:1c358ea10753 1122
spastor 0:1c358ea10753 1123 service_data->length_in_bytes = sizeof *data_ptr;
spastor 0:1c358ea10753 1124 MsgSetLastData(service_data->flags);
spastor 0:1c358ea10753 1125 }
spastor 0:1c358ea10753 1126 else
spastor 0:1c358ea10753 1127 {
spastor 0:1c358ea10753 1128 if (format_file_error_msg(connector_ptr, service_request, context) == connector_abort)
spastor 0:1c358ea10753 1129 {
spastor 0:1c358ea10753 1130 status = connector_abort;
spastor 0:1c358ea10753 1131 }
spastor 0:1c358ea10753 1132 }
spastor 0:1c358ea10753 1133 return status;
spastor 0:1c358ea10753 1134 }
spastor 0:1c358ea10753 1135
spastor 0:1c358ea10753 1136 static size_t parse_file_put_header(fs_context_t * const context,
spastor 0:1c358ea10753 1137 uint8_t const * const header_ptr,
spastor 0:1c358ea10753 1138 size_t const buffer_size)
spastor 0:1c358ea10753 1139 {
spastor 0:1c358ea10753 1140 /*
spastor 0:1c358ea10753 1141 *
spastor 0:1c358ea10753 1142 * File System Put request format:
spastor 0:1c358ea10753 1143 * --------------------------------------------
spastor 0:1c358ea10753 1144 * | 0 | N | +1 | +4 | N |
spastor 0:1c358ea10753 1145 * --------------------------------------------
spastor 0:1c358ea10753 1146 * | Opcode | Path | Flags | Offset | Payload |
spastor 0:1c358ea10753 1147 * --------------------------------------------
spastor 0:1c358ea10753 1148 *
spastor 0:1c358ea10753 1149 */
spastor 0:1c358ea10753 1150
spastor 0:1c358ea10753 1151 enum {
spastor 0:1c358ea10753 1152 field_define(fs_put_request, flags, uint8_t),
spastor 0:1c358ea10753 1153 field_define(fs_put_request, offset, uint32_t),
spastor 0:1c358ea10753 1154 record_end(fs_put_request_header)
spastor 0:1c358ea10753 1155 };
spastor 0:1c358ea10753 1156 uint8_t const *fs_put_request = header_ptr + FS_OPCODE_BYTES;
spastor 0:1c358ea10753 1157 size_t const header_len = record_bytes(fs_put_request_header) + FS_OPCODE_BYTES;
spastor 0:1c358ea10753 1158
spastor 0:1c358ea10753 1159 size_t len = parse_file_path(context, fs_put_request, buffer_size - header_len);
spastor 0:1c358ea10753 1160 if (len == 0)
spastor 0:1c358ea10753 1161 goto done;
spastor 0:1c358ea10753 1162
spastor 0:1c358ea10753 1163 fs_put_request += len;
spastor 0:1c358ea10753 1164 context->flags |= message_load_u8(fs_put_request, flags);
spastor 0:1c358ea10753 1165 context->data.f.offset = message_load_be32(fs_put_request, offset);
spastor 0:1c358ea10753 1166 if (context->data.f.offset < 0)
spastor 0:1c358ea10753 1167 {
spastor 0:1c358ea10753 1168 FsSetInternalError(context, fs_error_large_file);
spastor 0:1c358ea10753 1169 len = 0;
spastor 0:1c358ea10753 1170 goto done;
spastor 0:1c358ea10753 1171 }
spastor 0:1c358ea10753 1172 len += header_len;
spastor 0:1c358ea10753 1173
spastor 0:1c358ea10753 1174 done:
spastor 0:1c358ea10753 1175 return len;
spastor 0:1c358ea10753 1176 }
spastor 0:1c358ea10753 1177
spastor 0:1c358ea10753 1178
spastor 0:1c358ea10753 1179 static connector_status_t process_file_put_request(connector_data_t * const connector_ptr,
spastor 0:1c358ea10753 1180 msg_service_request_t * const service_request,
spastor 0:1c358ea10753 1181 fs_context_t * const context)
spastor 0:1c358ea10753 1182 {
spastor 0:1c358ea10753 1183 connector_status_t status = connector_working;
spastor 0:1c358ea10753 1184
spastor 0:1c358ea10753 1185 if ((context->errnum != NULL) || (FsGetState(context) >= fs_state_closing))
spastor 0:1c358ea10753 1186 goto close_file;
spastor 0:1c358ea10753 1187
spastor 0:1c358ea10753 1188 {
spastor 0:1c358ea10753 1189 msg_service_data_t * const service_data = service_request->have_data;
spastor 0:1c358ea10753 1190 uint8_t const * data_ptr = service_data->data_ptr;
spastor 0:1c358ea10753 1191 size_t bytes_to_write = service_data->length_in_bytes;
spastor 0:1c358ea10753 1192 size_t bytes_written = 0;
spastor 0:1c358ea10753 1193
spastor 0:1c358ea10753 1194 if (MsgIsStart(service_data->flags))
spastor 0:1c358ea10753 1195 {
spastor 0:1c358ea10753 1196 size_t header_len = parse_file_put_header(context, data_ptr, service_data->length_in_bytes);
spastor 0:1c358ea10753 1197 if (header_len == 0)
spastor 0:1c358ea10753 1198 goto done;
spastor 0:1c358ea10753 1199
spastor 0:1c358ea10753 1200 if (FsGetState(context) < fs_state_open)
spastor 0:1c358ea10753 1201 {
spastor 0:1c358ea10753 1202 int open_flags = CONNECTOR_FILE_O_WRONLY | CONNECTOR_FILE_O_CREAT;
spastor 0:1c358ea10753 1203 char const * path = service_data->data_ptr;
spastor 0:1c358ea10753 1204 path += FS_OPCODE_BYTES;
spastor 0:1c358ea10753 1205
spastor 0:1c358ea10753 1206 if (FsNeedTrunc(context))
spastor 0:1c358ea10753 1207 {
spastor 0:1c358ea10753 1208 if (context->data.f.offset == 0)
spastor 0:1c358ea10753 1209 {
spastor 0:1c358ea10753 1210 open_flags |= CONNECTOR_FILE_O_TRUNC;
spastor 0:1c358ea10753 1211 FsClearTrunc(context);
spastor 0:1c358ea10753 1212 }
spastor 0:1c358ea10753 1213 }
spastor 0:1c358ea10753 1214
spastor 0:1c358ea10753 1215 status = call_file_open_user(connector_ptr, service_request, context, path, open_flags);
spastor 0:1c358ea10753 1216 if (FsGetState(context) != fs_state_open)
spastor 0:1c358ea10753 1217 goto done;
spastor 0:1c358ea10753 1218 }
spastor 0:1c358ea10753 1219
spastor 0:1c358ea10753 1220 if (FsGetState(context) < fs_state_lseek)
spastor 0:1c358ea10753 1221 {
spastor 0:1c358ea10753 1222 if (context->data.f.offset != 0)
spastor 0:1c358ea10753 1223 {
spastor 0:1c358ea10753 1224 status = set_file_position(connector_ptr, service_request, context);
spastor 0:1c358ea10753 1225 if (status == connector_pending)
spastor 0:1c358ea10753 1226 goto done;
spastor 0:1c358ea10753 1227
spastor 0:1c358ea10753 1228 if (!FsOperationSuccess(status, context))
spastor 0:1c358ea10753 1229 goto close_file;
spastor 0:1c358ea10753 1230 }
spastor 0:1c358ea10753 1231 FsSetState(context, fs_state_lseek);
spastor 0:1c358ea10753 1232 }
spastor 0:1c358ea10753 1233 data_ptr += header_len;
spastor 0:1c358ea10753 1234 bytes_to_write -= header_len;
spastor 0:1c358ea10753 1235 }
spastor 0:1c358ea10753 1236
spastor 0:1c358ea10753 1237 data_ptr += context->data.f.bytes_done;
spastor 0:1c358ea10753 1238 bytes_to_write -= context->data.f.bytes_done;
spastor 0:1c358ea10753 1239
spastor 0:1c358ea10753 1240 while(bytes_to_write > 0)
spastor 0:1c358ea10753 1241 {
spastor 0:1c358ea10753 1242 size_t cnt = bytes_to_write;
spastor 0:1c358ea10753 1243 status = call_file_write_user(connector_ptr, service_request, context, data_ptr, &cnt);
spastor 0:1c358ea10753 1244
spastor 0:1c358ea10753 1245 if (status == connector_pending)
spastor 0:1c358ea10753 1246 {
spastor 0:1c358ea10753 1247 context->data.f.bytes_done += bytes_written;
spastor 0:1c358ea10753 1248 context->data.f.offset += bytes_written;
spastor 0:1c358ea10753 1249 goto done;
spastor 0:1c358ea10753 1250 }
spastor 0:1c358ea10753 1251 if (!FsOperationSuccess(status, context))
spastor 0:1c358ea10753 1252 goto close_file;
spastor 0:1c358ea10753 1253
spastor 0:1c358ea10753 1254 data_ptr += cnt;
spastor 0:1c358ea10753 1255 bytes_to_write -= cnt;
spastor 0:1c358ea10753 1256 bytes_written += cnt;
spastor 0:1c358ea10753 1257 }
spastor 0:1c358ea10753 1258 context->data.f.bytes_done = 0;
spastor 0:1c358ea10753 1259 context->data.f.offset += bytes_written;
spastor 0:1c358ea10753 1260
spastor 0:1c358ea10753 1261 if (!MsgIsLastData(service_data->flags))
spastor 0:1c358ea10753 1262 goto done;
spastor 0:1c358ea10753 1263
spastor 0:1c358ea10753 1264 if (FsNeedTrunc(context))
spastor 0:1c358ea10753 1265 {
spastor 0:1c358ea10753 1266 status = call_file_ftruncate_user(connector_ptr, service_request, context);
spastor 0:1c358ea10753 1267 if (status == connector_pending)
spastor 0:1c358ea10753 1268 goto done;
spastor 0:1c358ea10753 1269 }
spastor 0:1c358ea10753 1270 }
spastor 0:1c358ea10753 1271 close_file:
spastor 0:1c358ea10753 1272 status = call_file_close_user(connector_ptr,
spastor 0:1c358ea10753 1273 service_request,
spastor 0:1c358ea10753 1274 context,
spastor 0:1c358ea10753 1275 connector_request_id_file_system_close);
spastor 0:1c358ea10753 1276
spastor 0:1c358ea10753 1277 if (status == connector_pending)
spastor 0:1c358ea10753 1278 goto done;
spastor 0:1c358ea10753 1279
spastor 0:1c358ea10753 1280 /* finished closing file */
spastor 0:1c358ea10753 1281 if (context->status == connector_abort)
spastor 0:1c358ea10753 1282 status = connector_abort;
spastor 0:1c358ea10753 1283
spastor 0:1c358ea10753 1284 done:
spastor 0:1c358ea10753 1285 return status;
spastor 0:1c358ea10753 1286 }
spastor 0:1c358ea10753 1287
spastor 0:1c358ea10753 1288 static size_t parse_file_ls_header(fs_context_t * const context,
spastor 0:1c358ea10753 1289 uint8_t const * const header_ptr,
spastor 0:1c358ea10753 1290 size_t const buffer_size)
spastor 0:1c358ea10753 1291 {
spastor 0:1c358ea10753 1292 /*
spastor 0:1c358ea10753 1293 * File System Ls request format:
spastor 0:1c358ea10753 1294 * ----------------------------
spastor 0:1c358ea10753 1295 * | 0 | N | 1 |
spastor 0:1c358ea10753 1296 * ----------------------------
spastor 0:1c358ea10753 1297 * | Opcode | Path | hash alg |
spastor 0:1c358ea10753 1298 * ----------------------------
spastor 0:1c358ea10753 1299 */
spastor 0:1c358ea10753 1300 uint8_t const * data_ptr = header_ptr + FS_OPCODE_BYTES;
spastor 0:1c358ea10753 1301 const size_t header_len = 1 + FS_OPCODE_BYTES;
spastor 0:1c358ea10753 1302 connector_file_system_hash_algorithm_t hash_alg;
spastor 0:1c358ea10753 1303
spastor 0:1c358ea10753 1304 size_t len = parse_file_path(context, data_ptr, buffer_size - header_len);
spastor 0:1c358ea10753 1305 if (len != 0)
spastor 0:1c358ea10753 1306 {
spastor 0:1c358ea10753 1307 data_ptr += len;
spastor 0:1c358ea10753 1308 len += header_len;
spastor 0:1c358ea10753 1309
spastor 0:1c358ea10753 1310 hash_alg = (connector_file_system_hash_algorithm_t) *data_ptr;
spastor 0:1c358ea10753 1311
spastor 0:1c358ea10753 1312 switch (hash_alg)
spastor 0:1c358ea10753 1313 {
spastor 0:1c358ea10753 1314 case connector_file_system_hash_crc32:
spastor 0:1c358ea10753 1315 case connector_file_system_hash_md5:
spastor 0:1c358ea10753 1316 case connector_file_system_hash_best:
spastor 0:1c358ea10753 1317 case connector_file_system_hash_none:
spastor 0:1c358ea10753 1318 context->data.d.hash_alg = hash_alg;
spastor 0:1c358ea10753 1319 break;
spastor 0:1c358ea10753 1320
spastor 0:1c358ea10753 1321 default:
spastor 0:1c358ea10753 1322 FsSetInternalError(context, fs_error_invalid_hash);
spastor 0:1c358ea10753 1323 len = 0;
spastor 0:1c358ea10753 1324 }
spastor 0:1c358ea10753 1325 }
spastor 0:1c358ea10753 1326 return len;
spastor 0:1c358ea10753 1327 }
spastor 0:1c358ea10753 1328
spastor 0:1c358ea10753 1329 static size_t format_file_ls_response_header(connector_file_system_hash_algorithm_t const hash_alg,
spastor 0:1c358ea10753 1330 size_t const hash_size,
spastor 0:1c358ea10753 1331 uint8_t * const data_ptr)
spastor 0:1c358ea10753 1332 {
spastor 0:1c358ea10753 1333 /*
spastor 0:1c358ea10753 1334 * File System Ls response header format:
spastor 0:1c358ea10753 1335 * --------------------------------
spastor 0:1c358ea10753 1336 * | 1 | 1 | 1 |
spastor 0:1c358ea10753 1337 * --------------------------------
spastor 0:1c358ea10753 1338 * | opcode | hash_alg | hash_bytes |
spastor 0:1c358ea10753 1339 * --------------------------------
spastor 0:1c358ea10753 1340 */
spastor 0:1c358ea10753 1341
spastor 0:1c358ea10753 1342 enum {
spastor 0:1c358ea10753 1343 field_define(fs_ls_response, opcode, uint8_t),
spastor 0:1c358ea10753 1344 field_define(fs_ls_response, hash_alg, uint8_t),
spastor 0:1c358ea10753 1345 field_define(fs_ls_response, hash_bytes, uint8_t),
spastor 0:1c358ea10753 1346 record_end(fs_ls_response_header)
spastor 0:1c358ea10753 1347 };
spastor 0:1c358ea10753 1348
spastor 0:1c358ea10753 1349 uint8_t * fs_ls_response = data_ptr;
spastor 0:1c358ea10753 1350
spastor 0:1c358ea10753 1351 message_store_u8(fs_ls_response, opcode, fs_ls_response_opcode);
spastor 0:1c358ea10753 1352 message_store_u8(fs_ls_response, hash_alg, hash_alg);
spastor 0:1c358ea10753 1353 message_store_u8(fs_ls_response, hash_bytes, hash_size);
spastor 0:1c358ea10753 1354
spastor 0:1c358ea10753 1355 return record_bytes(fs_ls_response_header);
spastor 0:1c358ea10753 1356 }
spastor 0:1c358ea10753 1357
spastor 0:1c358ea10753 1358 static size_t file_ls_resp_header_size(void)
spastor 0:1c358ea10753 1359 {
spastor 0:1c358ea10753 1360 /*
spastor 0:1c358ea10753 1361 * File System Ls request format:
spastor 0:1c358ea10753 1362 * ----------------------------
spastor 0:1c358ea10753 1363 * | 1 | 4 | 0/4 |
spastor 0:1c358ea10753 1364 * ----------------------------
spastor 0:1c358ea10753 1365 * | flags | last | size |
spastor 0:1c358ea10753 1366 * | | modified | |
spastor 0:1c358ea10753 1367 * ----------------------------
spastor 0:1c358ea10753 1368 */
spastor 0:1c358ea10753 1369
spastor 0:1c358ea10753 1370 enum {
spastor 0:1c358ea10753 1371 field_define(fs_ls_response, flags, uint8_t),
spastor 0:1c358ea10753 1372 field_define(fs_ls_response, last_modified, uint32_t),
spastor 0:1c358ea10753 1373 field_define(fs_ls_response, size, connector_file_offset_t),
spastor 0:1c358ea10753 1374 record_end(fs_ls_response_file)
spastor 0:1c358ea10753 1375 };
spastor 0:1c358ea10753 1376 return record_bytes(fs_ls_response_file);
spastor 0:1c358ea10753 1377 }
spastor 0:1c358ea10753 1378
spastor 0:1c358ea10753 1379 static size_t format_file_ls_response(fs_context_t const * context,
spastor 0:1c358ea10753 1380 char const * path,
spastor 0:1c358ea10753 1381 size_t const path_len,
spastor 0:1c358ea10753 1382 uint8_t * const data_ptr)
spastor 0:1c358ea10753 1383 {
spastor 0:1c358ea10753 1384 /*
spastor 0:1c358ea10753 1385 * File System Ls request format:
spastor 0:1c358ea10753 1386 * ----------------------------
spastor 0:1c358ea10753 1387 * | 1 | 4 | 0/4 |
spastor 0:1c358ea10753 1388 * ----------------------------
spastor 0:1c358ea10753 1389 * | flags | last | size |
spastor 0:1c358ea10753 1390 * | | modified | |
spastor 0:1c358ea10753 1391 * ----------------------------
spastor 0:1c358ea10753 1392 */
spastor 0:1c358ea10753 1393
spastor 0:1c358ea10753 1394 enum {
spastor 0:1c358ea10753 1395 field_define(fs_ls_response, flags, uint8_t),
spastor 0:1c358ea10753 1396 field_define(fs_ls_response, last_modified, uint32_t),
spastor 0:1c358ea10753 1397 record_end(fs_ls_response_dir)
spastor 0:1c358ea10753 1398 };
spastor 0:1c358ea10753 1399 enum {
spastor 0:1c358ea10753 1400 field_define(fs_ls_response, size, connector_file_offset_t),
spastor 0:1c358ea10753 1401 record_end(fs_ls_response_file)
spastor 0:1c358ea10753 1402 };
spastor 0:1c358ea10753 1403
spastor 0:1c358ea10753 1404 uint8_t * fs_ls_response = data_ptr + path_len;
spastor 0:1c358ea10753 1405 uint8_t flags = FsIsDir(context) ? FS_IS_DIR_FLAG : 0;
spastor 0:1c358ea10753 1406 size_t result;
spastor 0:1c358ea10753 1407
spastor 0:1c358ea10753 1408 #if (defined CONNECTOR_FILE_SYSTEM_HAS_LARGE_FILES)
spastor 0:1c358ea10753 1409 flags |= FS_IS_LARGE_FLAG;
spastor 0:1c358ea10753 1410 #endif
spastor 0:1c358ea10753 1411 memcpy(data_ptr, path, path_len);
spastor 0:1c358ea10753 1412
spastor 0:1c358ea10753 1413 message_store_u8(fs_ls_response, flags, flags);
spastor 0:1c358ea10753 1414 message_store_be32(fs_ls_response, last_modified, context->data.d.last_modified);
spastor 0:1c358ea10753 1415 result = path_len + record_bytes(fs_ls_response_dir);
spastor 0:1c358ea10753 1416
spastor 0:1c358ea10753 1417 if (!FsIsDir(context))
spastor 0:1c358ea10753 1418 {
spastor 0:1c358ea10753 1419 fs_ls_response += record_bytes(fs_ls_response_dir);
spastor 0:1c358ea10753 1420 #if (defined CONNECTOR_FILE_SYSTEM_HAS_LARGE_FILES)
spastor 0:1c358ea10753 1421 message_store_be64(fs_ls_response, size, context->data.d.file_size);
spastor 0:1c358ea10753 1422 #else
spastor 0:1c358ea10753 1423 message_store_be32(fs_ls_response, size, context->data.d.file_size);
spastor 0:1c358ea10753 1424 #endif
spastor 0:1c358ea10753 1425 result += record_bytes(fs_ls_response_file);
spastor 0:1c358ea10753 1426 }
spastor 0:1c358ea10753 1427
spastor 0:1c358ea10753 1428 return result;
spastor 0:1c358ea10753 1429 }
spastor 0:1c358ea10753 1430
spastor 0:1c358ea10753 1431 static connector_status_t file_store_path(fs_context_t * const context,
spastor 0:1c358ea10753 1432 char const * const path)
spastor 0:1c358ea10753 1433 {
spastor 0:1c358ea10753 1434 connector_status_t status = connector_working;
spastor 0:1c358ea10753 1435 size_t path_len = strlen(path);
spastor 0:1c358ea10753 1436
spastor 0:1c358ea10753 1437 if (FsIsDir(context) && path[path_len - 1] != '/')
spastor 0:1c358ea10753 1438 {
spastor 0:1c358ea10753 1439 path_len++;
spastor 0:1c358ea10753 1440 }
spastor 0:1c358ea10753 1441
spastor 0:1c358ea10753 1442 if (path_len >= CONNECTOR_FILE_SYSTEM_MAX_PATH_LENGTH)
spastor 0:1c358ea10753 1443 {
spastor 0:1c358ea10753 1444 FsSetInternalError(context, fs_error_path_too_long);
spastor 0:1c358ea10753 1445 goto done;
spastor 0:1c358ea10753 1446 }
spastor 0:1c358ea10753 1447
spastor 0:1c358ea10753 1448 memcpy(context->data.d.path, path, path_len + 1);
spastor 0:1c358ea10753 1449
spastor 0:1c358ea10753 1450 if (FsIsDir(context) && (path[path_len - 1] != '/'))
spastor 0:1c358ea10753 1451 {
spastor 0:1c358ea10753 1452 context->data.d.path[path_len - 1] = '/';
spastor 0:1c358ea10753 1453 context->data.d.path[path_len] = '\0';
spastor 0:1c358ea10753 1454 }
spastor 0:1c358ea10753 1455 context->data.d.path_len = path_len;
spastor 0:1c358ea10753 1456
spastor 0:1c358ea10753 1457 done:
spastor 0:1c358ea10753 1458 return status;
spastor 0:1c358ea10753 1459 }
spastor 0:1c358ea10753 1460
spastor 0:1c358ea10753 1461 static connector_status_t process_file_ls_request(connector_data_t * const connector_ptr,
spastor 0:1c358ea10753 1462 msg_service_request_t * const service_request,
spastor 0:1c358ea10753 1463 fs_context_t * const context)
spastor 0:1c358ea10753 1464 {
spastor 0:1c358ea10753 1465 msg_service_data_t * const service_data = service_request->have_data;
spastor 0:1c358ea10753 1466 char const * path = service_data->data_ptr;
spastor 0:1c358ea10753 1467 connector_status_t status = connector_working;
spastor 0:1c358ea10753 1468
spastor 0:1c358ea10753 1469 path += FS_OPCODE_BYTES;
spastor 0:1c358ea10753 1470
spastor 0:1c358ea10753 1471 if (context->errnum != NULL)
spastor 0:1c358ea10753 1472 goto done;
spastor 0:1c358ea10753 1473
spastor 0:1c358ea10753 1474 if (parse_file_ls_header(context, service_data->data_ptr, service_data->length_in_bytes) == 0)
spastor 0:1c358ea10753 1475 goto done;
spastor 0:1c358ea10753 1476
spastor 0:1c358ea10753 1477 if (FsGetState(context) < fs_state_stat)
spastor 0:1c358ea10753 1478 {
spastor 0:1c358ea10753 1479 status = call_file_stat_user(connector_ptr, service_request, context, path, context->data.d.hash_alg);
spastor 0:1c358ea10753 1480 if (!FsOperationSuccess(status, context))
spastor 0:1c358ea10753 1481 {
spastor 0:1c358ea10753 1482 goto done;
spastor 0:1c358ea10753 1483 }
spastor 0:1c358ea10753 1484
spastor 0:1c358ea10753 1485 FsSetState(context, fs_state_stat);
spastor 0:1c358ea10753 1486 }
spastor 0:1c358ea10753 1487 if (FsIsDir(context))
spastor 0:1c358ea10753 1488 {
spastor 0:1c358ea10753 1489 status = call_file_opendir_user(connector_ptr, service_request, context, path);
spastor 0:1c358ea10753 1490 if (FsGetState(context) != fs_state_open)
spastor 0:1c358ea10753 1491 goto done;
spastor 0:1c358ea10753 1492 }
spastor 0:1c358ea10753 1493 else
spastor 0:1c358ea10753 1494 {
spastor 0:1c358ea10753 1495 FsSetLsSingleFile(context);
spastor 0:1c358ea10753 1496 }
spastor 0:1c358ea10753 1497
spastor 0:1c358ea10753 1498 /* call_file_stat_user must be done before store path, to strcat '/' to dir path */
spastor 0:1c358ea10753 1499 status = file_store_path(context, path);
spastor 0:1c358ea10753 1500
spastor 0:1c358ea10753 1501 done:
spastor 0:1c358ea10753 1502 return status;
spastor 0:1c358ea10753 1503 }
spastor 0:1c358ea10753 1504
spastor 0:1c358ea10753 1505 static connector_status_t process_file_ls_response(connector_data_t * const connector_ptr,
spastor 0:1c358ea10753 1506 msg_service_request_t * const service_request,
spastor 0:1c358ea10753 1507 fs_context_t * const context)
spastor 0:1c358ea10753 1508 {
spastor 0:1c358ea10753 1509 msg_service_data_t * const service_data = service_request->need_data;
spastor 0:1c358ea10753 1510 connector_status_t status = connector_working;
spastor 0:1c358ea10753 1511
spastor 0:1c358ea10753 1512 if ((context->errnum != NULL) || (FsGetState(context) >= fs_state_closing))
spastor 0:1c358ea10753 1513 {
spastor 0:1c358ea10753 1514 service_data->length_in_bytes = 0;
spastor 0:1c358ea10753 1515 goto close_dir;
spastor 0:1c358ea10753 1516 }
spastor 0:1c358ea10753 1517 {
spastor 0:1c358ea10753 1518 uint8_t * data_ptr = service_data->data_ptr;
spastor 0:1c358ea10753 1519 size_t buffer_size = service_data->length_in_bytes;
spastor 0:1c358ea10753 1520 size_t resp_len = 0;
spastor 0:1c358ea10753 1521
spastor 0:1c358ea10753 1522 size_t const header_len = file_ls_resp_header_size();
spastor 0:1c358ea10753 1523 size_t hash_len = file_hash_size(context->data.d.hash_alg);
spastor 0:1c358ea10753 1524 char * file_path;
spastor 0:1c358ea10753 1525 size_t file_path_len;
spastor 0:1c358ea10753 1526
spastor 0:1c358ea10753 1527 if (MsgIsStart(service_data->flags))
spastor 0:1c358ea10753 1528 {
spastor 0:1c358ea10753 1529 resp_len = format_file_ls_response_header(context->data.d.hash_alg, hash_len, data_ptr);
spastor 0:1c358ea10753 1530 data_ptr += resp_len;
spastor 0:1c358ea10753 1531 buffer_size -= resp_len;
spastor 0:1c358ea10753 1532 }
spastor 0:1c358ea10753 1533
spastor 0:1c358ea10753 1534 if (FsIsLsSingleFile(context))
spastor 0:1c358ea10753 1535 {
spastor 0:1c358ea10753 1536 /* ls command was issued for a single file */
spastor 0:1c358ea10753 1537 file_path_len = context->data.d.path_len + 1;
spastor 0:1c358ea10753 1538 file_path = context->data.d.path;
spastor 0:1c358ea10753 1539
spastor 0:1c358ea10753 1540 if ((file_path_len + header_len + hash_len) > buffer_size)
spastor 0:1c358ea10753 1541 {
spastor 0:1c358ea10753 1542 FsSetInternalError(context, fs_error_path_too_long);
spastor 0:1c358ea10753 1543 goto close_dir;
spastor 0:1c358ea10753 1544 }
spastor 0:1c358ea10753 1545
spastor 0:1c358ea10753 1546 if (hash_len != 0)
spastor 0:1c358ea10753 1547 {
spastor 0:1c358ea10753 1548 uint8_t * const hash_ptr = data_ptr + file_path_len + header_len;
spastor 0:1c358ea10753 1549 status = call_file_hash_user(connector_ptr, service_request, context, file_path, hash_ptr);
spastor 0:1c358ea10753 1550 if (status == connector_pending || status == connector_abort)
spastor 0:1c358ea10753 1551 goto done;
spastor 0:1c358ea10753 1552
spastor 0:1c358ea10753 1553 if (status == connector_working && context->errnum != NULL)
spastor 0:1c358ea10753 1554 {
spastor 0:1c358ea10753 1555 if (format_file_error_msg(connector_ptr, service_request, context) == connector_abort)
spastor 0:1c358ea10753 1556 {
spastor 0:1c358ea10753 1557 status = connector_abort;
spastor 0:1c358ea10753 1558 }
spastor 0:1c358ea10753 1559 goto done;
spastor 0:1c358ea10753 1560 }
spastor 0:1c358ea10753 1561 resp_len += hash_len;
spastor 0:1c358ea10753 1562 }
spastor 0:1c358ea10753 1563
spastor 0:1c358ea10753 1564 MsgSetLastData(service_data->flags);
spastor 0:1c358ea10753 1565 }
spastor 0:1c358ea10753 1566 else
spastor 0:1c358ea10753 1567 {
spastor 0:1c358ea10753 1568 /* ls command was issued for a directory */
spastor 0:1c358ea10753 1569 file_path = context->data.d.path + context->data.d.path_len;
spastor 0:1c358ea10753 1570
spastor 0:1c358ea10753 1571 while (FsGetState(context) < fs_state_readdir)
spastor 0:1c358ea10753 1572 {
spastor 0:1c358ea10753 1573 /* read next dir entry */
spastor 0:1c358ea10753 1574 size_t len = header_len + hash_len + context->data.d.path_len;
spastor 0:1c358ea10753 1575 size_t path_max = 0;
spastor 0:1c358ea10753 1576
spastor 0:1c358ea10753 1577 context->flags = 0;
spastor 0:1c358ea10753 1578 /* minimum of bytes left for the entry name in output buffer and context->data.d.path buffer */
spastor 0:1c358ea10753 1579 if (len < buffer_size)
spastor 0:1c358ea10753 1580 path_max = MIN_VALUE((buffer_size - len), (CONNECTOR_FILE_SYSTEM_MAX_PATH_LENGTH - context->data.d.path_len));
spastor 0:1c358ea10753 1581
spastor 0:1c358ea10753 1582 status = call_file_readdir_user(connector_ptr, service_request, context, file_path, path_max);
spastor 0:1c358ea10753 1583 if (status == connector_pending)
spastor 0:1c358ea10753 1584 goto done;
spastor 0:1c358ea10753 1585
spastor 0:1c358ea10753 1586 if (!FsOperationSuccess(status, context))
spastor 0:1c358ea10753 1587 goto close_dir;
spastor 0:1c358ea10753 1588
spastor 0:1c358ea10753 1589 if (*file_path == '\0')
spastor 0:1c358ea10753 1590 {
spastor 0:1c358ea10753 1591 /* all entries processed */
spastor 0:1c358ea10753 1592 service_data->length_in_bytes = resp_len;
spastor 0:1c358ea10753 1593 goto close_dir;
spastor 0:1c358ea10753 1594 }
spastor 0:1c358ea10753 1595 /* Don't send "." in any directory and ".." in "/" directory up to Device Cloud */
spastor 0:1c358ea10753 1596 if ((memcmp(file_path, ".", 2) != 0) &&
spastor 0:1c358ea10753 1597 (memcmp(context->data.d.path, "/..", 3) != 0))
spastor 0:1c358ea10753 1598 {
spastor 0:1c358ea10753 1599 FsSetState(context, fs_state_readdir);
spastor 0:1c358ea10753 1600 }
spastor 0:1c358ea10753 1601 }
spastor 0:1c358ea10753 1602
spastor 0:1c358ea10753 1603 file_path_len = strlen(file_path) + 1;
spastor 0:1c358ea10753 1604
spastor 0:1c358ea10753 1605 if (FsGetState(context) < fs_state_stat_dir_entry)
spastor 0:1c358ea10753 1606 {
spastor 0:1c358ea10753 1607 status = call_file_stat_dir_entry_user(connector_ptr, service_request, context, context->data.d.path);
spastor 0:1c358ea10753 1608 if (status == connector_pending)
spastor 0:1c358ea10753 1609 goto done;
spastor 0:1c358ea10753 1610
spastor 0:1c358ea10753 1611 if (!FsOperationSuccess(status, context))
spastor 0:1c358ea10753 1612 goto close_dir;
spastor 0:1c358ea10753 1613
spastor 0:1c358ea10753 1614 FsSetState(context, fs_state_stat_dir_entry);
spastor 0:1c358ea10753 1615 }
spastor 0:1c358ea10753 1616 file_path = context->data.d.path;
spastor 0:1c358ea10753 1617 file_path_len = context->data.d.path_len + file_path_len;
spastor 0:1c358ea10753 1618
spastor 0:1c358ea10753 1619 if (FsIsDir(context))
spastor 0:1c358ea10753 1620 hash_len = 0;
spastor 0:1c358ea10753 1621
spastor 0:1c358ea10753 1622 if (hash_len != 0)
spastor 0:1c358ea10753 1623 {
spastor 0:1c358ea10753 1624 uint8_t * const hash_ptr = data_ptr + file_path_len + header_len;
spastor 0:1c358ea10753 1625
spastor 0:1c358ea10753 1626 if (FsIsReg(context))
spastor 0:1c358ea10753 1627 {
spastor 0:1c358ea10753 1628 status = call_file_hash_user(connector_ptr, service_request, context, file_path, hash_ptr);
spastor 0:1c358ea10753 1629 if (status == connector_pending)
spastor 0:1c358ea10753 1630 goto done;
spastor 0:1c358ea10753 1631
spastor 0:1c358ea10753 1632 if (!FsOperationSuccess(status, context))
spastor 0:1c358ea10753 1633 goto close_dir;
spastor 0:1c358ea10753 1634 }
spastor 0:1c358ea10753 1635 else
spastor 0:1c358ea10753 1636 {
spastor 0:1c358ea10753 1637 memset(hash_ptr, 0, hash_len);
spastor 0:1c358ea10753 1638 }
spastor 0:1c358ea10753 1639 resp_len += hash_len;
spastor 0:1c358ea10753 1640 }
spastor 0:1c358ea10753 1641
spastor 0:1c358ea10753 1642 /* to read next dir entry */
spastor 0:1c358ea10753 1643 FsSetState(context, fs_state_open);
spastor 0:1c358ea10753 1644 }
spastor 0:1c358ea10753 1645 resp_len += format_file_ls_response(context, file_path, file_path_len, data_ptr);
spastor 0:1c358ea10753 1646 service_data->length_in_bytes = resp_len;
spastor 0:1c358ea10753 1647 goto done;
spastor 0:1c358ea10753 1648 }
spastor 0:1c358ea10753 1649
spastor 0:1c358ea10753 1650 close_dir:
spastor 0:1c358ea10753 1651 status = process_get_close(connector_ptr,
spastor 0:1c358ea10753 1652 service_request,
spastor 0:1c358ea10753 1653 context,
spastor 0:1c358ea10753 1654 connector_request_id_file_system_closedir);
spastor 0:1c358ea10753 1655 done:
spastor 0:1c358ea10753 1656 return status;
spastor 0:1c358ea10753 1657 }
spastor 0:1c358ea10753 1658
spastor 0:1c358ea10753 1659 static connector_status_t allocate_file_context(connector_data_t * const connector_ptr,
spastor 0:1c358ea10753 1660 fs_opcode_t const opcode,
spastor 0:1c358ea10753 1661 fs_context_t * * const result)
spastor 0:1c358ea10753 1662 {
spastor 0:1c358ea10753 1663 fs_context_t * context = NULL;
spastor 0:1c358ea10753 1664 connector_status_t status;
spastor 0:1c358ea10753 1665
spastor 0:1c358ea10753 1666 void * ptr;
spastor 0:1c358ea10753 1667
spastor 0:1c358ea10753 1668 status = malloc_data_buffer(connector_ptr, sizeof *context, named_buffer_id(msg_service), &ptr);
spastor 0:1c358ea10753 1669 if (status != connector_working)
spastor 0:1c358ea10753 1670 goto done;
spastor 0:1c358ea10753 1671
spastor 0:1c358ea10753 1672 context = ptr;
spastor 0:1c358ea10753 1673
spastor 0:1c358ea10753 1674 context->handle = NULL;
spastor 0:1c358ea10753 1675 context->user_context = NULL;
spastor 0:1c358ea10753 1676 context->flags = 0;
spastor 0:1c358ea10753 1677 context->errnum = NULL;
spastor 0:1c358ea10753 1678 context->state = fs_state_none;
spastor 0:1c358ea10753 1679 context->status = connector_working;
spastor 0:1c358ea10753 1680
spastor 0:1c358ea10753 1681 if (opcode != fs_ls_request_opcode)
spastor 0:1c358ea10753 1682 {
spastor 0:1c358ea10753 1683 context->data.f.bytes_done = 0;
spastor 0:1c358ea10753 1684 }
spastor 0:1c358ea10753 1685
spastor 0:1c358ea10753 1686 done:
spastor 0:1c358ea10753 1687 *result = context;
spastor 0:1c358ea10753 1688 return status;
spastor 0:1c358ea10753 1689 }
spastor 0:1c358ea10753 1690
spastor 0:1c358ea10753 1691 static connector_status_t file_system_request_callback(connector_data_t * const connector_ptr,
spastor 0:1c358ea10753 1692 msg_service_request_t * const service_request)
spastor 0:1c358ea10753 1693 {
spastor 0:1c358ea10753 1694 msg_session_t * const session = service_request->session;
spastor 0:1c358ea10753 1695 msg_service_data_t * const service_data = service_request->have_data;
spastor 0:1c358ea10753 1696 fs_context_t * context = session->service_context;
spastor 0:1c358ea10753 1697 connector_status_t status = connector_working;
spastor 0:1c358ea10753 1698
spastor 0:1c358ea10753 1699 if (MsgIsStart(service_data->flags))
spastor 0:1c358ea10753 1700 {
spastor 0:1c358ea10753 1701 if (context == NULL)
spastor 0:1c358ea10753 1702 {
spastor 0:1c358ea10753 1703 uint8_t const * const ptr = service_data->data_ptr;
spastor 0:1c358ea10753 1704 const fs_opcode_t opcode = (fs_opcode_t) *ptr;
spastor 0:1c358ea10753 1705
spastor 0:1c358ea10753 1706 status = allocate_file_context(connector_ptr, opcode, &context);
spastor 0:1c358ea10753 1707 if (status != connector_working)
spastor 0:1c358ea10753 1708 {
spastor 0:1c358ea10753 1709 goto done;
spastor 0:1c358ea10753 1710 }
spastor 0:1c358ea10753 1711 session->service_context = context;
spastor 0:1c358ea10753 1712 context->opcode = opcode;
spastor 0:1c358ea10753 1713 }
spastor 0:1c358ea10753 1714 }
spastor 0:1c358ea10753 1715 else
spastor 0:1c358ea10753 1716 {
spastor 0:1c358ea10753 1717 if (context == NULL)
spastor 0:1c358ea10753 1718 {
spastor 0:1c358ea10753 1719 fs_set_service_error(service_request, connector_session_error_format);
spastor 0:1c358ea10753 1720 ASSERT_GOTO(connector_false, done);
spastor 0:1c358ea10753 1721 }
spastor 0:1c358ea10753 1722 }
spastor 0:1c358ea10753 1723
spastor 0:1c358ea10753 1724 if (context->opcode != fs_put_request_opcode)
spastor 0:1c358ea10753 1725 {
spastor 0:1c358ea10753 1726 /* don't support request in >1 message */
spastor 0:1c358ea10753 1727 if ( !(MsgIsStart(service_data->flags) && MsgIsLastData(service_data->flags)) )
spastor 0:1c358ea10753 1728 {
spastor 0:1c358ea10753 1729 FsSetInternalError(context, fs_error_path_too_long);
spastor 0:1c358ea10753 1730 goto done;
spastor 0:1c358ea10753 1731 }
spastor 0:1c358ea10753 1732 }
spastor 0:1c358ea10753 1733
spastor 0:1c358ea10753 1734 switch (context->opcode)
spastor 0:1c358ea10753 1735 {
spastor 0:1c358ea10753 1736 case fs_get_request_opcode:
spastor 0:1c358ea10753 1737 status = process_file_get_request(connector_ptr, service_request, context);
spastor 0:1c358ea10753 1738 break;
spastor 0:1c358ea10753 1739
spastor 0:1c358ea10753 1740 case fs_put_request_opcode:
spastor 0:1c358ea10753 1741 status = process_file_put_request(connector_ptr, service_request, context);
spastor 0:1c358ea10753 1742 break;
spastor 0:1c358ea10753 1743
spastor 0:1c358ea10753 1744 case fs_rm_request_opcode:
spastor 0:1c358ea10753 1745 status = process_file_rm_request(connector_ptr, service_request, context);
spastor 0:1c358ea10753 1746 break;
spastor 0:1c358ea10753 1747
spastor 0:1c358ea10753 1748 case fs_ls_request_opcode:
spastor 0:1c358ea10753 1749 status = process_file_ls_request(connector_ptr, service_request, context);
spastor 0:1c358ea10753 1750 break;
spastor 0:1c358ea10753 1751
spastor 0:1c358ea10753 1752 default:
spastor 0:1c358ea10753 1753 FsSetInternalError(context, fs_error_format);
spastor 0:1c358ea10753 1754 ASSERT(connector_false);
spastor 0:1c358ea10753 1755 }
spastor 0:1c358ea10753 1756
spastor 0:1c358ea10753 1757 done:
spastor 0:1c358ea10753 1758 return status;
spastor 0:1c358ea10753 1759 }
spastor 0:1c358ea10753 1760
spastor 0:1c358ea10753 1761 static connector_status_t file_system_response_callback(connector_data_t * const connector_ptr,
spastor 0:1c358ea10753 1762 msg_service_request_t * const service_request)
spastor 0:1c358ea10753 1763 {
spastor 0:1c358ea10753 1764 msg_session_t * const session = service_request->session;
spastor 0:1c358ea10753 1765 fs_context_t * const context = session->service_context;
spastor 0:1c358ea10753 1766 connector_status_t status = connector_working;
spastor 0:1c358ea10753 1767
spastor 0:1c358ea10753 1768 if (context == NULL)
spastor 0:1c358ea10753 1769 {
spastor 0:1c358ea10753 1770 fs_set_service_error(service_request, connector_session_error_unknown_session);
spastor 0:1c358ea10753 1771 ASSERT_GOTO(connector_false, done);
spastor 0:1c358ea10753 1772 }
spastor 0:1c358ea10753 1773
spastor 0:1c358ea10753 1774
spastor 0:1c358ea10753 1775 switch (context->opcode)
spastor 0:1c358ea10753 1776 {
spastor 0:1c358ea10753 1777 case fs_get_request_opcode:
spastor 0:1c358ea10753 1778 status = process_file_get_response(connector_ptr, service_request, context);
spastor 0:1c358ea10753 1779 break;
spastor 0:1c358ea10753 1780
spastor 0:1c358ea10753 1781 case fs_put_request_opcode:
spastor 0:1c358ea10753 1782 status = process_file_response_nodata(connector_ptr, service_request, context, fs_put_response_opcode);
spastor 0:1c358ea10753 1783 break;
spastor 0:1c358ea10753 1784
spastor 0:1c358ea10753 1785 case fs_rm_request_opcode:
spastor 0:1c358ea10753 1786 status = process_file_response_nodata(connector_ptr, service_request, context, fs_rm_response_opcode);
spastor 0:1c358ea10753 1787 break;
spastor 0:1c358ea10753 1788
spastor 0:1c358ea10753 1789 case fs_ls_request_opcode:
spastor 0:1c358ea10753 1790 status = process_file_ls_response(connector_ptr, service_request, context);
spastor 0:1c358ea10753 1791 break;
spastor 0:1c358ea10753 1792
spastor 0:1c358ea10753 1793 default:
spastor 0:1c358ea10753 1794 fs_set_service_error(service_request, connector_session_error_unknown_session);
spastor 0:1c358ea10753 1795 ASSERT_GOTO(connector_false, done);
spastor 0:1c358ea10753 1796 break;
spastor 0:1c358ea10753 1797 }
spastor 0:1c358ea10753 1798
spastor 0:1c358ea10753 1799 done:
spastor 0:1c358ea10753 1800 return status;
spastor 0:1c358ea10753 1801 }
spastor 0:1c358ea10753 1802
spastor 0:1c358ea10753 1803 static connector_status_t file_system_free_callback(connector_data_t * const connector_ptr,
spastor 0:1c358ea10753 1804 msg_service_request_t * const service_request)
spastor 0:1c358ea10753 1805 {
spastor 0:1c358ea10753 1806 msg_session_t * const session = service_request->session;
spastor 0:1c358ea10753 1807 fs_context_t * const context = session->service_context;
spastor 0:1c358ea10753 1808 connector_status_t status = connector_working;
spastor 0:1c358ea10753 1809
spastor 0:1c358ea10753 1810 if (context != NULL)
spastor 0:1c358ea10753 1811 {
spastor 0:1c358ea10753 1812 status = free_data_buffer(connector_ptr, named_buffer_id(msg_service), context);
spastor 0:1c358ea10753 1813 }
spastor 0:1c358ea10753 1814
spastor 0:1c358ea10753 1815 return status;
spastor 0:1c358ea10753 1816 }
spastor 0:1c358ea10753 1817
spastor 0:1c358ea10753 1818 static connector_status_t call_session_error_user(connector_data_t * const connector_ptr,
spastor 0:1c358ea10753 1819 msg_service_request_t * const service_request,
spastor 0:1c358ea10753 1820 fs_context_t * const context)
spastor 0:1c358ea10753 1821 {
spastor 0:1c358ea10753 1822 connector_status_t status = connector_working;
spastor 0:1c358ea10753 1823
spastor 0:1c358ea10753 1824 if (context != NULL && FsSessionErrorCalled(context))
spastor 0:1c358ea10753 1825 goto done;
spastor 0:1c358ea10753 1826
spastor 0:1c358ea10753 1827 {
spastor 0:1c358ea10753 1828 connector_file_system_session_error_t data;
spastor 0:1c358ea10753 1829 connector_request_id_t request_id;
spastor 0:1c358ea10753 1830 connector_callback_status_t callback_status;
spastor 0:1c358ea10753 1831
spastor 0:1c358ea10753 1832 request_id.file_system_request = connector_request_id_file_system_session_error;
spastor 0:1c358ea10753 1833 data.session_error = service_request->error_value;
spastor 0:1c358ea10753 1834 data.user_context = context == NULL ? NULL : context->user_context;
spastor 0:1c358ea10753 1835
spastor 0:1c358ea10753 1836 callback_status = connector_callback(connector_ptr->callback,
spastor 0:1c358ea10753 1837 connector_class_id_file_system,
spastor 0:1c358ea10753 1838 request_id,
spastor 0:1c358ea10753 1839 &data);
spastor 0:1c358ea10753 1840
spastor 0:1c358ea10753 1841 if (context != NULL)
spastor 0:1c358ea10753 1842 context->user_context = data.user_context;
spastor 0:1c358ea10753 1843
spastor 0:1c358ea10753 1844 switch(callback_status)
spastor 0:1c358ea10753 1845 {
spastor 0:1c358ea10753 1846 case connector_callback_busy:
spastor 0:1c358ea10753 1847 status = connector_pending;
spastor 0:1c358ea10753 1848 goto done;
spastor 0:1c358ea10753 1849
spastor 0:1c358ea10753 1850 case connector_callback_continue:
spastor 0:1c358ea10753 1851 break;
spastor 0:1c358ea10753 1852
spastor 0:1c358ea10753 1853 case connector_callback_abort:
spastor 0:1c358ea10753 1854 default:
spastor 0:1c358ea10753 1855 status = connector_abort;
spastor 0:1c358ea10753 1856 if (context != NULL)
spastor 0:1c358ea10753 1857 context->status = connector_abort;
spastor 0:1c358ea10753 1858 break;
spastor 0:1c358ea10753 1859 }
spastor 0:1c358ea10753 1860
spastor 0:1c358ea10753 1861 if (context != NULL)
spastor 0:1c358ea10753 1862 FsSetSessionErrorCalled(context);
spastor 0:1c358ea10753 1863 }
spastor 0:1c358ea10753 1864
spastor 0:1c358ea10753 1865 done:
spastor 0:1c358ea10753 1866 return status;
spastor 0:1c358ea10753 1867 }
spastor 0:1c358ea10753 1868
spastor 0:1c358ea10753 1869
spastor 0:1c358ea10753 1870 static connector_status_t file_system_session_error_callback(connector_data_t * const connector_ptr,
spastor 0:1c358ea10753 1871 msg_service_request_t * const service_request)
spastor 0:1c358ea10753 1872 {
spastor 0:1c358ea10753 1873 msg_session_t * const session = service_request->session;
spastor 0:1c358ea10753 1874 fs_context_t * const context = session->service_context;
spastor 0:1c358ea10753 1875
spastor 0:1c358ea10753 1876 connector_status_t status = call_session_error_user(connector_ptr, service_request, context);
spastor 0:1c358ea10753 1877
spastor 0:1c358ea10753 1878 if (context != NULL)
spastor 0:1c358ea10753 1879 {
spastor 0:1c358ea10753 1880 connector_request_id_file_system_t fs_request_id = context->opcode == fs_ls_request_opcode ?
spastor 0:1c358ea10753 1881 connector_request_id_file_system_closedir :
spastor 0:1c358ea10753 1882 connector_request_id_file_system_close;
spastor 0:1c358ea10753 1883
spastor 0:1c358ea10753 1884 status = call_file_close_user(connector_ptr, service_request, context, fs_request_id);
spastor 0:1c358ea10753 1885 if (status == connector_pending)
spastor 0:1c358ea10753 1886 goto done;
spastor 0:1c358ea10753 1887
spastor 0:1c358ea10753 1888 if (context->status == connector_abort)
spastor 0:1c358ea10753 1889 status = connector_abort;
spastor 0:1c358ea10753 1890 }
spastor 0:1c358ea10753 1891
spastor 0:1c358ea10753 1892 done:
spastor 0:1c358ea10753 1893 return status;
spastor 0:1c358ea10753 1894 }
spastor 0:1c358ea10753 1895
spastor 0:1c358ea10753 1896
spastor 0:1c358ea10753 1897 static connector_status_t file_system_callback(connector_data_t * const connector_ptr,
spastor 0:1c358ea10753 1898 msg_service_request_t * const service_request)
spastor 0:1c358ea10753 1899 {
spastor 0:1c358ea10753 1900 connector_status_t status = connector_abort;
spastor 0:1c358ea10753 1901
spastor 0:1c358ea10753 1902 ASSERT_GOTO(connector_ptr != NULL, done);
spastor 0:1c358ea10753 1903 ASSERT_GOTO(service_request != NULL, done);
spastor 0:1c358ea10753 1904 ASSERT_GOTO(service_request->session != NULL, done);
spastor 0:1c358ea10753 1905
spastor 0:1c358ea10753 1906 switch (service_request->service_type)
spastor 0:1c358ea10753 1907 {
spastor 0:1c358ea10753 1908 case msg_service_type_have_data:
spastor 0:1c358ea10753 1909 status = file_system_request_callback(connector_ptr, service_request);
spastor 0:1c358ea10753 1910 break;
spastor 0:1c358ea10753 1911
spastor 0:1c358ea10753 1912 case msg_service_type_need_data:
spastor 0:1c358ea10753 1913 status = file_system_response_callback(connector_ptr, service_request);
spastor 0:1c358ea10753 1914 break;
spastor 0:1c358ea10753 1915
spastor 0:1c358ea10753 1916 case msg_service_type_error:
spastor 0:1c358ea10753 1917 status = file_system_session_error_callback(connector_ptr, service_request);
spastor 0:1c358ea10753 1918 break;
spastor 0:1c358ea10753 1919
spastor 0:1c358ea10753 1920 case msg_service_type_free:
spastor 0:1c358ea10753 1921 status = file_system_free_callback(connector_ptr, service_request);
spastor 0:1c358ea10753 1922 break;
spastor 0:1c358ea10753 1923
spastor 0:1c358ea10753 1924 default:
spastor 0:1c358ea10753 1925 ASSERT(connector_false);
spastor 0:1c358ea10753 1926 break;
spastor 0:1c358ea10753 1927 }
spastor 0:1c358ea10753 1928
spastor 0:1c358ea10753 1929 done:
spastor 0:1c358ea10753 1930 return status;
spastor 0:1c358ea10753 1931 }
spastor 0:1c358ea10753 1932
spastor 0:1c358ea10753 1933 static connector_status_t connector_facility_file_system_cleanup(connector_data_t * const connector_ptr)
spastor 0:1c358ea10753 1934 {
spastor 0:1c358ea10753 1935 return msg_cleanup_all_sessions(connector_ptr, msg_service_id_file);
spastor 0:1c358ea10753 1936 }
spastor 0:1c358ea10753 1937
spastor 0:1c358ea10753 1938 static connector_status_t connector_facility_file_system_delete(connector_data_t * const data_ptr)
spastor 0:1c358ea10753 1939 {
spastor 0:1c358ea10753 1940 return msg_delete_facility(data_ptr, msg_service_id_file);
spastor 0:1c358ea10753 1941 }
spastor 0:1c358ea10753 1942
spastor 0:1c358ea10753 1943 static connector_status_t connector_facility_file_system_init(connector_data_t * const data_ptr, unsigned int const facility_index)
spastor 0:1c358ea10753 1944 {
spastor 0:1c358ea10753 1945 return msg_init_facility(data_ptr, facility_index, msg_service_id_file, file_system_callback);
spastor 0:1c358ea10753 1946 }
spastor 0:1c358ea10753 1947