Home
last modified time | relevance | path

Searched refs:stream (Results 1 – 25 of 32) sorted by relevance

12

/systemd-251/src/resolve/
Dresolved-dnstls-openssl.c17 static int dnstls_flush_write_buffer(DnsStream *stream) { in dnstls_flush_write_buffer() argument
20 assert(stream); in dnstls_flush_write_buffer()
21 assert(stream->encrypted); in dnstls_flush_write_buffer()
23 if (stream->dnstls_data.buffer_offset < stream->dnstls_data.write_buffer->length) { in dnstls_flush_write_buffer()
24 assert(stream->dnstls_data.write_buffer->data); in dnstls_flush_write_buffer()
27 … iov[0] = IOVEC_MAKE(stream->dnstls_data.write_buffer->data + stream->dnstls_data.buffer_offset, in dnstls_flush_write_buffer()
28 … stream->dnstls_data.write_buffer->length - stream->dnstls_data.buffer_offset); in dnstls_flush_write_buffer()
29 ss = dns_stream_writev(stream, iov, 1, DNS_STREAM_WRITE_TLS_DATA); in dnstls_flush_write_buffer()
32 stream->dnstls_events |= EPOLLOUT; in dnstls_flush_write_buffer()
36 stream->dnstls_data.buffer_offset += ss; in dnstls_flush_write_buffer()
[all …]
Dresolved-dnstls-gnutls.c31 int dnstls_stream_connect_tls(DnsStream *stream, DnsServer *server) { in dnstls_stream_connect_tls() argument
35 assert(stream); in dnstls_stream_connect_tls()
47 … r = gnutls_credentials_set(gs, GNUTLS_CRD_CERTIFICATE, stream->manager->dnstls_data.cert_cred); in dnstls_stream_connect_tls()
64 stream->dnstls_data.validation.type = GNUTLS_DT_IP_ADDRESS; in dnstls_stream_connect_tls()
66 … stream->dnstls_data.validation.data = (unsigned char*) &server->address.in.s_addr; in dnstls_stream_connect_tls()
67 stream->dnstls_data.validation.size = 4; in dnstls_stream_connect_tls()
69 stream->dnstls_data.validation.data = server->address.in6.s6_addr; in dnstls_stream_connect_tls()
70 stream->dnstls_data.validation.size = 16; in dnstls_stream_connect_tls()
72 gnutls_session_set_verify_cert2(gs, &stream->dnstls_data.validation, 1, 0); in dnstls_stream_connect_tls()
84 gnutls_transport_set_ptr2(gs, (gnutls_transport_ptr_t) (long) stream->fd, stream); in dnstls_stream_connect_tls()
[all …]
Dresolved-dnstls.h26 int dnstls_stream_connect_tls(DnsStream *stream, DnsServer *server);
27 void dnstls_stream_free(DnsStream *stream);
28 int dnstls_stream_on_io(DnsStream *stream, uint32_t revents);
29 int dnstls_stream_shutdown(DnsStream *stream, int error);
30 ssize_t dnstls_stream_writev(DnsStream *stream, const struct iovec *iov, size_t iovcnt);
31 ssize_t dnstls_stream_read(DnsStream *stream, void *buf, size_t count);
Dtest-resolved-stream.c184 static void send_simple_question(DnsStream *stream, uint16_t type) { in send_simple_question() argument
195 assert_se(dns_stream_write_packet(stream, p) >= 0); in send_simple_question()
202 static int on_stream_packet(DnsStream *stream, DnsPacket *p) { in on_stream_packet() argument
214 _cleanup_(dns_stream_unrefp) DnsStream *stream = NULL; in test_dns_stream()
263 assert_se(dns_stream_new(&manager, &stream, DNS_STREAM_LOOKUP, DNS_PROTOCOL_DNS, in test_dns_stream()
275 assert_se(dnstls_stream_connect_tls(stream, &server) >= 0); in test_dns_stream()
281 send_simple_question(stream, DNS_TYPE_A); in test_dns_stream()
292 send_simple_question(stream, DNS_TYPE_AAAA); in test_dns_stream()
305 send_simple_question(stream, DNS_TYPE_A); in test_dns_stream()
306 send_simple_question(stream, DNS_TYPE_AAAA); in test_dns_stream()
Dmeson.build38 'resolved-dns-stream.c',
39 'resolved-dns-stream.h',
204 [files('test-resolved-stream.c')
Dresolved-dns-transaction.c59 if (t->stream) { in dns_transaction_close_connection()
61 LIST_REMOVE(transactions_by_stream, t->stream->transactions, t); in dns_transaction_close_connection()
64 dns_packet_unref(ordered_set_remove(t->stream->write_queue, t->sent)); in dns_transaction_close_connection()
66 t->stream = dns_stream_unref(t->stream); in dns_transaction_close_connection()
653 … if (t && t->stream == s) /* Validate that the stream we got this on actually is the stream the in on_stream_packet()
703 …if (t->server->stream && (DNS_SERVER_FEATURE_LEVEL_IS_TLS(t->current_feature_level) == t->server->… in dns_transaction_emit_tcp()
704 s = dns_stream_ref(t->server->stream); in dns_transaction_emit_tcp()
774 t->server->stream = dns_stream_ref(s); in dns_transaction_emit_tcp()
783 t->stream = TAKE_PTR(s); in dns_transaction_emit_tcp()
784 LIST_PREPEND(transactions_by_stream, t->stream->transactions, t); in dns_transaction_emit_tcp()
[all …]
Dresolved-dns-scope.c977 void dns_scope_process_query(DnsScope *s, DnsStream *stream, DnsPacket *p) { in dns_scope_process_query() argument
1034 if (stream) { in dns_scope_process_query()
1035 r = dns_stream_write_packet(stream, reply); in dns_scope_process_query()
1044 if (DNS_STREAM_QUEUED(stream)) in dns_scope_process_query()
1045 dns_stream_ref(stream); in dns_scope_process_query()
Dresolved-llmnr.c301 DnsStream *stream; in on_llmnr_stream() local
314 r = dns_stream_new(m, &stream, DNS_STREAM_LLMNR_RECV, DNS_PROTOCOL_LLMNR, cfd, NULL, in on_llmnr_stream()
Dresolved-dns-scope.h90 void dns_scope_process_query(DnsScope *s, DnsStream *stream, DnsPacket *p);
Dresolved-dns-transaction.h92 DnsStream *stream; member
Dresolved-dns-server.h68 DnsStream *stream; member
Dresolved-dns-stub.c1056 DnsStream *stream; in on_dns_stub_stream_internal() local
1067 r = dns_stream_new(m, &stream, DNS_STREAM_STUB, DNS_PROTOCOL_DNS, cfd, NULL, in on_dns_stub_stream_internal()
1074 stream->stub_listener_extra = l; in on_dns_stub_stream_internal()
Dresolved-dns-stream.c593 if (s->server->stream != s) in dns_stream_detach()
/systemd-251/src/journal/
Djournald-stream.c644 _cleanup_(stdout_stream_freep) StdoutStream *stream = NULL; in stdout_stream_install()
655 stream = new(StdoutStream, 1); in stdout_stream_install()
656 if (!stream) in stdout_stream_install()
659 *stream = (StdoutStream) { in stdout_stream_install()
665 xsprintf(stream->id_field, "_STREAM_ID=" SD_ID128_FORMAT_STR, SD_ID128_FORMAT_VAL(id)); in stdout_stream_install()
667 r = getpeercred(fd, &stream->ucred); in stdout_stream_install()
676 r = getpeersec(fd, &stream->label); in stdout_stream_install()
683 … r = sd_event_add_io(s->event, &stream->event_source, fd, EPOLLIN, stdout_stream_process, stream); in stdout_stream_install()
687 r = sd_event_source_set_priority(stream->event_source, SD_EVENT_PRIORITY_NORMAL+5); in stdout_stream_install()
691 stream->fd = fd; in stdout_stream_install()
[all …]
Dfuzz-journald-stream.c16 StdoutStream *stream; in LLVMFuzzerTestOneInput() local
27 assert_se(stdout_stream_install(&s, stream_fds[0], &stream) >= 0); in LLVMFuzzerTestOneInput()
32 stdout_stream_destroy(stream); in LLVMFuzzerTestOneInput()
Dmeson.build18 'journald-stream.c',
19 'journald-stream.h',
99 [files('test-journal-stream.c'),
141 [files('fuzz-journald-stream.c',
/systemd-251/src/basic/
Duser-util.c962 int putpwent_sane(const struct passwd *pw, FILE *stream) { in putpwent_sane() argument
964 assert(stream); in putpwent_sane()
967 if (putpwent(pw, stream) != 0) in putpwent_sane()
973 int putspent_sane(const struct spwd *sp, FILE *stream) { in putspent_sane() argument
975 assert(stream); in putspent_sane()
978 if (putspent(sp, stream) != 0) in putspent_sane()
984 int putgrent_sane(const struct group *gr, FILE *stream) { in putgrent_sane() argument
986 assert(stream); in putgrent_sane()
989 if (putgrent(gr, stream) != 0) in putgrent_sane()
996 int putsgent_sane(const struct sgrp *sg, FILE *stream) { in putsgent_sane() argument
[all …]
Duser-util.h121 int fgetpwent_sane(FILE *stream, struct passwd **pw);
122 int fgetspent_sane(FILE *stream, struct spwd **sp);
123 int fgetgrent_sane(FILE *stream, struct group **gr);
124 int putpwent_sane(const struct passwd *pw, FILE *stream);
125 int putspent_sane(const struct spwd *sp, FILE *stream);
126 int putgrent_sane(const struct group *gr, FILE *stream);
128 int fgetsgent_sane(FILE *stream, struct sgrp **sg);
129 int putsgent_sane(const struct sgrp *sg, FILE *stream);
/systemd-251/src/coredump/
Dcoredump.c587 _cleanup_fclose_ FILE *stream = NULL; in compose_open_fds() local
604 stream = open_memstream_unlocked(&buffer, &size); in compose_open_fds()
605 if (!stream) in compose_open_fds()
617 fprintf(stream, "%s%s:%s\n", fddelim, de->d_name, fdname); in compose_open_fds()
638 fputs(line, stream); in compose_open_fds()
639 fputc('\n', stream); in compose_open_fds()
644 stream = safe_fclose(stream); in compose_open_fds()
/systemd-251/.github/workflows/
Dmkosi.yml46 release: 8-stream
48 release: 9-stream
/systemd-251/test/
Dtest-exec-deserialization.py212 unittest.main(testRunner=unittest.TextTestRunner(stream=sys.stdout, verbosity=3))
Dsysv-generator-test.py411 unittest.main(testRunner=unittest.TextTestRunner(stream=sys.stdout, verbosity=2))
/systemd-251/docs/
DJOURNAL_FILE_FORMAT.md38 If you need access to the raw journal data in serialized stream form without C
43 stream-based nature it is not indexed.
100 present them as single stream to the user.
311 should hence carry the same seqnum_id. This should guarantee a monotonic stream
531 away as first two objects in the stream.
DJOURNAL_NATIVE_PROTOCOL.md167 connected to the Journal's stream transport, look for the `$JOURNAL_STREAM`
DUSERDB_AND_DESKTOPS.md85 providing a stream-lined UI for enrolling new-style authentication tokens such

12