Lines Matching refs:token
131 size_t token_options = pdu->data ? (size_t)(pdu->data - pdu->token) : pdu->used_size;
257 size_t token_options = pdu->data ? (size_t)(pdu->data - pdu->token) : pdu->used_size;
405 coap_cancel_observe(coap_session_t *session, coap_binary_t *token,
421 if ((!token && !lg_crcv->app_token->length) || (token &&
422 coap_binary_equal(token, lg_crcv->app_token))) {
467 * Need to fix lg_xmit stateless token as using tokens from
503 uint64_t token;
518 /* Re-send request with new token */
519 token = STATE_TOKEN_FULL(lg_crcv->state_token,
521 ltoken_len = coap_encode_var_safe8(ltoken, sizeof(token), token);
672 /* See if this token is already in use for large bodies (unlikely) */
723 token_options = pdu->data ? (size_t)(pdu->data - pdu->token) : pdu->used_size;
730 /* May need token of length 8, so account for this */
814 /* Need to keep original token for updating response PDUs */
821 * Need to set up new token for use during transmits
845 * token match is used for Block1 large body transmissions
904 lg_xmit->pdu.token = coap_malloc_type(COAP_PDU_BUF,
906 if (!lg_xmit->pdu.token)
910 lg_xmit->pdu.token += lg_xmit->pdu.max_hdr_size;
911 memcpy(lg_xmit->pdu.token, pdu->token, lg_xmit->pdu.used_size);
913 lg_xmit->pdu.data = lg_xmit->pdu.token + (pdu->data - pdu->token);
914 lg_xmit->pdu.actual_token.s = lg_xmit->pdu.token + pdu->e_token_length -
919 token_options = pdu->data ? (size_t)(pdu->data - pdu->token) : pdu->used_size;
923 /* May need token of length 8, so account for this */
1189 uint64_t token = STATE_TOKEN_FULL(p->state_token, ++p->retry_counter);
1191 size_t len = coap_encode_var_safe8(buf, sizeof(token), token);
1393 pdu->token[pdu->used_size++] = COAP_PAYLOAD_START;
1394 pdu->data = pdu->token + pdu->used_size;
1427 memcpy(&pdu->token[pdu->used_size], val, len);
1646 uint64_t token = coap_decode_var_bytes8(pdu->actual_token.s,
1683 token = STATE_TOKEN_FULL(lg_xmit->b.b1.state_token,++lg_xmit->b.b1.count);
1684 ltoken_length = coap_encode_var_safe8(ltoken, sizeof(token), token);
1729 token = STATE_TOKEN_FULL(lg_xmit->b.b1.state_token,++lg_xmit->b.b1.count);
1730 ltoken_length = coap_encode_var_safe8(ltoken, sizeof(token), token);
1882 * If Observe = 0, save the token away and return NULL
1883 * Else If Observe = 1, return the saved token for this block
1888 uint32_t block_num, coap_bin_const_t *token) {
1901 /* Save the token in lg_crcv */
1911 lg_crcv->obs_token[block_num] = coap_new_bin_const(token->s,
1912 token->length);
1916 /* Use the token in lg_crcv */
1991 uint8_t token[8];
2012 coap_session_new_token(session, &token_len, token);
2013 coap_add_token(pdu, token_len, token);
2033 size_t token_options = pdu->data ? (size_t)(pdu->data - pdu->token) :
2037 pdu->used_size - (pdu->data - pdu->token) : 0;
2044 coap_log_debug("** %s: lg_crcv %p initialized - stateless token xxxx%012llx\n",
2052 /* Make sure that there is space for increased token + option change */
2055 lg_crcv->pdu.token = coap_malloc_type(COAP_PDU_BUF,
2057 if (!lg_crcv->pdu.token) {
2061 lg_crcv->pdu.token += lg_crcv->pdu.max_hdr_size;
2062 memcpy(lg_crcv->pdu.token, pdu->token, token_options);
2064 lg_crcv->pdu.data = lg_crcv->pdu.token + token_options;
2068 /* Need to keep original token for updating response PDUs */
2076 /* Need to set up a base token for actual communications if retries needed */
2106 if (lg_crcv->pdu.token)
2107 coap_free_type(COAP_PDU_BUF, lg_crcv->pdu.token - lg_crcv->pdu.max_hdr_size);
2150 if (lg_xmit->pdu.token) {
2151 coap_free_type(COAP_PDU_BUF, lg_xmit->pdu.token - lg_xmit->pdu.max_hdr_size);
2433 size_t token_options = pdu->data ? (size_t)(pdu->data - pdu->token) : pdu->used_size;
2929 uint64_t token;
2950 token = STATE_TOKEN_FULL(lg_xmit->b.b1.state_token,
2953 token = STATE_TOKEN_FULL(lg_crcv->state_token,
2956 ltoken_len = coap_encode_var_safe8(ltoken, sizeof(token), token);
2966 /* Need to track Observe token change if Observe */
2974 lg_xmit->b.b1.state_token = token;
2976 lg_crcv->state_token = token;
3100 uint64_t token = STATE_TOKEN_FULL(p->b.b1.state_token, ++p->b.b1.count);
3101 size_t len = coap_encode_var_safe8(buf, sizeof(token), token);
3128 size_t token_options = pdu->data ? (size_t)(pdu->data - pdu->token) :
3201 uint64_t token = coap_decode_var_bytes8(rcvd->actual_token.s,
3218 token = STATE_TOKEN_FULL(p->b.b1.state_token,++p->b.b1.count);
3219 ltoken_length = coap_encode_var_safe8(ltoken, sizeof(token), token);
3267 /* need to put back original token into rcvd */
3467 uint64_t token = STATE_TOKEN_FULL(p->state_token,
3469 size_t len = coap_encode_var_safe8(buf, sizeof(token), token);
3577 uint64_t token;
3613 token = STATE_TOKEN_FULL(p->state_token, ++p->retry_counter);
3614 len = coap_encode_var_safe8(buf, sizeof(token), token);
3637 /* need to put back original token into rcvd */
3679 /* need to put back original token into rcvd */
3720 /* need to put back original token into rcvd */
3751 /* need to put back original token into rcvd */
3828 /* need to put back original token into rcvd */