Lines Matching refs:mmst
100 static void start_command_packet(MMSTContext *mmst, MMSCSPacketType packet_type)
102 MMSContext *mms = &mmst->mms;
110 bytestream_put_le32(&mms->write_out_ptr, mmst->outgoing_packet_seq++);
126 static int send_command_packet(MMSTContext *mmst)
128 MMSContext *mms = &mmst->mms;
167 static int send_time_test_data(MMSTContext *mmst)
169 start_command_packet(mmst, CS_PKT_TIMING_DATA_REQUEST);
170 insert_command_prefixes(&mmst->mms, 0x00f0f0f0, 0x0004000b);
171 return send_command_packet(mmst);
174 static int send_protocol_select(MMSTContext *mmst)
177 MMSContext *mms = &mmst->mms;
179 start_command_packet(mmst, CS_PKT_PROTOCOL_SELECT);
193 return send_command_packet(mmst);
196 static int send_media_file_request(MMSTContext *mmst)
198 MMSContext *mms = &mmst->mms;
199 start_command_packet(mmst, CS_PKT_MEDIA_FILE_REQUEST);
203 mms_put_utf16(mms, mmst->path + 1); // +1 for skip "/"
205 return send_command_packet(mmst);
208 static void handle_packet_stream_changing_type(MMSTContext *mmst)
210 MMSContext *mms = &mmst->mms;
214 mmst->header_packet_id= AV_RL32(mms->in_buffer + 40 + 7);
215 av_dlog(NULL, "Changed header prefix to 0x%x", mmst->header_packet_id);
218 static int send_keepalive_packet(MMSTContext *mmst)
221 start_command_packet(mmst, CS_PKT_KEEPALIVE);
222 insert_command_prefixes(&mmst->mms, 1, 0x100FFFF);
223 return send_command_packet(mmst);
238 static MMSSCPacketType get_tcp_server_response(MMSTContext *mmst)
242 MMSContext *mms = &mmst->mms;
263 mmst->incoming_flags= mms->in_buffer[3];
309 mmst->incoming_packet_seq = AV_RL32(mms->in_buffer);
311 mmst->incoming_flags = mms->in_buffer[5];
333 if(packet_id_type == mmst->header_packet_id) {
349 if (mmst->incoming_flags == 0x04)
351 } else if(packet_id_type == mmst->packet_id) {
361 send_keepalive_packet(mmst);
364 handle_packet_stream_changing_type(mmst);
372 static int mms_safe_send_recv(MMSTContext *mmst,
373 int (*send_fun)(MMSTContext *mmst),
378 int ret = send_fun(mmst);
385 if ((type = get_tcp_server_response(mmst)) != expect_type) {
395 static int send_media_header_request(MMSTContext *mmst)
397 MMSContext *mms = &mmst->mms;
398 start_command_packet(mmst, CS_PKT_MEDIA_HEADER_REQUEST);
413 return send_command_packet(mmst);
417 static int send_startup_packet(MMSTContext *mmst)
420 MMSContext *mms = &mmst->mms;
427 "7E667F5D-A661-495E-A512-F55686DDA178", mmst->host);
429 start_command_packet(mmst, CS_PKT_INITIAL);
433 return send_command_packet(mmst);
437 static int send_stream_selection_request(MMSTContext *mmst)
440 MMSContext *mms = &mmst->mms;
442 start_command_packet(mmst, CS_PKT_STREAM_ID_REQUEST);
449 return send_command_packet(mmst);
452 static int send_close_packet(MMSTContext *mmst)
454 start_command_packet(mmst, CS_PKT_STREAM_CLOSE);
455 insert_command_prefixes(&mmst->mms, 1, 1);
457 return send_command_packet(mmst);
463 MMSTContext *mmst = (MMSTContext *)h->priv_data;
464 MMSContext *mms = &mmst->mms;
466 send_close_packet(mmst);
477 static int send_media_packet_request(MMSTContext *mmst)
479 MMSContext *mms = &mmst->mms;
480 start_command_packet(mmst, CS_PKT_START_FROM_PKT_ID);
490 mmst->packet_id++; // new packet_id
491 bytestream_put_le32(&mms->write_out_ptr, mmst->packet_id);
492 return send_command_packet(mmst);
504 MMSTContext *mmst = h->priv_data;
510 mms = &mmst->mms;
514 mmst->host, sizeof(mmst->host), &port, mmst->path,
515 sizeof(mmst->path), uri);
521 ff_url_join(tcpname, sizeof(tcpname), "tcp", NULL, mmst->host, port, NULL);
527 mmst->packet_id = 3; // default, initial value.
528 mmst->header_packet_id = 2; // default, initial value.
529 err = mms_safe_send_recv(mmst, send_startup_packet, SC_PKT_CLIENT_ACCEPTED);
532 err = mms_safe_send_recv(mmst, send_time_test_data, SC_PKT_TIMING_TEST_REPLY);
535 err = mms_safe_send_recv(mmst, send_protocol_select, SC_PKT_PROTOCOL_ACCEPTED);
538 err = mms_safe_send_recv(mmst, send_media_file_request, SC_PKT_MEDIA_FILE_DETAILS);
541 err = mms_safe_send_recv(mmst, send_media_header_request, SC_PKT_HEADER_REQUEST_ACCEPTED);
544 err = mms_safe_send_recv(mmst, NULL, SC_PKT_ASF_HEADER);
547 if((mmst->incoming_flags != 0X08) && (mmst->incoming_flags != 0X0C)) {
564 err = mms_safe_send_recv(mmst, send_stream_selection_request, SC_PKT_STREAM_ID_ACCEPTED);
568 err = mms_safe_send_recv(mmst, send_media_packet_request, SC_PKT_MEDIA_PKT_FOLLOWS);
584 MMSTContext *mmst = h->priv_data;
585 MMSContext *mms = &mmst->mms;
598 int err = mms_safe_send_recv(mmst, NULL, SC_PKT_ASF_MEDIA);
623 .name = "mmst",