Class: DS9::Server

Inherits:

Session

• Object
• Session
• DS9::Server

Defined in:

ext/ds9/ds9.c

Instance Method Summary

• #submit_headers(stream_id, headers) ⇒ Object
• #submit_push_promise(stream_id, headers) ⇒ Object
• #submit_response(stream_id, headers) ⇒ Object
• #submit_shutdown ⇒ Object
• #submit_trailer(stream_id, trailers) ⇒ Object

Methods inherited from Session

#initialize, #last_proc_stream_id, #mem_receive, #mem_send, #outbound_queue_size, #receive, #resume_data, #send, #stream_local_closed?, #stream_remote_closed?, #submit_goaway, #submit_ping, #submit_settings, #terminate_session, #want_read?, #want_write?

Constructor Details

This class inherits a constructor from DS9::Session

Instance Method Details

#submit_headers(stream_id, headers) ⇒ Object

# File 'ext/ds9/ds9.c', line 870

static VALUE server_submit_headers(VALUE self, VALUE stream_id, VALUE headers) {
    nghttp2_session *session;
    size_t niv;
    nghttp2_nv *nva, *head;
    int rv;
    copy_header_func_t copy_func;

    TypedData_Get_Struct(self, nghttp2_session, &ds9_session_type, session);
    CheckSelf(session);

    switch(TYPE(headers))
    {
	case T_ARRAY:
	    niv = RARRAY_LEN(headers);
	    copy_func = copy_list_to_nv;
	    break;
	case T_HASH:
	    niv = RHASH_SIZE(headers);
	    copy_func = copy_hash_to_nv;
	    break;
	default:
	    Check_Type(headers, T_ARRAY);
    }

    nva = xcalloc(niv, sizeof(nghttp2_nv));

    copy_func(headers, nva, niv);

    /* nghttp2_submit_headers is too low level API for ds9 */
    rv = nghttp2_submit_response(session, NUM2INT(stream_id), nva, niv, NULL);

    xfree(nva);

    if (0 != rv) {
	explode(rv);
    }

    return self;
}

#submit_push_promise(stream_id, headers) ⇒ Object

# File 'ext/ds9/ds9.c', line 954

static VALUE server_submit_push_promise(VALUE self, VALUE stream_id, VALUE headers)
{
    nghttp2_session *session;
    nghttp2_nv *nva, *head;
    size_t niv, i;
    int rv;

    TypedData_Get_Struct(self, nghttp2_session, &ds9_session_type, session);
    CheckSelf(session);

    Check_Type(headers, T_ARRAY);
    niv = RARRAY_LEN(headers);
    nva = xcalloc(niv, sizeof(nghttp2_nv));
    head = nva;

    for(i = 0; i < niv; i++, head++) {
	VALUE tuple = rb_ary_entry(headers, (long)i);
	VALUE name = rb_ary_entry(tuple, 0);
	VALUE value = rb_ary_entry(tuple, 1);

	head->name = (uint8_t *)StringValuePtr(name);
	head->namelen = RSTRING_LEN(name);

	head->value = (uint8_t *)StringValuePtr(value);
	head->valuelen = RSTRING_LEN(value);
	head->flags = NGHTTP2_NV_FLAG_NONE;
    }

    rv = nghttp2_submit_push_promise(session, 0, NUM2INT(stream_id), nva, niv, NULL);

    xfree(nva);

    switch(rv) {
	case NGHTTP2_ERR_NOMEM:
	case NGHTTP2_ERR_PROTO:
	case NGHTTP2_ERR_STREAM_ID_NOT_AVAILABLE:
	case NGHTTP2_ERR_INVALID_ARGUMENT:
	    return explode(rv);
	    break;
	default:
	    return INT2NUM(rv);
    }
}

#submit_response(stream_id, headers) ⇒ Object

# File 'ext/ds9/ds9.c', line 827

static VALUE server_submit_response(VALUE self, VALUE stream_id, VALUE headers)
{
    nghttp2_session *session;
    size_t niv;
    nghttp2_nv *nva, *head;
    nghttp2_data_provider provider;
    int rv;
    copy_header_func_t copy_func;

    TypedData_Get_Struct(self, nghttp2_session, &ds9_session_type, session);
    CheckSelf(session);

    switch(TYPE(headers))
    {
	case T_ARRAY:
	    niv = RARRAY_LEN(headers);
	    copy_func = copy_list_to_nv;
	    break;
	case T_HASH:
	    niv = RHASH_SIZE(headers);
	    copy_func = copy_hash_to_nv;
	    break;
	default:
	    Check_Type(headers, T_ARRAY);
    }

    nva = xcalloc(niv, sizeof(nghttp2_nv));

    copy_func(headers, nva, niv);

    provider.read_callback = rb_data_read_callback;

    rv = nghttp2_submit_response(session, NUM2INT(stream_id), nva, niv, &provider);

    xfree(nva);

    if (0 != rv) {
	explode(rv);
    }

    return self;
}

#submit_shutdown ⇒ Object

# File 'ext/ds9/ds9.c', line 696

static VALUE session_submit_shutdown(VALUE self)
{
    int rv;
    nghttp2_session *session;

    TypedData_Get_Struct(self, nghttp2_session, &ds9_session_type, session);
    CheckSelf(session);

    rv = nghttp2_submit_shutdown_notice(session);

    if (rv == 0)
	return Qtrue;

    return explode(rv);
}

#submit_trailer(stream_id, trailers) ⇒ Object

# File 'ext/ds9/ds9.c', line 466

static VALUE session_submit_trailer(VALUE self, VALUE stream_id, VALUE trailers)
{
    size_t niv;
    nghttp2_nv *nva;
    nghttp2_session *session;
    int rv;
    int32_t s_id;
    copy_header_func_t copy_func;

    TypedData_Get_Struct(self, nghttp2_session, &ds9_session_type, session);
    CheckSelf(session);

    s_id = NUM2INT(stream_id);

    switch(TYPE(trailers))
    {
	case T_ARRAY:
	    niv = RARRAY_LEN(trailers);
	    copy_func = copy_list_to_nv;
	    break;
	case T_HASH:
	    niv = RHASH_SIZE(trailers);
	    copy_func = copy_hash_to_nv;
	    break;
	default:
	    Check_Type(trailers, T_ARRAY);
    }

    nva = xcalloc(niv, sizeof(nghttp2_nv));
    copy_func(trailers, nva, niv);

    rv = nghttp2_submit_trailer(session, s_id, nva, niv);

    xfree(nva);

    if (0 != rv) {
	explode(rv);
    }

    return self;
}