jackiehou / mp3lame Goto Github PK

   if (isStartStream) {
       memset(input, 0, sizeof(input));

       memcpy(input, buf, DEFAULT_BUF_LENGTH);
       lame_encode_buffer(lame, input, NULL, len, output_buf, len);
       
     SentNum = send(ConnectionDesc, output_buf, sizeof(output_buf), MSG_NOSIGNAL);
        if (SentNum < 0) {
            fprintf(stderr, "Error sending stream: \"%s\". Close the connection!\n", strerror(errno));

            // Close connection
            close_connection(ConnectionDesc);
            isStartStream = false;

            // Stop reading samples from dongle
            rtlsdr_cancel_async(dongle.dev);
            pthread_join(dongle.thread, NULL);
            isReading = false;
        }
    }