zotan/nginx-mod-rtmp
1
1
Fork 0
mirror of https://github.com/zotanmew/nginx-rtmp-module.git synced 2024-05-15 08:21:09 +02:00
Code Issues Projects Releases Wiki Activity

added reverse bit copy func

Browse source
This commit is contained in:
Roman Arutyunyan 2012-03-20 18:06:19 +04:00
parent f925fd0bc6
commit 140a322b99
2 changed files with 23 additions and 36 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

52
ngx_rtmp.c
View file

@ -288,42 +288,6 @@ ngx_rtmp_init_events(ngx_conf_t *cf, ngx_rtmp_core_main_conf_t *cmcf)
return NGX_OK;
}
/*
static ngx_int_t
ngx_rtmp_init_amf0_handler(ngx_rtmp_core_main_conf_t *cmcf,
ngx_int_t id, ngx_array_t *array, ngx_hash_t *hash,
ngx_rtmp_event_handler_pt handler)
{
ngx_hash_init_t calls_hash;
ngx_rtmp_event_handler_pt *eh;
ngx_hash_key_t *h;
size_t n;
eh = ngx_array_push(&cmcf->events[id]);
*eh = handler;
h = array->elts;
for(n = 0; n < array->nelts; ++n, ++h) {
h->key_hash = ngx_hash_key_lc(h->key.data, h->key.len);
}
calls_hash.hash = hash;
calls_hash.key = ngx_hash_key_lc;
calls_hash.max_size = 512;
calls_hash.bucket_size = ngx_cacheline_size;
calls_hash.name = "amf0_hash";
calls_hash.pool = cf->pool;
calls_hash.temp_pool = NULL;
if (ngx_hash_init(&calls_hash, array->elts, array->nelts)
!= NGX_OK)
{
return NGX_ERROR;
}
return NGX_OK;
}
*/
static ngx_int_t
ngx_rtmp_init_event_handlers(ngx_conf_t *cf, ngx_rtmp_core_main_conf_t *cmcf)
@ -689,3 +653,19 @@ ngx_rtmp_cmp_conf_addrs(const void *one, const void *two)
return 0;
}
void *
ngx_rtmp_rmemcpy(void *dst, void* src, size_t n)
{
u_char *d, *s;
d = dst;
s = (u_char*)src + n - 1;
while(s >= (u_char*)src) {
*d++ = *s--;
}
return dst;
}

7
ngx_rtmp.h
View file

@ -291,6 +291,13 @@ u_char * ngx_rtmp_log_error(ngx_log_t *log, u_char *buf, size_t len);
uint32_t ngx_rtmp_get_timestamp();
/* Bit reverse: we need big-endians in many places */
void * ngx_rtmp_rmemcpy(void *dst, void* src, size_t n);
#define ngx_rtmp_rcpymem(dst, src, n) \
(((u_char*)ngx_rtmp_rmemcpy(dst, src, n)) + (n))
/* Receiving messages */
ngx_int_t ngx_rtmp_protocol_message_handler(ngx_rtmp_session_t *s,
ngx_rtmp_header_t *h, ngx_chain_t *in);