Recherche avancée

Médias (0)

Mot : - Tags -/acrobat

Aucun média correspondant à vos critères n’est disponible sur le site.

Autres articles (72)

  • Organiser par catégorie

    17 mai 2013, par

    Dans MédiaSPIP, une rubrique a 2 noms : catégorie et rubrique.
    Les différents documents stockés dans MédiaSPIP peuvent être rangés dans différentes catégories. On peut créer une catégorie en cliquant sur "publier une catégorie" dans le menu publier en haut à droite ( après authentification ). Une catégorie peut être rangée dans une autre catégorie aussi ce qui fait qu’on peut construire une arborescence de catégories.
    Lors de la publication prochaine d’un document, la nouvelle catégorie créée sera proposée (...)

  • Récupération d’informations sur le site maître à l’installation d’une instance

    26 novembre 2010, par

    Utilité
    Sur le site principal, une instance de mutualisation est définie par plusieurs choses : Les données dans la table spip_mutus ; Son logo ; Son auteur principal (id_admin dans la table spip_mutus correspondant à un id_auteur de la table spip_auteurs)qui sera le seul à pouvoir créer définitivement l’instance de mutualisation ;
    Il peut donc être tout à fait judicieux de vouloir récupérer certaines de ces informations afin de compléter l’installation d’une instance pour, par exemple : récupérer le (...)

  • Encoding and processing into web-friendly formats

    13 avril 2011, par

    MediaSPIP automatically converts uploaded files to internet-compatible formats.
    Video files are encoded in MP4, Ogv and WebM (supported by HTML5) and MP4 (supported by Flash).
    Audio files are encoded in MP3 and Ogg (supported by HTML5) and MP3 (supported by Flash).
    Where possible, text is analyzed in order to retrieve the data needed for search engine detection, and then exported as a series of image files.
    All uploaded files are stored online in their original format, so you can (...)

Sur d’autres sites (5593)

  • Capture from multiple streams concurrently, best way to do it and how to reduce CPU usage

    19 juin 2019, par DRONE_6969

    I am currently in the process of writing an application that will capture a lot of RTSP streams(in my case its 12) and display it on the QT widget. The problem arouses when I am going beyond around 6-7 streams, the CPU usage spikes and there is visible stutter.

    The reason why I think that it is not QT draw function is because I have done some checking to measure how much time it takes to draw an incoming image from camera and just sample images I had, it is always a lot less than 33 milliseconds(even if there are 12 widgets being updated).

    I also just ran opencv capture method without drawing and got pretty much the same CPU consumption as if I was drawing the frames (lost like 10% CPU at most and GPU usage went to zero).

    IMPORTANT : I am using RTSP stream which is a h264 stream.

    IF IT MATTERS MY SPECS :

    Intel Core i7-6700 @ 3.40GHZ(8 CPUS)
    Memory : 16gb
    GPU : Intel HD Graphics 530

    (Also I ran my code on a computer with dedicated Graphics card, it did eliminate some stutter but CPU usage is still pretty high)

    I am currently using OPENCV 4.1.0 with GSTREAMER enabled and built, I also have the OPENCV-WORLD version, there is no difference in performance.

    I have created a special class called Camera that holds its frame size constraints and various control functions as well stream function. The stream function is being ran on a separate thread, whenever stream() function is done with current frame it sends ready Mat via onNewFrame event I created which converts to QPixmap and updates widget’s lastImage variable. This way I can update image in a more thread safe way.

    I have tried to manipulate those VideoCapture.set() values, but it didn’t really help.

    This is my stream function (Ignore the bool return, it doesn’t do anything it is a remnant from couple of minutes ago when I was trying to use std::async) :

    bool Camera::stream() {
    
    /* This function is meant to run on a separate thread and fill up the buffer independantly of
    
    main stream thread */
    
    //cv::setNumThreads(100);
    
    /* Rules for these slightly changed! */
    
    Mat pre;  // Grab initial undoctored frame
    
    //pre = Mat::zeros(size, CV_8UC1);
    
    Mat frame; // Final modified frame
    
    frame = Mat::zeros(size, CV_8UC1);
    
    if (!pre.isContinuous()) pre = pre.clone();
    

    
    ipCam.open(streamUrl, CAP_FFMPEG);
    

    

    
    while (ipCam.isOpened() && capture) {
    
        // If camera is opened wel need to capture and process the frame
    
        try {
    
            auto start = std::chrono::system_clock::now();
    

    
            ipCam >> pre;
    

    
            if (pre.empty()) {
    
                /* Check for blank frame, return error if there is a blank frame*/
    
                cerr << id << ": ERROR! blank frame grabbed\n";
    
                for (FrameListener* i : clients) {
    
                    i->onNotification(1); // Notify clients about this shit
    
                }
    
                break;
    
            }
    

    
            else {
    
                // Only continue if frame not empty
    

    
                if (pre.cols != size.width && pre.rows != size.height) {
    
                    resize(pre, frame, size);
    
                    pre.release();
    
                }
    
                else {
    
                    frame = pre;
    
                }
    

    
                dPacket* pack = new dPacket{id,&frame};
    
                for (auto i : clients) {
    
                    i->onPNewFrame(pack);
    
                }
    
                frame.release();
    
                delete pack;
    
            }
    
        }
    

    
        catch (int e) {
    
            cout << endl << "-----Exception during capture process! CODE " << e << endl;
    
        }
    
        // End camera manipulations
    
    }
    

    
    cout << "Camera timed out, or connection is closed..." << endl;
    
    if (tryResetConnection) {
    
        cout << "Reconnection flag is set, retrying after 3 seconds..." << endl;
    
        for (FrameListener* i : clients) {
    
            i->onNotification(-1); // Notify clients about this shit
    
        }
    
        this_thread::sleep_for(chrono::milliseconds(3000));
    
        stream();
    
    }
    

    
    return true;
    
}

    This is my onPNewFrame function. The conversion is still being done on camera’s thread because it was called within stream() and therefore is within that scope(and I also checked) :

    void GLWidget::onPNewFrame(dPacket* inPack) {
    
    lastFlag = 0;
    

    
    if (bufferEnabled) {
    
        buffer.push(QPixmap::fromImage(toQImageFromPMat(inPack->frame)));
    
    }
    
    else {
    
        if (playing) {
    
            /* Only process if this widget is playing */
    
            frameProcessing = true;
    
            lastImage.convertFromImage(toQImageFromPMat(inPack->frame));
    
            frameProcessing = false;
    
        }
    
    }
    

    
    if (lastFlag != -1 && !lastImage.isNull()) {
    
        connecting = false;
    
    }
    
    else {
    
        connecting = true;
    
    }
    
}

    This is my Mat to QImage :

    QImage GLWidget::toQImageFromPMat(cv::Mat* mat) {
    

    

    

    
    return QImage(mat->data, mat->cols, mat->rows, QImage::Format_RGB888).rgbSwapped();

    NOTE : not converting does not result in CPU boost (at least not a significant one).

    Minimal verifiable example

    This program is large. I am going to paste GLWidget.cpp and GLWidget.h as well as Camera.h and Camera.cpp. You can put GLWidget into anything just as long as you spawn more than 6 of it. Camera relies on the CamUtils, but it is possible to just paste url in videocapture

    I also supplied CamUtils, just in case

    Camera.h :

    #pragma once
    
#include <iostream>
    
#include <vector>
    
#include <fstream>
    
#include <map>
    
#include <string>
    
#include <sstream>
    
#include <algorithm>
    
#include "FrameListener.h"
    
#include 
    
#include <thread>
    
#include "CamUtils.h"
    
#include <ctime>
    
#include "dPacket.h"
    

    
using namespace std;
    
using namespace cv;
    

    
class Camera
    
{
    

    
    /*
    
        CLEANED UP!
    
        Camera now is only responsible for streaming and echoing captured frames.
    
        Frames are now wrapped into dPacket struct.
    
    */
    

    

    
private:
    
    string id;
    
    vector clients;
    
    VideoCapture ipCam;
    
    string streamUrl;
    
    Size size;
    
    bool tryResetConnection = false;
    

    
    //TODO: Remove these as they are not going to be used going on:
    
    bool isPlaying = true;
    
    bool capture = true;
    

    
    //SECRET FEATURES:
    
    bool detect = false;
    

    

    
public:
    
    Camera(string url, int width = 480, int height = 240, bool detect_=false);
    
    bool stream();
    
    void setReconnectable(bool newReconStatus);
    
    void addListener(FrameListener* client);
    
    vector<bool> getState();    // Returns current state: vector[0] stream state; vector[1] stream state; TODO: Remove this as this is no longer should control behaviour
    
    void killStream();
    
    bool getReconnectable();
    
};
    

    
</bool></ctime></thread></algorithm></sstream></string></map></fstream></vector></iostream>

    Camera.cpp

    #include "Camera.h"
    

    

    
Camera::Camera(string url, int width, int height, bool detect_) // Default 240p
    
{
    
    streamUrl = url; // Prepare url
    
    size = Size(width, height);
    
    detect = detect_;
    

    
}
    

    
void Camera::addListener(FrameListener* client) {
    
    clients.push_back(client);
    
}
    

    

    
/*
    
                TEST CAMERAS(Paste into cameras.dViewer):
    
                {"id":"96a73796-c129-46fc-9c01-40acd8ed7122","ip":"176.57.73.231","password":"null","username":"null"},
    
                {"id":"96a73796-c129-46fc-9c01-40acd8ed7122","ip":"176.57.73.231","password":"null","username":"null"},
    
                {"id":"96a73796-c129-46fc-9c01-40acd8ed7144","ip":"172.20.101.13","password":"admin","username":"root"}
    
                {"id":"96a73796-c129-46fc-9c01-40acd8ed7144","ip":"172.20.101.13","password":"admin","username":"root"}
    

    
*/
    

    

    

    
bool Camera::stream() {
    
    /* This function is meant to run on a separate thread and fill up the buffer independantly of
    
    main stream thread */
    
    //cv::setNumThreads(100);
    
    /* Rules for these slightly changed! */
    
    Mat pre;  // Grab initial undoctored frame
    
    //pre = Mat::zeros(size, CV_8UC1);
    
    Mat frame; // Final modified frame
    
    frame = Mat::zeros(size, CV_8UC1);
    
    if (!pre.isContinuous()) pre = pre.clone();
    

    
    ipCam.open(streamUrl, CAP_FFMPEG);
    

    
    while (ipCam.isOpened() &amp;&amp; capture) {
    
        // If camera is opened wel need to capture and process the frame
    
        try {
    
            auto start = std::chrono::system_clock::now();
    

    
            ipCam >> pre;
    

    
            if (pre.empty()) {
    
                /* Check for blank frame, return error if there is a blank frame*/
    
                cerr &lt;&lt; id &lt;&lt; ": ERROR! blank frame grabbed\n";
    
                for (FrameListener* i : clients) {
    
                    i->onNotification(1); // Notify clients about this shit
    
                }
    
                break;
    
            }
    

    
            else {
    
                // Only continue if frame not empty
    

    
                if (pre.cols != size.width &amp;&amp; pre.rows != size.height) {
    
                    resize(pre, frame, size);
    
                    pre.release();
    
                }
    
                else {
    
                    frame = pre;
    
                }
    

    
                auto end = std::chrono::system_clock::now();
    
                std::time_t ts = std::chrono::system_clock::to_time_t(end);
    
                dPacket* pack = new dPacket{ id,&amp;frame};
    
                for (auto i : clients) {
    
                    i->onPNewFrame(pack);
    
                }
    
                frame.release();
    
                delete pack;
    
            }
    
        }
    

    
        catch (int e) {
    
            cout &lt;&lt; endl &lt;&lt; "-----Exception during capture process! CODE " &lt;&lt; e &lt;&lt; endl;
    
        }
    
        // End camera manipulations
    
    }
    

    
    cout &lt;&lt; "Camera timed out, or connection is closed..." &lt;&lt; endl;
    
    if (tryResetConnection) {
    
        cout &lt;&lt; "Reconnection flag is set, retrying after 3 seconds..." &lt;&lt; endl;
    
        for (FrameListener* i : clients) {
    
            i->onNotification(-1); // Notify clients about this shit
    
        }
    
        this_thread::sleep_for(chrono::milliseconds(3000));
    
        stream();
    
    }
    

    
    return true;
    
}
    

    

    
void Camera::killStream(){
    
    tryResetConnection = false;
    
    capture = false;
    
    ipCam.release();
    
}
    

    
void Camera::setReconnectable(bool reconFlag) {
    
    tryResetConnection = reconFlag;
    
}
    

    
bool Camera::getReconnectable() {
    
    return tryResetConnection;
    
}
    

    
vector<bool> Camera::getState() {
    
    vector<bool> states;
    
    states.push_back(isPlaying);
    
    states.push_back(ipCam.isOpened());
    
    return states;
    
}
    

    

    

    
</bool></bool>

    GLWidget.h :

    #ifndef GLWIDGET_H
    
#define GLWIDGET_H
    

    
#include <qopenglwidget>
    
#include <qmouseevent>
    
#include "FrameListener.h"
    
#include "Camera.h"
    
#include "FrameListener.h"
    
#include 
    
#include "Camera.h"
    
#include "CamUtils.h"
    
#include 
    
#include "dPacket.h"
    
#include <chrono>
    
#include <ctime>
    
#include 
    
#include "FullScreenVideo.h"
    
#include <qmovie>
    
#include "helper.h"
    
#include <iostream>
    
#include <qpainter>
    
#include <qtimer>
    

    
class Helper;
    

    
class GLWidget : public QOpenGLWidget, public FrameListener
    
{
    
    Q_OBJECT
    

    
public:
    
    GLWidget(std::string camId, CamUtils *cUtils, int width, int height, bool denyFullScreen_ = false, bool detectFlag_=false, QWidget* parent = nullptr);
    
    void killStream();
    
    ~GLWidget();
    

    
public slots:
    
    void animate();
    
    void setBufferEnabled(bool setState);
    
    void setCameraRetryConnection(bool setState);
    
    void GLUpdate();            // Call to update the widget
    
    void onRightClickMenu(const QPoint&amp; point);
    

    
protected:
    
    void paintEvent(QPaintEvent* event) override;
    
    void onPNewFrame(dPacket* frame);
    
    void onNotification(int alert_code);
    

    

    
private:
    
    // Objects and resourses
    
    Helper* helper;
    
    Camera* cam;
    
    CamUtils* camUtils;
    
    QTimer* timer; // Keep track of update
    
    QPixmap lastImage;
    
    QMovie* connMov;
    
    QMovie* test;
    

    
    QPixmap logo;
    

    
    // Control fields
    
    int width;
    
    int height;
    
    int camUtilsAddr;
    
    int elapsed;
    
    std::thread* camThread;
    
    std::string camId;
    
    bool denyFullScreen = false;
    
    bool playing = true;
    
    bool streaming = true;
    
    bool debug = false;
    
    bool connecting = true;
    
    int lastFlag = 0;
    

    

    
    // Debug fields
    
    std::chrono::high_resolution_clock::time_point lastFrameAt;
    
    std::chrono::high_resolution_clock::time_point now;
    
    std::chrono::duration<double> painTime; // time took to draw last frame
    

    
    //Buffer stuff
    
    std::queue<qpixmap> buffer;
    
    bool bufferEnabled = false;
    
    bool initialBuffer = false;
    
    bool buffering = true;
    
    bool frameProcessing = false;
    

    

    

    
    //Functions
    
    QImage toQImageFromPMat(cv::Mat* inFrame);
    
    void mousePressEvent(QMouseEvent* event) override;
    
    void drawImageGLLatest(QPainter* painter, QPaintEvent* event, int elapsed);
    
    void drawOnPaused(QPainter* painter, QPaintEvent* event, int elapsed);
    
    void drawOnStatus(int statusFlag, QPainter* painter, QPaintEvent* event, int elapsed);
    
};
    

    
#endif
    

    
</qpixmap></double></qtimer></qpainter></iostream></qmovie></ctime></chrono></qmouseevent></qopenglwidget>

    GLWidget.cpp :

    #include "glwidget.h"
    
#include <future>
    

    

    
FullScreenVideo* fullScreen;
    

    
GLWidget::GLWidget(std::string camId_, CamUtils* cUtils, int width_, int height_,  bool denyFullScreen_, bool detectFlag_, QWidget* parent)
    
    : QOpenGLWidget(parent), helper(helper)
    
{
    
    cout &lt;&lt; "Player for CAMERA " &lt;&lt; camId_ &lt;&lt; endl;
    

    
    /* Underlying properties */
    
    camUtils = cUtils;
    
    cout &lt;&lt; "GLWidget Incoming CamUtils addr " &lt;&lt; camUtils &lt;&lt; endl;
    
    cout &lt;&lt; "GLWidget Set CamUtils addr " &lt;&lt; camUtils &lt;&lt; endl;
    
    camId = camId_;
    
    elapsed = 0;
    
    width = width_ + 5;
    
    height = height_ + 5;
    
    helper = new Helper();
    
    setFixedSize(width, height);
    
    denyFullScreen = denyFullScreen_;
    

    
    /* Camera capture thread */
    
    cam = new Camera(camUtils->getCameraStreamURL(camId), width_, height_, detectFlag_);
    
    cam->addListener(this);
    

    
    /* Sync states */
    
    vector<bool> initState = cam->getState();
    
    playing = initState[0];
    
    streaming = initState[1];
    
    cout &lt;&lt; "Initial states: " &lt;&lt; playing &lt;&lt; " " &lt;&lt; streaming &lt;&lt; endl;
    
    camThread = new std::thread(&amp;Camera::stream, cam);
    
    cout &lt;&lt; "================================================" &lt;&lt; endl;
    

    
    // Right click set up
    
    setContextMenuPolicy(Qt::CustomContextMenu);
    

    

    
    /* Loading gif */
    
    connMov = new QMovie("establishingConnection.gif");
    
    connMov->start();
    
    QString url = R"(RLC-logo.png)";
    
    logo = QPixmap(url);
    
    QTimer* timer = new QTimer(this);
    
    connect(timer, SIGNAL(timeout()), this, SLOT(GLUpdate()));
    
    timer->start(1000/30);
    
    playing = true;
    

    
}
    

    
/* SYSTEM */
    
void GLWidget::animate()
    
{
    
    elapsed = (elapsed + qobject_cast(sender())->interval()) % 1000;
    
    std::cout &lt;&lt; elapsed &lt;&lt; "\n";
    
}
    

    

    
void GLWidget::GLUpdate() {
    
    /* Process descisions before update call */
    
    if (bufferEnabled) {
    
        /* Process buffer before update */
    
        now = chrono::high_resolution_clock::now();
    
        std::chrono::duration timeSinceLastUpdate = now - lastFrameAt;
    
        if (timeSinceLastUpdate.count() > 25) {
    
            if (buffer.size() > 1 &amp;&amp; playing) {
    
                lastImage.swap(buffer.front());
    
                buffer.pop();
    
                lastFrameAt = chrono::high_resolution_clock::now();
    
            }
    
        }
    
        //update(); // Update
    
    }
    
    else {
    
        /* No buffer */
    
    }
    
    repaint();
    
}
    

    

    
/* EVENTS */
    
void GLWidget::onRightClickMenu(const QPoint&amp; point) {
    
    cout &lt;&lt; "Right click request got" &lt;&lt; endl;
    

    
    QPoint globPos = this->mapToGlobal(point);
    
    QMenu myMenu;
    

    
    if (!denyFullScreen) {
    
        myMenu.addAction("Open Full Screen");
    
    }
    
    myMenu.addAction("Toggle Debug Info");
    

    

    
    QAction* selected = myMenu.exec(globPos);
    

    
    if (selected) {
    
        string optiontxt = selected->text().toStdString();
    

    
        if (optiontxt == "Open Full Screen") {
    
            cout &lt;&lt; "Chose to open full screen of " &lt;&lt; camId &lt;&lt; endl;
    
            fullScreen = new FullScreenVideo(bufferEnabled, this);
    
            fullScreen->setUpView(camUtils, camId);
    
            fullScreen->show();
    
            playing = false;
    
        }
    

    
        if (optiontxt == "Toggle Debug Info") {
    
            cout &lt;&lt; "Chose to toggle debug of " &lt;&lt; camId &lt;&lt; endl;
    
            debug = !debug;
    
        }
    
    }
    
    else {
    
        cout &lt;&lt; "Chose nothing!" &lt;&lt; endl;
    
    }
    

    

    
}
    

    

    

    
void GLWidget::onPNewFrame(dPacket* inPack) {
    
    lastFlag = 0;
    

    
    if (bufferEnabled) {
    
        buffer.push(QPixmap::fromImage(toQImageFromPMat(inPack->frame)));
    
    }
    
    else {
    
        if (playing) {
    
            /* Only process if this widget is playing */
    
            frameProcessing = true;
    
            lastImage.convertFromImage(toQImageFromPMat(inPack->frame));
    
            frameProcessing = false;
    
        }
    
    }
    

    
    if (lastFlag != -1 &amp;&amp; !lastImage.isNull()) {
    
        connecting = false;
    
    }
    
    else {
    
        connecting = true;
    
    }
    
}
    

    

    
void GLWidget::onNotification(int alert) {
    
    lastFlag = alert;   
    
}
    

    

    
/* Paint events*/
    

    

    
void GLWidget::paintEvent(QPaintEvent* event)
    
{
    
    QPainter painter(this);
    

    
        if (lastFlag != 0 || connecting) {
    
            drawOnStatus(lastFlag, &amp;painter, event, elapsed);
    
        }
    
        else {
    

    
            /* Actual frame drawing */
    
            if (playing) {
    
                if (!frameProcessing) {
    
                    drawImageGLLatest(&amp;painter, event, elapsed);
    
                }
    
            }
    
            else {
    
                drawOnPaused(&amp;painter, event, elapsed);
    
            }
    
        }
    
    painter.end();
    

    
}
    

    

    
/* DRAWING STUFF */
    

    
void GLWidget::drawOnStatus(int statusFlag, QPainter* bgPaint, QPaintEvent* event, int elapsed) {
    

    
    QString str;
    
    QFont font("times", 15);
    
    bgPaint->eraseRect(QRect(0, 0, width, height));
    
    if (!lastImage.isNull()) {
    
        bgPaint->drawPixmap(QRect(0, 0, width, height), lastImage);
    
    }
    
    /* Test background painting */
    
    if (connecting) {
    
        string k = "Connecting to " + camUtils->getIp(camId);
    
        str.append(k.c_str());
    
    }
    
    else {
    
        switch (statusFlag) {
    
        case 1:
    
            str = "Blank frame received...";
    
            break;
    

    
        case -1:
    
            if (cam->getReconnectable()) {
    
                str = "Connection lost, will try to reconnect.";
    
                bgPaint->setOpacity(0.3);
    
            }
    
            else {
    
                str = "Connection lost...";
    
                bgPaint->setOpacity(0.3);
    
            }
    

    
            break;
    
        }
    
    }
    

    
    bgPaint->drawPixmap(QRect(0, 0, width, height), QPixmap::fromImage(connMov->currentImage()));
    
    bgPaint->setPen(Qt::red);
    
    bgPaint->setFont(font);
    
    QFontMetrics fm(font);
    
    const QRect kek(0, 0, fm.width(str), fm.height());
    
    QRect bound;
    
    bgPaint->setOpacity(1);
    
    bgPaint->drawText(bgPaint->viewport().width()/2 - kek.width()/2, bgPaint->viewport().height()/2 - kek.height(), str);
    

    
    bgPaint->drawPixmap(bgPaint->viewport().width() / 2 - logo.width()/2, height - logo.width() - 15, logo);
    

    
}
    

    

    

    
void GLWidget::drawOnPaused(QPainter* painter, QPaintEvent* event, int elapsed) {
    
    painter->eraseRect(0, 0, width, height);
    
    QFont font = painter->font();
    
    font.setPointSize(18);
    
    painter->setPen(Qt::red);
    
    QFontMetrics fm(font);
    
    QString str("Paused");
    
    painter->drawPixmap(QRect(0, 0, width, height),lastImage);
    
    painter->drawText(QPoint(painter->viewport().width() - fm.width(str), 50), str);
    

    
    if (debug) {
    
        QFont font = painter->font();
    
        font.setPointSize(25);
    
        painter->setPen(Qt::red);
    
        string camMess = "CAMID: " + camId;
    
        QString mess(camMess.c_str());
    
        string camIp = "IP: " + camUtils->getIp(camId);
    
        QString ipMess(camIp.c_str());
    
        QString bufferSize("Buffer size: " + QString::number(buffer.size()));
    
        QString lastFrameText("Last frame draw time: " + QString::number(painTime.count()) + "s");
    
        painter->drawText(QPoint(10, 50), mess);
    
        painter->drawText(QPoint(10, 60), ipMess);
    
        QString bufferState;
    
        if (bufferEnabled) {
    
            bufferState = QString("Experimental BUFFER is enabled!");
    
            QString currentBufferSize("Current buffer load: " + QString::number(buffer.size()));
    
            painter->drawText(QPoint(10, 80), currentBufferSize);
    
        }
    
        else {
    
            bufferState = QString("Experimental BUFFER is disabled!");
    
        }
    
        painter->drawText(QPoint(10, 70), bufferState);
    
        painter->drawText(QPoint(10, height - 25), lastFrameText);
    
    }
    
}
    

    

    
void GLWidget::drawImageGLLatest(QPainter* painter, QPaintEvent* event, int elapsed) {
    
    auto start = chrono::high_resolution_clock::now();
    
    painter->drawPixmap(QRect(0, 0, width, height), lastImage);
    
    if (debug) {
    
        QFont font = painter->font();
    
        font.setPointSize(25);
    
        painter->setPen(Qt::red);
    
        string camMess = "CAMID: " + camId;
    
        QString mess(camMess.c_str());
    
        string camIp = "IP: " + camUtils->getIp(camId);
    
        QString ipMess(camIp.c_str());
    
        QString bufferSize("Buffer size: " + QString::number(buffer.size()));
    
        QString lastFrameText("Last frame draw time: " + QString::number(painTime.count()) + "s");
    
        painter->drawText(QPoint(10, 50), mess);
    
        painter->drawText(QPoint(10, 60), ipMess);
    
        QString bufferState;
    
        if(bufferEnabled){
    
            bufferState = QString("Experimental BUFFER is enabled!");
    
            QString currentBufferSize("Current buffer load: " + QString::number(buffer.size()));
    
            painter->drawText(QPoint(10,80), currentBufferSize);
    
        }
    
        else {
    
            bufferState = QString("Experimental BUFFER is disabled!");
    
            QString currentBufferSize("Current buffer load: " + QString::number(buffer.size()));
    
            painter->drawText(QPoint(10, 80), currentBufferSize);
    
        }
    
        painter->drawText(QPoint(10, 70), bufferState);
    
        painter->drawText(QPoint(10, height - 25), lastFrameText);
    

    
    }
    
    auto end = chrono::high_resolution_clock::now();
    
    painTime = end - start;
    
}
    

    

    

    
/* END DRAWING STUFF */
    

    

    

    
/* UI EVENTS */
    

    
void GLWidget::mousePressEvent(QMouseEvent* e) {
    

    
    if (e->button() == Qt::LeftButton) {
    
        if (fullScreen == nullptr || !fullScreen->isVisible()) { // Do not unpause if window is opened
    
            playing = !playing;
    
        }
    
    }
    

    
    if (e->button() == Qt::RightButton) {
    
        onRightClickMenu(e->pos());
    
    }
    
}
    

    

    

    
/* Utilities */
    
QImage GLWidget::toQImageFromPMat(cv::Mat* mat) {
    

    

    

    
    return QImage(mat->data, mat->cols, mat->rows, QImage::Format_RGB888).rgbSwapped();
    

    

    

    
}
    

    
/* State control */
    

    
void GLWidget::killStream() {
    
    cam->killStream();
    
    camThread->join();
    
}
    

    
void GLWidget::setBufferEnabled(bool newBufferState) {
    
    cout &lt;&lt; "Player: " &lt;&lt; camId &lt;&lt; ", buffer state updated: " &lt;&lt; newBufferState &lt;&lt; endl;
    
    bufferEnabled = newBufferState;
    
    buffer.empty();
    
}
    

    
void GLWidget::setCameraRetryConnection(bool newState) {
    
    cam->setReconnectable(newState);
    
}
    

    
/* Destruction */
    
GLWidget::~GLWidget() {
    
    cam->killStream();
    
    camThread->join();
    
}
    
</bool></future>

    CamUtils.h :

    #pragma once
    
#include <iostream>
    
#include <vector>
    
#include <fstream>
    
#include <map>
    
#include <string>
    
#include <sstream>
    
#include <algorithm>
    
#include <nlohmann></nlohmann>json.hpp>
    

    
using namespace std;
    
using json = nlohmann::json;
    

    
class CamUtils
    
{
    
private:
    

    
    string camDb = "cameras.dViewer";
    
    map> cameraList; // Legacy
    
    json cameras;
    
    ofstream dbFile;
    
    bool dbExists(); // Always hard coded
    

    
    /* Old IMPLEMENTATION */
    
    void writeLineToDb_(const string&amp; content, bool append = false);
    
    void loadCameras_();
    

    
    /* JSON based */
    
    void loadCameras();
    

    
public:
    
    CamUtils();
    
    string generateRandomString(size_t length);
    
    string getCameraStreamURL(string cameraId) const;
    
    string saveCamera(string ip, string username, string pass); // Return generated id
    
    vector<string> listAllCameraIds();
    
    string getIp(string cameraId);
    
};
    

    

    
</string></algorithm></sstream></string></map></fstream></vector></iostream>

    CamUtils.cpp :

    #include "CamUtils.h"
    
#pragma comment(lib, "rpcrt4.lib")  // UuidCreate - Minimum supported OS Win 2000
    
#include 
    
#include <iostream>
    

    
CamUtils::CamUtils()
    
{
    
    if (!dbExists()) {
    
        ofstream dbFile;
    
        dbFile.open(camDb);
    
        cameras["cameras"] = json::array();
    
        dbFile &lt;&lt; cameras &lt;&lt; std::endl;
    
        dbFile.close();
    

    
    }
    
    else {
    
        loadCameras();
    
    }
    
}
    

    

    

    

    
vector<string> CamUtils::listAllCameraIds() {
    
    vector<string> ids;
    
    cout &lt;&lt; "IN LIST " &lt;&lt; endl;
    
    for (auto&amp; cam : cameras["cameras"]) {
    
        ids.push_back(cam["id"].get<string>());
    
        //cout &lt;&lt; cam["id"].get<string>() &lt;&lt; std::endl;
    
    }
    
    return ids;
    
}
    

    
string CamUtils::getIp(string id) {
    
    vector<string> camDetails = cameraList[id];
    
    string ip = "NO IP WILL DISPLAYED UNTIL I FIGURE OUT A BUG";
    
    for (auto&amp; cam : cameras["cameras"]) {
    
        if (id == cam["id"]) {
    
            ip = cam["ip"].get<string>();
    
        }
    
    }
    

    
    return ip;
    
}
    

    
string CamUtils::getCameraStreamURL(string id) const {
    
    string url = "err"; // err is the default, it will be overwritten in case id is found, dont forget to check for it
    

    
    for (auto&amp; cam : cameras["cameras"]) {
    
        if (id == cam["id"]) {
    
            if (cam["username"].get<string>() == "null") {
    
                url = "rtsp://" + cam["ip"].get<string>() + ":554/axis-media/media.amp?tcp";
    
            }
    
            else {
    
                url = "rtsp://" + cam["username"].get<string>() + ":" + cam["password"].get<string>() + "@" + cam["ip"].get<string>() + ":554/axis-media/media.amp?streamprofile=720_30";
    
            }
    
        }
    
    }
    

    
    return url;  // Dont forget to check for err when using this shit
    
}
    

    

    
string CamUtils::saveCamera(string ip, string username, string password) {
    
    UUID uid;
    
    UuidCreate(&amp;uid);
    
    char* str;
    
    UuidToStringA(&amp;uid, (RPC_CSTR*)&amp;str);
    
    string id = str;
    
    cout &lt;&lt; "GEN: " &lt;&lt; id &lt;&lt; endl;
    
    json cam = json({}); //Create emtpy object
    
    cam["id"] = id;
    
    cam["ip"] = ip;
    
    cam["username"] = username;
    
    cam["password"] = password;
    
    cameras["cameras"].push_back(cam);
    
    std::ofstream out(camDb);
    
    out &lt;&lt; cameras &lt;&lt; std::endl;
    
    cout &lt;&lt; cameras["cameras"] &lt;&lt; endl;
    

    
    cout &lt;&lt; "Saved camera as " &lt;&lt; id &lt;&lt; endl;
    
    return id;
    
}
    

    

    
bool CamUtils::dbExists() {
    
    ifstream dbFile(camDb);
    
    return (bool)dbFile;
    
}
    

    

    

    

    

    
void CamUtils::loadCameras() {
    
    cout &lt;&lt; "Load call" &lt;&lt; endl;
    
    ifstream dbFile(camDb);
    
    string line;
    
    string wholeFile;
    

    
    while (std::getline(dbFile, line)) {
    
        cout &lt;&lt; line &lt;&lt; endl;
    
        wholeFile += line;
    
    }
    
    try {
    
        cameras = json::parse(wholeFile);
    
        //cout &lt;&lt; cameras["cameras"] &lt;&lt; endl;
    

    
    }
    
    catch (exception e) {
    
        cout &lt;&lt; e.what() &lt;&lt; endl;
    
    }
    
    dbFile.close();
    
}
    

    

    

    

    

    

    

    

    

    

    
/*
    
    LEGACY CODE, TO BE REMOVED!
    

    
*/
    

    

    

    
void CamUtils::loadCameras_() {
    
    /* 
    
        LEGACY CODE:
    
        This used to be the way to load cameras, but I moved on to JSON based configuration so this is no longer needed and will be removed soon
    
    */
    

    
    ifstream dbFile(camDb);
    
    string line;
    
    while (std::getline(dbFile, line)) {
    
        /*
    
            This function load camera data to the map:
    
            The order MUST be the following: 0:ID, 1:IP, 2:USERNAME, 3:PASSWORD.
    
            Always delimited with | no spaces between!
    
        */
    
        if (!line.empty()) {
    
            stringstream ss(line);
    
            string item;
    
            vector<string> splitString;
    

    
            while (std::getline(ss, item, '|')) {
    
                splitString.push_back(item);
    
            }
    
            if (splitString.size() > 0) {
    
                /* Dont even parse if the program didnt split right*/
    
                //cout &lt;&lt; "Split string: " &lt;&lt; splitString.size() &lt;&lt; "\n";
    
                for (int i = 0; i &lt; (splitString.size()); i++) cameraList[splitString[0]].push_back(splitString[i]);
    
            }
    
        }
    
    }
    
}
    

    

    

    
void CamUtils::writeLineToDb_(const string &amp; content, bool append) {
    
    ofstream dbFile;
    
    cout &lt;&lt; "Creating?";
    
    if (append) {
    
        dbFile.open(camDb, ios_base::app);
    
    }
    
    else {
    
        dbFile.open(camDb);
    
    }
    

    
    dbFile &lt;&lt; content.c_str() &lt;&lt; "\r\n";
    
    dbFile.flush();
    
}
    

    
/* JSON Reworx */
    

    

    

    

    
string CamUtils::generateRandomString(size_t length)
    
{
    
    const char* charmap = "ABCDEFGHIJKLMNOPQRSTUVWXYZ";
    
    const size_t charmapLength = strlen(charmap);
    
    auto generator = [&amp;]() { return charmap[rand() % charmapLength]; };
    
    string result;
    
    result.reserve(length);
    
    generate_n(back_inserter(result), length, generator);
    
    return result;
    
}
    
</string></string></string></string></string></string></string></string></string></string></string></string></iostream>

    End of example

    How would I go about decreasing CPU usage when dealing with large amount of streams ?

  • How to verify user permissions – Introducing the Piwik Platform

    9 novembre 2014, par Thomas Steur — Development

    This is the next post of our blog series where we introduce the capabilities of the Piwik platform (our previous post was How to make your plugin multilingual). This time you’ll learn how to verify user permissions. For this tutorial you will need to have basic knowledge of PHP and the Piwik platform.

    When should a plugin verify permissions ?

    Usually you want to do this before executing any action – such as deleting or fetching data – and before rendering any sensitive information that should not be accessible by everyone. For instance in an API method or Controller action. You sometimes also need to verify permissions before registering menu items or widgets.

    How does Piwik’s user management work ?

    It is quite simple as it only differentiates between a few roles : View permission, Admin permission and Super User permission. If you manage multiple websites with Piwik a user can be assigned to different roles as a user might have no permission for some websites but view or admin permission for another set of websites.

    Worth mentioning is that roles inherit from each other. This means the role admin automatically includes the role view and a super user automatically covers the view and admin role.

    Getting started

    In this post, we assume that you have already set up your development environment and created a plugin. If not, visit the Piwik Developer Zone where you’ll find the tutorial Setting up Piwik and other Guides that help you to develop a plugin.

    Verifying user permissions

    To protect your data the platform offers many convenient methods in the \Piwik\Piwik class. There you will find methods that either start with check, is or has. While methods that start with check throw an exception in case a condition is not met, the other methods return a boolean true or false.

    Use methods that throw an exception if you want to stop any further execution in case a user does not have an appropriate role. The platform will catch the exception and display an error message or ask the user to log in.

    1. public function deleteAllMessages()
      2. 

    2. {
      3. 

    3.     // delete messages only if user has super user access, otherwise show an error message
      4. 

    4.     Piwik::checkUserSuperUserAccess();
      5. 

    5.  
      6. 

    6.     $this-&gt;getModel()-&gt;deleteAllMessages();
      7. 

    7. }
      8. 

    Télécharger

    Use methods that return a boolean for instance when registering menu items or widgets.

    1. public function configureAdminMenu(MenuAdmin $menu)
      2. 

    2. {
      3. 

    3.     if (Piwik::hasUserSuperUserAccess()) {
      4. 

    4.         $menu-&gt;addPlatformItem('Plugins', $this-&gt;urlForDefaultAction());
      5. 

    5.     }
      6. 

    6. }
      7. 

    Télécharger

    It is important to be aware that just because the menu item won’t be displayed in the UI a user can still open the registered URL manually. Therefore you have to check for permissions in the actual controller action as well.

    View permission

    A user having a view permission should be only able to view reports but not make any changes apart from his personal settings. The methods that end with UserHasSomeViewAccess make sure a user has at least view permission for one website whereas the methods *UserHasViewAccess($idSites = array(1,2,3)) check whether a user has view access for all of the given websites.

    1. Piwik::checkUserHasSomeViewAccess();
      2. 

    2.  
      3. 

    3. Piwik::checkUserHasViewAccess($idSites = array(1,2,3));
      4. 

    Télécharger

    As a plugin developer you would usually use the latter example to verify the permissions for specific websites. Use the first example in case you develop something like an “All Websites Dashboard” where you only want to make sure the user has a view permission for at least one website.

    Admin permission

    A user having an admin permission cannot only view reports but also change website related settings. The methods to check for this role are similar to the ones before, just swap the term View with Admin.

    1. Piwik::checkUserHasSomeAdminAccess();
      2. 

    2.  
      3. 

    3. Piwik::checkUserHasAdminAccess($idSites = array(1,2,3));
      4. 

    Télécharger

    Super user permission

    A user having the super user permission is allowed to access all of the data stored in Piwik and change any settings. To check if a user has this role use one of the methods that end with UserSuperUserAccess.

    Piwik::checkUserHasSuperUserAccess();

    As a plugin developer you would check for this permission for instance in places where your plugin shows an activity log over all users or where it offers the possibility to change any system wide settings.

    Getting information about the currently logged in user

    Sometimes you might want to know which user is currently logged in. This can be useful if you want to persist user related information in the database or if you want to send an email to the currently logged in user. You can easily get this information by calling the following methods :

    1. $login = Piwik::getCurrentUserLogin()
      2. 

    2. $email = Piwik::getCurrentUserEmail()
      3. 

    Télécharger

    Advanced features

    Of course there is more that you can do. For instance you can verify whether a user is an anonymous user or whether a user has a specific role. You can also perform any operation in the context of a super user even if the current user does not have this role. Would you like to know more about those features ? Check out the Piwik class reference, the Security guide and the Manage Users user guide.

    If you have any feedback regarding our APIs or our guides in the Developer Zone feel free to send it to us.

  • Evolution #3973 : Brancher inc/distant recuperer_url() sur une librairie récente

    20 février 2019, par Eric Camus

    Bonjour,
    Suite à un changement de machine pour nos SPIP (de WIMP vers LAMP (centos)) de nombreux flux RSS ne fonctionnaient plus, la cause : la fonction ’recuperer_url’ !!!.
    J’ai donc réécrit le corps de cette fonction avec la biblio PHP CURL a partir du code dans SPIP 3.2.0 (je sais que je suis en retard d’une version).
    Je vous le livre comme je viens de le finir après un léger debug.

    1. <span class="CodeRay"><span class="keyword">function</span> <span class="function">recuperer_url</span>(<span class="local-variable">$url</span>, <span class="local-variable">$options</span> = <span class="predefined">array</span>()) {
      2. 

    2.     <span class="local-variable">$default</span> = <span class="predefined">array</span>(
      3. 

    3.         <span class="string"><span class="delimiter">'</span><span class="content">transcoder</span><span class="delimiter">'</span></span> => <span class="predefined-constant">false</span>,
      4. 

    4.         <span class="string"><span class="delimiter">'</span><span class="content">methode</span><span class="delimiter">'</span></span> => <span class="string"><span class="delimiter">'</span><span class="content">GET</span><span class="delimiter">'</span></span>,
      5. 

    5.         <span class="string"><span class="delimiter">'</span><span class="content">taille_max</span><span class="delimiter">'</span></span> => <span class="predefined-constant">null</span>,
      6. 

    6.         <span class="string"><span class="delimiter">'</span><span class="content">datas</span><span class="delimiter">'</span></span> => <span class="string"><span class="delimiter">'</span><span class="delimiter">'</span></span>,
      7. 

    7.         <span class="string"><span class="delimiter">'</span><span class="content">boundary</span><span class="delimiter">'</span></span> => <span class="string"><span class="delimiter">'</span><span class="delimiter">'</span></span>,
      8. 

    8.         <span class="string"><span class="delimiter">'</span><span class="content">refuser_gz</span><span class="delimiter">'</span></span> => <span class="predefined-constant">false</span>,
      9. 

    9.         <span class="string"><span class="delimiter">'</span><span class="content">if_modified_since</span><span class="delimiter">'</span></span> => <span class="integer">0</span>,
      10. 

    10.         <span class="string"><span class="delimiter">'</span><span class="content">uri_referer</span><span class="delimiter">'</span></span> => <span class="string"><span class="delimiter">'</span><span class="delimiter">'</span></span>,
      11. 

    11.         <span class="string"><span class="delimiter">'</span><span class="content">file</span><span class="delimiter">'</span></span> => <span class="string"><span class="delimiter">'</span><span class="delimiter">'</span></span>,
      12. 

    12.         <span class="string"><span class="delimiter">'</span><span class="content">follow_location</span><span class="delimiter">'</span></span> => <span class="integer">10</span>,
      13. 

    13.         <span class="string"><span class="delimiter">'</span><span class="content">version_http</span><span class="delimiter">'</span></span> => _INC_DISTANT_VERSION_HTTP,
      14. 

    14.     );
      15. 

    15.     <span class="local-variable">$options</span> = <span class="predefined">array_merge</span>(<span class="local-variable">$default</span>, <span class="local-variable">$options</span>);
      16. 

    16.     <span class="comment">// copier directement dans un fichier ?</span>
      17. 

    17.     <span class="local-variable">$copy</span> = <span class="local-variable">$options</span>[<span class="string"><span class="delimiter">'</span><span class="content">file</span><span class="delimiter">'</span></span>];
      18. 

    18.  
      19. 

    19.     <span class="keyword">if</span> (<span class="local-variable">$options</span>[<span class="string"><span class="delimiter">'</span><span class="content">methode</span><span class="delimiter">'</span></span>] == <span class="string"><span class="delimiter">'</span><span class="content">HEAD</span><span class="delimiter">'</span></span>) {
      20. 

    20.         <span class="local-variable">$options</span>[<span class="string"><span class="delimiter">'</span><span class="content">taille_max</span><span class="delimiter">'</span></span>] = <span class="integer">0</span>;
      21. 

    21.     }
      22. 

    22.     <span class="keyword">if</span> (<span class="predefined">is_null</span>(<span class="local-variable">$options</span>[<span class="string"><span class="delimiter">'</span><span class="content">taille_max</span><span class="delimiter">'</span></span>])) {
      23. 

    23.         <span class="local-variable">$options</span>[<span class="string"><span class="delimiter">'</span><span class="content">taille_max</span><span class="delimiter">'</span></span>] = <span class="local-variable">$copy</span> ? _COPIE_LOCALE_MAX_SIZE : _INC_DISTANT_MAX_SIZE;
      24. 

    24.     }
      25. 

    25.  
      26. 

    26.     <span class="comment">// Accepter les URLs au format feed:// ou qui ont oublie le http:// ou les urls relatives au protocole</span>
      27. 

    27.     <span class="local-variable">$url</span> = <span class="predefined">preg_replace</span>(<span class="string"><span class="delimiter">'</span><span class="content">,^feed://,i</span><span class="delimiter">'</span></span>, <span class="string"><span class="delimiter">'</span><span class="content">http://</span><span class="delimiter">'</span></span>, <span class="local-variable">$url</span>);
      28. 

    28.     <span class="keyword">if</span> (!tester_url_absolue(<span class="local-variable">$url</span>)) {
      29. 

    29.         <span class="local-variable">$url</span> = <span class="string"><span class="delimiter">'</span><span class="content">http://</span><span class="delimiter">'</span></span> . <span class="local-variable">$url</span>;
      30. 

    30.     } <span class="keyword">elseif</span> (<span class="predefined">strncmp</span>(<span class="local-variable">$url</span>, <span class="string"><span class="delimiter">'</span><span class="content">//</span><span class="delimiter">'</span></span>, <span class="integer">2</span>) == <span class="integer">0</span>) {
      31. 

    31.         <span class="local-variable">$url</span> = <span class="string"><span class="delimiter">'</span><span class="content">http:</span><span class="delimiter">'</span></span> . <span class="local-variable">$url</span>;
      32. 

    32.     }
      33. 

    33.  
      34. 

    34.     <span class="local-variable">$url</span> = url_to_ascii(<span class="local-variable">$url</span>);
      35. 

    35.  
      36. 

    36.     <span class="local-variable">$result</span> = <span class="predefined">array</span>(
      37. 

    37.         <span class="string"><span class="delimiter">'</span><span class="content">status</span><span class="delimiter">'</span></span> => <span class="integer">0</span>,
      38. 

    38.         <span class="string"><span class="delimiter">'</span><span class="content">headers</span><span class="delimiter">'</span></span> => <span class="string"><span class="delimiter">'</span><span class="delimiter">'</span></span>,
      39. 

    39.         <span class="string"><span class="delimiter">'</span><span class="content">page</span><span class="delimiter">'</span></span> => <span class="string"><span class="delimiter">'</span><span class="delimiter">'</span></span>,
      40. 

    40.         <span class="string"><span class="delimiter">'</span><span class="content">length</span><span class="delimiter">'</span></span> => <span class="integer">0</span>,
      41. 

    41.         <span class="string"><span class="delimiter">'</span><span class="content">last_modified</span><span class="delimiter">'</span></span> => <span class="string"><span class="delimiter">'</span><span class="delimiter">'</span></span>,
      42. 

    42.         <span class="string"><span class="delimiter">'</span><span class="content">location</span><span class="delimiter">'</span></span> => <span class="string"><span class="delimiter">'</span><span class="delimiter">'</span></span>,
      43. 

    43.         <span class="string"><span class="delimiter">'</span><span class="content">url</span><span class="delimiter">'</span></span> => <span class="local-variable">$url</span>
      44. 

    44.     );
      45. 

    45.  
      46. 

    46.     <span class="local-variable">$pCurl</span>=curl_init(<span class="local-variable">$url</span>);
      47. 

    47.     curl_setopt(<span class="local-variable">$pCurl</span>,<span class="constant">CURLOPT_HTTP_VERSION</span>,<span class="constant">CURL_HTTP_VERSION_1_1</span>);
      48. 

    48.     curl_setopt(<span class="local-variable">$pCurl</span>,<span class="constant">CURLOPT_SSL_VERIFYPEER</span>,<span class="predefined-constant">false</span>);
      49. 

    49.     curl_setopt(<span class="local-variable">$pCurl</span>,<span class="constant">CURLOPT_RETURNTRANSFER</span>,<span class="predefined-constant">true</span>);
      50. 

    50.     curl_setopt(<span class="local-variable">$pCurl</span>,<span class="constant">CURLOPT_FOLLOWLOCATION</span>,<span class="predefined-constant">true</span>);
      51. 

    51.     curl_setopt(<span class="local-variable">$pCurl</span>,<span class="constant">CURLOPT_TIMEOUT</span>,<span class="integer">30</span>);  <span class="comment">// timeout 30s</span>
      52. 

    52.     <span class="keyword">if</span> (!<span class="predefined">empty</span>(<span class="local-variable">$options</span>[<span class="string"><span class="delimiter">'</span><span class="content">datas</span><span class="delimiter">'</span></span>])) {  <span class="comment">// des datas</span>
      53. 

    53.         curl_setopt(<span class="local-variable">$pCurl</span>,<span class="constant">CURLOPT_POST</span>,<span class="predefined-constant">true</span>);
      54. 

    54.         curl_setopt(<span class="local-variable">$pCurl</span>,<span class="constant">CURLOPT_SAFE_UPLOAD</span>,<span class="predefined-constant">true</span>);
      55. 

    55.         curl_setopt(<span class="local-variable">$pCurl</span>,<span class="constant">CURLOPT_POSTFIELDS</span>,<span class="local-variable">$options</span>[<span class="string"><span class="delimiter">'</span><span class="content">datas</span><span class="delimiter">'</span></span>]);
      56. 

    56.         <span class="local-variable">$options</span>[<span class="string"><span class="delimiter">'</span><span class="content">methode</span><span class="delimiter">'</span></span>]=<span class="string"><span class="delimiter">'</span><span class="content">POST</span><span class="delimiter">'</span></span>;
      57. 

    57.     }
      58. 

    58.     <span class="keyword">if</span>(<span class="local-variable">$options</span>[<span class="string"><span class="delimiter">'</span><span class="content">methode</span><span class="delimiter">'</span></span>]==<span class="string"><span class="delimiter">'</span><span class="content">HEAD</span><span class="delimiter">'</span></span>) {
      59. 

    59.         curl_setopt(<span class="local-variable">$pCurl</span>,<span class="constant">CURLOPT_NOBODY</span>,<span class="predefined-constant">true</span>);
      60. 

    60.         <span class="local-variable">$options</span>[<span class="string"><span class="delimiter">'</span><span class="content">taille_max</span><span class="delimiter">'</span></span>]=<span class="integer">0</span>;  <span class="comment">// pas de taille</span>
      61. 

    61.         <span class="local-variable">$options</span>[<span class="string"><span class="delimiter">'</span><span class="content">if_modified_since</span><span class="delimiter">'</span></span>]=<span class="integer">0</span>;  <span class="comment">// pas de date de modif</span>
      62. 

    62.         <span class="local-variable">$copy</span>=<span class="string"><span class="delimiter">'</span><span class="delimiter">'</span></span>;  <span class="comment">// pas de copie dans fichier</span>
      63. 

    63.     }
      64. 

    64.     <span class="keyword">if</span>(<span class="local-variable">$options</span>[<span class="string"><span class="delimiter">'</span><span class="content">if_modified_since</span><span class="delimiter">'</span></span>]><span class="integer">0</span>) {
      65. 

    65.         curl_setopt(<span class="local-variable">$pCurl</span>,<span class="constant">CURLOPT_TIMEVALUE</span>,<span class="local-variable">$options</span>[<span class="string"><span class="delimiter">'</span><span class="content">if_modified_since</span><span class="delimiter">'</span></span>]);
      66. 

    66.     }
      67. 

    67.     <span class="keyword">if</span>(<span class="local-variable">$options</span>[<span class="string"><span class="delimiter">'</span><span class="content">taille_max</span><span class="delimiter">'</span></span>]><span class="integer">0</span>) {
      68. 

    68.         curl_setopt(<span class="local-variable">$pCurl</span>,<span class="constant">CURLOPT_RANGE</span>,<span class="string"><span class="delimiter">'</span><span class="content">0-</span><span class="delimiter">'</span></span>.<span class="local-variable">$options</span>[<span class="string"><span class="delimiter">'</span><span class="content">taille_max</span><span class="delimiter">'</span></span>]);
      69. 

    69.     }
      70. 

    70.     <span class="keyword">if</span>(<span class="local-variable">$options</span>[<span class="string"><span class="delimiter">'</span><span class="content">uri_referer</span><span class="delimiter">'</span></span>]) {
      71. 

    71.         curl_setopt(<span class="local-variable">$pCurl</span>,<span class="constant">CURLOPT_REFERER</span>,<span class="local-variable">$options</span>[<span class="string"><span class="delimiter">'</span><span class="content">uri_referer</span><span class="delimiter">'</span></span>]);
      72. 

    72.     }
      73. 

    73.     <span class="local-variable">$opt_header</span>=<span class="predefined-constant">true</span>;
      74. 

    74.     <span class="local-variable">$fheader</span>=<span class="string"><span class="delimiter">'</span><span class="delimiter">'</span></span>;  <span class="comment">// nom du fichier contenant le header</span>
      75. 

    75.     <span class="keyword">if</span>(<span class="local-variable">$copy</span>) {
      76. 

    76.         <span class="local-variable">$fc</span>=<span class="predefined">fopen</span>(<span class="local-variable">$copy</span>,<span class="string"><span class="delimiter">'</span><span class="content">w</span><span class="delimiter">'</span></span>);
      77. 

    77.         <span class="keyword">if</span>(<span class="local-variable">$fc</span>) {
      78. 

    78.             <span class="local-variable">$fheader</span>=_DIR_TMP.<span class="predefined">md5</span>(<span class="local-variable">$copy</span>).<span class="string"><span class="delimiter">'</span><span class="content">_head.txt</span><span class="delimiter">'</span></span>;
      79. 

    79.             <span class="local-variable">$fh</span>=<span class="predefined">fopen</span>(<span class="local-variable">$fheader</span>,<span class="string"><span class="delimiter">'</span><span class="content">w</span><span class="delimiter">'</span></span>);
      80. 

    80.             <span class="keyword">if</span>(<span class="local-variable">$fh</span>) {
      81. 

    81.                 curl_setopt(<span class="local-variable">$pCurl</span>,<span class="constant">CURLOPT_FILE</span>,<span class="local-variable">$fc</span>);
      82. 

    82.                 curl_setopt(<span class="local-variable">$pCurl</span>,<span class="constant">CURLOPT_WRITEHEADER</span>,<span class="local-variable">$fh</span>);
      83. 

    83.                 <span class="local-variable">$opt_header</span>=<span class="predefined-constant">false</span>;
      84. 

    84.             }
      85. 

    85.             <span class="keyword">else</span> {
      86. 

    86.                 <span class="predefined">fclose</span>(<span class="local-variable">$fc</span>);
      87. 

    87.             }
      88. 

    88.         }
      89. 

    89.     }
      90. 

    90.     curl_setopt(<span class="local-variable">$pCurl</span>,<span class="constant">CURLOPT_HEADER</span>,<span class="local-variable">$opt_header</span>);
      91. 

    91.     <span class="local-variable">$cont</span>=curl_exec(<span class="local-variable">$pCurl</span>);
      92. 

    92.     <span class="local-variable">$info</span>=curl_getinfo(<span class="local-variable">$pCurl</span>);
      93. 

    93.     curl_close(<span class="local-variable">$pCurl</span>);  <span class="comment">// fermer curl</span>
      94. 

    94.     <span class="keyword">if</span>(<span class="local-variable">$fc</span>) {
      95. 

    95.         <span class="predefined">fclose</span>(<span class="local-variable">$fc</span>);  <span class="comment">// fermer fichier</span>
      96. 

    96.         <span class="local-variable">$result</span>[<span class="string"><span class="delimiter">'</span><span class="content">file</span><span class="delimiter">'</span></span>]=<span class="local-variable">$copy</span>;
      97. 

    97.     }
      98. 

    98.     <span class="keyword">if</span>(<span class="local-variable">$fh</span>) {
      99. 

    99.         <span class="predefined">fclose</span>(<span class="local-variable">$fh</span>);
      100. 

    100.     }
      101. 

    101.     <span class="keyword">if</span>(<span class="local-variable">$cont</span>===<span class="predefined-constant">false</span>) {
      102. 

    102.         spip_log(<span class="string"><span class="delimiter">'</span><span class="content">ECHEC CURL </span><span class="delimiter">'</span></span>.<span class="local-variable">$url</span>,_LOG_ERREUR);
      103. 

    103.         <span class="keyword">if</span>(<span class="predefined">file_exists</span>(<span class="local-variable">$copy</span>)) <span class="predefined">unlink</span>(<span class="local-variable">$copy</span>);  <span class="comment">// suppr fichier sur erreur</span>
      104. 

    104.         <span class="keyword">if</span>(<span class="predefined">file_exists</span>(<span class="local-variable">$fheader</span>)) <span class="predefined">unlink</span>(<span class="local-variable">$fheader</span>);
      105. 

    105.         <span class="keyword">return</span> <span class="predefined-constant">false</span>;
      106. 

    106.     }
      107. 

    107.     <span class="comment">// on range le tout dans la var $result</span>
      108. 

    108.     <span class="local-variable">$body</span>=<span class="string"><span class="delimiter">'</span><span class="delimiter">'</span></span>;
      109. 

    109.     <span class="local-variable">$head</span>=<span class="string"><span class="delimiter">'</span><span class="delimiter">'</span></span>;
      110. 

    110.     <span class="keyword">if</span>(<span class="local-variable">$cont</span>!==<span class="predefined-constant">true</span>) {  <span class="comment">// cas de demande par fichier</span>
      111. 

    111.         <span class="keyword">if</span>(<span class="local-variable">$options</span>[<span class="string"><span class="delimiter">'</span><span class="content">methode</span><span class="delimiter">'</span></span>]==<span class="string"><span class="delimiter">'</span><span class="content">HEAD</span><span class="delimiter">'</span></span>) {
      112. 

    112.             <span class="local-variable">$head</span>=<span class="local-variable">$cont</span>;
      113. 

    113.         }
      114. 

    114.         <span class="keyword">else</span> {
      115. 

    115.             <span class="keyword">if</span>(<span class="predefined">isset</span>(<span class="local-variable">$info</span>[<span class="string"><span class="delimiter">'</span><span class="content">download_content_length</span><span class="delimiter">'</span></span>]) <span class="keyword">and</span> <span class="local-variable">$info</span>[<span class="string"><span class="delimiter">'</span><span class="content">download_content_length</span><span class="delimiter">'</span></span>]><span class="integer">0</span>) {
      116. 

    116.                 <span class="local-variable">$body</span>=<span class="predefined">substr</span>(<span class="local-variable">$cont</span>,-<span class="local-variable">$info</span>[<span class="string"><span class="delimiter">'</span><span class="content">download_content_length</span><span class="delimiter">'</span></span>]);
      117. 

    117.                 <span class="local-variable">$result</span>[<span class="string"><span class="delimiter">'</span><span class="content">length</span><span class="delimiter">'</span></span>]=<span class="local-variable">$info</span>[<span class="string"><span class="delimiter">'</span><span class="content">download_content_length</span><span class="delimiter">'</span></span>];
      118. 

    118.             }
      119. 

    119.             <span class="keyword">elseif</span>(<span class="predefined">isset</span>(<span class="local-variable">$info</span>[<span class="string"><span class="delimiter">'</span><span class="content">size_download</span><span class="delimiter">'</span></span>]) <span class="keyword">and</span> <span class="local-variable">$info</span>[<span class="string"><span class="delimiter">'</span><span class="content">size_download</span><span class="delimiter">'</span></span>]><span class="integer">0</span>) {
      120. 

    120.                 <span class="local-variable">$body</span>=<span class="predefined">substr</span>(<span class="local-variable">$cont</span>,-<span class="local-variable">$info</span>[<span class="string"><span class="delimiter">'</span><span class="content">size_download</span><span class="delimiter">'</span></span>]);
      121. 

    121.                 <span class="local-variable">$result</span>[<span class="string"><span class="delimiter">'</span><span class="content">length</span><span class="delimiter">'</span></span>]=<span class="local-variable">$info</span>[<span class="string"><span class="delimiter">'</span><span class="content">size_download</span><span class="delimiter">'</span></span>];
      122. 

    122.             }
      123. 

    123.             <span class="keyword">if</span>(<span class="predefined">isset</span>(<span class="local-variable">$info</span>[<span class="string"><span class="delimiter">'</span><span class="content">header_size</span><span class="delimiter">'</span></span>]) <span class="keyword">and</span> <span class="local-variable">$info</span>[<span class="string"><span class="delimiter">'</span><span class="content">header_size</span><span class="delimiter">'</span></span>]><span class="integer">0</span>) {
      124. 

    124.                 <span class="local-variable">$head</span>=<span class="predefined">substr</span>(<span class="local-variable">$cont</span>,<span class="integer">0</span>,<span class="local-variable">$info</span>[<span class="string"><span class="delimiter">'</span><span class="content">header_size</span><span class="delimiter">'</span></span>]);
      125. 

    125.                 <span class="keyword">if</span>(<span class="local-variable">$body</span>==<span class="string"><span class="delimiter">'</span><span class="delimiter">'</span></span>) {  <span class="comment">// cas ou download_content_length=-1 !!!!!!</span>
      126. 

    126.                     <span class="local-variable">$body</span>=<span class="predefined">substr</span>(<span class="local-variable">$cont</span>,<span class="local-variable">$info</span>[<span class="string"><span class="delimiter">'</span><span class="content">header_size</span><span class="delimiter">'</span></span>]);
      127. 

    127.                     <span class="local-variable">$result</span>[<span class="string"><span class="delimiter">'</span><span class="content">length</span><span class="delimiter">'</span></span>]=<span class="predefined">strlen</span>(<span class="local-variable">$body</span>);  <span class="comment">// pare absence</span>
      128. 

    128.                 }
      129. 

    129.             }
      130. 

    130.         }
      131. 

    131.     }
      132. 

    132.     <span class="keyword">if</span>(<span class="local-variable">$fheader</span> <span class="keyword">and</span> <span class="predefined">file_exists</span>(<span class="local-variable">$fheader</span>)) {  <span class="comment">// si un fichier de header est fait</span>
      133. 

    133.         <span class="local-variable">$head</span>=<span class="predefined">file_get_contents</span>(<span class="local-variable">$fheader</span>);
      134. 

    134.         <span class="predefined">unlink</span>(<span class="local-variable">$fheader</span>);
      135. 

    135.     }
      136. 

    136.     <span class="local-variable">$result</span>[<span class="string"><span class="delimiter">'</span><span class="content">status</span><span class="delimiter">'</span></span>]=<span class="local-variable">$info</span>[<span class="string"><span class="delimiter">'</span><span class="content">http_code</span><span class="delimiter">'</span></span>];
      137. 

    137.     <span class="keyword">if</span>(<span class="local-variable">$info</span>[<span class="string"><span class="delimiter">'</span><span class="content">http_code</span><span class="delimiter">'</span></span>]==<span class="integer">206</span>) <span class="local-variable">$result</span>[<span class="string"><span class="delimiter">'</span><span class="content">status</span><span class="delimiter">'</span></span>]=<span class="integer">200</span>;  <span class="comment">// SPIP refuse les partial content alors qu'il les demande</span>
      138. 

    138.     <span class="local-variable">$result</span>[<span class="string"><span class="delimiter">'</span><span class="content">headers</span><span class="delimiter">'</span></span>]=<span class="local-variable">$head</span>;
      139. 

    139.     <span class="local-variable">$result</span>[<span class="string"><span class="delimiter">'</span><span class="content">page</span><span class="delimiter">'</span></span>]=<span class="local-variable">$body</span>;
      140. 

    140.     <span class="keyword">if</span>(<span class="predefined">isset</span>(<span class="local-variable">$info</span>[<span class="string"><span class="delimiter">'</span><span class="content">download_content_length</span><span class="delimiter">'</span></span>]) <span class="keyword">and</span> <span class="local-variable">$info</span>[<span class="string"><span class="delimiter">'</span><span class="content">download_content_length</span><span class="delimiter">'</span></span>]><span class="integer">0</span>) {
      141. 

    141.         <span class="local-variable">$result</span>[<span class="string"><span class="delimiter">'</span><span class="content">length</span><span class="delimiter">'</span></span>]=<span class="local-variable">$info</span>[<span class="string"><span class="delimiter">'</span><span class="content">download_content_length</span><span class="delimiter">'</span></span>];
      142. 

    142.     }
      143. 

    143.     <span class="keyword">elseif</span>(<span class="predefined">isset</span>(<span class="local-variable">$info</span>[<span class="string"><span class="delimiter">'</span><span class="content">size_download</span><span class="delimiter">'</span></span>]) <span class="keyword">and</span> <span class="local-variable">$info</span>[<span class="string"><span class="delimiter">'</span><span class="content">size_download</span><span class="delimiter">'</span></span>]><span class="integer">0</span>) {
      144. 

    144.         <span class="local-variable">$result</span>[<span class="string"><span class="delimiter">'</span><span class="content">length</span><span class="delimiter">'</span></span>]=<span class="local-variable">$info</span>[<span class="string"><span class="delimiter">'</span><span class="content">size_download</span><span class="delimiter">'</span></span>];
      145. 

    145.     }
      146. 

    146.     <span class="keyword">if</span>(<span class="predefined">isset</span>(<span class="local-variable">$info</span>[<span class="string"><span class="delimiter">'</span><span class="content">url</span><span class="delimiter">'</span></span>]) <span class="keyword">and</span> <span class="local-variable">$info</span>[<span class="string"><span class="delimiter">'</span><span class="content">url</span><span class="delimiter">'</span></span>]!=<span class="local-variable">$url</span>) <span class="local-variable">$result</span>[<span class="string"><span class="delimiter">'</span><span class="content">location</span><span class="delimiter">'</span></span>]=<span class="local-variable">$info</span>[<span class="string"><span class="delimiter">'</span><span class="content">url</span><span class="delimiter">'</span></span>];
      147. 

    147.     <span class="keyword">if</span>(<span class="local-variable">$head</span>) {  <span class="comment">// analyse de head pour info</span>
      148. 

    148.         <span class="local-variable">$trouve</span>=<span class="predefined">array</span>(<span class="string"><span class="delimiter">'</span><span class="content">Content-Length</span><span class="delimiter">'</span></span>=><span class="string"><span class="delimiter">'</span><span class="content">length</span><span class="delimiter">'</span></span>,  <span class="comment">// texte avant : => cle du $result</span>
      149. 

    149.                      <span class="string"><span class="delimiter">'</span><span class="content">Last-Modified</span><span class="delimiter">'</span></span>=><span class="string"><span class="delimiter">'</span><span class="content">last_modified</span><span class="delimiter">'</span></span>,
      150. 

    150.                      <span class="string"><span class="delimiter">'</span><span class="content">Accept-Ranges</span><span class="delimiter">'</span></span>=><span class="string"><span class="delimiter">'</span><span class="content">range</span><span class="delimiter">'</span></span>);
      151. 

    151.         <span class="local-variable">$liste</span>=<span class="predefined">preg_split</span>(<span class="string"><span class="delimiter">'</span><span class="content">/[</span><span class="content">\r</span><span class="content">\n</span><span class="content">]+/</span><span class="delimiter">'</span></span>,<span class="local-variable">$head</span>,-<span class="integer">1</span>,<span class="constant">PREG_SPLIT_NO_EMPTY</span>);
      152. 

    152.         <span class="keyword">if</span>(<span class="predefined">is_array</span>(<span class="local-variable">$liste</span>)) {
      153. 

    153.             <span class="local-variable">$liste</span>=<span class="predefined">array_reverse</span>(<span class="local-variable">$liste</span>);
      154. 

    154.             <span class="keyword">foreach</span>(<span class="local-variable">$liste</span> <span class="keyword">as</span> <span class="local-variable">$l</span>) {  <span class="comment">// premier trouver donc dernier dans le head</span>
      155. 

    155.                 <span class="local-variable">$lt</span>=<span class="predefined">trim</span>(<span class="local-variable">$l</span>);
      156. 

    156.                 <span class="keyword">if</span>(<span class="predefined">strlen</span>(<span class="local-variable">$lt</span>)><span class="integer">5</span> <span class="keyword">and</span> <span class="predefined">substr</span>(<span class="local-variable">$lt</span>,<span class="integer">0</span>,<span class="integer">4</span>)==<span class="string"><span class="delimiter">'</span><span class="content">HTTP</span><span class="delimiter">'</span></span>) <span class="keyword">break</span>;  <span class="comment">// on arrete sur derniere entete HTTP ?</span>
      157. 

    157.                 <span class="local-variable">$item</span>=<span class="predefined">explode</span>(<span class="string"><span class="delimiter">'</span><span class="content">:</span><span class="delimiter">'</span></span>,<span class="local-variable">$lt</span>,<span class="integer">2</span>);
      158. 

    158.                 <span class="keyword">if</span>(<span class="predefined">isset</span>(<span class="local-variable">$item</span>[<span class="integer">0</span>]) <span class="keyword">and</span> <span class="predefined">isset</span>(<span class="local-variable">$trouve</span>[<span class="local-variable">$item</span>[<span class="integer">0</span>]])) {
      159. 

    159.                     <span class="local-variable">$result</span>[<span class="local-variable">$trouve</span>[<span class="local-variable">$item</span>[<span class="integer">0</span>]]]=<span class="predefined">trim</span>(<span class="local-variable">$item</span>[<span class="integer">1</span>]);
      160. 

    160.                     <span class="predefined">unset</span>(<span class="local-variable">$trouve</span>[<span class="local-variable">$item</span>[<span class="integer">0</span>]]);  <span class="comment">// plus d'autre a chercher</span>
      161. 

    161.                 }
      162. 

    162.             }
      163. 

    163.         }
      164. 

    164.         <span class="comment">// cas particuliers</span>
      165. 

    165.         <span class="keyword">if</span>(<span class="local-variable">$result</span>[<span class="string"><span class="delimiter">'</span><span class="content">last_modified</span><span class="delimiter">'</span></span>]) {
      166. 

    166.             <span class="local-variable">$val</span>=<span class="predefined">strtotime</span>(<span class="local-variable">$result</span>[<span class="string"><span class="delimiter">'</span><span class="content">last_modified</span><span class="delimiter">'</span></span>]);
      167. 

    167.             <span class="keyword">if</span>(<span class="local-variable">$val</span>===<span class="predefined-constant">false</span>) {
      168. 

    168.                 <span class="local-variable">$result</span>[<span class="string"><span class="delimiter">'</span><span class="content">last_modified</span><span class="delimiter">'</span></span>]=<span class="string"><span class="delimiter">'</span><span class="delimiter">'</span></span>;
      169. 

    169.             }
      170. 

    170.             <span class="keyword">else</span> {
      171. 

    171.                 <span class="local-variable">$result</span>[<span class="string"><span class="delimiter">'</span><span class="content">last_modified</span><span class="delimiter">'</span></span>]=<span class="local-variable">$val</span>;
      172. 

    172.             }
      173. 

    173.         }
      174. 

    174.     }
      175. 

    175.  
      176. 

    176.     <span class="comment">// Faut-il l'importer dans notre charset local ?</span>
      177. 

    177.     <span class="keyword">if</span> (<span class="local-variable">$options</span>[<span class="string"><span class="delimiter">'</span><span class="content">transcoder</span><span class="delimiter">'</span></span>]) {
      178. 

    178.         include_spip(<span class="string"><span class="delimiter">'</span><span class="content">inc/charsets</span><span class="delimiter">'</span></span>);
      179. 

    179.         <span class="local-variable">$result</span>[<span class="string"><span class="delimiter">'</span><span class="content">page</span><span class="delimiter">'</span></span>] = transcoder_page(<span class="local-variable">$result</span>[<span class="string"><span class="delimiter">'</span><span class="content">page</span><span class="delimiter">'</span></span>], <span class="local-variable">$result</span>[<span class="string"><span class="delimiter">'</span><span class="content">headers</span><span class="delimiter">'</span></span>]);
      180. 

    180.     }
      181. 

    181.  
      182. 

    182.     <span class="keyword">return</span> <span class="local-variable">$result</span>;
      183. 

    183. }
      184. 

    184. </span>
      185. 

    Télécharger

    Normalement, ce code doit être compatible avec l’ancienne fonction, il donne en plus en sortie [’range’] qui permet de savoir si un partial content peut être délivré.
    Il ne prend plus en compte les entrées [’refuser_gz’], [’version_http’] et [’boundary’] et l’entrée [’data’] doit être compatible avec celle de ’curl_setopt : CURLOPT_POSTFIELDS’.
    Si des gens veulent la tester et l’améliorer : bienvenue.

    Petit nota : SPIP laisse le fichier créer dans cette fonction ([’file’]) dans le tmp sans le détruire (version de base idem) : accumulation !

Navigation