stream_name
if (op->stream_name != NULL) {
c_tgt = helper_local_get_c_stream(hl, op->stream_name);
s_stream_id = helper_get_s_stream(h, op->stream_name);
const char *stream_name;
if (!TEST_ptr(op->stream_name))
if (!TEST_true(helper_local_set_c_stream(hl, op->stream_name, c_stream)))
if (!TEST_ptr(op->stream_name))
if (!TEST_true(helper_local_set_c_stream(hl, op->stream_name, NULL)))
if (!TEST_ptr(op->stream_name))
if (!TEST_true(helper_local_set_c_stream(hl, op->stream_name, c_stream)))
if (!TEST_ptr(op->stream_name))
if (!TEST_true(helper_set_s_stream(h, op->stream_name,
if (!TEST_ptr(op->stream_name))
if (!TEST_true(helper_local_set_c_stream(hl, op->stream_name,
if (!TEST_ptr(op->stream_name))
if (!TEST_true(helper_set_s_stream(h, op->stream_name, new_stream_id)))
if (!TEST_ptr(op->stream_name))
if (!TEST_true(helper_local_set_c_stream(hl, op->stream_name, NULL)))
if (!TEST_ptr(op->stream_name))
if (!TEST_true(helper_set_s_stream(h, op->stream_name, op->arg2)))
if (!TEST_ptr(op->stream_name))
if (!TEST_true(helper_set_s_stream(h, op->stream_name, UINT64_MAX)))
#define OP_C_WRITE(stream_name, buf, buf_len) \
{ OPK_C_WRITE, (buf), (buf_len), NULL, #stream_name },
#define OP_S_WRITE(stream_name, buf, buf_len) \
{ OPK_S_WRITE, (buf), (buf_len), NULL, #stream_name },
#define OP_C_READ_EXPECT(stream_name, buf, buf_len) \
{ OPK_C_READ_EXPECT, (buf), (buf_len), NULL, #stream_name },
#define OP_S_READ_EXPECT(stream_name, buf, buf_len) \
{ OPK_S_READ_EXPECT, (buf), (buf_len), NULL, #stream_name },
#define OP_C_EXPECT_FIN(stream_name) \
{ OPK_C_EXPECT_FIN, NULL, 0, NULL, #stream_name },
#define OP_S_EXPECT_FIN(stream_name) \
{ OPK_S_EXPECT_FIN, NULL, 0, NULL, #stream_name },
#define OP_C_CONCLUDE(stream_name) \
{ OPK_C_CONCLUDE, NULL, 0, NULL, #stream_name },
#define OP_S_CONCLUDE(stream_name) \
{ OPK_S_CONCLUDE, NULL, 0, NULL, #stream_name },
#define OP_C_DETACH(stream_name) \
{ OPK_C_DETACH, NULL, 0, NULL, #stream_name },
#define OP_C_ATTACH(stream_name) \
{ OPK_C_ATTACH, NULL, 0, NULL, #stream_name },
#define OP_C_NEW_STREAM_BIDI(stream_name, expect_id) \
{ OPK_C_NEW_STREAM, NULL, 0, NULL, #stream_name, (expect_id) },
#define OP_C_NEW_STREAM_BIDI_EX(stream_name, expect_id, flags) \
{ OPK_C_NEW_STREAM, NULL, (flags), NULL, #stream_name, (expect_id) },
#define OP_C_NEW_STREAM_UNI(stream_name, expect_id) \
NULL, #stream_name, (expect_id) },
#define OP_C_NEW_STREAM_UNI_EX(stream_name, expect_id, flags) \
NULL, #stream_name, (expect_id) },
#define OP_S_NEW_STREAM_BIDI(stream_name, expect_id) \
{ OPK_S_NEW_STREAM, NULL, 0, NULL, #stream_name, (expect_id) },
#define OP_S_NEW_STREAM_UNI(stream_name, expect_id) \
{ OPK_S_NEW_STREAM, NULL, 1, NULL, #stream_name, (expect_id) },
#define OP_C_ACCEPT_STREAM_WAIT(stream_name) \
{ OPK_C_ACCEPT_STREAM_WAIT, NULL, 0, NULL, #stream_name },
#define OP_C_FREE_STREAM(stream_name) \
{ OPK_C_FREE_STREAM, NULL, 0, NULL, #stream_name },
#define OP_S_BIND_STREAM_ID(stream_name, stream_id) \
{ OPK_S_BIND_STREAM_ID, NULL, 0, NULL, #stream_name, (stream_id) },
#define OP_C_WAIT_FOR_DATA(stream_name) \
{ OPK_C_WAIT_FOR_DATA, NULL, 0, NULL, #stream_name },
#define OP_C_WRITE_FAIL(stream_name) \
{ OPK_C_WRITE_FAIL, NULL, 0, NULL, #stream_name },
#define OP_S_WRITE_FAIL(stream_name) \
{ OPK_S_WRITE_FAIL, NULL, 0, NULL, #stream_name },
#define OP_C_READ_FAIL(stream_name) \
{ OPK_C_READ_FAIL, NULL, 0, NULL, #stream_name },
#define OP_S_READ_FAIL(stream_name, allow_zero_len) \
{ OPK_S_READ_FAIL, NULL, (allow_zero_len), NULL, #stream_name },
#define OP_C_STREAM_RESET(stream_name, aec) \
{ OPK_C_STREAM_RESET, NULL, 0, NULL, #stream_name, (aec) },
#define OP_C_STREAM_RESET_FAIL(stream_name, aec) \
{ OPK_C_STREAM_RESET_FAIL, NULL, 0, NULL, #stream_name, (aec) },
#define OP_S_ACCEPT_STREAM_WAIT(stream_name) \
{ OPK_S_ACCEPT_STREAM_WAIT, NULL, 0, NULL, #stream_name },
#define OP_S_UNBIND_STREAM_ID(stream_name) \
{ OPK_S_UNBIND_STREAM_ID, NULL, 0, NULL, #stream_name },
#define OP_C_READ_FAIL_WAIT(stream_name) \
{ OPK_C_READ_FAIL_WAIT, NULL, 0, NULL, #stream_name },
#define OP_C_EXPECT_SSL_ERR(stream_name, err) \
{ OPK_C_EXPECT_SSL_ERR, NULL, (err), NULL, #stream_name },
#define OP_C_SET_WRITE_BUF_SIZE(stream_name, size) \
{ OPK_C_SET_WRITE_BUF_SIZE, NULL, (size), NULL, #stream_name },
#define OP_C_SKIP_IF_UNBOUND(stream_name, n) \
{ OPK_C_SKIP_IF_UNBOUND, NULL, (n), NULL, #stream_name },
#define OP_C_WRITE_EX2(stream_name, buf, buf_len, flags) \
{ OPK_C_WRITE_EX2, (buf), (buf_len), NULL, #stream_name, (flags) },
const char *stream_name)
if (!TEST_ptr(stream_name))
if (!strcmp(stream_name, "DEFAULT"))
key.name = stream_name;
info->name = stream_name;
const char *stream_name,
STREAM_INFO *info = get_stream_info(hl->c_streams, stream_name);
const char *stream_name)
if (!strcmp(stream_name, "DEFAULT"))
info = get_stream_info(hl->c_streams, stream_name);
helper_set_s_stream(struct helper *h, const char *stream_name,
if (!strcmp(stream_name, "DEFAULT"))
info = get_stream_info(h->s_streams, stream_name);
static uint64_t helper_get_s_stream(struct helper *h, const char *stream_name)
if (!strcmp(stream_name, "DEFAULT"))
info = get_stream_info(h->s_streams, stream_name);
#define OP_NEW_STREAM(conn_name, stream_name, flags) \
OP_PUSH_PZ(#stream_name), \
#define OP_ACCEPT_STREAM_WAIT(conn_name, stream_name, flags) \
OP_PUSH_PZ(#stream_name), \
#define OP_DETACH(conn_name, stream_name) \
OP_PUSH_PZ(#stream_name), \
#define OP_ATTACH(conn_name, stream_name) \
OP_PUSH_PZ(stream_name), \
const char *stream_name;
F_POP(stream_name);
if (!TEST_ptr_null(RADIX_PROCESS_get_obj(RP(), stream_name)))
&& !TEST_true(RADIX_PROCESS_set_ssl(RP(), stream_name, stream))) {
const char *conn_name, *stream_name;
F_POP2(conn_name, stream_name);
if (!TEST_true(RADIX_PROCESS_set_ssl(RP(), stream_name, stream))) {
const char *conn_name, *stream_name;
F_POP2(conn_name, stream_name);
if (!TEST_ptr(stream = RADIX_PROCESS_get_ssl(RP(), stream_name)))
if (!TEST_true(RADIX_PROCESS_set_ssl(RP(), stream_name, NULL)))
stream_name(s));
stream_name(s));
stream_name(s));