| /spdk/scripts/ |
| H A D | eofnl | 8 f="$1" 10 if [ -z "$f" ]; then 15 if [ ! -f "$f" ]; then 19 if [[ $(tail -c1 "$f") ]]; then 20 echo "$f: No newline at end of file" 21 echo '' >> "$f" 25 if [[ ! $(tail -c2 "$f") ]]; then 26 echo "$f: Extra trailing newline" 30 if grep -q $'\r' "$f"; then 31 echo "$f: DOS-style newlines" [all …]
|
| H A D | spdx.sh | 86 for f in $(git ls-files '**/*.c' '**/*.cpp' '**/*.h' '**/*.cc' '**/*.go'); do 87 get_sha $f 93 echo $f 94 sed -i "$((start - 1)),+$((count))d" $f 95 sed -i '1,3d' $f 96 sed -i '1 i /* SPDX-License-Identifier: BSD-3-Clause' $f 107 for f in $(git ls-files CONFIG MAKEFILE '**/*.mk' '**/Makefile'); do 108 get_sha $f 114 echo $f 115 sed -i "$((start - 1)),+$((count))d" $f [all …]
|
| H A D | sma.py | 48 logging.info(f'Overriding "{argname}" value from command-line') 67 logging.error(f'Couldn\'t find device: {name}') 69 logging.info(f'Registering device: {name}') 86 logging.error(f'Invalid crypto engine: {name}') 95 logging.debug(f'Loading external device: {plugin}.{device.__name__}') 99 logging.debug(f'Loading external crypto engine: {plugin}.{engine.name}')
|
| H A D | calc-iobuf.py | 46 value = input(f'{i.prefix}{i.name}: ') 267 print(f'{appname}: {args.format}: Invalid format') 271 with open(args.config, 'r') as f: 272 config = json.load(f) 289 print(f'Minimum small pool size: {pool.small}') 290 print(f'Minimum large pool size: {pool.large}') 292 print(f'{appname}: {args.config}: {os.strerror(errno.ENOENT)}') 295 print(f'{appname}: {args.config}: {os.strerror(errno.EINVAL)}')
|
| H A D | genconfig.py | 24 with open("mk/config.mk") as f: 25 for line in f:
|
| /spdk/doc/ |
| H A D | two.min.js | 34 …f){null==c&&(c=a||0,a=0);f=f||1;c=Math.max(Math.ceil((c-a)/f),0);for(var e=Array(c),d=0;d<c;d++,a+… argument 35 …f&&a.bind===f)return f.apply(a,x.call(arguments,1));var e=x.call(arguments,2);return function(){a.… 36 …f=[],e=0;e<c.length;e++)f.push(a[c[e]]);return f},each:function(a,c,f){f=f||this;for(var e=!q(a)&&… argument 37 …f=Math.PI,t=f/2,v=Math.pow,B=Math.min,z=Math.max,A=0,x=d.natural.slice,u=l.performance&&l.performa… argument 38 f,!!e):a.attachEvent("on"+c,f);return w},unbind:function(a,c,f,e){w.hasEventListeners?a.removeEvent… argument 41 …n a},Utils:d.extend(d,{performance:u,defineProperty:function(a){var c="_"+a,f="_flag"+a.charAt(0).… 42 …f]=!0}})},release:function(a){d.isObject(a)&&(d.isFunction(a.unbind)&&a.unbind(),a.vertices&&(d.is… 43 200===f.status&&c(f.responseText)};f.send();return f},Curve:{CollinearityEpsilon:v(10,-30),Recursio… 49 …f=[];a&&a._matrix;)f.push(a._matrix),a=a.parent;f.reverse();d.each(f,function(a){a=a.elements;c.mu… argument 50 …f.y,f.x),rotation:c}},applySvgAttributes:function(a,c){var f={},e={},g;if(getComputedStyle){var n=… [all …]
|
| /spdk/test/app/jsoncat/ |
| H A D | jsoncat.c | 44 FILE *f = cb_ctx; in json_write_cb() local 47 rc = fwrite(data, 1, size, f); in json_write_cb() 52 process_file(const char *filename, FILE *f, uint32_t parse_flags, uint32_t write_flags) in process_file() argument 61 buf = spdk_posix_file_load(f, &size); in process_file() 118 FILE *f; in main() local 148 f = stdin; in main() 150 f = fopen(filename, "r"); in main() 151 if (f == NULL) { in main() 157 rc = process_file(filename, f, parse_flags, write_flags); in main() 159 if (f != stdin) { in main() [all …]
|
| /spdk/python/spdk/rpc/ |
| H A D | helpers.py | 11 def wrap(f): argument 13 ret = f(*args, **kwargs) 14 print("{} is deprecated, use {} instead.".format(old_name, f.__name__), file=sys.stderr) 17 deprecated_aliases[old_name] = f.__name__ 18 setattr(sys.modules[f.__module__], old_name, old_f) 19 return f
|
| /spdk/ |
| H A D | autorun_post.py | 31 with open(output_file, 'w') as f: 33 f.write('<table>\n') 34 f.write(table_row.format('Total number of tests', total_tests_number)) 35 f.write(table_row.format('Tests executed', executed_tests)) 36 f.write(table_row.format('Number of test executions', tests_executions)) 37 f.write('</table>\n') 38 f.write(pivot_by_test.to_html(None)) 60 for f in covfiles: 61 print(f) 78 …lcov = ['lcov', *lcov_opts, '-q', *itertools.chain(*[('-a', f) for f in covfiles]), '-o', cov_tota… [all …]
|
| /spdk/lib/log/ |
| H A D | log_flags.c | 114 spdk_log_usage(FILE *f, const char *log_arg) in spdk_log_usage() argument 128 fprintf(f, "%s", first_line); in spdk_log_usage() 134 fprintf(f, "\n%s", LINE_PREFIX); in spdk_log_usage() 138 fprintf(f, "%s", flag->name); in spdk_log_usage() 145 fprintf(f, "%s", ENTRY_SEPARATOR); in spdk_log_usage() 149 fprintf(f, ")\n"); in spdk_log_usage()
|
| /spdk/python/spdk/sma/device/ |
| H A D | nvmf_vfiouser.py | 45 self._prefix = f'{self.protocol}' 59 logging.error(f'Transport query NVMe/vfiouser failed') 123 raise DeviceException(grpc.StatusCode.INTERNAL, f'Socket path error {path}') 172 dev_id = f'{self.name}-{physical_id}' 173 subnqn = f'nqn.2016-06.io.spdk:{dev_id}' 196 return sma_pb2.CreateDeviceResponse(handle=f'{self._prefix}:{subnqn}') 210 nqn = request.handle[len(f'{self._prefix}:'):] 223 raise DeviceException(grpc.StatusCode.INTERNAL, f'Socket path error {path}') 253 nqn = request.device_handle[len(f'{self._prefix}:'):] 281 nqn = request.device_handle[len(f'{self._prefix}:'):] [all …]
|
| H A D | nvmf_tcp.py | 38 def _check_transport(f): argument 43 return f(self, *args) 115 logging.warning(f'Failed to delete subsystem: {params.subnqn}') 119 return sma_pb2.CreateDeviceResponse(handle=f'nvmf-tcp:{params.subnqn}') 135 logging.info(f'Tried to delete a non-existing device: {nqn}') 189 logging.info(f'Tried to detach non-existing volume: {volume}') 197 logging.info(f'Tried to detach volume: {volume} from non-existing ' + 198 f'device: {nqn}')
|
| H A D | vhost_blk.py | 41 self._prefix = f'{self.protocol}' 171 ctrlr = f'sma-{params.physical_id}' 186 return sma_pb2.CreateDeviceResponse(handle=f'{self.protocol}:{ctrlr}') 190 ctrlr = request.handle[len(f'{self._prefix}:'):] 199 ctrlr = request.device_handle[len(f'{self._prefix}:'):]
|
| /spdk/python/spdk/sma/volume/ |
| H A D | volume.py | 47 def _locked(f): argument 51 return f(self, *args, **kwargs) 87 log.warning(f'Found disconnected volume: {volume_id}') 92 log.error(f'Failure when trying to disconnect volumes: {ex.message}') 94 log.error(f'Failed to retrieve bdevs: {ex.message}') 130 log.debug(f'Starting discovery service {name}') 146 log.debug(f'Stopping discovery service {name}, refcnt={refcnt}') 160 log.debug(f'Stopped discovery service {name}') 192 logging.warning(f'Failed to cleanup crypto: {ex.message}') 272 log.warning(f'Failed to cleanup discovery service: {name}') [all …]
|
| /spdk/lib/trace/ |
| H A D | trace_flags.c | 201 spdk_trace_mask_usage(FILE *f, const char *tmask_arg) in spdk_trace_mask_usage() argument 214 fprintf(f, " %s, --tpoint-group <group-name>[:<tpoint_mask>]\n", tmask_arg); in spdk_trace_mask_usage() 215 fprintf(f, "%s%s", LINE_PREFIX, first_entry); in spdk_trace_mask_usage() 222 fprintf(f, "\n%s", LINE_PREFIX); in spdk_trace_mask_usage() 226 fprintf(f, "%s%s", register_fn->name, ENTRY_SEPARATOR); in spdk_trace_mask_usage() 231 fprintf(f, " "); in spdk_trace_mask_usage() 233 fprintf(f, "%s\n", last_entry); in spdk_trace_mask_usage() 240 fprintf(f, "%stpoint_mask - tracepoint mask for enabling individual tpoints inside\n", in spdk_trace_mask_usage() 242 fprintf(f, "%sa tracepoint group. First tpoint inside a group can be enabled by\n", in spdk_trace_mask_usage() 244 fprintf(f, "%ssetting tpoint_mask to 1 (e.g. bdev:0x1). Groups and masks can be\n", in spdk_trace_mask_usage() [all …]
|
| /spdk/scripts/bpf/ |
| H A D | trace.py | 66 raise ValueError(f'Unexpected argument: {name}') 81 raise ValueError(f'Couldn\'t find probe: "{probe.name}"') 109 files = filter(lambda f: len(f) > 0, str(files, 'ascii').split('\n')) 123 usdt = (f'usdt:__EXE__:{probe.name} {{' + 124 f'printf("{probe.name}: ') 128 argcast = {int: lambda x: x, str: lambda x: f'str({x})'} 129 argstr = [f'{a.name}={argtype[a.type]}' for a in args.values()] 130 argval = [f'{argcast[a.type](f"arg{a.pos}")}' for a in args.values()] 145 subprocess.run([f'{os.path.dirname(__file__)}/../bpftrace.sh', 146 f'{pid}', f'{script.name}']) [all …]
|
| /spdk/test/iscsi_tgt/calsoft/ |
| H A D | calsoft.py | 56 with open(log_dir_path + case + '.txt', 'w') as f: 57 f.write(case_log) 123 with open(output_file, 'w') as f: 124 json.dump(obj=result, fp=f, indent=2)
|
| /spdk/test/blobfs/rocksdb/ |
| H A D | postprocess.py | 21 with open(sys.argv[1] + "/" + sys.argv[2] + ".perf.txt") as f: 22 for line in f: 64 with open(sys.argv[1] + "/" + sys.argv[2] + "_db_bench.txt") as f: 65 for line in f:
|
| /spdk/examples/go/hello_gorpc/ |
| H A D | hello_gorpc.go | 58 fs.Visit(func(f *flag.Flag) { 59 paramsMap[f.Name] = f.Value
|
| /spdk/test/vhost/windows/ |
| H A D | windows_scsi_compliance.py | 144 not_expected_fails = [f for f in fails if f[1] not in expected_fails and "WIN_SCSI_2" in f[0]]
|
| /spdk/test/dd/ |
| H A D | common.sh | 26 local f 27 for f; do : > "$f"; done
|
| /spdk/test/common/config/pkgdep/patches/qat/ |
| H A D | 0001-no-vmlinux.patch | |
| /spdk/test/sma/plugins/plugin1/ |
| H A D | __init__.py | 33 return sma_pb2.CreateDeviceResponse(handle=f'{self.protocol}:{self.name}:{crypto}') 42 return sma_pb2.CreateDeviceResponse(handle=f'{self.protocol}:{self.name}:{crypto}')
|
| /spdk/test/sma/plugins/plugin2/ |
| H A D | __init__.py | 33 return sma_pb2.CreateDeviceResponse(handle=f'{self.protocol}:{self.name}:{crypto}') 42 return sma_pb2.CreateDeviceResponse(handle=f'{self.protocol}:{self.name}:{crypto}')
|
| /spdk/rpmbuild/ |
| H A D | spdk.spec | 66 local dst=$1 f 69 shift; for f; do [[ -e $f ]] && cp -a "$f" "$dst"; done 75 cfs "$1" $(find "$2" -name '*.so*' -type f -o -type l | grep -v .symbols)
|