Perl x Open Food Facts Hackathon: Paris, France - May 24-25 Learn more

ILYAZ / Bundle-OS2_default-1.07 / patches / diff_DBD-SQLite-0.28 

            

              
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142

              
--- ./os.c-pre  Sat Aug 23 02:46:54 2003
+++ ./os.c      Mon Oct  6 20:54:12 2003
@@ -61,6 +61,11 @@
 # define fcntl(A,B,C) 0
 #endif
  
+#ifdef __EMX__                 /* flock available via perl.h */
+#include "EXTERN.h"
+#include "perl.h"
+#endif
+
 /*
 ** Macros for performance tracing.  Normally turned off
 */
@@ -1119,6 +1124,68 @@ int isNT(void){
 # define FIRST_LOCKBYTE   (0xffffffff - N_LOCKBYTE)
 #endif
  
+enum sqlite_flock_t {
+    sqlite_flock_rlock,
+    sqlite_flock_wlock,
+    sqlite_flock_unlock
+};
+
+#if OS_UNIX
+#  if defined(HAVE_FLOCK) || defined(__EMX__)
+static int
+sqlite_flock(int fd, enum sqlite_flock_t how)
+{
+    int type;
+    int s, rc;
+
+    switch (how) {
+    case sqlite_flock_rlock:
+       type = LOCK_SH;
+       break;  
+    case sqlite_flock_wlock:
+       type = LOCK_EX;
+       break;
+    case sqlite_flock_unlock:
+       type = LOCK_UN;
+       break;
+    }
+    rc = flock(fd, type);
+    if( rc != 0 )
+      rc = (errno==EINVAL) ? SQLITE_NOLFS : SQLITE_BUSY;
+    else
+      rc = SQLITE_OK;
+    return rc;
+}
+#  else
+static int
+sqlite_flock(int fd, sqlite_flock_t how)
+{
+    struct flock lock;
+    int s, rc;
+
+    switch (how) {
+    case sqlite_flock_rlock:
+       lock.l_type = F_RDLCK;
+       break;  
+    case sqlite_flock_wlock:
+       lock.l_type = F_WRLCK;
+       break;
+    case sqlite_flock_unlock:
+       lock.l_type = F_UNLCK;
+       break;
+    }
+    lock.l_whence = SEEK_SET;
+    lock.l_start = lock.l_len = 0L;
+    s = fcntl(fd, F_SETLK, &lock);
+    if( s!=0 )
+      rc = (errno==EINVAL) ? SQLITE_NOLFS : SQLITE_BUSY;
+    else
+      rc = SQLITE_OK;
+    return rc;
+}
+#  endif
+#endif
+
 /*
 ** Change the status of the lock on the file "id" to be a readlock.
 ** If the file was write locked, then this reduces the lock to a read.
@@ -1139,16 +1206,8 @@ int sqliteOsReadLock(OsFile *id){
     }
     rc = SQLITE_OK;
   }else if( id->locked || id->pLock->cnt==0 ){
-    struct flock lock;
-    int s;
-    lock.l_type = F_RDLCK;
-    lock.l_whence = SEEK_SET;
-    lock.l_start = lock.l_len = 0L;
-    s = fcntl(id->fd, F_SETLK, &lock);
-    if( s!=0 ){
-      rc = (errno==EINVAL) ? SQLITE_NOLFS : SQLITE_BUSY;
-    }else{
-      rc = SQLITE_OK;
+    rc = sqlite_flock(id->fd, sqlite_flock_rlock);
+    if (rc == SQLITE_OK) {
       id->pLock->cnt = 1;
       id->locked = 1;
     }
@@ -1243,16 +1302,8 @@ int sqliteOsWriteLock(OsFile *id){
   int rc;
   sqliteOsEnterMutex();
   if( id->pLock->cnt==0 || (id->pLock->cnt==1 && id->locked==1) ){
-    struct flock lock;
-    int s;
-    lock.l_type = F_WRLCK;
-    lock.l_whence = SEEK_SET;
-    lock.l_start = lock.l_len = 0L;
-    s = fcntl(id->fd, F_SETLK, &lock);
-    if( s!=0 ){
-      rc = (errno==EINVAL) ? SQLITE_NOLFS : SQLITE_BUSY;
-    }else{
-      rc = SQLITE_OK;
+    rc = sqlite_flock(id->fd, sqlite_flock_wlock);
+    if (rc == SQLITE_OK) {
       id->pLock->cnt = -1;
       id->locked = 1;
     }
@@ -1355,18 +1406,9 @@ int sqliteOsUnlock(OsFile *id){
     id->pLock->cnt--;
     rc = SQLITE_OK;
   }else{
-    struct flock lock;
-    int s;
-    lock.l_type = F_UNLCK;
-    lock.l_whence = SEEK_SET;
-    lock.l_start = lock.l_len = 0L;
-    s = fcntl(id->fd, F_SETLK, &lock);
-    if( s!=0 ){
-      rc = (errno==EINVAL) ? SQLITE_NOLFS : SQLITE_BUSY;
-    }else{
-      rc = SQLITE_OK;
+    rc = sqlite_flock(id->fd, sqlite_flock_wlock);
+    if (rc == SQLITE_OK)
       id->pLock->cnt = 0;
-    }
   }
   sqliteOsLeaveMutex();
   id->locked = 0;