| /openbmc/qemu/qobject/ |
| H A D | json-writer.c | 29 JSONWriter *writer = g_new(JSONWriter, 1); in json_writer_new() local
31 writer->pretty = pretty; in json_writer_new()
32 writer->need_comma = false; in json_writer_new()
33 writer->contents = g_string_new(NULL); in json_writer_new()
34 writer->container_is_array = g_byte_array_new(); in json_writer_new()
35 return writer; in json_writer_new()
38 const char *json_writer_get(JSONWriter *writer) in json_writer_get() argument
40 g_assert(!writer->container_is_array->len); in json_writer_get()
41 return writer->contents->str; in json_writer_get()
44 GString *json_writer_get_and_free(JSONWriter *writer) in json_writer_get_and_free() argument
[all …]
|
| H A D | qjson.c | 151 static void to_json(JSONWriter *writer, const char *name, in to_json() argument
156 json_writer_null(writer, name); in to_json()
163 json_writer_int64(writer, name, val->u.i64); in to_json()
166 json_writer_uint64(writer, name, val->u.u64); in to_json()
169 json_writer_double(writer, name, val->u.dbl); in to_json()
179 json_writer_str(writer, name, qstring_get_str(val)); in to_json()
186 json_writer_start_object(writer, name); in to_json()
191 to_json(writer, qdict_entry_key(entry), qdict_entry_value(entry)); in to_json()
194 json_writer_end_object(writer); in to_json()
201 json_writer_start_array(writer, name); in to_json()
[all …]
|
| /openbmc/openbmc/poky/bitbake/lib/bb/asyncrpc/ |
| H A D | connection.py | 41 def __init__(self, reader, writer, timeout, max_chunk=DEFAULT_MAX_CHUNK): argument
43 self.writer = writer
49 return self.writer.get_extra_info("peername")
53 self.writer.write(c.encode("utf-8"))
54 await self.writer.drain()
76 self.writer.write(("%s\n" % msg).encode("utf-8"))
77 await self.writer.drain()
100 if self.writer is not None:
101 self.writer.close()
102 self.writer = None
|
| /openbmc/openbmc/poky/scripts/pybootchartgui/pybootchartgui/tests/ |
| H A D | parser_test.py | 18 writer = main._mk_writer(options) variable
30 trace = parsing.Trace(writer, args, options)
31 state = parsing.parse_file(writer, trace, self.mk_fname('header'))
36 trace = parsing.Trace(writer, args, options)
37 state = parsing.parse_file(writer, trace, self.mk_fname('proc_diskstats.log'))
41 trace = parsing.Trace(writer, args, options)
42 state = parsing.parse_file(writer, trace, self.mk_fname('proc_ps.log'))
63 trace = parsing.Trace(writer, args, options)
64 state_with_headers = parsing.parse_file(writer, trace, self.mk_fname('header'))
66 …samples = parsing.parse_file(writer, state_with_headers, self.mk_fname('proc_diskstats.log')).disk…
[all …]
|
| H A D | process_tree_test.py | 22 writer = main._mk_writer(options)
23 trace = parsing.Trace(writer, args, options)
25 parsing.parse_file(writer, trace, self.mk_fname('proc_ps.log'))
26 trace.compile(writer)
27 self.processtree = process_tree.ProcessTree(writer, None, trace.ps_stats, \
|
| /openbmc/qemu/python/qemu/qmp/ |
| H A D | util.py | 33 async def flush(writer: asyncio.StreamWriter) -> None:
44 asyncio.WriteTransport, writer.transport
51 await writer.drain()
107 def is_closing(writer: asyncio.StreamWriter) -> bool:
115 return writer.is_closing()
118 transport = writer.transport
123 async def wait_closed(writer: asyncio.StreamWriter) -> None:
130 await writer.wait_closed()
134 transport = writer.transport
|
| /openbmc/openbmc/poky/scripts/pybootchartgui/pybootchartgui/ |
| H A D | parsing.py | 34 def __init__(self, writer, paths, options): argument
58 parse_paths (writer, self, paths)
83 self.compile(writer)
88 idle = self.crop (writer, options.crop_after)
104 self.proc_tree = ProcessTree(writer, self.kernel, self.ps_stats,
111 self.kernel_tree = ProcessTree(writer, self.kernel, None, 0,
131 def compile(self, writer): argument
177 def crop(self, writer, crop_after): argument
204 writer.info("selected proc '%s' from list (start %d)"
208 writer.warn("no selected crop proc '%s' in list" % crop_after)
[all …]
|
| H A D | samples.py | 118 def __init__(self, writer, process_map, sample_count, sample_period, start_time, end_time): argument
124 writer.info ("%d samples, avg. sample length %f" % (self.sample_count, self.sample_period))
125 writer.info ("process list size: %d" % len (self.process_map.values()))
128 def __init__(self, writer, pid, cmd, ppid, start_time): argument
129 self.writer = writer
150 def split(self, writer, pid, cmd, ppid, start_time): argument
151 split = Process (writer, pid, cmd, ppid, start_time)
188 … self.writer.warn("Missing CONFIG_PROC_EVENTS: no parent for pid '%i' ('%s') with ppid '%i'" \
|
| H A D | batch.py | 20 def render(writer, trace, app_options, filename): argument
34 writer.error ("Unknown format '%s'." % fmt)
45 writer.status ("bootchart written to '%s'" % filename)
|
| H A D | process_tree.py | 40 def __init__(self, writer, kernel, psstats, sample_period, argument
43 self.writer = writer
68 writer.status("merged %i logger processes" % removed)
75 …writer.status("pruned %i process, %i exploders, %i threads, and %i runs" % (p_processes, p_explode…
|
| /openbmc/linux/Documentation/trace/ |
| H A D | ring-buffer-design.rst | 28 - the task that writes into the ring buffer (same as writer)
30 writer
81 but a writer may interrupt another writer, but it must finish writing
82 before the previous writer may continue. This is very important to the
94 This is very much like a writer being preempted by an interrupt and
99 cannot preempt/interrupt a writer, but it may read/consume from the
100 buffer at the same time as a writer is writing, but the reader must be
102 and can be preempted by a writer.
104 A writer can preempt a reader, but a reader cannot preempt a writer.
106 as a writer.
[all …]
|
| /openbmc/openbmc/meta-openembedded/meta-oe/recipes-support/bmap-writer/ |
| H A D | bmap-writer_git.bb | 2 DESCRIPTION = "bmap-writer is a command-line utility designed to efficiently write disk images \
5 bmap-writer is C++ based does not require Python and focuses solely on writing an image."
6 HOMEPAGE = "https://github.com/embetrix/bmap-writer"
20 FILES:${PN} = "${bindir}/bmap-writer"
|
| /openbmc/linux/scripts/ |
| H A D | jobserver-exec | 36 writer = os.open(path, os.O_WRONLY) variable
38 reader, writer = [int(x) for x in fds.split(",", 1)]
55 os.write(writer, jobs)
75 os.write(writer, jobs)
|
| /openbmc/google-misc/subprojects/dhcp-done/ |
| H A D | file-io.cpp | 34 stdplus::fd::AtomicWriter writer(filename, 0644); in fileWrite() local
35 stdplus::fd::FormatBuffer out(writer); in fileWrite()
38 writer.commit(); in fileWrite()
|
| /openbmc/linux/include/linux/ |
| H A D | percpu-rwsem.h | 15 struct rcuwait writer; member
34 .writer = __RCUWAIT_INITIALIZER(name.writer), \
119 rcuwait_wake_up(&sem->writer); in percpu_up_read()
|
| /openbmc/linux/tools/testing/radix-tree/ |
| H A D | regression4.c | 60 pthread_t reader, writer; in regression4_test() local
68 pthread_create(&writer, NULL, writer_fn, NULL)) { in regression4_test()
73 if (pthread_join(reader, NULL) || pthread_join(writer, NULL)) { in regression4_test()
|
| /openbmc/linux/Documentation/locking/ |
| H A D | seqlock.rst | 8 Sequence counters are a reader-writer consistency mechanism with
9 lockless readers (read-only retry loops), and no writer starvation. They
30 interrupted writer. If that reader belongs to a real-time scheduling
34 as the writer can invalidate a pointer that the reader is following.
53 requirements of writer serialization and non-preemptibility, use
97 sequence counters associate the lock used for writer serialization at
165 embedded spinlock for writer serialization and non-preemptibility.
195 1. Normal Sequence readers which never block a writer but they must
196 retry if a writer is in progress by detecting change in the sequence
206 2. Locking readers which will wait if a writer or another locking reader
[all …]
|
| /openbmc/openbmc/poky/meta/recipes-devtools/python/python3-installer/ |
| H A D | 0001-src-installer-utils.py-sort-entries-before-writing-o.patch | 22 writer = csv.writer(stream, delimiter=",", quotechar='"', lineterminator="\n")
25 writer.writerow(record.to_row(prefix_for_scheme(scheme)))
|
| /openbmc/linux/lib/ |
| H A D | decompress_unlzma.c | 277 struct writer { struct
292 static inline size_t INIT get_pos(struct writer *wr) in get_pos() argument
298 static inline uint8_t INIT peek_old_byte(struct writer *wr, in peek_old_byte()
316 static inline int INIT write_byte(struct writer *wr, uint8_t byte) in write_byte()
330 static inline int INIT copy_byte(struct writer *wr, uint32_t offs) in copy_byte()
335 static inline int INIT copy_bytes(struct writer *wr, in copy_bytes()
347 static inline int INIT process_bit0(struct writer *wr, struct rc *rc, in process_bit0()
391 static inline int INIT process_bit1(struct writer *wr, struct rc *rc, in process_bit1()
553 struct writer wr; in unlzma()
|
| /openbmc/phosphor-pid-control/sensors/ |
| H A D | pluggable.hpp | 20 std::unique_ptr<WriteInterface> writer) : in PluggableSensor() argument
22 _writer(std::move(writer)) in PluggableSensor()
|
| /openbmc/phosphor-logging/test/openpower-pels/ |
| H A D | section_header_test.cpp | 48 Stream writer{data}; in TEST() local
50 writer << header; in TEST()
|
| /openbmc/openbmc/poky/bitbake/lib/bb/server/ |
| H A D | process.py | 215 self.command_channel_reply.writer.close()
216 self.event_writer.writer.close()
252 writer = ConnectionWriter(ui_fds[0])
253 self.event_handle = bb.event.register_UIHhandler(writer, True)
254 self.event_writer = writer
262 writer = ConnectionWriter(ui_fds[2])
263 self.command_channel_reply = writer
663 writer = ConnectionWriter(readypipeinfd)
670 writer.send("r")
671 writer.close()
[all …]
|
| /openbmc/qemu/tests/unit/ |
| H A D | io-channel-helpers.c | 107 GThread *reader, *writer; in qio_channel_test_run_threads() local
118 writer = g_thread_new("writer", in qio_channel_test_run_threads()
123 g_thread_join(writer); in qio_channel_test_run_threads()
|
| /openbmc/linux/tools/perf/util/ |
| H A D | data-convert-bt.c | 64 struct bt_ctf_writer *writer; member
92 struct ctf_writer writer; member
704 stream = bt_ctf_writer_create_stream(cw->writer, cw->stream_class); in ctf_stream__create()
803 struct ctf_writer *cw = &c->writer; in process_sample_event()
880 struct ctf_writer *cw = &c->writer; \
1373 struct bt_ctf_writer *writer = cw->writer; in ctf_writer__setup_env() local
1377 if (bt_ctf_writer_add_environment_field(writer, __n, __v)) \ in ctf_writer__setup_env()
1502 bt_ctf_writer_put(cw->writer); in ctf_writer__cleanup()
1511 struct bt_ctf_writer *writer; in ctf_writer__init() local
1518 writer = bt_ctf_writer_create(path); in ctf_writer__init()
[all …]
|
| /openbmc/linux/tools/testing/selftests/powerpc/dscr/ |
| H A D | dscr_default_test.c | 41 pthread_t writer; in dscr_default_lockstep_test() local
52 FAIL_IF(pthread_create(&writer, NULL, dscr_default_lockstep_writer, (void *)rw_semaphores)); in dscr_default_lockstep_test()
65 FAIL_IF(pthread_join(writer, NULL)); in dscr_default_lockstep_test()
|