Lines Matching refs:av_val
414 const char *socksport = strchr(sockshost->av_val, ':'); in SocksSetup()
415 char *hostname = strdup(sockshost->av_val); in SocksSetup()
418 hostname[socksport - sockshost->av_val] = '\0'; in SocksSetup()
419 r->Link.sockshost.av_val = hostname; in SocksSetup()
423 RTMP_Log(RTMP_LOGDEBUG, "Connecting via SOCKS proxy: %s:%d", r->Link.sockshost.av_val, in SocksSetup()
428 r->Link.sockshost.av_val = NULL; in SocksSetup()
455 RTMP_Log(RTMP_LOGDEBUG, "Hostname : %.*s", host->av_len, host->av_val); in RTMP_SetupStream()
457 RTMP_Log(RTMP_LOGDEBUG, "Playpath : %s", playpath->av_val); in RTMP_SetupStream()
459 if (tcUrl && tcUrl->av_val) in RTMP_SetupStream()
460 RTMP_Log(RTMP_LOGDEBUG, "tcUrl : %s", tcUrl->av_val); in RTMP_SetupStream()
461 if (swfUrl && swfUrl->av_val) in RTMP_SetupStream()
462 RTMP_Log(RTMP_LOGDEBUG, "swfUrl : %s", swfUrl->av_val); in RTMP_SetupStream()
463 if (pageUrl && pageUrl->av_val) in RTMP_SetupStream()
464 RTMP_Log(RTMP_LOGDEBUG, "pageUrl : %s", pageUrl->av_val); in RTMP_SetupStream()
465 if (app && app->av_val) in RTMP_SetupStream()
466 RTMP_Log(RTMP_LOGDEBUG, "app : %.*s", app->av_len, app->av_val); in RTMP_SetupStream()
467 if (auth && auth->av_val) in RTMP_SetupStream()
468 RTMP_Log(RTMP_LOGDEBUG, "auth : %s", auth->av_val); in RTMP_SetupStream()
469 if (subscribepath && subscribepath->av_val) in RTMP_SetupStream()
470 RTMP_Log(RTMP_LOGDEBUG, "subscribepath : %s", subscribepath->av_val); in RTMP_SetupStream()
471 if (usherToken && usherToken->av_val) in RTMP_SetupStream()
472 RTMP_Log(RTMP_LOGDEBUG, "NetStream.Authenticate.UsherToken : %s", usherToken->av_val); in RTMP_SetupStream()
473 if (flashVer && flashVer->av_val) in RTMP_SetupStream()
474 RTMP_Log(RTMP_LOGDEBUG, "flashVer : %s", flashVer->av_val); in RTMP_SetupStream()
486 memcpy(r->Link.SWFHash, swfSHA256Hash->av_val, sizeof(r->Link.SWFHash)); in RTMP_SetupStream()
615 RTMP_Log(RTMP_LOGERROR, "%10s %-7s %s\n", options[i].name.av_val, in RTMP_OptUsage()
625 char *p, *arg = av->av_val; in parseAMF()
638 prop.p_vu.p_aval.av_val = p; in parseAMF()
669 prop.p_name.av_val = (char *)arg+3; in parseAMF()
681 prop.p_vu.p_aval.av_val = p; in parseAMF()
720 if (strcasecmp(opt->av_val, options[i].name.av_val)) continue; in RTMP_SetOpt()
728 long l = strtol(arg->av_val, NULL, 0); in RTMP_SetOpt()
736 if (strcasecmp(arg->av_val, truth[j].av_val)) continue; in RTMP_SetOpt()
749 RTMP_Log(RTMP_LOGERROR, "Unknown option %s", opt->av_val); in RTMP_SetOpt()
781 opt.av_val = p1; in RTMP_SetupURL()
784 arg.av_val = p2; in RTMP_SetupURL()
812 arg.av_len = p2 - arg.av_val; in RTMP_SetupURL()
821 r->Link.tcUrl.av_val = url; in RTMP_SetupURL()
824 if (r->Link.app.av_val < url + len) in RTMP_SetupURL()
827 r->Link.tcUrl.av_len = r->Link.app.av_len + (r->Link.app.av_val - url); in RTMP_SetupURL()
833 r->Link.tcUrl.av_val = malloc(len); in RTMP_SetupURL()
834 r->Link.tcUrl.av_len = snprintf(r->Link.tcUrl.av_val, len, in RTMP_SetupURL()
837 r->Link.hostname.av_len, r->Link.hostname.av_val, in RTMP_SetupURL()
839 r->Link.app.av_len, r->Link.app.av_val); in RTMP_SetupURL()
851 RTMP_HashSWF(r->Link.swfUrl.av_val, &r->Link.SWFSize, in RTMP_SetupURL()
874 if (host->av_val[host->av_len]) in add_addr_info()
877 memcpy(hostname, host->av_val, host->av_len); in add_addr_info()
882 hostname = host->av_val; in add_addr_info()
900 if (hostname != host->av_val) in add_addr_info()
1000 r->m_clientID.av_val = NULL; in RTMP_Connect1()
1765 RTMP_Log(RTMP_LOGDEBUG, "FCSubscribe: %s", subscribepath->av_val); in SendFCSubscribe()
1797 RTMP_Log(RTMP_LOGDEBUG, "UsherToken: %s", usherToken->av_val); in SendUsherToken()
2210 r->Link.playpath.av_val); in SendPlay()
2396 free(vals[i].name.av_val); in AV_erase()
2402 vals[i].name.av_val = NULL; in AV_erase()
2420 memcpy(tmp, av->av_val, av->av_len); in AV_queue()
2424 (*vals)[(*num)++].name.av_val = tmp; in AV_queue()
2432 free(vals[i].name.av_val); in AV_clear()
2516 if (av->av_val[i] == c) in AValChr()
2517 return &av->av_val[i]; in AValChr()
2540 if (strstr(description->av_val, av_authmod_adobe.av_val) != NULL) in PublisherAuth()
2542 if(strstr(description->av_val, "code=403 need auth") != NULL) in PublisherAuth()
2544 if (strstr(r->Link.app.av_val, av_authmod_adobe.av_val) != NULL) { in PublisherAuth()
2548 pubToken.av_val = malloc(r->Link.pubUser.av_len + av_authmod_adobe.av_len + 8); in PublisherAuth()
2549 pubToken.av_len = sprintf(pubToken.av_val, "?%s&user=%s", in PublisherAuth()
2550 av_authmod_adobe.av_val, in PublisherAuth()
2551 r->Link.pubUser.av_val); in PublisherAuth()
2552 RTMP_Log(RTMP_LOGDEBUG, "%s, pubToken1: %s", __FUNCTION__, pubToken.av_val); in PublisherAuth()
2558 else if((token_in = strstr(description->av_val, "?reason=needauth")) != NULL) in PublisherAuth()
2578 aptr->av_len = par - aptr->av_val - 1; in PublisherAuth()
2582 user.av_val = val; in PublisherAuth()
2585 salt.av_val = val; in PublisherAuth()
2588 opaque.av_val = val; in PublisherAuth()
2591 challenge.av_val = val; in PublisherAuth()
2598 aptr->av_len = strlen(aptr->av_val); in PublisherAuth()
2602 MD5_Update(&md5ctx, user.av_val, user.av_len); in PublisherAuth()
2603 MD5_Update(&md5ctx, salt.av_val, salt.av_len); in PublisherAuth()
2604 MD5_Update(&md5ctx, r->Link.pubPasswd.av_val, r->Link.pubPasswd.av_len); in PublisherAuth()
2607 user.av_val, salt.av_val, r->Link.pubPasswd.av_val); in PublisherAuth()
2622 MD5_Update(&md5ctx, opaque.av_val, opaque.av_len); in PublisherAuth()
2624 MD5_Update(&md5ctx, challenge.av_val, challenge.av_len); in PublisherAuth()
2629 salted2, opaque.av_len ? opaque.av_val : "", challenge2); in PublisherAuth()
2636 pubToken.av_val = malloc(32 + B64INT_LEN + B64DIGEST_LEN + opaque.av_len); in PublisherAuth()
2637 pubToken.av_len = sprintf(pubToken.av_val, in PublisherAuth()
2641 opaque.av_len ? opaque.av_val : ""); in PublisherAuth()
2642 RTMP_Log(RTMP_LOGDEBUG, "%s, pubToken2: %s", __FUNCTION__, pubToken.av_val); in PublisherAuth()
2645 else if(strstr(description->av_val, "?reason=authfailed") != NULL) in PublisherAuth()
2650 else if(strstr(description->av_val, "?reason=nosuchuser") != NULL) in PublisherAuth()
2658 __FUNCTION__, description->av_val); in PublisherAuth()
2663 strncpy(ptr, r->Link.app.av_val, r->Link.app.av_len); in PublisherAuth()
2664 strncpy(ptr + r->Link.app.av_len, pubToken.av_val, pubToken.av_len); in PublisherAuth()
2667 free(r->Link.app.av_val); in PublisherAuth()
2668 r->Link.app.av_val = ptr; in PublisherAuth()
2671 strncpy(ptr, r->Link.tcUrl.av_val, r->Link.tcUrl.av_len); in PublisherAuth()
2672 strncpy(ptr + r->Link.tcUrl.av_len, pubToken.av_val, pubToken.av_len); in PublisherAuth()
2675 free(r->Link.tcUrl.av_val); in PublisherAuth()
2676 r->Link.tcUrl.av_val = ptr; in PublisherAuth()
2678 free(pubToken.av_val); in PublisherAuth()
2682 r->Link.app.av_len, r->Link.app.av_val, in PublisherAuth()
2683 r->Link.tcUrl.av_len, r->Link.tcUrl.av_val, in PublisherAuth()
2684 r->Link.playpath.av_val); in PublisherAuth()
2686 else if (strstr(description->av_val, av_authmod_llnw.av_val) != NULL) in PublisherAuth()
2688 if(strstr(description->av_val, "code=403 need auth") != NULL) in PublisherAuth()
2692 if (strstr(r->Link.app.av_val, av_authmod_llnw.av_val) != NULL) { in PublisherAuth()
2696 pubToken.av_val = malloc(r->Link.pubUser.av_len + av_authmod_llnw.av_len + 8); in PublisherAuth()
2697 pubToken.av_len = sprintf(pubToken.av_val, "?%s&user=%s", in PublisherAuth()
2698 av_authmod_llnw.av_val, in PublisherAuth()
2699 r->Link.pubUser.av_val); in PublisherAuth()
2700 RTMP_Log(RTMP_LOGDEBUG, "%s, pubToken1: %s", __FUNCTION__, pubToken.av_val); in PublisherAuth()
2706 else if((token_in = strstr(description->av_val, "?reason=needauth")) != NULL) in PublisherAuth()
2745 aptr->av_len = par - aptr->av_val - 1; in PublisherAuth()
2749 user.av_val = val; in PublisherAuth()
2752 nonce.av_val = val; in PublisherAuth()
2759 aptr->av_len = strlen(aptr->av_val); in PublisherAuth()
2768 MD5_Update(&md5ctx, user.av_val, user.av_len); in PublisherAuth()
2772 MD5_Update(&md5ctx, r->Link.pubPasswd.av_val, r->Link.pubPasswd.av_len); in PublisherAuth()
2775 user.av_val, realm, r->Link.pubPasswd.av_val); in PublisherAuth()
2784 apptmp.av_len = ptr - apptmp.av_val; in PublisherAuth()
2789 MD5_Update(&md5ctx, apptmp.av_val, apptmp.av_len); in PublisherAuth()
2794 method, apptmp.av_len, apptmp.av_val); in PublisherAuth()
2802 MD5_Update(&md5ctx, nonce.av_val, nonce.av_len); in PublisherAuth()
2813 hash1, nonce.av_val, nchex, cnonce, qop, hash2); in PublisherAuth()
2820 …pubToken.av_val = malloc(64 + sizeof(authmod)-1 + user.av_len + nonce.av_len + sizeof(cnonce)-1 + … in PublisherAuth()
2821 sprintf(pubToken.av_val, in PublisherAuth()
2823 nonce.av_val, cnonce, nchex, hash3); in PublisherAuth()
2824 pubToken.av_len = strlen(pubToken.av_val); in PublisherAuth()
2825 RTMP_Log(RTMP_LOGDEBUG, "%s, pubToken2: %s", __FUNCTION__, pubToken.av_val); in PublisherAuth()
2829 else if(strstr(description->av_val, "?reason=authfail") != NULL) in PublisherAuth()
2834 else if(strstr(description->av_val, "?reason=nosuchuser") != NULL) in PublisherAuth()
2842 __FUNCTION__, description->av_val); in PublisherAuth()
2847 strncpy(ptr, r->Link.app.av_val, r->Link.app.av_len); in PublisherAuth()
2848 strncpy(ptr + r->Link.app.av_len, pubToken.av_val, pubToken.av_len); in PublisherAuth()
2851 free(r->Link.app.av_val); in PublisherAuth()
2852 r->Link.app.av_val = ptr; in PublisherAuth()
2855 strncpy(ptr, r->Link.tcUrl.av_val, r->Link.tcUrl.av_len); in PublisherAuth()
2856 strncpy(ptr + r->Link.tcUrl.av_len, pubToken.av_val, pubToken.av_len); in PublisherAuth()
2859 free(r->Link.tcUrl.av_val); in PublisherAuth()
2860 r->Link.tcUrl.av_val = ptr; in PublisherAuth()
2862 free(pubToken.av_val); in PublisherAuth()
2866 r->Link.app.av_len, r->Link.app.av_val, in PublisherAuth()
2867 r->Link.tcUrl.av_len, r->Link.tcUrl.av_val, in PublisherAuth()
2868 r->Link.playpath.av_val); in PublisherAuth()
2935 RTMP_Log(RTMP_LOGDEBUG, "%s, server invoking <%s>", __FUNCTION__, method.av_val); in HandleInvoke()
2949 if (!methodInvoked.av_val) { in HandleInvoke()
2956 methodInvoked.av_val); in HandleInvoke()
3014 free(methodInvoked.av_val); in HandleInvoke()
3065 if (!methodInvoked.av_val) in HandleInvoke()
3073 methodInvoked.av_val); in HandleInvoke()
3083 … RTMP_Log(RTMP_LOGDEBUG, "%s, error description: %s", __FUNCTION__, description.av_val); in HandleInvoke()
3097 free(methodInvoked.av_val); in HandleInvoke()
3115 RTMP_Log(RTMP_LOGDEBUG, "%s, onStatus: %s", __FUNCTION__, code.av_val); in HandleInvoke()
3123 RTMP_Log(RTMP_LOGERROR, "Closing connection: %s", code.av_val); in HandleInvoke()
3235 !memcmp(prop->p_name.av_val, name->av_val, name->av_len)) in RTMP_FindPrefixProperty()
3265 RTMP_Log(RTMP_LOGINFO, "%.*s:", prop->p_name.av_len, prop->p_name.av_val); in DumpMetaData()
3277 prop->p_vu.p_aval.av_val); in DumpMetaData()
3291 prop->p_name.av_val, str); in DumpMetaData()
4104 RTMP_Log(RTMP_LOGDEBUG, "Invoking %s", method.av_val); in RTMP_SendPacket()
4147 if (r->m_clientID.av_val) in CloseInternal()
4150 free(r->m_clientID.av_val); in CloseInternal()
4151 r->m_clientID.av_val = NULL; in CloseInternal()
4216 free(r->Link.tcUrl.av_val); in CloseInternal()
4217 r->Link.tcUrl.av_val = NULL; in CloseInternal()
4222 free(r->Link.app.av_val); in CloseInternal()
4223 r->Link.app.av_val = NULL; in CloseInternal()
4229 free(r->Link.playpath0.av_val); in CloseInternal()
4230 r->Link.playpath0.av_val = NULL; in CloseInternal()
4346 ptr = (unsigned char *)key->av_val; in DecodeTEA()
4372 ptr = (unsigned char *)text->av_val; in DecodeTEA()
4402 memcpy(text->av_val, out, text->av_len); in DecodeTEA()
4418 r->m_clientID.av_val ? r->m_clientID.av_val : "", in HTTP_Post()
4419 r->m_msgCounter, r->Link.hostname.av_len, r->Link.hostname.av_val, in HTTP_Post()
4465 if (ptr + (r->m_clientID.av_val ? 1 : hlen) > r->m_sb.sb_start + r->m_sb.sb_size) in HTTP_read()
4475 if (!r->m_clientID.av_val) in HTTP_read()
4478 r->m_clientID.av_val = malloc(hlen+1); in HTTP_read()
4479 if (!r->m_clientID.av_val) in HTTP_read()
4481 r->m_clientID.av_val[0] = '/'; in HTTP_read()
4482 memcpy(r->m_clientID.av_val+1, ptr, hlen-1); in HTTP_read()
4483 r->m_clientID.av_val[hlen] = 0; in HTTP_read()