← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to plugin/pbms/src/cslib/CSS3Protocol.h

Merge Revision revid:marko.makela@oracle.com-20100505101406-u4low2x26q6itck0 from MySQL InnoDB

Original revid:marko.makela@oracle.com-20100505101406-u4low2x26q6itck0

Original Authors: Marko Mäkelä <marko.makela@oracle.com>
Original commit message:
Merge from mysql-5.1-innodb:

  ------------------------------------------------------------
  revno: 3446
  revision-id: marko.makela@oracle.com-20100505100507-6kcd2hf32hruxbv7
  parent: marko.makela@oracle.com-20100505095328-vetnl0flhmhao7p5
  committer: Marko Mäkelä <marko.makela@oracle.com>
  branch nick: 5.1-innodb
  timestamp: Wed 2010-05-05 13:05:07 +0300
  message:
    Add Valgrind diagnostics to track down Bug #38999.
  ------------------------------------------------------------

Show diffs side-by-side

added added

removed removed

Lines of Context:
plugin/pbms/src/cslib/CSS3Protocol.h
 
1
#ifndef __CSS3PROTOCOL_H__
 
2
#define __CSS3PROTOCOL_H__
 
3
/* Copyright (c) 2009 PrimeBase Technologies GmbH, Germany
 
4
 *
 
5
 * PrimeBase Media Stream for MySQL
 
6
 *
 
7
 * This program is free software; you can redistribute it and/or modify
 
8
 * it under the terms of the GNU General Public License as published by
 
9
 * the Free Software Foundation; either version 2 of the License, or
 
10
 * (at your option) any later version.
 
11
 *
 
12
 * This program is distributed in the hope that it will be useful,
 
13
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 
14
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 
15
 * GNU General Public License for more details.
 
16
 *
 
17
 * You should have received a copy of the GNU General Public License
 
18
 * along with this program; if not, write to the Free Software
 
19
 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
 
20
 *
 
21
 *  Created by Barry Leslie on 10/02/09.
 
22
 *
 
23
 */
 
24
 
 
25
#include "CSHTTPStream.h"
 
26
#include "CSMd5.h"
 
27
class S3ProtocolCon;
 
28
 
 
29
#define PUB_KEY_BIT             ((uint8_t)1)
 
30
#define PRIV_KEY_BIT    ((uint8_t)2)
 
31
#define SERVER_BIT              ((uint8_t)4)
 
32
 
 
33
 
 
34
typedef struct S3Range {
 
35
         off64_t startByte;
 
36
         off64_t endByte;
 
37
} S3RangeRec, *S3RangePtr;
 
38
 
 
39
class CSS3Protocol: public CSRefObject {
 
40
        private:
 
41
        
 
42
        CSStringBuffer *s3_server;
 
43
        
 
44
        CSString *s3_public_key;
 
45
        CSString *s3_private_key;
 
46
        
 
47
        uint8_t s3_ready; // A flag to indicate if the S3 protocol has been fully initialised.
 
48
        uint32_t s3_maxRetries; 
 
49
        uint32_t s3_sleepTime; 
 
50
        
 
51
        CSString *s3_getSignature(const char *verb, 
 
52
                                                                const char *md5, 
 
53
                                                                const char *content_type, 
 
54
                                                                const char *date, 
 
55
                                                                const char *bucket, 
 
56
                                                                const char *key,
 
57
                                                                CSString *headers = NULL 
 
58
                                                        );
 
59
                                                        
 
60
        public:
 
61
        CSS3Protocol();
 
62
                
 
63
        ~CSS3Protocol();
 
64
        
 
65
        void s3_setServer(const char *server_arg)
 
66
        {
 
67
                s3_server->setLength(0);
 
68
                if (server_arg && *server_arg) {
 
69
                        s3_ready |= SERVER_BIT;
 
70
                        
 
71
                        s3_server->append(server_arg);
 
72
                        if (server_arg[strlen(server_arg)-1] != '/')
 
73
                                s3_server->append("/");
 
74
                } else {
 
75
                        s3_ready ^= SERVER_BIT;
 
76
                }
 
77
        }
 
78
        const char *s3_getServer() { return s3_server->getCString();}
 
79
        
 
80
        void s3_setPublicKey(const char *key_arg) 
 
81
        {
 
82
                s3_public_key->release();
 
83
                s3_public_key = NULL;
 
84
                if (key_arg && *key_arg) {
 
85
                        s3_ready |= PUB_KEY_BIT;                                        
 
86
                        s3_public_key = CSString::newString(key_arg);
 
87
                } else {
 
88
                        s3_ready ^= PUB_KEY_BIT;
 
89
                }
 
90
        }
 
91
        const char *s3_getPublicKey() { return s3_public_key->getCString();}
 
92
        
 
93
        void s3_setPrivateKey(const char *key_arg)
 
94
        {
 
95
                s3_private_key->release();
 
96
                s3_private_key = NULL;
 
97
                if (key_arg && *key_arg) {
 
98
                        s3_ready |= PRIV_KEY_BIT;                                       
 
99
                        s3_private_key = CSString::newString(key_arg);
 
100
                } else {
 
101
                        s3_ready ^= PRIV_KEY_BIT;
 
102
                }
 
103
        }
 
104
 
 
105
        void s3_setMaxRetries(uint32_t retries){s3_maxRetries = retries;}
 
106
        void s3_setSleepTime(uint32_t nap_time){s3_sleepTime = nap_time;}
 
107
        
 
108
        const char *s3_getPrivateKey() { return s3_private_key->getCString();}
 
109
        
 
110
        bool s3_isReady() { return ((s3_ready & SERVER_BIT) && (s3_ready & PUB_KEY_BIT) && (s3_ready & PRIV_KEY_BIT));}
 
111
        
 
112
        // s3_getAuthorization() returns the S3 Authorization sting and the time on which it was based.
 
113
        CSString *s3_getAuthorization(const char *bucket, const char *key, const char *content_type, uint32_t *s3AuthorizationTime);
 
114
        
 
115
        CSVector *s3_send(CSInputStream *input, const char *bucket, const char *key, off64_t size, const char *content_type = NULL, Md5Digest *digest = NULL, const char *s3Authorization = NULL, time_t s3AuthorizationTime = 0);
 
116
 
 
117
        // s3_receive() returns false if the object was not found.
 
118
        // If 'output' is NULL then only the headers will be fetched.
 
119
        CSVector *s3_receive(CSOutputStream *output, const char *bucket, const char *key, bool *found, S3RangePtr range = NULL, time_t *last_modified = NULL);
 
120
 
 
121
        // s3_delete() returns false if the object was not found.
 
122
        bool s3_delete(const char *bucket, const char *key);
 
123
        
 
124
        void s3_copy(const char *dest_server, const char *dest_bucket, const char *dest_key, const char *src_bucket, const char *src_key);
 
125
        
 
126
        // s3_list() returns a CSString list if the keys in the bucket with the specified prefix.
 
127
        // The list size returned can be limited with the 'max' parameter. The value 0 indicates no max.
 
128
        CSVector *s3_list(const char *bucket, const char *key_prefix = NULL, uint32_t max = 0);
 
129
 
 
130
        CSString *s3_getDataURL(const char *bucket, const char *key, uint32_t keep_alive);
 
131
};
 
132
 
 
133
#endif //__CSS3PROTOCOL_H__